nucleic/nucleic
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Launch Activity Logic

Browse Source 
Nucleic-Session: EBB24271-3AB2-4CBD-A47A-59FC73500371
Co-authored-by: Nucleic <[email protected]>
This commit is contained in:
abkslm
2026-07-06 13:43:19 -07:00
co-authored by nucleic
parent 2a7a8c3fc7
commit 409485e75b
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cloud/nucleic-edge/src/index.ts
+6 -1
View File
@@ -298,7 +298,12 @@ async function pushLiveActivity(request: Request, env: Env): Promise<Response> {
// The push body's topic wins (freshest, from this phone's hello), then the stored record, then
// the worker's configured fallback. `sendLiveActivityApns` appends `.push-type.liveactivity`.
const topic = body.topic ?? rec.topic ?? cfg.topic;
const payload = liveActivityPayload(body.event ?? "update", body.contentState ?? null);
// A push-to-start carries the static attributes + their type name; update/end don't.
const start =
body.event === "start" && body.attributesType
? { type: body.attributesType, attributes: body.attributes ?? {} }
: null;
const payload = liveActivityPayload(body.event ?? "update", body.contentState ?? null, Date.now(), start);
const result = await sendLiveActivityApns({ ...cfg, env: apsEnv, topic }, body.token, payload);
logPush("liveActivity", body.deviceId, `${topic}.push-type.liveactivity`, apsEnv, result);
return json(result, result.status === 200 ? 200 : 502);