clanker-saddle/src/Data/Entities.vala

using InvercargillSql.Orm;

namespace ClankerSaddle.Data {

    /**
     * A software project worked on by saddle agents, stored in the
     * `projects` table.
     */
    public class Project : Object {

        public int64 id { get; set; }
        public string name { get; set; default = ""; }
        public string git_url { get; set; default = ""; }
        public string default_branch { get; set; default = "main"; }
        public string? summary { get; set; default = null; }
        public DateTime? created_at { get; set; default = null; }

        public static void entity_mapping(EntityMapperBuilder<Project> cfg) {
            cfg.table("projects")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<string>("name", o => o.name, (o, v) => o.name = v)
                .column<string>("git_url", o => o.git_url, (o, v) => o.git_url = v)
                .column<string>("default_branch", o => o.default_branch, (o, v) => o.default_branch = v)
                .column<string>("summary", o => o.summary, (o, v) => o.summary = v)
                .column<DateTime?>("created_at", o => o.created_at, (o, v) => o.created_at = v);
        }
    }

    /**
     * A directed relationship between two projects ('co-developed' or
     * 'reference'), stored in the `project_links` table.
     */
    public class ProjectLink : Object {

        public int64 id { get; set; }
        public int64 parent_project_id { get; set; }
        public int64 linked_project_id { get; set; }
        public string relationship { get; set; default = "reference"; }

        public static void entity_mapping(EntityMapperBuilder<ProjectLink> cfg) {
            cfg.table("project_links")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<int64?>("parent_project_id", o => o.parent_project_id, (o, v) => o.parent_project_id = v)
                .column<int64?>("linked_project_id", o => o.linked_project_id, (o, v) => o.linked_project_id = v)
                .column<string>("relationship", o => o.relationship, (o, v) => o.relationship = v);
        }
    }

    /**
     * A unit of work for a saddle agent: created in {@link
     * TaskService.STATUS_DRAFT}, queued by its creator (human or goal
     * agent), dispatched to a saddle, worked, possibly blocked on
     * questions, and eventually done or failed (completion is
     * agent-only). The plan-12 shape: goals own the task graph — a task
     * links its {@link goal_id}, runs as a plain worker or the goal
     * agent itself ({@link kind}), carries a work {@link mode} and its
     * {@link creator}, and human tasks may carry an auto-enqueue
     * predecessor ({@link enqueue_after_task_id}). Stored in the
     * `tasks` table. Named `TaskEntity` (not `Task`) to stay clear of
     * `GLib.Task` in files that import Gio transitively.
     */
    public class TaskEntity : Object {

        public int64 id { get; set; }
        public int64 project_id { get; set; }
        public string title { get; set; default = ""; }
        public string? description { get; set; default = null; }
        public string status { get; set; default = "draft"; }
        public int64 priority { get; set; default = 5; }
        public string? summary { get; set; default = null; }
        public string? task_branch { get; set; default = null; }
        public string? branch_from { get; set; default = null; }
        public DateTime? created_at { get; set; default = null; }
        public DateTime? started_at { get; set; default = null; }
        public DateTime? completed_at { get; set; default = null; }
        public DateTime? suspended_at { get; set; default = null; }
        /**
         * Goal 4 task 1 (Force Wake): the human pressed Force wake on
         * the task page — this suspended plain task becomes
         * parked-offerable again with the explicit wake notice.
         * Consumed (cleared) by the allocation that resumes it.
         */
        public bool force_wake { get; set; default = false; }
        /** The goal this task belongs to (0 = standalone). */
        public int64 goal_id { get; set; default = 0; }
        /** "task" (a worker) or "goal_run" (the goal agent's own run). */
        public string kind { get; set; default = "task"; }
        /** implement / investigate / review / test (orchestrate for goal runs). */
        public string mode { get; set; default = "implement"; }
        /** "human" or "goal" — enqueueing is creator-only. */
        public string creator { get; set; default = "human"; }
        /** Human-created tasks only: auto-enqueue when this predecessor is done. */
        public int64 enqueue_after_task_id { get; set; default = 0; }

