Something went wrong. Try again.
Monorepo for Tangled tangled.org
Something went wrong. Try again.
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495import { ok } from "@atcute/client";import { mainSchema as putRecordSchema } from "@atcute/atproto/types/repo/putRecord";import { mainSchema as deleteRecordSchema } from "@atcute/atproto/types/repo/deleteRecord";import type { Nsid, RecordKey } from "@atcute/lexicons/syntax";import type { OAuthUserAgent } from "@atcute/oauth-browser-client";import { createClient } from "$lib/auth/agent";import type { BobbinContext, XrpcRequestInit } from "./client";import { jsonGet } from "./_request";import type { RecordList, RecordView } from "./records";import type * as ShTangledRepoIssue from "./lexicons/types/sh/tangled/repo/issue";import type * as ShTangledRepoIssueState from "./lexicons/types/sh/tangled/repo/issue/state";
export type IssueRecord = ShTangledRepoIssue.Main;export type IssueStateRecord = ShTangledRepoIssueState.Main;
const ISSUE_COLLECTION = "sh.tangled.repo.issue" as Nsid;
export const putIssue = async ( agent: OAuthUserAgent, rkey: string, record: IssueRecord): Promise<RecordView<IssueRecord>> => { const rpc = createClient(agent); const { uri, cid } = await ok( rpc.call(putRecordSchema, { input: { repo: agent.sub, collection: ISSUE_COLLECTION, rkey: rkey as RecordKey, record } }) ); return { uri, cid, value: record };};
export const deleteIssue = async (agent: OAuthUserAgent, rkey: string): Promise<void> => { const rpc = createClient(agent); await ok( rpc.call(deleteRecordSchema, { input: { repo: agent.sub, collection: ISSUE_COLLECTION, rkey: rkey as RecordKey } }) );};
export const getIssue = (ctx: BobbinContext, issue: string, init?: XrpcRequestInit) => jsonGet<RecordView<IssueRecord>>(ctx, "sh.tangled.repo.getIssue", { issue }, init);
export const getIssues = (ctx: BobbinContext, issues: readonly string[], init?: XrpcRequestInit) => jsonGet<RecordList<IssueRecord>>(ctx, "sh.tangled.repo.getIssues", { issues }, init);
export type IssueState = "open" | "closed";
// a listIssues row: the embedded issue record plus bobbin-derived state/counts.export interface IssueListItem { cid?: string; commentCount: number; state: string; stateUpdatedAt?: string; uri: string; value: IssueRecord;}
export interface IssueListPage { cursor?: string | null; items: IssueListItem[];}
export interface ListIssuesFilter { state?: IssueState; author?: string; limit?: number; cursor?: string; order?: "asc" | "desc";}
export const listIssues = ( ctx: BobbinContext, subject: string, filter: ListIssuesFilter = {}, init?: XrpcRequestInit) => jsonGet<IssueListPage>(ctx, "sh.tangled.repo.listIssues", { subject, ...filter }, init);
export interface IssueStateList { cursor?: string | null; items: RecordView<IssueStateRecord>[];}
export const listIssueStates = ( ctx: BobbinContext, subject: string, filter: { limit?: number; cursor?: string; order?: "asc" | "desc" } = {}, init?: XrpcRequestInit) => jsonGet<IssueStateList>(ctx, "sh.tangled.repo.issue.listStates", { subject, ...filter }, init);