Spaces:
Sleeping
Sleeping
File size: 3,896 Bytes
a5d1c1b 61b1da1 a5d1c1b | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 | import fs from 'node:fs';
import path from 'node:path';
import crypto from 'node:crypto';
import { isBinaryOrIgnoredFile } from '@ever-brain/api/utils/binary-filter.js';
import { projectConfigManager } from '../config/project-config.js';
export interface LocalModifications {
modified: string[];
added: string[];
deleted: string[];
isDirty: boolean;
}
export function computeSha256(content: string): string {
return crypto.createHash('sha256').update(content, 'utf8').digest('hex');
}
export function normalizePosixPath(filePath: string): string {
return filePath.replace(/\\/g, '/').replace(/^\/+/, '');
}
export class CacheService {
readCachedFile(workspaceRoot: string, relativePath: string): string | null {
const cleanPath = normalizePosixPath(relativePath);
const fullPath = path.join(projectConfigManager.getCacheDirPath(workspaceRoot), cleanPath);
if (!fs.existsSync(fullPath)) {
return null;
}
return fs.readFileSync(fullPath, 'utf8');
}
writeCachedFile(workspaceRoot: string, relativePath: string, content: string): void {
const cleanPath = normalizePosixPath(relativePath);
const fullPath = path.join(projectConfigManager.getCacheDirPath(workspaceRoot), cleanPath);
const dirName = path.dirname(fullPath);
if (!fs.existsSync(dirName)) {
fs.mkdirSync(dirName, { recursive: true });
}
fs.writeFileSync(fullPath, content, 'utf8');
}
deleteCachedFile(workspaceRoot: string, relativePath: string): void {
const cleanPath = normalizePosixPath(relativePath);
const fullPath = path.join(projectConfigManager.getCacheDirPath(workspaceRoot), cleanPath);
if (fs.existsSync(fullPath)) {
fs.unlinkSync(fullPath);
}
}
listCachedFiles(workspaceRoot: string): string[] {
const cacheDir = projectConfigManager.getCacheDirPath(workspaceRoot);
if (!fs.existsSync(cacheDir)) {
return [];
}
const results: string[] = [];
const walk = (currentDir: string) => {
const entries = fs.readdirSync(currentDir, { withFileTypes: true });
for (const entry of entries) {
const fullPath = path.join(currentDir, entry.name);
if (entry.isDirectory()) {
walk(fullPath);
} else if (entry.isFile()) {
const relPath = normalizePosixPath(path.relative(cacheDir, fullPath));
if (!isBinaryOrIgnoredFile(relPath)) {
results.push(relPath);
}
}
}
};
walk(cacheDir);
return results.sort();
}
computeDirtyState(workspaceRoot: string): LocalModifications {
const state = projectConfigManager.readState(workspaceRoot);
const baselineFiles = state?.files || {};
const localFiles = this.listCachedFiles(workspaceRoot);
const localFileSet = new Set(localFiles);
const baselineFileSet = new Set(Object.keys(baselineFiles));
const modified: string[] = [];
const added: string[] = [];
const deleted: string[] = [];
// Check existing local files for additions and modifications
for (const file of localFiles) {
const content = this.readCachedFile(workspaceRoot, file);
if (content === null) continue;
const currentHash = computeSha256(content);
if (!baselineFileSet.has(file)) {
added.push(file);
} else {
const baselineHash = baselineFiles[file];
if (currentHash !== baselineHash) {
modified.push(file);
}
}
}
// Check for deleted baseline files
for (const baselineFile of Object.keys(baselineFiles)) {
if (!localFileSet.has(baselineFile)) {
deleted.push(baselineFile);
}
}
return {
modified: modified.sort(),
added: added.sort(),
deleted: deleted.sort(),
isDirty: modified.length > 0 || added.length > 0 || deleted.length > 0,
};
}
}
export const cacheService = new CacheService();
|