        public static void entity_mapping(EntityMapperBuilder<TaskEntity> cfg) {
            cfg.table("tasks")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<int64?>("project_id", o => o.project_id, (o, v) => o.project_id = v)
                .column<string>("title", o => o.title, (o, v) => o.title = v)
                .column<string>("description", o => o.description, (o, v) => o.description = v)
                .column<string>("status", o => o.status, (o, v) => o.status = v)
                .column<int64?>("priority", o => o.priority, (o, v) => o.priority = v)
                .column<string>("summary", o => o.summary, (o, v) => o.summary = v)
                .column<string>("task_branch", o => o.task_branch, (o, v) => o.task_branch = v)
                .column<string>("branch_from", o => o.branch_from, (o, v) => o.branch_from = v)
                .column<DateTime?>("created_at", o => o.created_at, (o, v) => o.created_at = v)
                .column<DateTime?>("started_at", o => o.started_at, (o, v) => o.started_at = v)
                .column<DateTime?>("completed_at", o => o.completed_at, (o, v) => o.completed_at = v)
                .column<DateTime?>("suspended_at", o => o.suspended_at, (o, v) => o.suspended_at = v)
                .column<bool>("force_wake", o => o.force_wake, (o, v) => o.force_wake = v)
                .column<int64?>("goal_id", o => o.goal_id, (o, v) => o.goal_id = v ?? 0)
                .column<string>("kind", o => o.kind, (o, v) => o.kind = v)
                .column<string>("mode", o => o.mode, (o, v) => o.mode = v)
                .column<string>("creator", o => o.creator, (o, v) => o.creator = v)
                .column<int64?>("enqueue_after_task_id", o => o.enqueue_after_task_id, (o, v) => o.enqueue_after_task_id = v ?? 0);
        }
    }

    /**
     * One row of the plan-17 unified event ledger (`events`): daemon
     * events carry their session and its per-session monotonic `seq`
     * (the idempotency key), web-originated events carry neither. The
     * payload is a JSON object whose shape depends on `kind` (see
     * Services.EventService).
     */
    public class EventRecord : Object {

        public int64 id { get; set; }
        public int64 session_id { get; set; default = 0; }
        public int64 seq { get; set; default = 0; }
        public string kind { get; set; default = ""; }
        public string actor { get; set; default = ""; }
        public string scope_type { get; set; default = ""; }
        public int64 scope_id { get; set; }
        public string payload { get; set; default = "{}"; }
        public DateTime? created_at { get; set; default = null; }

        public static void entity_mapping(EntityMapperBuilder<EventRecord> cfg) {
            cfg.table("events")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<int64?>("session_id",
                    o => o.session_id > 0 ? (int64?) o.session_id : (int64?) null,
                    (o, v) => o.session_id = v ?? 0)
                .column<int64?>("seq",
                    o => o.seq > 0 ? (int64?) o.seq : (int64?) null,
                    (o, v) => o.seq = v ?? 0)
                .column<string>("kind", o => o.kind, (o, v) => o.kind = v)
                .column<string>("actor", o => o.actor, (o, v) => o.actor = v)
                .column<string>("scope_type", o => o.scope_type, (o, v) => o.scope_type = v)
                .column<int64?>("scope_id", o => o.scope_id, (o, v) => o.scope_id = v ?? 0)
                .column<string>("payload", o => o.payload, (o, v) => o.payload = v)
                .column<DateTime?>("created_at", o => o.created_at, (o, v) => o.created_at = v);
        }
    }

    /** A remark on a task, authored either by a human or by the agent ('agent'). */
    public class TaskComment : Object {

        public int64 id { get; set; }
        public int64 task_id { get; set; }
        public string author { get; set; default = "agent"; }
        public string body { get; set; default = ""; }
        public string? quote { get; set; default = null; }
        public DateTime? created_at { get; set; default = null; }

