Nulo/isogit-lfs
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Activity

chore(download): write downloaded blob to LFS cache

Browse source
This commit is contained in:
Anton Strogonoff 2021-11-29 02:56:58 +01:00
parent c3ccd39671
commit 73fd547892
1 changed files with 15 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
src/download.ts
View file

@ -1,6 +1,8 @@
import path from 'path';
import fsp from 'fs/promises';
import { HttpClient } from 'isomorphic-git/http/node'; import { HttpClient } from 'isomorphic-git/http/node';
import { bodyToBuffer } from './util'; import { bodyToBuffer, isWriteable } from './util';
import { Pointer } from './pointers'; import { Pointer } from './pointers';
@ -28,7 +30,9 @@ function isValidLFSInfoResponseData(val: Record<string, any>): val is LFSInfoRes
} }
/** Downloads a blob corresponding to given LFS pointer. */ /**
* Downloads, caches and returns a blob corresponding to given LFS pointer.
*/
export default async function downloadBlobFromPointer( export default async function downloadBlobFromPointer(
{ http: { request }, headers = {}, url }: DownloadBlobRequset, { http: { request }, headers = {}, url }: DownloadBlobRequset,
{ info, objectPath }: Pointer, { info, objectPath }: Pointer,
@ -73,7 +77,15 @@ export default async function downloadBlobFromPointer(
headers: dlHeaders, headers: dlHeaders,
}); });
return await bodyToBuffer(lfsObjectBody); const blob = await bodyToBuffer(lfsObjectBody);
// Write LFS cache for this object, if cache path is still accessible and unoccupied.
if (await isWriteable(objectPath)) {
await fsp.mkdir(path.dirname(objectPath), { recursive: true });
await fsp.writeFile(objectPath, blob);
}
return blob;
} else { } else {
throw new Error("LFS response didn’t return an expected structure"); throw new Error("LFS response didn’t return an expected structure");