Cursor Agentandnsrb
7d51ff433f
- Store up to 50 revisions per workflow in SQLite with normalized SHA dedup - Soft-delete workflows to trash (7-day retention) with restore and permanent purge - Assign UUID filenames for new and duplicated workflows; show name + file in UI - Warn on invalid YAML, unknown scripts, and plaintext secrets with save-anyway option - Add workflow backup zip (workflows + plugins) and merge/replace restore - Trash page, history panel on editor, and smoke test Co-authored-by: Nasyarobby Putra <nasyarobby@gmail.com>
50 lines
1.5 KiB
JavaScript
50 lines
1.5 KiB
JavaScript
/**
|
|
* @param {import("knex").Knex} knex
|
|
*/
|
|
export async function up(knex) {
|
|
await knex.schema.createTable("workflow_revisions", (t) => {
|
|
t.text("id").primary();
|
|
t.text("workflow_id").notNullable();
|
|
t.text("owner").notNullable();
|
|
t.text("file").notNullable();
|
|
t.integer("revision").notNullable();
|
|
t.text("content_sha").notNullable();
|
|
t.text("content").notNullable();
|
|
t.text("reason");
|
|
t.text("meta");
|
|
t.text("created_at").notNullable();
|
|
});
|
|
|
|
await knex.schema.raw(
|
|
"CREATE UNIQUE INDEX workflow_revisions_workflow_id_revision_idx ON workflow_revisions (workflow_id, revision)",
|
|
);
|
|
await knex.schema.raw(
|
|
"CREATE INDEX workflow_revisions_workflow_id_created_at_idx ON workflow_revisions (workflow_id, created_at DESC)",
|
|
);
|
|
|
|
await knex.schema.createTable("workflow_trash", (t) => {
|
|
t.text("id").primary();
|
|
t.text("workflow_id").notNullable();
|
|
t.text("owner").notNullable();
|
|
t.text("file").notNullable();
|
|
t.text("name");
|
|
t.text("deleted_at").notNullable();
|
|
t.text("trash_path").notNullable();
|
|
});
|
|
|
|
await knex.schema.raw(
|
|
"CREATE INDEX workflow_trash_deleted_at_idx ON workflow_trash (deleted_at ASC)",
|
|
);
|
|
await knex.schema.raw(
|
|
"CREATE UNIQUE INDEX workflow_trash_owner_file_idx ON workflow_trash (owner, file)",
|
|
);
|
|
}
|
|
|
|
/**
|
|
* @param {import("knex").Knex} knex
|
|
*/
|
|
export async function down(knex) {
|
|
await knex.schema.dropTableIfExists("workflow_trash");
|
|
await knex.schema.dropTableIfExists("workflow_revisions");
|
|
}
|