        public static void entity_mapping(EntityMapperBuilder<TaskComment> cfg) {
            cfg.table("task_comments")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<int64?>("task_id", o => o.task_id, (o, v) => o.task_id = v)
                .column<string>("author", o => o.author, (o, v) => o.author = v)
                .column<string>("body", o => o.body, (o, v) => o.body = v)
                .column<string>("quote", o => o.quote, (o, v) => o.quote = v)
                .column<DateTime?>("created_at", o => o.created_at, (o, v) => o.created_at = v);
        }
    }

    /**
     * A blocking prompt raised by an agent mid-task — a multiple-choice
     * {@link block_type} question, a request for comment or a review
     * request — answered by a human in the web UI; the answer is collected
     * by the saddle on its next
     * {@link ClankerSaddle.Services.SaddlePollState} delivery ledger poll.
     */
    public class TaskBlock : Object {

        public int64 id { get; set; }
        public int64 task_id { get; set; }
        public string question { get; set; default = ""; }
        public string? answer { get; set; default = null; }
        public string block_type { get; set; default = "question"; }
        public string? options { get; set; default = null; }
        public string? body { get; set; default = null; }
        public DateTime? answered_at { get; set; default = null; }
        public string? answered_by { get; set; default = null; }
        public DateTime? created_at { get; set; default = null; }

        public static void entity_mapping(EntityMapperBuilder<TaskBlock> cfg) {
            cfg.table("task_blocks")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<int64?>("task_id", o => o.task_id, (o, v) => o.task_id = v)
                .column<string>("question", o => o.question, (o, v) => o.question = v)
                .column<string>("answer", o => o.answer, (o, v) => o.answer = v)
                .column<string>("type", o => o.block_type, (o, v) => o.block_type = v)
                .column<string>("options", o => o.options, (o, v) => o.options = v)
                .column<string>("body", o => o.body, (o, v) => o.body = v)
                .column<DateTime?>("answered_at", o => o.answered_at, (o, v) => o.answered_at = v)
                .column<string>("answered_by", o => o.answered_by, (o, v) => o.answered_by = v)
                .column<DateTime?>("created_at", o => o.created_at, (o, v) => o.created_at = v);
        }
    }

    /**
     * A saddle container registered with this app: one daemon managing one
     * bash session at a time, controlled over HTTP at {@link host}. The
     * per-saddle token ({@link token}, plan 10) authorises every
     * daemon→web call; removing the row revokes it. Plan 16 item 23:
     * sessions are the source of truth for "who runs what" — busy/idle
     * are DERIVED (busy iff an open session on an assigned/working task
     * exists; see {@link Services.SaddleService.current_work_view}) and
     * the row's `status` column is only the OFFLINE probe state
     * ('offline' vs 'idle'): the poller's unreachable stamp, cleared by
     * a successful probe or a proof-of-life ask. The former
     * `current_task_id`/`allocated_at` cache columns are gone.
     */
    public class Saddle : Object {

        public int64 id { get; set; }
        public string name { get; set; default = ""; }
        public string host { get; set; default = ""; }
        public string status { get; set; default = "idle"; }
        public string? git_name { get; set; default = null; }
        public string? git_email { get; set; default = null; }
        public string? ssh_public_key { get; set; default = null; }
        public string? token { get; set; default = null; }

        public static void entity_mapping(EntityMapperBuilder<Saddle> cfg) {
            cfg.table("saddles")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<string>("name", o => o.name, (o, v) => o.name = v)
                .column<string>("host", o => o.host, (o, v) => o.host = v)
                .column<string>("status", o => o.status, (o, v) => o.status = v)
                .column<string>("git_name", o => o.git_name, (o, v) => o.git_name = v)
                .column<string>("git_email", o => o.git_email, (o, v) => o.git_email = v)
                .column<string>("ssh_public_key", o => o.ssh_public_key, (o, v) => o.ssh_public_key = v)
                .column<string>("token", o => o.token, (o, v) => o.token = v);
        }
    }

    /**
     * One run of a task on a saddle: opened when the dispatcher assigns
     * the task, closed with an outcome when the session ends.
     */
    public class Session : Object {

