apunkt/rowboat
1
0
Fork 0
mirror of https://github.com/rowboatlabs/rowboat.git synced 2026-06-03 19:25:19 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

housekeeping

Browse source
This commit is contained in:
Ramnique Singh 2025-08-18 06:33:03 +05:30
parent 580ecc7f98
commit 7458f5f58c
1 changed files with 9 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

20
apps/rowboat/app/lib/mongodb.ts
View file

@ -1,6 +1,5 @@
import { MongoClient } from "mongodb"; import { MongoClient } from "mongodb";
import { User } from "./types/types"; import { User } from "./types/types";
import { Workflow } from "./types/workflow_types";
import { TwilioConfig, TwilioInboundCall } from "./types/voice_types"; import { TwilioConfig, TwilioInboundCall } from "./types/voice_types";
import { z } from 'zod'; import { z } from 'zod';
import { apiV1 } from "rowboat-shared"; import { apiV1 } from "rowboat-shared";
@ -8,7 +7,6 @@ import { apiV1 } from "rowboat-shared";
const client = new MongoClient(process.env["MONGODB_CONNECTION_STRING"] || "mongodb://localhost:27017"); const client = new MongoClient(process.env["MONGODB_CONNECTION_STRING"] || "mongodb://localhost:27017");
export const db = client.db("rowboat"); export const db = client.db("rowboat");
export const agentWorkflowsCollection = db.collection<z.infer<typeof Workflow>>("agent_workflows");
export const chatsCollection = db.collection<z.infer<typeof apiV1.Chat>>("chats"); export const chatsCollection = db.collection<z.infer<typeof apiV1.Chat>>("chats");
export const chatMessagesCollection = db.collection<z.infer<typeof apiV1.ChatMessage>>("chat_messages"); export const chatMessagesCollection = db.collection<z.infer<typeof apiV1.ChatMessage>>("chat_messages");
export const twilioConfigsCollection = db.collection<z.infer<typeof TwilioConfig>>("twilio_configs"); export const twilioConfigsCollection = db.collection<z.infer<typeof TwilioConfig>>("twilio_configs");
@ -16,12 +14,12 @@ export const usersCollection = db.collection<z.infer<typeof User>>("users");
export const twilioInboundCallsCollection = db.collection<z.infer<typeof TwilioInboundCall>>("twilio_inbound_calls"); export const twilioInboundCallsCollection = db.collection<z.infer<typeof TwilioInboundCall>>("twilio_inbound_calls");
// Create indexes // Create indexes
twilioConfigsCollection.createIndexes([ // twilioConfigsCollection.createIndexes([
{ // {
key: { workflow_id: 1, status: 1 }, // key: { workflow_id: 1, status: 1 },
name: "workflow_status_idx", // name: "workflow_status_idx",
// This ensures only one active config per workflow // // This ensures only one active config per workflow
unique: true, // unique: true,
partialFilterExpression: { status: "active" } // partialFilterExpression: { status: "active" }
} // }
]); // ]);