Function OpenSQLiteEventLog

internal/controller/executor/sqlite.go:38–79

OpenSQLiteEventLog opens (or creates) a SQLite database at path and initializes the event log schema.

(path string)

// OpenSQLiteEventLog opens (or creates) a SQLite database at path and initializes the event log schema.
func OpenSQLiteEventLog(path string) (*SQLiteEventLog, error) {
	dir := filepath.Dir(path)
	if err := os.MkdirAll(dir, 0755); err != nil {
		return nil, fmt.Errorf("sqlite_eventlog: mkdir %s: %w", dir, err)
	}

	dsn := fmt.Sprintf("%s?_pragma=busy_timeout(%d)", path, sqliteBusyTimeout.Milliseconds())
	db, err := sql.Open("sqlite", dsn)
	if err != nil {
		return nil, fmt.Errorf("sqlite_eventlog: open %s: %w", dsn, err)
	}

	// Create tables if they don't exist
	if _, err := db.Exec(`
		CREATE TABLE IF NOT EXISTS conversation_log (
			conversation_id TEXT NOT NULL,
			seq INTEGER NOT NULL,
			payload TEXT NOT NULL,
			PRIMARY KEY (conversation_id, seq)
		)`); err != nil {
		db.Close()
		return nil, fmt.Errorf("sqlite_eventlog: create conversation_log table: %w", err)
	}

	if _, err := db.Exec(`
		CREATE TABLE IF NOT EXISTS execution_log (
			exec_id TEXT NOT NULL,
			payload TEXT NOT NULL,
			timestamp DATETIME NOT NULL
		)`); err != nil {
		db.Close()
		return nil, fmt.Errorf("sqlite_eventlog: create execution_log table: %w", err)
	}

	// Create indexes if they don't exist
	if _, err := db.Exec(`CREATE INDEX IF NOT EXISTS idx_execution_log_exec_id ON execution_log(exec_id)`); err != nil {
		db.Close()
		return nil, fmt.Errorf("sqlite_eventlog: create index exec_id: %w", err)
	}

	return &SQLiteEventLog{db: db}, nil
}

// Append serializes the event to JSON and inserts it into the database.
func (l *SQLiteEventLog) Append(ctx context.Context, event *proto.ConversationEvent) (int32, error) {