        public int64 id { get; set; }
        public int64 task_id { get; set; }
        public int64 saddle_id { get; set; }
        public DateTime? started_at { get; set; default = null; }
        public DateTime? ended_at { get; set; default = null; }
        public string? outcome { get; set; default = null; }
        /**
         * What a resumed session's agent first received (plan 14 B4):
         * the resume_notice the allocation built, stored on the row at
         * resume-allocation; null for fresh sessions.
         */
        public string? resume_notice { get; set; default = null; }

        public static void entity_mapping(EntityMapperBuilder<Session> cfg) {
            cfg.table("sessions")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<int64?>("task_id", o => o.task_id, (o, v) => o.task_id = v)
                .column<int64?>("saddle_id", o => o.saddle_id, (o, v) => o.saddle_id = v)
                .column<DateTime?>("started_at", o => o.started_at, (o, v) => o.started_at = v)
                .column<DateTime?>("ended_at", o => o.ended_at, (o, v) => o.ended_at = v)
                .column<string>("outcome", o => o.outcome, (o, v) => o.outcome = v)
                .column<string>("resume_notice", o => o.resume_notice, (o, v) => o.resume_notice = v);
        }
    }

    /**
     * A reusable instruction the dispatched agent must follow, stored in
     * the `rules` table and attached to projects and/or tasks.
     * `updated_at` stamps the last body/name edit (null until edited)
     * — the resume-time context_update delta keys on it.
     */
    public class Rule : Object {

        public int64 id { get; set; }
        public string name { get; set; default = ""; }
        public string body { get; set; default = ""; }
        public DateTime? created_at { get; set; default = null; }
        public DateTime? updated_at { get; set; default = null; }

        public static void entity_mapping(EntityMapperBuilder<Rule> cfg) {
            cfg.table("rules")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<string>("name", o => o.name, (o, v) => o.name = v)
                .column<string>("body", o => o.body, (o, v) => o.body = v)
                .column<DateTime?>("created_at", o => o.created_at, (o, v) => o.created_at = v)
                .column<DateTime?>("updated_at", o => o.updated_at, (o, v) => o.updated_at = v);
        }
    }

    /** An attachment of a rule to a project (`rule_projects`). */
    public class RuleProject : Object {

        public int64 id { get; set; }
        public int64 rule_id { get; set; }
        public int64 project_id { get; set; }
        public DateTime? created_at { get; set; default = null; }

        public static void entity_mapping(EntityMapperBuilder<RuleProject> cfg) {
            cfg.table("rule_projects")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<int64?>("rule_id", o => o.rule_id, (o, v) => o.rule_id = v)
                .column<int64?>("project_id", o => o.project_id, (o, v) => o.project_id = v)
                .column<DateTime?>("created_at", o => o.created_at, (o, v) => o.created_at = v);
        }
    }

    /** An attachment of a rule to a task (`task_rules`). */
    public class TaskRule : Object {

        public int64 id { get; set; }
        public int64 rule_id { get; set; }
        public int64 task_id { get; set; }
        public DateTime? created_at { get; set; default = null; }

        public static void entity_mapping(EntityMapperBuilder<TaskRule> cfg) {
            cfg.table("task_rules")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<int64?>("rule_id", o => o.rule_id, (o, v) => o.rule_id = v)
                .column<int64?>("task_id", o => o.task_id, (o, v) => o.task_id = v)
                .column<DateTime?>("created_at", o => o.created_at, (o, v) => o.created_at = v);
        }
    }

    /**
     * An LLM-authored remark about a project (`saddle note` via the
     * callback endpoint), curated from the project page. The source task
     * is null for notes without one.
     */
    public class ProjectNote : Object {

        public int64 id { get; set; }
        public int64 project_id { get; set; }
        public int64 source_task_id { get; set; default = 0; }
        public string body { get; set; default = ""; }
        public DateTime? created_at { get; set; default = null; }

