Skip to content

Share batch operation in restate #2199

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
yujonglee merged 15 commits into from
Dec 10, 2025
Merged

Share batch operation in restate #2199

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
15 commits
Select commit Hold shift + click to select a range
8cc3c99
chores
yujonglee Dec 9, 2025
5bef1ee
add db function
yujonglee Dec 10, 2025
98b943e
add start-trial route in apps/api
yujonglee Dec 10, 2025
5219c0a
update apps/desktop to support trial
yujonglee Dec 10, 2025
461f401
openapi stuffs for apps/api
yujonglee Dec 10, 2025
6eb5097
openapi client genertion
yujonglee Dec 10, 2025
49e8aa5
use rpc in apps/api
yujonglee Dec 10, 2025
893463b
rename stuff
yujonglee Dec 10, 2025
a7912a2
openapi stuff
yujonglee Dec 10, 2025
a705d7f
onboarding wip
yujonglee Dec 10, 2025
444c888
fix bearer case sensitive
yujonglee Dec 10, 2025
9a5dc5e
trial flow got it working in desktop
yujonglee Dec 10, 2025
73b007b
done
yujonglee Dec 10, 2025
c5ac509
Merge remote-tracking branch 'origin/main' into share-batch-restate
yujonglee Dec 10, 2025
bd3f01f
fix stuff
yujonglee Dec 10, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
209 changes: 206 additions & 3 deletions apps/api/openapi.gen.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@
"get": {
"responses": {
"200": {
"description": "-",
"description": "result",
"content": {
"application/json": {
"schema": {
Expand Down Expand Up @@ -222,6 +222,209 @@
}
}
},
"/file-transcription/start": {
"post": {
"responses": {
"200": {
"description": "Pipeline started",
"content": {
"application/json": {
"schema": {
"type": "object",
"properties": {
"pipelineId": {
"type": "string"
},
"invocationId": {
"type": "string"
}
},
"required": [
"pipelineId",
"invocationId"
],
"additionalProperties": false
}
}
}
},
"400": {
"description": "Invalid fileId"
},
"401": {
"description": "Unauthorized"
},
"500": {
"description": "Internal error"
}
},
"operationId": "postFile-transcriptionStart",
"tags": [
"private"
],
"parameters": [],
"security": [
{
"Bearer": []
}
],
"requestBody": {
"content": {
"application/json": {
"schema": {
"type": "object",
"properties": {
"fileId": {
"type": "string"
},
"pipelineId": {
"type": "string"
}
},
"required": [
"fileId"
],
"additionalProperties": false
}
}
}
}
}
},
"/file-transcription/status/{pipelineId}": {
"get": {
"responses": {
"200": {
"description": "Pipeline status",
"content": {
"application/json": {
"schema": {
"type": "object",
"properties": {
"status": {
"type": "string",
"enum": [
"QUEUED",
"TRANSCRIBING",
"TRANSCRIBED",
"LLM_RUNNING",
"DONE",
"ERROR"
]
},
"transcript": {
"type": "string"
},
"llmResult": {
"type": "string"
},
"error": {
"type": "string"
}
},
"required": [
"status"
],
"additionalProperties": false
}
}
}
},
"401": {
"description": "Unauthorized"
},
"500": {
"description": "Internal error"
}
},
"operationId": "getFile-transcriptionStatusByPipelineId",
"tags": [
"private"
],
"parameters": [
{
"in": "path",
"name": "pipelineId",
"schema": {
"type": "string"
},
"required": true
}
],
"security": [
{
"Bearer": []
}
]
}
},
"/file-transcription/result/{pipelineId}": {
"get": {
"responses": {
"200": {
"description": "Pipeline result",
"content": {
"application/json": {
"schema": {
"type": "object",
"properties": {
"status": {
"type": "string",
"enum": [
"QUEUED",
"TRANSCRIBING",
"TRANSCRIBED",
"LLM_RUNNING",
"DONE",
"ERROR"
]
},
"transcript": {
"type": "string"
},
"llmResult": {
"type": "string"
},
"error": {
"type": "string"
}
},
"required": [
"status"
],
"additionalProperties": false
}
}
}
},
"401": {
"description": "Unauthorized"
},
"500": {
"description": "Internal error"
}
},
"operationId": "getFile-transcriptionResultByPipelineId",
"tags": [
"private"
],
"parameters": [
{
"in": "path",
"name": "pipelineId",
"schema": {
"type": "string"
},
"required": true
}
],
"security": [
{
"Bearer": []
}
]
}
},
"/rpc/can-start-trial": {
"get": {
"responses": {
Expand Down Expand Up @@ -287,7 +490,7 @@
"post": {
"responses": {
"200": {
"description": "-",
"description": "result",
"content": {
"application/json": {
"schema": {
Expand Down Expand Up @@ -421,7 +624,7 @@
"post": {
"responses": {
"200": {
"description": "-",
"description": "result",
"content": {
"application/json": {
"schema": {
Expand Down
3 changes: 2 additions & 1 deletion apps/api/package.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,14 +3,15 @@
"private": true,
"type": "module",
"scripts": {
"dev": "dotenvx run --ignore MISSING_ENV_FILE -f ../../.env.supabase -f ../../.env.stripe -f .env -- bun --hot src/index.ts",
"dev": "dotenvx run --ignore MISSING_ENV_FILE -f ../../.env.supabase -f ../../.env.stripe -f ../../.env.restate -f .env -- bun --hot src/index.ts",
"stripe:migrate": "dotenvx run --ignore MISSING_ENV_FILE -f ../../.env.supabase -f ../../.env.stripe -f .env -- bun src/scripts/run-stripe-migrations.ts",
"openapi": "CI=true bun src/scripts/generate-openapi.ts",
"typecheck": "tsc --noEmit",
"test": "bun test"
},
"dependencies": {
"@hypr/api-client": "workspace:*",
"@restatedev/restate-sdk-clients": "^1.9.1",
"@hono/zod-validator": "^0.7.5",
"@posthog/ai": "^7.2.1",
"@scalar/hono-api-reference": "^0.5.184",
Expand Down
1 change: 1 addition & 0 deletions apps/api/src/env.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@ export const env = createEnv({
ASSEMBLYAI_API_KEY: z.string().min(1),
SONIOX_API_KEY: z.string().min(1),
POSTHOG_API_KEY: z.string().min(1),
RESTATE_INGRESS_URL: z.url(),
OVERRIDE_AUTH: z.string().optional(),
},
runtimeEnv: Bun.env,
Expand Down
1 change: 1 addition & 0 deletions apps/api/src/integration/index.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,3 +2,4 @@ export * from "./supabase";
export * from "./stripe";
export * from "./openrouter";
export * from "./posthog";
export * from "./restate";
12 changes: 12 additions & 0 deletions apps/api/src/integration/restate.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
import * as clients from "@restatedev/restate-sdk-clients";

import { env } from "../env";

let restateClientInstance: ReturnType<typeof clients.connect> | null = null;

export function getRestateClient() {
if (!restateClientInstance) {
restateClientInstance = clients.connect({ url: env.RESTATE_INGRESS_URL });
}
return restateClientInstance;
}
Loading
Loading