sune-org/us.proxy.sune.chat
1
0
Fork 0
mirror of https://github.com/sune-org/us.proxy.sune.chat.git synced 2026-03-17 02:21:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Feat: Include duration in ntfy notifications

Browse Source
This commit is contained in:
multipleof4
2026-02-18 14:22:45 -08:00
parent 8a04f3f37a
commit c36a4f7d49
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
run.js
View File

@@ -114,16 +114,18 @@ function stop(r) {
flush(r, true) flush(r, true)
r.phase = 'done' r.phase = 'done'
r.error = null r.error = null
const duration = ((Date.now() - r.startedAt) / 1000).toFixed(1)
try { r.controller?.abort() } catch {} try { r.controller?.abort() } catch {}
saveSnapshot(r) saveSnapshot(r)
bcast(r, { type: 'done' }) bcast(r, { type: 'done' })
notify(`Run ${r.rid} ended.`, 3, ['stop_sign']) notify(`Run ${r.rid} ended. Duration: ${duration}s`, 3, ['stop_sign'])
} }
function fail(r, message) { function fail(r, message) {
if (r.phase !== 'running') return if (r.phase !== 'running') return
clearTimeoutTimer(r) clearTimeoutTimer(r)
const err = String(message || 'stream_failed') const err = String(message || 'stream_failed')
const duration = ((Date.now() - r.startedAt) / 1000).toFixed(1)
queueDelta(r, `\n\nRun failed: ${err}`) queueDelta(r, `\n\nRun failed: ${err}`)
flush(r, true) flush(r, true)
r.phase = 'error' r.phase = 'error'
@@ -131,7 +133,7 @@ function fail(r, message) {
try { r.controller?.abort() } catch {} try { r.controller?.abort() } catch {}
saveSnapshot(r) saveSnapshot(r)
bcast(r, { type: 'err', message: r.error }) bcast(r, { type: 'err', message: r.error })
notify(`Run ${r.rid} failed: ${r.error}`, 3, ['rotating_light']) notify(`Run ${r.rid} failed after ${duration}s: ${r.error}`, 3, ['rotating_light'])
} }
function sanitizeMessages(messages) { function sanitizeMessages(messages) {