feat(ingest): add landslide forecast source

Author: neuwcodebox

README.md

@@ -24,7 +24,7 @@
 - [x] 기상 특보
 - [x] 대기질 (PM, O3)
 - [x] 교통 돌발정보
-- [ ] 산사태경보
+- [x] 산사태 예보
 - [x] 사이버위기경보
 - [x] 테러경보
 - [x] 산불경보

src/modules/events/domain/event.enums.ts

@@ -69,4 +69,5 @@ export enum EventSources {
   KpxPowerSupply = 13,
   FloodAlert = 14,
   ForestFireWarning = 15,
+  LandslideForecast = 16,
 }

src/modules/ingest/app/source.list.ts

@@ -11,6 +11,7 @@ import { KmaMicroEarthquakeSource } from './sources/kma-micro-earthquake.source'
 import { KmaPewsEarthquakeSource } from './sources/kma-pews-earthquake.source';
 import { KmaWeatherWarningSource } from './sources/kma-weather-warning.source';
 import { KpxPowerSupplySource } from './sources/kpx-power-supply.source';
+import { LandslideForecastSource } from './sources/landslide-forecast.source';
 import { NcscCyberCrisisSource } from './sources/ncsc-cyber-crisis.source';
 import { NctcTerrorAlertSource } from './sources/nctc-terror-alert.source';
 import { NfdsFireDispatchSource } from './sources/nfds-fire-dispatch.source';
@@ -30,6 +31,7 @@ export function buildSourceList(
     new NfdsFireDispatchSource(regionRepository),
     new ForestFireInfoSource(),
     new ForestFireWarningSource(),
+    new LandslideForecastSource(),
     new UticTrafficIncidentSource(),
     new YnaNewsSource(llmLabelClassifier),
     new AirkoreaPmWarningSource(regionRepository),

src/modules/ingest/app/sources/landslide-forecast.source.test.ts

@@ -0,0 +1,76 @@
+import { afterEach, describe, expect, it, vi } from 'vitest';
+import { EventLevels } from '@/modules/events/domain/event.enums';
+import { LandslideForecastSource } from './landslide-forecast.source';
+
+describe('LandslideForecastSource', () => {
+  afterEach(() => {
+    vi.useRealTimers();
+    vi.unstubAllGlobals();
+  });
+
+  it('should parse forecast table and emit issued alerts only', async () => {
+    vi.useFakeTimers();
+    vi.setSystemTime(new Date('2025-10-25T06:30:00.000Z'));
+
+    const html = `
+      <table id="fctTbl">
+        <tbody>
+          <tr>
+            <td>
+              <a href="javascript:fn_moveAlertView('47940', '', '12310');">경상북도 울릉군</a>
+            </td>
+            <td>
+              <a href="javascript:fn_moveAlertView('47940','','12310');" title="주의보">주의보</a>
+            </td>
+            <td>
+              <a href="javascript:fn_moveAlertView('47940','','12310');" title="2025-10-25 13:19">2025-10-25<br>13:19</a>
+            </td>
+            <td>
+              <a href="javascript:fn_moveAlertView('47940','','12310');" title="2025-10-25 14:10">2025-10-25<br>14:10</a>
+            </td>
+            <td>
+              <a href="javascript:fn_moveAlertView('47940','','12310');" title="-">-</a>
+            </td>
+            <td>
+              <a href="javascript:fn_moveAlertView('47940','','12310');" title="작성자">작성자</a>
+            </td>
+            <td>발령</td>
+          </tr>
+          <tr>
+            <td>
+              <a href="javascript:fn_moveAlertView('11110', '', '99999');">서울특별시 종로구</a>
+            </td>
+            <td>
+              <a href="javascript:fn_moveAlertView('11110','','99999');" title="경보">경보</a>
+            </td>
+            <td>
+              <a href="javascript:fn_moveAlertView('11110','','99999');" title="2025-10-25 11:00">2025-10-25<br>11:00</a>
+            </td>
+            <td>
+              <a href="javascript:fn_moveAlertView('11110','','99999');" title="2025-10-25 11:10">2025-10-25<br>11:10</a>
+            </td>
+            <td>
+              <a href="javascript:fn_moveAlertView('11110','','99999');" title="2025-10-25 12:00">2025-10-25<br>12:00</a>
+            </td>
+            <td>
+              <a href="javascript:fn_moveAlertView('11110','','99999');" title="작성자">작성자</a>
+            </td>
+            <td>해제</td>
+          </tr>
+        </tbody>
+      </table>
+    `;
+
+    const fetchMock = vi.fn().mockImplementation(() => Promise.resolve(new Response(html, { status: 200 })));
+    vi.stubGlobal('fetch', fetchMock);
+
+    const source = new LandslideForecastSource();
+    const result = await source.run(null);
+
+    expect(result.events).toHaveLength(1);
+    expect(result.events[0].title).toBe('경상북도 울릉군 산사태 주의보 발령');
+    expect(result.events[0].level).toBe(EventLevels.Minor);
+    expect(result.events[0].regionCodes).toEqual(['4794000000']);
+    expect(result.events[0].occurredAt).toBe('2025-10-25T04:19:00.000Z');
+  });
+});