mirror of
https://github.com/MBombeck/HealthLog.git
synced 2026-11-08 20:42:43 +00:00
Marc-André Bombeck
bd467d0c4d
The Google sleep payload carries a real per-stage segment series, but the mapper summed each stage's segments into one row stamped on the stage's last end. The hypnogram then reconstructed all of a stage's time as a single block ending at the night's right edge — the same stacked-bar artefact as WHOOP, despite the source carrying true timing. Emit one row per segment with measuredAt at that segment's end and an indexed externalId so the several segments of one stage stay distinct under the dedup key. The timeline is measured (real onsets), so these rows are not flagged reconstructed.
83 lines
2.7 KiB
TypeScript
83 lines
2.7 KiB
TypeScript
/**
|
|
* Fitbit / Google Health sleep-bundle sync (v1.12.0, W5).
|
|
*
|
|
* Reads sleep sessions from the `sleep.readonly` Restricted bundle and maps
|
|
* each into per-SEGMENT `SLEEP_DURATION` rows via `mapSleepSession` (one row
|
|
* per stage segment; `measuredAt = that segment's END instant; harmonised onto
|
|
* the shared `SleepStage` enum IN_BED/AWAKE/ASLEEP/REM/CORE/DEEP that the
|
|
* night-total + hypnogram readers already consume for WHOOP / Apple). Google
|
|
* carries a real per-segment series, so the rows lay each block at its true
|
|
* clock time (a MEASURED timeline, not reconstructed). Upserts as
|
|
* `source = FITBIT`.
|
|
*
|
|
* Each segment carries the `sleepStage` axis and an indexed fieldTag so the
|
|
* several segments of one stage stay distinct under the
|
|
* `(userId, type, source, externalId)` dedup key. externalId =
|
|
* `<session-anchor>:sleep_<stage>:<i>` — a re-scored night overwrites in place.
|
|
* A 24 h overlap covers Google's after-the-fact re-score.
|
|
*
|
|
* A per-data-class 403 soft-skips the resource — the sleep bundle is granted
|
|
* independently of activity / metrics in the Google consent flow.
|
|
*/
|
|
import {
|
|
FITBIT_ACTIVITY_PAGE_SIZE,
|
|
FITBIT_DATA_TYPES,
|
|
fetchDataPoints,
|
|
mapSleepSession,
|
|
} from "./client";
|
|
import {
|
|
getValidToken,
|
|
handleCollectionFetchError,
|
|
upsertFitbitMeasurements,
|
|
type FitbitMeasurementUpsert,
|
|
type FitbitResourceSyncOptions,
|
|
} from "./sync";
|
|
import { annotate } from "@/lib/logging/context";
|
|
|
|
export async function syncUserSleep(
|
|
userId: string,
|
|
opts: FitbitResourceSyncOptions = {},
|
|
): Promise<number> {
|
|
const tokenInfo = await getValidToken(userId);
|
|
if (!tokenInfo) return 0;
|
|
|
|
// Cycle-wide watermark snapshotted once by `syncUserFitbit`; undefined on a
|
|
// full/backfill run.
|
|
const start = opts.start;
|
|
|
|
let points: Record<string, unknown>[];
|
|
try {
|
|
points = await fetchDataPoints(
|
|
FITBIT_DATA_TYPES.sleep,
|
|
tokenInfo.accessToken,
|
|
"fetchSleep",
|
|
{ start, pageSize: FITBIT_ACTIVITY_PAGE_SIZE },
|
|
);
|
|
} catch (err) {
|
|
return handleCollectionFetchError("fetchSleep", userId, err);
|
|
}
|
|
|
|
const readings: FitbitMeasurementUpsert[] = [];
|
|
for (const point of points) {
|
|
for (const m of mapSleepSession(point)) {
|
|
readings.push({
|
|
type: m.type,
|
|
value: m.value,
|
|
unit: m.unit,
|
|
measuredAt: m.measuredAt,
|
|
externalId: m.fieldTag,
|
|
sleepStage: m.sleepStage ?? null,
|
|
});
|
|
}
|
|
}
|
|
|
|
const imported = (
|
|
await upsertFitbitMeasurements(userId, readings, {
|
|
deferRollup: opts.deferRollup,
|
|
})
|
|
).imported;
|
|
// `markSynced` is owned by the orchestrator (`syncUserFitbit`).
|
|
annotate({ action: { name: "fitbit.sleep.sync", details: { imported } } });
|
|
return imported;
|
|
}
|