add schema migration

Author: pashagolub

internal/pgengine/migration.go

@@ -141,6 +141,12 @@ var Migrations func() migrator.Option = func() migrator.Option {
 				return ExecuteMigrationScript(ctx, tx, "00629.sql")
 			},
 		},
+		&migrator.Migration{
+			Name: "00721 Add more job control functions",
+			Func: func(ctx context.Context, tx pgx.Tx) error {
+				return ExecuteMigrationScript(ctx, tx, "00721.sql")
+			},
+		},
 		// adding new migration here, update "timetable"."migration" in "sql/init.sql"
 		// and "dbapi" variable in main.go!
 

internal/pgengine/sql/migrations/00721.sql

@@ -0,0 +1,15 @@
+-- pause_job() will pause the chain (set live = false)
+CREATE OR REPLACE FUNCTION timetable.pause_job(IN job_name TEXT) RETURNS boolean AS $$
+    WITH upd_chain AS (UPDATE timetable.chain SET live = false WHERE chain.chain_name = $1 RETURNING chain_id)
+    SELECT EXISTS(SELECT 1 FROM upd_chain)
+$$ LANGUAGE SQL;
+
+COMMENT ON FUNCTION timetable.pause_job IS 'Pause the chain (set live = false)';
+
+-- resume_job() will resume the chain (set live = true)
+CREATE OR REPLACE FUNCTION timetable.resume_job(IN job_name TEXT) RETURNS boolean AS $$
+    WITH upd_chain AS (UPDATE timetable.chain SET live = true WHERE chain.chain_name = $1 RETURNING chain_id)
+    SELECT EXISTS(SELECT 1 FROM upd_chain)
+$$ LANGUAGE SQL;
+
+COMMENT ON FUNCTION timetable.resume_job IS 'Resume the chain (set live = true)';