sune-org/ORP
1
0
Fork 0
mirror of https://github.com/sune-org/ORP.git synced 2026-01-13 16:17:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Refactor: Notify on run completion instead of start

Browse Source
This commit is contained in:
multipleof4
2025-11-06 18:45:26 -08:00
parent 2ec844b766
commit 981e7dc745
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
index.js
View File

@@ -194,7 +194,6 @@ export class MyDurableObject {
this.controller = new AbortController(); this.controller = new AbortController();
await this.saveSnapshot(); await this.saveSnapshot();
this.notify(`Run ${this.rid} started (provider: ${provider || 'openrouter'})`, 3, ['rocket']);
this.state.waitUntil(this.startHeartbeat()); this.state.waitUntil(this.startHeartbeat());
this.state.waitUntil(this.stream({ apiKey, body, provider: provider || 'openrouter' })); this.state.waitUntil(this.stream({ apiKey, body, provider: provider || 'openrouter' }));
} }
@@ -359,7 +358,10 @@ export class MyDurableObject {
} }
async stopHeartbeat() { async stopHeartbeat() {
if (!this.hbActive) return;
this.hbActive = false; this.hbActive = false;
const ageSeconds = (this.age * HB_INTERVAL_MS) / 1000;
this.notify(`Run ${this.rid} ended. Phase: ${this.phase}. Age: ${ageSeconds.toFixed(1)}s.`, 3, ['stop_sign']);
await this.state.storage.setAlarm(null).catch(() => {}); await this.state.storage.setAlarm(null).catch(() => {});
} }