        public static void entity_mapping(EntityMapperBuilder<ProjectNote> cfg) {
            cfg.table("project_notes")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<int64?>("project_id", o => o.project_id, (o, v) => o.project_id = v)
                .column<int64?>("source_task_id", o => o.source_task_id, (o, v) => o.source_task_id = v ?? 0)
                .column<string>("body", o => o.body, (o, v) => o.body = v)
                .column<DateTime?>("created_at", o => o.created_at, (o, v) => o.created_at = v);
        }
    }

    /**
     * A named tag used for dispatch routing (`capabilities`): saddles
     * declare the tags they carry, tasks the tags they require.
     */
    public class Capability : Object {

        public int64 id { get; set; }
        public string name { get; set; default = ""; }
        public DateTime? created_at { get; set; default = null; }

        public static void entity_mapping(EntityMapperBuilder<Capability> cfg) {
            cfg.table("capabilities")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<string>("name", o => o.name, (o, v) => o.name = v)
                .column<DateTime?>("created_at", o => o.created_at, (o, v) => o.created_at = v);
        }
    }

    /** A tag declaration on a saddle (`saddle_capabilities`). */
    public class SaddleCapability : Object {

        public int64 id { get; set; }
        public int64 capability_id { get; set; }
        public int64 saddle_id { get; set; }

        public static void entity_mapping(EntityMapperBuilder<SaddleCapability> cfg) {
            cfg.table("saddle_capabilities")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<int64?>("capability_id", o => o.capability_id, (o, v) => o.capability_id = v)
                .column<int64?>("saddle_id", o => o.saddle_id, (o, v) => o.saddle_id = v);
        }
    }

    /** A required tag on a task (`task_capabilities`). */
    public class TaskCapability : Object {

        public int64 id { get; set; }
        public int64 capability_id { get; set; }
        public int64 task_id { get; set; }

        public static void entity_mapping(EntityMapperBuilder<TaskCapability> cfg) {
            cfg.table("task_capabilities")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<int64?>("capability_id", o => o.capability_id, (o, v) => o.capability_id = v)
                .column<int64?>("task_id", o => o.task_id, (o, v) => o.task_id = v);
        }
    }

    /**
     * A user's Web Push subscription endpoint (plan 11 task E shape):
     * `p256dh`/`auth` are the browser's application server keys; the
     * endpoint URL is unique per browser. `user_id` references the
     * Spry users table by value (no FK — the auth schema owns that
     * table).
     */
    public class PushSubscription : Object {

        public int64 id { get; set; }
        public int64 user_id { get; set; }
        public string endpoint { get; set; default = ""; }
        public string p256dh { get; set; default = ""; }
        public string auth { get; set; default = ""; }
        public DateTime? created_at { get; set; default = null; }

        public static void entity_mapping(EntityMapperBuilder<PushSubscription> cfg) {
            cfg.table("push_subscriptions")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<int64?>("user_id", o => o.user_id, (o, v) => o.user_id = v)
                .column<string>("endpoint", o => o.endpoint, (o, v) => o.endpoint = v)
                .column<string>("p256dh", o => o.p256dh, (o, v) => o.p256dh = v)
                .column<string>("auth", o => o.auth, (o, v) => o.auth = v)
                .column<DateTime?>("created_at", o => o.created_at, (o, v) => o.created_at = v);
        }
    }

    /**
     * A user's per-task "Notify me" opt-in (plan 11 task E shape): the
     * task's first start, failure and completion notify the opted-in
     * user; block events notify all push-subscribed users globally.
     */
    public class TaskNotifyPref : Object {

        public int64 id { get; set; }
        public int64 task_id { get; set; }
        public int64 user_id { get; set; }

        public static void entity_mapping(EntityMapperBuilder<TaskNotifyPref> cfg) {
            cfg.table("task_notify_prefs")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<int64?>("task_id", o => o.task_id, (o, v) => o.task_id = v)
                .column<int64?>("user_id", o => o.user_id, (o, v) => o.user_id = v);
        }
    }

