feat: persist automation scheduler state

packages/opencode/migration/20260530170000_automation_persistence/migration.sql

@@ -0,0 +1,26 @@
+CREATE TABLE `automation_definition` (
+	`id` text PRIMARY KEY,
+	`project_id` text NOT NULL,
+	`owner_directory` text NOT NULL,
+	`time_created` integer NOT NULL,
+	`time_updated` integer NOT NULL,
+	`data` text NOT NULL,
+	CONSTRAINT `fk_automation_definition_project_id_project_id_fk` FOREIGN KEY (`project_id`) REFERENCES `project`(`id`) ON DELETE CASCADE
+);
+--> statement-breakpoint
+CREATE INDEX `automation_definition_project_owner_updated_idx` ON `automation_definition` (`project_id`,`owner_directory`,`time_updated`,`id`);--> statement-breakpoint
+CREATE TABLE `automation_run` (
+	`id` text PRIMARY KEY,
+	`automation_id` text NOT NULL,
+	`project_id` text NOT NULL,
+	`owner_directory` text NOT NULL,
+	`triggered_at` integer NOT NULL,
+	`data` text NOT NULL,
+	`time_created` integer NOT NULL,
+	`time_updated` integer NOT NULL,
+	CONSTRAINT `fk_automation_run_automation_id_automation_definition_id_fk` FOREIGN KEY (`automation_id`) REFERENCES `automation_definition`(`id`) ON DELETE CASCADE,
+	CONSTRAINT `fk_automation_run_project_id_project_id_fk` FOREIGN KEY (`project_id`) REFERENCES `project`(`id`) ON DELETE CASCADE
+);
+--> statement-breakpoint
+CREATE INDEX `automation_run_automation_triggered_idx` ON `automation_run` (`automation_id`,`triggered_at`,`id`);--> statement-breakpoint
+CREATE INDEX `automation_run_project_owner_idx` ON `automation_run` (`project_id`,`owner_directory`);

packages/opencode/package.json

@@ -58,6 +58,7 @@
     "@types/babel__core": "7.20.5",
     "@types/bun": "catalog:",
     "@types/cross-spawn": "catalog:",
+    "@types/luxon": "catalog:",
     "@types/mime-types": "3.0.1",
     "@types/npm-package-arg": "6.1.4",
     "@types/npmcli__arborist": "6.3.3",
@@ -143,6 +144,7 @@
     "hono-openapi": "catalog:",
     "ignore": "7.0.5",
     "jsonc-parser": "3.3.1",
+    "luxon": "catalog:",
     "mime-types": "3.0.2",
     "minimatch": "10.2.3",
     "npm-package-arg": "13.0.2",

packages/opencode/src/automation/automation.sql.ts

@@ -0,0 +1,45 @@
+import { index, integer, sqliteTable, text } from "drizzle-orm/sqlite-core"
+import type { Automation } from "."
+import { ProjectTable } from "@/project/project.sql"
+import type { ProjectID } from "@/project/schema"
+import { Timestamps } from "@/storage/schema.sql"
+
+export const AutomationDefinitionTable = sqliteTable(
+  "automation_definition",
+  {
+    id: text().primaryKey().$type<Automation.Definition["id"]>(),
+    project_id: text()
+      .$type<ProjectID>()
+      .notNull()
+      .references(() => ProjectTable.id, { onDelete: "cascade" }),
+    owner_directory: text().notNull(),
+    time_created: integer().notNull(),
+    time_updated: integer().notNull(),
+    data: text({ mode: "json" }).notNull().$type<Automation.Definition>(),
+  },
+  (table) => [
+    index("automation_definition_project_owner_updated_idx").on(table.project_id, table.owner_directory, table.time_updated, table.id),
+  ],
+)
+
+export const AutomationRunTable = sqliteTable(
+  "automation_run",
+  {
+    id: text().primaryKey().$type<Automation.Run["id"]>(),
+    automation_id: text()
+      .notNull()
+      .references(() => AutomationDefinitionTable.id, { onDelete: "cascade" }),
+    project_id: text()
+      .$type<ProjectID>()
+      .notNull()
+      .references(() => ProjectTable.id, { onDelete: "cascade" }),
+    owner_directory: text().notNull(),
+    triggered_at: integer().notNull(),
+    data: text({ mode: "json" }).notNull().$type<Automation.Run>(),
+    ...Timestamps,
+  },
+  (table) => [
+    index("automation_run_automation_triggered_idx").on(table.automation_id, table.triggered_at, table.id),
+    index("automation_run_project_owner_idx").on(table.project_id, table.owner_directory),
+  ],
+)