Compare commits
5
Commits
8bc43b3ce4
...
449b6d8ca3
| Author | SHA1 | Date | |
|---|---|---|---|
 jsahnandClaude Fable 5
|
449b6d8ca3 | ||
|
jsahnandClaude Fable 5
|
ab16eaf5a7 | ||
|
jsahnandClaude Fable 5
|
a482a0a3e3 | ||
|
jsahnandClaude Fable 5
|
f7b8d895c3 | ||
|
jsahnandClaude Fable 5
|
920d9358a0 |
@@ -11,6 +11,11 @@ TELEGRAM_CHAT_ID=
|
||||
# FRED (선택) — 경제지표 실제 발표값
|
||||
FRED_API_KEY=
|
||||
|
||||
# SearXNG (선택) — 설정하면 RSS 외에 메타검색 뉴스도 수집 (인스턴스에 json 포맷 활성화 필요)
|
||||
SEARXNG_BASE_URL=
|
||||
# 검색어 CSV. 비우면 기본값(us2kr/collectors/searx.py DEFAULT_QUERIES)
|
||||
US2KR_SEARXNG_QUERIES=
|
||||
|
||||
# 실행 정책
|
||||
US2KR_RUN_OFFSET_MINUTES=75
|
||||
US2KR_CATCHUP_WINDOW_HOURS=3
|
||||
|
||||
@@ -9,3 +9,5 @@ reports/
|
||||
logs/
|
||||
.pytest_cache/
|
||||
.ruff_cache/
|
||||
node_modules/
|
||||
dashboard/dist/
|
||||
|
||||
@@ -57,9 +57,14 @@ cp .env.example .env # MINIMAX_API_KEY 필수, TELEGRAM_* 선택
|
||||
| 환경 | 방법 |
|
||||
|---|---|
|
||||
| macOS | `bash deploy/install-launchd.sh` (launchd, KeepAlive) |
|
||||
| macOS (Apple container) | `bash deploy/install-apple-container.sh` — 데몬+대시보드 빌드·기동. `--boot`를 붙이면 로그인 시 자동 기동(LaunchAgent) 등록 |
|
||||
| Linux | `deploy/us2kr.service` → `systemctl enable --now us2kr` |
|
||||
| Docker | `docker compose -f deploy/compose.yaml up -d --build` |
|
||||
|
||||
Apple container(`brew install container`)는 restart 정책이 없어 재부팅 후 자동 기동은 `--boot`의
|
||||
LaunchAgent(`container system start` + `container start us2kr`)가 담당합니다.
|
||||
`data/` `reports/` `logs/`는 호스트 디렉터리를 그대로 마운트하므로 launchd 방식과 산출물 위치가 같습니다.
|
||||
|
||||
> macOS 노트북은 **잠자기 중에는 실행되지 않습니다.** 06~07시에 깨어 있도록
|
||||
> `sudo pmset repeat wakeorpoweron MTWRFS 06:00:00` 로 예약 기동을 걸거나, 항상 켜진 머신/서버에서 돌리세요.
|
||||
|
||||
@@ -76,6 +81,8 @@ cp .env.example .env # MINIMAX_API_KEY 필수, TELEGRAM_* 선택
|
||||
| `US2KR_CATCHUP_WINDOW_HOURS` | `3` | 재시작 시 따라잡기 허용 창 |
|
||||
| `US2KR_SKIP_WHEN_KRX_CLOSED` | `false` | 한국 휴장일에 다음 미국 세션이 먼저 마감되어 브리핑이 무의미해질 때만 스킵(금요일 세션은 항상 발송) |
|
||||
| `US2KR_NEWS_LOOKBACK_HOURS` / `US2KR_NEWS_MAX_ITEMS` | `18` / `40` | 뉴스 수집 범위 |
|
||||
| `SEARXNG_BASE_URL` | — | 있으면 RSS 외에 SearXNG 뉴스 검색 결과도 병합 (인스턴스에 `json` 포맷 활성화 필요) |
|
||||
| `US2KR_SEARXNG_QUERIES` | 기본 검색어 3개 | SearXNG 검색어 CSV (기본: `us2kr/collectors/searx.py`의 `DEFAULT_QUERIES`) |
|
||||
| `US2KR_KRX_EXTRA_HOLIDAYS` | — | 캘린더에 없는 한국 임시휴장일 CSV (예: `2026-06-03`) |
|
||||
|
||||
## 산출물
|
||||
@@ -84,6 +91,22 @@ cp .env.example .env # MINIMAX_API_KEY 필수, TELEGRAM_* 선택
|
||||
- `data/us2kr.sqlite3` — 시세 스냅샷·리포트·발송 기록(전일 대비 비교, 중복 방지)
|
||||
- `logs/us2kr.log` — 일자별 회전, API 키 마스킹
|
||||
|
||||
## 대시보드 (dashboard/)
|
||||
|
||||
쌓인 브리핑을 보는 웹 대시보드(TypeScript, 런타임 의존성 없는 Node 24 서버 + 번들 클라이언트).
|
||||
`reports/*.json`만 읽는 읽기 전용 뷰라 데몬의 SQLite(WAL)와 절대 경합하지 않습니다.
|
||||
|
||||
- 최신 세션 요약 타일(S&P·나스닥·SOX·VIX·달러/원·10년물), 종목별 종가 추이 차트(표 전환 가능)
|
||||
- 브리핑 목록/본문(Markdown 렌더, sanitize), 데이터 결측·오류 로그 표시
|
||||
- Apple container 배포 시 함께 기동: `http://localhost:8090` (포트: `US2KR_DASHBOARD_PORT`)
|
||||
|
||||
```bash
|
||||
cd dashboard
|
||||
npm install
|
||||
npm run build # tsc 타입체크 + esbuild 번들
|
||||
US2KR_REPORTS_DIR=../reports npm start # http://localhost:8090
|
||||
```
|
||||
|
||||
## 개발
|
||||
|
||||
```bash
|
||||
|
||||
@@ -0,0 +1,2 @@
|
||||
node_modules
|
||||
dist
|
||||
@@ -0,0 +1,16 @@
|
||||
FROM node:24-slim AS build
|
||||
WORKDIR /app
|
||||
COPY package.json package-lock.json ./
|
||||
RUN npm ci
|
||||
COPY tsconfig.json ./
|
||||
COPY src ./src
|
||||
COPY web ./web
|
||||
RUN npm run build
|
||||
|
||||
FROM node:24-slim
|
||||
WORKDIR /app
|
||||
ENV NODE_ENV=production US2KR_REPORTS_DIR=/data/reports PORT=8090
|
||||
COPY --from=build /app/dist ./dist
|
||||
EXPOSE 8090
|
||||
USER node
|
||||
CMD ["node", "dist/server.js"]
|
||||
Generated
+565
@@ -0,0 +1,565 @@
|
||||
{
|
||||
"name": "us2kr-dashboard",
|
||||
"version": "0.1.0",
|
||||
"lockfileVersion": 3,
|
||||
"requires": true,
|
||||
"packages": {
|
||||
"": {
|
||||
"name": "us2kr-dashboard",
|
||||
"version": "0.1.0",
|
||||
"devDependencies": {
|
||||
"@types/node": "^24.3.0",
|
||||
"dompurify": "^3.2.4",
|
||||
"esbuild": "^0.25.0",
|
||||
"marked": "^16.0.0",
|
||||
"typescript": "^5.9.0"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/aix-ppc64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/aix-ppc64/-/aix-ppc64-0.25.12.tgz",
|
||||
"integrity": "sha512-Hhmwd6CInZ3dwpuGTF8fJG6yoWmsToE+vYgD4nytZVxcu1ulHpUQRAB1UJ8+N1Am3Mz4+xOByoQoSZf4D+CpkA==",
|
||||
"cpu": [
|
||||
"ppc64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"aix"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/android-arm": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/android-arm/-/android-arm-0.25.12.tgz",
|
||||
"integrity": "sha512-VJ+sKvNA/GE7Ccacc9Cha7bpS8nyzVv0jdVgwNDaR4gDMC/2TTRc33Ip8qrNYUcpkOHUT5OZ0bUcNNVZQ9RLlg==",
|
||||
"cpu": [
|
||||
"arm"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"android"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/android-arm64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/android-arm64/-/android-arm64-0.25.12.tgz",
|
||||
"integrity": "sha512-6AAmLG7zwD1Z159jCKPvAxZd4y/VTO0VkprYy+3N2FtJ8+BQWFXU+OxARIwA46c5tdD9SsKGZ/1ocqBS/gAKHg==",
|
||||
"cpu": [
|
||||
"arm64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"android"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/android-x64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/android-x64/-/android-x64-0.25.12.tgz",
|
||||
"integrity": "sha512-5jbb+2hhDHx5phYR2By8GTWEzn6I9UqR11Kwf22iKbNpYrsmRB18aX/9ivc5cabcUiAT/wM+YIZ6SG9QO6a8kg==",
|
||||
"cpu": [
|
||||
"x64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"android"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/darwin-arm64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/darwin-arm64/-/darwin-arm64-0.25.12.tgz",
|
||||
"integrity": "sha512-N3zl+lxHCifgIlcMUP5016ESkeQjLj/959RxxNYIthIg+CQHInujFuXeWbWMgnTo4cp5XVHqFPmpyu9J65C1Yg==",
|
||||
"cpu": [
|
||||
"arm64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"darwin"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/darwin-x64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/darwin-x64/-/darwin-x64-0.25.12.tgz",
|
||||
"integrity": "sha512-HQ9ka4Kx21qHXwtlTUVbKJOAnmG1ipXhdWTmNXiPzPfWKpXqASVcWdnf2bnL73wgjNrFXAa3yYvBSd9pzfEIpA==",
|
||||
"cpu": [
|
||||
"x64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"darwin"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/freebsd-arm64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/freebsd-arm64/-/freebsd-arm64-0.25.12.tgz",
|
||||
"integrity": "sha512-gA0Bx759+7Jve03K1S0vkOu5Lg/85dou3EseOGUes8flVOGxbhDDh/iZaoek11Y8mtyKPGF3vP8XhnkDEAmzeg==",
|
||||
"cpu": [
|
||||
"arm64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"freebsd"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/freebsd-x64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/freebsd-x64/-/freebsd-x64-0.25.12.tgz",
|
||||
"integrity": "sha512-TGbO26Yw2xsHzxtbVFGEXBFH0FRAP7gtcPE7P5yP7wGy7cXK2oO7RyOhL5NLiqTlBh47XhmIUXuGciXEqYFfBQ==",
|
||||
"cpu": [
|
||||
"x64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"freebsd"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/linux-arm": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/linux-arm/-/linux-arm-0.25.12.tgz",
|
||||
"integrity": "sha512-lPDGyC1JPDou8kGcywY0YILzWlhhnRjdof3UlcoqYmS9El818LLfJJc3PXXgZHrHCAKs/Z2SeZtDJr5MrkxtOw==",
|
||||
"cpu": [
|
||||
"arm"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"linux"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/linux-arm64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/linux-arm64/-/linux-arm64-0.25.12.tgz",
|
||||
"integrity": "sha512-8bwX7a8FghIgrupcxb4aUmYDLp8pX06rGh5HqDT7bB+8Rdells6mHvrFHHW2JAOPZUbnjUpKTLg6ECyzvas2AQ==",
|
||||
"cpu": [
|
||||
"arm64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"linux"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/linux-ia32": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/linux-ia32/-/linux-ia32-0.25.12.tgz",
|
||||
"integrity": "sha512-0y9KrdVnbMM2/vG8KfU0byhUN+EFCny9+8g202gYqSSVMonbsCfLjUO+rCci7pM0WBEtz+oK/PIwHkzxkyharA==",
|
||||
"cpu": [
|
||||
"ia32"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"linux"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/linux-loong64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/linux-loong64/-/linux-loong64-0.25.12.tgz",
|
||||
"integrity": "sha512-h///Lr5a9rib/v1GGqXVGzjL4TMvVTv+s1DPoxQdz7l/AYv6LDSxdIwzxkrPW438oUXiDtwM10o9PmwS/6Z0Ng==",
|
||||
"cpu": [
|
||||
"loong64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"linux"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/linux-mips64el": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/linux-mips64el/-/linux-mips64el-0.25.12.tgz",
|
||||
"integrity": "sha512-iyRrM1Pzy9GFMDLsXn1iHUm18nhKnNMWscjmp4+hpafcZjrr2WbT//d20xaGljXDBYHqRcl8HnxbX6uaA/eGVw==",
|
||||
"cpu": [
|
||||
"mips64el"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"linux"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/linux-ppc64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/linux-ppc64/-/linux-ppc64-0.25.12.tgz",
|
||||
"integrity": "sha512-9meM/lRXxMi5PSUqEXRCtVjEZBGwB7P/D4yT8UG/mwIdze2aV4Vo6U5gD3+RsoHXKkHCfSxZKzmDssVlRj1QQA==",
|
||||
"cpu": [
|
||||
"ppc64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"linux"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/linux-riscv64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/linux-riscv64/-/linux-riscv64-0.25.12.tgz",
|
||||
"integrity": "sha512-Zr7KR4hgKUpWAwb1f3o5ygT04MzqVrGEGXGLnj15YQDJErYu/BGg+wmFlIDOdJp0PmB0lLvxFIOXZgFRrdjR0w==",
|
||||
"cpu": [
|
||||
"riscv64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"linux"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/linux-s390x": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/linux-s390x/-/linux-s390x-0.25.12.tgz",
|
||||
"integrity": "sha512-MsKncOcgTNvdtiISc/jZs/Zf8d0cl/t3gYWX8J9ubBnVOwlk65UIEEvgBORTiljloIWnBzLs4qhzPkJcitIzIg==",
|
||||
"cpu": [
|
||||
"s390x"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"linux"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/linux-x64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/linux-x64/-/linux-x64-0.25.12.tgz",
|
||||
"integrity": "sha512-uqZMTLr/zR/ed4jIGnwSLkaHmPjOjJvnm6TVVitAa08SLS9Z0VM8wIRx7gWbJB5/J54YuIMInDquWyYvQLZkgw==",
|
||||
"cpu": [
|
||||
"x64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"linux"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/netbsd-arm64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/netbsd-arm64/-/netbsd-arm64-0.25.12.tgz",
|
||||
"integrity": "sha512-xXwcTq4GhRM7J9A8Gv5boanHhRa/Q9KLVmcyXHCTaM4wKfIpWkdXiMog/KsnxzJ0A1+nD+zoecuzqPmCRyBGjg==",
|
||||
"cpu": [
|
||||
"arm64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"netbsd"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/netbsd-x64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/netbsd-x64/-/netbsd-x64-0.25.12.tgz",
|
||||
"integrity": "sha512-Ld5pTlzPy3YwGec4OuHh1aCVCRvOXdH8DgRjfDy/oumVovmuSzWfnSJg+VtakB9Cm0gxNO9BzWkj6mtO1FMXkQ==",
|
||||
"cpu": [
|
||||
"x64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"netbsd"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/openbsd-arm64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/openbsd-arm64/-/openbsd-arm64-0.25.12.tgz",
|
||||
"integrity": "sha512-fF96T6KsBo/pkQI950FARU9apGNTSlZGsv1jZBAlcLL1MLjLNIWPBkj5NlSz8aAzYKg+eNqknrUJ24QBybeR5A==",
|
||||
"cpu": [
|
||||
"arm64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"openbsd"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/openbsd-x64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/openbsd-x64/-/openbsd-x64-0.25.12.tgz",
|
||||
"integrity": "sha512-MZyXUkZHjQxUvzK7rN8DJ3SRmrVrke8ZyRusHlP+kuwqTcfWLyqMOE3sScPPyeIXN/mDJIfGXvcMqCgYKekoQw==",
|
||||
"cpu": [
|
||||
"x64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"openbsd"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/openharmony-arm64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/openharmony-arm64/-/openharmony-arm64-0.25.12.tgz",
|
||||
"integrity": "sha512-rm0YWsqUSRrjncSXGA7Zv78Nbnw4XL6/dzr20cyrQf7ZmRcsovpcRBdhD43Nuk3y7XIoW2OxMVvwuRvk9XdASg==",
|
||||
"cpu": [
|
||||
"arm64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"openharmony"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/sunos-x64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/sunos-x64/-/sunos-x64-0.25.12.tgz",
|
||||
"integrity": "sha512-3wGSCDyuTHQUzt0nV7bocDy72r2lI33QL3gkDNGkod22EsYl04sMf0qLb8luNKTOmgF/eDEDP5BFNwoBKH441w==",
|
||||
"cpu": [
|
||||
"x64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"sunos"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/win32-arm64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/win32-arm64/-/win32-arm64-0.25.12.tgz",
|
||||
"integrity": "sha512-rMmLrur64A7+DKlnSuwqUdRKyd3UE7oPJZmnljqEptesKM8wx9J8gx5u0+9Pq0fQQW8vqeKebwNXdfOyP+8Bsg==",
|
||||
"cpu": [
|
||||
"arm64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"win32"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/win32-ia32": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/win32-ia32/-/win32-ia32-0.25.12.tgz",
|
||||
"integrity": "sha512-HkqnmmBoCbCwxUKKNPBixiWDGCpQGVsrQfJoVGYLPT41XWF8lHuE5N6WhVia2n4o5QK5M4tYr21827fNhi4byQ==",
|
||||
"cpu": [
|
||||
"ia32"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"win32"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@esbuild/win32-x64": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/@esbuild/win32-x64/-/win32-x64-0.25.12.tgz",
|
||||
"integrity": "sha512-alJC0uCZpTFrSL0CCDjcgleBXPnCrEAhTBILpeAp7M/OFgoqtAetfBzX0xM00MUsVVPpVjlPuMbREqnZCXaTnA==",
|
||||
"cpu": [
|
||||
"x64"
|
||||
],
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true,
|
||||
"os": [
|
||||
"win32"
|
||||
],
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
}
|
||||
},
|
||||
"node_modules/@types/node": {
|
||||
"version": "24.13.3",
|
||||
"resolved": "https://registry.npmjs.org/@types/node/-/node-24.13.3.tgz",
|
||||
"integrity": "sha512-Dh8vAsV36ig5wa9OX4pXvMc9D3Veibfw2wix0CUwYODLD8nkj9UsLjASr49nPg+2eKzxhBV+v7L8pXvT4e639Q==",
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"undici-types": "~7.18.0"
|
||||
}
|
||||
},
|
||||
"node_modules/@types/trusted-types": {
|
||||
"version": "2.0.7",
|
||||
"resolved": "https://registry.npmjs.org/@types/trusted-types/-/trusted-types-2.0.7.tgz",
|
||||
"integrity": "sha512-ScaPdn1dQczgbl0QFTeTOmVHFULt394XJgOQNoyVhZ6r2vLnMLJfBPd53SB52T/3G36VI1/g2MZaX0cwDuXsfw==",
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"optional": true
|
||||
},
|
||||
"node_modules/dompurify": {
|
||||
"version": "3.4.14",
|
||||
"resolved": "https://registry.npmjs.org/dompurify/-/dompurify-3.4.14.tgz",
|
||||
"integrity": "sha512-dVoH9z+MY+C9IilgGCk3YfFqjLi3fChm2OiKJMzh6axrJ5qwxqWaZamgmHrpv22CN/KdbZJuGEGgfQoL00LTdg==",
|
||||
"dev": true,
|
||||
"license": "(MPL-2.0 OR Apache-2.0)",
|
||||
"optionalDependencies": {
|
||||
"@types/trusted-types": "^2.0.7"
|
||||
}
|
||||
},
|
||||
"node_modules/esbuild": {
|
||||
"version": "0.25.12",
|
||||
"resolved": "https://registry.npmjs.org/esbuild/-/esbuild-0.25.12.tgz",
|
||||
"integrity": "sha512-bbPBYYrtZbkt6Os6FiTLCTFxvq4tt3JKall1vRwshA3fdVztsLAatFaZobhkBC8/BrPetoa0oksYoKXoG4ryJg==",
|
||||
"dev": true,
|
||||
"hasInstallScript": true,
|
||||
"license": "MIT",
|
||||
"bin": {
|
||||
"esbuild": "bin/esbuild"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
},
|
||||
"optionalDependencies": {
|
||||
"@esbuild/aix-ppc64": "0.25.12",
|
||||
"@esbuild/android-arm": "0.25.12",
|
||||
"@esbuild/android-arm64": "0.25.12",
|
||||
"@esbuild/android-x64": "0.25.12",
|
||||
"@esbuild/darwin-arm64": "0.25.12",
|
||||
"@esbuild/darwin-x64": "0.25.12",
|
||||
"@esbuild/freebsd-arm64": "0.25.12",
|
||||
"@esbuild/freebsd-x64": "0.25.12",
|
||||
"@esbuild/linux-arm": "0.25.12",
|
||||
"@esbuild/linux-arm64": "0.25.12",
|
||||
"@esbuild/linux-ia32": "0.25.12",
|
||||
"@esbuild/linux-loong64": "0.25.12",
|
||||
"@esbuild/linux-mips64el": "0.25.12",
|
||||
"@esbuild/linux-ppc64": "0.25.12",
|
||||
"@esbuild/linux-riscv64": "0.25.12",
|
||||
"@esbuild/linux-s390x": "0.25.12",
|
||||
"@esbuild/linux-x64": "0.25.12",
|
||||
"@esbuild/netbsd-arm64": "0.25.12",
|
||||
"@esbuild/netbsd-x64": "0.25.12",
|
||||
"@esbuild/openbsd-arm64": "0.25.12",
|
||||
"@esbuild/openbsd-x64": "0.25.12",
|
||||
"@esbuild/openharmony-arm64": "0.25.12",
|
||||
"@esbuild/sunos-x64": "0.25.12",
|
||||
"@esbuild/win32-arm64": "0.25.12",
|
||||
"@esbuild/win32-ia32": "0.25.12",
|
||||
"@esbuild/win32-x64": "0.25.12"
|
||||
}
|
||||
},
|
||||
"node_modules/marked": {
|
||||
"version": "16.4.2",
|
||||
"resolved": "https://registry.npmjs.org/marked/-/marked-16.4.2.tgz",
|
||||
"integrity": "sha512-TI3V8YYWvkVf3KJe1dRkpnjs68JUPyEa5vjKrp1XEEJUAOaQc+Qj+L1qWbPd0SJuAdQkFU0h73sXXqwDYxsiDA==",
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"bin": {
|
||||
"marked": "bin/marked.js"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">= 20"
|
||||
}
|
||||
},
|
||||
"node_modules/typescript": {
|
||||
"version": "5.9.3",
|
||||
"resolved": "https://registry.npmjs.org/typescript/-/typescript-5.9.3.tgz",
|
||||
"integrity": "sha512-jl1vZzPDinLr9eUt3J/t7V6FgNEw9QjvBPdysz9KfQDD41fQrC2Y4vKQdiaUpFT4bXlb1RHhLpp8wtm6M5TgSw==",
|
||||
"dev": true,
|
||||
"license": "Apache-2.0",
|
||||
"bin": {
|
||||
"tsc": "bin/tsc",
|
||||
"tsserver": "bin/tsserver"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">=14.17"
|
||||
}
|
||||
},
|
||||
"node_modules/undici-types": {
|
||||
"version": "7.18.2",
|
||||
"resolved": "https://registry.npmjs.org/undici-types/-/undici-types-7.18.2.tgz",
|
||||
"integrity": "sha512-AsuCzffGHJybSaRrmr5eHr81mwJU3kjw6M+uprWvCXiNeN9SOGwQ3Jn8jb8m3Z6izVgknn1R0FTCEAP2QrLY/w==",
|
||||
"dev": true,
|
||||
"license": "MIT"
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,21 @@
|
||||
{
|
||||
"name": "us2kr-dashboard",
|
||||
"version": "0.1.0",
|
||||
"private": true,
|
||||
"type": "module",
|
||||
"scripts": {
|
||||
"typecheck": "tsc --noEmit",
|
||||
"build:server": "esbuild src/server.ts --bundle --platform=node --target=node24 --format=esm --outfile=dist/server.js",
|
||||
"build:client": "esbuild src/client/main.ts --bundle --minify --target=es2022 --outfile=dist/public/app.js",
|
||||
"build:static": "mkdir -p dist/public && cp web/index.html web/styles.css dist/public/",
|
||||
"build": "npm run typecheck && npm run build:server && npm run build:client && npm run build:static",
|
||||
"start": "node dist/server.js"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@types/node": "^24.3.0",
|
||||
"dompurify": "^3.2.4",
|
||||
"esbuild": "^0.25.0",
|
||||
"marked": "^16.0.0",
|
||||
"typescript": "^5.9.0"
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,171 @@
|
||||
/** Hand-rolled single-series SVG line chart with crosshair + tooltip hover. */
|
||||
|
||||
const SVG_NS = "http://www.w3.org/2000/svg";
|
||||
const W = 920;
|
||||
const H = 260;
|
||||
const PAD = { top: 14, right: 16, bottom: 26, left: 58 };
|
||||
|
||||
interface Point {
|
||||
date: string;
|
||||
value: number;
|
||||
}
|
||||
|
||||
function svgEl<K extends keyof SVGElementTagNameMap>(
|
||||
tag: K,
|
||||
attrs: Record<string, string | number> = {},
|
||||
): SVGElementTagNameMap[K] {
|
||||
const el = document.createElementNS(SVG_NS, tag);
|
||||
for (const [k, v] of Object.entries(attrs)) el.setAttribute(k, String(v));
|
||||
return el;
|
||||
}
|
||||
|
||||
function niceTicks(min: number, max: number, count = 4): number[] {
|
||||
if (min === max) {
|
||||
const pad = Math.abs(min) * 0.01 || 1;
|
||||
min -= pad;
|
||||
max += pad;
|
||||
}
|
||||
const span = max - min;
|
||||
const step = 10 ** Math.floor(Math.log10(span / count));
|
||||
const err = span / count / step;
|
||||
const mult = err >= 7.5 ? 10 : err >= 3.5 ? 5 : err >= 1.5 ? 2 : 1;
|
||||
const s = step * mult;
|
||||
const first = Math.ceil(min / s) * s;
|
||||
const ticks: number[] = [];
|
||||
for (let v = first; v <= max + s * 1e-9; v += s) ticks.push(Number(v.toFixed(10)));
|
||||
return ticks;
|
||||
}
|
||||
|
||||
export function formatValue(v: number): string {
|
||||
const decimals = Math.abs(v) >= 1000 ? 0 : Math.abs(v) >= 10 ? 2 : Math.abs(v) >= 1 ? 3 : 4;
|
||||
return v.toLocaleString("ko-KR", { minimumFractionDigits: decimals, maximumFractionDigits: decimals });
|
||||
}
|
||||
|
||||
/** Render the chart into `host` (cleared first). Null values break the line. */
|
||||
export function renderLineChart(
|
||||
host: HTMLElement,
|
||||
dates: string[],
|
||||
values: (number | null)[],
|
||||
seriesLabel: string,
|
||||
): void {
|
||||
host.textContent = "";
|
||||
const points: (Point | null)[] = dates.map((date, i) => {
|
||||
const v = values[i];
|
||||
return v === null || v === undefined ? null : { date, value: v };
|
||||
});
|
||||
const present = points.filter((p): p is Point => p !== null);
|
||||
if (present.length === 0) {
|
||||
const empty = document.createElement("p");
|
||||
empty.className = "chart-empty";
|
||||
empty.textContent = "표시할 데이터가 없습니다.";
|
||||
host.append(empty);
|
||||
return;
|
||||
}
|
||||
|
||||
const lo = Math.min(...present.map((p) => p.value));
|
||||
const hi = Math.max(...present.map((p) => p.value));
|
||||
const span = hi - lo || Math.abs(hi) * 0.02 || 1;
|
||||
const yMin = lo - span * 0.08;
|
||||
const yMax = hi + span * 0.08;
|
||||
|
||||
const innerW = W - PAD.left - PAD.right;
|
||||
const innerH = H - PAD.top - PAD.bottom;
|
||||
const x = (i: number) => PAD.left + (dates.length === 1 ? innerW / 2 : (i / (dates.length - 1)) * innerW);
|
||||
const y = (v: number) => PAD.top + (1 - (v - yMin) / (yMax - yMin)) * innerH;
|
||||
|
||||
const svg = svgEl("svg", { viewBox: `0 0 ${W} ${H}`, role: "img" });
|
||||
const title = svgEl("title");
|
||||
title.textContent = `${seriesLabel} 종가 추이`;
|
||||
svg.append(title);
|
||||
|
||||
for (const tick of niceTicks(yMin, yMax)) {
|
||||
svg.append(svgEl("line", { class: "gridline", x1: PAD.left, x2: W - PAD.right, y1: y(tick), y2: y(tick) }));
|
||||
const label = svgEl("text", { class: "axis-label", x: PAD.left - 8, y: y(tick) + 4, "text-anchor": "end" });
|
||||
label.textContent = formatValue(tick);
|
||||
svg.append(label);
|
||||
}
|
||||
svg.append(
|
||||
svgEl("line", { class: "baseline", x1: PAD.left, x2: W - PAD.right, y1: H - PAD.bottom, y2: H - PAD.bottom }),
|
||||
);
|
||||
|
||||
const maxLabels = Math.max(2, Math.floor(innerW / 90));
|
||||
const stride = Math.max(1, Math.ceil(dates.length / maxLabels));
|
||||
dates.forEach((d, i) => {
|
||||
if (i % stride !== 0 && i !== dates.length - 1) return;
|
||||
const label = svgEl("text", { class: "axis-label", x: x(i), y: H - 8, "text-anchor": "middle" });
|
||||
label.textContent = d.slice(5); // MM-DD
|
||||
svg.append(label);
|
||||
});
|
||||
|
||||
// polyline per contiguous run so nulls read as gaps, not interpolation
|
||||
let run: string[] = [];
|
||||
const flush = () => {
|
||||
if (run.length >= 2) svg.append(svgEl("polyline", { class: "series-line", points: run.join(" ") }));
|
||||
else if (run.length === 1) {
|
||||
const [px = "", py = ""] = (run[0] ?? "").split(",");
|
||||
svg.append(svgEl("circle", { class: "hover-dot", cx: px, cy: py, r: 3 }));
|
||||
}
|
||||
run = [];
|
||||
};
|
||||
points.forEach((pt, i) => {
|
||||
if (pt === null) flush();
|
||||
else run.push(`${x(i)},${y(pt.value)}`);
|
||||
});
|
||||
flush();
|
||||
|
||||
// hover layer: crosshair + dot + tooltip on the nearest present point
|
||||
const crosshair = svgEl("line", {
|
||||
class: "crosshair",
|
||||
y1: PAD.top,
|
||||
y2: H - PAD.bottom,
|
||||
x1: -10,
|
||||
x2: -10,
|
||||
visibility: "hidden",
|
||||
});
|
||||
const dot = svgEl("circle", { class: "hover-dot", r: 4.5, visibility: "hidden" });
|
||||
svg.append(crosshair, dot);
|
||||
|
||||
const tooltip = document.createElement("div");
|
||||
tooltip.className = "chart-tooltip";
|
||||
tooltip.hidden = true;
|
||||
host.append(svg, tooltip);
|
||||
|
||||
const hide = () => {
|
||||
crosshair.setAttribute("visibility", "hidden");
|
||||
dot.setAttribute("visibility", "hidden");
|
||||
tooltip.hidden = true;
|
||||
};
|
||||
svg.addEventListener("pointerleave", hide);
|
||||
svg.addEventListener("pointermove", (ev) => {
|
||||
const rect = svg.getBoundingClientRect();
|
||||
const relX = ((ev.clientX - rect.left) / rect.width) * W;
|
||||
let best: { i: number; pt: Point } | null = null;
|
||||
points.forEach((pt, i) => {
|
||||
if (pt === null) return;
|
||||
if (best === null || Math.abs(x(i) - relX) < Math.abs(x(best.i) - relX)) best = { i, pt };
|
||||
});
|
||||
if (best === null) {
|
||||
hide();
|
||||
return;
|
||||
}
|
||||
const { i, pt } = best as { i: number; pt: Point };
|
||||
const cx = x(i);
|
||||
const cy = y(pt.value);
|
||||
crosshair.setAttribute("x1", String(cx));
|
||||
crosshair.setAttribute("x2", String(cx));
|
||||
crosshair.setAttribute("visibility", "visible");
|
||||
dot.setAttribute("cx", String(cx));
|
||||
dot.setAttribute("cy", String(cy));
|
||||
dot.setAttribute("visibility", "visible");
|
||||
tooltip.innerHTML = "";
|
||||
const dateEl = document.createElement("div");
|
||||
dateEl.textContent = pt.date;
|
||||
const valueEl = document.createElement("div");
|
||||
valueEl.className = "tt-value";
|
||||
valueEl.textContent = formatValue(pt.value);
|
||||
tooltip.append(dateEl, valueEl);
|
||||
tooltip.hidden = false;
|
||||
tooltip.style.left = `${(cx / W) * rect.width}px`;
|
||||
tooltip.style.top = `${(cy / H) * rect.height}px`;
|
||||
});
|
||||
}
|
||||
@@ -0,0 +1,374 @@
|
||||
import DOMPurify from "dompurify";
|
||||
import { marked } from "marked";
|
||||
|
||||
import type {
|
||||
BriefingResult,
|
||||
BriefingSummary,
|
||||
ErrorLine,
|
||||
HealthResponse,
|
||||
Quote,
|
||||
SeriesResponse,
|
||||
} from "../shared/types";
|
||||
import { formatValue, renderLineChart } from "./chart";
|
||||
|
||||
/** Symbols shown as stat tiles, in order (subset of what the daemon tracks). */
|
||||
const TILE_SYMBOLS = ["^GSPC", "^IXIC", "^SOX", "^VIX", "KRW=X", "^TNX"];
|
||||
const GROUP_LABELS: Record<string, string> = {
|
||||
indices: "지수",
|
||||
futures: "선물",
|
||||
rates: "금리",
|
||||
fx: "환율/달러",
|
||||
commodities: "원자재/크립토",
|
||||
sectors: "섹터 ETF",
|
||||
semis: "반도체",
|
||||
megacap: "빅테크",
|
||||
korea_linked: "한국 연관",
|
||||
};
|
||||
|
||||
function el<K extends keyof HTMLElementTagNameMap>(
|
||||
tag: K,
|
||||
className?: string,
|
||||
text?: string,
|
||||
): HTMLElementTagNameMap[K] {
|
||||
const node = document.createElement(tag);
|
||||
if (className) node.className = className;
|
||||
if (text !== undefined) node.textContent = text;
|
||||
return node;
|
||||
}
|
||||
|
||||
function byId<T extends HTMLElement>(id: string): T {
|
||||
const node = document.getElementById(id);
|
||||
if (!node) throw new Error(`missing #${id}`);
|
||||
return node as T;
|
||||
}
|
||||
|
||||
async function getJson<T>(url: string): Promise<T> {
|
||||
const res = await fetch(url);
|
||||
if (!res.ok) throw new Error(`${url} -> ${res.status}`);
|
||||
return (await res.json()) as T;
|
||||
}
|
||||
|
||||
// ------------------------------------------------------------------ dates & clocks
|
||||
|
||||
/** Today's calendar date in Seoul, as YYYY-MM-DD. */
|
||||
function kstToday(): string {
|
||||
return new Intl.DateTimeFormat("en-CA", { timeZone: "Asia/Seoul" }).format(new Date());
|
||||
}
|
||||
|
||||
function addDays(iso: string, delta: number): string {
|
||||
const d = new Date(`${iso}T00:00:00Z`);
|
||||
d.setUTCDate(d.getUTCDate() + delta);
|
||||
return d.toISOString().slice(0, 10);
|
||||
}
|
||||
|
||||
/** Weekday of a pure calendar date (0=Sun..6=Sat). */
|
||||
function weekday(iso: string): number {
|
||||
return new Date(`${iso}T00:00:00Z`).getUTCDay();
|
||||
}
|
||||
|
||||
function fmtInZone(dt: Date, tz: string, withSeconds = false): string {
|
||||
return new Intl.DateTimeFormat("ko-KR", {
|
||||
timeZone: tz,
|
||||
month: "2-digit",
|
||||
day: "2-digit",
|
||||
weekday: "short",
|
||||
hour: "2-digit",
|
||||
minute: "2-digit",
|
||||
...(withSeconds ? { second: "2-digit" } : {}),
|
||||
hour12: false,
|
||||
}).format(dt);
|
||||
}
|
||||
|
||||
/** Live Seoul + New York clocks in the top bar. */
|
||||
function startClocks(): void {
|
||||
const host = byId<HTMLElement>("clocks");
|
||||
const seoul = el("span", "clock");
|
||||
const ny = el("span", "clock");
|
||||
host.append(seoul, ny);
|
||||
const tick = () => {
|
||||
const now = new Date();
|
||||
seoul.textContent = `서울 ${fmtInZone(now, "Asia/Seoul", true)}`;
|
||||
ny.textContent = `뉴욕 ${fmtInZone(now, "America/New_York", true)}`;
|
||||
};
|
||||
tick();
|
||||
setInterval(tick, 1000);
|
||||
}
|
||||
|
||||
// ------------------------------------------------------------------ stat tiles
|
||||
|
||||
function deltaText(q: Quote): { text: string; cls: string } {
|
||||
const isRates = q.group === "rates";
|
||||
const v = isRates ? q.change_abs : q.change_pct;
|
||||
if (v === null || v === undefined) return { text: "—", cls: "" };
|
||||
const arrow = v > 0 ? "▲" : v < 0 ? "▼" : "＝";
|
||||
const cls = v > 0 ? "up" : v < 0 ? "down" : "";
|
||||
const body = isRates ? `${(v * 100).toFixed(1)}bp` : `${Math.abs(v).toFixed(2)}%`;
|
||||
return { text: `${arrow} ${body}`, cls };
|
||||
}
|
||||
|
||||
function renderTiles(result: BriefingResult): void {
|
||||
const host = byId<HTMLElement>("tiles");
|
||||
host.textContent = "";
|
||||
const quotes = new Map(result.payload.quotes.map((q) => [q.symbol, q]));
|
||||
for (const sym of TILE_SYMBOLS) {
|
||||
const q = quotes.get(sym);
|
||||
if (!q) continue;
|
||||
const tile = el("div", "tile");
|
||||
tile.append(el("div", "tile-label", q.name || sym));
|
||||
tile.append(el("div", "tile-value", q.close === null ? "—" : formatValue(q.close)));
|
||||
const { text, cls } = deltaText(q);
|
||||
tile.append(el("div", `tile-delta ${cls}`.trim(), text));
|
||||
host.append(tile);
|
||||
}
|
||||
}
|
||||
|
||||
// ------------------------------------------------------------------ briefing list + body
|
||||
|
||||
function badgeFor(s: BriefingSummary): HTMLElement {
|
||||
if (s.error) return el("span", "badge badge-error", "오류");
|
||||
if (s.degraded) return el("span", "badge badge-warn", "축소");
|
||||
return el("span", "badge badge-ok", "정상");
|
||||
}
|
||||
|
||||
/** Label for a calendar day with no briefing. The US session feeding KRX date D is D-1:
|
||||
* a weekend session day means "no US market"; today with a weekday session is just "not yet". */
|
||||
function closedRow(krxDate: string, today: string): HTMLElement {
|
||||
const sessionDay = weekday(addDays(krxDate, -1));
|
||||
const isWeekend = sessionDay === 0 || sessionDay === 6;
|
||||
const label = isWeekend ? "주말 · 미국 휴장" : krxDate === today ? "오늘 · 미국 마감 후 생성 예정" : "미국 휴장";
|
||||
const item = el("li", "day-closed");
|
||||
item.append(el("span", "briefing-date", krxDate), el("span", undefined, label));
|
||||
return item;
|
||||
}
|
||||
|
||||
function renderList(
|
||||
summaries: BriefingSummary[],
|
||||
selected: string,
|
||||
onSelect: (krxDate: string) => void,
|
||||
): void {
|
||||
const list = byId<HTMLUListElement>("briefing-list");
|
||||
list.textContent = "";
|
||||
const byDate = new Map(summaries.map((s) => [s.krx_date, s]));
|
||||
const today = kstToday();
|
||||
const newest = summaries[0]?.krx_date ?? today;
|
||||
const oldest = summaries[summaries.length - 1]?.krx_date ?? today;
|
||||
const start = today > newest ? today : newest;
|
||||
// walk the calendar day by day so gaps (weekends, US holidays) are visible, not silent
|
||||
for (let d = start; d >= oldest; d = addDays(d, -1)) {
|
||||
const s = byDate.get(d);
|
||||
if (!s) {
|
||||
list.append(closedRow(d, today));
|
||||
continue;
|
||||
}
|
||||
const item = el("li");
|
||||
const button = el("button");
|
||||
button.type = "button";
|
||||
button.setAttribute("aria-current", String(s.krx_date === selected));
|
||||
button.append(el("span", "briefing-date", `${s.krx_date} (KRX)`));
|
||||
const line = el("span", "briefing-line");
|
||||
line.append(`세션 ${s.session_date}`, badgeFor(s));
|
||||
if (s.data_gaps.length > 0) line.append(el("span", "badge badge-warn", `결측 ${s.data_gaps.length}`));
|
||||
button.append(line);
|
||||
if (s.headline) button.append(el("span", "briefing-line", s.headline));
|
||||
button.addEventListener("click", () => onSelect(s.krx_date));
|
||||
item.append(button);
|
||||
list.append(item);
|
||||
}
|
||||
}
|
||||
|
||||
function metaChips(result: BriefingResult): HTMLElement[] {
|
||||
const p = result.payload;
|
||||
const close = new Date(p.us_close_time);
|
||||
const chips: HTMLElement[] = [
|
||||
el("span", undefined, `미국 세션 ${p.session_date} → KRX ${p.krx_date}`),
|
||||
el(
|
||||
"span",
|
||||
undefined,
|
||||
`마감 뉴욕 ${fmtInZone(close, "America/New_York")} · 서울 ${fmtInZone(close, "Asia/Seoul")}`,
|
||||
),
|
||||
el("span", undefined, `생성 ${new Date(p.generated_at).toLocaleString("ko-KR")}`),
|
||||
];
|
||||
if (!p.krx_open_today) chips.push(el("span", "badge badge-warn", "한국 휴장"));
|
||||
if (result.degraded) chips.push(el("span", "badge badge-warn", "요약 없음"));
|
||||
for (const gap of p.data_gaps) chips.push(el("span", "badge badge-warn", gap));
|
||||
if (result.error) chips.push(el("span", "badge badge-error", result.error));
|
||||
return chips;
|
||||
}
|
||||
|
||||
/** Compact "핵심 요약" card: the LLM report's actionable parts, above the full markdown. */
|
||||
function renderSummaryCard(result: BriefingResult): void {
|
||||
const host = byId<HTMLElement>("report-summary");
|
||||
host.textContent = "";
|
||||
const report = result.report;
|
||||
if (!report) return;
|
||||
const card = el("section", "summary-card");
|
||||
card.setAttribute("aria-label", "핵심 요약");
|
||||
if (report.headline) card.append(el("p", "summary-headline", report.headline));
|
||||
if (report.market_overview) card.append(el("p", "summary-overview", report.market_overview));
|
||||
const blocks: Array<[string, string[], string]> = [
|
||||
["한국 장 시사점", report.korea_implications, ""],
|
||||
["오늘 볼 것", report.watchlist_today, ""],
|
||||
["리스크", report.risk_flags, "risk"],
|
||||
];
|
||||
const grid = el("div", "summary-grid");
|
||||
for (const [title, items, kind] of blocks) {
|
||||
if (!items || items.length === 0) continue;
|
||||
const block = el("div", `summary-block ${kind}`.trim());
|
||||
block.append(el("h3", undefined, title));
|
||||
const list = el("ul");
|
||||
for (const item of items) list.append(el("li", undefined, item));
|
||||
block.append(list);
|
||||
grid.append(block);
|
||||
}
|
||||
if (grid.childElementCount > 0) card.append(grid);
|
||||
host.append(card);
|
||||
}
|
||||
|
||||
async function showBriefing(krxDate: string): Promise<void> {
|
||||
const result = await getJson<BriefingResult>(`/api/briefings/${krxDate}`);
|
||||
renderTiles(result);
|
||||
const meta = byId<HTMLElement>("report-meta");
|
||||
meta.textContent = "";
|
||||
meta.append(...metaChips(result));
|
||||
renderSummaryCard(result);
|
||||
const body = byId<HTMLElement>("report-body");
|
||||
// News titles inside the markdown come from external feeds - sanitize the rendered HTML.
|
||||
body.innerHTML = DOMPurify.sanitize(marked.parse(result.markdown, { async: false }));
|
||||
}
|
||||
|
||||
// ------------------------------------------------------------------ chart section
|
||||
|
||||
function seriesLabel(sym: string, data: SeriesResponse): string {
|
||||
const entry = data.series[sym];
|
||||
return entry && entry.name && entry.name !== sym ? `${entry.name} (${sym})` : sym;
|
||||
}
|
||||
|
||||
function renderChartTable(host: HTMLElement, dates: string[], values: (number | null)[]): void {
|
||||
host.textContent = "";
|
||||
const table = el("table", "data-table");
|
||||
const head = el("tr");
|
||||
head.append(el("th", undefined, "세션"), el("th", undefined, "종가"));
|
||||
table.append(head);
|
||||
for (let i = dates.length - 1; i >= 0; i--) {
|
||||
const row = el("tr");
|
||||
const v = values[i];
|
||||
row.append(
|
||||
el("td", undefined, dates[i] ?? ""),
|
||||
el("td", undefined, v === null || v === undefined ? "—" : formatValue(v)),
|
||||
);
|
||||
table.append(row);
|
||||
}
|
||||
host.append(table);
|
||||
}
|
||||
|
||||
function setupChart(data: SeriesResponse): void {
|
||||
const select = byId<HTMLSelectElement>("symbol-select");
|
||||
const chartHost = byId<HTMLElement>("chart");
|
||||
const tableHost = byId<HTMLElement>("chart-table");
|
||||
const toggle = byId<HTMLButtonElement>("table-toggle");
|
||||
const chartTitle = byId<HTMLElement>("chart-title");
|
||||
|
||||
const symbols = Object.keys(data.series);
|
||||
if (symbols.length === 0) {
|
||||
chartHost.append(el("p", "chart-empty", "브리핑이 쌓이면 시세 추이가 표시됩니다."));
|
||||
select.disabled = true;
|
||||
toggle.disabled = true;
|
||||
return;
|
||||
}
|
||||
|
||||
const byGroup = new Map<string, string[]>();
|
||||
for (const sym of symbols) {
|
||||
const group = data.series[sym]?.group ?? "etc";
|
||||
const bucket = byGroup.get(group) ?? [];
|
||||
bucket.push(sym);
|
||||
byGroup.set(group, bucket);
|
||||
}
|
||||
for (const [group, syms] of byGroup) {
|
||||
const optgroup = document.createElement("optgroup");
|
||||
optgroup.label = GROUP_LABELS[group] ?? group;
|
||||
for (const sym of syms.sort()) {
|
||||
const option = document.createElement("option");
|
||||
option.value = sym;
|
||||
option.textContent = seriesLabel(sym, data);
|
||||
optgroup.append(option);
|
||||
}
|
||||
select.append(optgroup);
|
||||
}
|
||||
|
||||
const draw = () => {
|
||||
const sym = select.value;
|
||||
const entry = data.series[sym];
|
||||
if (!entry) return;
|
||||
chartTitle.textContent = `시세 추이 — ${seriesLabel(sym, data)}`;
|
||||
renderLineChart(chartHost, data.sessions, entry.closes, seriesLabel(sym, data));
|
||||
renderChartTable(tableHost, data.sessions, entry.closes);
|
||||
};
|
||||
select.value = symbols.includes("^GSPC") ? "^GSPC" : (symbols[0] ?? "");
|
||||
select.addEventListener("change", draw);
|
||||
toggle.addEventListener("click", () => {
|
||||
const showTable = tableHost.hidden;
|
||||
tableHost.hidden = !showTable;
|
||||
toggle.setAttribute("aria-pressed", String(showTable));
|
||||
toggle.textContent = showTable ? "표 숨기기" : "표로 보기";
|
||||
});
|
||||
draw();
|
||||
}
|
||||
|
||||
// ------------------------------------------------------------------ errors + health
|
||||
|
||||
function renderErrors(errors: ErrorLine[]): void {
|
||||
if (errors.length === 0) return;
|
||||
const panel = byId<HTMLElement>("errors-panel");
|
||||
panel.hidden = false;
|
||||
byId<HTMLElement>("errors-count").textContent = String(errors.length);
|
||||
const list = byId<HTMLUListElement>("errors-list");
|
||||
for (const e of errors.slice(0, 30)) {
|
||||
const item = el("li");
|
||||
item.append(
|
||||
el("span", "err-ts", e.ts),
|
||||
el("span", "err-subject", e.subject),
|
||||
el("span", "err-detail", e.detail),
|
||||
);
|
||||
list.append(item);
|
||||
}
|
||||
}
|
||||
|
||||
// ------------------------------------------------------------------ boot
|
||||
|
||||
async function main(): Promise<void> {
|
||||
startClocks();
|
||||
const health = await getJson<HealthResponse>("/api/health");
|
||||
byId<HTMLElement>("health").textContent =
|
||||
health.report_count > 0
|
||||
? `브리핑 ${health.report_count}건 · 최신 ${health.latest_krx_date}`
|
||||
: "아직 쌓인 브리핑이 없습니다";
|
||||
|
||||
const [summaries, series, errors] = await Promise.all([
|
||||
getJson<BriefingSummary[]>("/api/briefings"),
|
||||
getJson<SeriesResponse>("/api/series"),
|
||||
getJson<ErrorLine[]>("/api/errors"),
|
||||
]);
|
||||
|
||||
renderErrors(errors);
|
||||
setupChart(series);
|
||||
|
||||
if (summaries.length === 0) {
|
||||
byId<HTMLElement>("report-body").append(
|
||||
el("p", "chart-empty", "브리핑이 아직 없습니다. 다음 미국 장 마감 후 첫 브리핑이 생성됩니다."),
|
||||
);
|
||||
return;
|
||||
}
|
||||
|
||||
let selected = summaries[0]!.krx_date;
|
||||
const select = async (krxDate: string) => {
|
||||
selected = krxDate;
|
||||
renderList(summaries, selected, (d) => void select(d));
|
||||
await showBriefing(krxDate);
|
||||
};
|
||||
await select(selected);
|
||||
}
|
||||
|
||||
void main().catch((err) => {
|
||||
console.error(err);
|
||||
byId<HTMLElement>("health").textContent = "대시보드 로드 실패 — 서버 로그를 확인하세요";
|
||||
});
|
||||
@@ -0,0 +1,235 @@
|
||||
/** Read-only dashboard API + static file server.
|
||||
*
|
||||
* The single source of truth is the reports directory the us2kr daemon archives into
|
||||
* (reports/YYYY-MM-DD.{md,json} + errors.log). Nothing here touches the SQLite DB, so the
|
||||
* dashboard container never contends with the daemon's WAL over virtiofs.
|
||||
*/
|
||||
|
||||
import { createServer, type ServerResponse } from "node:http";
|
||||
import { readFile, readdir, stat } from "node:fs/promises";
|
||||
import path from "node:path";
|
||||
import { fileURLToPath } from "node:url";
|
||||
|
||||
import type {
|
||||
BriefingResult,
|
||||
BriefingSummary,
|
||||
ErrorLine,
|
||||
HealthResponse,
|
||||
SeriesResponse,
|
||||
} from "./shared/types";
|
||||
|
||||
const REPORTS_DIR = process.env.US2KR_REPORTS_DIR ?? "/data/reports";
|
||||
const PORT = Number(process.env.PORT ?? 8090);
|
||||
const PUBLIC_DIR = path.join(path.dirname(fileURLToPath(import.meta.url)), "public");
|
||||
|
||||
const DATE_RE = /^\d{4}-\d{2}-\d{2}$/;
|
||||
const JSON_FILE_RE = /^\d{4}-\d{2}-\d{2}\.json$/;
|
||||
|
||||
// ------------------------------------------------------------------ report loading
|
||||
|
||||
/** mtime+size keyed cache so repeated requests do not re-parse unchanged files. */
|
||||
const cache = new Map<string, { mtimeMs: number; size: number; data: BriefingResult }>();
|
||||
|
||||
async function loadBriefing(krxDate: string): Promise<BriefingResult | null> {
|
||||
const file = path.join(REPORTS_DIR, `${krxDate}.json`);
|
||||
let st;
|
||||
try {
|
||||
st = await stat(file);
|
||||
} catch {
|
||||
return null;
|
||||
}
|
||||
const cached = cache.get(file);
|
||||
if (cached && cached.mtimeMs === st.mtimeMs && cached.size === st.size) return cached.data;
|
||||
try {
|
||||
const data = JSON.parse(await readFile(file, "utf8")) as BriefingResult;
|
||||
cache.set(file, { mtimeMs: st.mtimeMs, size: st.size, data });
|
||||
return data;
|
||||
} catch (err) {
|
||||
console.error(`unparseable report ${file}:`, err);
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
async function listDates(): Promise<string[]> {
|
||||
let names: string[];
|
||||
try {
|
||||
names = await readdir(REPORTS_DIR);
|
||||
} catch {
|
||||
return []; // directory not mounted yet / no briefing produced yet
|
||||
}
|
||||
return names
|
||||
.filter((n) => JSON_FILE_RE.test(n))
|
||||
.map((n) => n.slice(0, 10))
|
||||
.sort()
|
||||
.reverse();
|
||||
}
|
||||
|
||||
function summarize(krxDate: string, r: BriefingResult): BriefingSummary {
|
||||
return {
|
||||
krx_date: krxDate,
|
||||
session_date: r.payload.session_date,
|
||||
generated_at: r.payload.generated_at,
|
||||
krx_open_today: r.payload.krx_open_today,
|
||||
model_used: r.model_used,
|
||||
degraded: r.degraded,
|
||||
error: r.error,
|
||||
headline: r.report?.headline ?? null,
|
||||
quote_count: r.payload.quotes.length,
|
||||
news_count: r.payload.news.length,
|
||||
data_gaps: r.payload.data_gaps,
|
||||
};
|
||||
}
|
||||
|
||||
async function allBriefings(): Promise<Array<{ krxDate: string; result: BriefingResult }>> {
|
||||
const out: Array<{ krxDate: string; result: BriefingResult }> = [];
|
||||
for (const krxDate of await listDates()) {
|
||||
const result = await loadBriefing(krxDate);
|
||||
if (result) out.push({ krxDate, result });
|
||||
}
|
||||
return out; // newest first (listDates is descending)
|
||||
}
|
||||
|
||||
async function buildSeries(): Promise<SeriesResponse> {
|
||||
const briefings = (await allBriefings()).reverse(); // ascending for time series
|
||||
// One column per US session; a session may appear once only (krx_date↔session is 1:1).
|
||||
const sessions: string[] = [];
|
||||
const series: SeriesResponse["series"] = {};
|
||||
for (const { result } of briefings) {
|
||||
const session = result.payload.session_date;
|
||||
if (sessions.includes(session)) continue;
|
||||
sessions.push(session);
|
||||
const idx = sessions.length - 1;
|
||||
for (const q of result.payload.quotes) {
|
||||
let entry = series[q.symbol];
|
||||
if (!entry) {
|
||||
entry = { name: q.name, group: q.group, closes: [], change_pct: [] };
|
||||
series[q.symbol] = entry;
|
||||
}
|
||||
entry.closes[idx] = q.close;
|
||||
entry.change_pct[idx] = q.change_pct;
|
||||
}
|
||||
}
|
||||
// pad ragged arrays so every series aligns with `sessions`
|
||||
for (const entry of Object.values(series)) {
|
||||
for (let i = 0; i < sessions.length; i++) {
|
||||
if (entry.closes[i] === undefined) entry.closes[i] = null;
|
||||
if (entry.change_pct[i] === undefined) entry.change_pct[i] = null;
|
||||
}
|
||||
}
|
||||
return { sessions, series };
|
||||
}
|
||||
|
||||
async function readErrors(limit = 100): Promise<ErrorLine[]> {
|
||||
let text: string;
|
||||
try {
|
||||
text = await readFile(path.join(REPORTS_DIR, "errors.log"), "utf8");
|
||||
} catch {
|
||||
return [];
|
||||
}
|
||||
const lines = text.split("\n").filter((l) => l.trim().length > 0);
|
||||
return lines
|
||||
.slice(-limit)
|
||||
.reverse()
|
||||
.map((line) => {
|
||||
const [ts = "", subject = "", ...rest] = line.split("\t");
|
||||
return { ts, subject, detail: rest.join("\t") };
|
||||
});
|
||||
}
|
||||
|
||||
// ------------------------------------------------------------------ http plumbing
|
||||
|
||||
function sendJson(res: ServerResponse, status: number, body: unknown): void {
|
||||
const payload = JSON.stringify(body);
|
||||
res.writeHead(status, {
|
||||
"content-type": "application/json; charset=utf-8",
|
||||
"cache-control": "no-cache",
|
||||
});
|
||||
res.end(payload);
|
||||
}
|
||||
|
||||
const STATIC_TYPES: Record<string, string> = {
|
||||
".html": "text/html; charset=utf-8",
|
||||
".js": "text/javascript; charset=utf-8",
|
||||
".css": "text/css; charset=utf-8",
|
||||
".svg": "image/svg+xml",
|
||||
};
|
||||
|
||||
async function sendStatic(res: ServerResponse, urlPath: string): Promise<void> {
|
||||
const rel = urlPath === "/" ? "index.html" : urlPath.replace(/^\/+/, "");
|
||||
const file = path.resolve(PUBLIC_DIR, rel);
|
||||
if (!file.startsWith(PUBLIC_DIR + path.sep) && file !== path.join(PUBLIC_DIR, "index.html")) {
|
||||
sendJson(res, 404, { error: "not found" });
|
||||
return;
|
||||
}
|
||||
try {
|
||||
const body = await readFile(file);
|
||||
res.writeHead(200, {
|
||||
"content-type": STATIC_TYPES[path.extname(file)] ?? "application/octet-stream",
|
||||
});
|
||||
res.end(body);
|
||||
} catch {
|
||||
sendJson(res, 404, { error: "not found" });
|
||||
}
|
||||
}
|
||||
|
||||
const server = createServer(async (req, res) => {
|
||||
const url = new URL(req.url ?? "/", "http://localhost");
|
||||
const p = url.pathname;
|
||||
try {
|
||||
if (req.method !== "GET" && req.method !== "HEAD") {
|
||||
sendJson(res, 405, { error: "method not allowed" });
|
||||
return;
|
||||
}
|
||||
if (p === "/api/health") {
|
||||
const dates = await listDates();
|
||||
const body: HealthResponse = {
|
||||
ok: true,
|
||||
report_count: dates.length,
|
||||
reports_dir: REPORTS_DIR,
|
||||
latest_krx_date: dates[0] ?? null,
|
||||
};
|
||||
sendJson(res, 200, body);
|
||||
return;
|
||||
}
|
||||
if (p === "/api/briefings") {
|
||||
const briefings = await allBriefings();
|
||||
sendJson(res, 200, briefings.map(({ krxDate, result }) => summarize(krxDate, result)));
|
||||
return;
|
||||
}
|
||||
const detail = p.match(/^\/api\/briefings\/(\d{4}-\d{2}-\d{2})$/);
|
||||
if (detail) {
|
||||
const krxDate = detail[1]!;
|
||||
if (!DATE_RE.test(krxDate)) {
|
||||
sendJson(res, 400, { error: "bad date" });
|
||||
return;
|
||||
}
|
||||
const result = await loadBriefing(krxDate);
|
||||
if (!result) {
|
||||
sendJson(res, 404, { error: `no briefing for ${krxDate}` });
|
||||
return;
|
||||
}
|
||||
sendJson(res, 200, result);
|
||||
return;
|
||||
}
|
||||
if (p === "/api/series") {
|
||||
sendJson(res, 200, await buildSeries());
|
||||
return;
|
||||
}
|
||||
if (p === "/api/errors") {
|
||||
sendJson(res, 200, await readErrors());
|
||||
return;
|
||||
}
|
||||
if (p.startsWith("/api/")) {
|
||||
sendJson(res, 404, { error: "not found" });
|
||||
return;
|
||||
}
|
||||
await sendStatic(res, p);
|
||||
} catch (err) {
|
||||
console.error(`request ${p} failed:`, err);
|
||||
sendJson(res, 500, { error: "internal error" });
|
||||
}
|
||||
});
|
||||
|
||||
server.listen(PORT, "0.0.0.0", () => {
|
||||
console.log(`us2kr dashboard listening on :${PORT} (reports: ${REPORTS_DIR})`);
|
||||
});
|
||||
@@ -0,0 +1,122 @@
|
||||
/** Mirrors us2kr/models.py (pydantic model_dump_json → snake_case). */
|
||||
|
||||
export interface Quote {
|
||||
symbol: string;
|
||||
name: string;
|
||||
group: string;
|
||||
close: number | null;
|
||||
prev_close: number | null;
|
||||
change_pct: number | null;
|
||||
change_abs: number | null;
|
||||
day_high: number | null;
|
||||
day_low: number | null;
|
||||
volume: number | null;
|
||||
avg_volume_10d: number | null;
|
||||
after_hours_price: number | null;
|
||||
after_hours_change_pct: number | null;
|
||||
as_of: string | null;
|
||||
source: string;
|
||||
}
|
||||
|
||||
export interface NewsItem {
|
||||
title: string;
|
||||
summary: string;
|
||||
link: string;
|
||||
source: string;
|
||||
published: string;
|
||||
}
|
||||
|
||||
export interface EconEvent {
|
||||
name: string;
|
||||
time: string | null;
|
||||
country: string;
|
||||
actual: string | null;
|
||||
forecast: string | null;
|
||||
previous: string | null;
|
||||
importance: "high" | "medium" | "low";
|
||||
kind: "released" | "upcoming";
|
||||
}
|
||||
|
||||
export interface EarningsItem {
|
||||
symbol: string;
|
||||
name: string;
|
||||
report_date: string;
|
||||
timing: "bmo" | "amc" | "unknown";
|
||||
eps_actual: number | null;
|
||||
eps_estimate: number | null;
|
||||
revenue_actual: number | null;
|
||||
revenue_estimate: number | null;
|
||||
}
|
||||
|
||||
export interface MarketPayload {
|
||||
session_date: string;
|
||||
us_close_time: string;
|
||||
generated_at: string;
|
||||
krx_date: string;
|
||||
krx_open_today: boolean;
|
||||
quotes: Quote[];
|
||||
news: NewsItem[];
|
||||
events: EconEvent[];
|
||||
earnings: EarningsItem[];
|
||||
history_notes: string[];
|
||||
data_gaps: string[];
|
||||
}
|
||||
|
||||
export interface Report {
|
||||
headline: string;
|
||||
market_overview: string;
|
||||
key_drivers: string[];
|
||||
rates_fx_commodities: string;
|
||||
korea_implications: string[];
|
||||
watchlist_today: string[];
|
||||
risk_flags: string[];
|
||||
data_gaps: string[];
|
||||
}
|
||||
|
||||
export interface BriefingResult {
|
||||
payload: MarketPayload;
|
||||
report: Report | null;
|
||||
markdown: string;
|
||||
model_used: string | null;
|
||||
degraded: boolean;
|
||||
error: string | null;
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------- API shapes
|
||||
|
||||
export interface BriefingSummary {
|
||||
krx_date: string;
|
||||
session_date: string;
|
||||
generated_at: string;
|
||||
krx_open_today: boolean;
|
||||
model_used: string | null;
|
||||
degraded: boolean;
|
||||
error: string | null;
|
||||
headline: string | null;
|
||||
quote_count: number;
|
||||
news_count: number;
|
||||
data_gaps: string[];
|
||||
}
|
||||
|
||||
export interface SeriesResponse {
|
||||
/** US session dates, ascending. */
|
||||
sessions: string[];
|
||||
/** symbol → aligned arrays (null where the session had no value). */
|
||||
series: Record<
|
||||
string,
|
||||
{ name: string; group: string; closes: (number | null)[]; change_pct: (number | null)[] }
|
||||
>;
|
||||
}
|
||||
|
||||
export interface ErrorLine {
|
||||
ts: string;
|
||||
subject: string;
|
||||
detail: string;
|
||||
}
|
||||
|
||||
export interface HealthResponse {
|
||||
ok: boolean;
|
||||
report_count: number;
|
||||
reports_dir: string;
|
||||
latest_krx_date: string | null;
|
||||
}
|
||||
@@ -0,0 +1,16 @@
|
||||
{
|
||||
"compilerOptions": {
|
||||
"target": "ES2022",
|
||||
"module": "ESNext",
|
||||
"moduleResolution": "bundler",
|
||||
"lib": ["ES2022", "DOM", "DOM.Iterable"],
|
||||
"types": ["node"],
|
||||
"strict": true,
|
||||
"noUncheckedIndexedAccess": true,
|
||||
"noFallthroughCasesInSwitch": true,
|
||||
"forceConsistentCasingInFileNames": true,
|
||||
"skipLibCheck": true,
|
||||
"noEmit": true
|
||||
},
|
||||
"include": ["src"]
|
||||
}
|
||||
@@ -0,0 +1,55 @@
|
||||
<!doctype html>
|
||||
<html lang="ko">
|
||||
<head>
|
||||
<meta charset="utf-8" />
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1" />
|
||||
<title>US2KR 대시보드</title>
|
||||
<link rel="stylesheet" href="/styles.css" />
|
||||
</head>
|
||||
<body>
|
||||
<header class="topbar">
|
||||
<h1>US2KR <span class="topbar-sub">미국 마감 → 한국 개장 브리핑</span></h1>
|
||||
<div class="topbar-right">
|
||||
<div id="clocks" class="clocks"></div>
|
||||
<div id="health" class="health" role="status"></div>
|
||||
</div>
|
||||
</header>
|
||||
|
||||
<main class="layout">
|
||||
<section id="tiles" class="tiles" aria-label="최신 세션 요약"></section>
|
||||
|
||||
<section class="panel chart-panel" aria-label="시세 추이">
|
||||
<div class="panel-head">
|
||||
<h2 id="chart-title">시세 추이</h2>
|
||||
<div class="chart-controls">
|
||||
<label class="visually-hidden" for="symbol-select">종목 선택</label>
|
||||
<select id="symbol-select"></select>
|
||||
<button id="table-toggle" type="button" aria-pressed="false">표로 보기</button>
|
||||
</div>
|
||||
</div>
|
||||
<div id="chart" class="chart"></div>
|
||||
<div id="chart-table" class="chart-table" hidden></div>
|
||||
</section>
|
||||
|
||||
<div class="columns">
|
||||
<aside class="panel list-panel" aria-label="브리핑 목록">
|
||||
<h2>브리핑</h2>
|
||||
<ul id="briefing-list" class="briefing-list"></ul>
|
||||
</aside>
|
||||
|
||||
<article class="panel report-panel">
|
||||
<div id="report-meta" class="report-meta"></div>
|
||||
<div id="report-summary"></div>
|
||||
<div id="report-body" class="markdown"></div>
|
||||
</article>
|
||||
</div>
|
||||
|
||||
<section id="errors-panel" class="panel errors-panel" hidden>
|
||||
<h2>오류 로그 <span id="errors-count" class="badge badge-error"></span></h2>
|
||||
<ul id="errors-list" class="errors-list"></ul>
|
||||
</section>
|
||||
</main>
|
||||
|
||||
<script src="/app.js" defer></script>
|
||||
</body>
|
||||
</html>
|
||||
@@ -0,0 +1,254 @@
|
||||
/* Design tokens - light is the base, dark overrides via prefers-color-scheme. */
|
||||
:root {
|
||||
color-scheme: light;
|
||||
--page: #f9f9f7;
|
||||
--surface: #fcfcfb;
|
||||
--ink: #0b0b0b;
|
||||
--ink-2: #52514e;
|
||||
--muted: #898781;
|
||||
--grid: #e1e0d9;
|
||||
--baseline: #c3c2b7;
|
||||
--border: rgba(11, 11, 11, 0.1);
|
||||
--series-1: #2a78d6;
|
||||
/* Korean market convention: up = red, down = blue (diverging pair poles). */
|
||||
--delta-up: #d03b3b;
|
||||
--delta-down: #256abf;
|
||||
--badge-warn-bg: #fdf3d7;
|
||||
--badge-warn-ink: #7a5600;
|
||||
--badge-err-bg: #fbe3e3;
|
||||
--badge-err-ink: #8f2020;
|
||||
--badge-ok-bg: #e2f2e2;
|
||||
--badge-ok-ink: #106310;
|
||||
}
|
||||
@media (prefers-color-scheme: dark) {
|
||||
:root {
|
||||
color-scheme: dark;
|
||||
--page: #0d0d0d;
|
||||
--surface: #1a1a19;
|
||||
--ink: #ffffff;
|
||||
--ink-2: #c3c2b7;
|
||||
--muted: #898781;
|
||||
--grid: #2c2c2a;
|
||||
--baseline: #383835;
|
||||
--border: rgba(255, 255, 255, 0.1);
|
||||
--series-1: #3987e5;
|
||||
--delta-up: #e66767;
|
||||
--delta-down: #3987e5;
|
||||
--badge-warn-bg: #3a2f10;
|
||||
--badge-warn-ink: #fab219;
|
||||
--badge-err-bg: #3c1a1a;
|
||||
--badge-err-ink: #e66767;
|
||||
--badge-ok-bg: #143214;
|
||||
--badge-ok-ink: #4fc24f;
|
||||
}
|
||||
}
|
||||
|
||||
* { box-sizing: border-box; }
|
||||
body {
|
||||
margin: 0;
|
||||
background: var(--page);
|
||||
color: var(--ink);
|
||||
font: 14px/1.55 system-ui, -apple-system, "Segoe UI", sans-serif;
|
||||
}
|
||||
h1, h2 { margin: 0; font-weight: 650; }
|
||||
h1 { font-size: 17px; }
|
||||
h2 { font-size: 14px; color: var(--ink-2); }
|
||||
|
||||
.visually-hidden {
|
||||
position: absolute;
|
||||
width: 1px; height: 1px;
|
||||
margin: -1px; padding: 0;
|
||||
overflow: hidden;
|
||||
clip: rect(0 0 0 0);
|
||||
white-space: nowrap; border: 0;
|
||||
}
|
||||
|
||||
.topbar {
|
||||
display: flex;
|
||||
align-items: baseline;
|
||||
justify-content: space-between;
|
||||
gap: 12px;
|
||||
padding: 14px 20px;
|
||||
border-bottom: 1px solid var(--border);
|
||||
background: var(--surface);
|
||||
}
|
||||
.topbar-sub { font-size: 13px; font-weight: 400; color: var(--muted); margin-left: 6px; }
|
||||
.topbar-right { display: flex; flex-direction: column; align-items: flex-end; gap: 2px; }
|
||||
.clocks { display: flex; gap: 14px; font-size: 12.5px; color: var(--ink-2); font-variant-numeric: tabular-nums; }
|
||||
.clock::before { content: "●"; font-size: 7px; vertical-align: 2px; margin-right: 5px; color: var(--series-1); }
|
||||
.health { font-size: 12px; color: var(--muted); }
|
||||
|
||||
.layout {
|
||||
max-width: 1180px;
|
||||
margin: 0 auto;
|
||||
padding: 16px 20px 48px;
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 16px;
|
||||
}
|
||||
|
||||
.panel {
|
||||
background: var(--surface);
|
||||
border: 1px solid var(--border);
|
||||
border-radius: 10px;
|
||||
padding: 14px 16px;
|
||||
}
|
||||
.panel-head {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
justify-content: space-between;
|
||||
gap: 10px;
|
||||
flex-wrap: wrap;
|
||||
margin-bottom: 6px;
|
||||
}
|
||||
.chart-controls { display: flex; gap: 8px; align-items: center; }
|
||||
select, button {
|
||||
font: inherit;
|
||||
color: var(--ink);
|
||||
background: var(--surface);
|
||||
border: 1px solid var(--baseline);
|
||||
border-radius: 7px;
|
||||
padding: 5px 9px;
|
||||
}
|
||||
button { cursor: pointer; }
|
||||
button[aria-pressed="true"] { background: var(--grid); }
|
||||
|
||||
/* ------------------------------------------------------------------ stat tiles */
|
||||
.tiles {
|
||||
display: grid;
|
||||
grid-template-columns: repeat(auto-fit, minmax(150px, 1fr));
|
||||
gap: 10px;
|
||||
}
|
||||
.tile {
|
||||
background: var(--surface);
|
||||
border: 1px solid var(--border);
|
||||
border-radius: 10px;
|
||||
padding: 10px 13px;
|
||||
}
|
||||
.tile-label { font-size: 12px; color: var(--ink-2); }
|
||||
.tile-value { font-size: 21px; font-weight: 650; margin-top: 2px; }
|
||||
.tile-delta { font-size: 12.5px; margin-top: 1px; color: var(--ink-2); }
|
||||
.tile-delta.up { color: var(--delta-up); }
|
||||
.tile-delta.down { color: var(--delta-down); }
|
||||
|
||||
/* ------------------------------------------------------------------ chart */
|
||||
.chart { position: relative; }
|
||||
.chart svg { display: block; width: 100%; height: auto; }
|
||||
.chart .axis-label { font-size: 11px; fill: var(--muted); }
|
||||
.chart .gridline { stroke: var(--grid); stroke-width: 1; }
|
||||
.chart .baseline { stroke: var(--baseline); stroke-width: 1; }
|
||||
.chart .series-line { stroke: var(--series-1); stroke-width: 2; fill: none; }
|
||||
.chart .hover-dot { fill: var(--series-1); stroke: var(--surface); stroke-width: 2; }
|
||||
.chart .crosshair { stroke: var(--baseline); stroke-width: 1; stroke-dasharray: 3 3; }
|
||||
.chart-tooltip {
|
||||
position: absolute;
|
||||
pointer-events: none;
|
||||
background: var(--surface);
|
||||
border: 1px solid var(--baseline);
|
||||
border-radius: 7px;
|
||||
padding: 5px 9px;
|
||||
font-size: 12px;
|
||||
color: var(--ink);
|
||||
box-shadow: 0 2px 8px rgba(0, 0, 0, 0.12);
|
||||
white-space: nowrap;
|
||||
transform: translate(-50%, -110%);
|
||||
}
|
||||
.chart-tooltip .tt-value { font-weight: 650; }
|
||||
.chart-empty { color: var(--muted); padding: 24px 4px; }
|
||||
|
||||
.chart-table { overflow-x: auto; margin-top: 8px; }
|
||||
|
||||
/* ------------------------------------------------------------------ columns */
|
||||
.columns {
|
||||
display: grid;
|
||||
grid-template-columns: 250px 1fr;
|
||||
gap: 16px;
|
||||
align-items: start;
|
||||
}
|
||||
@media (max-width: 820px) {
|
||||
.columns { grid-template-columns: 1fr; }
|
||||
}
|
||||
|
||||
.briefing-list { list-style: none; margin: 10px 0 0; padding: 0; display: flex; flex-direction: column; gap: 6px; }
|
||||
.briefing-list button {
|
||||
width: 100%;
|
||||
text-align: left;
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 2px;
|
||||
border-color: var(--border);
|
||||
}
|
||||
.briefing-list button[aria-current="true"] { border-color: var(--series-1); background: var(--grid); }
|
||||
.briefing-date { font-weight: 650; }
|
||||
.day-closed {
|
||||
display: flex;
|
||||
flex-wrap: wrap;
|
||||
justify-content: space-between;
|
||||
align-items: baseline;
|
||||
column-gap: 8px;
|
||||
padding: 4px 10px;
|
||||
font-size: 12px;
|
||||
color: var(--muted);
|
||||
border: 1px dashed var(--grid);
|
||||
border-radius: 7px;
|
||||
}
|
||||
.day-closed .briefing-date { font-weight: 500; white-space: nowrap; }
|
||||
.briefing-line { font-size: 12px; color: var(--ink-2); display: flex; gap: 6px; align-items: center; flex-wrap: wrap; }
|
||||
|
||||
.badge {
|
||||
display: inline-block;
|
||||
font-size: 11px;
|
||||
border-radius: 20px;
|
||||
padding: 1px 8px;
|
||||
font-weight: 600;
|
||||
}
|
||||
.badge-ok { background: var(--badge-ok-bg); color: var(--badge-ok-ink); }
|
||||
.badge-warn { background: var(--badge-warn-bg); color: var(--badge-warn-ink); }
|
||||
.badge-error { background: var(--badge-err-bg); color: var(--badge-err-ink); }
|
||||
|
||||
/* ------------------------------------------------------------------ summary card */
|
||||
.summary-card {
|
||||
border: 1px solid var(--border);
|
||||
border-left: 3px solid var(--series-1);
|
||||
border-radius: 10px;
|
||||
background: var(--page);
|
||||
padding: 12px 16px;
|
||||
margin: 10px 0 14px;
|
||||
}
|
||||
.summary-headline { font-size: 16px; font-weight: 700; margin: 0 0 6px; }
|
||||
.summary-overview { margin: 0 0 10px; color: var(--ink-2); }
|
||||
.summary-grid {
|
||||
display: grid;
|
||||
grid-template-columns: repeat(auto-fit, minmax(220px, 1fr));
|
||||
gap: 12px;
|
||||
}
|
||||
.summary-block h3 { font-size: 12.5px; margin: 0 0 4px; color: var(--muted); font-weight: 650; }
|
||||
.summary-block.risk h3 { color: var(--badge-err-ink); }
|
||||
.summary-block ul { margin: 0; padding-left: 18px; }
|
||||
.summary-block li { margin: 2px 0; }
|
||||
|
||||
/* ------------------------------------------------------------------ report */
|
||||
.report-meta { display: flex; flex-wrap: wrap; gap: 8px; align-items: center; font-size: 12.5px; color: var(--ink-2); margin-bottom: 4px; }
|
||||
.markdown { max-width: 76ch; }
|
||||
.markdown h1 { font-size: 19px; margin: 10px 0 6px; }
|
||||
.markdown h2 { font-size: 15px; color: var(--ink); margin: 18px 0 6px; }
|
||||
.markdown h3 { font-size: 14px; margin: 14px 0 4px; }
|
||||
.markdown p, .markdown li { color: var(--ink); }
|
||||
.markdown a { color: var(--series-1); }
|
||||
.markdown table { border-collapse: collapse; font-size: 13px; margin: 8px 0; display: block; overflow-x: auto; }
|
||||
.markdown th, .markdown td { border: 1px solid var(--grid); padding: 4px 9px; text-align: right; }
|
||||
.markdown th:first-child, .markdown td:first-child { text-align: left; }
|
||||
.markdown th { background: var(--page); color: var(--ink-2); font-weight: 600; }
|
||||
.markdown td { font-variant-numeric: tabular-nums; }
|
||||
.markdown blockquote { margin: 8px 0; padding: 2px 12px; border-left: 3px solid var(--baseline); color: var(--ink-2); }
|
||||
.markdown code { background: var(--page); border: 1px solid var(--grid); border-radius: 4px; padding: 0 4px; font-size: 12.5px; }
|
||||
|
||||
table.data-table { border-collapse: collapse; font-size: 13px; }
|
||||
table.data-table th, table.data-table td { border: 1px solid var(--grid); padding: 4px 10px; text-align: right; font-variant-numeric: tabular-nums; }
|
||||
table.data-table th:first-child, table.data-table td:first-child { text-align: left; }
|
||||
table.data-table th { background: var(--page); color: var(--ink-2); font-weight: 600; }
|
||||
|
||||
.errors-list { list-style: none; margin: 8px 0 0; padding: 0; font-size: 12.5px; display: flex; flex-direction: column; gap: 6px; }
|
||||
.errors-list .err-ts { color: var(--muted); margin-right: 8px; }
|
||||
.errors-list .err-subject { font-weight: 650; color: var(--badge-err-ink); margin-right: 8px; }
|
||||
.errors-list .err-detail { color: var(--ink-2); overflow-wrap: anywhere; }
|
||||
@@ -0,0 +1,18 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!DOCTYPE plist PUBLIC "-//Apple//DTD PLIST 1.0//EN" "http://www.apple.com/DTDs/PropertyList-1.0.dtd">
|
||||
<!-- 로그인 시 Apple container 런타임과 us2kr 컨테이너를 기동하는 one-shot 에이전트.
|
||||
__CONTAINER__/__ROOT__ 는 install-apple-container.sh --boot 가 치환한다. -->
|
||||
<plist version="1.0">
|
||||
<dict>
|
||||
<key>Label</key><string>com.us2kr.container</string>
|
||||
<key>ProgramArguments</key>
|
||||
<array>
|
||||
<string>/bin/bash</string>
|
||||
<string>-c</string>
|
||||
<string>__CONTAINER__ system start && __CONTAINER__ start us2kr; __CONTAINER__ start us2kr-dashboard</string>
|
||||
</array>
|
||||
<key>RunAtLoad</key><true/>
|
||||
<key>StandardOutPath</key><string>__ROOT__/logs/container-boot.log</string>
|
||||
<key>StandardErrorPath</key><string>__ROOT__/logs/container-boot.log</string>
|
||||
</dict>
|
||||
</plist>
|
||||
@@ -0,0 +1,59 @@
|
||||
#!/usr/bin/env bash
|
||||
# macOS: Apple container(https://github.com/apple/container)로 빌드·상주 실행.
|
||||
# 실행: bash deploy/install-apple-container.sh # 이미지 빌드 + 컨테이너 (재)기동
|
||||
# bash deploy/install-apple-container.sh --boot # + 로그인 시 자동 기동(LaunchAgent) 등록
|
||||
set -euo pipefail
|
||||
ROOT="$(cd "$(dirname "$0")/.." && pwd)"
|
||||
NAME=us2kr
|
||||
|
||||
CONTAINER_BIN="$(command -v container || true)"
|
||||
if [ -z "$CONTAINER_BIN" ]; then
|
||||
echo "Apple container CLI가 없습니다: brew install container (macOS 15+, Apple Silicon)" >&2
|
||||
exit 1
|
||||
fi
|
||||
if [ ! -f "$ROOT/.env" ]; then
|
||||
echo "$ROOT/.env 가 없습니다: cp .env.example .env 후 MINIMAX_API_KEY를 넣으세요" >&2
|
||||
exit 1
|
||||
fi
|
||||
|
||||
DASHBOARD=us2kr-dashboard
|
||||
DASHBOARD_PORT="${US2KR_DASHBOARD_PORT:-8090}"
|
||||
|
||||
mkdir -p "$ROOT/data" "$ROOT/reports" "$ROOT/logs"
|
||||
container system start
|
||||
container build -t "$NAME" -f "$ROOT/deploy/Dockerfile" "$ROOT"
|
||||
container build -t "$DASHBOARD" -f "$ROOT/dashboard/Dockerfile" "$ROOT/dashboard"
|
||||
|
||||
# 기존 컨테이너는 갈아끼운다 (이미지 갱신 반영). container에는 restart 정책이 없어
|
||||
# 자동 기동은 --boot 의 LaunchAgent가 담당한다.
|
||||
container stop "$NAME" "$DASHBOARD" >/dev/null 2>&1 || true
|
||||
container delete "$NAME" "$DASHBOARD" >/dev/null 2>&1 || true
|
||||
container run --detach --name "$NAME" \
|
||||
--env-file "$ROOT/.env" \
|
||||
--env US2KR_DATA_DIR=/app/data \
|
||||
--env US2KR_REPORTS_DIR=/app/reports \
|
||||
--env US2KR_LOG_DIR=/app/logs \
|
||||
--volume "$ROOT/data:/app/data" \
|
||||
--volume "$ROOT/reports:/app/reports" \
|
||||
--volume "$ROOT/logs:/app/logs" \
|
||||
"$NAME"
|
||||
container run --detach --name "$DASHBOARD" \
|
||||
--volume "$ROOT/reports:/data/reports:ro" \
|
||||
--publish "0.0.0.0:$DASHBOARD_PORT:8090" \
|
||||
"$DASHBOARD"
|
||||
|
||||
if [ "${1:-}" = "--boot" ]; then
|
||||
PLIST_SRC="$ROOT/deploy/com.us2kr.container.plist"
|
||||
PLIST_DST="$HOME/Library/LaunchAgents/com.us2kr.container.plist"
|
||||
mkdir -p "$HOME/Library/LaunchAgents"
|
||||
sed -e "s#__CONTAINER__#$CONTAINER_BIN#g" -e "s#__ROOT__#$ROOT#g" "$PLIST_SRC" > "$PLIST_DST"
|
||||
launchctl bootout "gui/$(id -u)/com.us2kr.container" 2>/dev/null || true
|
||||
launchctl bootstrap "gui/$(id -u)" "$PLIST_DST"
|
||||
echo "boot agent: $PLIST_DST (로그인 시 container system start + container start $NAME $DASHBOARD)"
|
||||
fi
|
||||
|
||||
echo "dashboard: http://localhost:$DASHBOARD_PORT"
|
||||
echo "status: container list --all"
|
||||
echo "logs: container logs --follow $NAME (파일: tail -f $ROOT/logs/us2kr.log)"
|
||||
echo "stop: container stop $NAME $DASHBOARD"
|
||||
echo "remove: container stop $NAME $DASHBOARD && container delete $NAME $DASHBOARD"
|
||||
@@ -192,6 +192,70 @@ def test_build_payload_history_failure_is_a_gap(env):
|
||||
assert any(g.startswith("history:") for g in payload.data_gaps)
|
||||
|
||||
|
||||
def test_build_payload_skips_searx_when_not_configured(env):
|
||||
def boom(*args, **kwargs):
|
||||
raise AssertionError("fetch_searx_news must not be called without SEARXNG_BASE_URL")
|
||||
|
||||
env.monkeypatch.setattr(pipeline, "fetch_searx_news", boom)
|
||||
payload = pipeline.build_payload(SESSION, env.settings, env.clock, env.store)
|
||||
assert payload.data_gaps == []
|
||||
|
||||
|
||||
def test_build_payload_merges_searx_news(monkeypatch, tmp_path):
|
||||
env = Env(
|
||||
monkeypatch,
|
||||
tmp_path,
|
||||
SEARXNG_BASE_URL="http://searx.local:8888",
|
||||
US2KR_SEARXNG_QUERIES="markets, fed",
|
||||
US2KR_NEWS_MAX_ITEMS="3",
|
||||
)
|
||||
rss = sample_news() # 1 item, published 17:00 ET
|
||||
searx_items = [
|
||||
NewsItem( # duplicate of the RSS story by link; same timestamp -> RSS copy wins the tie
|
||||
title="Stocks rally (search copy)",
|
||||
link="https://example.com/1#utm",
|
||||
source="Reuters",
|
||||
published=datetime(2026, 8, 25, 17, 0, tzinfo=ET),
|
||||
),
|
||||
NewsItem(
|
||||
title="Chip stocks jump",
|
||||
link="https://example.com/chips",
|
||||
source="Barron's",
|
||||
published=datetime(2026, 8, 25, 18, 30, tzinfo=ET),
|
||||
),
|
||||
]
|
||||
|
||||
def fetch_searx_news(base_url, since, queries=None, **kwargs):
|
||||
env.calls["searxng"] = env.calls.get("searxng", 0) + 1
|
||||
assert base_url == "http://searx.local:8888"
|
||||
assert queries == ["markets", "fed"]
|
||||
assert since == env.news_since
|
||||
return searx_items
|
||||
|
||||
env.monkeypatch.setattr(pipeline, "fetch_searx_news", fetch_searx_news)
|
||||
payload = pipeline.build_payload(SESSION, env.settings, env.clock, env.store)
|
||||
|
||||
assert env.calls["searxng"] == 1
|
||||
assert [n.title for n in payload.news] == ["Chip stocks jump", "Stocks rally"]
|
||||
assert payload.data_gaps == []
|
||||
# the archived news blob is the merged list
|
||||
assert "Chip stocks jump" in env.store.raw[(SESSION, "news")]
|
||||
assert rss[0].title in env.store.raw[(SESSION, "news")]
|
||||
|
||||
|
||||
def test_build_payload_searx_failure_keeps_rss_news(monkeypatch, tmp_path):
|
||||
env = Env(monkeypatch, tmp_path, SEARXNG_BASE_URL="http://searx.local:8888")
|
||||
|
||||
def boom(base_url, since, queries=None, **kwargs):
|
||||
raise RuntimeError("all searxng queries failed: markets: HTTPError")
|
||||
|
||||
env.monkeypatch.setattr(pipeline, "fetch_searx_news", boom)
|
||||
payload = pipeline.build_payload(SESSION, env.settings, env.clock, env.store)
|
||||
|
||||
assert [n.title for n in payload.news] == ["Stocks rally"]
|
||||
assert any(g.startswith("searxng: RuntimeError") for g in payload.data_gaps)
|
||||
|
||||
|
||||
# -------------------------------------------------------------------------------- run_briefing
|
||||
def test_run_briefing_happy_path_saves_then_delivers(env):
|
||||
result = pipeline.run_briefing(SESSION, env.settings)
|
||||
|
||||
@@ -115,7 +115,7 @@ def test_markdown_header_and_degraded_mode():
|
||||
assert "🧩 축소 모드(LLM 요약 없음)" in md
|
||||
assert "## 총평" not in md and "## 시장 개요" not in md
|
||||
assert "## 📊 주요 지수" in md # tables still present
|
||||
assert md.rstrip().endswith("요약 모델: 없음")
|
||||
assert "요약 모델" not in md # the model is an implementation detail, never displayed
|
||||
|
||||
|
||||
def test_markdown_with_report_sections_and_numbers_from_payload():
|
||||
@@ -132,7 +132,7 @@ def test_markdown_with_report_sections_and_numbers_from_payload():
|
||||
# numeric table values come from the payload
|
||||
assert "| S&P 500 | 6,432.10 | +0.52% |" in md
|
||||
assert "| VIX | 15.20 | -5.00% |" in md
|
||||
assert md.rstrip().endswith("요약 모델: MiniMax-M3")
|
||||
assert "요약 모델" not in md
|
||||
|
||||
|
||||
def test_markdown_group_order_and_sections():
|
||||
@@ -333,7 +333,6 @@ def test_telegram_full_briefing_roundtrip(limit: int):
|
||||
assert 0 < len(c) <= limit
|
||||
_assert_balanced(c)
|
||||
joined = "\n".join(chunks)
|
||||
assert "요약 모델: MiniMax-M3" in joined
|
||||
assert "미 10년물" in joined and "+3.5bp" in joined
|
||||
|
||||
|
||||
|
||||
@@ -0,0 +1,151 @@
|
||||
"""Tests for us2kr.collectors.searx (no network: requests.get is mocked)."""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
import json
|
||||
from datetime import UTC, datetime, timedelta
|
||||
|
||||
import pytest
|
||||
import requests
|
||||
|
||||
from us2kr.collectors import searx
|
||||
from us2kr.collectors.searx import _parse_published, fetch_searx_news
|
||||
|
||||
SINCE = datetime(2026, 8, 25, 12, 0, tzinfo=UTC)
|
||||
|
||||
|
||||
def _result(title: str, url: str, published: str | None = None, **extra) -> dict:
|
||||
result = {"title": title, "url": url, "content": extra.pop("content", "")}
|
||||
if published is not None:
|
||||
result["publishedDate"] = published
|
||||
result.update(extra)
|
||||
return result
|
||||
|
||||
|
||||
class _Resp:
|
||||
def __init__(self, results: list | None, status: int = 200, body: str | None = None):
|
||||
self.status_code = status
|
||||
self._body = body if body is not None else json.dumps({"results": results})
|
||||
|
||||
def raise_for_status(self) -> None:
|
||||
if self.status_code >= 400:
|
||||
raise requests.HTTPError(f"{self.status_code} error")
|
||||
|
||||
def json(self):
|
||||
return json.loads(self._body)
|
||||
|
||||
|
||||
def _iso(dt: datetime) -> str:
|
||||
return dt.isoformat()
|
||||
|
||||
|
||||
def test_parse_published_variants():
|
||||
assert _parse_published("2026-08-25T14:00:00+00:00") == datetime(2026, 8, 25, 14, 0, tzinfo=UTC)
|
||||
assert _parse_published("2026-08-25T14:00:00Z") == datetime(2026, 8, 25, 14, 0, tzinfo=UTC)
|
||||
# naive -> assumed UTC
|
||||
assert _parse_published("2026-08-25T14:00:00") == datetime(2026, 8, 25, 14, 0, tzinfo=UTC)
|
||||
assert _parse_published(None) is None
|
||||
assert _parse_published("") is None
|
||||
assert _parse_published("yesterday-ish") is None
|
||||
assert _parse_published(1234) is None
|
||||
|
||||
|
||||
def test_filters_maps_and_floors_undated(mocker):
|
||||
fresh = SINCE + timedelta(hours=2)
|
||||
results = [
|
||||
_result("Fed pauses", "https://n.example/fed", _iso(fresh), content="<p>Held & steady</p>", source="Reuters"),
|
||||
_result("Old story", "https://n.example/old", _iso(SINCE - timedelta(hours=3))),
|
||||
_result("Undated wrap", "https://n.example/wrap", None, engine="bing news"),
|
||||
_result("", "https://n.example/notitle", _iso(fresh)),
|
||||
_result("No link", "", _iso(fresh)),
|
||||
]
|
||||
get = mocker.patch("us2kr.collectors.searx.requests.get", return_value=_Resp(results))
|
||||
|
||||
items = fetch_searx_news("http://searx.local:8888", since=SINCE, queries=["markets"])
|
||||
|
||||
assert [i.title for i in items] == ["Fed pauses", "Undated wrap"]
|
||||
assert items[0].summary == "Held & steady"
|
||||
assert items[0].source == "Reuters"
|
||||
assert items[0].published == fresh
|
||||
# undated: kept, timestamped at the window floor, engine used as source fallback
|
||||
assert items[1].published == SINCE
|
||||
assert items[1].source == "bing news"
|
||||
|
||||
params = get.call_args.kwargs["params"]
|
||||
assert params["format"] == "json"
|
||||
assert params["categories"] == "news"
|
||||
assert params["time_range"] == "day"
|
||||
assert get.call_args.args[0] == "http://searx.local:8888/search"
|
||||
|
||||
|
||||
def test_naive_since_is_treated_as_utc(mocker):
|
||||
fresh = SINCE + timedelta(hours=1)
|
||||
mocker.patch(
|
||||
"us2kr.collectors.searx.requests.get",
|
||||
return_value=_Resp([_result("A", "https://n.example/a", _iso(fresh))]),
|
||||
)
|
||||
items = fetch_searx_news("http://searx.local:8888", since=SINCE.replace(tzinfo=None), queries=["q"])
|
||||
assert len(items) == 1
|
||||
assert items[0].published.tzinfo is not None
|
||||
|
||||
|
||||
def test_dedup_across_queries_and_max_per_query(mocker):
|
||||
fresh = SINCE + timedelta(hours=1)
|
||||
per_query = {
|
||||
"q1": _Resp(
|
||||
[
|
||||
_result("Story A", "https://n.example/a/", _iso(fresh)),
|
||||
_result("Story B", "https://n.example/b", _iso(fresh)),
|
||||
]
|
||||
),
|
||||
# same article as q1's Story A modulo trailing slash / fragment
|
||||
"q2": _Resp([_result("Story A again", "https://n.example/a#frag", _iso(fresh))]),
|
||||
}
|
||||
mocker.patch(
|
||||
"us2kr.collectors.searx.requests.get",
|
||||
side_effect=lambda url, params, **kw: per_query[params["q"]],
|
||||
)
|
||||
items = fetch_searx_news("http://searx.local:8888", since=SINCE, queries=["q1", "q2"], max_per_query=1)
|
||||
# max_per_query=1 keeps only Story A from q1; q2's duplicate link is dropped
|
||||
assert [i.title for i in items] == ["Story A"]
|
||||
|
||||
|
||||
def test_partial_failure_is_tolerated(mocker, caplog):
|
||||
fresh = SINCE + timedelta(hours=1)
|
||||
per_query = {
|
||||
"bad": _Resp(None, status=500),
|
||||
"good": _Resp([_result("Kept", "https://n.example/k", _iso(fresh))]),
|
||||
}
|
||||
mocker.patch(
|
||||
"us2kr.collectors.searx.requests.get",
|
||||
side_effect=lambda url, params, **kw: per_query[params["q"]],
|
||||
)
|
||||
items = fetch_searx_news("http://searx.local:8888", since=SINCE, queries=["bad", "good"])
|
||||
assert [i.title for i in items] == ["Kept"]
|
||||
|
||||
|
||||
def test_all_queries_failing_raises(mocker):
|
||||
mocker.patch("us2kr.collectors.searx.requests.get", return_value=_Resp(None, status=502))
|
||||
with pytest.raises(RuntimeError, match="all searxng queries failed"):
|
||||
fetch_searx_news("http://searx.local:8888", since=SINCE, queries=["a", "b"])
|
||||
|
||||
|
||||
def test_malformed_response_counts_as_failure(mocker):
|
||||
mocker.patch(
|
||||
"us2kr.collectors.searx.requests.get",
|
||||
return_value=_Resp(None, body=json.dumps({"unexpected": True})),
|
||||
)
|
||||
with pytest.raises(RuntimeError, match="all searxng queries failed"):
|
||||
fetch_searx_news("http://searx.local:8888", since=SINCE, queries=["only"])
|
||||
|
||||
|
||||
def test_default_queries_used_when_none(mocker):
|
||||
calls: list[str] = []
|
||||
|
||||
def record(url, params, **kw):
|
||||
calls.append(params["q"])
|
||||
return _Resp([])
|
||||
|
||||
mocker.patch("us2kr.collectors.searx.requests.get", side_effect=record)
|
||||
assert fetch_searx_news("http://searx.local:8888", since=SINCE) == []
|
||||
assert calls == searx.DEFAULT_QUERIES
|
||||
+18
-12
@@ -125,6 +125,23 @@ def _parse_feed(source: str, content: bytes, since: datetime) -> list[NewsItem]:
|
||||
return items
|
||||
|
||||
|
||||
def dedup_news(items: list[NewsItem]) -> list[NewsItem]:
|
||||
"""Newest first, deduplicated by normalised title and by link (fragment/trailing slash ignored)."""
|
||||
seen_titles: set[str] = set()
|
||||
seen_links: set[str] = set()
|
||||
unique: list[NewsItem] = []
|
||||
# Stable sort newest first before dedup so the freshest duplicate is the one kept.
|
||||
for item in sorted(items, key=lambda n: n.published, reverse=True):
|
||||
tkey = normalize_title(item.title)
|
||||
lkey = item.link.split("#", 1)[0].rstrip("/").lower()
|
||||
if tkey in seen_titles or lkey in seen_links:
|
||||
continue
|
||||
seen_titles.add(tkey)
|
||||
seen_links.add(lkey)
|
||||
unique.append(item)
|
||||
return unique
|
||||
|
||||
|
||||
def fetch_news(since: datetime, max_items: int = 40) -> list[NewsItem]:
|
||||
"""Collect headlines published at/after `since` from all feeds, deduplicated, newest first.
|
||||
|
||||
@@ -151,18 +168,7 @@ def fetch_news(since: datetime, max_items: int = 40) -> list[NewsItem]:
|
||||
if failures and len(failures) == len(FEEDS):
|
||||
raise RuntimeError("all news feeds failed: " + "; ".join(failures))
|
||||
|
||||
seen_titles: set[str] = set()
|
||||
seen_links: set[str] = set()
|
||||
unique: list[NewsItem] = []
|
||||
# Stable sort newest first before dedup so the freshest duplicate is the one kept.
|
||||
for item in sorted(collected, key=lambda n: n.published, reverse=True):
|
||||
tkey = normalize_title(item.title)
|
||||
lkey = item.link.split("#", 1)[0].rstrip("/").lower()
|
||||
if tkey in seen_titles or lkey in seen_links:
|
||||
continue
|
||||
seen_titles.add(tkey)
|
||||
seen_links.add(lkey)
|
||||
unique.append(item)
|
||||
unique = dedup_news(collected)
|
||||
|
||||
log.info(
|
||||
"news: %d raw -> %d unique, returning %d (feeds failed: %d/%d)",
|
||||
|
||||
@@ -0,0 +1,121 @@
|
||||
"""SearXNG news collector: supplements the RSS feeds with meta-search results.
|
||||
|
||||
Used only when ``SEARXNG_BASE_URL`` is configured. Each query is fetched independently so that
|
||||
one failing query never spoils the others. Only if *every* query fails does
|
||||
`fetch_searx_news` raise. The instance must have the JSON output format enabled
|
||||
(searxng settings.yml: ``search.formats`` includes ``json``).
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
import logging
|
||||
from datetime import UTC, datetime
|
||||
from urllib.parse import urljoin
|
||||
|
||||
import requests
|
||||
|
||||
from us2kr.collectors.news import USER_AGENT, strip_html
|
||||
from us2kr.models import NewsItem
|
||||
|
||||
log = logging.getLogger(__name__)
|
||||
|
||||
SEARX_TIMEOUT_SECONDS = 15.0
|
||||
MAX_PER_QUERY = 15
|
||||
|
||||
# Complements the fixed RSS feeds: broad market wrap + macro + the Korea/semis angle the
|
||||
# briefing cares about. Override with US2KR_SEARXNG_QUERIES (CSV).
|
||||
DEFAULT_QUERIES: list[str] = [
|
||||
"US stock market",
|
||||
"Federal Reserve",
|
||||
"semiconductor stocks",
|
||||
]
|
||||
|
||||
|
||||
def _parse_published(raw: object) -> datetime | None:
|
||||
"""ISO-8601 publishedDate -> tz-aware UTC datetime, or None when absent/garbled."""
|
||||
if not raw or not isinstance(raw, str):
|
||||
return None
|
||||
try:
|
||||
parsed = datetime.fromisoformat(raw)
|
||||
except ValueError:
|
||||
return None
|
||||
if parsed.tzinfo is None:
|
||||
parsed = parsed.replace(tzinfo=UTC)
|
||||
return parsed.astimezone(UTC)
|
||||
|
||||
|
||||
def _fetch_query(base_url: str, query: str) -> list[dict]:
|
||||
resp = requests.get(
|
||||
urljoin(base_url.rstrip("/") + "/", "search"),
|
||||
params={"q": query, "format": "json", "categories": "news", "time_range": "day"},
|
||||
timeout=SEARX_TIMEOUT_SECONDS,
|
||||
headers={"User-Agent": USER_AGENT},
|
||||
)
|
||||
resp.raise_for_status()
|
||||
results = resp.json().get("results")
|
||||
if not isinstance(results, list): # malformed server payload, not a caller type error
|
||||
raise ValueError("malformed SearXNG response: no results list") # noqa: TRY004
|
||||
return results
|
||||
|
||||
|
||||
def fetch_searx_news(
|
||||
base_url: str,
|
||||
since: datetime,
|
||||
queries: list[str] | None = None,
|
||||
max_per_query: int = MAX_PER_QUERY,
|
||||
) -> list[NewsItem]:
|
||||
"""Search the news category for each query, returning items published at/after `since`.
|
||||
|
||||
Results without a publishedDate are kept (time_range=day already bounds their age) but
|
||||
timestamped at `since`, so they sort last and never win deduplication against a dated copy.
|
||||
Raises RuntimeError only when every query failed.
|
||||
"""
|
||||
if since.tzinfo is None:
|
||||
since = since.replace(tzinfo=UTC)
|
||||
else:
|
||||
since = since.astimezone(UTC)
|
||||
|
||||
queries = queries or DEFAULT_QUERIES
|
||||
collected: list[NewsItem] = []
|
||||
failures: list[str] = []
|
||||
seen_links: set[str] = set() # the same article routinely matches several queries
|
||||
for query in queries:
|
||||
try:
|
||||
results = _fetch_query(base_url, query)
|
||||
except Exception as exc: # noqa: BLE001 - per-query isolation
|
||||
log.warning("searxng query %r failed: %s: %s", query, type(exc).__name__, str(exc)[:200])
|
||||
failures.append(f"{query}: {type(exc).__name__}")
|
||||
continue
|
||||
kept = undated = 0
|
||||
for result in results:
|
||||
title = (result.get("title") or "").strip()
|
||||
link = (result.get("url") or "").strip()
|
||||
if not title or not link:
|
||||
continue
|
||||
lkey = link.split("#", 1)[0].rstrip("/").lower()
|
||||
if lkey in seen_links:
|
||||
continue
|
||||
published = _parse_published(result.get("publishedDate"))
|
||||
if published is None:
|
||||
undated += 1
|
||||
published = since
|
||||
elif published < since:
|
||||
continue
|
||||
seen_links.add(lkey)
|
||||
collected.append(
|
||||
NewsItem(
|
||||
title=title,
|
||||
summary=strip_html(result.get("content") or ""),
|
||||
link=link,
|
||||
source=result.get("source") or result.get("engine") or "SearXNG",
|
||||
published=published,
|
||||
)
|
||||
)
|
||||
kept += 1
|
||||
if kept >= max_per_query:
|
||||
break
|
||||
log.info("searxng query %r: %d kept (%d undated) of %d results", query, kept, undated, len(results))
|
||||
|
||||
if failures and len(failures) == len(queries):
|
||||
raise RuntimeError("all searxng queries failed: " + "; ".join(failures))
|
||||
return collected
|
||||
+8
-1
@@ -38,6 +38,13 @@ class Settings(BaseSettings):
|
||||
# --- Optional data keys ---
|
||||
fred_api_key: str | None = Field(default=None, alias="FRED_API_KEY")
|
||||
|
||||
# --- SearXNG (optional news search; instance must enable the json output format) ---
|
||||
searxng_base_url: str | None = Field(default=None, alias="SEARXNG_BASE_URL")
|
||||
# Empty -> collector defaults (us2kr.collectors.searx.DEFAULT_QUERIES).
|
||||
searxng_queries: Annotated[list[str], NoDecode] = Field(
|
||||
default_factory=list, alias="US2KR_SEARXNG_QUERIES"
|
||||
)
|
||||
|
||||
# --- Paths ---
|
||||
data_dir: Path = Field(default=Path("data"), alias="US2KR_DATA_DIR")
|
||||
reports_dir: Path = Field(default=Path("reports"), alias="US2KR_REPORTS_DIR")
|
||||
@@ -60,7 +67,7 @@ class Settings(BaseSettings):
|
||||
|
||||
log_level: str = Field(default="INFO", alias="US2KR_LOG_LEVEL")
|
||||
|
||||
@field_validator("minimax_fallback_models", "krx_extra_holidays", mode="before")
|
||||
@field_validator("minimax_fallback_models", "krx_extra_holidays", "searxng_queries", mode="before")
|
||||
@classmethod
|
||||
def _split_csv(cls, v):
|
||||
if isinstance(v, str):
|
||||
|
||||
+16
-1
@@ -16,8 +16,9 @@ from pydantic import BaseModel
|
||||
|
||||
from us2kr.collectors.base import run_safely
|
||||
from us2kr.collectors.events import fetch_earnings, fetch_events
|
||||
from us2kr.collectors.news import fetch_news
|
||||
from us2kr.collectors.news import dedup_news, fetch_news
|
||||
from us2kr.collectors.prices import fetch_quotes
|
||||
from us2kr.collectors.searx import fetch_searx_news
|
||||
from us2kr.config import KST, Settings
|
||||
from us2kr.deliver import build_deliverers
|
||||
from us2kr.llm.base import LLMError
|
||||
@@ -79,6 +80,20 @@ def build_payload(session: date, settings: Settings, clock: MarketClock, store:
|
||||
news = run_safely(
|
||||
"news", lambda: fetch_news(since=news_since, max_items=settings.news_max_items), [], gaps
|
||||
)
|
||||
if settings.searxng_base_url:
|
||||
searx_news = run_safely(
|
||||
"searxng",
|
||||
lambda: fetch_searx_news(
|
||||
settings.searxng_base_url, # type: ignore[arg-type]
|
||||
since=news_since,
|
||||
queries=settings.searxng_queries or None,
|
||||
),
|
||||
[],
|
||||
gaps,
|
||||
)
|
||||
if searx_news:
|
||||
# RSS first so it wins timestamp ties in dedup; cap stays at news_max_items overall.
|
||||
news = dedup_news([*news, *searx_news])[: settings.news_max_items]
|
||||
events = run_safely("events", lambda: fetch_events(session, settings.fred_api_key), [], gaps)
|
||||
tickers = earnings_tickers()
|
||||
earnings = run_safely("earnings", lambda: fetch_earnings(session, tickers), [], gaps)
|
||||
|
||||
@@ -218,7 +218,6 @@ def render_markdown(payload: MarketPayload, report: Report | None, model_used: s
|
||||
ev_lines = [_event_line(e) for e in payload.events] + [_earnings_line(e) for e in payload.earnings]
|
||||
lines += _section("경제지표·실적", ev_lines)
|
||||
lines += _section("수집 누락", _bullets(payload.data_gaps))
|
||||
lines += ["---", f"요약 모델: {model_used or '없음'}"]
|
||||
return "\n".join(lines).rstrip() + "\n"
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user