microcron/pink
1
0
Fork 0
mirror of https://github.com/microcron/pink.git synced 2026-04-27 18:22:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix: Log ntfy HTTP errors instead of silently discarding

Browse Source 
Co-authored-by: Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
multipleof4
2026-04-12 14:53:39 -07:00
parent 59fa8a44d7
commit 2e4d026a7e
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pink.js
View File

@@ -26,12 +26,13 @@ async function chat(model, messages, system) {
async function sendNtfy(msg, priority) { async function sendNtfy(msg, priority) {
const url = process.env.NTFY_URL const url = process.env.NTFY_URL
if (!url) return console.warn("!! NTFY_URL not set") if (!url) return console.warn("!! NTFY_URL not set")
await fetch(url, { const res = await fetch(url, {
method: "POST", method: "POST",
headers: { "Priority": String(priority) }, headers: { "Priority": String(priority) },
body: msg body: msg
}) })
console.log(`📨 ntfy (p${priority}): ${msg.slice(0, 80)}`) if (!res.ok) console.error(`!! ntfy ${res.status}: ${await res.text()}`)
else console.log(`📨 ntfy (p${priority}): ${msg.slice(0, 80)}`)
} }
for (const file of files) { for (const file of files) {
@@ -80,6 +81,7 @@ for (const file of files) {
// --- Parse ntfy block --- // --- Parse ntfy block ---
const ntfyMatch = reasonAnswer.match(/```ntfy([1-5])\n([\s\S]*?)```/) const ntfyMatch = reasonAnswer.match(/```ntfy([1-5])\n([\s\S]*?)```/)
if (ntfyMatch) await sendNtfy(ntfyMatch[2].trim(), parseInt(ntfyMatch[1])) if (ntfyMatch) await sendNtfy(ntfyMatch[2].trim(), parseInt(ntfyMatch[1]))
else console.warn(`!! no ntfy block found in reason response for ${file}`)
// --- Trim to rolling window (each window = 4 messages) --- // --- Trim to rolling window (each window = 4 messages) ---
const windowSize = 4 const windowSize = 4