[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_168":169,"_170":171},"routes/_app.x.$handle.$name",{"_97":96,"_33":45,"_104":87,"_27":37,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":26,"_118":119,"_120":26,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_33":45,"_38":46,"_47":-5,"_48":26,"_49":50,"_51":50,"_52":37,"_53":-5,"_18":54,"_55":-5,"_56":26,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":26},"version",18,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":26,"_27":28,"_29":30},"file",{"_31":32,"_33":28,"_34":35,"_36":37,"_38":39,"_40":14,"_41":42,"_23":26},"previous","deleted",true,"deletedHere",false,"path","new-file-4985.ts","latestPath","test.ts","fileId","4259064a-542c-11f1-a0fa-ee650bb23af1","name","fileType","script","content","","createdAt",["D",1779268449348],"branchVersion","branchId","0becafea-5403-11f1-af46-ee650bb23af1","id","0bec0c48-5403-11f1-af46-ee650bb23af1","gg_safety_monitor",["D",1779250748684],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","b1cd140f-1d29-4e4b-81e7-552900ed0fc2","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019de14d-1bc0-77c6-a04d-18d9b7c7ba27","tursoName","0bec0c48540311f1af46ee650bb23af1","tursoHostname","0bec0c48540311f1af46ee650bb23af1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789515055826],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_103":37},"org",{"_97":96,"_98":37,"_99":37,"_18":54,"_100":101,"_102":26},"branch",{"_13":86,"_33":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"isOwned",25,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","x_x","handle","displayName","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_33":45,"_38":163,"_47":-5,"_48":26,"_49":50,"_51":50,"_52":37,"_53":-5,"_18":54,"_55":-5,"_56":26,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":164,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":165,"_81":166,"_83":167,"_85":26},"tree",[154,155],"files",[154,155],"counts",{"_142":60,"_143":144,"_145":60,"_146":147,"_148":149},"contents",[125,126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":133,"_33":134,"_31":135,"_128":-5,"_41":42,"_40":136,"_129":26,"_38":137,"_13":138,"_34":139,"_36":140,"_23":26,"_131":-5,"_27":141},{"_43":127,"_33":28,"_31":32,"_128":-5,"_41":42,"_40":14,"_129":26,"_38":130,"_13":60,"_34":35,"_36":37,"_23":26,"_131":-5,"_27":132},"4259058c-542c-11f1-a0fa-ee650bb23af1","parentId","latest",["D",1779268449348],"label",[28],"35bb8b80-5425-11f1-8b82-ee650bb23af1","main.ts","0beead90-5403-11f1-af46-ee650bb23af1",17,["D",1779265421701],16,"interval","// 경기도 31개 시군 — 특사경 수사 소관 '안전관리 부정기사' 모니터링 v0\n// Val.town cron val (권장 주기: 1~2시간)\n// 설계: 재현율 우선(과포함) → 텔레그램에서 검토 → 노이즈를 음성예시로 누적 → 분류기 자동 보정\n//\n// 환경변수(Val.town Secrets): NAVER_ID, NAVER_SECRET, ANTHROPIC_KEY, TG_TOKEN, SUB_PASSPHRASE\n// 구독·노이즈버튼은 webhook 없이 getUpdates 폴링으로 처리(단일 val). webhook val 불필요.\n// blob 키: seen_urls, noise_examples, subscribers, tg_offset, noise_candidate:{id}, review_log:YYYY-MM-DD\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\n// ── 대상 지역: 경기도 31개 시군 ───────────────────────────────\nconst SIGUN = [\n \"수원\",\n \"성남\",\n \"의정부\",\n \"안양\",\n \"부천\",\n \"광명\",\n \"평택\",\n \"동두천\",\n \"안산\",\n \"고양\",\n \"과천\",\n \"구리\",\n \"남양주\",\n \"오산\",\n \"시흥\",\n \"군포\",\n \"의왕\",\n \"하남\",\n \"용인\",\n \"파주\",\n \"이천\",\n \"안성\",\n \"김포\",\n \"화성\",\n \"광주\",\n \"양주\",\n \"포천\",\n \"여주\",\n \"연천\",\n \"가평\",\n \"양평\",\n];\n\n// ── 수집 키워드 설정 (여기만 고치면 됨) ───────────────────────\n// 실행 시 [시군 × 소관키워드]로 자동 조합됨. 예: \"안산 무허가\", \"수원 폐기물 적발\"\n// '경기' 앵커 대신 시군명을 앵커로 써서, 기사에 \"경기\"가 없어도(예: \"안산 글램핑…\") 잡힘.\n// 키워드 추가/삭제는 이 배열만 수정. 시군은 위 SIGUN 그대로 사용.\nconst SOGWAN_KEYWORDS = [\n \"무허가\", // 야영장/숙박업/일반 무허가 영업\n \"불법 적발\", // 광범위 단속/적발\n \"글램핑 야영장\", // 야영장\n \"숙박업 위반\", // 숙박업/관광\n \"폐기물 무단투기\", // 폐기물\n \"환경오염 적발\", // 환경/하천/계곡\n \"식품위생 위반\", // 식품위생/식품표시/건강기능식품/위생용품\n \"원산지 둔갑\", // 원산지/축산물\n \"짝퉁 적발\", // 상표/짝퉁\n];\n// 한 번 실행에 네이버 호출 = SIGUN(31) × SOGWAN_KEYWORDS(9) = 279쿼리.\n// 너무 많으면 키워드 수를 줄이거나, 아래 collect의 display를 낮춰 조절.\n\n// 시군 × 키워드 조합 생성\nconst KEYWORDS = SIGUN.flatMap((sg) =>\n SOGWAN_KEYWORDS.map((k) => `${sg} ${k}`)\n);\n\n// ── 분류기 시스템 프롬프트 (음성예시는 런타임에 주입) ──────────\nfunction buildSystemPrompt(noiseExamples: string): string {\n return `당신은 경기도 특별사법경찰(특사경) 수사 분야 뉴스 모니터링 분류기다.\n경기도 31개 시군에서 발생한 사안 중, 아래 수사 소관 분야와 관련되며\n'부정적 이슈'(위반·부실·위험·논란·의혹)에 해당하는 기사를 가려낸다.\n\n[대상 지역] 경기도 31개 시군: ${SIGUN.join(\", \")}\n\n[수사 소관 분야]\n하천/계곡, 폐기물, 환경, 식품위생법, 식품표시, 의료, 약사, 건강기능식품,\n위생용품, 야영장, 숙박업, 관광, 원산지, 축산물, 개발제한(개발제한구역),\n공유수면, 산지, 상표/짝퉁, 석유\n\n[판정 원칙 — 재현율 우선]\n- 실제 사고·사망이 없더라도 인허가 위반, 무허가 영업, 관리·감독 부실,\n 잠재적 안전 위험, 적법성 의혹·논란이 제기되면 관련=true.\n- 애매하면 포함하되 심각도를 낮게 준다. (놓치는 것보다 과포함이 낫다)\n- 단순 홍보·축제·실적 기사, 소관 밖 사안(예: 교통사고·일반 화재),\n 경기도 외 지역 사안은 관련=false.\n\n[출력] 아래 JSON만 출력. 코드펜스·설명 등 다른 텍스트 절대 금지.\n{\n \"관련\": true|false,\n \"시군\": \"\", // 31개 시군 중 하나. 미상이면 \"\"\n \"소관영역\": [], // 위 분야 중 해당하는 것, 복수 가능\n \"부정성\": \"높음|중간|낮음|없음\",\n \"심각도\": 1, // 1~5 정수\n \"한줄요약\": \"\",\n \"판단근거\": \"\" // 왜 이렇게 판정했는지 1~2문장 (검토용)\n}\n\n[양성 예시]\n입력: 제목=\"무허가 글램핑 '러브썸팜' 안전공백 비판 확산\" 요약=\"안산 글램핑장이 야영장 등록 없이 1년 운영, 소방·대피 기준 미적용 의혹, 무면허 주류 판매 정황\"\n출력: {\"관련\":true,\"시군\":\"안산\",\"소관영역\":[\"야영장\",\"숙박업\",\"식품위생법\"],\"부정성\":\"높음\",\"심각도\":4,\"한줄요약\":\"안산 무허가 글램핑장이 야영장 등록·소방 기준 없이 1년 운영, 무면허 주류판매 정황까지 제기\",\"판단근거\":\"실제 사고는 없으나 야영장 무허가·안전기준 미적용·무면허 주류판매 등 복수 소관의 적법성·안전 이슈가 명확.\"}\n\n[음성(노이즈) 예시 — 검토로 누적됨]\n${noiseExamples || \"(아직 없음)\"}`;\n}\n\n// ── 1. 수집: 네이버 뉴스 검색 API (병렬 배치) ─────────────────\nasync function collect(): Promise {\n const out: any[] = [];\n const FETCH_BATCH = 20; // 동시 네이버 호출 수\n const DISPLAY = 10; // 쿼리당 결과 수 (sort=date라 최신순; 적게 가져와도 신규는 잡힘)\n\n async function one(q: string) {\n const url = `https://openapi.naver.com/v1/search/news.json?query=${\n encodeURIComponent(q)\n }&display=${DISPLAY}&sort=date`;\n try {\n const r = await fetch(url, {\n headers: {\n \"X-Naver-Client-Id\": Deno.env.get(\"NAVER_ID\")!,\n \"X-Naver-Client-Secret\": Deno.env.get(\"NAVER_SECRET\")!,\n },\n });\n if (!r.ok) {\n console.error(\"naver\", q, r.status);\n return;\n }\n const j = await r.json();\n for (const it of j.items ?? []) {\n out.push({\n title: stripTags(it.title),\n desc: stripTags(it.description),\n url: it.originallink || it.link,\n date: it.pubDate,\n });\n }\n } catch (e) {\n console.error(\"naver err\", q, String(e));\n }\n }\n\n for (let i = 0; i < KEYWORDS.length; i += FETCH_BATCH) {\n await Promise.all(KEYWORDS.slice(i, i + FETCH_BATCH).map(one));\n }\n return out;\n}\n\nconst stripTags = (s: string) =>\n s.replace(/<[^>]+>/g, \"\").replace(/"/g, '\"').replace(/&/g, \"&\")\n .replace(/</g, \"<\").replace(/>/g, \">\").trim();\n\n// ── 2. 중복 제거: 아직 안 본 기사만 골라냄 (seen 기록은 처리 후에) ──\nasync function pickFresh(items: any[]): Promise {\n let seen: string[] = [];\n try {\n seen = (await blob.getJSON(\"seen_urls\")) ?? [];\n } catch {}\n const seenSet = new Set(seen);\n // URL 기준 중복 + 같은 배치 내 중복 제거\n const out: any[] = [];\n const batchSeen = new Set();\n for (const it of items) {\n if (!it.url || seenSet.has(it.url) || batchSeen.has(it.url)) continue;\n batchSeen.add(it.url);\n out.push(it);\n }\n return out;\n}\n\n// 처리 완료한 URL들을 seen에 기록\nasync function markSeen(urls: string[]) {\n let seen: string[] = [];\n try {\n seen = (await blob.getJSON(\"seen_urls\")) ?? [];\n } catch {}\n const merged = [...seen, ...urls].slice(-5000); // 최근 5000개 유지\n await blob.setJSON(\"seen_urls\", merged);\n}\n\nconst sleep = (ms: number) => new Promise((res) => setTimeout(res, ms));\n\n// ── 3. 분류: Claude Haiku (저비용, 대량 처리용) ───────────────\n// 429(rate limit) 시 Retry-After 만큼 대기 후 재시도 (최대 3회)\nasync function classify(\n item: any,\n system: string,\n tries = 2,\n): Promise {\n const r = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": Deno.env.get(\"ANTHROPIC_KEY\")!,\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"claude-haiku-4-5-20251001\",\n max_tokens: 400,\n system,\n messages: [{\n role: \"user\",\n content: `제목=\"${item.title}\" 요약=\"${item.desc}\"`,\n }],\n }),\n });\n if (r.status === 429 && tries > 0) {\n const ra = parseInt(r.headers.get(\"retry-after\") ?? \"0\") || 4;\n await sleep(Math.min(ra, 8) * 1000); // 최대 8초로 제한 (타임아웃 잠식 방지)\n return classify(item, system, tries - 1);\n }\n if (!r.ok) {\n console.error(\"claude\", r.status, await r.text());\n return null;\n }\n const j = await r.json();\n const text = (j.content?.[0]?.text ?? \"\").replace(/```json|```/g, \"\").trim();\n try {\n return JSON.parse(text);\n } catch {\n console.error(\"parse fail\", text);\n return null;\n }\n}\n\n// 텔레그램 호출 헬퍼 (실패 시 사유 로깅)\nasync function tg(method: string, body: any) {\n const r = await fetch(\n `https://api.telegram.org/bot${Deno.env.get(\"TG_TOKEN\")}/${method}`,\n {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify(body),\n },\n );\n if (!r.ok) console.error(`tg ${method} ${r.status}`, await r.text());\n return r;\n}\n\n// UTF-8 인코딩 불가능한 깨진 문자(고립 서로게이트 등) 제거 + 길이 제한\nfunction clean(s: any, max = 1500): string {\n return String(s ?? \"\")\n .replace(/[\\uD800-\\uDBFF](?![\\uDC00-\\uDFFF])/g, \"\") // 짝 없는 high surrogate\n .replace(/(? = {\n sg: \"소관밖\",\n pr: \"홍보성\",\n rg: \"타지역\",\n et: \"기타\",\n};\n\n// URL → 짧은 식별자 (콜백데이터 64바이트 제한 대응)\nfunction shortId(s: string): string {\n let h = 5381;\n for (const ch of s) h = ((h * 33) ^ ch.charCodeAt(0)) >>> 0;\n return h.toString(36);\n}\n\nconst NOISE_CAP = 25; // 음성예시 최대 개수\n\n// ── 0. 텔레그램 폴링: /start·/stop·노이즈버튼 처리 (webhook 대체) ──\n// 매 실행 시작에 getUpdates로 그동안 쌓인 메시지/콜백을 한 번에 소화.\nasync function processUpdates() {\n let offset = 0;\n try {\n offset = (await blob.getJSON(\"tg_offset\")) ?? 0;\n } catch {}\n const pass = Deno.env.get(\"SUB_PASSPHRASE\");\n\n for (let loop = 0; loop < 5; loop++) { // 최대 5회(=500건)까지 페이지네이션\n const r = await tg(\"getUpdates\", { offset, timeout: 0, limit: 100 });\n let j: any;\n try {\n j = await r.json();\n } catch {\n break;\n }\n const ups: any[] = j.result ?? [];\n if (!ups.length) break;\n\n for (const u of ups) {\n offset = u.update_id + 1;\n\n // 구독 관리\n const msg = u.message;\n if (msg?.text) {\n const text = msg.text.trim();\n const chatId = String(msg.chat.id);\n const name = msg.chat.title ||\n [msg.from?.first_name, msg.from?.last_name].filter(Boolean).join(\n \" \",\n ) ||\n chatId;\n if (text.startsWith(\"/start\")) {\n const given = text.replace(/^\\/start(@\\w+)?\\s*/, \"\").trim();\n // fail-safe: 암구호가 설정 안 됐거나(=빈 값) 불일치면 등록 거부\n if (!pass || given !== pass) {\n const why = !pass\n ? \"⚠️ 구독 기능이 아직 설정되지 않았습니다. 관리자에게 문의하세요.\"\n : \"🔒 구독하려면 부서에서 안내받은 암구호가 필요합니다.\\n사용법: /start 암구호\";\n await tg(\"sendMessage\", { chat_id: chatId, text: why });\n } else {\n const subs = await getSubs();\n subs[chatId] = { name, ts: Date.now() };\n await blob.setJSON(\"subscribers\", subs);\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n `✅ 경기 안전관리 부정기사 알림을 구독했습니다.\\n현재 구독자 ${\n Object.keys(subs).length\n }명.\\n해지: /stop`,\n });\n }\n } else if (text.startsWith(\"/stop\")) {\n const subs = await getSubs();\n delete subs[chatId];\n await blob.setJSON(\"subscribers\", subs);\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text: \"🔕 구독을 해지했습니다. 다시 받으려면 /start 암구호\",\n });\n }\n continue;\n }\n\n // 노이즈 버튼 콜백\n const cq = u.callback_query;\n if (cq?.data?.startsWith(\"n:\")) {\n const [, code, id] = cq.data.split(\":\");\n const reason = REASONS[code] ?? code;\n let cand: any = null;\n try {\n cand = await blob.getJSON(`noise_candidate:${id}`);\n } catch {}\n if (!cand) {\n await tg(\"answerCallbackQuery\", {\n callback_query_id: cq.id,\n text: \"후보 정보 만료됨\",\n });\n continue;\n }\n let arr: any[] = [];\n try {\n arr = (await blob.getJSON(\"noise_examples\")) ?? [];\n } catch {}\n arr = arr.filter((n) => n.title !== cand.title);\n arr.push({\n title: cand.title,\n desc: cand.desc,\n reason,\n ts: Date.now(),\n });\n arr = arr.slice(-NOISE_CAP);\n await blob.setJSON(\"noise_examples\", arr);\n await tg(\"answerCallbackQuery\", {\n callback_query_id: cq.id,\n text: `노이즈 등록됨 (${reason}) · 학습 ${arr.length}건`,\n });\n if (cq.message) {\n await tg(\"editMessageText\", {\n chat_id: cq.message.chat.id,\n message_id: cq.message.message_id,\n text: `🚫 [노이즈:${reason}] ${cq.message.text}`,\n disable_web_page_preview: true,\n });\n }\n }\n }\n await blob.setJSON(\"tg_offset\", offset);\n }\n}\n\n// 구독자 명단 read\nasync function getSubs(): Promise> {\n try {\n return (await blob.getJSON(\"subscribers\")) ?? {};\n } catch {\n return {};\n }\n}\n\n// ── 4. 알림: 텔레그램 (구독자 전체에게 건별 메시지 + 노이즈 버튼) ──\nasync function notify(hits: any[]) {\n if (!hits.length) return;\n hits.sort((a, b) => (b.c.심각도 ?? 0) - (a.c.심각도 ?? 0));\n\n // 구독자 명단 로드\n const subs = await getSubs();\n const chatIds = Object.keys(subs);\n if (!chatIds.length) {\n console.log(\"구독자 0명 — 발송 생략 (봇에게 /start 한 사람이 없음)\");\n return;\n }\n\n const dead = new Set(); // 403 등으로 더 못 보내는 구독자\n\n // 한 chat에 전체 알림 묶음 발송\n async function sendAll(payload: (chat_id: string) => any) {\n for (const cid of chatIds) {\n if (dead.has(cid)) continue;\n const res = await tg(\"sendMessage\", payload(cid));\n if (res.status === 403) dead.add(cid); // 차단/탈퇴 → 명단에서 제거 예정\n }\n }\n\n await sendAll((chat_id) => ({\n chat_id,\n text: `📡 경기 안전관리 부정기사 ${hits.length}건`,\n }));\n\n for (const h of hits) {\n const c = h.c;\n const id = shortId(h.item.url);\n // 노이즈 표시 시 webhook이 참조할 후보 정보 저장\n await blob.setJSON(`noise_candidate:${id}`, {\n title: h.item.title,\n desc: h.item.desc,\n });\n\n const SEV = [\"⚪\", \"🟢\", \"🟡\", \"🟠\", \"🔴\"];\n const sev = SEV[Math.min(5, Math.max(1, c.심각도)) - 1] ?? \"⚪\";\n const text = `${sev} [심각도 ${c.심각도}] ${clean(c.시군, 40)} · ${\n clean((c.소관영역 ?? []).join(\"/\"), 100)\n }\n${clean(c.한줄요약, 300)}\n↳ 근거: ${clean(c.판단근거, 300)}\n${h.item.url}`;\n const reply_markup = {\n inline_keyboard: [[\n { text: \"👎소관밖\", callback_data: `n:sg:${id}` },\n { text: \"👎홍보성\", callback_data: `n:pr:${id}` },\n { text: \"👎타지역\", callback_data: `n:rg:${id}` },\n { text: \"👎기타\", callback_data: `n:et:${id}` },\n ]],\n };\n await sendAll((chat_id) => ({\n chat_id,\n text,\n disable_web_page_preview: true,\n reply_markup,\n }));\n }\n\n // 죽은 구독자 정리\n if (dead.size) {\n for (const cid of dead) delete subs[cid];\n await blob.setJSON(\"subscribers\", subs);\n console.log(\n `구독자 ${dead.size}명 정리(차단/탈퇴). 현재 ${\n Object.keys(subs).length\n }명.`,\n );\n }\n console.log(\n `구독자 ${chatIds.length - dead.size}명에게 ${hits.length}건 발송`,\n );\n}\n\n// ── 메인 ──────────────────────────────────────────────────────\nexport default async function () {\n // 0. 텔레그램 구독/버튼 먼저 소화 (webhook 없이 폴링)\n await processUpdates();\n\n let noiseArr: any[] = [];\n try {\n noiseArr = (await blob.getJSON(\"noise_examples\")) ?? [];\n } catch {}\n const noiseText = noiseArr\n .map((n) => `- 제목=\"${n.title}\" → 관련=false (검토자 사유: ${n.reason})`)\n .join(\"\\n\");\n const system = buildSystemPrompt(noiseText);\n\n const collected = await collect();\n const freshAll = await pickFresh(collected);\n\n // ── 부트스트랩 모드 ──────────────────────────────────────────\n // 최초 1회: 기존 기사 전체를 분류 없이 seen에만 등록하고 종료.\n // → 백로그(과거 기사)를 알림 없이 한 방에 비우고, 다음 실행부터 \"진짜 신규\"만 처리.\n // 한 번 돌린 뒤 false로 바꾸면 정상 모니터링 모드로 전환됨.\n const BOOTSTRAP = true;\n if (BOOTSTRAP) {\n await markSeen(freshAll.map((f) => f.url));\n console.log(\n `[부트스트랩] 기존 ${freshAll.length}건 seen 처리 완료. BOOTSTRAP=false로 바꾸고 정상 운영하세요.`,\n );\n return;\n }\n\n // 무료/1티어: 분당 50요청 + 1분 타임아웃. backoff 발동 없이 끝나도록 보수적으로.\n // 동시 3개 × 배치당 ~5초 간격 → 20건이면 ~40초, 타임아웃 여유 확보.\n const MAX_PER_RUN = 20; // Pro(10분 타임아웃)면 150~250까지 올려도 됨\n const BATCH = 3; // 동시 호출 (concurrent 제한 + RPM 양쪽 회피)\n const GAP_MS = 5000; // 배치 간 간격\n const fresh = freshAll.slice(0, MAX_PER_RUN);\n console.log(\n `수집 ${collected.length} → 신규 ${freshAll.length} → 이번 처리 ${fresh.length}`,\n );\n\n const hits: any[] = [];\n const log: any[] = [];\n const done: string[] = []; // 실제로 분류 끝낸 URL만 seen에 기록\n\n for (let i = 0; i < fresh.length; i += BATCH) {\n const slice = fresh.slice(i, i + BATCH);\n const results = await Promise.all(\n slice.map((item) => classify(item, system)),\n );\n slice.forEach((item, k) => {\n done.push(item.url);\n const c = results[k];\n if (!c) return; // 분류 실패는 seen 처리하되 알림/로그엔 안 넣음\n log.push({ ...item, c });\n if (c.관련 === true) hits.push({ item, c });\n });\n if (i + BATCH < fresh.length) await sleep(GAP_MS); // 다음 배치 전 페이싱\n }\n\n await markSeen(done); // 처리한 것만 기록 → 타임아웃 나도 미처리분은 다음에 다시 잡힘\n\n // 검토로그 저장 (음성예시 추출 시 여기서 골라냄)\n const today = new Date().toISOString().slice(0, 10);\n let prevLog: any[] = [];\n try {\n prevLog = (await blob.getJSON(`review_log:${today}`)) ?? [];\n } catch {}\n await blob.setJSON(`review_log:${today}`, [...prevLog, ...log]);\n\n await notify(hits);\n console.log(\n `알림 ${hits.length}건 발송 (미처리 ${\n freshAll.length - fresh.length\n }건은 다음 실행)`,\n );\n}",[134],"pulls","branches",1,"forks","envVars",{"_150":152,"_153":60},"connections",{"_150":60,"_151":60},"count","unfilledCount",6,"emptyCount",{"_43":133,"_33":134,"_31":135,"_128":-5,"_41":42,"_40":136,"_129":26,"_38":160,"_13":138,"_34":139,"_36":140,"_23":26,"_131":-5,"_157":161,"_27":162},{"_43":127,"_33":28,"_31":32,"_128":-5,"_41":42,"_40":14,"_129":26,"_38":156,"_13":60,"_34":35,"_36":37,"_23":26,"_131":-5,"_157":158,"_27":159},["D",1779268449348],"children",[],[28],["D",1779265421701],[],[134],["D",1779250748684],["D",1789515055826],{"_97":96,"_103":37},{"_97":96,"_98":37,"_99":37,"_18":54,"_100":101,"_102":26},{"_13":86,"_33":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_79":-5,"_122":201,"_202":203,"_204":205,"_206":26,"_207":26,"_208":26,"_209":24,"_210":-5,"_211":-7,"_212":-7,"_213":60,"_214":26,"_215":26,"_216":-5,"_217":26,"_218":26,"_219":26,"_220":-5},"ENV",{"_172":173,"_174":175,"_176":87,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v18