fix(ingest): resolve date-only timestamps with server time

Author: neuwcodebox

src/modules/ingest/app/sources/_shared/resolve-date-only-with-server-time.test.ts

@@ -0,0 +1,28 @@
+import { describe, expect, it } from 'vitest';
+import { resolveDateOnlyWithServerTime } from './resolve-date-only-with-server-time';
+
+describe('resolveDateOnlyWithServerTime', () => {
+  it('should apply server time when the date matches today', () => {
+    const now = new Date('2026-01-15T01:02:03.004Z');
+
+    const result = resolveDateOnlyWithServerTime({ year: 2026, month: 1, day: 15 }, now);
+
+    expect(result).toBe(now.toISOString());
+  });
+
+  it('should return end-of-day for past dates', () => {
+    const now = new Date('2026-01-15T01:02:03.004Z');
+
+    const result = resolveDateOnlyWithServerTime({ year: 2026, month: 1, day: 14 }, now);
+
+    expect(result).toBe(new Date('2026-01-14T23:59:59.999+09:00').toISOString());
+  });
+
+  it('should return start-of-day for future dates', () => {
+    const now = new Date('2026-01-15T01:02:03.004Z');
+
+    const result = resolveDateOnlyWithServerTime({ year: 2026, month: 1, day: 16 }, now);
+
+    expect(result).toBe(new Date('2026-01-16T00:00:00.000+09:00').toISOString());
+  });
+});

src/modules/ingest/app/sources/_shared/resolve-date-only-with-server-time.ts

@@ -0,0 +1,47 @@
+type DateOnlyParts = {
+  year: number;
+  month: number;
+  day: number;
+};
+
+const KST_OFFSET_MS = 9 * 60 * 60 * 1000;
+
+export function resolveDateOnlyWithServerTime(parts: DateOnlyParts, now: Date): string | null {
+  const target = new Date(Date.UTC(parts.year, parts.month - 1, parts.day));
+  if (Number.isNaN(target.getTime())) {
+    return null;
+  }
+
+  const nowKst = new Date(now.getTime() + KST_OFFSET_MS);
+  const todayTime = Date.UTC(nowKst.getUTCFullYear(), nowKst.getUTCMonth(), nowKst.getUTCDate());
+  const targetTime = target.getTime();
+
+  const { hour, minute, second, millisecond } =
+    targetTime === todayTime
+      ? {
+          hour: nowKst.getUTCHours(),
+          minute: nowKst.getUTCMinutes(),
+          second: nowKst.getUTCSeconds(),
+          millisecond: nowKst.getUTCMilliseconds(),
+        }
+      : targetTime < todayTime
+        ? { hour: 23, minute: 59, second: 59, millisecond: 999 }
+        : { hour: 0, minute: 0, second: 0, millisecond: 0 };
+
+  const kstIso = buildKstIso(parts, hour, minute, second, millisecond);
+  const resolved = new Date(kstIso);
+  if (Number.isNaN(resolved.getTime())) {
+    return null;
+  }
+  return resolved.toISOString();
+}
+
+function buildKstIso(parts: DateOnlyParts, hour: number, minute: number, second: number, millisecond: number): string {
+  const monthText = String(parts.month).padStart(2, '0');
+  const dayText = String(parts.day).padStart(2, '0');
+  const hourText = String(hour).padStart(2, '0');
+  const minuteText = String(minute).padStart(2, '0');
+  const secondText = String(second).padStart(2, '0');
+  const millisecondText = String(millisecond).padStart(3, '0');
+  return `${parts.year}-${monthText}-${dayText}T${hourText}:${minuteText}:${secondText}.${millisecondText}+09:00`;
+}

src/modules/ingest/app/sources/kasa-space-weather-crisis-alert.source.ts

@@ -8,6 +8,7 @@ import type { Source, SourceEvent, SourceRunResult } from '../../domain/port/sou
 import { isTooOld } from './_shared/is-too-old';
 import { normalizeText } from './_shared/normalize';
 import { pruneTimedMap } from './_shared/prune-timed-map';
