make runner apply db migration on startup

Author: sparrowDom

contracts/runner.ts

@@ -1,4 +1,28 @@
-import { runContainer } from "@talos/client";
+import { readFileSync } from "node:fs";
+import { dirname, resolve } from "node:path";
+import { fileURLToPath } from "node:url";
+
+import { createPool, runContainer } from "@talos/client";
+
+const databaseUrl = process.env.DATABASE_URL;
+if (!databaseUrl) {
+  throw new Error("DATABASE_URL env var required");
+}
+
+// Apply contracts/migrations/seed_schedules.sql before the runner boots so
+// any new schedule rows in that file land in the shared Talos Postgres on
+// container start. The file uses INSERT ... ON CONFLICT DO NOTHING, so it
+// is safe to re-run on every restart and only adds previously-unseen rows.
+const __dirname = dirname(fileURLToPath(import.meta.url));
+const seedSqlPath = resolve(__dirname, "migrations/seed_schedules.sql");
+const seedSql = readFileSync(seedSqlPath, "utf8");
+const pool = createPool({ connectionString: databaseUrl });
+try {
+  await pool.query(seedSql);
+  console.log(`[runner] applied ${seedSqlPath}`);
+} finally {
+  await pool.end();
+}
 
 await runContainer({
   product: "origin-dollar",

contracts/tasks/crossChain.js

@@ -292,9 +292,7 @@ const processCctpBridgeTransactions = async ({
       !hasEligibleMessage || !hasUnprocessedEligibleMessages;
     if (shouldMarkTxProcessed) {
       await store.put(txStoreKey, "processed");
-      log(
-        `Marked tx ${txHash} as processed using tx-level key ${txStoreKey}`
-      );
+      log(`Marked tx ${txHash} as processed using tx-level key ${txStoreKey}`);
     } else {
       log(
         `Did not mark tx-level key ${txStoreKey} because eligible messages exist but none were fully processed for tx ${txHash}`

contracts/tasks/tasks.js

@@ -1099,8 +1099,7 @@ task("setRewardTokenAddresses", "Sets the reward token of a strategy")
 task(
   "updateWOETHPrice",
   "Update the wOETH oracle price on the Base BridgedWOETHStrategy"
-)
-  .setAction(updateWOETHOraclePrice);
+).setAction(updateWOETHOraclePrice);
 
 // Harvester