diff --git a/database/common.ts b/database/common.ts index ee736c3..4ed97b2 100644 --- a/database/common.ts +++ b/database/common.ts @@ -25,48 +25,3 @@ export type FactTrigger = { scopeConversationId: string; createdAt?: string; }; - -export type User = Omit & { - id: string; -}; - -export interface Entity { - construct: (data: T) => T; - create: (data: Omit) => Promise; - createMany: (data: Omit[]) => Promise; - findAll: (user?: { userId: string }) => Promise; - findById: (id: string) => Promise; - update: (id: string, data: Partial) => Promise; - delete: (id: string) => Promise; -} - -export interface ConversationEntity extends Entity { - fetchMessages: (conversationId: string) => Promise>; -} - -export interface FactEntity extends Entity { - findByConversationId: (conversationId: string) => Promise>; -} - -export interface MessageEntity extends Entity { - findByConversationId: ( - conversationId: string - ) => Promise>; -} - -export type FactTriggerEntity = Entity & { - findByFactId: (factId: string) => Promise>; - findByConversationId: (conversationId: string) => Promise>; -}; - -export type UserEntity = Entity & { - findByEmailAddress: (emailAddress: string) => Promise; -}; - -export interface ApplicationDatabase { - conversations: ConversationEntity; - factTriggers: FactTriggerEntity; - facts: FactEntity; - messages: MessageEntity; - users: UserEntity; -} diff --git a/database/postgres.ts b/database/postgres.ts index 4ea1d1b..181927a 100644 --- a/database/postgres.ts +++ b/database/postgres.ts @@ -3,14 +3,6 @@ import { neon } from "@neondatabase/serverless"; import { Kysely /*PostgresDialect*/ } from "kysely"; import { NeonDialect } from "kysely-neon"; import type Database from "./generated/Database"; -import type { - ConversationEntity, - FactEntity, - FactTriggerEntity, - MessageEntity, - UserEntity, -} from "./common.ts"; -import type { CommittedMessage } from "../types"; // export const pool = new Pool({ // connectionString: env.POSTGRES_CONNECTION_STRING as string,