feat: Expose on-demand sync via OpenAPI and add param for async

useVenice · Feb 18, 2024 · a0370e7 · a0370e7 · vercel · Feb 18, 2024
1 parent 442cd53
commit a0370e7
Show file tree

Hide file tree

Showing 8 changed files with 332 additions and 27 deletions.
diff --git a/apps/web/inngest/functions.ts b/apps/web/inngest/functions.ts
@@ -65,7 +65,7 @@ export const syncPipeline = inngest.createFunction(
         ...contextFactory.fromViewer({role: 'system'}),
         remoteResourceId: null,
       })
-      .syncPipeline([pipelineId, {}])
+      .syncPipeline({id: pipelineId})
     console.log('did sync pipeline', pipelineId)
     return pipelineId
   },
@@ -90,7 +90,7 @@ export const syncResource = inngest.createFunction(
           ...contextFactory.fromViewer({role: 'system'}),
           remoteResourceId: null,
         })
-        .syncResource([resourceId, {}])
+        .syncResource({id: resourceId})
 
       console.log('did sync pipeline', resourceId)
       return resourceId

diff --git a/apps/web/vcommands/vcommand-definitions.ts b/apps/web/vcommands/vcommand-definitions.ts
@@ -34,7 +34,7 @@ export const pipelineCommands = {
     icon: 'RefreshCw',
     execute: ({params: {pipeline}, ctx}) => {
       void ctx.withToast(() =>
-        ctx.trpcCtx.client.syncPipeline.mutate([pipeline.id, {}]),
+        ctx.trpcCtx.client.syncPipeline.mutate({id: pipeline.id}),
       )
     },
   }),
@@ -85,7 +85,7 @@ export const resourceCommands = {
     icon: 'RefreshCw',
     execute: ({params: {resource}, ctx}) => {
       void ctx.withToast(() =>
-        ctx.trpcCtx.client.syncResource.mutate([resource.id, {}]),
+        ctx.trpcCtx.client.syncResource.mutate({id: resource.id}),
       )
     },
   }),

diff --git a/kits/sdk/package.json b/kits/sdk/package.json
@@ -8,9 +8,9 @@
   "scripts": {
     "build": "tsc -p ./tsconfig.json",
     "clean": "rm -rf ./dist",
-    "generate": "pnpm generate:schema && pnpm generate:types",
-    "generate:schema": "NEXT_PUBLIC_SERVER_URL=https://app.venice.is npx tsx ../../apps/web/lib-server/appRouter.ts > ./venice.oas.json",
-    "generate:types": "openapi-typescript ./venice.oas.json --output ./venice.oas.d.ts",
+    "gen": "pnpm gen:schema && pnpm gen:types",
+    "gen:schema": "NEXT_PUBLIC_SERVER_URL=https://app.venice.is npx tsx ../../apps/web/lib-server/appRouter.ts > ./venice.oas.json",
+    "gen:types": "openapi-typescript ./venice.oas.json --output ./venice.oas.d.ts",
     "pub": "pnpm publish --no-git-checks --access public"
   },
   "dependencies": {

diff --git a/kits/sdk/venice.oas.d.ts b/kits/sdk/venice.oas.d.ts
diff --git a/kits/sdk/venice.oas.json b/kits/sdk/venice.oas.json