Ходьба · лайв

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_170":171,"_172":173},"routes/_app.x.$handle.$name",{"_97":96,"_32":45,"_106":87,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":59,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",27,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","client.ts","latestPath","fileId","03108698-a3be-11f1-acf8-1607ee4eb77e","name","fileType","script","content","// Лайв-трекер ходьбы. Читает дорожку по Web Bluetooth.\n// Состояние связи берём напрямую из GATT, разрыв — переподключаемся сами.\n\nconst $ = (id: string) => document.getElementById(id)!;\n\nconst FTMS = 0x1826;\nconst RSC = 0x1814;\nconst EXTRA_SERVICES = [0x180d, 0x180f, 0x181c, 0xfe00, 0xffe0, 0xfff0];\n\nconst DAY = () => new Date().toISOString().slice(0, 10);\nconst KEY = \"walk-live\";\n\ntype State = {\n speedKmh: number;\n distanceM: number;\n movingS: number;\n steps: number;\n source: string;\n};\n\nfunction load(): State {\n const empty: State = { speedKmh: 0, distanceM: 0, movingS: 0, steps: 0, source: \"\" };\n try {\n const raw = JSON.parse(localStorage.getItem(KEY) || \"{}\");\n if (raw.day === DAY()) return { ...empty, ...raw.state, speedKmh: 0 };\n } catch { /* пусто */ }\n return empty;\n}\n\nconst s = load();\nlet distReal = s.distanceM;\n\nfunction save() {\n try {\n localStorage.setItem(KEY, JSON.stringify({ day: DAY(), state: { ...s, speedKmh: 0 } }));\n } catch { /* приватный режим */ }\n}\n\nconst num = (id: string, fallback: number) => {\n const v = parseFloat(($(id) as HTMLInputElement).value);\n return Number.isFinite(v) ? v : fallback;\n};\n\n// ── журнал ───────────────────────────────────────────────────────────────────\n\nconst lines: string[] = [];\nfunction log(line: string) {\n lines.unshift(`${new Date().toLocaleTimeString(\"ru-RU\")} ${line}`);\n if (lines.length > 200) lines.pop();\n $(\"log\").textContent = lines.join(\"\\n\") || \"пусто\";\n}\n\nconst hex = (v: DataView) =>\n [...new Uint8Array(v.buffer)].map((b) => b.toString(16).padStart(2, \"0\")).join(\" \");\n\n// ── связь ────────────────────────────────────────────────────────────────────\n\nlet device: any = null;\nlet packets = 0;\nlet lastPacketAt = 0;\nlet reconnecting = false;\n\nconst isConnected = () => !!device?.gatt?.connected;\n\nasync function pickDevice() {\n const bt = (navigator as any).bluetooth;\n if (!bt) {\n alert(\"Web Bluetooth есть только в Chrome. Открой страницу там.\");\n return;\n }\n try {\n device = await bt.requestDevice({\n acceptAllDevices: true,\n optionalServices: [FTMS, RSC, ...EXTRA_SERVICES],\n });\n log(`устройство: ${device.name || \"без имени\"}`);\n\n device.addEventListener(\"gattserverdisconnected\", () => {\n log(\"связь разорвана, переподключаюсь…\");\n s.speedKmh = 0;\n prevDev = null;\n render();\n reconnect();\n });\n\n await attach();\n } catch (e: any) {\n log(`ошибка выбора: ${e.message || e}`);\n }\n}\n\nasync function attach() {\n const server = await device.gatt.connect();\n const services = await server.getPrimaryServices();\n log(`подключено, сервисов: ${services.length}`);\n\n let bound = 0;\n for (const svc of services) {\n const chars = await svc.getCharacteristics().catch(() => []);\n log(`сервис ${svc.uuid}`);\n for (const ch of chars) {\n const p = ch.properties;\n const props = [\n p.read && \"read\",\n p.write && \"write\",\n p.writeWithoutResponse && \"writeNR\",\n p.notify && \"notify\",\n ].filter(Boolean).join(\",\");\n log(` · ${ch.uuid} [${props}]`);\n\n // 2AD9 — пульт: старт/стоп/скорость\n if (ch.uuid.includes(\"2ad9\")) {\n ctlChar = ch;\n ($(\"ctl\") as HTMLElement).hidden = false;\n await ctlWrite([0x00], \"запрос управления\");\n }\n\n // 2AD4 — какие скорости дорожка вообще принимает\n if (ch.uuid.includes(\"2ad4\") && p.read) {\n try {\n const r = await ch.readValue();\n speedMin = r.getUint16(0, true) / 100;\n speedMax = r.getUint16(2, true) / 100;\n speedStep = Math.max(0.1, r.getUint16(4, true) / 100);\n target = Math.min(Math.max(target, speedMin), speedMax);\n $(\"range\").textContent =\n `диапазон ${speedMin.toFixed(1)}–${speedMax.toFixed(1)} км/ч, шаг ${speedStep.toFixed(1)}`;\n renderCtl();\n } catch { /* не прочиталось */ }\n }\n\n if (!p.notify) continue;\n try {\n await ch.startNotifications();\n bound++;\n const uuid = ch.uuid;\n ch.addEventListener(\"characteristicvaluechanged\", (e: any) => {\n const v: DataView = e.target.value;\n packets++;\n lastPacketAt = performance.now();\n if (uuid.includes(\"2acd\")) parseFtms(v);\n else if (uuid.includes(\"2a53\")) parseRsc(v);\n else if (packets < 40) log(`${uuid.slice(4, 8)}: ${hex(v)}`);\n advance();\n render();\n });\n } catch { /* не даёт подписаться */ }\n }\n }\n\n if (!bound) log(\"нет каналов с уведомлениями — данные не придут\");\n lastAdv = performance.now();\n render();\n}\n\nasync function reconnect() {\n if (reconnecting || !device) return;\n reconnecting = true;\n for (let i = 1; i <= 20; i++) {\n await new Promise((r) => setTimeout(r, 3000));\n if (isConnected()) break;\n try {\n await attach();\n log(\"переподключился\");\n break;\n } catch {\n log(`попытка ${i} не удалась`);\n }\n }\n reconnecting = false;\n}\n\n// ── пульт (FTMS Control Point, 2AD9) ─────────────────────────────────────────\n\nlet ctlChar: any = null;\nlet speedMin = 0.5;\nlet speedMax = 6;\nlet speedStep = 0.1;\nlet target = 2;\n\nasync function ctlWrite(bytes: number[], what = \"\") {\n if (!ctlChar) return;\n try {\n const buf = new Uint8Array(bytes);\n if (ctlChar.writeValueWithResponse) await ctlChar.writeValueWithResponse(buf);\n else await ctlChar.writeValue(buf);\n log(`→ ${what || bytes.map((b) => b.toString(16).padStart(2, \"0\")).join(\" \")}`);\n } catch (e: any) {\n log(`команда не прошла: ${e.message || e}`);\n }\n}\n\nconst startBelt = () => ctlWrite([0x07], \"старт\");\nconst stopBelt = () => ctlWrite([0x08, 0x01], \"стоп\");\n\nasync function setSpeed(kmh: number) {\n target = Math.min(speedMax, Math.max(speedMin, Math.round(kmh * 10) / 10));\n const v = Math.round(target * 100);\n await ctlWrite([0x02, v & 0xff, (v >> 8) & 0xff], `скорость ${target.toFixed(1)}`);\n renderCtl();\n}\n\nfunction renderCtl() {\n $(\"target\").textContent = target.toFixed(1);\n}\n\n// ── весы ─────────────────────────────────────────────────────────────────────\n\n// Браузер показывает только те сервисы, которые заявлены заранее.\n// Поэтому перечисляем всё, на чём делают бытовые весы.\nconst SCALE_SERVICES = [\n 0x181d, // Weight Scale — стандарт\n 0x181b, // Body Composition — стандарт\n 0x180f, 0x180a, 0x1800, 0x1801,\n 0xfff0, 0xffe0, 0xffb0, 0xffe5, 0xfee0, 0xfee7, 0xfe95, 0x1910,\n \"0000fff0-0000-1000-8000-00805f9b34fb\",\n \"0000ffb0-0000-1000-8000-00805f9b34fb\",\n \"0000ffe0-0000-1000-8000-00805f9b34fb\",\n \"0000fee0-0000-1000-8000-00805f9b34fb\",\n \"0000face-0000-1000-8000-00805f9b34fb\",\n \"0000fff1-0000-1000-8000-00805f9b34fb\",\n \"0000ffc0-0000-1000-8000-00805f9b34fb\",\n];\n\nlet scaleDev: any = null;\nlet lastKg = 0;\n\n// Стандартный Weight Measurement (0x2A9D)\nfunction parseWeight(v: DataView) {\n const flags = v.getUint8(0);\n const raw = v.getUint16(1, true);\n const kg = flags & 0x01 ? raw * 0.01 * 0.4536 : raw * 0.005;\n return kg;\n}\n\nfunction onWeight(kg: number, source: string) {\n if (kg < 20 || kg > 250) return;\n lastKg = kg;\n log(`⚖️ ВЕС: ${kg.toFixed(1)} кг (${source})`);\n $(\"state\").textContent = `вес ${kg.toFixed(1)} кг`;\n}\n\nasync function pickScale() {\n const bt = (navigator as any).bluetooth;\n if (!bt) { alert(\"Нужен Chrome.\"); return; }\n\n try {\n log(\"выбор весов… встань на них сейчас\");\n scaleDev = await bt.requestDevice({\n acceptAllDevices: true,\n optionalServices: SCALE_SERVICES,\n });\n log(`весы: ${scaleDev.name || \"без имени\"}`);\n\n const server = await scaleDev.gatt.connect();\n const services = await server.getPrimaryServices();\n log(`весы подключены, сервисов: ${services.length}`);\n\n if (!services.length) {\n log(\"сервисов нет — весы шлют вес только в эфир, браузер такое не читает\");\n return;\n }\n\n for (const svc of services) {\n log(`сервис весов ${svc.uuid}`);\n const chars = await svc.getCharacteristics().catch(() => []);\n for (const ch of chars) {\n const p = ch.properties;\n log(` · ${ch.uuid} [${[\n p.read && \"read\",\n p.write && \"write\",\n p.writeWithoutResponse && \"writeNR\",\n p.notify && \"notify\",\n p.indicate && \"indicate\",\n ].filter(Boolean).join(\",\")}]`);\n\n if (!p.notify && !p.indicate) continue;\n try {\n await ch.startNotifications();\n const uuid = ch.uuid;\n ch.addEventListener(\"characteristicvaluechanged\", (e: any) => {\n const v: DataView = e.target.value;\n if (uuid.includes(\"2a9d\")) onWeight(parseWeight(v), \"стандарт\");\n else log(`весы ${uuid.slice(4, 8)}: ${hex(v)}`);\n });\n } catch { /* не подписалось */ }\n }\n }\n log(\"готово — встань на весы и дождись цифры на экране весов\");\n } catch (e: any) {\n log(`весы: ${e.message || e}`);\n }\n}\n\n// ── накопление ───────────────────────────────────────────────────────────────\n\nlet lastAdv = performance.now();\nlet hasDeviceDistance = false;\nlet prevDev: number | null = null;\n\n// Дорожка шлёт метры целыми числами раз в несколько секунд — как якорь, не как счётчик.\nlet devTotal = 0;\n\nfunction onDeviceDistance(d: number) {\n hasDeviceDistance = true;\n if (prevDev === null || d < prevDev) { prevDev = d; return; } // первый пакет или сброс\n const delta = d - prevDev;\n prevDev = d;\n if (delta > 0 && delta < 500) devTotal += delta;\n}\n\nfunction advance() {\n const now = performance.now();\n let dt = (now - lastAdv) / 1000;\n lastAdv = now;\n if (dt > 3) dt = 3;\n\n // молчит больше 5 секунд — считаем, что стоим\n if (lastPacketAt && now - lastPacketAt > 5000) s.speedKmh = 0;\n\n // Основной счёт — от скорости: она приходит каждую секунду, поэтому цифры бегут ровно.\n if (s.speedKmh > 0.2) {\n s.movingS += dt;\n distReal += (s.speedKmh / 3.6) * dt;\n }\n\n // Якорь от дорожки только подталкивает вперёд и никогда не тормозит:\n // её метры приходят с запозданием, и торможение назад съедало рост счётчика.\n if (hasDeviceDistance && devTotal > distReal) {\n const drift = devTotal - distReal;\n if (drift > 50) distReal = devTotal;\n else distReal += drift * Math.min(1, dt * 0.5);\n }\n\n // Показываемая цифра догоняет расчётную. Скорость догона зависит от времени,\n // а не от числа вызовов, иначе темп плавает вместе с частотой пакетов.\n const diff = distReal - s.distanceM;\n if (diff > 30) s.distanceM = distReal;\n else if (diff > 0) s.distanceM += diff * Math.min(1, dt * 4);\n\n s.steps = s.distanceM / num(\"stride\", 0.7);\n}\n\n// ── разбор ───────────────────────────────────────────────────────────────────\n\nlet ftmsSeen = 0;\n\nfunction parseFtms(v: DataView) {\n if (ftmsSeen < 5) { log(`FTMS: ${hex(v)}`); ftmsSeen++; }\n const flags = v.getUint16(0, true);\n let i = 2;\n if (!(flags & 0x01)) { s.speedKmh = v.getUint16(i, true) / 100; i += 2; }\n if (flags & 0x02) i += 2;\n if (flags & 0x04 && v.byteLength >= i + 3) {\n onDeviceDistance(v.getUint8(i) | (v.getUint8(i + 1) << 8) | (v.getUint8(i + 2) << 16));\n }\n s.source = \"FTMS\";\n}\n\nfunction parseRsc(v: DataView) {\n const flags = v.getUint8(0);\n s.speedKmh = (v.getUint16(1, true) / 256) * 3.6;\n if (flags & 0x04 && v.byteLength >= (flags & 0x01 ? 10 : 8)) {\n onDeviceDistance(v.getUint32(flags & 0x01 ? 6 : 4, true) / 10);\n }\n s.source = \"RSC\";\n}\n\n// ── отрисовка ────────────────────────────────────────────────────────────────\n\nfunction fmtTime(sec: number) {\n const m = Math.floor(sec / 60);\n const ss = Math.floor(sec % 60);\n if (m < 60) return `${m}:${String(ss).padStart(2, \"0\")}`;\n return `${Math.floor(m / 60)}:${String(m % 60).padStart(2, \"0\")}:${String(ss).padStart(2, \"0\")}`;\n}\n\nfunction render() {\n const goal = num(\"goal\", 10000);\n const weight = num(\"weight\", 80);\n const live = isConnected() || demoTimer !== null;\n const moving = s.speedKmh > 0.2;\n\n $(\"steps\").textContent = Math.round(s.steps).toLocaleString(\"ru-RU\");\n $(\"speed\").textContent = s.speedKmh.toFixed(1);\n $(\"dist\").textContent = (s.distanceM / 1000).toFixed(2);\n $(\"time\").textContent = fmtTime(s.movingS);\n\n const met = moving ? Math.max(2, 1.2 + s.speedKmh * 0.55) : 0;\n $(\"kcal\").textContent = Math.round(met * weight * (s.movingS / 3600)).toString();\n\n ($(\"goalBar\") as HTMLElement).style.width = Math.min(100, (s.steps / goal) * 100) + \"%\";\n $(\"stepsSub\").textContent = s.steps >= goal\n ? `цель ${goal.toLocaleString(\"ru-RU\")} взята`\n : `осталось ${Math.max(0, Math.round(goal - s.steps)).toLocaleString(\"ru-RU\")} до цели`;\n\n const dot = $(\"dot\");\n dot.classList.toggle(\"on\", live);\n dot.classList.toggle(\"walking\", moving);\n\n const silent = lastPacketAt ? Math.round((performance.now() - lastPacketAt) / 1000) : 0;\n $(\"state\").textContent = !device && demoTimer === null\n ? \"не подключено\"\n : !live\n ? \"связь потеряна, переподключаюсь\"\n : moving\n ? \"идёшь\"\n : silent > 5\n ? `тишина ${silent} с`\n : \"стоишь\";\n\n $(\"src\").textContent = device || demoTimer\n ? `${s.source || \"?\"} · пакетов: ${packets}`\n : \"\";\n\n if (mini) {\n mini.steps.textContent = Math.round(s.steps).toLocaleString(\"ru-RU\");\n mini.speed.textContent = s.speedKmh.toFixed(1);\n mini.dist.textContent = (s.distanceM / 1000).toFixed(2);\n mini.time.textContent = fmtTime(s.movingS);\n mini.dot.style.background = moving ? \"#3BE08F\" : live ? \"#8391A6\" : \"#B4453C\";\n }\n}\n\n// ── отправка итога в телеграм-бота ───────────────────────────────────────────\n\nconst BOT_STEPS = \"https://johnjackson--01a04520b5f67759b71de0d149881ac4.web.val.run/steps\";\nconst BOT_TOKEN_Q = \"van-walk-7fQ2xK9mLp\";\nlet lastSent = 0;\n\nasync function pushSteps() {\n if (Date.now() - lastSent < 60000) return;\n if (s.steps < 10) return;\n lastSent = Date.now();\n const u = `${BOT_STEPS}?token=${BOT_TOKEN_Q}` +\n `&steps=${Math.round(s.steps)}&m=${Math.round(s.distanceM)}&sec=${Math.round(s.movingS)}`;\n try {\n await fetch(u);\n } catch { /* нет сети — отправим на следующем круге */ }\n}\n\nlet ticks = 0;\nsetInterval(() => {\n advance();\n render();\n if (++ticks % 20 === 0) save();\n if (ticks % 100 === 0) pushSteps();\n}, 100);\n\n// ── мини-окно ────────────────────────────────────────────────────────────────\n\nlet mini: Record | null = null;\nlet miniWin: any = null;\n\nconst MINI_CSS = `\n body { margin:0; background:#0B0D11; color:#EDF1F7; font-family: system-ui, sans-serif;\n display:flex; flex-direction:column; align-items:center; justify-content:center;\n height:100vh; gap:2px; -webkit-font-smoothing:antialiased; }\n .top { display:flex; align-items:center; gap:7px; font-size:11px; letter-spacing:.16em;\n text-transform:uppercase; color:#8391A6; }\n .dot { width:8px; height:8px; border-radius:50%; background:#6B7688; }\n .big { font-size:clamp(44px, 22vw, 96px); font-weight:700; line-height:1;\n font-variant-numeric:tabular-nums; }\n .row { display:flex; gap:14px; font-size:13px; color:#8391A6; margin-top:6px;\n font-variant-numeric:tabular-nums; }\n .row b { color:#EDF1F7; font-weight:600; }\n`;\n\nasync function openMini() {\n const dpip = (window as any).documentPictureInPicture;\n if (!dpip) { alert(\"Плавающее окно есть только в Chrome.\"); return; }\n if (miniWin) { miniWin.close(); return; }\n\n miniWin = await dpip.requestWindow({ width: 300, height: 190 });\n const d = miniWin.document;\n const st = d.createElement(\"style\");\n st.textContent = MINI_CSS;\n d.head.appendChild(st);\n d.body.innerHTML = `\n

