Sign in

flagon-io/g1t

public

g1t/services/work/src/rows.rs

241 lines7,068 bytesCodeBlame

Pick any line to see why it is the way it is: the commit, the pull request and issue it came from, and what the agent was thinking.

Work service in Rust, with RFC 3339 timestamps1//! Rows as they come out of D1, and their conversion to contract types.
2
3use g1t_contracts::User;
4use g1t_contracts::repos::RepoPath;
5use g1t_contracts::work::{
Agents as a team: lifecycle, merge queue, billing and a new shell6 CheckStatus, Comment, CommentKind, Issue, IssueReason, Pull, PullStatus, Runtime, SessionEntry,
Acceptance checks in sandboxes, line comments and review verdicts7 SessionEntryKind, State, Verdict,
Work service in Rust, with RFC 3339 timestamps8};
9use serde::Deserialize;
10
Agents as a team: lifecycle, merge queue, billing and a new shell11pub(crate) fn user(id: String, username: String) -> User {
Issues and pull requests replace intents and attempts12 User {
13 id,
14 username,
15 ..User::default()
16 }
17}
18
Work service in Rust, with RFC 3339 timestamps19#[derive(Deserialize)]
Issues and pull requests replace intents and attempts20pub struct IssueRow {
Work service in Rust, with RFC 3339 timestamps21 pub id: String,
22 pub repo_id: String,
23 pub number: u32,
24 pub title: String,
Issues and pull requests replace intents and attempts25 pub body: String,
26 /// JSON array of label names.
27 pub labels: String,
Work service in Rust, with RFC 3339 timestamps28 /// JSON array of commands.
29 pub checks: String,
Issues and pull requests replace intents and attempts30 pub state: State,
31 pub reason: Option<IssueReason>,
32 pub resolved_by: Option<u32>,
Work service in Rust, with RFC 3339 timestamps33 pub author_id: String,
34 pub author_name: String,
35 pub created_at: String,
Issues and pull requests replace intents and attempts36 pub updated_at: String,
37 pub closed_at: Option<String>,
38 pub pull_count: u32,
39 pub comment_count: u32,
Agents as a team: lifecycle, merge queue, billing and a new shell40 /// JSON array of usernames.
41 pub assignees: String,
42 /// JSON array of issue numbers.
43 pub blocked_by: String,
44 /// JSON of who queued it for a g1t agent, if anyone has.
45 pub queued_by: Option<String>,
46 pub agent: Option<String>,
Work service in Rust, with RFC 3339 timestamps47}
48
Issues and pull requests replace intents and attempts49impl From<IssueRow> for Issue {
50 fn from(row: IssueRow) -> Self {
51 Issue {
Work service in Rust, with RFC 3339 timestamps52 id: row.id,
53 repo_id: row.repo_id,
54 number: row.number,
55 title: row.title,
Issues and pull requests replace intents and attempts56 body: row.body,
57 labels: serde_json::from_str(&row.labels).unwrap_or_default(),
Work service in Rust, with RFC 3339 timestamps58 checks: serde_json::from_str(&row.checks).unwrap_or_default(),
Issues and pull requests replace intents and attempts59 state: row.state,
60 reason: row.reason,
61 resolved_by: row.resolved_by,
62 author: user(row.author_id, row.author_name),
Work service in Rust, with RFC 3339 timestamps63 created_at: row.created_at,
Issues and pull requests replace intents and attempts64 updated_at: row.updated_at,
65 closed_at: row.closed_at,
66 pull_count: row.pull_count,
67 comment_count: row.comment_count,
Agents as a team: lifecycle, merge queue, billing and a new shell68 assignees: serde_json::from_str(&row.assignees).unwrap_or_default(),
69 blocked_by: serde_json::from_str(&row.blocked_by).unwrap_or_default(),
70 queued: row.queued_by.is_some(),
71 agent: row.agent,
Work service in Rust, with RFC 3339 timestamps72 }
73 }
74}
75
Agents as a team: lifecycle, merge queue, billing and a new shell76/// The remembered assessment of a pull request, read beside its row.
Work service in Rust, with RFC 3339 timestamps77#[derive(Deserialize)]
Agents as a team: lifecycle, merge queue, billing and a new shell78pub struct Snapshot {
79 pub stage: Option<g1t_contracts::work::Stage>,
80 pub stage_detail: Option<String>,
81 #[serde(default)]
82 pub revisions: u32,
83 /// Whether g1t is seeing it through at all.
84 #[serde(default)]
85 pub managed: u32,
86}
87
Thirteen MCP tools and classic token scopes; agents rate their confidence and can be put on an issue in one step88/// A pull request's columns, with its confidence (confidence.rs) beside
89/// them: what every read of a [`PullRow`] selects.
90pub const PULL_COLUMNS: &str =
91 "pulls.*, (SELECT detail FROM pull_confidence WHERE pull_confidence.pull_id = pulls.id) AS confidence";
92
Agents as a team: lifecycle, merge queue, billing and a new shell93#[derive(Deserialize)]
Issues and pull requests replace intents and attempts94pub struct PullRow {
Work service in Rust, with RFC 3339 timestamps95 pub id: String,
96 pub repo_id: String,
97 pub number: u32,
Issues and pull requests replace intents and attempts98 pub issue_number: Option<u32>,
99 pub title: String,
100 pub body: Option<String>,
Work service in Rust, with RFC 3339 timestamps101 pub agent: String,
Issues and pull requests replace intents and attempts102 pub runtime: Runtime,
103 pub status: PullStatus,
Pull requests from branches104 pub fork_repo_id: Option<String>,
105 pub fork_namespace: Option<String>,
106 pub fork_name: Option<String>,
107 pub source_branch: Option<String>,
Work service in Rust, with RFC 3339 timestamps108 pub head_commit: Option<String>,
Issues and pull requests replace intents and attempts109 pub merge_base: Option<String>,
110 pub merged_by: Option<String>,
111 pub merged_at: Option<String>,
112 pub superseded_by: Option<u32>,
Acceptance checks in sandboxes, line comments and review verdicts113 pub check_status: Option<CheckStatus>,
Agents as a team: lifecycle, merge queue, billing and a new shell114 /// JSON array of changed files; `None` until first worked out.
115 pub files: Option<String>,
116 /// JSON arrays of usernames.
117 pub assignees: String,
118 pub reviewers: String,
Issues and pull requests replace intents and attempts119 pub author_id: String,
120 pub author_name: String,
Work service in Rust, with RFC 3339 timestamps121 pub created_at: String,
122 pub updated_at: String,
Thirteen MCP tools and classic token scopes; agents rate their confidence and can be put on an issue in one step123 /// JSON of its confidence, once worked out.
124 #[serde(default)]
125 pub confidence: Option<String>,
Work service in Rust, with RFC 3339 timestamps126}
127
Issues and pull requests replace intents and attempts128impl From<PullRow> for Pull {
129 fn from(row: PullRow) -> Self {
130 Pull {
Work service in Rust, with RFC 3339 timestamps131 id: row.id,
132 repo_id: row.repo_id,
133 number: row.number,
Issues and pull requests replace intents and attempts134 issue: row.issue_number,
135 title: row.title,
136 body: row.body,
Work service in Rust, with RFC 3339 timestamps137 agent: row.agent,
138 runtime: row.runtime,
139 status: row.status,
Pull requests from branches140 fork: row
141 .fork_namespace
142 .zip(row.fork_name)
143 .map(|(namespace, name)| RepoPath { namespace, name }),
Work service in Rust, with RFC 3339 timestamps144 fork_repo_id: row.fork_repo_id,
Pull requests from branches145 branch: row.source_branch,
Work service in Rust, with RFC 3339 timestamps146 head_commit: row.head_commit,
Issues and pull requests replace intents and attempts147 merge_base: row.merge_base,
148 merged_by: row.merged_by,
149 merged_at: row.merged_at,
150 superseded_by: row.superseded_by,
Acceptance checks in sandboxes, line comments and review verdicts151 check_status: row.check_status,
Agents as a team: lifecycle, merge queue, billing and a new shell152 files: row
153 .files
154 .as_deref()
155 .and_then(|files| serde_json::from_str(files).ok())
156 .unwrap_or_default(),
157 assignees: serde_json::from_str(&row.assignees).unwrap_or_default(),
158 reviewers: serde_json::from_str(&row.reviewers).unwrap_or_default(),
Issues and pull requests replace intents and attempts159 author: user(row.author_id, row.author_name),
Work service in Rust, with RFC 3339 timestamps160 created_at: row.created_at,
161 updated_at: row.updated_at,
Thirteen MCP tools and classic token scopes; agents rate their confidence and can be put on an issue in one step162 confidence: row
163 .confidence
164 .as_deref()
165 .and_then(|detail| serde_json::from_str(detail).ok()),
Work service in Rust, with RFC 3339 timestamps166 }
167 }
168}
169
170#[derive(Deserialize)]
Issues and pull requests replace intents and attempts171pub struct CommentRow {
172 pub id: String,
Agents as a team: lifecycle, merge queue, billing and a new shell173 pub kind: CommentKind,
Issues and pull requests replace intents and attempts174 pub author_id: String,
175 pub author_name: String,
176 pub body: String,
Acceptance checks in sandboxes, line comments and review verdicts177 pub path: Option<String>,
178 pub line: Option<u32>,
179 pub verdict: Option<Verdict>,
Issues and pull requests replace intents and attempts180 pub created_at: String,
181}
182
183impl From<CommentRow> for Comment {
184 fn from(row: CommentRow) -> Self {
185 Comment {
186 id: row.id,
Agents as a team: lifecycle, merge queue, billing and a new shell187 kind: row.kind,
Issues and pull requests replace intents and attempts188 author: user(row.author_id, row.author_name),
189 body: row.body,
Acceptance checks in sandboxes, line comments and review verdicts190 path: row.path,
191 line: row.line,
192 verdict: row.verdict,
Issues and pull requests replace intents and attempts193 created_at: row.created_at,
194 }
195 }
196}
197
198#[derive(Deserialize)]
Work service in Rust, with RFC 3339 timestamps199pub struct SessionRow {
200 pub seq: u32,
201 pub kind: SessionEntryKind,
202 pub text: String,
203 pub tool: Option<String>,
204 pub commit: Option<String>,
205 pub at: String,
206}
207
208impl From<SessionRow> for SessionEntry {
209 fn from(row: SessionRow) -> Self {
210 SessionEntry {
211 seq: row.seq,
212 kind: row.kind,
213 text: row.text,
214 tool: row.tool,
215 commit: row.commit,
216 at: row.at,
217 }
218 }
219}
Issues and pull requests replace intents and attempts220
Acceptance checks in sandboxes, line comments and review verdicts221/// A pull request whose head a push moved.
222#[derive(Deserialize)]
223pub struct MovedRow {
224 pub id: String,
225 pub repo_id: String,
226 pub number: u32,
227 pub issue_number: Option<u32>,
228 pub status: PullStatus,
229}
230
Issues and pull requests replace intents and attempts231/// A single number selected as `n`.
232#[derive(Deserialize)]
233pub struct NumberRow {
234 pub n: u32,
235}
236
237/// A single string selected as `value`.
238#[derive(Deserialize)]
239pub struct ValueRow {
240 pub value: String,
241}