Add bridge migrations

apps/bridge-frontend/app/_lib/database.ts

@@ -16,7 +16,7 @@ export const addGraphileJob = async (jobInfo: GraphileJob) => {
   // await db.insertInto("graphile_worker.jobs").values(jobInfo).execute();
 };
 
-interface Database {
+export interface Database {
   User: {
     id: string;
     name: string | null;
@@ -93,6 +93,7 @@ export const db = new KyselyAuth<Database>({
     pool: new Pool({
       host: process.env.DATABASE_HOST,
       database: process.env.DATABASE_NAME,
+      port: parseInt(process.env.DATABASE_PORT!),
       user: process.env.DATABASE_USER,
       password: process.env.DATABASE_PASSWORD,
     }),

apps/bridge-frontend/database/migrate.ts

@@ -0,0 +1,93 @@
+import * as path from "path";
+import { fileURLToPath } from "url";
+import { promises as fs } from "fs";
+import {
+  Kysely,
+  Migrator,
+  MigrationResult,
+  FileMigrationProvider,
+  PostgresDialect,
+  CamelCasePlugin,
+} from "kysely";
+import pkg from "pg";
+const { Pool } = pkg;
+import * as dotenv from "dotenv";
+
+interface Database {}
+
+export const migrate = async (arg: string) => {
+  const __filename = fileURLToPath(import.meta.url);
+  const __dirname = path.dirname(__filename);
+  if (process.env.NODE_ENV !== "production") {
+    dotenv.config({ path: path.join(__dirname, "../.env.local") });
+  }
+  const db = new Kysely<Database>({
+    dialect: new PostgresDialect({
+      pool: new Pool({
+        host: process.env.DATABASE_HOST,
+        database: process.env.DATABASE_NAME,
+        port: parseInt(process.env.DATABASE_PORT!),
+        user: process.env.DATABASE_USER,
+        password: process.env.DATABASE_PASSWORD,
+      }),
+    }),
+    plugins: [new CamelCasePlugin()],
+  });
+  const migrator = new Migrator({
+    db,
+    provider: new FileMigrationProvider({
+      fs,
+      path,
+      migrationFolder: path.join(__dirname, "migrations"),
+    }),
+  });
+
+  let error = null;
+  let results: MigrationResult[] = [];
+
+  if (arg === "up:all") {
+    const out = await migrator.migrateToLatest();
+    results = out.results ?? [];
+    error = out.error;
+  } else if (arg === "up:one") {
+    const out = await migrator.migrateUp();
+    results = out.results ?? [];
+    error = out.error;
+  } else if (arg === "down:all") {
+    const migrations = await migrator.getMigrations();
+    for (const _ of migrations) {
+      const out = await migrator.migrateDown();
+      if (out.results) {
+        results = results.concat(out.results);
+        error = out.error;
+      }
+    }
+  } else if (arg === "down:one") {
+    const out = await migrator.migrateDown();
+    if (out.results) {
+      results = out.results ?? [];
+      error = out.error;
+    }
+  }
+
+  results?.forEach((it) => {
+    if (it.status === "Success") {
+      console.log(
+        `Migration "${it.migrationName} ${it.direction.toLowerCase()}" was executed successfully`,
+      );
+    } else if (it.status === "Error") {
+      console.error(`Failed to execute migration "${it.migrationName}"`);
+    }
+  });
+
+  if (error) {
+    console.error("Failed to migrate");
+    console.error(error);
+    process.exit(1);
+  }
+
+  await db.destroy();
+};
+
+const arg = process.argv.slice(2).pop();
+migrate(arg as string);

apps/bridge-frontend/database/migrations/0001-add-next-auth.ts

@@ -0,0 +1,72 @@
+import { Kysely, sql } from "kysely";
+
+export async function up(db: Kysely<any>): Promise<void> {
+  await db.schema
+    .createTable("User")
+    .addColumn("id", "uuid", (col) =>
+      col.primaryKey().defaultTo(sql`gen_random_uuid()`),
+    )
+    .addColumn("name", "text")
+    .addColumn("email", "text", (col) => col.unique().notNull())
+    .addColumn("emailVerified", "timestamptz")
+    .addColumn("image", "text")
+    .execute();
+
+  await db.schema
+    .createTable("Account")
+    .addColumn("id", "uuid", (col) =>
+      col.primaryKey().defaultTo(sql`gen_random_uuid()`),
+    )
+    .addColumn("userId", "uuid", (col) =>
+      col.references("User.id").onDelete("cascade").notNull(),
+    )
+    .addColumn("type", "text", (col) => col.notNull())
+    .addColumn("provider", "text", (col) => col.notNull())
+    .addColumn("providerAccountId", "text", (col) => col.notNull())
+    .addColumn("refresh_token", "text")
+    .addColumn("access_token", "text")
+    .addColumn("expires_at", "bigint")
+    .addColumn("token_type", "text")
+    .addColumn("scope", "text")
+    .addColumn("id_token", "text")
+    .addColumn("session_state", "text")
+    .execute();
+
+  await db.schema
+    .createTable("Session")
+    .addColumn("id", "uuid", (col) =>
+      col.primaryKey().defaultTo(sql`gen_random_uuid()`),
+    )
+    .addColumn("userId", "uuid", (col) =>
+      col.references("User.id").onDelete("cascade").notNull(),
+    )
+    .addColumn("sessionToken", "text", (col) => col.notNull().unique())
+    .addColumn("expires", "timestamptz", (col) => col.notNull())
+    .execute();
+
+  await db.schema
+    .createTable("VerificationToken")
+    .addColumn("identifier", "text", (col) => col.notNull())
+    .addColumn("token", "text", (col) => col.notNull().unique())
+    .addColumn("expires", "timestamptz", (col) => col.notNull())
+    .execute();
+
+  await db.schema
+    .createIndex("Account_userId_index")
+    .on("Account")
+    .column("userId")
+    .execute();
+
+  await db.schema
+    .createIndex("Session_userId_index")
+    .on("Session")
+    .column("userId")
+    .execute();
+}
+
+export async function down(db: Kysely<any>): Promise<void> {
+  await db.schema.dropTable("Account").ifExists().execute();
+  await db.schema.dropTable("Session").ifExists().execute();
+  await db.schema.dropTable("User").ifExists().execute();
+  await db.schema.dropTable("VerificationToken").ifExists().execute();
+}

apps/bridge-frontend/database/migrations/0002-add-signal.ts

@@ -0,0 +1,34 @@
+import { Kysely, sql } from "kysely";
+
+export async function up(db: Kysely<any>): Promise<void> {
+  await db.schema
+    .createTable("SignalBot")
+    .addColumn("id", "uuid", (col) =>
+      col.primaryKey().defaultTo(sql`gen_random_uuid()`),
+    )
+    .addColumn("phone_number", "text")
+    .addColumn("token", "text", (col) => col.unique().notNull())
+    .addColumn("user_id", "uuid")
+    .addColumn("description", "text")
+    .addColumn("auth_info", "text")
+    .addColumn("is_verified", "boolean", (col) =>
+      col.notNull().defaultTo(false),
+    )
+    .addColumn("created_at", "timestamptz", (col) =>
+      col.notNull().defaultTo(sql`now()`),
+    )
+    .addColumn("updated_at", "timestamptz", (col) =>
+      col.notNull().defaultTo(sql`now()`),
+    )
+    .execute();
+
+  await db.schema
+    .createIndex("SignalBotToken")
+    .on("SignalBot")
+    .column("token")
+    .execute();
+}
+
+export async function down(db: Kysely<any>): Promise<void> {
+  await db.schema.dropTable("SignalBot").ifExists().execute();
+}

apps/bridge-frontend/database/migrations/0003-add-whatsapp.ts

@@ -0,0 +1,34 @@
+import { Kysely, sql } from "kysely";
+
+export async function up(db: Kysely<any>): Promise<void> {
+  await db.schema
+    .createTable("WhatsappBot")
+    .addColumn("id", "uuid", (col) =>
+      col.primaryKey().defaultTo(sql`gen_random_uuid()`),
+    )
+    .addColumn("phone_number", "text")
+    .addColumn("token", "text", (col) => col.unique().notNull())
+    .addColumn("user_id", "uuid")
+    .addColumn("description", "text")
+    .addColumn("auth_info", "text")
+    .addColumn("is_verified", "boolean", (col) =>
+      col.notNull().defaultTo(false),
+    )
+    .addColumn("created_at", "timestamptz", (col) =>
+      col.notNull().defaultTo(sql`now()`),
+    )
+    .addColumn("updated_at", "timestamptz", (col) =>
+      col.notNull().defaultTo(sql`now()`),
+    )
+    .execute();
+
+  await db.schema
+    .createIndex("WhatsappBotToken")
+    .on("WhatsappBot")
+    .column("token")
+    .execute();
+}
+
+export async function down(db: Kysely<any>): Promise<void> {
+  await db.schema.dropTable("WhatsappBot").ifExists().execute();
+}

apps/bridge-frontend/database/migrations/0004-add-voice.ts

@@ -0,0 +1,74 @@
+import { Kysely, sql } from "kysely";
+
+export async function up(db: Kysely<any>): Promise<void> {
+  await db.schema
+    .createTable("VoiceProvider")
+    .addColumn("id", "uuid", (col) =>
+      col.primaryKey().defaultTo(sql`gen_random_uuid()`),
+    )
+    .addColumn("kind", "text", (col) => col.notNull())
+    .addColumn("name", "text", (col) => col.notNull())
+    .addColumn("credentials", "jsonb", (col) => col.notNull())
+    .addColumn("created_at", "timestamptz", (col) =>
+      col.notNull().defaultTo(sql`now()`),
+    )
+    .addColumn("updated_at", "timestamptz", (col) =>
+      col.notNull().defaultTo(sql`now()`),
+    )
+    .execute();
+
+  await db.schema
+    .createIndex("VoiceProviderName")
+    .on("VoiceProvider")
+    .column("name")
+    .execute();
+
+  await db.schema
+    .createTable("VoiceLine")
+    .addColumn("id", "uuid", (col) =>
+      col.primaryKey().defaultTo(sql`gen_random_uuid()`),
+    )
+    .addColumn("provider_id", "uuid", (col) =>
+      col.notNull().references("VoiceProvider.id").onDelete("cascade"),
+    )
+    .addColumn("provider_line_sid", "text", (col) => col.notNull())
+    .addColumn("number", "text", (col) => col.notNull())
+    .addColumn("language", "text", (col) => col.notNull())
+    .addColumn("voice", "text", (col) => col.notNull())
+    .addColumn("prompt_text", "text")
+    .addColumn("prompt_audio", "jsonb")
+    .addColumn("audio_prompt_enabled", "boolean", (col) =>
+      col.notNull().defaultTo(false),
+    )
+    .addColumn("audio_converted_at", "timestamptz")
+    .addColumn("created_at", "timestamptz", (col) =>
+      col.notNull().defaultTo(sql`now()`),
+    )
+    .addColumn("updated_at", "timestamptz", (col) =>
+      col.notNull().defaultTo(sql`now()`),
+    )
+    .execute();
+
+  await db.schema
+    .createIndex("VoiceLineProviderId")
+    .on("VoiceLine")
+    .column("provider_id")
+    .execute();
+
+  await db.schema
+    .createIndex("VoiceLineProviderLineSid")
+    .on("VoiceLine")
+    .column("provider_line_sid")
+    .execute();
+
+  await db.schema
+    .createIndex("VoiceLineNumber")
+    .on("VoiceLine")
+    .column("number")
+    .execute();
+}
+
+export async function down(db: Kysely<any>): Promise<void> {
+  await db.schema.dropTable("VoiceLine").ifExists().execute();
+  await db.schema.dropTable("VoiceProvider").ifExists().execute();
+}

apps/bridge-frontend/database/migrations/0005-add-facebook.ts

@@ -0,0 +1,34 @@
+import { Kysely, sql } from "kysely";
+
+export async function up(db: Kysely<any>): Promise<void> {
+  await db.schema
+    .createTable("FacebookBot")
+    .addColumn("id", "uuid", (col) =>
+      col.primaryKey().defaultTo(sql`gen_random_uuid()`),
+    )
+    .addColumn("phone_number", "text")
+    .addColumn("token", "text", (col) => col.unique().notNull())
+    .addColumn("user_id", "uuid")
+    .addColumn("description", "text")
+    .addColumn("auth_info", "text")
+    .addColumn("is_verified", "boolean", (col) =>
+      col.notNull().defaultTo(false),
+    )
+    .addColumn("created_at", "timestamptz", (col) =>
+      col.notNull().defaultTo(sql`now()`),
+    )
+    .addColumn("updated_at", "timestamptz", (col) =>
+      col.notNull().defaultTo(sql`now()`),
+    )
+    .execute();
+
+  await db.schema
+    .createIndex("FacebookBotToken")
+    .on("FacebookBot")
+    .column("token")
+    .execute();
+}
+
+export async function down(db: Kysely<any>): Promise<void> {
+  await db.schema.dropTable("FacebookBot").ifExists().execute();
+}

apps/bridge-frontend/database/migrations/0006-add-webhooks.ts

@@ -0,0 +1,40 @@
+import { Kysely, sql } from "kysely";
+
+export async function up(db: Kysely<any>): Promise<void> {
+  await db.schema
+    .createTable("Webhook")
+    .addColumn("id", "uuid", (col) =>
+      col.primaryKey().defaultTo(sql`gen_random_uuid()`),
+    )
+    .addColumn("backend_type", "text", (col) => col.notNull())
+    .addColumn("backend_id", "uuid", (col) => col.notNull())
+    .addColumn("name", "text", (col) => col.notNull())
+    .addColumn("endpoint_url", "text", (col) =>
+      col.notNull().check(sql`endpoint_url ~ '^https?://[^/]+'`),
+    )
+    .addColumn("http_method", "text", (col) =>
+      col
+        .notNull()
+        .defaultTo("post")
+        .check(sql`http_method in ('post', 'put')`),
+    )
+    .addColumn("headers", "jsonb")
+    .addColumn("created_at", "timestamptz", (col) =>
+      col.notNull().defaultTo(sql`now()`),
+    )
+    .addColumn("updated_at", "timestamptz", (col) =>
+      col.notNull().defaultTo(sql`now()`),
+    )
+    .execute();
+
+  await db.schema
+    .createIndex("WebhookBackendTypeBackendId")
+    .on("Webhook")
+    .column("backend_type")
+    .column("backend_id")
+    .execute();
+}
+
+export async function down(db: Kysely<any>): Promise<void> {
+  await db.schema.dropTable("Webhook").ifExists().execute();
+}

apps/bridge-frontend/database/migrations/0007-add-settings.ts

@@ -0,0 +1,28 @@
+import { Kysely, sql } from "kysely";
+
+export async function up(db: Kysely<any>): Promise<void> {
+  await db.schema
+    .createTable("Setting")
+    .addColumn("id", "uuid", (col) =>
+      col.primaryKey().defaultTo(sql`gen_random_uuid()`),
+    )
+    .addColumn("name", "text")
+    .addColumn("value", "jsonb")
+    .addColumn("created_at", "timestamptz", (col) =>
+      col.notNull().defaultTo(sql`now()`),
+    )
+    .addColumn("updated_at", "timestamptz", (col) =>
+      col.notNull().defaultTo(sql`now()`),
+    )
+    .execute();
+
+  await db.schema
+    .createIndex("SettingName")
+    .on("Setting")
+    .column("name")
+    .execute();
+}
+
+export async function down(db: Kysely<any>): Promise<void> {
+  await db.schema.dropTable("Setting").ifExists().execute();
+}

apps/bridge-frontend/next.config.js

@@ -1,6 +1,9 @@
 /** @type {import('next').NextConfig} */
 const nextConfig = {
-  transpilePackages: ["ui"]
+  transpilePackages: ["ui"],
+  experimental: {
+    instrumentationHook: true,
+  },
 };
 
 export default nextConfig;

apps/bridge-frontend/package.json

@@ -1,12 +1,16 @@
 {
   "name": "bridge-frontend",
   "version": "0.1.0",
-  "private": true,
+  "type": "module",
   "scripts": {
     "dev": "next dev",
     "build": "next build",
     "start": "next start",
-    "lint": "next lint"
+    "lint": "next lint",
+    "migrate:up:all": "tsx database/migrate.ts up:all",
+    "migrate:up:one": "tsx database/migrate.ts up:one",
+    "migrate:down:all": "tsx database/migrate.ts down:all",
+    "migrate:down:one": "tsx database/migrate.ts down:one"
   },
   "dependencies": {
     "@auth/kysely-adapter": "^1.0.0",
@@ -21,6 +25,7 @@
     "@mui/x-date-pickers-pro": "^7.2.0",
     "@mui/x-license": "^7.2.0",
     "date-fns": "^3.6.0",
+    "dotenv": "^16.4.5",
     "kysely": "^0.26.1",
     "material-ui-popup-state": "^5.1.0",
     "mui-chips-input": "^2.1.4",
@@ -34,6 +39,7 @@
     "react-qr-code": "^2.0.12",
     "react-timer-hook": "^3.0.7",
     "tss-react": "^4.9.6",
+    "tsx": "^4.7.2",
     "ui": "*"
   },
   "devDependencies": {