feat: add trigger to remote api

src/app/api/ops/[database_id]/handle-trigger.ts

@@ -0,0 +1,20 @@
+import { DatabaseOperationHandler } from "@/lib/with-database-ops";
+import { NextResponse } from "next/server";
+import { createTursoEdgeDriver } from "./turso-edge-client";
+import { RequestOperationTrigger } from "@/lib/api/api-request-types";
+
+const handleTriggerRequest: DatabaseOperationHandler<
+  RequestOperationTrigger
+> = async ({ database, body }) => {
+  const client = await createTursoEdgeDriver(database);
+
+  try {
+    return NextResponse.json({
+      data: await client.trigger(body.name),
+    });
+  } catch (e) {
+    return NextResponse.json({ error: (e as Error).message });
+  }
+};
+
+export default handleTriggerRequest;

src/app/api/ops/[database_id]/route.ts

@@ -7,6 +7,7 @@ import handleSelectTableRequest from "./handle-select-table";
 import handleUpdateTableDataRequest from "./handle-update-table-data";
 import handleSchemaRequest from "./handle-schema";
 import { RequestOperationBody } from "@/lib/api/api-request-types";
+import handleTriggerRequest from "./handle-trigger";
 
 export const runtime = "edge";
 
@@ -27,6 +28,8 @@ export const POST = withDatabaseOperation<RequestOperationBody>(async function (
     return await handleUpdateTableDataRequest({ ...props, body });
   } else if (body.type === "schema") {
     return await handleSchemaRequest({ ...props, body });
+  } else if (body.type === "trigger") {
+    return await handleTriggerRequest({ ...props, body });
   }
 
   return NextResponse.json({ error: "Unknown command" }, { status: 500 });

src/drivers/remote-driver.ts

@@ -6,13 +6,15 @@ import {
   DatabaseTableOperation,
   DatabaseTableOperationReslt,
   DatabaseTableSchema,
+  DatabaseTriggerSchema,
   SelectFromTableOptions,
 } from "./base-driver";
 import {
   ApiOpsBatchResponse,
   ApiOpsQueryResponse,
   ApiSchemaListResponse,
   ApiSchemaResponse,
+  ApiTriggerResponse,
 } from "@/lib/api-response-types";
 import { RequestOperationBody } from "@/lib/api/api-request-types";
 
@@ -76,6 +78,11 @@ export default class RemoteDriver implements BaseDriver {
     ).data;
   }
 
+  async trigger(name: string): Promise<DatabaseTriggerSchema> {
+    return (await this.request<ApiTriggerResponse>({ type: "trigger", name }))
+      .data;
+  }
+
   async updateTableData(
     tableName: string,
     ops: DatabaseTableOperation[]

src/lib/api-response-types.ts

@@ -3,6 +3,7 @@ import {
   DatabaseResultSet,
   DatabaseSchemaItem,
   DatabaseTableSchema,
+  DatabaseTriggerSchema,
 } from "@/drivers/base-driver";
 
 export interface ApiOpsBatchResponse {
@@ -32,3 +33,8 @@ export interface ApiSchemaResponse {
   data: DatabaseTableSchema;
   error?: string;
 }
+
+export interface ApiTriggerResponse {
+  data: DatabaseTriggerSchema;
+  error?: string;
+}

src/lib/api/api-request-types.ts

@@ -23,6 +23,16 @@ export interface RequestOperationSchema {
   tableName: string;
 }
 
+export interface RequestTriggerSchema {
+  type: "trigger";
+  name: string;
+}
+
+export interface RequestOperationTrigger {
+  type: "trigger";
+  name: string;
+}
+
 export interface RequestOperationSelectTable {
   type: "select-table";
   tableName: string;
@@ -41,4 +51,6 @@ export type RequestOperationBody =
   | RequestOperationSchemas
   | RequestOperationSelectTable
   | RequestOperationUpdateTableData
-  | RequestOperationSchema;
+  | RequestOperationSchema
+  | RequestOperationTrigger
+  | RequestTriggerSchema;