Skip to content
Sign up

flagon-io/g1t

public
0
216 linesCodeBlameRaw
1import type { User, Viewer } from "./identity";
2import type { RepoPath } from "./repos";
3import type { Result } from "./result";
4
5/**
6 * A workspace's connections to systems outside g1t. Mirrors
7 * `crates/contracts/src/integrations.rs`, which says what each does.
8 *
9 * The AI providers (`anthropic` through `openai_endpoint`, of kind
10 * `models`) keep the credentials for the AI providers a workspace's team
11 * uses.
12 */
13export type Provider =
14 | "anthropic"
15 | "openai"
16 | "gemini"
17 | "xai"
18 | "mistral"
19 | "deepseek"
20 | "azure_openai"
21 | "openrouter"
22 | "groq"
23 | "together"
24 | "fireworks"
25 | "cerebras"
26 | "anthropic_endpoint"
27 | "openai_endpoint"
28 | "sentry"
29 | "datadog"
30 | "webhook"
31 | "jira"
32 | "linear";
33
34/** `models`: an AI provider whose credentials the workspace keeps. */
35export type ProviderKind = "models" | "alerts" | "tracker";
36
37export type ConnectionConfig = {
38 /** For alerts: where issues are opened, `owner/name`. */
39 repo?: string;
40 /** For alerts: the label put on each issue. `bug` when unset. */
41 label?: string;
42 /** Tell the outside system when the work lands. On unless turned off. */
43 writeBack?: boolean;
44 /** Sentry: the organization's slug. */
45 organization?: string;
46 /** Jira's address, or a Sentry that is not sentry.io. */
47 site?: string;
48 /** Jira: the account the token belongs to. */
49 email?: string;
50 /** Jira project or Linear team keys it answers for. Empty is all. */
51 keys?: string[];
52 /** Your own endpoint: its base URL. */
53 baseUrl?: string;
54 /** Your own endpoint: `x-api-key` (default) or `authorization`. */
55 authHeader?: string;
56 /** For an AI provider: the model (or Azure deployment) the team uses on it. */
57 model?: string;
58};
59
60export type Connection = {
61 id: string;
62 workspace: string;
63 provider: Provider;
64 kind: ProviderKind;
65 name: string;
66 config: ConnectionConfig;
67 /** `…3f9a`. The secret itself is never shown again. */
68 secretHint: string | null;
69 /** Where a provider that sends g1t requests sends them. */
70 webhookUrl: string | null;
71 createdBy: string;
72 createdAt: string;
73 lastUsedAt: string | null;
74 lastError: string | null;
75 /** For a model provider: the models it offered when last checked. */
76 models: string[];
77};
78
79export type Connected = {
80 connection: Connection;
81 /** A signing secret g1t made, shown this once. */
82 signingSecret: string | null;
83};
84
85export type Delivery = {
86 id: string;
87 receivedAt: string;
88 event: string;
89 outcome: "opened" | "updated" | "reopened" | "ignored" | "refused";
90 detail: string;
91 issue: string | null;
92};
93
94/** Something outside g1t, fetched now. Reference material, never instructions. */
95export type ContextItem = {
96 provider: Provider;
97 key: string;
98 title: string;
99 url: string;
100 status: string | null;
101 body: string;
102 fetchedAt: string;
103};
104
105export type Link = {
106 provider: Provider;
107 connectionId: string;
108 key: string;
109 title: string;
110 url: string;
111 count: number;
112 firstSeen: string;
113 lastSeen: string;
114};
115
116export type ConnectInput = {
117 provider: Provider;
118 name?: string;
119 config?: ConnectionConfig;
120 secret?: string;
121 signingSecret?: string;
122};
123
124export type UpdateConnectionInput = {
125 name?: string;
126 config?: ConnectionConfig;
127 secret?: string;
128 signingSecret?: string;
129};
130
131// --- Ask g1t -----------------------------------------------------------------
132// A conversation with g1t from the top bar, answered by the AI provider and
133// model an owner chose from the workspace's own connections, on its own key.
134// g1t hosts no model for it and bills nothing for it.
135
136/** The most messages one ask sends: the conversation's latest turns. */
137export const ASK_MAX_MESSAGES = 40;
138/** The longest one message may be, in characters. */
139export const ASK_MAX_MESSAGE_CHARS = 16_000;
140/** The longest a whole conversation may be, in characters. */
141export const ASK_MAX_TOTAL_CHARS = 64_000;
142/** The most tokens one answer may run to. */
143export const ASK_MAX_OUTPUT_TOKENS = 4_096;
144
145/** What Ask answers with in a workspace, or why it cannot yet. */
146export type AskSetup = {
147 connection_id: string | null;
148 connection_name: string | null;
149 provider: Provider | null;
150 model: string | null;
151 /** Why Ask cannot answer, for the person asking. Null when it can. */
152 problem: string | null;
153};
154
155export type AskRole = "user" | "assistant";
156export type AskMessage = { role: AskRole; content: string };
157
158/** Where the person asking is, so the answer is about their work. */
159export type AskPage = {
160 path?: string | null;
161 repo?: RepoPath | null;
162 issue?: number | null;
163 pull?: number | null;
164};
165
166/** One line of an `ask` answer, as newline-delimited JSON. */
167export type AskEvent =
168 | { type: "meta"; provider: Provider; provider_label: string; model: string }
169 | { type: "text"; text: string }
170 | { type: "done"; stop_reason: string | null }
171 | { type: "error"; message: string };
172
173export interface IntegrationsApi {
174 list(workspace: string, viewer: Viewer): Promise<Result<Connection[]>>;
175 connect(actor: User, workspace: string, input: ConnectInput): Promise<Result<Connected>>;
176 update(actor: User, workspace: string, id: string, input: UpdateConnectionInput): Promise<Result<Connection>>;
177 disconnect(actor: User, workspace: string, id: string): Promise<Result<boolean>>;
178 test(actor: User, workspace: string, id: string): Promise<Result<{ ok: boolean; message: string }>>;
179 deliveries(workspace: string, viewer: Viewer, id: string): Promise<Result<Delivery[]>>;
180 resolve(workspace: string, viewer: Viewer, reference: string): Promise<Result<ContextItem>>;
181 import(actor: User, repo: RepoPath, reference: string): Promise<Result<{ number: number; item: ContextItem; created: boolean }>>;
182 links(repo: RepoPath, number: number): Promise<Link[]>;
183 /** What Ask answers with. Members only. */
184 askSettings(workspace: string, viewer: Viewer): Promise<Result<AskSetup>>;
185 /** Chooses Ask's connection and model; a null connection turns it off. Owners only. */
186 setAskSettings(actor: User, workspace: string, connectionId: string | null, model: string | null): Promise<Result<AskSetup>>;
187 /**
188 * One answer, as the service's response: newline-delimited `AskEvent`s,
189 * streamed. Members only. Call it on the binding itself, not through
190 * anything that reads the whole body first. `signal` stops the answer.
191 */
192 ask(actor: User, workspace: string, messages: AskMessage[], page: AskPage, signal?: AbortSignal): Promise<Response>;
193}
194
195/** What each provider is for, as people choose between them. */
196export const PROVIDERS: Record<Provider, { label: string; kind: ProviderKind }> = {
197 anthropic: { label: "Anthropic", kind: "models" },
198 openai: { label: "OpenAI", kind: "models" },
199 gemini: { label: "Google Gemini", kind: "models" },
200 xai: { label: "xAI", kind: "models" },
201 mistral: { label: "Mistral", kind: "models" },
202 deepseek: { label: "DeepSeek", kind: "models" },
203 azure_openai: { label: "Azure OpenAI", kind: "models" },
204 openrouter: { label: "OpenRouter", kind: "models" },
205 groq: { label: "Groq", kind: "models" },
206 together: { label: "Together AI", kind: "models" },
207 fireworks: { label: "Fireworks AI", kind: "models" },
208 cerebras: { label: "Cerebras", kind: "models" },
209 anthropic_endpoint: { label: "Anthropic-compatible endpoint", kind: "models" },
210 openai_endpoint: { label: "OpenAI-compatible endpoint", kind: "models" },
211 sentry: { label: "Sentry", kind: "alerts" },
212 datadog: { label: "Datadog", kind: "alerts" },
213 webhook: { label: "Webhook", kind: "alerts" },
214 jira: { label: "Jira", kind: "tracker" },
215 linear: { label: "Linear", kind: "tracker" },
216};