+import { resolveDateOnlyWithServerTime } from './_shared/resolve-date-only-with-server-time';
 import { shouldEmitEvent } from './_shared/should-emit-event';
 
 const KASA_SPACE_WEATHER_CRISIS_ENDPOINT = 'https://spaceweather.kasa.go.kr/Alarm.do';
@@ -258,28 +259,7 @@ function parseIssuedAt(value: string, now: Date): string | null {
     return null;
   }
 
-  const dateOnly = new Date(yearNum, monthNum - 1, dayNum);
-  if (Number.isNaN(dateOnly.getTime())) {
-    return null;
-  }
-
-  const today = new Date(now.getFullYear(), now.getMonth(), now.getDate());
-  const isPastDay = dateOnly.getTime() < today.getTime();
-  const resolved = new Date(
-    yearNum,
-    monthNum - 1,
-    dayNum,
-    isPastDay ? 23 : now.getHours(),
-    isPastDay ? 59 : now.getMinutes(),
-    isPastDay ? 59 : now.getSeconds(),
-    isPastDay ? 999 : now.getMilliseconds(),
-  );
-
-  if (Number.isNaN(resolved.getTime())) {
-    return null;
-  }
-
-  return resolved.toISOString();
+  return resolveDateOnlyWithServerTime({ year: yearNum, month: monthNum, day: dayNum }, now);
 }
 
 type FetchInit = NonNullable<Parameters<typeof fetch>[1]>;

src/modules/ingest/app/sources/msit-press-release.source.test.ts

@@ -93,7 +93,7 @@ describe('MsitPressReleaseSource', () => {
       buildItem({
         title: '사이버위기 경보 단계 관심 상향',
         link: 'https://www.msit.go.kr/bbs/view.do?sCode=user&bbsSeqNo=94&nttSeqNo=3186769',
-        pubDate: '2026.01.16',
+        pubDate: '2026.01.14',
       }),
     );
 
@@ -107,6 +107,6 @@ describe('MsitPressReleaseSource', () => {
     const result = await source.run(null);
 
     expect(result.events).toHaveLength(1);
-    expect(result.events[0].occurredAt).toBe('2026-01-15T15:00:00.000Z');
+    expect(result.events[0].occurredAt).toBe('2026-01-14T14:59:59.999Z');
   });
 });

src/modules/ingest/app/sources/msit-press-release.source.ts

@@ -9,13 +9,13 @@ import { fetchWithTimeout } from './_shared/fetch-with-timeout';
 import { isTooOld } from './_shared/is-too-old';
 import { normalizeText } from './_shared/normalize';
 import { pruneTimedMap } from './_shared/prune-timed-map';
+import { resolveDateOnlyWithServerTime } from './_shared/resolve-date-only-with-server-time';
 import { shouldEmitEvent } from './_shared/should-emit-event';
 
 const MSIT_PRESS_RSS_ENDPOINT = 'https://www.msit.go.kr/user/rss/rss.do?bbsSeqNo=94';
 const REQUEST_TIMEOUT_MS = 60000;
 const STATE_TTL_MS = 1000 * 60 * 60 * 24;
 const EVENT_MAX_AGE_MS = STATE_TTL_MS * 0.9;
-const KST_OFFSET_MS = 9 * 60 * 60 * 1000;
 
 const REQUIRED_KEYWORD = '경보';
 const ACTION_KEYWORDS = ['발령', '상향', '하향', '격상'] as const;
@@ -293,26 +293,14 @@ function parseMsitDate(value: string | null, now: Date): string | null {
   }
 
   const [, year, month, day] = matched;
