Something went wrong. Try again.
Monorepo for Tangled forked from tangled.org/core
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129import { createBobbinClient, type BobbinContext } from "$lib/api/client";import { branches as knotMirrorBranches, blob as knotMirrorBlob, blobRawUrl as knotMirrorBlobRawUrl, createKnotMirrorClient, languages as knotMirrorLanguages, log as knotMirrorLog, getTag as knotMirrorGetTag, tags as knotMirrorTags, tree as knotMirrorTree} from "$lib/api/knotmirror";import { blob as knotBlob, blobRawUrl as knotBlobRawUrl, getDefaultBranch, languages as knotLanguages, tree as knotTree} from "$lib/api/knot";import { branchesFor, logFor, tagFor, tagsFor } from "$lib/api/repo";import type { Did, ResourceUri } from "@atcute/lexicons";
export interface GitServiceConfig { bobbinUrl: string; knotMirrorUrl: string;}
export interface GitTarget { ctx: BobbinContext; bobbin: BobbinContext; repo: Did | ResourceUri; via: "mirror" | "bobbin";}
export const knotMirrorTarget = ( config: GitServiceConfig, repo: { repoDid: string }, fetch: typeof globalThis.fetch): GitTarget => { if (!config.knotMirrorUrl) throw new Error("No knot mirror is configured"); return { ctx: createKnotMirrorClient(config.knotMirrorUrl, fetch), bobbin: createBobbinClient({ serviceUrl: config.bobbinUrl, fetch }), repo: repo.repoDid as Did, via: "mirror" };};
export const gitTarget = ( config: GitServiceConfig, repo: { uri: string; repoDid?: string }, fetch: typeof globalThis.fetch): GitTarget => { if (config.knotMirrorUrl && repo.repoDid) { return knotMirrorTarget(config, { repoDid: repo.repoDid }, fetch); } const bobbin = createBobbinClient({ serviceUrl: config.bobbinUrl, fetch }); return { ctx: bobbin, bobbin, repo: repo.uri as ResourceUri, via: "bobbin" };};
// the mirror has no getDefaultBranch, the default falls out of the branch// list's is_default flag insteadexport const resolveDefaultBranch = ( target: GitTarget, init?: { signal?: AbortSignal }): Promise<string | null> => target.via === "mirror" ? (async () => { for (let offset = 0; ; offset += 100) { const response = await knotMirrorBranches( target.ctx, { repo: target.repo, limit: 100, cursor: offset ? `${offset}` : undefined }, init ); const list = response.branches ?? []; const found = list.find((branch) => branch.is_default)?.reference.name; if (found) return found; if (list.length < 100) return null; } })().catch(() => null) : getDefaultBranch(target.ctx, { repo: target.repo }) .then((branch) => branch.name) .catch(() => null);
export const tree = (target: GitTarget, params: { ref: string; path?: string }) => target.via === "mirror" ? knotMirrorTree(target.bobbin, target.ctx, { repo: target.repo, ...params }) : knotTree(target.ctx, { repo: target.repo, ...params });
export const log = (target: GitTarget, params: { ref: string; limit: number; cursor?: string }) => target.via === "mirror" ? knotMirrorLog(target.ctx, { repo: target.repo, ...params }) : logFor(target.ctx, target.repo, params.ref, params.limit, params.cursor);
export const branches = (target: GitTarget, limit: number, cursor?: string) => target.via === "mirror" ? knotMirrorBranches(target.ctx, { repo: target.repo, limit, cursor }) : branchesFor(target.ctx, target.repo, limit, cursor);
export const tags = (target: GitTarget, limit: number, cursor?: string) => target.via === "mirror" ? knotMirrorTags(target.ctx, { repo: target.repo, limit, cursor }) : tagsFor(target.ctx, target.repo, limit, cursor);
export const tag = (target: GitTarget, name: string) => target.via === "mirror" ? knotMirrorGetTag(target.ctx, { repo: target.repo, tag: name }) : tagFor(target.ctx, target.repo, name);
export const languages = ( target: GitTarget, ref: string): Promise<{ languages?: { name: string; size: number }[] | null }> => target.via === "mirror" ? knotMirrorLanguages(target.ctx, { repo: target.repo, ref }) : knotLanguages(target.ctx, { repo: target.repo, ref });
// only the mirror needs the inline cap, the knot enforces its own and 413s// past itexport const blob = (target: GitTarget, params: { ref: string; path: string }, maxBytes: number) => target.via === "mirror" ? knotMirrorBlob(target.bobbin, target.ctx, { repo: target.repo, ...params }, maxBytes) : knotBlob(target.ctx, { repo: target.repo as ResourceUri, ...params });
export const blobRawUrl = (target: GitTarget, params: { ref: string; path: string }): string => target.via === "mirror" ? knotMirrorBlobRawUrl(target.ctx.serviceUrl, { repo: target.repo, ...params }) : knotBlobRawUrl(target.ctx.serviceUrl, { repo: target.repo, ...params });