update example (#22)

restackio · Oct 31, 2024 · 32fe49a · 32fe49a
1 parent 022f181
commit 32fe49a
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 11 deletions.
diff --git a/examples/composio/package.json b/examples/composio/package.json
@@ -22,7 +22,7 @@
   },
   "dependencies": {
     "@restackio/ai": "^0.0.80",
-    "@restackio/integrations-composio": "^0.0.3",
+    "@restackio/integrations-composio": "^0.0.4",
     "@temporalio/workflow": "^1.11.2",
     "dotenv": "^16.4.5"
   },

diff --git a/examples/composio/pnpm-lock.yaml b/examples/composio/pnpm-lock.yaml
diff --git a/examples/composio/src/workflows/createCalendarEvent.ts b/examples/composio/src/workflows/createCalendarEvent.ts
@@ -1,4 +1,4 @@
-import { step } from "@restackio/ai/workflow";
+import { step, log } from "@restackio/ai/workflow";
 import * as composioFunctions from "@restackio/integrations-composio/functions";
 import { composioTaskQueue } from "@restackio/integrations-composio/taskQueue";
 
@@ -9,6 +9,20 @@ export async function createCalendarEventWorkflow({
   entityId: string;
   calendarInstruction: string;
 }) {
+  const connection = await step<typeof composioFunctions>({
+    taskQueue: composioTaskQueue,
+  }).initiateConnection({
+    entityId,
+    appName: "googlecalendar",
+  });
+
+  if (!connection.authenticated) {
+    log.info(
+      `Follow the link to authenticate with google calendar ${connection.redirectUrl}`
+    );
+    return connection;
+  }
+
   await step<typeof composioFunctions>({
     taskQueue: composioTaskQueue,
   }).createCalendarEvent({