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

Debug: Add heartbeat notification

Browse Source
This commit is contained in:
multipleof4
2026-02-16 13:48:09 -08:00
parent 2b3c3057d9
commit 4c8508ae17
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
index.js
View File

@@ -460,6 +460,11 @@ export class MyDurableObject {
async Heart() { async Heart() {
if (this.phase !== 'running' || !this.hbActive) return this.stopHeartbeat(); if (this.phase !== 'running' || !this.hbActive) return this.stopHeartbeat();
///////////// Debug: To be removed
this.notify(`Heartbeat for ${this.rid}: age ${this.age}`, 3, ['heartbeat']);
///////////// Debug: To be removed
if (++this.age * HB_INTERVAL_MS >= MAX_RUN_MS) return this.fail(`Run timed out after ${MAX_RUN_MS / 60000} minutes.`); if (++this.age * HB_INTERVAL_MS >= MAX_RUN_MS) return this.fail(`Run timed out after ${MAX_RUN_MS / 60000} minutes.`);
await this.state.storage.setAlarm(Date.now() + HB_INTERVAL_MS).catch(() => {}); await this.state.storage.setAlarm(Date.now() + HB_INTERVAL_MS).catch(() => {});
} }