Compare commits

..

4 commits

Author SHA1 Message Date
eb430ffb78 ui: bulk-delete tracks, HR/VR record + detail layout
- Tracks list: the long-press multi-select (used for merge) now also offers Удалить -
  bulk delete of the selected tracks (1+; merge still needs 2+), same selection flow.
- HR/VR record screen: heart rate fills the main area (like the map on a GPS ride),
  Подключить/Стоп moved into a bottom bar, consistent with the GPS screen.
- HR/VR workout detail: 'Удалить зарядку' pinned to the bottom (was floating in the
  scroll flow and stretched).
2026-10-30 23:07:53 +03:00
9251c1dd90 ble: barometer on its own connection - simultaneous HR+baro, auto-connect, UI
Separate BleBaroService so the HR strap and the barometer each hold their own GATT link and
work at the same time (one adapter, several LE connections). Verified on device against a PC
BlueZ emulator of the sensor: BleHR and BleBaro deliver in parallel, no cross-talk.

- BleBaroService: dedicated baro connection (scan-before-connect + direct-connect fallback,
  ESS subscribe, writes ble_baro_data.json). MainActivity routes baro connects to it and
  auto-connects both HR (ble_device.json) and baro (baro_device.json) at start.
- Rust: ble_baro_disconnect, ble_save_baro_device.
- Settings: a 'Датчики (BLE)' section - heart-rate and barometer as separate rows with their
  own slots, bind/connect/unbind, and a live pressure/temperature/altitude readout.
- Tracking: altitude_baro_m stored per point, preferred in elevation stats (null without baro).
- Record screen: 'Высота' from the barometer (1 Hz, dot marker), temperature from the sensor.
- Fixes: direct-connect on scan timeout; Locale.US JSON (RU decimal comma broke the parse);
  parsing routed by characteristic (baro no longer written into the pulse); VR/HR stop returns
  to the tracks list instead of into details.
- tools/baro-sensor/emulate_baro.py: PC BlueZ peripheral that emulates the sensor for testing.

Emulator-verified only; real board still pending.
2026-10-30 22:46:26 +03:00
82f3dc9d4a ble: read DIY barometer (BaroBalDav) over BLE + firmware
Self-made altitude sensor: ESP32-C3 SuperMini + BMP280 broadcasting pressure and
temperature over standard BLE Environmental Sensing. Read into baldav the same way as
the heart-rate strap (Kotlin BLE service -> file -> Rust -> JS), new device_type 'baro'.

- BleHrService: 'baro' type subscribes to ESS 0x181A (pressure 0x2A6D uint32 0.1 Pa,
  temperature 0x2A6E int16 0.01 C), writes ble_baro_data.json + ble_baro_log.jsonl.
  Every baro branch is gated by deviceType=='baro', so HR/GPS paths are untouched.
- ble.rs: BaroReading, ESS detection, ble_get_baro command (Android reads the file,
  desktop returns None). Registered in lib.rs.
- frontend/js/baro.js: passive window.BARO - hypsometric pressure->altitude using the
  sensor temperature, anchored to GPS altitude at ride start. Nothing runs until
  BARO.start(), so with no barometer the app is unchanged.
- tools/baro-sensor: firmware (PlatformIO main.cpp + Arduino sketch) that reads BMP280
  at max oversampling and advertises the ESS service.

Prep only: no hardware yet, verified by compile (build 0.1.538). Live wiring and
ride-track integration pending the board.
2026-10-30 00:38:12 +03:00
1101016ef4 hydration: spoken 'hydrate now' alert, per-activity sweat, drink reconciliation
- signal is now a loud TTS 'hydrate now' on the ALARM stream (TTS warmed at
  session start), so it is unmistakably BalDav and audible when the phone is not
  in view (walking/VR); the old ringtone was indistinguishable from a system alarm.
- sweat need scales by activity instead of a flat 600 ml/h: bike 600, walk 200,
  run 450, workout/vr 250 ml/h. Walking no longer nags every 15 min.
- deficit split into baseDeficit (seeded from the food log) + accrued sweat;
  logging a drink mid-session recomputes the base and re-seeds via seedSeq, so it
  silences the reminder. seedSeq=0 (profile save / init) never zeroes it mid-ride.
- persistent 'БалДав: попей воды (HH:MM)' notification left as a record.
2026-10-27 21:47:10 +03:00
18 changed files with 1215 additions and 90 deletions

View file

@ -0,0 +1,51 @@
# 2026-10-30 - BLE-барометр: сторона baldav
## Контекст
Делаем самодельный датчик высоты: ESP32-C3 SuperMini + BMP280, вещает давление и
температуру по BLE (стандартный Environmental Sensing). Железо заказано, ещё едет.
Прошивка датчика - в `tools/baro-sensor/` (PlatformIO + Arduino-скетч), схема сборки -
`tools/baro-sensor/baro-guide.html`. Эта задача - прочитать датчик в baldav и считать высоту.
## Что сделано
Читаем барометр тем же путём, что и пульсометр (Kotlin BLE-сервис -> файл -> Rust -> JS),
новым `device_type = "baro"`. Диспетчер команд (`MainActivity`) не менялся - тип проходит насквозь.
- `BleHrService.kt`: тип `baro` - подписка на ESS (`0x181A`): давление `0x2A6D` (uint32, 0.1 Па)
и температура `0x2A6E` (int16, 0.01 C). Пишет `ble_baro_data.json` + `ble_baro_log.jsonl`.
Все ветки барометра под `deviceType == "baro"`; HR/GPS-пути не тронуты.
- `ble.rs`: структура `BaroReading`, определение ESS, команда `ble_get_baro`
(Android читает файл; десктоп возвращает None). Зарегистрирована в `lib.rs`.
- `frontend/js/baro.js`: ПАССИВНЫЙ модуль `window.BARO`. Гипсометрический пересчёт давления
в высоту с реальной температурой датчика, якорь к высоте GPS на старте. Ничего не исполняется,
пока не вызван `BARO.start()` - без барометра приложение работает как раньше.
## Состояние
Проверено компиляцией (сборка 0.1.538, без ошибок). На устройстве НЕ проверено - нет железа.
## Продолжение того же дня: обвязка, UI, проверка эмулятором
Железа ещё нет, поэтому эмулировали датчик на ПК (`tools/baro-sensor/emulate_baro.py` -
BlueZ D-Bus GATT-сервер, вещает ESS `0x181A` с давлением/температурой), телефон читал его
реальным путём. Проверено на устройстве: `BleHR: HR:70` и `BleBaro: Baro:... Pa` одновременно.
Сделано:
- `BleBaroService` - отдельный сервис/соединение для барометра, работает параллельно с
пульсометром (один адаптер держит несколько LE-связей). Баро-подключения маршрутизируются
в него из `MainActivity`. Авто-подключение при старте: баро из `baro_device.json`, пульс из
`ble_device.json` (оба сами цепляются).
- Rust: `ble_baro_disconnect`, `ble_save_baro_device`. JS сохраняет baro-устройство при привязке.
- Настройки: секция "Датчики (BLE)" - пульсометр и барометр раздельно, свои слоты и кнопки,
живой показ давления/температуры/высоты.
- Трекинг: `altitude_baro_m` в точках, предпочитается в статистике высот (null без датчика).
- Экран записи: "Высота" от барометра (обновление 1 Гц, пометка точкой), температура с датчика
(белая, с десятой).
- Починки по пути: directConnect при таймауте скана; Locale.US в JSON (была запятая от RU-локали);
маршрутизация парсинга по характеристике (баро не писал в пульс); навигация после Стоп в VR/ЧСС
(на список, а не в детали).
## Осталось (по приходу платы)
- Активировать модуль: `BARO.start()` при подключении baro-устройства, задать `BARO.getGpsAlt`.
- Привязать высоту барометра к треку поездки (в точки / поправка высот П.5).
- UI: показать барометрическую высоту; выбор baro-устройства в scan-UI уже работает (тип проходит).
- Ограничение: сервис держит одно BLE-соединение, поэтому барометр и пульсометр одновременно
пока нельзя - отдельный следующий шаг (две связи / второй сервис).

View file

