mandatory client for services

restackio · Sep 12, 2024 · 270f867 · 270f867
1 parent 00a6012
commit 270f867
Show file tree

Hide file tree

Showing 16 changed files with 22 additions and 52 deletions.
diff --git a/azure-speech/package.json b/azure-speech/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@restackio/integrations-azurespeech",
-  "version": "0.0.4",
+  "version": "0.0.5",
   "main": "dist/service.js",
   "types": "dist/service.d.ts",
   "scripts": {

diff --git a/azure-speech/service.ts b/azure-speech/service.ts
@@ -12,20 +12,16 @@ export async function azureSpeechService({
     maxConcurrentFunctionRuns: 1,
   },
 }: {
-  client?: Restack;
+  client: Restack;
   options?: ServiceInput["options"];
 }) {
-  if (!client) {
-    client = new Restack();
-  }
-
   await client.startService({
     taskQueue: azureSpeechTaskQueue,
     functions: { azureSpeech },
     options,
   });
 }
 
-azureSpeechService({}).catch((err) => {
+azureSpeechService({ client: new Restack() }).catch((err) => {
   console.error("Error service:", err);
 });
diff --git a/cartesia/package.json b/cartesia/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@restackio/integrations-cartesia",
-  "version": "0.0.3",
+  "version": "0.0.4",
   "main": "dist/service.js",
   "types": "dist/service.d.ts",
   "scripts": {

diff --git a/cartesia/service.ts b/cartesia/service.ts
@@ -12,18 +12,16 @@ export async function cartesiaService({
     maxConcurrentFunctionRuns: 3,
   },
 }: {
-  client?: Restack;
+  client: Restack;
   options?: ServiceInput["options"];
 }) {
-  const restack = new Restack();
-
-  await restack.startService({
+  await client.startService({
     taskQueue: cartesiaTaskQueue,
     functions: { cartesiaTtsBytes },
     options,
   });
 }
 
-cartesiaService({}).catch((err) => {
+cartesiaService({ client: new Restack() }).catch((err) => {
   console.error("Error service:", err);
 });
diff --git a/deepgram/package.json b/deepgram/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@restackio/integrations-deepgram",
-  "version": "0.0.6",
+  "version": "0.0.7",
   "main": "dist/service.js",
   "types": "dist/service.d.ts",
   "scripts": {

diff --git a/deepgram/service.ts b/deepgram/service.ts
@@ -13,20 +13,16 @@ export async function deepgramService({
     maxConcurrentFunctionRuns: 100,
   },
 }: {
-  client?: Restack;
+  client: Restack;
   options?: ServiceInput["options"];
 }) {
-  if (!client) {
-    client = new Restack();
-  }
-
   await client.startService({
     taskQueue: deepgramTaskQueue,
     functions: { deepgramListen, deepgramSpeak },
     options,
   });
 }
 
-deepgramService({}).catch((err) => {
+deepgramService({ client: new Restack() }).catch((err) => {
   console.error("Error service:", err);
 });
diff --git a/elevenlabs/package.json b/elevenlabs/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@restackio/integrations-elevenlabs",
-  "version": "0.0.3",
+  "version": "0.0.4",
   "main": "dist/service.js",
   "types": "dist/service.d.ts",
   "scripts": {

diff --git a/elevenlabs/service.ts b/elevenlabs/service.ts
@@ -10,20 +10,16 @@ export async function elevenlabsService({
     maxConcurrentFunctionRuns: 2,
   },
 }: {
-  client?: Restack;
+  client: Restack;
   options?: ServiceInput["options"];
 }) {
-  if (!client) {
-    client = new Restack();
-  }
-
   await client.startService({
     taskQueue: elevenlabsTaskQueue,
     functions: { elevenlabsConvert },
     options,
   });
 }
 
-elevenlabsService({}).catch((err) => {
+elevenlabsService({ client: new Restack() }).catch((err) => {
   console.error("Error service:", err);
 });
diff --git a/fal/package.json b/fal/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@restackio/integrations-fal",
-  "version": "0.0.2",
+  "version": "0.0.3",
   "main": "dist/service.js",
   "types": "dist/service.d.ts",
   "scripts": {

diff --git a/fal/service.ts b/fal/service.ts
@@ -6,13 +6,9 @@ export async function falService({
   client,
   options,
 }: {
-  client?: Restack;
+  client: Restack;
   options?: ServiceInput["options"];
 }) {
-  if (!client) {
-    client = new Restack();
-  }
-
   await client.startService({
     taskQueue: falTaskQueue,
     functions: { falRun },

diff --git a/openai/package.json b/openai/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@restackio/integrations-openai",
-  "version": "0.0.17",
+  "version": "0.0.18",
   "main": "dist/service.js",
   "types": "dist/service.d.ts",
   "scripts": {

diff --git a/openai/service.ts b/openai/service.ts
@@ -14,13 +14,9 @@ export async function openaiService({
     rateLimit: rpmToSecond(5000),
   },
 }: {
-  client?: Restack;
+  client: Restack;
   options?: ServiceInput["options"];
 }) {
-  if (!client) {
-    client = new Restack();
-  }
-
   await client.startService({
     taskQueue: openaiTaskQueue,
     functions: { openaiChatCompletionsBase, openaiChatCompletionsStream },

diff --git a/twilio/package.json b/twilio/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@restackio/integrations-twilio",
-  "version": "0.0.3",
+  "version": "0.0.4",
   "main": "dist/service.js",
   "types": "dist/service.d.ts",
   "scripts": {

diff --git a/twilio/service.ts b/twilio/service.ts
@@ -10,20 +10,16 @@ export async function twilioService({
     rateLimit: 1,
   },
 }: {
-  client?: Restack;
+  client: Restack;
   options?: ServiceInput["options"];
 }) {
-  if (!client) {
-    client = new Restack();
-  }
-
   await client.startService({
     taskQueue: twilioTaskQueue,
     functions: { twilioCall },
     options,
   });
 }
 
-twilioService({}).catch((err) => {
+twilioService({ client: new Restack() }).catch((err) => {
   console.error("Error service:", err);
 });
diff --git a/websocket/package.json b/websocket/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@restackio/integrations-websocket",
-  "version": "0.0.10",
+  "version": "0.0.11",
   "main": "dist/service.js",
   "types": "dist/service.d.ts",
   "scripts": {

diff --git a/websocket/service.ts b/websocket/service.ts
@@ -6,13 +6,9 @@ export async function websocketService({
   client,
   options,
 }: {
-  client?: Restack;
+  client: Restack;
   options?: ServiceInput["options"];
 }) {
-  if (!client) {
-    client = new Restack();
-  }
-
   await client.startService({
     taskQueue: websocketTaskQueue,
     functions: { websocketListen, websocketSend },