    /**
     * A user-created goal (plan 12): an agent-orchestrated unit of
     * work over one primary project plus optional links. The brief
     * locks once started; the lifecycle runs draft → planning → plan
     * review → active → completion review → complete / failed /
     * cancelled, with paused freezing supervision in between. Stored
     * in the `goals` table.
     */
    public class Goal : Object {

        public int64 id { get; set; }
        public int64 project_id { get; set; }
        public string title { get; set; default = ""; }
        public string brief { get; set; default = ""; }
        public string branch_name { get; set; default = ""; }
        public string? base_branch { get; set; default = null; }
        public string status { get; set; default = "draft"; }
        public int64 priority { get; set; default = 3; }
        public string? plan { get; set; default = null; }
        public string? completion_report { get; set; default = null; }
        public string creator { get; set; default = "human"; }
        /**
         * Plan 15 C3 (was last_seen_event_id): the timestamp through
         * which the goal agent has consumed its tasks' terminal
         * transitions — resume_due fires on transitions newer than
         * it, and a resume advance it. The narrative itself is
         * derived at read time.
         */
        public DateTime? last_terminal_watermark { get; set; default = null; }
        public DateTime? created_at { get; set; default = null; }
        public DateTime? started_at { get; set; default = null; }
        public DateTime? completed_at { get; set; default = null; }
        public DateTime? paused_at { get; set; default = null; }
        /**
         * Goal 4 task 1 (Force Wake): the human pressed Force wake on
         * the goal page — the parked run becomes offerable immediately
         * and the resume notice leads with the explicit wake line.
         * Consumed (cleared) by the resume that carries it.
         */
        public bool force_wake { get; set; default = false; }

        public static void entity_mapping(EntityMapperBuilder<Goal> cfg) {
            cfg.table("goals")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<int64?>("project_id", o => o.project_id, (o, v) => o.project_id = v)
                .column<string>("title", o => o.title, (o, v) => o.title = v)
                .column<string>("brief", o => o.brief, (o, v) => o.brief = v)
                .column<string>("branch_name", o => o.branch_name, (o, v) => o.branch_name = v)
                .column<string>("base_branch", o => o.base_branch, (o, v) => o.base_branch = v)
                .column<string>("status", o => o.status, (o, v) => o.status = v)
                .column<int64?>("priority", o => o.priority, (o, v) => o.priority = v)
                .column<string>("plan", o => o.plan, (o, v) => o.plan = v)
                .column<string>("completion_report", o => o.completion_report, (o, v) => o.completion_report = v)
                .column<string>("creator", o => o.creator, (o, v) => o.creator = v)
                .column<DateTime?>("last_terminal_watermark", o => o.last_terminal_watermark, (o, v) => o.last_terminal_watermark = v)
                .column<DateTime?>("created_at", o => o.created_at, (o, v) => o.created_at = v)
                .column<DateTime?>("started_at", o => o.started_at, (o, v) => o.started_at = v)
                .column<DateTime?>("completed_at", o => o.completed_at, (o, v) => o.completed_at = v)
                .column<DateTime?>("paused_at", o => o.paused_at, (o, v) => o.paused_at = v)
                .column<bool>("force_wake", o => o.force_wake, (o, v) => o.force_wake = v);
        }
    }

    /** A project link on a goal (`goal_links`): co-developed or reference. */
    public class GoalLink : Object {

        public int64 id { get; set; }
        public int64 goal_id { get; set; }
        public int64 project_id { get; set; }
        public string relationship { get; set; default = "reference"; }

        public static void entity_mapping(EntityMapperBuilder<GoalLink> cfg) {
            cfg.table("goal_links")
                .column<int64?>("id", o => o.id, (o, v) => o.id = v)
                .column<int64?>("goal_id", o => o.goal_id, (o, v) => o.goal_id = v)
                .column<int64?>("project_id", o => o.project_id, (o, v) => o.project_id = v)
                .column<string>("relationship", o => o.relationship, (o, v) => o.relationship = v);
        }
    }

}