scriptoriumadmin/GitNexus
1
0
Fork 0
mirror of https://github.com/abhigyanpatwari/GitNexus.git synced 2026-09-12 23:02:45 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 10

style: run prettier on changed files

Browse source
This commit is contained in:
MekayelAnik 2026-04-14 16:00:41 +06:00
parent 1912a8aeb3
commit 20dc22d902
2 changed files with 49 additions and 22 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
gitnexus/src/core/lbug/lbug-adapter.ts
View file

@ -273,10 +273,16 @@ export const loadGraphToLbug = async (
const cleanup = (err: Error) => {
if (settled) return;
settled = true;
try { rl.close(); } catch {}
try { inputStream.destroy(); } catch {}
try {
rl.close();
} catch {}
try {
inputStream.destroy();
} catch {}
for (const ws of pairWriteStreams.values()) {
try { ws.destroy(); } catch {}
try {
ws.destroy();
} catch {}
}
reject(err);
};
@ -347,7 +353,10 @@ export const loadGraphToLbug = async (
(ws) =>
new Promise<void>((resolve, reject) => {
ws.once('error', reject);
ws.end(() => { ws.removeListener('error', reject); resolve(); });
ws.end(() => {
ws.removeListener('error', reject);
resolve();
});
}),
),
);

54
gitnexus/test/unit/rel-csv-split.test.ts
View file

@ -96,10 +96,16 @@ async function splitRelCsvByLabelPair(
const cleanup = (err: Error) => {
if (settled) return;
settled = true;
try { rl.close(); } catch {}
try { inputStream.destroy(); } catch {}
try {
rl.close();
} catch {}
try {
inputStream.destroy();
} catch {}
for (const ws of pairStreams.values()) {
try { ws.destroy(); } catch {}
try {
ws.destroy();
} catch {}
}
reject(err);
};
@ -147,7 +153,10 @@ async function splitRelCsvByLabelPair(
}
});
rl.on('close', () => {
if (!settled) { settled = true; resolve(); }
if (!settled) {
settled = true;
resolve();
}
});
rl.on('error', cleanup);
});
@ -199,10 +208,11 @@ describe('splitRelCsvByLabelPair', () => {
]);
const streams: MockWriteStream[] = [];
const result = await splitRelCsvByLabelPair(
csvPath, tmpDir, validTables, getNodeLabel,
() => { const ws = new MockWriteStream(); streams.push(ws); return ws; },
);
const result = await splitRelCsvByLabelPair(csvPath, tmpDir, validTables, getNodeLabel, () => {
const ws = new MockWriteStream();
streams.push(ws);
return ws;
});
expect(result.totalValidRels).toBe(3);
expect(result.pairMeta.get('Function|Class')?.rows).toBe(2);
@ -213,7 +223,10 @@ describe('splitRelCsvByLabelPair', () => {
const csvPath = writeCsv([HEADER, csvLine('Function:a', 'Class:b')]);
const result = await splitRelCsvByLabelPair(
csvPath, tmpDir, validTables, getNodeLabel,
csvPath,
tmpDir,
validTables,
getNodeLabel,
() => new MockWriteStream(),
);
@ -229,7 +242,10 @@ describe('splitRelCsvByLabelPair', () => {
]);
const result = await splitRelCsvByLabelPair(
csvPath, tmpDir, validTables, getNodeLabel,
csvPath,
tmpDir,
validTables,
getNodeLabel,
() => new MockWriteStream(),
);
@ -241,7 +257,10 @@ describe('splitRelCsvByLabelPair', () => {
const csvPath = writeCsv([HEADER, '', csvLine('Function:a', 'Class:b'), '', '']);
const result = await splitRelCsvByLabelPair(
csvPath, tmpDir, validTables, getNodeLabel,
csvPath,
tmpDir,
validTables,
getNodeLabel,
() => new MockWriteStream(),
);
@ -266,9 +285,7 @@ describe('splitRelCsvByLabelPair', () => {
};
// Start the split — it will pause on first backpressure
const promise = splitRelCsvByLabelPair(
csvPath, tmpDir, validTables, getNodeLabel, factory,
);
const promise = splitRelCsvByLabelPair(csvPath, tmpDir, validTables, getNodeLabel, factory);
// Give readline time to buffer and fire lines
await new Promise((r) => setTimeout(r, 50));
@ -313,9 +330,7 @@ describe('splitRelCsvByLabelPair', () => {
};
// Error the first stream after both are created
const promise = splitRelCsvByLabelPair(
csvPath, tmpDir, validTables, getNodeLabel, factory,
);
const promise = splitRelCsvByLabelPair(csvPath, tmpDir, validTables, getNodeLabel, factory);
await new Promise((r) => setTimeout(r, 20));
if (streams.length > 0) {
@ -333,7 +348,10 @@ describe('splitRelCsvByLabelPair', () => {
const csvPath = writeCsv([HEADER]);
const result = await splitRelCsvByLabelPair(
csvPath, tmpDir, validTables, getNodeLabel,
csvPath,
tmpDir,
validTables,
getNodeLabel,
() => new MockWriteStream(),
);