Prototype of a Roomote tab (#147)

Co-authored-by: cte <[email protected]>
Co-authored-by: Roomote <[email protected]>
Co-authored-by: John Richmond <[email protected]>

Author: 4 people

.gitignore

@@ -26,4 +26,4 @@ Thumbs.db
 *.log
 
 # project mcp config
-.roo/mcp.json
+.roo/mcp.json

.roo/rules/rules.md

@@ -3,7 +3,6 @@
 ## Testing & Formatting
 
 - **Test**: `pnpm test` (runs all tests via Turbo)
-- **Test single file**: `pnpm test path/to/file.test.ts`
 - **Lint**: `pnpm lint` (ESLint with TypeScript support)
 - **Type check**: `pnpm check-types`
 - **Format**: Files are auto-formatted on commit via lint-staged

apps/roomote/package.json

@@ -13,8 +13,6 @@
     "controller:production": "dotenvx run -f ../../.env.production -- tsx src/lib/controller.ts",
     "worker": "dotenvx run -f ../../.env.development -- tsx src/lib/worker.ts",
     "worker:production": "dotenvx run -f ../../.env.production -- tsx src/lib/worker.ts",
-    "cli": "dotenvx run -f ../../.env.development -- tsx src/lib/cli.ts",
-    "cli:production": "dotenvx run -f ../../.env.production -- tsx src/lib/cli.ts",
     "clean": "rimraf .next .turbo"
   },
   "dependencies": {
@@ -24,7 +22,6 @@
     "@roo-code-cloud/job-auth": "workspace:^",
     "@roo-code/types": "^1.30.0",
     "bullmq": "^5.37.0",
-    "cmd-ts": "^0.13.0",
     "drizzle-orm": "^0.44.2",
     "execa": "^9.6.0",
     "ioredis": "^5.6.1",

apps/roomote/src/app/api/webhooks/github/handlers/__tests__/utils.test.ts

@@ -87,6 +87,7 @@ describe('GitHub Webhook Utils', () => {
     const mockJob = { id: 123 };
     const mockEnqueuedJob = { id: 'enqueued-123' };
     const mockCloudJobs = {};
+    const testOrgId = 'test-org-123';
 
     beforeEach(() => {
       mockDb.insert.mockReturnValue({
@@ -107,13 +108,14 @@ describe('GitHub Webhook Utils', () => {
         body: 'Test body',
       };
 
-      const result = await createAndEnqueueJob(type, payload);
+      const result = await createAndEnqueueJob(type, payload, testOrgId);
 
       expect(mockDb.insert).toHaveBeenCalledWith(mockCloudJobs);
       expect(mockEnqueue).toHaveBeenCalledWith({
         jobId: mockJob.id,
         type,
         payload,
+        orgId: testOrgId,
       });
       expect(result).toEqual({
         jobId: mockJob.id,
@@ -136,9 +138,9 @@ describe('GitHub Webhook Utils', () => {
         body: 'Test',
       };
 
-      await expect(createAndEnqueueJob(type, payload)).rejects.toThrow(
-        'Failed to create `cloudJobs` record.',
-      );
+      await expect(
+        createAndEnqueueJob(type, payload, testOrgId),
+      ).rejects.toThrow('Failed to create `cloudJobs` record.');
     });
 
     it('should throw error when enqueue fails to return job ID', async () => {
@@ -152,9 +154,9 @@ describe('GitHub Webhook Utils', () => {
         body: 'Test',
       };
 
-      await expect(createAndEnqueueJob(type, payload)).rejects.toThrow(
-        'Failed to get enqueued job ID.',
-      );
+      await expect(
+        createAndEnqueueJob(type, payload, testOrgId),
+      ).rejects.toThrow('Failed to get enqueued job ID.');
     });
 
     it('should throw error when enqueue returns undefined', async () => {
@@ -168,9 +170,9 @@ describe('GitHub Webhook Utils', () => {
         body: 'Test',
       };
 
-      await expect(createAndEnqueueJob(type, payload)).rejects.toThrow(
-        'Failed to get enqueued job ID.',
-      );
+      await expect(
+        createAndEnqueueJob(type, payload, testOrgId),
+      ).rejects.toThrow('Failed to get enqueued job ID.');
     });
 
     it('should handle different job types', async () => {
@@ -189,12 +191,13 @@ describe('GitHub Webhook Utils', () => {
         commentUrl: 'https://github.com/test/repo/issues/456#issuecomment-789',
       };
 
-      const result = await createAndEnqueueJob(type, payload);
+      const result = await createAndEnqueueJob(type, payload, testOrgId);
 
       expect(mockEnqueue).toHaveBeenCalledWith({
         jobId: mockJob.id,
         type,
         payload,
+        orgId: testOrgId,
       });
       expect(result).toEqual({
         jobId: mockJob.id,
@@ -213,7 +216,7 @@ describe('GitHub Webhook Utils', () => {
         body: 'Test',
       };
 
-      await createAndEnqueueJob(type, payload);
+      await createAndEnqueueJob(type, payload, testOrgId);
 
       expect(consoleSpy).toHaveBeenCalledWith(
         `🔗 Enqueued ${type} job (id: ${mockJob.id}) ->`,
@@ -236,9 +239,9 @@ describe('GitHub Webhook Utils', () => {
         body: 'Test',
       };
 
-      await expect(createAndEnqueueJob(type, payload)).rejects.toThrow(
-        'Database connection failed',
-      );
+      await expect(
+        createAndEnqueueJob(type, payload, testOrgId),
+      ).rejects.toThrow('Database connection failed');
     });
 
     it('should handle enqueue service errors', async () => {
@@ -252,9 +255,9 @@ describe('GitHub Webhook Utils', () => {
         body: 'Test',
       };
 
-      await expect(createAndEnqueueJob(type, payload)).rejects.toThrow(
-        'Queue service unavailable',
-      );
+      await expect(
+        createAndEnqueueJob(type, payload, testOrgId),
+      ).rejects.toThrow('Queue service unavailable');
     });
   });
 
@@ -362,6 +365,7 @@ describe('GitHub Webhook Utils', () => {
       // Test job creation in a realistic webhook scenario.
       const mockJob = { id: 456 };
       const mockEnqueuedJob = { id: 'job-456' };
+      const testOrgId = 'test-org-456';
 
       mockDb.insert.mockReturnValue({
         values: vi.fn().mockReturnValue({
@@ -371,12 +375,16 @@ describe('GitHub Webhook Utils', () => {
       mockEnqueue.mockResolvedValue(mockEnqueuedJob);
 
       // Create job after successful verification.
-      const result = await createAndEnqueueJob('github.issue.fix', {
-        repo: 'test/repo',
-        issue: 123,
-        title: 'Test issue',
-        body: 'Test issue body',
-      });
+      const result = await createAndEnqueueJob(
+        'github.issue.fix',
+        {
+          repo: 'test/repo',
+          issue: 123,
+          title: 'Test issue',
+          body: 'Test issue body',
+        },
+        testOrgId,
+      );
 
       expect(result).toEqual({
         jobId: mockJob.id,

apps/roomote/src/app/api/webhooks/github/handlers/utils.ts

@@ -1,10 +1,12 @@
 import { createHmac } from 'crypto';
+import { or, eq } from 'drizzle-orm';
 
 import {
   type JobType,
   type JobPayload,
   db,
   cloudJobs,
+  orgs,
 } from '@roo-code-cloud/db/server';
 
 import { enqueue } from '@/lib';
@@ -25,17 +27,38 @@ export function verifySignature(
 export async function createAndEnqueueJob<T extends JobType>(
   type: T,
   payload: JobPayload<T>,
+  orgId?: string,
 ): Promise<{ jobId: number; enqueuedJobId: string }> {
+  // @TODO: Require `orgId` to be specified.
+  const organizationId =
+    orgId ||
+    (
+      await db
+        .select({ id: orgs.id })
+        .from(orgs)
+        .where(or(eq(orgs.name, 'Roo Code'), eq(orgs.name, 'Roo Code / Dev')))
+        .limit(1)
+    )[0]?.id;
+
+  if (!organizationId) {
+    throw new Error('Organization ID is required for job creation.');
+  }
+
   const [job] = await db
     .insert(cloudJobs)
-    .values({ type, payload, status: 'pending' })
+    .values({ type, payload, status: 'pending', orgId: organizationId })
     .returning();
 
   if (!job) {
     throw new Error('Failed to create `cloudJobs` record.');
   }
 
-  const enqueuedJob = await enqueue({ jobId: job.id, type, payload });
+  const enqueuedJob = await enqueue({
+    jobId: job.id,
+    type,
+    payload,
+    orgId: organizationId,
+  });
   console.log(`🔗 Enqueued ${type} job (id: ${job.id}) ->`, payload);
 
   if (!enqueuedJob.id) {