Merge pull request #89 from restackio/agentChat

Add agent chat

Author: aboutphilippe

agent_chat/.env.example

@@ -0,0 +1,10 @@
+
+# For inference
+RESTACK_API_KEY=
+
+# For Restack Cloud deployment
+RESTACK_ENGINE_ID=
+RESTACK_ENGINE_ADDRESS=
+RESTACK_ENGINE_API_KEY=
+RESTACK_ENGINE_API_ADDRESS=
+

agent_chat/Dockerfile

@@ -0,0 +1,55 @@
+# Build stage
+FROM node:20-bullseye AS builder
+
+WORKDIR /app
+
+# Install pnpm
+RUN npm install -g pnpm
+
+# Copy package files and env file if it exists
+COPY package*.json .env* ./
+
+# Copy package files
+COPY package*.json ./
+
+# Install dependencies including TypeScript
+RUN pnpm install
+RUN pnpm add -D typescript
+
+# Copy source code
+COPY . .
+
+# Build TypeScript code
+RUN pnpm run build
+
+# Production stage
+FROM node:20-bullseye
+
+WORKDIR /app
+
+# Install pnpm
+RUN npm install -g pnpm
+
+# Copy package files and built code
+COPY --from=builder /app/package*.json ./
+COPY --from=builder /app/dist ./dist
+
+# Install production dependencies only
+RUN pnpm install --prod
+
+# Define environment variables
+ARG RESTACK_ENGINE_ID
+ENV RESTACK_ENGINE_ID=${RESTACK_ENGINE_ID}
+
+ARG RESTACK_ENGINE_ADDRESS 
+ENV RESTACK_ENGINE_ADDRESS=${RESTACK_ENGINE_ADDRESS}
+
+ARG RESTACK_ENGINE_API_KEY
+ENV RESTACK_ENGINE_API_KEY=${RESTACK_ENGINE_API_KEY}
+
+ARG RESTACK_ENGINE_API_ADDRESS
+ENV RESTACK_ENGINE_API_ADDRESS=${RESTACK_ENGINE_API_ADDRESS}
+
+EXPOSE 3000
+
+CMD ["node", "dist/services.js"]

agent_chat/chat_post.png

@@ -0,0 +1,41 @@
+import { client } from "./src/client";
+
+export type EventInput = {
+  workflowId: string;
+  runId: string;
+};
+
+async function eventWorkflow(input: EventInput) {
+  try {
+    await client.sendWorkflowEvent({
+      event: {
+        name: "message",
+        input: { content: "Telle ma another one" },
+      },
+      workflow: {
+        workflowId: input.workflowId,
+        runId: input.runId,
+      },
+    });
+
+    await client.sendWorkflowEvent({
+      event: {
+        name: "end",
+      },
+      workflow: {
+        workflowId: input.workflowId,
+        runId: input.runId,
+      },
+    });
+
+    process.exit(0); // Exit the process successfully
+  } catch (error) {
+    console.error("Error sending event to workflow:", error);
+    process.exit(1); // Exit the process with an error code
+  }
+}
+
+eventWorkflow({
+  workflowId: "your-workflow-id",
+  runId: "your-run-id",
+});