Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224import type { BobbinContext, XrpcRequestInit } from "$lib/api/client";import { createBobbinClient } from "$lib/api/client";import { buildUrl, jsonGet, rawGet } from "$lib/api/_request";import type { RepoTagResponse } from "$lib/api/repo";import type * as RepoBlob from "$lib/api/lexicons/types/sh/tangled/repo/blob";import type * as GitDefs from "$lib/api/lexicons/types/sh/tangled/git/temp/defs";import type * as MirrorBranch from "$lib/api/lexicons/types/org/tangled/temp/git/getBranch";import type * as MirrorEntry from "$lib/api/lexicons/types/org/tangled/temp/git/getEntry";import type * as MirrorTree from "$lib/api/lexicons/types/org/tangled/temp/git/getTree";import type * as Tree from "$lib/api/lexicons/types/sh/tangled/repo/tree";import { treeEntryKind, type BranchesResponse, type LogResponse, type TagsResponse} from "$lib/api/repo";
const TREE_NSID = "org.tangled.temp.git.getTree";const ENTRY_NSID = "org.tangled.temp.git.getEntry";const MERGE_BASE_NSID = "org.tangled.temp.git.getMergeBase";const GET_BRANCH_NSID = "org.tangled.temp.git.getBranch";
const BLOB_NSID = "sh.tangled.git.temp.getBlob";const FORMAT_PATCH_NSID = "sh.tangled.git.temp.formatPatch";const LOG_NSID = "sh.tangled.git.temp.listCommits";const BRANCHES_NSID = "sh.tangled.git.temp.listBranches";const TAGS_NSID = "sh.tangled.git.temp.listTags";const LANGUAGES_NSID = "sh.tangled.git.temp.listLanguages";const GET_TAG_NSID = "sh.tangled.git.temp.getTag";
const MAX_README_BYTES = 1 << 20;
export interface KnotMirrorLanguagesResponse { languages?: { name: string; size: number }[]; total?: number; ref?: string;}
export const createKnotMirrorClient = (serviceUrl: string, fetch: typeof globalThis.fetch) => createBobbinClient({ serviceUrl, fetch });
export const entry = ( bobbin: BobbinContext, params: { repo: string; ref: string; path: string }, init?: XrpcRequestInit) => jsonGet<MirrorEntry.$output>(bobbin, ENTRY_NSID, params, init);
export const blobRawUrl = ( serviceUrl: string, params: { repo: string; ref: string; path: string }): string => buildUrl(serviceUrl, BLOB_NSID, params).toString();
// the mirror streams `git format-patch --stdout` for a range, which is the only// way to get a large diff in one response: the knot builds the whole thing as// json first and refuses anything past its 5MB response ceilingexport const formatPatchUrl = ( serviceUrl: string, params: { repo: string; from: string; to: string }): string => buildUrl(serviceUrl, FORMAT_PATCH_NSID, params).toString();
type LastCommit = { hash: string; message: string; when: string; author?: { name: string; email: string; when: string };};
const normalizeCommit = (commit: GitDefs.Commit | undefined): LastCommit | undefined => commit ? { hash: commit.hash, message: commit.message, when: commit.committer?.when ?? commit.author?.when ?? "", author: commit.author ? { name: commit.author.name, email: commit.author.email, when: commit.author.when } : undefined } : undefined;
const normalizeTree = (tree: MirrorTree.$output, ref: string): Tree.$output => ({ ref, lastCommit: normalizeCommit(tree.lastCommit), files: tree.entries.map((entry) => ({ name: entry.name, mode: entry.mode, size: entry.size, last_commit: normalizeCommit(entry.lastCommit) }))});
// same heuristic as git: a null byte in the first chunk means binaryconst looksBinary = (bytes: Uint8Array): boolean => bytes.subarray(0, 8000).includes(0);
// temp.getBlob answers raw bytes only, metadata comes from getEntry and// the binary flag from a content sniffexport const blob = async ( bobbin: BobbinContext, ctx: BobbinContext, params: { repo: string; ref: string; path: string }, maxBytes: number, init?: XrpcRequestInit): Promise<RepoBlob.$output> => { const meta = await entry(bobbin, params, init); const lastCommit = normalizeCommit(meta.lastCommit);
// a gitlink is a submodule pointer, not a file if (treeEntryKind(meta.mode) === "submodule") { return { path: params.path, ref: params.ref, size: meta.size, submodule: { name: meta.name, url: "" } }; }
if (meta.size !== undefined && meta.size > maxBytes) { return { path: params.path, ref: params.ref, size: meta.size, fileTooLarge: true, lastCommit }; }
const bytes = new Uint8Array(await (await rawGet(ctx, BLOB_NSID, params, init)).arrayBuffer()); if (looksBinary(bytes)) { return { path: params.path, ref: params.ref, size: meta.size ?? bytes.length, isBinary: true, lastCommit }; }
return { path: params.path, ref: params.ref, size: meta.size ?? bytes.length, isBinary: false, encoding: "utf-8", content: new TextDecoder().decode(bytes), lastCommit };};
const isReadmeFile = (name: string, mode: string): boolean => /^readme(?:\.[^.]+)?$/i.test(name) && treeEntryKind(mode) === "file";
const pathInTree = (path: string | undefined, name: string): string => path ? `${path}/${name}` : name;
export const tree = async ( bobbin: BobbinContext, ctx: BobbinContext, params: { repo: string; ref: string; path?: string }, init?: XrpcRequestInit): Promise<Tree.$output> => { const response = await jsonGet<MirrorTree.$output>(bobbin, TREE_NSID, params, init); const result = normalizeTree(response, params.ref); const readme = response.entries.find((entry) => isReadmeFile(entry.name, entry.mode)); if (!readme) return result; if (readme.size !== undefined && readme.size > MAX_README_BYTES) return result;
try { const blob = await rawGet( ctx, BLOB_NSID, { repo: params.repo, ref: params.ref, path: pathInTree(params.path, readme.name) }, init ); return { ...result, readme: { filename: readme.name, contents: await blob.text() } }; } catch { return result; }};
export const log = ( ctx: BobbinContext, params: { repo: string; ref: string; limit: number; cursor?: string }, init?: XrpcRequestInit) => jsonGet<LogResponse>(ctx, LOG_NSID, params, init);
export const branches = ( ctx: BobbinContext, params: { repo: string; limit: number; cursor?: string }, init?: XrpcRequestInit) => jsonGet<BranchesResponse>(ctx, BRANCHES_NSID, params, init);
export const tags = ( ctx: BobbinContext, params: { repo: string; limit: number; cursor?: string }, init?: XrpcRequestInit) => jsonGet<TagsResponse>(ctx, TAGS_NSID, params, init);
export const getTag = ( ctx: BobbinContext, params: { repo: string; tag: string }, init?: XrpcRequestInit) => jsonGet<RepoTagResponse>(ctx, GET_TAG_NSID, params, init);
export const languages = ( ctx: BobbinContext, params: { repo: string; ref: string }, init?: XrpcRequestInit) => jsonGet<KnotMirrorLanguagesResponse>(ctx, LANGUAGES_NSID, params, init);
export const getMergeBase = ( bobbin: BobbinContext, params: { repo: string; base: string; head: string }, init?: XrpcRequestInit) => jsonGet<{ commit: string }>(bobbin, MERGE_BASE_NSID, params, init);
export const getBranch = ( bobbin: BobbinContext, params: { repo: string; name: string }, init?: XrpcRequestInit) => jsonGet<MirrorBranch.$output>(bobbin, GET_BRANCH_NSID, params, init);