75 lines
1.8 KiB
TypeScript
75 lines
1.8 KiB
TypeScript
|
import git from 'isomorphic-git';
|
|||
|
|
import { HttpClient } from 'isomorphic-git/http/node';
|
|||
|
|
|
|||
|
|
import { bodyToBuffer } from './util';
|
|||
|
|
import { Pointer } from './pointers';
|
|||
|
|
|
|||
|
|
|
|||
|
|
interface DownloadBlobRequset {
|
|||
|
|
http: HttpClient;
|
|||
|
|
headers?: Record<string, any>;
|
|||
|
|
|
|||
|
|
/** Repository URL. */
|
|||
|
|
url: string;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
interface LFSInfoResponse {
|
|||
|
|
objects: {
|
|||
|
|
actions: {
|
|||
|
|
download: {
|
|||
|
|
href: string;
|
|||
|
|
};
|
|||
|
|
};
|
|||
|
|
}[];
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function isValidLFSInfoResponseData(val: Record<string, any>): val is LFSInfoResponse {
|
|||
|
|
return val.objects?.[0]?.actions?.download?.href?.trim !== undefined;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/** Downloads a blob corresponding to given LFS pointer. */
|
|||
|
|
export default async function downloadBlobFromPointer(
|
|||
|
|
{ http: { request }, headers = {}, url }: DownloadBlobRequset,
|
|||
|
|
{ info, objectPath }: Pointer
|
|||
|
|
): Promise<Buffer> {
|
|||
|
|
// Request LFS metadata
|
|||
|
|
|
|||
|
|
const lfsInfoRequestData = {
|
|||
|
|
operation: 'download',
|
|||
|
|
transfers: ['basic'],
|
|||
|
|
objects: [info],
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
const { body: lfsInfoBody } = await request({
|
|||
|
|
url: `${url}/info/lfs/objects/batch`,
|
|||
|
|
method: 'POST',
|
|||
|
|
headers: {
|
|||
|
|
'User-Agent': `git/isomorphic-git@${git.version()}`,
|
|||
|
|
...headers,
|
|||
|
|
'Accept': 'application/vnd.git-lfs+json',
|
|||
|
|
'Content-Type': 'application/vnd.git-lfs+json',
|
|||
|
|
},
|
|||
|
|
body: [Buffer.from(JSON.stringify(lfsInfoRequestData))],
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
const lfsInfoResponseData = JSON.parse((await bodyToBuffer(lfsInfoBody)).toString());
|
|||
|
|
|
|||
|
|
if (isValidLFSInfoResponseData(lfsInfoResponseData)) {
|
|||
|
|
|
|||
|
|
// Request the actual blob
|
|||
|
|
const lfsObjectDownloadURL = lfsInfoResponseData.objects[0].actions.download.href;
|
|||
|
|
|
|||
|
|
const { body: lfsObjectBody } = await request({
|
|||
|
|
url: lfsObjectDownloadURL,
|
|||
|
|
method: 'GET',
|
|||
|
|
headers,
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
return await bodyToBuffer(lfsObjectBody);
|
|||
|
|
|
|||
|
|
} else {
|
|||
|
|
throw new Error("LFS response didn’t return an expected structure");
|
|||
|
|
}
|
|||
|
|
}
|