шаги

\n 0.0 км/ч\n 0.00 км\n 0:00\n

`;\n\n mini = {\n steps: d.getElementById(\"m-steps\"),\n speed: d.getElementById(\"m-speed\"),\n dist: d.getElementById(\"m-dist\"),\n time: d.getElementById(\"m-time\"),\n dot: d.getElementById(\"m-dot\"),\n };\n miniWin.addEventListener(\"pagehide\", () => { miniWin = null; mini = null; });\n render();\n}\n\n// ── демо ─────────────────────────────────────────────────────────────────────\n\nlet demoTimer: number | null = null;\nfunction demo() {\n if (demoTimer) {\n clearInterval(demoTimer);\n demoTimer = null;\n s.speedKmh = 0;\n render();\n return;\n }\n s.source = \"демо\";\n demoTimer = setInterval(() => {\n s.speedKmh = 3.6 + Math.sin(Date.now() / 9000) * 0.7;\n lastPacketAt = performance.now();\n }, 1000) as unknown as number;\n}\n\n// ── кнопки ───────────────────────────────────────────────────────────────────\n\n$(\"connect\").addEventListener(\"click\", pickDevice);\n$(\"demo\").addEventListener(\"click\", demo);\n$(\"mini\").addEventListener(\"click\", openMini);\n$(\"scale\").addEventListener(\"click\", pickScale);\n\n$(\"start\").addEventListener(\"click\", startBelt);\n$(\"stop\").addEventListener(\"click\", stopBelt);\n$(\"minus\").addEventListener(\"click\", () => setSpeed(target - speedStep));\n$(\"plus\").addEventListener(\"click\", () => setSpeed(target + speedStep));\n\n$(\"copy\").addEventListener(\"click\", async () => {\n const text = lines.join(\"\\n\") || \"пусто\";\n try {\n await navigator.clipboard.writeText(text);\n $(\"copy\").textContent = \"скопировано\";\n setTimeout(() => ($(\"copy\").textContent = \"Копировать лог\"), 1800);\n } catch {\n alert(text);\n }\n});\n\n$(\"reset\").addEventListener(\"click\", () => {\n s.distanceM = 0;\n s.movingS = 0;\n s.steps = 0;\n distReal = 0;\n devTotal = 0; // без этого якорь от дорожки возвращал всё обратно\n prevDev = null;\n save();\n render();\n log(\"сброшено\");\n});\n\nfor (const id of [\"stride\", \"goal\", \"weight\"]) {\n const el = $(id) as HTMLInputElement;\n const saved = localStorage.getItem(KEY + \":\" + id);\n if (saved) el.value = saved;\n el.addEventListener(\"change\", () => {\n localStorage.setItem(KEY + \":\" + id, el.value);\n render();\n });\n}\n\nrender();\n","// Лайв-трекер ходьбы. Читает дорожку по Web Bluetooth.\n// Состояние связи берём напрямую из GATT, разрыв — переподключаемся сами.\n\nconst $ = (id: string) => document.getElementById(id)!;\n\nconst FTMS = 0x1826;\nconst RSC = 0x1814;\nconst EXTRA_SERVICES = [0x180d, 0x180f, 0x181c, 0xfe00, 0xffe0, 0xfff0];\n\nconst DAY = () => new Date().toISOString().slice(0, 10);\nconst KEY = \"walk-live\";\n\ntype State = {\n speedKmh: number;\n distanceM: number;\n movingS: number;\n steps: number;\n source: string;\n};\n\nfunction load(): State {\n const empty: State = { speedKmh: 0, distanceM: 0, movingS: 0, steps: 0, source: \"\" };\n try {\n const raw = JSON.parse(localStorage.getItem(KEY) || \"{}\");\n if (raw.day === DAY()) return { ...empty, ...raw.state, speedKmh: 0 };\n } catch { /* пусто */ }\n return empty;\n}\n\nconst s = load();\nlet distReal = s.distanceM;\n\nfunction save() {\n try {\n localStorage.setItem(KEY, JSON.stringify({ day: DAY(), state: { ...s, speedKmh: 0 } }));\n } catch { /* приватный режим */ }\n}\n\nconst num = (id: string, fallback: number) => {\n const v = parseFloat(($(id) as HTMLInputElement).value);\n return Number.isFinite(v) ? v : fallback;\n};\n\n// ── журнал ───────────────────────────────────────────────────────────────────\n\nconst lines: string[] = [];\nfunction log(line: string) {\n lines.unshift(`${new Date().toLocaleTimeString(\"ru-RU\")} ${line}`);\n if (lines.length > 200) lines.pop();\n $(\"log\").textContent = lines.join(\"\\n\") || \"пусто\";\n}\n\nconst hex = (v: DataView) =>\n [...new Uint8Array(v.buffer)].map((b) => b.toString(16).padStart(2, \"0\")).join(\" \");\n\n// ── связь ────────────────────────────────────────────────────────────────────\n\nlet device: any = null;\nlet packets = 0;\nlet lastPacketAt = 0;\nlet reconnecting = false;\n\nconst isConnected = () => !!device?.gatt?.connected;\n\nasync function pickDevice() {\n const bt = (navigator as any).bluetooth;\n if (!bt) {\n alert(\"Web Bluetooth есть только в Chrome. Открой страницу там.\");\n return;\n }\n try {\n device = await bt.requestDevice({\n acceptAllDevices: true,\n optionalServices: [FTMS, RSC, ...EXTRA_SERVICES],\n });\n log(`устройство: ${device.name || \"без имени\"}`);\n\n device.addEventListener(\"gattserverdisconnected\", () => {\n log(\"связь разорвана, переподключаюсь…\");\n s.speedKmh = 0;\n prevDev = null;\n render();\n reconnect();\n });\n\n await attach();\n } catch (e: any) {\n log(`ошибка выбора: ${e.message || e}`);\n }\n}\n\nasync function attach() {\n const server = await device.gatt.connect();\n const services = await server.getPrimaryServices();\n log(`подключено, сервисов: ${services.length}`);\n\n let bound = 0;\n for (const svc of services) {\n const chars = await svc.getCharacteristics().catch(() => []);\n log(`сервис ${svc.uuid}`);\n for (const ch of chars) {\n const p = ch.properties;\n const props = [\n p.read && \"read\",\n p.write && \"write\",\n p.writeWithoutResponse && \"writeNR\",\n p.notify && \"notify\",\n ].filter(Boolean).join(\",\");\n log(` · ${ch.uuid} [${props}]`);\n\n // 2AD9 — пульт: старт/стоп/скорость\n if (ch.uuid.includes(\"2ad9\")) {\n ctlChar = ch;\n ($(\"ctl\") as HTMLElement).hidden = false;\n await ctlWrite([0x00], \"запрос управления\");\n }\n\n // 2AD4 — какие скорости дорожка вообще принимает\n if (ch.uuid.includes(\"2ad4\") && p.read) {\n try {\n const r = await ch.readValue();\n speedMin = r.getUint16(0, true) / 100;\n speedMax = r.getUint16(2, true) / 100;\n speedStep = Math.max(0.1, r.getUint16(4, true) / 100);\n target = Math.min(Math.max(target, speedMin), speedMax);\n $(\"range\").textContent =\n `диапазон ${speedMin.toFixed(1)}–${speedMax.toFixed(1)} км/ч, шаг ${speedStep.toFixed(1)}`;\n renderCtl();\n } catch { /* не прочиталось */ }\n }\n\n if (!p.notify) continue;\n try {\n await ch.startNotifications();\n bound++;\n const uuid = ch.uuid;\n ch.addEventListener(\"characteristicvaluechanged\", (e: any) => {\n const v: DataView = e.target.value;\n packets++;\n lastPacketAt = performance.now();\n if (uuid.includes(\"2acd\")) parseFtms(v);\n else if (uuid.includes(\"2a53\")) parseRsc(v);\n else if (packets < 40) log(`${uuid.slice(4, 8)}: ${hex(v)}`);\n advance();\n render();\n });\n } catch { /* не даёт подписаться */ }\n }\n }\n\n if (!bound) log(\"нет каналов с уведомлениями — данные не придут\");\n lastAdv = performance.now();\n render();\n}\n\nasync function reconnect() {\n if (reconnecting || !device) return;\n reconnecting = true;\n for (let i = 1; i <= 20; i++) {\n await new Promise((r) => setTimeout(r, 3000));\n if (isConnected()) break;\n try {\n await attach();\n log(\"переподключился\");\n break;\n } catch {\n log(`попытка ${i} не удалась`);\n }\n }\n reconnecting = false;\n}\n\n// ── пульт (FTMS Control Point, 2AD9) ─────────────────────────────────────────\n\nlet ctlChar: any = null;\nlet speedMin = 0.5;\nlet speedMax = 6;\nlet speedStep = 0.1;\nlet target = 2;\n\nasync function ctlWrite(bytes: number[], what = \"\") {\n if (!ctlChar) return;\n try {\n const buf = new Uint8Array(bytes);\n if (ctlChar.writeValueWithResponse) await ctlChar.writeValueWithResponse(buf);\n else await ctlChar.writeValue(buf);\n log(`→ ${what || bytes.map((b) => b.toString(16).padStart(2, \"0\")).join(\" \")}`);\n } catch (e: any) {\n log(`команда не прошла: ${e.message || e}`);\n }\n}\n\nconst startBelt = () => ctlWrite([0x07], \"старт\");\nconst stopBelt = () => ctlWrite([0x08, 0x01], \"стоп\");\n\nasync function setSpeed(kmh: number) {\n target = Math.min(speedMax, Math.max(speedMin, Math.round(kmh * 10) / 10));\n const v = Math.round(target * 100);\n await ctlWrite([0x02, v & 0xff, (v >> 8) & 0xff], `скорость ${target.toFixed(1)}`);\n renderCtl();\n}\n\nfunction renderCtl() {\n $(\"target\").textContent = target.toFixed(1);\n}\n\n// ── весы ─────────────────────────────────────────────────────────────────────\n\n// Браузер показывает только те сервисы, которые заявлены заранее.\n// Поэтому перечисляем всё, на чём делают бытовые весы.\nconst SCALE_SERVICES = [\n 0x181d, // Weight Scale — стандарт\n 0x181b, // Body Composition — стандарт\n 0x180f, 0x180a, 0x1800, 0x1801,\n 0xfff0, 0xffe0, 0xffb0, 0xffe5, 0xfee0, 0xfee7, 0xfe95, 0x1910,\n \"0000fff0-0000-1000-8000-00805f9b34fb\",\n \"0000ffb0-0000-1000-8000-00805f9b34fb\",\n \"0000ffe0-0000-1000-8000-00805f9b34fb\",\n \"0000fee0-0000-1000-8000-00805f9b34fb\",\n \"0000face-0000-1000-8000-00805f9b34fb\",\n \"0000fff1-0000-1000-8000-00805f9b34fb\",\n \"0000ffc0-0000-1000-8000-00805f9b34fb\",\n];\n\nlet scaleDev: any = null;\nlet lastKg = 0;\n\n// Стандартный Weight Measurement (0x2A9D)\nfunction parseWeight(v: DataView) {\n const flags = v.getUint8(0);\n const raw = v.getUint16(1, true);\n const kg = flags & 0x01 ? raw * 0.01 * 0.4536 : raw * 0.005;\n return kg;\n}\n\nfunction onWeight(kg: number, source: string) {\n if (kg < 20 || kg > 250) return;\n lastKg = kg;\n log(`⚖️ ВЕС: ${kg.toFixed(1)} кг (${source})`);\n $(\"state\").textContent = `вес ${kg.toFixed(1)} кг`;\n}\n\nasync function pickScale() {\n const bt = (navigator as any).bluetooth;\n if (!bt) { alert(\"Нужен Chrome.\"); return; }\n\n try {\n log(\"выбор весов… встань на них сейчас\");\n scaleDev = await bt.requestDevice({\n acceptAllDevices: true,\n optionalServices: SCALE_SERVICES,\n });\n log(`весы: ${scaleDev.name || \"без имени\"}`);\n\n scaleDev.addEventListener(\"gattserverdisconnected\", () => log(\"весы отключились\"));\n\n // Весы спят и просыпаются на несколько секунд.\n // Chrome не умеет отваливаться по таймауту сам — ставим свой и долбимся.\n const withTimeout = (p: any, ms: number) =>\n Promise.race([\n p,\n new Promise((_, rej) => setTimeout(() => rej(new Error(\"таймаут\")), ms)),\n ]);\n\n let server: any = null;\n for (let i = 1; i <= 10; i++) {\n log(`подключаюсь, попытка ${i} — стой на весах`);\n try {\n server = await withTimeout(scaleDev.gatt.connect(), 5000);\n break;\n } catch (e: any) {\n log(` ${e.message || e}`);\n try { scaleDev.gatt.disconnect(); } catch { /* уже отвалилось */ }\n await new Promise((r) => setTimeout(r, 1200));\n }\n }\n\n if (!server) {\n log(\"не достучался. Наступи на весы и сразу жми ⚖️ Весы заново\");\n return;\n }\n\n const services = await withTimeout(server.getPrimaryServices(), 5000) as any[];\n log(`весы подключены, сервисов: ${services.length}`);\n\n if (!services.length) {\n log(\"сервисов нет — весы шлют вес только в эфир, браузер такое не читает\");\n return;\n }\n\n for (const svc of services) {\n log(`сервис весов ${svc.uuid}`);\n const chars = await svc.getCharacteristics().catch(() => []);\n for (const ch of chars) {\n const p = ch.properties;\n log(` · ${ch.uuid} [${[\n p.read && \"read\",\n p.write && \"write\",\n p.writeWithoutResponse && \"writeNR\",\n p.notify && \"notify\",\n p.indicate && \"indicate\",\n ].filter(Boolean).join(\",\")}]`);\n\n if (!p.notify && !p.indicate) continue;\n try {\n await ch.startNotifications();\n const uuid = ch.uuid;\n ch.addEventListener(\"characteristicvaluechanged\", (e: any) => {\n const v: DataView = e.target.value;\n if (uuid.includes(\"2a9d\")) onWeight(parseWeight(v), \"стандарт\");\n else log(`весы ${uuid.slice(4, 8)}: ${hex(v)}`);\n });\n } catch { /* не подписалось */ }\n }\n }\n log(\"готово — встань на весы и дождись цифры на экране весов\");\n } catch (e: any) {\n log(`весы: ${e.message || e}`);\n }\n}\n\n// ── накопление ───────────────────────────────────────────────────────────────\n\nlet lastAdv = performance.now();\nlet hasDeviceDistance = false;\nlet prevDev: number | null = null;\n\n// Дорожка шлёт метры целыми числами раз в несколько секунд — как якорь, не как счётчик.\nlet devTotal = 0;\n\nfunction onDeviceDistance(d: number) {\n hasDeviceDistance = true;\n if (prevDev === null || d < prevDev) { prevDev = d; return; } // первый пакет или сброс\n const delta = d - prevDev;\n prevDev = d;\n if (delta > 0 && delta < 500) devTotal += delta;\n}\n\nfunction advance() {\n const now = performance.now();\n let dt = (now - lastAdv) / 1000;\n lastAdv = now;\n if (dt > 3) dt = 3;\n\n // молчит больше 5 секунд — считаем, что стоим\n if (lastPacketAt && now - lastPacketAt > 5000) s.speedKmh = 0;\n\n // Основной счёт — от скорости: она приходит каждую секунду, поэтому цифры бегут ровно.\n if (s.speedKmh > 0.2) {\n s.movingS += dt;\n distReal += (s.speedKmh / 3.6) * dt;\n }\n\n // Якорь от дорожки только подталкивает вперёд и никогда не тормозит:\n // её метры приходят с запозданием, и торможение назад съедало рост счётчика.\n if (hasDeviceDistance && devTotal > distReal) {\n const drift = devTotal - distReal;\n if (drift > 50) distReal = devTotal;\n else distReal += drift * Math.min(1, dt * 0.5);\n }\n\n // Показываемая цифра догоняет расчётную. Скорость догона зависит от времени,\n // а не от числа вызовов, иначе темп плавает вместе с частотой пакетов.\n const diff = distReal - s.distanceM;\n if (diff > 30) s.distanceM = distReal;\n else if (diff > 0) s.distanceM += diff * Math.min(1, dt * 4);\n\n s.steps = s.distanceM / num(\"stride\", 0.7);\n}\n\n// ── разбор ───────────────────────────────────────────────────────────────────\n\nlet ftmsSeen = 0;\n\nfunction parseFtms(v: DataView) {\n if (ftmsSeen < 5) { log(`FTMS: ${hex(v)}`); ftmsSeen++; }\n const flags = v.getUint16(0, true);\n let i = 2;\n if (!(flags & 0x01)) { s.speedKmh = v.getUint16(i, true) / 100; i += 2; }\n if (flags & 0x02) i += 2;\n if (flags & 0x04 && v.byteLength >= i + 3) {\n onDeviceDistance(v.getUint8(i) | (v.getUint8(i + 1) << 8) | (v.getUint8(i + 2) << 16));\n }\n s.source = \"FTMS\";\n}\n\nfunction parseRsc(v: DataView) {\n const flags = v.getUint8(0);\n s.speedKmh = (v.getUint16(1, true) / 256) * 3.6;\n if (flags & 0x04 && v.byteLength >= (flags & 0x01 ? 10 : 8)) {\n onDeviceDistance(v.getUint32(flags & 0x01 ? 6 : 4, true) / 10);\n }\n s.source = \"RSC\";\n}\n\n// ── отрисовка ────────────────────────────────────────────────────────────────\n\nfunction fmtTime(sec: number) {\n const m = Math.floor(sec / 60);\n const ss = Math.floor(sec % 60);\n if (m < 60) return `${m}:${String(ss).padStart(2, \"0\")}`;\n return `${Math.floor(m / 60)}:${String(m % 60).padStart(2, \"0\")}:${String(ss).padStart(2, \"0\")}`;\n}\n\nfunction render() {\n const goal = num(\"goal\", 10000);\n const weight = num(\"weight\", 80);\n const live = isConnected() || demoTimer !== null;\n const moving = s.speedKmh > 0.2;\n\n $(\"steps\").textContent = Math.round(s.steps).toLocaleString(\"ru-RU\");\n $(\"speed\").textContent = s.speedKmh.toFixed(1);\n $(\"dist\").textContent = (s.distanceM / 1000).toFixed(2);\n $(\"time\").textContent = fmtTime(s.movingS);\n\n const met = moving ? Math.max(2, 1.2 + s.speedKmh * 0.55) : 0;\n $(\"kcal\").textContent = Math.round(met * weight * (s.movingS / 3600)).toString();\n\n ($(\"goalBar\") as HTMLElement).style.width = Math.min(100, (s.steps / goal) * 100) + \"%\";\n $(\"stepsSub\").textContent = s.steps >= goal\n ? `цель ${goal.toLocaleString(\"ru-RU\")} взята`\n : `осталось ${Math.max(0, Math.round(goal - s.steps)).toLocaleString(\"ru-RU\")} до цели`;\n\n const dot = $(\"dot\");\n dot.classList.toggle(\"on\", live);\n dot.classList.toggle(\"walking\", moving);\n\n const silent = lastPacketAt ? Math.round((performance.now() - lastPacketAt) / 1000) : 0;\n $(\"state\").textContent = !device && demoTimer === null\n ? \"не подключено\"\n : !live\n ? \"связь потеряна, переподключаюсь\"\n : moving\n ? \"идёшь\"\n : silent > 5\n ? `тишина ${silent} с`\n : \"стоишь\";\n\n $(\"src\").textContent = device || demoTimer\n ? `${s.source || \"?\"} · пакетов: ${packets}`\n : \"\";\n\n if (mini) {\n mini.steps.textContent = Math.round(s.steps).toLocaleString(\"ru-RU\");\n mini.speed.textContent = s.speedKmh.toFixed(1);\n mini.dist.textContent = (s.distanceM / 1000).toFixed(2);\n mini.time.textContent = fmtTime(s.movingS);\n mini.dot.style.background = moving ? \"#3BE08F\" : live ? \"#8391A6\" : \"#B4453C\";\n }\n}\n\n// ── отправка итога в телеграм-бота ───────────────────────────────────────────\n\nconst BOT_STEPS = \"https://johnjackson--01a04520b5f67759b71de0d149881ac4.web.val.run/steps\";\nconst BOT_TOKEN_Q = \"van-walk-7fQ2xK9mLp\";\nlet lastSent = 0;\n\nasync function pushSteps() {\n if (Date.now() - lastSent < 60000) return;\n if (s.steps < 10) return;\n lastSent = Date.now();\n const u = `${BOT_STEPS}?token=${BOT_TOKEN_Q}` +\n `&steps=${Math.round(s.steps)}&m=${Math.round(s.distanceM)}&sec=${Math.round(s.movingS)}`;\n try {\n await fetch(u);\n } catch { /* нет сети — отправим на следующем круге */ }\n}\n\nlet ticks = 0;\nsetInterval(() => {\n advance();\n render();\n if (++ticks % 20 === 0) save();\n if (ticks % 100 === 0) pushSteps();\n}, 100);\n\n// ── мини-окно ────────────────────────────────────────────────────────────────\n\nlet mini: Record | null = null;\nlet miniWin: any = null;\n\nconst MINI_CSS = `\n body { margin:0; background:#0B0D11; color:#EDF1F7; font-family: system-ui, sans-serif;\n display:flex; flex-direction:column; align-items:center; justify-content:center;\n height:100vh; gap:2px; -webkit-font-smoothing:antialiased; }\n .top { display:flex; align-items:center; gap:7px; font-size:11px; letter-spacing:.16em;\n text-transform:uppercase; color:#8391A6; }\n .dot { width:8px; height:8px; border-radius:50%; background:#6B7688; }\n .big { font-size:clamp(44px, 22vw, 96px); font-weight:700; line-height:1;\n font-variant-numeric:tabular-nums; }\n .row { display:flex; gap:14px; font-size:13px; color:#8391A6; margin-top:6px;\n font-variant-numeric:tabular-nums; }\n .row b { color:#EDF1F7; font-weight:600; }\n`;\n\nasync function openMini() {\n const dpip = (window as any).documentPictureInPicture;\n if (!dpip) { alert(\"Плавающее окно есть только в Chrome.\"); return; }\n if (miniWin) { miniWin.close(); return; }\n\n miniWin = await dpip.requestWindow({ width: 300, height: 190 });\n const d = miniWin.document;\n const st = d.createElement(\"style\");\n st.textContent = MINI_CSS;\n d.head.appendChild(st);\n d.body.innerHTML = `\n

шаги

\n 0.0 км/ч\n 0.00 км\n 0:00\n

\n Ходьба · лайв\n

не подключено

\n \n \n \n \n

\n\n

шагов сегодня

цель 10 000

\n\n \n\n

скорость

0.0км/ч

дистанция

0.00км

в движении

0:00

ккал

\n\n \n\n \n\n`;\n\nexport default async function (req: Request): Promise {\n const path = new URL(req.url).pathname;\n if (path === \"/client.ts\") return serveFile(\"/client.ts\", import.meta.url);\n return new Response(HTML, { headers: { \"content-type\": \"text/html; charset=utf-8\" } });\n}\n","label","van-walk",[131],"801b3bf0-3aec-4657-ad69-2b76f3b7db80",["D",1789325046055],19,[28],"pulls","branches",1,"forks","envVars",{"_154":63,"_156":63},"connections",{"_154":63,"_155":63},"count","unfilledCount","emptyCount",{"_43":142,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_134":25,"_38":163,"_13":144,"_33":34,"_35":37,"_24":25,"_139":-5,"_160":164,"_27":165},{"_43":130,"_32":131,"_30":57,"_132":-5,"_41":42,"_40":133,"_134":59,"_38":159,"_13":136,"_33":137,"_35":138,"_24":25,"_139":140,"_160":161,"_27":162},["D",1789324791574],"children",[],[131],["D",1789325046055],[],[28],["D",1788016699715],{"_97":96,"_105":101},{"_97":96,"_98":99,"_100":101,"_18":55,"_102":103,"_104":25},{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_79":-5,"_125":203,"_204":205,"_206":207,"_208":25,"_209":25,"_210":25,"_211":59,"_212":-5,"_213":-7,"_214":-7,"_215":63,"_216":25,"_217":25,"_218":-5,"_219":25,"_220":25,"_221":25,"_222":-5},"ENV",{"_174":175,"_176":177,"_178":87,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v27