Calibration & Fusion

import { RppgProcessor, MuseFusionCalibrator } from "@elata-biosciences/rppg-web";

const processor = new RppgProcessor("wasm", 30);
const calibrator = new MuseFusionCalibrator();

// Feed Muse PPG readings (from headband)
calibrator.updateMuse(museBpm, quality, timestampMs);

// Feed camera rPPG readings
calibrator.updateCamera(cameraBpm, cameraQuality, timestampMs);

// Get fused result
const fused = calibrator.fuse(cameraBpm, cameraQuality, timestampMs);

processor.updateMuseMetrics(museBpm, quality, timestampMs);

import { MuseCalibrationModel } from "@elata-biosciences/rppg-web";

const model = new MuseCalibrationModel();

// Train with paired observations
model.train(spectralBpm, acfBpm, trueBpm);

// Check if enough data collected
if (model.isTrained()) {
  const predictedBpm = model.predict(spectralBpm, acfBpm);
}

// Persistence
const snapshot = model.getSnapshot();
model.loadSnapshot(snapshot);
model.reset();

type BpmEvidenceSource = "spectral" | "acf" | "tracker" | "muse" | "calibrated";

type BpmEvidence = {
  source: BpmEvidenceSource;
  bpm: number;
  quality: number;
  timestampMs: number;
};

type BpmResolutionResult = {
  bpm: number;
  quality: number;
  source: BpmEvidenceSource;
  evidence: BpmEvidence[];
};

type FusionSource = "camera" | "muse" | "fused";

import { museStyleFilter } from "@elata-biosciences/rppg-web";

const filtered = museStyleFilter(ppgSamples, sampleRate);