Function setupDatabase

api/db.go:9–108

setupDatabase sets up the database and schema migrations.

(db *sql.DB)

// setupDatabase sets up the database and schema migrations.
func setupDatabase(db *sql.DB) error {
	migrations := []string{
		/* 000 */ `CREATE TABLE IF NOT EXISTS schema_version (version INT PRIMARY KEY, timestamp TIMESTAMP)`,
		/* 001 */ `
		CREATE TABLE IF NOT EXISTS configs (
			loaded_at TIMESTAMP NOT NULL,
			hash TEXT NOT NULL,
			config JSON NOT NULL
		);
		CREATE TABLE IF NOT EXISTS workflows (
			config_hash TEXT NOT NULL,
			id TEXT NOT NULL,
			text TEXT NOT NULL,
			PRIMARY KEY (config_hash, id)
		);
		CREATE TABLE IF NOT EXISTS workflow_runs (
			id TEXT NOT NULL PRIMARY KEY,
			config_hash TEXT NOT NULL,
			workflow_id TEXT NOT NULL,
			started_at TIMESTAMP,
			completed_at TIMESTAMP,
			success BOOL
		);
		CREATE TABLE tasks (
			id TEXT NOT NULL PRIMARY KEY,
			workflow_run_id TEXT NOT NULL,
			workflow_task_id TEXT NOT NULL,
			input JSON NOT NULL DEFAULT '{}',
			output JSON NOT NULL DEFAULT '{}',
			created_at TIMESTAMP NOT NULL,
			started_at TIMESTAMP,
			timeout_at TIMESTAMP,
			completed_at TIMESTAMP,
			attempts_left NOT NULL DEFAULT 3,
			stdout TEXT,
			stderr TEXT,
			success BOOL
		);
		CREATE TABLE IF NOT EXISTS data_connections (
			config_hash TEXT NOT NULL,
			id TEXT NOT NULL,
			type TEXT NOT NULL,
			path TEXT,
			connection_string TEXT,
			PRIMARY KEY (config_hash, id)
		);
		CREATE TABLE IF NOT EXISTS datasets (
			config_hash TEXT NOT NULL,
			id TEXT NOT NULL,
			text TEXT NOT NULL,
			PRIMARY KEY (config_hash, id)
		)
		`,
	}

	tx, err := db.Begin()
	if err != nil {
		return err