refactor: rename DB table cron_locks -> process_lock

Signed-off-by: Robert Zaremba <robert@zaremba.ch>

Author: robert-zaremba

packages/btcindexer/db/migrations/0001_initial_schema.sql

@@ -128,7 +128,7 @@ CREATE TABLE IF NOT EXISTS presign_objects (
 
 CREATE INDEX IF NOT EXISTS presign_objects_sui_network_created_at ON presign_objects(sui_network, created_at);
 
-CREATE TABLE IF NOT EXISTS cron_locks (
+CREATE TABLE IF NOT EXISTS process_locks (
 	lock_name TEXT NOT NULL PRIMARY KEY,
 	acquired_at INTEGER NOT NULL,
 	expires_at INTEGER NOT NULL

packages/lib/src/test-helpers/init_db.ts

@@ -42,7 +42,7 @@ export const tables = [
 	"btc_blocks",
 	"indexer_state",
 	"presign_objects",
-	"cron_locks",
+	"process_locks",
 	"setups",
 ];
 

packages/sui-indexer/src/storage.test.ts

@@ -601,7 +601,7 @@ describe("IndexerStorage", () => {
 	describe("Distributed Lock", () => {
 		async function getLock(lockName: string) {
 			return db
-				.prepare("SELECT * FROM cron_locks WHERE lock_name = ?")
+				.prepare("SELECT * FROM process_locks WHERE lock_name = ?")
 				.bind(lockName)
 				.first<{ lock_name: string; acquired_at: number; expires_at: number }>();
 		}
@@ -634,7 +634,7 @@ describe("IndexerStorage", () => {
 			const expiredTime = Date.now() - 10000;
 			await db
 				.prepare(
-					"INSERT INTO cron_locks (lock_name, acquired_at, expires_at) VALUES (?, ?, ?)",
+					"INSERT INTO process_locks (lock_name, acquired_at, expires_at) VALUES (?, ?, ?)",
 				)
 				.bind("test-lock", expiredTime - 60000, expiredTime)
 				.run();
@@ -664,7 +664,7 @@ describe("IndexerStorage", () => {
 			const expiredTime = now - 10000;
 			await db
 				.prepare(
-					"INSERT INTO cron_locks (lock_name, acquired_at, expires_at) VALUES (?, ?, ?)",
+					"INSERT INTO process_locks (lock_name, acquired_at, expires_at) VALUES (?, ?, ?)",
 				)
 				.bind("lock-x", expiredTime - 60000, expiredTime)
 				.run();

packages/sui-indexer/src/storage.ts

@@ -866,11 +866,11 @@ export class D1Storage {
 		try {
 			const { results } = await this.db
 				.prepare(
-					`INSERT INTO cron_locks (lock_name, acquired_at, expires_at)
+					`INSERT INTO process_locks (lock_name, acquired_at, expires_at)
 					 VALUES ${valueRows}
 					 ON CONFLICT(lock_name) DO UPDATE
 					   SET acquired_at = excluded.acquired_at, expires_at = excluded.expires_at
-					   WHERE cron_locks.expires_at <= excluded.acquired_at
+					   WHERE process_locks.expires_at <= excluded.acquired_at
 					   RETURNING lock_name, acquired_at`,
 				)
 				.bind(...params)
@@ -891,7 +891,7 @@ export class D1Storage {
 
 		try {
 			await this.db
-				.prepare(`DELETE FROM cron_locks WHERE lock_name IN (${placeholders})`)
+				.prepare(`DELETE FROM process_locks WHERE lock_name IN (${placeholders})`)
 				.bind(...lockNames)
 				.run();
 		} catch (error) {