@@ -396,10 +396,6 @@ type DailyIngestionState = {
396396files: Record<string, DailyIngestionFileState>;
397397};
398398399-function resolveDailyIngestionStatePath(workspaceDir: string): string {
400-return path.join(workspaceDir, DAILY_INGESTION_STATE_RELATIVE_PATH);
401-}
402-403399function normalizeDailyIngestionState(raw: unknown): DailyIngestionState {
404400const record = asRecord(raw);
405401const filesRaw = asRecord(record?.files);
@@ -442,10 +438,9 @@ function normalizeMemoryDay(value: unknown): string | undefined {
442438}
443439444440async function readDailyIngestionState(workspaceDir: string): Promise<DailyIngestionState> {
445-const statePath = resolveDailyIngestionStatePath(workspaceDir);
446441try {
447442return normalizeDailyIngestionState(
448-await privateFileStore(workspaceDir).readJsonIfExists(path.relative(workspaceDir, statePath)),
443+await privateFileStore(workspaceDir).readJsonIfExists(DAILY_INGESTION_STATE_RELATIVE_PATH),
449444);
450445} catch (err) {
451446if (err instanceof SyntaxError) {
@@ -459,8 +454,7 @@ async function writeDailyIngestionState(
459454workspaceDir: string,
460455state: DailyIngestionState,
461456): Promise<void> {
462-const statePath = resolveDailyIngestionStatePath(workspaceDir);
463-await privateFileStore(workspaceDir).writeJson(path.relative(workspaceDir, statePath), state, {
457+await privateFileStore(workspaceDir).writeJson(DAILY_INGESTION_STATE_RELATIVE_PATH, state, {
464458trailingNewline: true,
465459});
466460}
@@ -496,10 +490,6 @@ function normalizeWorkspaceKey(workspaceDir: string): string {
496490return process.platform === "win32" ? resolved.toLowerCase() : resolved;
497491}
498492499-function resolveSessionIngestionStatePath(workspaceDir: string): string {
500-return path.join(workspaceDir, SESSION_INGESTION_STATE_RELATIVE_PATH);
501-}
502-503493function normalizeSessionIngestionState(raw: unknown): SessionIngestionState {
504494const record = asRecord(raw);
505495const filesRaw = asRecord(record?.files);
@@ -554,10 +544,9 @@ function normalizeSessionIngestionState(raw: unknown): SessionIngestionState {
554544}
555545556546async function readSessionIngestionState(workspaceDir: string): Promise<SessionIngestionState> {
557-const statePath = resolveSessionIngestionStatePath(workspaceDir);
558547try {
559548return normalizeSessionIngestionState(
560-await privateFileStore(workspaceDir).readJsonIfExists(path.relative(workspaceDir, statePath)),
549+await privateFileStore(workspaceDir).readJsonIfExists(SESSION_INGESTION_STATE_RELATIVE_PATH),
561550);
562551} catch (err) {
563552if (err instanceof SyntaxError) {
@@ -571,8 +560,7 @@ async function writeSessionIngestionState(
571560workspaceDir: string,
572561state: SessionIngestionState,
573562): Promise<void> {
574-const statePath = resolveSessionIngestionStatePath(workspaceDir);
575-await privateFileStore(workspaceDir).writeJson(path.relative(workspaceDir, statePath), state, {
563+await privateFileStore(workspaceDir).writeJson(SESSION_INGESTION_STATE_RELATIVE_PATH, state, {
576564trailingNewline: true,
577565});
578566}
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。