gitbutlerapp/gitbutler
1
1
Fork 0
mirror of https://github.com/gitbutlerapp/gitbutler.git synced 2024-12-24 18:12:48 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix deltas cache

Browse Source
This commit is contained in:
Nikita Galaiko 2023-04-19 08:05:31 +02:00
parent c0048936aa
commit 72310d6a84
1 changed files with 19 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/lib/deltas.ts
View File

@ -23,29 +23,31 @@ export type DeltasEvent = {
filePath: string;
};
const cache: Record<string, Promise<Record<string, Delta[]>>> = {};
const cache: Record<string, Record<string, Promise<Record<string, Delta[]>>>> = {};
export const list = async (params: { projectId: string; sessionId: string; paths?: string[] }) => {
const cacheKey = `${params.projectId}/${params.sessionId}`;
if (cacheKey in cache) {
return cache[cacheKey].then((deltas) =>
Object.fromEntries(
Object.entries(deltas).filter(([path]) =>
const sessionDeltasCache = cache[params.projectId] || {};
if (params.sessionId in sessionDeltasCache) {
return sessionDeltasCache[params.sessionId].then((files) => {
return Object.fromEntries(
Object.entries(files).filter(([path]) =>
params.paths ? params.paths.includes(path) : true
)
)
);
);
});
}
const deltas = invoke<Record<string, Delta[]>>('list_deltas', {
projectId: params.projectId,
sessionId: params.sessionId
const promise = invoke<Record<string, Delta[]>>('list_deltas', {
sessionId: params.sessionId,
projectId: params.projectId
});
sessionDeltasCache[params.sessionId] = promise;
cache[params.projectId] = sessionDeltasCache;
return promise.then((files) => {
return Object.fromEntries(
Object.entries(files).filter(([path]) => (params.paths ? params.paths.includes(path) : true))
);
});
cache[cacheKey] = deltas;
return deltas.then((deltas) =>
Object.fromEntries(
Object.entries(deltas).filter(([path]) => (params.paths ? params.paths.includes(path) : true))
)
);
};
export const subscribe = (