-  const targetDate = `${year}-${month}-${day}`;
-  const nowKst = new Date(now.getTime() + KST_OFFSET_MS);
-  if (targetDate === formatUtcDate(nowKst)) {
-    return now.toISOString();
-  }
-
-  const kstIso = `${year}-${month}-${day}T00:00:00+09:00`;
-  const parsed = new Date(kstIso);
-  if (Number.isNaN(parsed.getTime())) {
+  const yearNum = Number(year);
+  const monthNum = Number(month);
+  const dayNum = Number(day);
+  if (!Number.isFinite(yearNum) || !Number.isFinite(monthNum) || !Number.isFinite(dayNum)) {
     return null;
   }
 
-  return parsed.toISOString();
-}
-
-function formatUtcDate(date: Date): string {
-  const year = date.getUTCFullYear();
-  const month = String(date.getUTCMonth() + 1).padStart(2, '0');
-  const day = String(date.getUTCDate()).padStart(2, '0');
-  return `${year}-${month}-${day}`;
+  return resolveDateOnlyWithServerTime({ year: yearNum, month: monthNum, day: dayNum }, now);
 }
 
 function parseState(state: string | null): MsitPressState {

src/modules/ingest/app/sources/ncsc-cyber-crisis.source.ts

@@ -8,6 +8,7 @@ import { fetchWithTimeout } from './_shared/fetch-with-timeout';
 import { isTooOld } from './_shared/is-too-old';
 import { normalizeText } from './_shared/normalize';
 import { pruneTimedMap } from './_shared/prune-timed-map';
+import { resolveDateOnlyWithServerTime } from './_shared/resolve-date-only-with-server-time';
 import { shouldEmitEvent } from './_shared/should-emit-event';
 
 const NCSC_CYBER_CRISIS_ENDPOINT =
@@ -207,19 +208,5 @@ function parseKstDate(value: string, now: Date): string | null {
   const yearNum = Number(year);
   const monthNum = Number(month);
   const dayNum = Number(day);
-  const isSameDay = yearNum === now.getFullYear() && monthNum === now.getMonth() + 1 && dayNum === now.getDate();
-  const parsed = new Date(
-    yearNum,
-    monthNum - 1,
-    dayNum,
-    isSameDay ? now.getHours() : 0,
-    isSameDay ? now.getMinutes() : 0,
-    isSameDay ? now.getSeconds() : 0,
-    isSameDay ? now.getMilliseconds() : 0,
-  );
-  if (Number.isNaN(parsed.getTime())) {
-    return null;
-  }
-
-  return parsed.toISOString();
+  return resolveDateOnlyWithServerTime({ year: yearNum, month: monthNum, day: dayNum }, now);
 }

src/modules/ingest/app/sources/nctc-terror-alert.source.ts

@@ -9,6 +9,7 @@ import { fetchWithTimeout } from './_shared/fetch-with-timeout';
 import { isTooOld } from './_shared/is-too-old';
 import { normalizeText } from './_shared/normalize';
 import { pruneTimedMap } from './_shared/prune-timed-map';
+import { resolveDateOnlyWithServerTime } from './_shared/resolve-date-only-with-server-time';
 import { shouldEmitEvent } from './_shared/should-emit-event';
 
 const NCTC_TERROR_ALERT_LIST_ENDPOINT =
@@ -400,17 +401,5 @@ function parseKstDate(value: string, now: Date): string | null {
   const yearNum = Number(year);
   const monthNum = Number(month);
   const dayNum = Number(day);
-  const isSameDay = yearNum === now.getFullYear() && monthNum === now.getMonth() + 1 && dayNum === now.getDate();
-  const parsed = new Date(
-    yearNum,
-    monthNum - 1,
-    dayNum,
-    isSameDay ? now.getHours() : 0,
-    isSameDay ? now.getMinutes() : 0,
-  );
-  if (Number.isNaN(parsed.getTime())) {
-    return null;
-  }
-
-  return parsed.toISOString();
+  return resolveDateOnlyWithServerTime({ year: yearNum, month: monthNum, day: dayNum }, now);
 }