@ -751,7 +751,12 @@ select {
.full-width { width: 100%; }
/* HR-only workout (зарядка) recording screen: big heart rate, timer, kcal, no map. */
.workout-screen { padding: 24px 16px; display: flex; flex-direction: column; align-items: center; gap: 8px; }
.workout-screen { display: flex; flex-direction: column; height: 100%; }
.wk-main { flex: 1; display: flex; flex-direction: column; align-items: center; justify-content: center; gap: 4px; padding: 16px; }
.wk-panel { flex-shrink: 0; display: flex; flex-direction: column; padding: 10px 16px; padding-bottom: calc(10px + var(--safe-area-bottom, 0px)); }
/* Workout detail (in a modal): fill the scrollable body so the delete button sits at the bottom. */
.wkd-wrap { display: flex; flex-direction: column; min-height: 100%; }
.wkd-del { margin-top: auto; flex: none; align-self: stretch; }
.wk-hr-big { font-size: 92px; font-weight: 700; line-height: 1; color: var(--primary); }
.wk-hr-lbl { color: var(--muted); margin-top: -4px; }
.wk-stats { display: flex; gap: 18px; margin: 14px 0; flex-wrap: wrap; justify-content: center; }
@ -1460,7 +1465,7 @@ body.dark-map .poi-badge { background: #111; border-color: #eee; }
background: var(--surface);
}
.rec-topbar .rec-top { font-size: 27px; font-weight: 700; color: var(--on-surface); }
.rec-topbar .rec-top-mid { color: var(--muted); }
.rec-topbar .rec-top-mid { color: var(--on-surface); }
.rec-lbl {
font-size: 10px;

View file

@ -20,6 +20,7 @@
<script src="lib/jszip.min.js"></script>
<script src="lib/zxing-wasm.js"></script>
<script src="js/db.js"></script>
<script src="js/baro.js"></script>
<script src="js/bmr.js"></script>
<script src="js/tilecache.js"></script>
<script src="js/gps.js"></script>

116
frontend/js/baro.js Normal file
View file

@ -0,0 +1,116 @@
// Barometric altitude from the DIY BLE sensor "BaroBalDav" (ESP32-C3 + BMP280).
// PASSIVE module: it only defines window.BARO. Nothing runs until BARO.start() is called, so with
// no barometer connected the app behaves exactly as before. Activation (start on a "baro" connect,
// plus the getGpsAlt hook) is wired in main.js only when a baro device is in use.
//
// How it works: the Kotlin BLE service writes the latest {pressure_pa, temp_c, ts} to a file; the
// Rust command `ble_get_baro` returns it. We turn pressure into altitude with the hypsometric
// formula using the sensor's own temperature, and anchor the absolute value to the GPS altitude at
// ride start. The sensor is excellent for relative change (~1 m); weather drift of the absolute
// baseline is handled by the GPS anchor (optionally re-anchored slowly).
let BARO = {};
(function () {
let R = 287.05; // specific gas constant for dry air, J/(kg*K)
let G = 9.80665; // standard gravity, m/s^2
let state = {
anchorPa: null, // reference pressure at the anchor point
anchorAltM: null, // absolute altitude (m) at the anchor point, from GPS
lastPa: null, // most recent pressure, Pa
lastTempC: null, // most recent chip temperature, C (for the hypsometric term)
lastTs: 0, // unix seconds of the last reading
lastAltM: null, // computed absolute altitude at the last reading
polling: false,
timer: null,
};
BARO.state = state;
// Height of a level at pressure `pa` above a level at pressure `refPa`, at air temperature tC.
// Hypsometric formula: dh = (R*T/g) * ln(refPa/pa). Measured temperature is used instead of a
// 15 C constant, so a hot or cold day does not bias the climb. Returns metres (positive = higher).
function deltaH(refPa, pa, tC) {
let T = (tC == null ? 15 : tC) + 273.15;
return (R * T / G) * Math.log(refPa / pa);
}
BARO.deltaH = deltaH;
// Pin the barometric altitude to a known absolute altitude (from GPS) at a given pressure.
// Call once at ride start; may be re-called later to slowly correct weather drift.
BARO.anchor = function (gpsAltM, pa) {
if (pa == null) pa = state.lastPa;
if (gpsAltM == null || pa == null) return false;
state.anchorAltM = gpsAltM;
state.anchorPa = pa;
state.lastAltM = BARO.altitude();
return true;
};
// Absolute altitude now = anchor altitude + barometric rise since the anchor. null until anchored.
BARO.altitude = function () {
if (state.anchorPa == null || state.lastPa == null) return null;
return state.anchorAltM + deltaH(state.anchorPa, state.lastPa, state.lastTempC);
};
// Fresh reading within 15 s?
BARO.isLive = function () {
return state.lastTs > 0 && (Date.now() / 1000 - state.lastTs) < 15;
};
// Override this to provide the current GPS altitude (m) for auto-anchoring; return null if no fix.
// Default: the altitude of the last recorded GPS point, if a recording is active.
BARO.getGpsAlt = function () {
try {
let pts = window.GPS && GPS.recording && GPS.recording.points;
if (pts && pts.length) {
let p = pts[pts.length - 1];
let a = p.altitude_srtm_m != null ? p.altitude_srtm_m : p.altitude;
return a != null ? a : null;
}
} catch (e) {}
return null;
};
async function tick() {
let r = null;
try { r = await window.__TAURI__.core.invoke("ble_get_baro"); } catch (e) {}
if (r && r.pressure_pa > 0) {
state.lastPa = r.pressure_pa;
if (r.temp_c != null) state.lastTempC = r.temp_c;
state.lastTs = r.timestamp || Math.floor(Date.now() / 1000);
// auto-anchor on the first good reading, once GPS has an altitude to anchor to
if (state.anchorPa == null) {
let g = null;
try { g = BARO.getGpsAlt(); } catch (e) {}
if (g != null) BARO.anchor(g, state.lastPa);
}
state.lastAltM = BARO.altitude();
}
}
BARO.tick = tick;
// Begin polling the sensor (~1 Hz). No-op if already running. Call this only when a baro device
// is connected, so the app does nothing extra when no barometer is in use.
BARO.start = function () {
if (state.polling) return;
state.polling = true;
let loop = async function () {
if (!state.polling) return;
await tick();
if (state.polling) state.timer = setTimeout(loop, 1000); // 1 s poll interval (a real delay)
};
loop();
};
BARO.stop = function () {
state.polling = false;
if (state.timer) { clearTimeout(state.timer); state.timer = null; }
};
// Clear the anchor and readings (e.g. between rides) so the next ride re-anchors fresh.
BARO.reset = function () {
state.anchorPa = null; state.anchorAltM = null;
state.lastPa = null; state.lastTempC = null; state.lastTs = 0; state.lastAltM = null;
};
window.BARO = BARO;
})();

View file

@ -745,6 +745,7 @@ async function addGpsPoint(sessionId, ts, lat, lon, altGps, speedMs, seq, bleDat
["accel_rms", sensorData?.accel_rms], ["accel_max", sensorData?.accel_max],
["gyro_pitch", sensorData?.gyro_pitch], ["gyro_yaw", sensorData?.gyro_yaw],
["bearing_deg", sensorData?.bearing], ["accuracy_m", sensorData?.accuracy],
["altitude_baro_m", sensorData?.altitude_baro_m],
];
for (const [col, val] of extra) {
if (_gpsPointCols.has(col)) { cols.push(col); vals.push(val ?? null); }
@ -1676,6 +1677,7 @@ async function runMigrations() {
if (!gpsCols.includes("gyro_yaw")) await execute("ALTER TABLE gps_points ADD COLUMN gyro_yaw REAL");
if (!gpsCols.includes("bearing_deg")) await execute("ALTER TABLE gps_points ADD COLUMN bearing_deg REAL");
if (!gpsCols.includes("accuracy_m")) await execute("ALTER TABLE gps_points ADD COLUMN accuracy_m REAL");
if (!gpsCols.includes("altitude_baro_m")) await execute("ALTER TABLE gps_points ADD COLUMN altitude_baro_m REAL"); // barometric altitude from the BLE sensor (null without it)
if (!gpsCols.includes("lat_smoothed")) await execute("ALTER TABLE gps_points ADD COLUMN lat_smoothed REAL");
if (!gpsCols.includes("lon_smoothed")) await execute("ALTER TABLE gps_points ADD COLUMN lon_smoothed REAL");
if (!gpsCols.includes("estimated")) await execute("ALTER TABLE gps_points ADD COLUMN estimated INTEGER DEFAULT 0"); // gap-fill (BRouter) points, reversible

View file

@ -311,7 +311,8 @@ GPS.computeStats = function(points, weightKg, opts) {
// e.g. [45, 45, 52, 45, 45] — the 52 is a GPS altitude glitch.
// Prefer terrain (SRTM/open-elevation) altitude when available — GPS altitude is noisy
// and the stuck-filter destroys its real signal. Terrain is clean and accurate for slope.
const rawAlt = sorted.map(p => p.altitude_srtm_m ?? p.altitude ?? p.altitude_gps_m ?? null);
// Prefer the barometer (best for real climbs/descents) when present, then terrain (SRTM), then GPS.
const rawAlt = sorted.map(p => p.altitude_baro_m ?? p.altitude_srtm_m ?? p.altitude ?? p.altitude_gps_m ?? null);
const filteredAlt = rawAlt.slice();
for (let i = 1; i < filteredAlt.length - 1; i++) {
if (filteredAlt[i] == null) continue;
@ -1170,6 +1171,15 @@ GPS.recoverFromFiles = async function(onProgress) {
// live marker — the same fix is never written twice with different timestamps.
GPS._processIncomingPoint = async function(p, fromNative) {
if (!GPS.recording.active) return;
// Attach barometric altitude to this point when the BLE baro sensor is live and anchored.
// Null without a barometer, so elevation stats fall back to GPS/SRTM exactly as before.
try {
if (window.BARO && BARO.isLive()) {
let ba = BARO.altitude();
if (ba != null && isFinite(ba)) p.altitude_baro_m = ba;
}
} catch (e) {}
// DB writes come only from the source of truth: native points on Android, or
// watchPosition on desktop (no native service).
const writeDb = !!fromNative || !GPS.recording.nativeService;

View file

@ -1364,6 +1364,7 @@ function showFoodModal() {
amountG = Math.round(rawAmount * selectedUnit.grams_per_unit * 10) / 10;
}
await DB.addFoodEntry(state.date, time, selectedProduct.id, amountG, null, unitId, unitAmount);
hydrationOnDrink(); // if it was liquid, quiet the reminder once you've drunk
} else {
let desc = overlay.querySelector("#m-desc").value.trim();
if (!desc) return false;
@ -1850,6 +1851,7 @@ async function renderProducts(container) {
let note = overlay.querySelector("#m-note").value.trim() || null;
if (isNaN(amount) || amount <= 0) return false;
await DB.addFoodEntry(state.date, time, productId, amount, note);
hydrationOnDrink(); // quiet the drink reminder if this was liquid
});
}
@ -2824,23 +2826,46 @@ let gpsMarker = null;
// At session start, seed the native hydration deficit from the FOOD LOG: how far behind on water
// you are for the time of day (need-so-far minus logged intake). During the session the native
// service adds sweat on top. Intake comes from what you log, not a button.
async function seedHydrationDeficit() {
// Sweat (extra water loss) per activity — cycling sweats far more than a walk, so a walk must
// NOT accrue the ride rate (that made it falsely hit the threshold after ~1 h of walking).
let HYDR_SWEAT = { bike: 600, walk: 200, run: 450, workout: 250, vr: 250 };
function hydrSweatFor(type) { return HYDR_SWEAT[type] || 600; }
// Compute the current sedentary shortfall (need-so-far for the time of day minus what you've
// logged drinking today). Shared by the session seed and the on-drink re-seed.
async function hydrBaseDeficit() {
let target = parseInt(state.profile?.daily_water_ml) || 2000;
let now = new Date();
let nowMin = now.getHours() * 60 + now.getMinutes();
let wakeStart = 7 * 60, wakeEnd = 23 * 60; // assume waking 07:00–23:00
let frac = Math.max(0, Math.min(1, (nowMin - wakeStart) / (wakeEnd - wakeStart)));
let intake = await DB.getDailyWaterMl(now.toISOString().slice(0, 10));
return Math.max(0, Math.min(5000, Math.round(target * frac - intake)));
}
async function seedHydrationDeficit(activityType) {
if (localStorage.getItem("baldav_hydr_on") === "0") return; // ON by default unless turned off
try {
let target = parseInt(state.profile?.daily_water_ml) || 2000;
let now = new Date();
let nowMin = now.getHours() * 60 + now.getMinutes();
let wakeStart = 7 * 60, wakeEnd = 23 * 60; // assume waking 07:00–23:00
let frac = Math.max(0, Math.min(1, (nowMin - wakeStart) / (wakeEnd - wakeStart)));
let needSoFar = target * frac;
let intake = await DB.getDailyWaterMl(now.toISOString().slice(0, 10));
let startDeficit = Math.max(0, Math.min(5000, Math.round(needSoFar - intake)));
let startDeficit = await hydrBaseDeficit();
let alertMl = parseInt(localStorage.getItem("baldav_hydr_alert")) || 600;
await window.__TAURI__.core.invoke("set_hydration_config",
{ enabled: true, alertMl, sweatMlPerHour: 600, reAlertMin: 15, startDeficitMl: startDeficit });
{ enabled: true, alertMl, sweatMlPerHour: hydrSweatFor(activityType), reAlertMin: 15, startDeficitMl: startDeficit, seedSeq: Date.now() });
} catch (e) { console.error("seedHydration", e); }
}
// After you log a drink DURING a session: recompute the base deficit (now lower) and push it with
// a fresh seedSeq so the native side drops baseDeficit — the reminder goes quiet once you've drunk.
async function hydrationOnDrink() {
try {
if (!(GPS.recording && GPS.recording.active)) return; // only matters during a session
if (localStorage.getItem("baldav_hydr_on") === "0") return;
let base = await hydrBaseDeficit();
let alertMl = parseInt(localStorage.getItem("baldav_hydr_alert")) || 600;
await window.__TAURI__.core.invoke("set_hydration_config",
{ enabled: true, alertMl, sweatMlPerHour: hydrSweatFor(GPS.recording.activityType), reAlertMin: 15, startDeficitMl: base, seedSeq: Date.now() });
} catch (e) {}
}
async function renderGpsScreen(container) {
// Check Bluetooth state if BLE device is paired
let bleAddr = await DB.getProfileValue("ble_device_addr");
@ -2909,6 +2934,7 @@ async function renderGpsScreen(container) {
<div id="gps-sel-bar" class="gps-sel-bar" hidden>
<span id="gps-sel-count">Выбрано 0</span>
<button id="gps-sel-merge" class="btn-primary" disabled>Объединить</button>
<button id="gps-sel-delete" class="btn-secondary" style="color:#cf6679" disabled>Удалить</button>
<button id="gps-sel-cancel" class="btn-secondary">Отмена</button>
</div>
</div>`;
@ -2955,7 +2981,7 @@ async function renderGpsScreen(container) {
heightCm: parseFloat(state.profile?.height_cm) || 178,
} : null;
await GPS.startRecording(type, wkg, hrProfile);
seedHydrationDeficit();
seedHydrationDeficit(type);
renderScreen("recording");
}
};
@ -2966,11 +2992,13 @@ async function renderGpsScreen(container) {
let selBar = container.querySelector("#gps-sel-bar");
let selCount = container.querySelector("#gps-sel-count");
let selMergeBtn = container.querySelector("#gps-sel-merge");
let selDeleteBtn = container.querySelector("#gps-sel-delete");
let refreshSel = () => {
container.querySelectorAll(".gps-session-item").forEach(it => it.classList.toggle("selected", selected.has(it.dataset.sid)));
if (selBar) selBar.hidden = !selMode;
if (selCount) selCount.textContent = "Выбрано " + selected.size;
if (selMergeBtn) selMergeBtn.disabled = selected.size < 2;
if (selMergeBtn) selMergeBtn.disabled = selected.size < 2; // merge needs 2+
if (selDeleteBtn) selDeleteBtn.disabled = selected.size < 1; // delete works from 1
};
let exitSel = () => { selMode = false; selected.clear(); refreshSel(); };
let toggleSel = (sid) => {
@ -3035,6 +3063,27 @@ async function renderGpsScreen(container) {
selMergeBtn.disabled = false; selMergeBtn.textContent = "Объединить";
}
};
if (selDeleteBtn) selDeleteBtn.onclick = async () => {
if (selected.size < 1) return;
let ids = [...selected];
let n = ids.length;
let word = (n % 10 === 1 && n % 100 !== 11) ? "трек"
: (n % 10 >= 2 && n % 10 <= 4 && (n % 100 < 10 || n % 100 >= 20)) ? "трека" : "треков";
if (!(await appConfirm(`Удалить ${n} ${word}? Это необратимо.`, "Удалить"))) return;
try {
selDeleteBtn.disabled = true; selDeleteBtn.textContent = "Удаляю...";
let done = 0;
for (let id of ids) {
try { await DB.deleteGpsSession(id); done++; } catch (e) { console.error("[bulk delete]", id, e); }
}
showToast(`Удалено: ${done}`);
exitSel();
renderScreen("gps");
} catch (e) {
showToast("Ошибка удаления: " + (e.message || e));
selDeleteBtn.disabled = false; selDeleteBtn.textContent = "Удалить";
}
};
// Pagination: "Показать ещё" loads the next page from the DB and appends it.
let sessOffset = sessions.length;
@ -4752,6 +4801,7 @@ function renderWorkoutDetail(session) {
let max = hrs.length ? Math.max(...hrs) : null;
let kcal = Math.round(session.total_kcal || 0);
let html = `
<div class="wkd-wrap">
<div class="sd-section"><div class="sd-title">${session.activity_type === "vr" ? "Руки/VR" : "Зарядка"} · ${session.date} ${session.start_time ?? ""}</div>
<div class="sd-row">
<div class="sd-stat"><span class="sd-val">${GPS.formatDuration(durSec)}</span><span class="sd-lbl">Время</span></div>
@ -4765,7 +4815,8 @@ function renderWorkoutDetail(session) {
<div class="sd-section"><div class="sd-title">Пульс</div>
<div class="chart-wrap"><canvas id="wk-hr-chart" height="150"></canvas></div>
</div>
<button id="wk-del" class="btn-secondary full-width" style="margin-top:8px;color:#cf6679">Удалить зарядку</button>`;
<button id="wk-del" class="btn-secondary full-width wkd-del" style="color:#cf6679">Удалить зарядку</button>
</div>`;
showModal(html, () => {}, (overlay) => {
let ctx = overlay.querySelector("#wk-hr-chart");
if (ctx && samples.length) {
@ -4792,17 +4843,21 @@ function renderWorkoutDetail(session) {
function renderWorkoutInline(container) {
container.innerHTML = `
<div class="workout-screen">
<div class="wk-hr-big" id="wk-hr">--</div>
<div class="wk-hr-lbl">уд/мин</div>
<div class="wk-stats">
<div class="wk-stat"><span id="wk-time" class="wk-val">0:00</span><span class="wk-lbl">Время</span></div>
<div class="wk-stat"><span id="wk-kcal" class="wk-val">0</span><span class="wk-lbl">ккал</span></div>
<div class="wk-stat"><span id="wk-avg" class="wk-val">--</span><span class="wk-lbl">средний</span></div>
<div class="wk-stat"><span id="wk-max" class="wk-val">--</span><span class="wk-lbl">макс</span></div>
<div class="wk-main">
<div class="wk-hr-big" id="wk-hr">--</div>
<div class="wk-hr-lbl">уд/мин</div>
<div class="wk-status" id="wk-status">Подключите пульсометр</div>
</div>
<div class="wk-panel">
<div class="wk-stats">
<div class="wk-stat"><span id="wk-time" class="wk-val">0:00</span><span class="wk-lbl">Время</span></div>
<div class="wk-stat"><span id="wk-kcal" class="wk-val">0</span><span class="wk-lbl">ккал</span></div>
<div class="wk-stat"><span id="wk-avg" class="wk-val">--</span><span class="wk-lbl">средний</span></div>
<div class="wk-stat"><span id="wk-max" class="wk-val">--</span><span class="wk-lbl">макс</span></div>
</div>
<button id="wk-connect" class="btn-secondary full-width">Подключить пульсометр</button>
<button id="wk-stop" class="btn-primary gps-rec recording full-width">Стоп</button>
</div>
<div class="wk-status" id="wk-status">Подключите пульсометр</div>
<button id="wk-connect" class="btn-secondary full-width">Подключить пульсометр</button>
<button id="wk-stop" class="btn-primary gps-rec recording full-width">Стоп</button>
</div>`;
let hrEl = container.querySelector("#wk-hr"), timeEl = container.querySelector("#wk-time");
@ -4846,8 +4901,8 @@ function renderWorkoutInline(container) {
let res = await GPS.stopRecording();
if (res && res.sessionId) {
showToast(`Зарядка: ${res.kcal} ккал, ${GPS.formatDuration(res.durationSec)}, пульс ${res.avgHr ?? "--"}/${res.maxHr ?? "--"}`);
showSessionDetail(res.sessionId);
} else { renderScreen("gps"); }
}
renderScreen("gps"); // back to the tracks list after stop, like a GPS ride (not into details)
};
}
@ -5445,9 +5500,10 @@ async function renderRecordingInline(container) {
let median = sorted[Math.floor(sorted.length / 2)] || 0;
if (spdEl) spdEl.textContent = median.toFixed(1);
// Elevation
let alt = p.altitude;
if (alt != null && elevEl) elevEl.textContent = Math.round(alt) + " м";
// Elevation - prefer the live barometer (smoother, tracks real climbs) over noisy GPS altitude
let baroAlt = (window.BARO && BARO.isLive()) ? BARO.altitude() : null;
let alt = (baroAlt != null) ? baroAlt : p.altitude;
if (alt != null && elevEl) elevEl.textContent = Math.round(alt) + (baroAlt != null ? " м·" : " м");
// Pause indicator
if (GPS.recording.pauseStart) {
@ -5481,6 +5537,14 @@ async function renderRecordingInline(container) {
// Update clock
let clockEl = document.querySelector("#rec-clock");
if (clockEl) clockEl.textContent = new Date().toTimeString().slice(0, 5);
// Barometer readout at 1 Hz, independent of GPS fixes (so altitude/temp move smoothly).
if (window.BARO && BARO.isLive()) {
let ba = BARO.altitude();
if (ba != null && elevEl) elevEl.textContent = Math.round(ba) + " м·"; // trailing dot = from the barometer
let tc = BARO.state ? BARO.state.lastTempC : null;
let tEl = document.querySelector("#rec-temp");
if (tc != null && tEl) tEl.textContent = tc.toFixed(1) + "°"; // one decimal: visibly live + has the dot
}
}, 1000);
// Fetch temperature — try multiple APIs (mobile internet blocks foreign services)
@ -7781,18 +7845,34 @@ async function renderSettings(container) {
</div>
<div class="settings-section">
<div class="settings-section-title">Пульсометр (BLE)</div>
<div class="settings-section-title">Датчики (BLE)</div>
<div class="settings-item" id="s-ble-device">
<div class="settings-item-left">
<div class="settings-item-title" id="s-ble-name">${state.profile.ble_device_name || "Не привязан"}</div>
<div class="settings-item-desc" id="s-ble-status">${state.profile.ble_device_addr ? state.profile.ble_device_addr : "Нажмите для поиска"}</div>
<div class="settings-item-title">Пульсометр: <span id="s-ble-name">${state.profile.ble_device_name || "не привязан"}</span></div>
<div class="settings-item-desc" id="s-ble-status">${state.profile.ble_device_addr ? state.profile.ble_device_addr : "найдите в поиске ниже"}</div>
</div>
<div style="display:flex;gap:6px">
${state.profile.ble_device_addr ? `<button id="s-ble-unbind" style="padding:6px 12px;font-size:13px;background:#cf6679;color:#fff;border:none;border-radius:4px">Отвязать</button>` : ""}
${state.profile.ble_device_addr ? `<button class="btn-primary" id="s-ble-connect" style="padding:6px 12px;font-size:13px">Подключить</button>` : ""}
<button class="btn-primary" id="s-ble-scan" style="padding:6px 12px;font-size:13px">Поиск</button>
</div>
</div>
<div class="settings-item" id="s-baro-device">
<div class="settings-item-left">
<div class="settings-item-title">Барометр высоты: <span id="s-baro-name">${state.profile.baro_device_name || "не привязан"}</span></div>
<div class="settings-item-desc" id="s-baro-status">${state.profile.baro_device_addr ? state.profile.baro_device_addr : "найдите в поиске ниже"}</div>
</div>
<div style="display:flex;gap:6px">
${state.profile.baro_device_addr ? `<button id="s-baro-unbind" style="padding:6px 12px;font-size:13px;background:#cf6679;color:#fff;border:none;border-radius:4px">Отвязать</button>` : ""}
${state.profile.baro_device_addr ? `<button class="btn-primary" id="s-baro-connect" style="padding:6px 12px;font-size:13px">Подключить</button>` : ""}
</div>
</div>
<div class="settings-item">
<div class="settings-item-left">
<div class="settings-item-title">Поиск устройств</div>
<div class="settings-item-desc">Пульсометр и барометр привяжутся каждый в свою строку. Пока работает одно BLE-подключение за раз.</div>
</div>
<button class="btn-primary" id="s-ble-scan" style="padding:6px 12px;font-size:13px">Поиск</button>
</div>
<div id="s-ble-results" style="padding:0 14px"></div>
<label class="settings-item" style="cursor:pointer">
<div class="settings-item-left"><div class="settings-item-title">Не спрашивать про Bluetooth</div>
@ -8247,6 +8327,69 @@ async function renderSettings(container) {
bleConnectBtn.disabled = false; bleConnectBtn.textContent = "Подключить";
};
// --- Barometer (altitude sensor): its own bind/connect, separate from the heart-rate strap ---
let baroReadoutOn = false;
function startBaroReadout() {
if (baroReadoutOn) return;
baroReadoutOn = true;
let anchorPa = null;
let loop = () => {
let st = container.querySelector("#s-baro-status");
if (!st) { baroReadoutOn = false; return; } // left the settings screen
let s = window.BARO ? BARO.state : null;
let pa = s ? s.lastPa : null, tc = s ? s.lastTempC : null;
if (pa) {
if (anchorPa == null) anchorPa = pa;
let rel = BARO.deltaH(anchorPa, pa, tc);
st.textContent = `${(pa / 100).toFixed(1)} гПа${tc != null ? " · " + tc.toFixed(1) + " C" : ""} · высота ${rel >= 0 ? "+" : ""}${rel.toFixed(1)} м (отн. подключения)`;
} else {
st.textContent = "подключение, ждём данные...";
}
if (baroReadoutOn) setTimeout(loop, 2000);
};
loop();
}
let baroUnbindBtn = container.querySelector("#s-baro-unbind");
if (baroUnbindBtn) baroUnbindBtn.onclick = async () => {
await DB.setProfileValue("baro_device_addr", "");
await DB.setProfileValue("baro_device_name", "");
state.profile.baro_device_addr = "";
state.profile.baro_device_name = "";
try { if (window.BARO) { BARO.stop(); BARO.reset(); } } catch {}
baroReadoutOn = false;
try { await window.__TAURI__.core.invoke("ble_save_baro_device", { address: "" }); } catch {}
try { await window.__TAURI__.core.invoke("ble_baro_disconnect"); } catch {}
let nm = container.querySelector("#s-baro-name"); if (nm) nm.textContent = "не привязан";
let st = container.querySelector("#s-baro-status"); if (st) st.textContent = "найдите в поиске ниже";
baroUnbindBtn.remove();
};
let baroConnectBtn = container.querySelector("#s-baro-connect");
if (baroConnectBtn) baroConnectBtn.onclick = async () => {
let addr = state.profile.baro_device_addr;
if (!addr) return;
let bt = "on"; try { bt = await window.__TAURI__.core.invoke("ble_check_bluetooth"); } catch {}
if (bt === "off") { try { await window.__TAURI__.core.invoke("ble_request_enable"); } catch {} showToast("Включите Bluetooth, затем «Подключить»"); return; }
if (bt === "no_adapter") { showToast("Bluetooth недоступен"); return; }
baroConnectBtn.disabled = true; baroConnectBtn.textContent = "...";
let st = container.querySelector("#s-baro-status"); if (st) st.textContent = "Подключение...";
try {
await window.__TAURI__.core.invoke("ble_connect", { address: addr, deviceType: "baro" });
try { await window.__TAURI__.core.invoke("ble_save_baro_device", { address: addr }); } catch {}
try { if (window.BARO) { BARO.reset(); BARO.start(); } } catch {}
startBaroReadout();
showToast("Барометр: подключение...");
} catch (e) {
if (st) st.textContent = "ошибка подключения";
showToast("Ошибка: " + (e.message || e));
}
baroConnectBtn.disabled = false; baroConnectBtn.textContent = "Подключить";
};
// already-bound barometer that is still polling: resume its live readout on opening settings
if (state.profile.baro_device_addr && window.BARO && BARO.state && BARO.state.polling) startBaroReadout();
let dontAskBt = container.querySelector("#s-dontask-bt");
if (dontAskBt) dontAskBt.onchange = () => { try { localStorage.setItem("baldav_dontask_bt", dontAskBt.checked ? "1" : "0"); } catch {} };
let dontAskGps = container.querySelector("#s-dontask-gps");
@ -8312,17 +8455,27 @@ async function renderSettings(container) {
item.querySelector(".settings-item-desc").textContent = "Подключение...";
try {
await window.__TAURI__.core.invoke("ble_connect", { address: addr, deviceType: type });
await DB.setProfileValue("ble_device_addr", addr);
await DB.setProfileValue("ble_device_type", type);
await DB.setProfileValue("ble_device_name", name);
// Write file for Kotlin to read at GPS start
try { await window.__TAURI__.core.invoke("ble_save_device", { address: addr, deviceType: type }); } catch {}
state.profile.ble_device_addr = addr;
state.profile.ble_device_type = type;
state.profile.ble_device_name = name;
container.querySelector("#s-ble-name").textContent = name;
container.querySelector("#s-ble-status").textContent = addr + " (подключён)";
bleResults.innerHTML = "";
if (type === "baro") {
// barometer -> its own slot, so it doesn't overwrite the heart-rate strap
await DB.setProfileValue("baro_device_addr", addr);
await DB.setProfileValue("baro_device_name", name);
state.profile.baro_device_addr = addr;
state.profile.baro_device_name = name;
// persist for auto-connect at start (separate from the HR device file)
try { await window.__TAURI__.core.invoke("ble_save_baro_device", { address: addr }); } catch {}
try { if (window.BARO) { BARO.reset(); BARO.start(); } } catch {}
} else {
await DB.setProfileValue("ble_device_addr", addr);
await DB.setProfileValue("ble_device_type", type);
await DB.setProfileValue("ble_device_name", name);
// Write file for Kotlin to read at GPS start (HR auto-connect)
try { await window.__TAURI__.core.invoke("ble_save_device", { address: addr, deviceType: type }); } catch {}
state.profile.ble_device_addr = addr;
state.profile.ble_device_type = type;
state.profile.ble_device_name = name;
}
// re-render settings so the Connect/Unbind buttons appear and the baro readout resumes
await renderSettings(container);
} catch (e) {
item.querySelector(".settings-item-desc").textContent = "Ошибка: " + e;
}

View file

@ -48,6 +48,11 @@
android:foregroundServiceType="connectedDevice"
android:exported="false" />
<service
android:name=".BleBaroService"
android:foregroundServiceType="connectedDevice"
android:exported="false" />
<provider
android:name="androidx.core.content.FileProvider"
android:authorities="${applicationId}.fileprovider"

View file

@ -0,0 +1,257 @@
package dev.baldav.app
import android.app.Notification
import android.app.NotificationChannel
import android.app.NotificationManager
import android.app.PendingIntent
import android.app.Service
import android.bluetooth.*
import android.content.BroadcastReceiver
import android.content.Context
import android.content.Intent
import android.content.IntentFilter
import android.os.Build
import android.os.Handler
import android.os.IBinder
import android.os.Looper
import android.util.Log
import java.io.File
import java.util.Locale
import java.util.UUID
// Dedicated BLE connection for the DIY barometer "BaroBalDav" (ESP32-C3 + BMP280). Kept separate
// from BleHrService so the heart-rate strap and the barometer each hold their OWN GATT link and work
// at the same time (one adapter handles several LE connections). Reads the standard Environmental
// Sensing service and writes the latest {pressure_pa, temp_c, ts} to ble_baro_data.json for Rust/JS.
class BleBaroService : Service() {
companion object {
const val TAG = "BleBaro"
const val CHANNEL_ID = "baldav_ble_baro"
const val NOTIFICATION_ID = 3
const val ACTION_STOP = "dev.baldav.app.STOP_BARO"
const val EXTRA_ADDRESS = "address"
val ESS_SERVICE: UUID = UUID.fromString("0000181a-0000-1000-8000-00805f9b34fb")
val PRESSURE_CHAR: UUID = UUID.fromString("00002a6d-0000-1000-8000-00805f9b34fb") // uint32, 0.1 Pa
val TEMP_CHAR: UUID = UUID.fromString("00002a6e-0000-1000-8000-00805f9b34fb") // int16, 0.01 C
val CCCD_UUID: UUID = UUID.fromString("00002902-0000-1000-8000-00805f9b34fb")
var isRunning = false
private set
}
private var gatt: BluetoothGatt? = null
private var dataFile: File? = null
private var logFile: File? = null
private var lastAddress: String? = null
private var connectedOnce = false
private var stopping = false
private var reconnectTries = 0
private val maxReconnect = 3
private var lastTempC: Double = Double.NaN
private val handler = Handler(Looper.getMainLooper())
private val btStateReceiver = object : BroadcastReceiver() {
override fun onReceive(ctx: Context?, intent: Intent?) {
if (intent?.action != BluetoothAdapter.ACTION_STATE_CHANGED) return
val state = intent.getIntExtra(BluetoothAdapter.EXTRA_STATE, BluetoothAdapter.ERROR)
if (state == BluetoothAdapter.STATE_TURNING_OFF || state == BluetoothAdapter.STATE_OFF) {
stopping = true
handler.removeCallbacksAndMessages(null)
disconnect()
stopSelf()
}
}
}
private fun adapter(): BluetoothAdapter? =
(getSystemService(BLUETOOTH_SERVICE) as? android.bluetooth.BluetoothManager)?.adapter
override fun onBind(intent: Intent?): IBinder? = null
override fun onCreate() {
super.onCreate()
createNotificationChannel()
try { registerReceiver(btStateReceiver, IntentFilter(BluetoothAdapter.ACTION_STATE_CHANGED)) }
catch (e: Exception) { Log.e(TAG, "register BT receiver: ${e.message}") }
}
override fun onStartCommand(intent: Intent?, flags: Int, startId: Int): Int {
if (intent?.action == ACTION_STOP) {
stopping = true
disconnect()
stopSelf()
return START_NOT_STICKY
}
val address = intent?.getStringExtra(EXTRA_ADDRESS)
if (address != null) {
startForeground(NOTIFICATION_ID, buildNotification("Барометр: подключение..."))
isRunning = true
val appDataDir = filesDir.parentFile ?: filesDir
dataFile = File(appDataDir, "ble_baro_data.json")
logFile = File(appDataDir, "ble_baro_log.jsonl")
lastAddress = address; stopping = false; connectedOnce = false; reconnectTries = 0
connectDevice(address)
}
return START_NOT_STICKY
}
// Quick scan to warm the BLE cache (avoids status=133), then connect. On scan timeout fall back
// to a direct connect by address - a stationary sensor is reachable even if a 5 s scan misses it.
private fun connectDevice(address: String) {
val adapter = adapter()
if (adapter == null || !adapter.isEnabled) { Log.e(TAG, "Bluetooth not available"); stopSelf(); return }
val scanner = adapter.bluetoothLeScanner
if (scanner == null) { directConnect(adapter, address); return }
val scanCallback = object : android.bluetooth.le.ScanCallback() {
override fun onScanResult(callbackType: Int, result: android.bluetooth.le.ScanResult) {
if (result.device.address == address) {
try { scanner.stopScan(this) } catch (e: Exception) {}
try { gatt = result.device.connectGatt(this@BleBaroService, false, gattCallback, BluetoothDevice.TRANSPORT_LE) }
catch (e: Exception) { Log.e(TAG, "connectGatt: ${e.message}") }
}
}
override fun onScanFailed(errorCode: Int) { directConnect(adapter, address) }
}
try { scanner.startScan(scanCallback) } catch (e: Exception) { directConnect(adapter, address); return }
handler.postDelayed({
try { scanner.stopScan(scanCallback) } catch (e: Exception) {}
if (gatt == null) { Log.d(TAG, "scan timeout - direct connect"); directConnect(adapter, address) }
}, 5000)
}
private fun directConnect(adapter: BluetoothAdapter, address: String) {
if (!adapter.isEnabled) { stopSelf(); return }
try {
gatt = adapter.getRemoteDevice(address).connectGatt(this, false, gattCallback, BluetoothDevice.TRANSPORT_LE)
} catch (e: Exception) { Log.e(TAG, "directConnect: ${e.message}"); stopSelf() }
}
private val gattCallback = object : BluetoothGattCallback() {
override fun onConnectionStateChange(g: BluetoothGatt, status: Int, newState: Int) {
if (newState == BluetoothProfile.STATE_CONNECTED) {
updateNotification("Барометр: поиск сервисов...")
try { g.discoverServices() } catch (e: Exception) { Log.e(TAG, "discoverServices: ${e.message}") }
} else if (newState == BluetoothProfile.STATE_DISCONNECTED) {
isRunning = false
try { g.close() } catch (e: Exception) {}
gatt = null
if (!stopping && connectedOnce && reconnectTries < maxReconnect && adapter()?.isEnabled == true && lastAddress != null) {
reconnectTries++
updateNotification("Барометр: переподключение...")
handler.postDelayed({ if (!stopping) connectDevice(lastAddress!!) }, 8000)
} else stopSelf()
}
}
override fun onServicesDiscovered(g: BluetoothGatt, status: Int) {
if (status != BluetoothGatt.GATT_SUCCESS) { Log.e(TAG, "service discovery failed: $status"); return }
connectedOnce = true; reconnectTries = 0; isRunning = true
setupBaro(g)
updateNotification("Барометр подключён")
}
override fun onCharacteristicChanged(g: BluetoothGatt, char: BluetoothGattCharacteristic, value: ByteArray) {
parseBaro(char, value)
}
@Deprecated("Deprecated in API 33")
override fun onCharacteristicChanged(g: BluetoothGatt, char: BluetoothGattCharacteristic) {
parseBaro(char, char.value ?: return)
}
override fun onDescriptorWrite(g: BluetoothGatt, descriptor: BluetoothGattDescriptor, status: Int) {
onGattOperationComplete()
}
}
private val gattQueue = mutableListOf<() -> Unit>()
private var gattBusy = false
private fun enqueueGatt(op: () -> Unit) { gattQueue.add(op); processGattQueue() }
private fun processGattQueue() {
if (gattBusy || gattQueue.isEmpty()) return
gattBusy = true
gattQueue.removeAt(0).invoke()
}
private fun onGattOperationComplete() {
gattBusy = false
handler.postDelayed({ processGattQueue() }, 100)
}
private fun setupBaro(g: BluetoothGatt) {
val svc = g.getService(ESS_SERVICE)
if (svc == null) { Log.e(TAG, "ESS service not found"); return }
val pc = svc.getCharacteristic(PRESSURE_CHAR)
if (pc == null) { Log.e(TAG, "pressure characteristic not found"); return }
val tc = svc.getCharacteristic(TEMP_CHAR)
enqueueGatt { subscribeNotify(g, pc) }
if (tc != null) enqueueGatt { subscribeNotify(g, tc) }
Log.d(TAG, "subscribed pressure${if (tc != null) " + temp" else ""}")
}
private fun subscribeNotify(g: BluetoothGatt, char: BluetoothGattCharacteristic) {
try {
g.setCharacteristicNotification(char, true)
val desc = char.getDescriptor(CCCD_UUID)
if (desc != null) {
desc.value = BluetoothGattDescriptor.ENABLE_NOTIFICATION_VALUE
g.writeDescriptor(desc)
} else onGattOperationComplete()
} catch (e: Exception) { Log.e(TAG, "subscribeNotify: ${e.message}"); onGattOperationComplete() }
}
private fun parseBaro(char: BluetoothGattCharacteristic, value: ByteArray) {
when (char.uuid) {
TEMP_CHAR -> if (value.size >= 2) {
val u = ((value[1].toInt() and 0xFF) shl 8) or (value[0].toInt() and 0xFF)
lastTempC = u.toShort().toInt() / 100.0
}
PRESSURE_CHAR -> if (value.size >= 4) {
val raw = (value[0].toLong() and 0xFF) or ((value[1].toLong() and 0xFF) shl 8) or
((value[2].toLong() and 0xFF) shl 16) or ((value[3].toLong() and 0xFF) shl 24)
val pa = raw / 10.0
val ts = System.currentTimeMillis() / 1000
val tj = if (!lastTempC.isNaN()) ",\"temp_c\":${String.format(Locale.US, "%.2f", lastTempC)}" else ""
val json = "{\"pressure_pa\":${String.format(Locale.US, "%.1f", pa)}$tj,\"ts\":$ts}"
try { dataFile?.writeText(json) } catch (e: Exception) { Log.e(TAG, "write: ${e.message}") }
try { logFile?.appendText(json + "\n") } catch (e: Exception) {}
Log.d(TAG, "Baro: $pa Pa T=$lastTempC")
}
}
}
private fun disconnect() {
isRunning = false
handler.removeCallbacksAndMessages(null)
try { gatt?.disconnect() } catch (e: Exception) {}
try { gatt?.close() } catch (e: Exception) {}
gatt = null
}
private fun createNotificationChannel() {
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
val channel = NotificationChannel(CHANNEL_ID, "BLE барометр", NotificationManager.IMPORTANCE_LOW)
getSystemService(NotificationManager::class.java).createNotificationChannel(channel)
}
}
private fun buildNotification(text: String): Notification {
val intent = packageManager.getLaunchIntentForPackage(packageName)
val pi = PendingIntent.getActivity(this, 0, intent, PendingIntent.FLAG_IMMUTABLE)
return Notification.Builder(this, CHANNEL_ID)
.setContentTitle("BalDav барометр")
.setContentText(text)
.setSmallIcon(android.R.drawable.ic_menu_compass)
.setContentIntent(pi)
.setOngoing(true)
.build()
}
private fun updateNotification(text: String) {
getSystemService(NotificationManager::class.java).notify(NOTIFICATION_ID, buildNotification(text))
}
override fun onDestroy() {
stopping = true
try { unregisterReceiver(btStateReceiver) } catch (e: Exception) {}
disconnect()
super.onDestroy()
}
}

View file

@ -19,6 +19,7 @@ import android.os.Looper
import android.os.ParcelUuid
import android.util.Log
import java.io.File
import java.util.Locale
import java.util.UUID
import org.json.JSONArray
import org.json.JSONObject
@ -42,6 +43,11 @@ class BleHrService : Service() {
val BATTERY_SERVICE: UUID = UUID.fromString("0000180f-0000-1000-8000-00805f9b34fb")
val BATTERY_LEVEL: UUID = UUID.fromString("00002a19-0000-1000-8000-00805f9b34fb")
// Standard Environmental Sensing — our DIY barometer "BaroBalDav" (ESP32-C3 + BMP280)
val ESS_SERVICE: UUID = UUID.fromString("0000181a-0000-1000-8000-00805f9b34fb")
val PRESSURE_CHAR: UUID = UUID.fromString("00002a6d-0000-1000-8000-00805f9b34fb") // uint32, 0.1 Pa
val TEMP_CHAR: UUID = UUID.fromString("00002a6e-0000-1000-8000-00805f9b34fb") // int16, 0.01 C
// FitPro Nordic UART
val FITPRO_SERVICE: UUID = UUID.fromString("6e400001-b5a3-f393-e0a9-e50e24dcca9d")
val FITPRO_WRITE: UUID = UUID.fromString("6e400002-b5a3-f393-e0a9-e50e24dcca9d")
@ -78,6 +84,11 @@ class BleHrService : Service() {
private var scanResultsFile: File? = null
private var fitproWriteChar: BluetoothGattCharacteristic? = null
private var fitproGatt: BluetoothGatt? = null
// DIY barometer (BaroBalDav): its own data/log files, and the last temperature so each pressure
// reading can carry the temperature for the altitude calc on the JS side.
private var baroDataFile: File? = null
private var baroLogFile: File? = null
private var lastTempC: Double = Double.NaN
// One handler for all postDelayed work, so teardown can cancel every pending callback at once
// (a stray callback touching a GATT/scanner after the adapter is off crashes the native BT stack).
@ -135,9 +146,14 @@ class BleHrService : Service() {
startForeground(NOTIFICATION_ID, buildNotification("Подключение..."))
isRunning = true
val appDataDir = filesDir.parentFile ?: filesDir
dataFile = File(appDataDir, "ble_hr_data.json")
logFile = File(appDataDir, "ble_hr_log.jsonl")
uptimeFile = File(appDataDir, "strap_uptime.json")
if (deviceType == "baro") {
baroDataFile = File(appDataDir, "ble_baro_data.json")
baroLogFile = File(appDataDir, "ble_baro_log.jsonl")
} else {
dataFile = File(appDataDir, "ble_hr_data.json")
logFile = File(appDataDir, "ble_hr_log.jsonl")
uptimeFile = File(appDataDir, "strap_uptime.json")
}
// fresh user-initiated connect: arm reconnect only after it actually connects
lastAddress = address; stopping = false; connectedOnce = false; reconnectTries = 0
connectDevice(address)
@ -176,8 +192,10 @@ class BleHrService : Service() {
val services = result.scanRecord?.serviceUuids?.map { it.uuid } ?: emptyList()
val type = when {
services.contains(ESS_SERVICE) -> "baro"
services.contains(HR_SERVICE_UUID) -> "hr_standard"
services.contains(FITPRO_SERVICE) -> "fitpro"
name.lowercase().contains("baro") -> "baro"
name.lowercase().let { it.contains("fitpro") || it.contains("band") || it.contains("m7") || it.contains("m8") } -> "fitpro"
name.lowercase().let { it.contains("coospo") || it.contains("polar") || it.contains("garmin") || it.contains("hr") } -> "hr_standard"
else -> "unknown"
@ -243,12 +261,14 @@ class BleHrService : Service() {
handler.postDelayed({
try { scanner.stopScan(scanCallback) } catch (e: Exception) { Log.e(TAG, "stopScan: ${e.message}") }
if (gatt == null) {
// Not seen in the scan → the band isn't nearby/on. Do NOT hold a GATT connect to
// an absent device (that keeps the radio busy and drains the battery). Give up;
// the user re-taps "Подключить" once the band is on.
Log.d(TAG, "Scan timeout, device $address not found - stopping")
writeData("""{"status":"not_found","ts":${System.currentTimeMillis()/1000}}""")
stopSelf()
// Not re-found in the pre-connect scan within 5 s. A present-but-not-rescanned device
// (a stationary sensor, or a BlueZ peripheral that the scanner just missed) still
// connects by address, so fall back to a direct connect instead of giving up. The
// address type is already cached from the earlier scan, so connectGatt uses it.
Log.d(TAG, "Scan timeout, device $address not re-found - direct connect fallback")
val a = adapter()
if (a != null && a.isEnabled) directConnect(a, address)
else { writeData("""{"status":"not_found","ts":${System.currentTimeMillis()/1000}}"""); stopSelf() }
}
}, 5000)
}
@ -297,6 +317,7 @@ class BleHrService : Service() {
if (deviceType == "unknown") {
deviceType = when {
g.getService(HR_SERVICE_UUID) != null -> "hr_standard"
g.getService(ESS_SERVICE) != null -> "baro"
g.getService(FITPRO_SERVICE) != null -> "fitpro"
else -> "fitpro" // fallback: try FitPro (Nordic UART is common for cheap bracelets)
}
@ -308,15 +329,25 @@ class BleHrService : Service() {
when (deviceType) {
"hr_standard" -> setupStandardHr(g)
"fitpro" -> setupFitPro(g)
"baro" -> setupBaro(g)
}
updateNotification("Пульсометр подключён")
startHydrationReminder() // workout is on (strap connected) → arm the drink reminder
updateNotification(if (deviceType == "baro") "Барометр подключён" else "Пульсометр подключён")
// drink reminder is a workout/HR feature; the barometer is just a passive altitude source
if (deviceType != "baro") startHydrationReminder()
}
override fun onCharacteristicChanged(g: BluetoothGatt, char: BluetoothGattCharacteristic, value: ByteArray) {
Log.d(TAG, "Data received (${value.size} bytes): ${value.joinToString(" ") { "%02X".format(it) }}")
// Route by WHAT the characteristic is, not the current deviceType: if an HR auto-connect
// races in and flips deviceType while the baro link is still delivering, a pressure/temp
// packet must NOT be parsed as HR. Standard GATT UUIDs are unambiguous.
when (char.uuid) {
PRESSURE_CHAR, TEMP_CHAR -> { parseBaro(char, value); return }
HR_MEASUREMENT_UUID -> { parseStandardHr(value); return }
}
when (deviceType) {
"hr_standard" -> parseStandardHr(value)
"baro" -> parseBaro(char, value)
"fitpro" -> {
// Send ACK for data packets (0xCD) — required by FitPro protocol
if (value.isNotEmpty() && value[0] == 0xCD.toByte() && value.size >= 4) {
@ -391,6 +422,61 @@ class BleHrService : Service() {
} catch (e: Exception) { Log.e(TAG, "readBattery: ${e.message}") }
}
// DIY barometer (Environmental Sensing): subscribe to pressure (required) and temperature
// (optional) notifications. Two CCCD writes can't overlap, so queue them like the FitPro setup.
private fun setupBaro(g: BluetoothGatt) {
val svc = g.getService(ESS_SERVICE)
if (svc == null) { Log.e(TAG, "ESS service not found"); return }
val pc = svc.getCharacteristic(PRESSURE_CHAR)
if (pc == null) { Log.e(TAG, "Pressure characteristic not found"); return }
val tc = svc.getCharacteristic(TEMP_CHAR)
enqueueGatt { subscribeNotify(g, pc) }
if (tc != null) enqueueGatt { subscribeNotify(g, tc) }
Log.d(TAG, "Baro setup: subscribed pressure${if (tc != null) " + temp" else ""}")
}
// Enable notifications on one characteristic and write its CCCD; onDescriptorWrite advances the
// GATT queue. If there's no CCCD, complete immediately so the queue doesn't stall.
private fun subscribeNotify(g: BluetoothGatt, char: BluetoothGattCharacteristic) {
try {
g.setCharacteristicNotification(char, true)
val desc = char.getDescriptor(CCCD_UUID)
if (desc != null) {
desc.value = BluetoothGattDescriptor.ENABLE_NOTIFICATION_VALUE
g.writeDescriptor(desc)
} else onGattOperationComplete()
} catch (e: Exception) { Log.e(TAG, "subscribeNotify: ${e.message}"); onGattOperationComplete() }
}
// Pressure char = uint32 little-endian in 0.1 Pa; Temperature char = int16 little-endian in 0.01 C
// (standard BLE Environmental Sensing units). Temperature arrives on its own notification, so keep
// the last value and attach it to each pressure reading. JS turns pressure into altitude.
private fun parseBaro(char: BluetoothGattCharacteristic, value: ByteArray) {
when (char.uuid) {
TEMP_CHAR -> {
if (value.size >= 2) {
val u = ((value[1].toInt() and 0xFF) shl 8) or (value[0].toInt() and 0xFF)
lastTempC = u.toShort().toInt() / 100.0
}
}
PRESSURE_CHAR -> {
if (value.size >= 4) {
val raw = (value[0].toLong() and 0xFF) or ((value[1].toLong() and 0xFF) shl 8) or
((value[2].toLong() and 0xFF) shl 16) or ((value[3].toLong() and 0xFF) shl 24)
val pa = raw / 10.0 // 0.1 Pa units -> Pa
val ts = System.currentTimeMillis() / 1000
// format with Locale.US - the phone's RU locale writes a decimal comma, which is
// invalid JSON and fails the Rust parse
val tj = if (!lastTempC.isNaN()) ",\"temp_c\":${String.format(Locale.US, "%.2f", lastTempC)}" else ""
val json = "{\"pressure_pa\":${String.format(Locale.US, "%.1f", pa)}$tj,\"ts\":$ts}"
try { baroDataFile?.writeText(json) } catch (e: Exception) { Log.e(TAG, "baro write: ${e.message}") }
try { baroLogFile?.appendText(json + "\n") } catch (e: Exception) {}
Log.d(TAG, "Baro: $pa Pa T=$lastTempC")
}
}
}
}
private val gattQueue = mutableListOf<() -> Unit>()
private var gattBusy = false

View file

@ -12,8 +12,10 @@ import android.os.Build
import android.os.Handler
import android.os.VibrationEffect
import android.os.Vibrator
import android.speech.tts.TextToSpeech
import android.util.Log
import java.io.File
import java.util.Locale
import org.json.JSONObject
// Drink reminder shared by GpsRecorderService (rides) and BleHrService (VR/workout). LEVEL-based,
@ -25,18 +27,23 @@ import org.json.JSONObject
object Hydration {
private const val TAG = "Hydration"
private const val CH = "baldav_hydration"
private var accruedMl = 0.0 // running water deficit: start-of-session shortfall + sweat
private var startDeficitMl = 0.0 // how far behind you were at session start (from the food log)
private var pendingStart = false // apply startDeficitMl on the first tick after reset()
private var baseDeficit = 0.0 // sedentary shortfall at (re)seed: need-so-far minus intake
private var sweatMl = 0.0 // activity sweat accrued this session (grows with the session)
private var startDeficitMl = 0.0 // last seeded base from the food log; applied on (re)seed
private var seedSeq = 0L // JS bumps it on (re)seed (e.g. after you log a drink)
private var lastSeedSeq = -1L // a change re-applies startDeficitMl to baseDeficit mid-session
private var pendingStart = false // apply the seed on the first tick after reset()
private var lastTickMs = 0L
private var lastBeepMs = 0L
private var lastCfgMs = 0L
private var enabled = true // ON by default — works out of the box, no toggle to find
private var sweatMlPerMin = 10.0 // need rate during an active session (600 ml/h default)
private var sweatMlPerMin = 10.0 // need rate during an active session (set per activity by JS)
private var alertMl = 600.0 // beep once the deficit reaches this
private var reAlertMs = 15 * 60 * 1000L
private var lastLogMs = 0L
private var savedAlarmVol = -1 // alarm volume to restore after an alert
private var tts: TextToSpeech? = null
private var ttsReady = false // the signal is a SPOKEN "hydrate now" — unmistakably BalDav
private fun readCfg(ctx: Context) {
try {
@ -48,6 +55,11 @@ object Hydration {
alertMl = j.optInt("alertMl", 600).coerceIn(100, 3000).toDouble()
reAlertMs = j.optInt("reAlertMin", 15).coerceIn(2, 120) * 60_000L
startDeficitMl = j.optInt("startDeficitMl", 0).coerceIn(0, 5000).toDouble()
seedSeq = j.optLong("seedSeq", 0L)
// a NON-ZERO new seedSeq means JS recomputed the base (session start / after a drink)
// -> re-apply it to baseDeficit mid-session; sweat keeps accruing. seedSeq=0 (profile
// save, init) must NOT zero the deficit mid-ride, so it's ignored here.
if (seedSeq != 0L && seedSeq != lastSeedSeq) { baseDeficit = startDeficitMl; lastSeedSeq = seedSeq }
} else enabled = true // no config yet -> ON by default
} catch (e: Exception) { Log.e(TAG, "cfg: ${e.message}"); enabled = true }
}
@ -63,14 +75,15 @@ object Hydration {
val now = System.currentTimeMillis()
if (now - lastCfgMs > 30_000L) { readCfg(ctx); lastCfgMs = now }
if (!enabled) { if (now - lastLogMs > 120_000L) { logState(ctx, "disabled"); lastLogMs = now }; return }
if (pendingStart) { accruedMl = startDeficitMl; pendingStart = false }
if (lastTickMs == 0L) { lastTickMs = now; logState(ctx, "start"); lastLogMs = now; return }
if (pendingStart) { baseDeficit = startDeficitMl; sweatMl = 0.0; lastSeedSeq = seedSeq; pendingStart = false }
if (lastTickMs == 0L) { lastTickMs = now; ensureTts(ctx); logState(ctx, "start"); lastLogMs = now; return }
val dtMin = (now - lastTickMs) / 60_000.0
lastTickMs = now
accruedMl += sweatMlPerMin * dtMin
if (accruedMl >= alertMl && now - lastBeepMs >= reAlertMs) {
sweatMl += sweatMlPerMin * dtMin
val deficit = baseDeficit + sweatMl
if (deficit >= alertMl && now - lastBeepMs >= reAlertMs) {
lastBeepMs = now
val ok = beep(ctx, handler); vibrate(ctx); notify(ctx, accruedMl.toInt())
val ok = beep(ctx, handler); vibrate(ctx); notify(ctx, deficit.toInt())
logState(ctx, if (ok) "beepOk" else "beepError"); lastLogMs = now
} else if (now - lastLogMs > 120_000L) { logState(ctx, "tick"); lastLogMs = now }
}
@ -80,8 +93,8 @@ object Hydration {
try {
val f = File(ctx.filesDir.parentFile ?: ctx.filesDir, "hydration_log.jsonl")
f.appendText("{\"ts\":${System.currentTimeMillis() / 1000},\"ev\":\"$event\"," +
"\"enabled\":$enabled,\"accruedMl\":${accruedMl.toInt()},\"alertMl\":${alertMl.toInt()}," +
"\"startMl\":${startDeficitMl.toInt()}}\n")
"\"enabled\":$enabled,\"accruedMl\":${(baseDeficit + sweatMl).toInt()},\"sweatMl\":${sweatMl.toInt()}," +
"\"baseMl\":${baseDeficit.toInt()},\"alertMl\":${alertMl.toInt()},\"startMl\":${startDeficitMl.toInt()}}\n")
} catch (e: Exception) {}
}
@ -93,24 +106,43 @@ object Hydration {
val am = ctx.getSystemService(Context.AUDIO_SERVICE) as AudioManager
if (savedAlarmVol < 0) savedAlarmVol = am.getStreamVolume(AudioManager.STREAM_ALARM)
am.setStreamVolume(AudioManager.STREAM_ALARM, am.getStreamMaxVolume(AudioManager.STREAM_ALARM), 0)
val uri = RingtoneManager.getActualDefaultRingtoneUri(ctx, RingtoneManager.TYPE_ALARM)
?: RingtoneManager.getDefaultUri(RingtoneManager.TYPE_ALARM)
val mp = MediaPlayer()
mp.setAudioAttributes(AudioAttributes.Builder()
.setUsage(AudioAttributes.USAGE_ALARM)
.setContentType(AudioAttributes.CONTENT_TYPE_SONIFICATION).build())
mp.setDataSource(ctx, uri)
mp.isLooping = true
mp.prepare()
mp.start()
if (tts == null) {
tts = TextToSpeech(ctx.applicationContext) { status ->
ttsReady = status == TextToSpeech.SUCCESS
if (ttsReady) { try { tts?.language = Locale.US } catch (e: Exception) {}; speakNow() }
}
} else if (ttsReady) speakNow()
// restore the alarm volume a few seconds after the phrase
handler.postDelayed({
try { mp.stop(); mp.release() } catch (e: Exception) {}
try { if (savedAlarmVol >= 0) { am.setStreamVolume(AudioManager.STREAM_ALARM, savedAlarmVol, 0); savedAlarmVol = -1 } } catch (e: Exception) {}
}, 4000)
}, 5000)
true
} catch (e: Exception) { Log.e(TAG, "beep: ${e.message}"); false }
}
// Warm the TTS engine up at session start so the first alert isn't silent (init is async).
private fun ensureTts(ctx: Context) {
if (tts != null) return
try {
tts = TextToSpeech(ctx.applicationContext) { status ->
ttsReady = status == TextToSpeech.SUCCESS
if (ttsReady) { try { tts?.language = Locale.US } catch (e: Exception) {} }
}
} catch (e: Exception) { Log.e(TAG, "tts init: ${e.message}") }
}
// Speak the phrase over the ALARM stream so it's loud even with media muted.
private fun speakNow() {
try {
val t = tts ?: return
t.setAudioAttributes(AudioAttributes.Builder()
.setUsage(AudioAttributes.USAGE_ALARM)
.setContentType(AudioAttributes.CONTENT_TYPE_SPEECH).build())
t.speak("hydrate now", TextToSpeech.QUEUE_FLUSH, null, "hyd1")
t.speak("hydrate now", TextToSpeech.QUEUE_ADD, null, "hyd2")
} catch (e: Exception) { Log.e(TAG, "speak: ${e.message}") }
}
private fun vibrate(ctx: Context) {
try {
val v = ctx.getSystemService(Context.VIBRATOR_SERVICE) as? Vibrator ?: return
@ -127,11 +159,12 @@ object Hydration {
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O && nm.getNotificationChannel(CH) == null) {
nm.createNotificationChannel(NotificationChannel(CH, "Напоминание пить", NotificationManager.IMPORTANCE_HIGH))
}
val time = java.text.SimpleDateFormat("HH:mm", Locale.getDefault()).format(java.util.Date())
val n = Notification.Builder(ctx, CH)
.setContentTitle("Попей воды!")
.setContentText("Отстаёшь примерно на $deficitMl мл — попей")
.setContentTitle("БалДав: попей воды")
.setContentText("$time — отстаёшь примерно на $deficitMl мл")
.setSmallIcon(android.R.drawable.ic_menu_compass)
.setAutoCancel(true)
.setAutoCancel(true) // stays in the shade as a record until you tap it
.build()
nm.notify(776601, n)
} catch (e: Exception) { Log.e(TAG, "notify: ${e.message}") }

View file

@ -565,9 +565,14 @@ class MainActivity : TauriActivity() {
val type = if (lastColon > 0) payload.substring(lastColon + 1) else "hr_standard"
Log.d("BalDav", "BLE connect: $address ($type)")
if (ensureBlePermissions()) {
val intent = Intent(this, BleHrService::class.java).apply {
putExtra(BleHrService.EXTRA_ADDRESS, address)
putExtra(BleHrService.EXTRA_DEVICE_TYPE, type)
// barometer has its own service so it and the HR strap connect at the same time
val intent = if (type == "baro") {
Intent(this, BleBaroService::class.java).apply { putExtra(BleBaroService.EXTRA_ADDRESS, address) }
} else {
Intent(this, BleHrService::class.java).apply {
putExtra(BleHrService.EXTRA_ADDRESS, address)
putExtra(BleHrService.EXTRA_DEVICE_TYPE, type)
}
}
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) startForegroundService(intent) else startService(intent)
}
@ -578,6 +583,12 @@ class MainActivity : TauriActivity() {
intent.action = BleHrService.ACTION_STOP
startService(intent)
}
cmd == "baro_disconnect" -> {
Log.d("BalDav", "Baro disconnect")
val intent = Intent(this, BleBaroService::class.java)
intent.action = BleBaroService.ACTION_STOP
startService(intent)
}
cmd == "ble_request_enable" -> {
Log.d("BalDav", "Requesting Bluetooth enable")
if (ensureBlePermissions()) {
@ -711,6 +722,18 @@ class MainActivity : TauriActivity() {
private fun autoStartBle(appDataDir: File) {
try {
// Barometer: auto-connect its own device via its own service, so it runs alongside the HR strap
val baroFile = File(appDataDir, "baro_device.json")
if (baroFile.exists()) {
val bjson = baroFile.readText().trim()
val baddr = Regex(""""addr"\s*:\s*"([^"]+)"""").find(bjson)?.groupValues?.get(1)
if (!baddr.isNullOrEmpty() && ensureBlePermissions()) {
Log.d("BalDav", "Auto-starting baro: $baddr")
val bi = Intent(this, BleBaroService::class.java).apply { putExtra(BleBaroService.EXTRA_ADDRESS, baddr) }
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) startForegroundService(bi) else startService(bi)
}
}
// Read paired BLE device from profile in DB
val bleAddr = File(appDataDir, "ble_device.txt")
// JS saves ble_device_addr in profile (SQLite), but we can't read SQLite here easily.

View file

@ -29,6 +29,17 @@ pub struct HrReading {
pub battery: Option<u8>,
}
// DIY barometer reading (BaroBalDav): atmospheric pressure in Pa and optional chip temperature.
// JS turns pressure into altitude (hypsometric formula, using temp), anchored to GPS at ride start.
#[derive(Serialize, Deserialize, Clone, Debug, Default)]
pub struct BaroReading {
pub pressure_pa: f64,
#[serde(default)]
pub temp_c: Option<f64>,
#[serde(alias = "ts", default)]
pub timestamp: u64,
}
// Shared state for BLE operations
#[cfg(not(target_os = "android"))]
lazy_static::lazy_static! {
@ -49,6 +60,9 @@ struct BleState {
const HR_SERVICE_UUID: &str = "0000180d-0000-1000-8000-00805f9b34fb";
const HR_MEASUREMENT_UUID: &str = "00002a37-0000-1000-8000-00805f9b34fb";
// Standard Environmental Sensing — our DIY barometer "BaroBalDav"
const ESS_SERVICE: &str = "0000181a-0000-1000-8000-00805f9b34fb";
// FitPro Nordic UART UUIDs
const FITPRO_SERVICE: &str = "6e400001-b5a3-f393-e0a9-e50e24dcca9d";
const FITPRO_WRITE: &str = "6e400002-b5a3-f393-e0a9-e50e24dcca9d";
@ -81,6 +95,10 @@ mod desktop {
}
fn detect_device_type(name: &str, services: &[Uuid]) -> String {
// Our DIY barometer advertises standard Environmental Sensing
if services.contains(&uuid(ESS_SERVICE)) {
return "baro".to_string();
}
// Check for standard HR service
if services.contains(&uuid(HR_SERVICE_UUID)) {
return "hr_standard".to_string();
@ -384,6 +402,15 @@ mod android {
}
Ok(None)
}
pub fn read_baro_data(app: &tauri::AppHandle) -> Result<Option<BaroReading>, String> {
if let Some(s) = read_file(app, "ble_baro_data.json") {
if let Ok(r) = serde_json::from_str::<BaroReading>(&s) {
if r.pressure_pa > 0.0 { return Ok(Some(r)); }
}
}
Ok(None)
}
}
// --- Tauri commands ---
@ -465,6 +492,18 @@ pub fn ble_get_hr(
{ android::read_hr_data(&app) }
}
// Latest barometer reading (BaroBalDav). Android: read from the file the Kotlin BLE service writes.
// Desktop: not wired (btleplug baro path not implemented) — returns None.
#[tauri::command]
pub fn ble_get_baro(
app: tauri::AppHandle,
) -> Result<Option<BaroReading>, String> {
#[cfg(not(target_os = "android"))]
{ let _ = &app; Ok(None) }
#[cfg(target_os = "android")]
{ android::read_baro_data(&app) }
}
// Full HR history for the current workout. The Kotlin foreground service appends every
// reading to ble_hr_log.jsonl (one {"hr","ts"[,"bat"]} per line) — that keeps logging with
// the screen off, unlike the JS poll which Android freezes in the background. The workout
@ -557,6 +596,29 @@ pub fn ble_save_device(app: tauri::AppHandle, address: String, device_type: Stri
Ok(())
}
// Disconnect ONLY the barometer (its own service), leaving the HR strap connected.
#[tauri::command]
pub async fn ble_baro_disconnect(app: tauri::AppHandle) -> Result<String, String> {
#[cfg(not(target_os = "android"))]
{ let _ = &app; Ok("desktop: no-op".to_string()) }
#[cfg(target_os = "android")]
{ android::send_command(&app, "baro_disconnect")?; Ok("Disconnecting baro".to_string()) }
}
// Persist the paired barometer so the Kotlin side auto-connects it at start (separate from the HR
// device file). Empty address clears it.
#[tauri::command]
pub fn ble_save_baro_device(app: tauri::AppHandle, address: String) -> Result<(), String> {
use tauri::Manager;
let data_dir = app.path().app_data_dir().map_err(|e: tauri::Error| e.to_string())?;
let json = format!(r#"{{"addr":"{}","type":"baro"}}"#, address);
std::fs::write(data_dir.join("baro_device.json"), &json).ok();
if let Some(root) = data_dir.parent().and_then(|p| p.parent()) {
std::fs::write(root.join("baro_device.json"), &json).ok();
}
Ok(())
}
#[tauri::command]
pub fn ble_check_bluetooth(
app: tauri::AppHandle,

View file

@ -550,10 +550,12 @@ fn gps_service_command(app: tauri::AppHandle, cmd: String) -> Result<String, Str
// start_deficit_ml: how far behind on water you were at session start (from logged intake vs
// need-so-far), computed in JS and seeded into the native deficit. From the settings screen it is 0.
#[tauri::command]
fn set_hydration_config(app: tauri::AppHandle, enabled: bool, alert_ml: u32, sweat_ml_per_hour: u32, re_alert_min: u32, start_deficit_ml: u32) -> Result<String, String> {
fn set_hydration_config(app: tauri::AppHandle, enabled: bool, alert_ml: u32, sweat_ml_per_hour: u32, re_alert_min: u32, start_deficit_ml: u32, seed_seq: Option<u64>) -> Result<String, String> {
// seed_seq: bump it (e.g. a timestamp) whenever the base deficit is recomputed mid-session
// (after logging a drink) so the native side re-applies start_deficit_ml to its baseDeficit.
let json = format!(
"{{\"enabled\":{},\"alertMl\":{},\"sweatMlPerHour\":{},\"reAlertMin\":{},\"startDeficitMl\":{}}}",
enabled, alert_ml.clamp(100, 3000), sweat_ml_per_hour.clamp(60, 2000), re_alert_min.clamp(2, 120), start_deficit_ml.clamp(0, 5000)
"{{\"enabled\":{},\"alertMl\":{},\"sweatMlPerHour\":{},\"reAlertMin\":{},\"startDeficitMl\":{},\"seedSeq\":{}}}",
enabled, alert_ml.clamp(100, 3000), sweat_ml_per_hour.clamp(60, 2000), re_alert_min.clamp(2, 120), start_deficit_ml.clamp(0, 5000), seed_seq.unwrap_or(0)
);
write_app_root_file(&app, "hydration.json", &json);
Ok(json)
@ -1313,7 +1315,7 @@ pub fn run() {
.add_migrations("sqlite:baldav.db", migrations)
.build(),
)
.invoke_handler(tauri::generate_handler![get_safe_insets, import_seed_products, import_tiles, download_file, get_points_filename, delete_points_file, gps_set_session_id, list_points_files, read_points_file, pick_file_open, get_picked_file, debug_native_paths, rebuild_roads, get_road_points, get_ride_graph, get_elev_correction, get_app_info, gps_service_command, set_hydration_config, set_live_config, send_sms, pick_contact, get_contact_result, gps_service_read_points, brouter_route, brouter_download_tile, brouter_download_status, brouter_list_tiles, save_file, export_image, read_file_base64, export_db, import_db, restart_app, get_update_info, http_request, chzn_http, ble::ble_scan, ble::ble_scan_results, ble::ble_connect, ble::ble_disconnect, ble::ble_get_hr, ble::ble_is_connected, ble::ble_check_bluetooth, ble::ble_save_device, ble::ble_clear_hr, ble::ble_read_hr_log, ble::ble_read_strap_uptime, ble::ble_reset_strap_uptime, ble::ble_request_enable, read_state_file])
.invoke_handler(tauri::generate_handler![get_safe_insets, import_seed_products, import_tiles, download_file, get_points_filename, delete_points_file, gps_set_session_id, list_points_files, read_points_file, pick_file_open, get_picked_file, debug_native_paths, rebuild_roads, get_road_points, get_ride_graph, get_elev_correction, get_app_info, gps_service_command, set_hydration_config, set_live_config, send_sms, pick_contact, get_contact_result, gps_service_read_points, brouter_route, brouter_download_tile, brouter_download_status, brouter_list_tiles, save_file, export_image, read_file_base64, export_db, import_db, restart_app, get_update_info, http_request, chzn_http, ble::ble_scan, ble::ble_scan_results, ble::ble_connect, ble::ble_disconnect, ble::ble_get_hr, ble::ble_get_baro, ble::ble_baro_disconnect, ble::ble_save_baro_device, ble::ble_is_connected, ble::ble_check_bluetooth, ble::ble_save_device, ble::ble_clear_hr, ble::ble_read_hr_log, ble::ble_read_strap_uptime, ble::ble_reset_strap_uptime, ble::ble_request_enable, read_state_file])
.run(tauri::generate_context!())
.expect("error while running tauri application");
}

View file

@ -0,0 +1,70 @@
// BalDav BLE barometer - Arduino IDE version (ESP32-C3 SuperMini + BMP280).
// Reads BMP280 over I2C at max oversampling (+IIR) and broadcasts pressure and temperature over
// BLE as the standard Environmental Sensing service, ~1 Hz. baldav reads it via noble and turns
// pressure into altitude (using the temperature for the hypsometric correction). It advertises
// continuously so a USB power bank does not cut off on an idle load.
//
// One-time setup in Arduino IDE:
// 1. File > Preferences > Additional Boards Manager URLs:
// https://raw.githubusercontent.com/espressif/arduino-esp32/gh-pages/package_esp32_index.json
// 2. Boards Manager: install "esp32 by Espressif Systems".
// 3. Tools > Board > ESP32 Arduino > "ESP32C3 Dev Module".
// Tools > USB CDC On Boot > Enabled (so the native USB serial works).
// 4. Library Manager: install "Adafruit BMP280 Library" (pulls Adafruit Unified Sensor +
// Adafruit BusIO) and "NimBLE-Arduino".
// 5. Plug the board (USB-C), pick the port, press Upload.
// If upload can't connect: hold BOOT (GPIO9), tap RESET, release BOOT, upload again.
#include <Wire.h>
#include <Adafruit_BMP280.h>
#include <NimBLEDevice.h>
static const int SDA_PIN = 3; // BMP280 SDA -> GPIO3
static const int SCL_PIN = 4; // BMP280 SCL -> GPIO4
static const uint8_t BMP_ADDR_A = 0x76; // SDO -> GND
static const uint8_t BMP_ADDR_B = 0x77; // SDO -> 3V3 (fallback)
Adafruit_BMP280 bmp;
NimBLECharacteristic* chPress; // 0x2A6D Pressure, uint32, units 0.1 Pa
NimBLECharacteristic* chTemp; // 0x2A6E Temperature, int16, units 0.01 C
void setup() {
Serial.begin(115200);
Wire.begin(SDA_PIN, SCL_PIN);
if (!bmp.begin(BMP_ADDR_A) && !bmp.begin(BMP_ADDR_B)) {
Serial.println("BMP280 not found - check VCC/GND/SDA/SCL, CSB->3V3, SDO->GND");
}
bmp.setSampling(Adafruit_BMP280::MODE_NORMAL,
Adafruit_BMP280::SAMPLING_X2, // temperature oversampling
Adafruit_BMP280::SAMPLING_X16, // pressure oversampling (max)
Adafruit_BMP280::FILTER_X16, // IIR filter (max smoothing)
Adafruit_BMP280::STANDBY_MS_250);
NimBLEDevice::init("BaroBalDav");
NimBLEServer* srv = NimBLEDevice::createServer();
NimBLEService* ess = srv->createService("181A"); // Environmental Sensing
chPress = ess->createCharacteristic("2A6D",
NIMBLE_PROPERTY::READ | NIMBLE_PROPERTY::NOTIFY); // Pressure
chTemp = ess->createCharacteristic("2A6E",
NIMBLE_PROPERTY::READ | NIMBLE_PROPERTY::NOTIFY); // Temperature
ess->start();
NimBLEAdvertising* adv = NimBLEDevice::getAdvertising();
adv->addServiceUUID("181A");
adv->setName("BaroBalDav");
adv->start();
}
void loop() {
float pa = bmp.readPressure(); // Pa
float tc = bmp.readTemperature(); // deg C (chip temperature)
uint32_t pv = (uint32_t)lroundf(pa * 10.0f); // 0.1 Pa units per BLE spec
int16_t tv = (int16_t)lroundf(tc * 100.0f); // 0.01 C units per BLE spec
chPress->setValue((uint8_t*)&pv, sizeof(pv)); chPress->notify();
chTemp->setValue((uint8_t*)&tv, sizeof(tv)); chTemp->notify();
Serial.printf("P=%.2f hPa T=%.2f C\n", pa / 100.0f, tc);
delay(1000);
}

View file

@ -0,0 +1,168 @@
#!/usr/bin/env python3
# Emulate the "BaroBalDav" sensor on this PC's Bluetooth so the phone's baldav can be tested
# against the REAL Kotlin BLE read path before the ESP32 arrives. Advertises the standard
# Environmental Sensing service (0x181A) with Pressure (0x2A6D, uint32 0.1 Pa) and Temperature
# (0x2A6E, int16 0.01 C), and pushes a simulated pressure that rises and falls so altitude moves.
#
# Pure BlueZ D-Bus GATT server (python3-dbus + python3-gi) - no bluetoothctl, no pip installs.
# Run: python3 tools/baro-sensor/emulate_baro.py (Ctrl+C to stop)
import struct, math, time, sys
import dbus, dbus.mainloop.glib, dbus.service
from gi.repository import GLib
BLUEZ = "org.bluez"
ADAPTER_IFACE = "org.bluez.Adapter1"
GATT_MANAGER = "org.bluez.GattManager1"
LE_ADV_MANAGER = "org.bluez.LEAdvertisingManager1"
DBUS_OM = "org.freedesktop.DBus.ObjectManager"
DBUS_PROP = "org.freedesktop.DBus.Properties"
ESS_UUID = "0000181a-0000-1000-8000-00805f9b34fb"
PRESSURE_UUID = "00002a6d-0000-1000-8000-00805f9b34fb"
TEMP_UUID = "00002a6e-0000-1000-8000-00805f9b34fb"
def find_adapter(bus):
om = dbus.Interface(bus.get_object(BLUEZ, "/"), DBUS_OM)
for path, ifaces in om.GetManagedObjects().items():
if ADAPTER_IFACE in ifaces and LE_ADV_MANAGER in ifaces:
return path
return None
# ---- GATT application / service / characteristic boilerplate (BlueZ example pattern) ----
class Application(dbus.service.Object):
def __init__(self, bus):
self.path = "/dev/baldav/baro"
self.services = []
dbus.service.Object.__init__(self, bus, self.path)
def get_path(self): return dbus.ObjectPath(self.path)
def add_service(self, s): self.services.append(s)
@dbus.service.method(DBUS_OM, out_signature="a{oa{sa{sv}}}")
def GetManagedObjects(self):
out = {}
for s in self.services:
out[s.get_path()] = s.get_properties()
for c in s.chars:
out[c.get_path()] = c.get_properties()
return out
class Service(dbus.service.Object):
def __init__(self, bus, index, uuid, primary=True):
self.path = "/dev/baldav/baro/service%d" % index
self.uuid = uuid; self.primary = primary; self.chars = []
dbus.service.Object.__init__(self, bus, self.path)
def get_path(self): return dbus.ObjectPath(self.path)
def add_char(self, c): self.chars.append(c)
def get_properties(self):
return {"org.bluez.GattService1": {
"UUID": self.uuid, "Primary": self.primary,
"Characteristics": dbus.Array([c.get_path() for c in self.chars], signature="o")}}
class Characteristic(dbus.service.Object):
def __init__(self, bus, index, uuid, flags, service):
self.path = service.path + "/char%d" % index
self.uuid = uuid; self.flags = flags; self.service = service
self.notifying = False; self.value = []
dbus.service.Object.__init__(self, bus, self.path)
def get_path(self): return dbus.ObjectPath(self.path)
def get_properties(self):
return {"org.bluez.GattCharacteristic1": {
"Service": self.service.get_path(), "UUID": self.uuid, "Flags": self.flags}}
@dbus.service.method(DBUS_PROP, in_signature="s", out_signature="a{sv}")
def GetAll(self, iface):
if iface != "org.bluez.GattCharacteristic1":
raise dbus.exceptions.DBusException("org.bluez.Error.InvalidArguments")
return self.get_properties()["org.bluez.GattCharacteristic1"]
@dbus.service.method("org.bluez.GattCharacteristic1", in_signature="a{sv}", out_signature="ay")
def ReadValue(self, options): return dbus.Array(self.value, signature="y")
@dbus.service.method("org.bluez.GattCharacteristic1")
def StartNotify(self):
self.notifying = True
print(" [%s] StartNotify" % self.uuid[4:8])
@dbus.service.method("org.bluez.GattCharacteristic1")
def StopNotify(self):
self.notifying = False
print(" [%s] StopNotify" % self.uuid[4:8])
@dbus.service.signal(DBUS_PROP, signature="sa{sv}as")
def PropertiesChanged(self, iface, changed, invalidated): pass
def set_value(self, raw):
self.value = [dbus.Byte(b) for b in raw]
if self.notifying:
self.PropertiesChanged("org.bluez.GattCharacteristic1",
{"Value": dbus.Array(self.value, signature="y")}, [])
# ---- LE advertisement ----
class Advertisement(dbus.service.Object):
def __init__(self, bus, index):
self.path = "/dev/baldav/baro/adv%d" % index
dbus.service.Object.__init__(self, bus, self.path)
def get_path(self): return dbus.ObjectPath(self.path)
@dbus.service.method(DBUS_PROP, in_signature="s", out_signature="a{sv}")
def GetAll(self, iface):
if iface != "org.bluez.LEAdvertisement1":
raise dbus.exceptions.DBusException("org.bluez.Error.InvalidArguments")
return {
"Type": "peripheral",
"ServiceUUIDs": dbus.Array([ESS_UUID], signature="s"),
"LocalName": dbus.String("BaroBalDav"),
"Includes": dbus.Array(["tx-power"], signature="s"),
}
@dbus.service.method("org.bluez.LEAdvertisement1")
def Release(self): print("Advertisement released")
# ---- pressure/temperature simulation ----
def enc_pressure(pa): return struct.pack("<I", round(pa * 10)) # uint32, 0.1 Pa
def enc_temp(tc): return struct.pack("<h", round(tc * 100)) # int16, 0.01 C
def main():
dbus.mainloop.glib.DBusGMainLoop(set_as_default=True)
bus = dbus.SystemBus()
adapter = find_adapter(bus)
if not adapter:
print("No BLE adapter with GATT+Advertising found"); sys.exit(1)
print("adapter:", adapter)
app = Application(bus)
svc = Service(bus, 0, ESS_UUID, True)
press = Characteristic(bus, 0, PRESSURE_UUID, ["read", "notify"], svc)
temp = Characteristic(bus, 1, TEMP_UUID, ["read", "notify"], svc)
svc.add_char(press); svc.add_char(temp); app.add_service(svc)
gatt = dbus.Interface(bus.get_object(BLUEZ, adapter), GATT_MANAGER)
adv_mgr = dbus.Interface(bus.get_object(BLUEZ, adapter), LE_ADV_MANAGER)
adv = Advertisement(bus, 0)
t0 = time.time()
def tick():
t = time.time() - t0
# sea-level-ish pressure that swings ~600 Pa (~ +-50 m) with a ~60 s period, so altitude moves
pa = 101325.0 - 600.0 * math.sin(t / 10.0)
tc = 24.0 + 0.5 * math.sin(t / 25.0)
press.set_value(enc_pressure(pa))
temp.set_value(enc_temp(tc))
if int(t) % 5 == 0:
print(" sim: P=%.1f Pa (%.2f hPa) T=%.2f C" % (pa, pa/100.0, tc))
return True
tick()
def reg_ok(): print("GATT application registered")
def reg_err(e): print("GATT register error:", e); mainloop.quit()
def adv_ok(): print("Advertising as 'BaroBalDav' (service 0x181A)")
def adv_err(e): print("Advertising error:", e); mainloop.quit()
gatt.RegisterApplication(app.get_path(), {}, reply_handler=reg_ok, error_handler=reg_err)
adv_mgr.RegisterAdvertisement(adv.get_path(), {}, reply_handler=adv_ok, error_handler=adv_err)
GLib.timeout_add(1000, tick)
mainloop = GLib.MainLoop()
print("BaroBalDav emulator running - connect from the phone. Ctrl+C to stop.")
try:
mainloop.run()
except KeyboardInterrupt:
print("\nstopping")
try: adv_mgr.UnregisterAdvertisement(adv.get_path())
except Exception: pass
try: gatt.UnregisterApplication(app.get_path())
except Exception: pass
if __name__ == "__main__":
main()

View file

@ -0,0 +1,20 @@
; BalDav BLE barometer - ESP32-C3 SuperMini + BMP280
; Build & flash over USB, no Arduino IDE:
; pip install platformio (once)
; pio run -t upload (compile + flash via USB-C)
; pio device monitor (optional: see logs)
; ESP32-C3 flashes over its native USB. If upload can't find the port the first time:
; hold BOOT (GPIO9), tap RESET, release BOOT -> it enters download mode, then retry upload.
[env:esp32-c3-supermini]
platform = espressif32
board = esp32-c3-devkitm-1
framework = arduino
monitor_speed = 115200
; native USB-CDC so the board enumerates as a serial port over its own USB-C
build_flags =
-D ARDUINO_USB_MODE=1
-D ARDUINO_USB_CDC_ON_BOOT=1
lib_deps =
adafruit/Adafruit BMP280 Library @ ^2.6.8
h2zero/NimBLE-Arduino @ ^1.4.1

View file

@ -0,0 +1,61 @@
// BalDav BLE barometer: ESP32-C3 SuperMini + BMP280.
// Reads the BMP280 over I2C at max oversampling (+IIR filter) and broadcasts pressure and
// temperature over BLE as the standard Environmental Sensing service, ~1 Hz. baldav reads it
// via noble like the HR strap and turns pressure into altitude (using the temperature for the
// hypsometric correction). It advertises continuously (no deep sleep) so a USB power bank does
// not cut off on an idle load; current is dominated by the radio, the barometer is negligible.
#include <Wire.h>
#include <Adafruit_BMP280.h>
#include <NimBLEDevice.h>
static const int SDA_PIN = 3; // BMP280 SDA -> GPIO3
static const int SCL_PIN = 4; // BMP280 SCL -> GPIO4
static const uint8_t BMP_ADDR_A = 0x76; // SDO->GND
static const uint8_t BMP_ADDR_B = 0x77; // SDO->3V3 (fallback)
Adafruit_BMP280 bmp;
NimBLECharacteristic* chPress; // 0x2A6D Pressure, uint32, units 0.1 Pa
NimBLECharacteristic* chTemp; // 0x2A6E Temperature, int16, units 0.01 C
void setup() {
Serial.begin(115200);
Wire.begin(SDA_PIN, SCL_PIN);
if (!bmp.begin(BMP_ADDR_A) && !bmp.begin(BMP_ADDR_B)) {
Serial.println("BMP280 not found - check wiring (VCC/GND/SDA/SCL, CSB->3V3, SDO->GND)");
}
// Max pressure oversampling + max IIR filter = lowest noise. We sample ~1 Hz, so the extra
// conversion time costs microamps - nothing next to the BLE radio.
bmp.setSampling(Adafruit_BMP280::MODE_NORMAL,
Adafruit_BMP280::SAMPLING_X2, // temperature oversampling
Adafruit_BMP280::SAMPLING_X16, // pressure oversampling (max)
Adafruit_BMP280::FILTER_X16, // IIR filter (max smoothing)
Adafruit_BMP280::STANDBY_MS_250);
NimBLEDevice::init("BaroBalDav");
NimBLEServer* srv = NimBLEDevice::createServer();
NimBLEService* ess = srv->createService("181A"); // Environmental Sensing
chPress = ess->createCharacteristic("2A6D",
NIMBLE_PROPERTY::READ | NIMBLE_PROPERTY::NOTIFY); // Pressure
chTemp = ess->createCharacteristic("2A6E",
NIMBLE_PROPERTY::READ | NIMBLE_PROPERTY::NOTIFY); // Temperature
ess->start();
NimBLEAdvertising* adv = NimBLEDevice::getAdvertising();
adv->addServiceUUID("181A");
adv->setName("BaroBalDav");
adv->start();
}
void loop() {
float pa = bmp.readPressure(); // Pa
float tc = bmp.readTemperature(); // deg C (chip temperature)
uint32_t pv = (uint32_t)lroundf(pa * 10.0f); // 0.1 Pa units per BLE spec
int16_t tv = (int16_t)lroundf(tc * 100.0f); // 0.01 C units per BLE spec
chPress->setValue((uint8_t*)&pv, sizeof(pv)); chPress->notify();
chTemp->setValue((uint8_t*)&tv, sizeof(tv)); chTemp->notify();
Serial.printf("P=%.2f hPa T=%.2f C\n", pa / 100.0f, tc);
delay(1000);
}