Compare commits

...
4 Commits
Author SHA1 Message Date
mates 364d46bc18 fix: oprava zobrazení ikonky o zaplacení u historických objednávek
CI / Generate TypeScript types (push) Successful in 21s
CI / Server unit tests (push) Successful in 22s
CI / Build server (push) Successful in 35s
CI / Build client (push) Successful in 36s
CI / Playwright E2E tests (push) Successful in 1m18s
CI / Build and push Docker image (push) Successful in 40s
CI / Notify (push) Successful in 2s
2026-06-12 21:55:25 +02:00
mates 8c3c47dba1 Opravy UI na stránkách objednání 2026-06-12 21:07:19 +02:00
mates 34f6ba520e feat: podpora simulace objednávek z Bolt Food ve vývoji 2026-06-12 19:44:20 +02:00
mates bcec015c37 feat: skript pro import dat z Redis databáze 2026-06-12 19:19:36 +02:00
18 changed files with 865 additions and 16 deletions
+4 -3
View File
@@ -7,7 +7,7 @@
position: relative; position: relative;
display: flex; display: flex;
flex-direction: column; flex-direction: column;
align-items: center; align-items: flex-start;
flex: 1; flex: 1;
min-width: 64px; min-width: 64px;
@@ -27,12 +27,13 @@
white-space: nowrap; white-space: nowrap;
} }
// Spojnice k předchozímu kroku // Spojnice k předchozímu kroku vede od středu této tečky doleva ke středu předchozí.
// Tečka má průměr 12px, takže její střed je 6px od levého okraje segmentu.
&:not(:first-child)::before { &:not(:first-child)::before {
content: ''; content: '';
position: absolute; position: absolute;
top: 5px; top: 5px;
right: 50%; left: calc(6px - 100%);
width: 100%; width: 100%;
height: 2px; height: 2px;
background: var(--luncher-border, #ced4da); background: var(--luncher-border, #ced4da);
@@ -0,0 +1,170 @@
import { useState } from "react";
import { Modal, Button, Form, Alert, Badge } from "react-bootstrap";
import {
OrderGroup,
simulateBoltTracking, advanceBoltTracking, setBoltTrackingState,
pollBoltTracking, stopBoltTrackingSimulation,
} from "../../../../types";
type Props = {
isOpen: boolean;
onClose: () => void;
group: OrderGroup;
};
/** Nabídka stavů pro ruční nastavení (odpovídá mapování v BoltOrderProgress). */
const STATE_OPTIONS: { value: string; label: string }[] = [
{ value: 'accepted', label: 'Přijato' },
{ value: 'preparing', label: 'Příprava' },
{ value: 'waiting_delivery', label: 'Příprava (čeká na vyzvednutí)' },
{ value: 'in_delivery', label: 'Na cestě' },
{ value: 'delivered', label: 'Doručeno' },
{ value: 'cancelled', label: 'Zrušeno' },
];
/** Modální dialog pro simulaci sledování Bolt objednávky (pouze DEV). */
export default function BoltSimulationModal({ isOpen, onClose, group }: Readonly<Props>) {
const [loading, setLoading] = useState(false);
const [error, setError] = useState<string | null>(null);
const [info, setInfo] = useState<string | null>(null);
const [manualState, setManualState] = useState<string>('preparing');
const running = !!group.boltTrackingToken;
/** Obecný runner — spustí akci, ošetří chybu a krátce zobrazí výsledek. */
const run = async (action: () => Promise<{ error?: unknown }>, okMsg: string) => {
setError(null);
setInfo(null);
setLoading(true);
try {
const response = await action();
if (response.error) {
setError((response.error as any)?.error || 'Akce simulace selhala');
} else {
setInfo(okMsg);
}
} catch (e: any) {
setError(e?.message || 'Akce simulace selhala');
} finally {
setLoading(false);
}
};
const handleStart = () => run(
() => simulateBoltTracking({ body: { groupId: group.id } }),
'Simulace spuštěna — objednávka přijata.',
);
const handleAdvance = () => run(
() => advanceBoltTracking({ body: { groupId: group.id } }),
'Posunuto na další krok.',
);
const handleSetState = () => run(
() => setBoltTrackingState({
body: {
groupId: group.id,
order_state: manualState,
// "Na cestě" zpřesníme i stavem kurýra
courier_state: manualState === 'in_delivery' ? 'heading_to_client' : undefined,
},
}),
`Stav nastaven na „${STATE_OPTIONS.find(o => o.value === manualState)?.label}".`,
);
const handlePoll = () => run(
() => pollBoltTracking(),
'Scheduler spuštěn (poll proběhl).',
);
const handleStop = () => run(
() => stopBoltTrackingSimulation({ body: { groupId: group.id } }),
'Simulace ukončena.',
);
const handleClose = () => {
setError(null);
setInfo(null);
onClose();
};
return (
<Modal show={isOpen} onHide={handleClose}>
<Modal.Header closeButton>
<Modal.Title><h2>Simulace sledování Bolt</h2></Modal.Title>
</Modal.Header>
<Modal.Body>
<Alert variant="warning">
<strong>DEV režim</strong> simuluje sledování objednávky Bolt pro skupinu{' '}
<strong>{group.name}</strong> bez reálné objednávky.
</Alert>
{error && (
<Alert variant="danger" onClose={() => setError(null)} dismissible>
{error}
</Alert>
)}
{info && (
<Alert variant="success" onClose={() => setInfo(null)} dismissible>
{info}
</Alert>
)}
<p className="mb-2">
Stav simulace:{' '}
{running
? <Badge bg="success">běží{group.boltOrderState ? `${group.boltOrderState}` : ''}</Badge>
: <Badge bg="secondary">neběží</Badge>}
</p>
{!running ? (
<p className="text-muted">
Spuštěním se skupina přepne do stavu Objednáno", přiřadí se simulovaný
sledovací token a provede se první poll (stav „Přijato").
</p>
) : (
<>
<p className="text-muted">
Krokuj objednávku tlačítkem <strong>Další krok</strong> (Přijato Příprava
Na cestě Doručeno) nebo nastav konkrétní stav ručně:
</p>
<Form.Group className="mb-3 d-flex gap-2 align-items-end">
<div className="flex-grow-1">
<Form.Label>Konkrétní stav</Form.Label>
<Form.Select
value={manualState}
onChange={e => setManualState(e.target.value)}
>
{STATE_OPTIONS.map(o => (
<option key={o.value} value={o.value}>{o.label}</option>
))}
</Form.Select>
</div>
<Button variant="outline-primary" onClick={handleSetState} disabled={loading}>
Nastavit
</Button>
</Form.Group>
</>
)}
</Modal.Body>
<Modal.Footer className="d-flex flex-wrap gap-2">
{!running ? (
<Button variant="primary" onClick={handleStart} disabled={loading}>
{loading ? 'Spouštím…' : 'Spustit simulaci'}
</Button>
) : (
<>
<Button variant="success" onClick={handleAdvance} disabled={loading}>
Další krok
</Button>
<Button variant="outline-secondary" onClick={handlePoll} disabled={loading}>
Aktualizovat teď
</Button>
<Button variant="outline-danger" onClick={handleStop} disabled={loading}>
Ukončit simulaci
</Button>
</>
)}
<Button variant="secondary" onClick={handleClose} disabled={loading}>
Zavřít
</Button>
</Modal.Footer>
</Modal>
);
}
+25 -6
View File
@@ -22,6 +22,7 @@ import Loader from '../components/Loader';
import StoreAdminModal from '../components/modals/StoreAdminModal'; import StoreAdminModal from '../components/modals/StoreAdminModal';
import PayForGroupModal from '../components/modals/PayForGroupModal'; import PayForGroupModal from '../components/modals/PayForGroupModal';
import EditGroupFeesModal from '../components/modals/EditGroupFeesModal'; import EditGroupFeesModal from '../components/modals/EditGroupFeesModal';
import BoltSimulationModal from '../components/modals/BoltSimulationModal';
import PendingPayments from '../components/PendingPayments'; import PendingPayments from '../components/PendingPayments';
import BoltOrderProgress from '../components/BoltOrderProgress'; import BoltOrderProgress from '../components/BoltOrderProgress';
@@ -29,6 +30,7 @@ const SLOT = MealSlot.EXTRA;
const TIME_REGEX = /^([01]\d|2[0-3]):[0-5]\d$/; const TIME_REGEX = /^([01]\d|2[0-3]):[0-5]\d$/;
const BOLT_SHARE_URL_PREFIX = 'https://food.bolt.eu/sharedActiveOrder/'; const BOLT_SHARE_URL_PREFIX = 'https://food.bolt.eu/sharedActiveOrder/';
const BOLT_TOKEN_REGEX = /^[0-9a-f]{64}$/i; const BOLT_TOKEN_REGEX = /^[0-9a-f]{64}$/i;
const IS_DEV = process.env.NODE_ENV === 'development';
/** Vytáhne sledovací token ze sdílecí URL Bolt Food, nebo přijme samotný token. Null = neplatný vstup. */ /** Vytáhne sledovací token ze sdílecí URL Bolt Food, nebo přijme samotný token. Null = neplatný vstup. */
function extractBoltToken(input: string): string | null { function extractBoltToken(input: string): string | null {
@@ -100,6 +102,7 @@ export default function OrderGroupsPage() {
const [editTimes, setEditTimes] = useState<Record<string, { orderedAt: string; deliveryAt: string; boltUrl: string }>>({}); const [editTimes, setEditTimes] = useState<Record<string, { orderedAt: string; deliveryAt: string; boltUrl: string }>>({});
const [payModal, setPayModal] = useState<OrderGroup | null>(null); const [payModal, setPayModal] = useState<OrderGroup | null>(null);
const [feesModal, setFeesModal] = useState<OrderGroup | null>(null); const [feesModal, setFeesModal] = useState<OrderGroup | null>(null);
const [boltSimModal, setBoltSimModal] = useState<OrderGroup | null>(null);
const [confirmOrderGroup, setConfirmOrderGroup] = useState<OrderGroup | null>(null); const [confirmOrderGroup, setConfirmOrderGroup] = useState<OrderGroup | null>(null);
const [pageError, setPageError] = useState<string | null>(null); const [pageError, setPageError] = useState<string | null>(null);
@@ -355,8 +358,9 @@ export default function OrderGroupsPage() {
<div className="wrapper"> <div className="wrapper">
<div className="d-flex align-items-center justify-content-between mb-1"> <div className="d-flex align-items-center justify-content-between mb-1">
<h1 className="title mb-0">Objednání</h1> <h1 className="title mb-0">Objednání</h1>
<Button variant="outline-secondary" size="sm" onClick={() => setAdminModalOpen(true)} title="Správa obchodů"> <Button variant="outline-primary" size="sm" onClick={() => setAdminModalOpen(true)} title="Správa obchodů">
<FontAwesomeIcon icon={faGear} /> <FontAwesomeIcon icon={faGear} className="me-1" />
Obchody
</Button> </Button>
</div> </div>
<p style={{ color: 'var(--luncher-text-muted)' }}>Skupinové objednávky z obchodů a restaurací</p> <p style={{ color: 'var(--luncher-text-muted)' }}>Skupinové objednávky z obchodů a restaurací</p>
@@ -418,7 +422,7 @@ export default function OrderGroupsPage() {
</Button> </Button>
</p> </p>
) : ( ) : (
<div className="d-flex gap-2 align-items-end flex-wrap"> <div className="d-flex gap-2 align-items-center flex-wrap">
<Form.Select <Form.Select
value={newGroupName} value={newGroupName}
onChange={e => setNewGroupName(e.target.value)} onChange={e => setNewGroupName(e.target.value)}
@@ -646,8 +650,8 @@ export default function OrderGroupsPage() {
{memberTotal > 0 ? `${memberTotal / 100}` : '—'} {memberTotal > 0 ? `${memberTotal / 100}` : '—'}
</small> </small>
</td> </td>
<td> <td className="align-middle">
<div className="d-flex gap-1 justify-content-end"> <div className="d-flex gap-1 justify-content-end align-items-center">
{canManageMembers(group) && (isCreator || memberLogin === login) && (memberLogin !== group.creatorLogin) && ( {canManageMembers(group) && (isCreator || memberLogin === login) && (memberLogin !== group.creatorLogin) && (
<FontAwesomeIcon <FontAwesomeIcon
icon={faTrashCan} icon={faTrashCan}
@@ -753,7 +757,7 @@ export default function OrderGroupsPage() {
{canEdit && ( {canEdit && (
<FontAwesomeIcon <FontAwesomeIcon
icon={faPen} icon={faPen}
className="action-icon" className="action-icon ms-0"
title="Upravit časy a odkaz pro sledování" title="Upravit časy a odkaz pro sledování"
onClick={startEdit} onClick={startEdit}
/> />
@@ -803,6 +807,13 @@ export default function OrderGroupsPage() {
<BoltOrderProgress state={group.boltOrderState} courierState={group.boltCourierState} tracking={!!group.boltTrackingToken} /> <BoltOrderProgress state={group.boltOrderState} courierState={group.boltCourierState} tracking={!!group.boltTrackingToken} />
</div> </div>
)} )}
{IS_DEV && (
<div className="mt-2">
<Button variant="outline-warning" size="sm" onClick={() => setBoltSimModal(group)} title="Simulovat sledování Bolt (DEV)">
🔧 Simulace Bolt
</Button>
</div>
)}
</div> </div>
)} )}
</Card.Body> </Card.Body>
@@ -874,6 +885,14 @@ export default function OrderGroupsPage() {
}} }}
/> />
)} )}
{IS_DEV && boltSimModal && (
<BoltSimulationModal
isOpen={!!boltSimModal}
onClose={() => setBoltSimModal(null)}
// živá skupina z dat (aktualizuje se přes websocket), fallback na snapshot
group={groups.find(g => g.id === boltSimModal.id) ?? boltSimModal}
/>
)}
</div> </div>
); );
} }
+4
View File
@@ -52,3 +52,7 @@
# Admin heslo pro správu seznamu obchodů na stránce /objednani. # Admin heslo pro správu seznamu obchodů na stránce /objednani.
# Bez hesla nelze přidávat ani odebírat obchody ze seznamu (POST/DELETE na /api/stores vrátí 403). # Bez hesla nelze přidávat ani odebírat obchody ze seznamu (POST/DELETE na /api/stores vrátí 403).
# ADMIN_PASSWORD= # ADMIN_PASSWORD=
# Interval (ms) scheduleru sledování objednávek Bolt Food. Výchozí 60000 (60 s).
# Pro vývoj se simulací lze zkrátit (min. 1000), aby se změny stavu projevily rychleji.
# BOLT_POLL_INTERVAL_MS=3000
+2 -1
View File
@@ -8,7 +8,8 @@
"start": "ts-node src/index.ts", "start": "ts-node src/index.ts",
"startReload": "nodemon --watch src src/index.ts", "startReload": "nodemon --watch src src/index.ts",
"build": "tsc -p .", "build": "tsc -p .",
"test": "jest" "test": "jest",
"export:redis": "ts-node scripts/exportRedisToJson.ts"
}, },
"devDependencies": { "devDependencies": {
"@babel/core": "^7.28.5", "@babel/core": "^7.28.5",
+152
View File
@@ -0,0 +1,152 @@
/**
* Vývojový skript pro export dat z Redisu do JSON souboru (data/db.json).
*
* Použití: typicky proti produkčnímu Redisu zpřístupněnému přes dočasný SSH tunel:
* ssh -L 6379:localhost:6379 user@prod-host
* cd server && yarn export:redis
*
* Skript jde přes stejné StorageInterface jako aplikace (RedisStorage), takže
* korektně přečte i hodnoty uložené přes RedisJSON modul a zapíše je ve tvaru,
* který očekává JsonStorage (simple-json-db) — tedy plochý objekt { klíč: hodnota }.
*
* Volitelné parametry (CLI nebo env):
* --host <host> (REDIS_HOST) výchozí: localhost
* --port <port> (REDIS_PORT) výchozí: 6379
* --out <cesta> výchozí: server/data/db.json
* --filter <text> exportovat jen klíče obsahující daný podřetězec
* --yes přeskočit interaktivní potvrzení přepisu
*/
import * as fs from 'fs';
import * as path from 'path';
import * as readline from 'readline';
import RedisStorage, { shutdownRedisStorage } from '../src/storage/redis';
// Bezpečnostní pojistka — skript nikdy nepouštět v produkčním režimu.
if ((process.env.NODE_ENV ?? 'development') === 'production') {
console.error('Tento skript nelze spustit s NODE_ENV=production.');
process.exit(1);
}
/** Jednoduché parsování CLI argumentů typu --klíč hodnota a --flag. */
function parseArgs(argv: string[]): Record<string, string | boolean> {
const out: Record<string, string | boolean> = {};
for (let i = 0; i < argv.length; i++) {
const arg = argv[i];
if (!arg.startsWith('--')) continue;
const key = arg.slice(2);
const next = argv[i + 1];
if (next === undefined || next.startsWith('--')) {
out[key] = true;
} else {
out[key] = next;
i++;
}
}
return out;
}
/** Dotaz na potvrzení (y/n) ve stdin. */
function confirm(question: string): Promise<boolean> {
const rl = readline.createInterface({ input: process.stdin, output: process.stdout });
return new Promise(resolve => {
rl.question(question, answer => {
rl.close();
resolve(/^(y|a|ano|yes)$/i.test(answer.trim()));
});
});
}
async function main() {
const args = parseArgs(process.argv.slice(2));
// Host/port nastavíme do env PŘED načtením RedisStorage — jeho konstruktor je čte z env.
if (typeof args.host === 'string') process.env.REDIS_HOST = args.host;
if (typeof args.port === 'string') process.env.REDIS_PORT = args.port;
const host = process.env.REDIS_HOST ?? 'localhost';
const port = process.env.REDIS_PORT ?? '6379';
const outPath = typeof args.out === 'string'
? path.resolve(process.cwd(), args.out)
: path.resolve(__dirname, '../data/db.json');
const filter = typeof args.filter === 'string' ? args.filter : undefined;
// RedisStorage čte REDIS_HOST/PORT z env až ve svém konstruktoru (ne při importu),
// proto stačí je nastavit výše a teprve teď vytvořit instanci.
console.log(`Připojuji se k Redisu na ${host}:${port} ...`);
const storage = new RedisStorage();
await storage.initialize!();
const keys = await storage.listKeys(filter);
console.log(`Nalezeno ${keys.length} klíčů${filter ? ` (filtr: "${filter}")` : ''}.`);
if (keys.length === 0) {
console.warn('Žádná data k exportu — končím bez zápisu.');
await shutdownRedisStorage();
return;
}
// Bezpečné načtení jednoho klíče — getData jde přes json.get, takže ne-JSON klíče
// (např. lease připomínkovače uložené jako plain string přes SET NX EX) vyhodí chybu.
// Takové klíče nejsou aplikační data a do db.json nepatří, proto je přeskočíme.
const skipped: string[] = [];
async function readSafe(key: string): Promise<unknown> {
try {
return await storage.getData(key);
} catch {
skipped.push(key);
return undefined;
}
}
// Načtení hodnot po dávkách, ať zbytečně nezahltíme spojení.
const BATCH = 20;
const result: Record<string, unknown> = {};
for (let i = 0; i < keys.length; i += BATCH) {
const batch = keys.slice(i, i + BATCH);
const values = await Promise.all(batch.map(k => readSafe(k)));
batch.forEach((k, idx) => {
const value = values[idx];
if (value !== undefined && value !== null) {
result[k] = value;
}
});
console.log(`Načteno ${Math.min(i + BATCH, keys.length)}/${keys.length} klíčů ...`);
}
if (skipped.length > 0) {
console.warn(`Přeskočeno ${skipped.length} ne-JSON klíčů: ${skipped.join(', ')}`);
}
await shutdownRedisStorage();
// Potvrzení přepisu existujícího souboru (pokud není --yes) + záloha.
if (fs.existsSync(outPath) && args.yes !== true) {
const ok = await confirm(`Soubor ${outPath} už existuje a bude přepsán. Pokračovat? [a/N] `);
if (!ok) {
console.log('Zrušeno uživatelem.');
return;
}
}
if (fs.existsSync(outPath)) {
const backupPath = `${outPath}.bak`;
fs.copyFileSync(outPath, backupPath);
console.log(`Záloha původního souboru: ${backupPath}`);
}
const dir = path.dirname(outPath);
if (!fs.existsSync(dir)) {
fs.mkdirSync(dir, { recursive: true });
}
// simple-json-db ukládá data jako plochý JSON objekt { klíč: hodnota }.
fs.writeFileSync(outPath, JSON.stringify(result), 'utf-8');
console.log(`Hotovo — ${Object.keys(result).length} klíčů zapsáno do ${outPath}.`);
}
main().catch(err => {
console.error('Export selhal:', err);
process.exit(1);
});
+134
View File
@@ -0,0 +1,134 @@
import crypto from 'crypto';
/**
* Vývojový simulátor sledování objednávek Bolt Food.
*
* Drží in-memory registr „simulovaných" objednávek klíčovaný tokenem. Funkce
* pollBoltOrder v boltTracking.ts se na začátku podívá, zda je token simulovaný,
* a pokud ano, vrátí vyfabrikovaný stav místo dotazu na reálné Bolt API.
*
* Registr se plní výhradně přes dev endpointy (gated requireDevMode), takže
* v produkci zůstává prázdný a chování pollBoltOrder se nijak nemění.
*
* Postup stavů je řízen ručně (krokováním), bez časové osy — viz advance/setState.
*/
/** Jeden krok simulace — odpovídá tomu, co vrací Bolt API a co čte BoltOrderProgress. */
export interface SimStep {
order_state: string;
courier_state?: string;
etaSeconds?: number;
}
/** Tvar objednávky, který vrací pollBoltOrder (shodný s interface BoltOrder). */
export interface SimulatedBoltOrder {
order_id: number;
order_state: string;
expected_time_to_client_in_seconds?: number;
courier?: { state?: string } | null;
}
interface Simulation {
groupId: string;
token: string;
orderId: number;
steps: SimStep[];
index: number;
/** Jednorázové ruční přepsání aktuálního stavu (má přednost před steps[index]). */
override?: SimStep;
}
/**
* Výchozí scénář „happy path". Stavy a stavy kurýra odpovídají mapování ve
* client/src/components/BoltOrderProgress.tsx (Přijato → Příprava → Na cestě → Doručeno).
*/
export const DEFAULT_SCENARIO: SimStep[] = [
{ order_state: 'accepted', etaSeconds: 1800 },
{ order_state: 'preparing', etaSeconds: 1500 },
{ order_state: 'waiting_delivery', courier_state: 'arrived_to_provider', etaSeconds: 900 },
{ order_state: 'in_delivery', courier_state: 'heading_to_client', etaSeconds: 300 },
{ order_state: 'delivered', courier_state: 'delivered', etaSeconds: 0 },
];
const byToken = new Map<string, Simulation>();
function findByGroup(groupId: string): Simulation | undefined {
for (const sim of byToken.values()) {
if (sim.groupId === groupId) return sim;
}
return undefined;
}
/** Sestaví Bolt objednávku z aktuálního kroku simulace. */
function buildOrder(sim: Simulation): SimulatedBoltOrder {
const step = sim.override ?? sim.steps[sim.index];
return {
order_id: sim.orderId,
order_state: step.order_state,
expected_time_to_client_in_seconds: step.etaSeconds,
courier: step.courier_state ? { state: step.courier_state } : null,
};
}
/** Je token registrovaný v simulátoru? */
export function isBoltSimulated(token: string): boolean {
return byToken.has(token);
}
/** Vrátí simulovaný stav objednávky pro daný token (nebo null, pokud není simulovaný). */
export function getSimulatedBoltOrder(token: string): SimulatedBoltOrder | null {
const sim = byToken.get(token);
return sim ? buildOrder(sim) : null;
}
/**
* Spustí novou simulaci pro skupinu. Pokud už pro skupinu simulace běží, nahradí ji.
* Vrátí vygenerovaný 64-hex token (validní pro extractBoltToken).
*/
export function startBoltSimulation(groupId: string, steps: SimStep[] = DEFAULT_SCENARIO): string {
stopBoltSimulationByGroup(groupId);
const token = crypto.randomBytes(32).toString('hex');
byToken.set(token, {
groupId,
token,
orderId: crypto.randomInt(100000, 999999),
steps: steps.length ? steps : DEFAULT_SCENARIO,
index: 0,
});
return token;
}
/** Posune simulaci skupiny na další krok (a zruší případný ruční override). Vrátí aktuální krok. */
export function advanceBoltSimulation(groupId: string): SimStep {
const sim = findByGroup(groupId);
if (!sim) throw new Error('Pro skupinu neběží žádná simulace Bolt');
sim.override = undefined;
sim.index = Math.min(sim.index + 1, sim.steps.length - 1);
return sim.steps[sim.index];
}
/** Nastaví konkrétní stav simulace skupiny (ruční override — užitečné pro edge-case stavy). */
export function setBoltSimulationStep(groupId: string, step: SimStep): SimStep {
const sim = findByGroup(groupId);
if (!sim) throw new Error('Pro skupinu neběží žádná simulace Bolt');
sim.override = step;
return step;
}
/** Ukončí simulaci pro skupinu. */
export function stopBoltSimulationByGroup(groupId: string): void {
const sim = findByGroup(groupId);
if (sim) byToken.delete(sim.token);
}
/** Vrátí přehled simulace skupiny (pro stavové zobrazení v UI). */
export function getBoltSimulation(groupId: string): { token: string; index: number; total: number; current: SimStep } | null {
const sim = findByGroup(groupId);
if (!sim) return null;
return {
token: sim.token,
index: sim.index,
total: sim.steps.length,
current: sim.override ?? sim.steps[sim.index],
};
}
+14 -3
View File
@@ -6,6 +6,7 @@ import { getToday } from './service';
import { formatDate } from './utils'; import { formatDate } from './utils';
import { getWebsocket } from './websocket'; import { getWebsocket } from './websocket';
import { ClientData, GroupState } from '../../types/gen/types.gen'; import { ClientData, GroupState } from '../../types/gen/types.gen';
import { isBoltSimulated, getSimulatedBoltOrder } from './boltSimulator';
const storage = getStorage(); const storage = getStorage();
const lease = createLeaderLease('luncher:bolt:leader'); const lease = createLeaderLease('luncher:bolt:leader');
@@ -58,6 +59,11 @@ interface BoltOrder {
/** Dotáže se veřejného Bolt API na stav sdílené objednávky. Vrátí null, pokud objednávka už neexistuje. */ /** Dotáže se veřejného Bolt API na stav sdílené objednávky. Vrátí null, pokud objednávka už neexistuje. */
export async function pollBoltOrder(token: string): Promise<BoltOrder | null> { export async function pollBoltOrder(token: string): Promise<BoltOrder | null> {
// DEV simulace: simulované tokeny obsluhuje boltSimulator místo reálného Bolt API.
// V produkci je registr vždy prázdný, takže se sem nikdy nedostane.
if (isBoltSimulated(token)) {
return getSimulatedBoltOrder(token);
}
const res = await axios.post(BOLT_POLLING_URL, { token }, { const res = await axios.post(BOLT_POLLING_URL, { token }, {
params: { params: {
version: 'FW.1.111', version: 'FW.1.111',
@@ -158,10 +164,15 @@ export async function checkBoltTracking(): Promise<void> {
} }
} }
/** Spustí scheduler pro sledování Bolt objednávek (každou minutu). */ /**
* Spustí scheduler pro sledování Bolt objednávek. Interval je 60 s, lze ho ale
* zkrátit přes env BOLT_POLL_INTERVAL_MS (užitečné při vývoji se simulací).
*/
export function startBoltTrackingScheduler(): void { export function startBoltTrackingScheduler(): void {
boltInterval = setInterval(checkBoltTracking, 60_000); const parsed = Number(process.env.BOLT_POLL_INTERVAL_MS);
console.log('Bolt tracking: scheduler spuštěn'); const intervalMs = Number.isFinite(parsed) && parsed >= 1000 ? parsed : 60_000;
boltInterval = setInterval(checkBoltTracking, intervalMs);
console.log(`Bolt tracking: scheduler spuštěn (interval ${intervalMs} ms)`);
} }
/** Stopne scheduler sledování. Volá se při graceful shutdown. */ /** Stopne scheduler sledování. Volá se při graceful shutdown. */
+80
View File
@@ -6,6 +6,12 @@ import { getWebsocket } from "../websocket";
import { getLogin } from "../auth"; import { getLogin } from "../auth";
import { parseToken } from "../utils"; import { parseToken } from "../utils";
import webpush from 'web-push'; import webpush from 'web-push';
import { ClientData, GroupState } from "../../../types/gen/types.gen";
import {
startBoltSimulation, advanceBoltSimulation, setBoltSimulationStep,
stopBoltSimulationByGroup, getBoltSimulation,
} from "../boltSimulator";
import { checkBoltTracking } from "../boltTracking";
const router = express.Router(); const router = express.Router();
const storage = getStorage(); const storage = getStorage();
@@ -195,4 +201,78 @@ router.post("/testPush", async (req, res, next) => {
} catch (e: any) { next(e) } } catch (e: any) { next(e) }
}); });
// --- DEV simulace sledování Bolt Food ---
/** Nastaví/zruší sledovací token skupiny a zajistí stav ORDERED. Vrátí aktualizovaná data. */
async function applyBoltToken(groupId: string, token: string | undefined): Promise<ClientData> {
const key = `${formatDate(getToday())}_extra`;
return storage.updateData<ClientData>(key, current => {
const d = current;
const group = d?.groups?.find(g => g.id === groupId);
if (!group) throw new Error('Skupina nebyla nalezena');
group.boltTrackingToken = token;
if (token) {
group.state = GroupState.ORDERED;
} else {
group.boltOrderState = undefined;
group.boltCourierState = undefined;
}
return d!;
});
}
/** Spustí simulaci sledování Bolt pro skupinu a provede první poll. */
router.post("/bolt/simulate", async (req: Request<{}, any, any>, res, next) => {
try {
const groupId = req.body?.groupId;
if (!groupId) return res.status(400).json({ error: 'Chybí groupId' });
const token = startBoltSimulation(groupId);
await applyBoltToken(groupId, token);
await checkBoltTracking(); // okamžitý první poll → stav "accepted" + websocket
res.status(200).json({ success: true, token, simulation: getBoltSimulation(groupId) });
} catch (e: any) { next(e); }
});
/** Posune simulaci na další krok a přepošle aktualizovaný stav klientům. */
router.post("/bolt/advance", async (req: Request<{}, any, any>, res, next) => {
try {
const groupId = req.body?.groupId;
if (!groupId) return res.status(400).json({ error: 'Chybí groupId' });
advanceBoltSimulation(groupId);
await checkBoltTracking();
res.status(200).json({ success: true, simulation: getBoltSimulation(groupId) });
} catch (e: any) { next(e); }
});
/** Nastaví konkrétní stav simulace (ruční override, např. pro stav "cancelled"). */
router.post("/bolt/state", async (req: Request<{}, any, any>, res, next) => {
try {
const { groupId, order_state, courier_state, etaSeconds } = req.body ?? {};
if (!groupId || !order_state) return res.status(400).json({ error: 'Chybí groupId nebo order_state' });
setBoltSimulationStep(groupId, { order_state, courier_state, etaSeconds });
await checkBoltTracking();
res.status(200).json({ success: true, simulation: getBoltSimulation(groupId) });
} catch (e: any) { next(e); }
});
/** Spustí jeden tik scheduleru okamžitě (bez čekání na interval). */
router.post("/bolt/poll", async (_req, res, next) => {
try {
await checkBoltTracking();
res.status(200).json({ success: true });
} catch (e: any) { next(e); }
});
/** Ukončí simulaci skupiny a odebere sledovací token. */
router.delete("/bolt/simulate", async (req: Request<{}, any, any>, res, next) => {
try {
const groupId = req.body?.groupId;
if (!groupId) return res.status(400).json({ error: 'Chybí groupId' });
stopBoltSimulationByGroup(groupId);
const updated = await applyBoltToken(groupId, undefined);
getWebsocket()?.emit('message', updated);
res.status(200).json({ success: true });
} catch (e: any) { next(e); }
});
export default router; export default router;
+4 -1
View File
@@ -135,7 +135,10 @@ router.post("/dismissQr", async (req: Request<{}, any, DismissQrData["body"]>, r
try { try {
const dismissed = await dismissPendingQr(login, req.body.id); const dismissed = await dismissPendingQr(login, req.body.id);
if (dismissed?.groupId) { if (dismissed?.groupId) {
const updatedExtra = await markGroupMemberPaid(login, dismissed.groupId); // Platbu zapisujeme ke dni, ke kterému se QR kód vztahuje, ne k dnešnímu dni
// jinak by se při potvrzení platby jiný den příznak zapsal do špatných dat (a zelené zatržítko by se neobjevilo).
const orderDate = new Date(`${dismissed.date}T00:00:00`);
const updatedExtra = await markGroupMemberPaid(login, dismissed.groupId, orderDate);
if (updatedExtra) getWebsocket().emit("message", updatedExtra); if (updatedExtra) getWebsocket().emit("message", updatedExtra);
} }
res.status(200).json({}); res.status(200).json({});
+58
View File
@@ -4,6 +4,7 @@ import getStorage from '../storage';
import { addStore } from '../stores'; import { addStore } from '../stores';
import { createGroup, setGroupState, setGroupBoltTracking } from '../groups'; import { createGroup, setGroupState, setGroupBoltTracking } from '../groups';
import { extractBoltToken, computeDeliveryHHMM, checkBoltTracking } from '../boltTracking'; import { extractBoltToken, computeDeliveryHHMM, checkBoltTracking } from '../boltTracking';
import { startBoltSimulation, advanceBoltSimulation, setBoltSimulationStep, stopBoltSimulationByGroup } from '../boltSimulator';
import { ClientData, GroupState } from '../../../types/gen/types.gen'; import { ClientData, GroupState } from '../../../types/gen/types.gen';
import { formatDate } from '../utils'; import { formatDate } from '../utils';
@@ -263,3 +264,60 @@ describe('checkBoltTracking', () => {
expect(mockedAxios.post).not.toHaveBeenCalled(); expect(mockedAxios.post).not.toHaveBeenCalled();
}); });
}); });
describe('DEV simulace (boltSimulator + checkBoltTracking)', () => {
const extraKey = () => `${formatDate(new Date())}_extra`;
let groupId: string;
beforeEach(async () => {
const d = await createGroup(CREATOR, STORE);
groupId = d.groups![0].id;
await setGroupState(CREATOR, groupId, GroupState.LOCKED);
await setGroupState(CREATOR, groupId, GroupState.ORDERED);
// Simulátor vygeneruje validní 64-hex token a přiřadíme ho skupině jako reálný dev endpoint
const token = startBoltSimulation(groupId);
await setGroupBoltTracking(CREATOR, groupId, `https://food.bolt.eu/sharedActiveOrder/${token}`);
});
afterEach(() => stopBoltSimulationByGroup(groupId));
async function getGroup() {
const data = await storage.getData<ClientData>(extraKey());
return data!.groups!.find(g => g.id === groupId)!;
}
test('simulovaný token nevolá reálné Bolt API', async () => {
await checkBoltTracking();
expect(mockedAxios.post).not.toHaveBeenCalled();
});
test('první poll nastaví stav accepted a ETA', async () => {
await checkBoltTracking();
const g = await getGroup();
expect(g.boltOrderState).toBe('accepted');
expect(g.deliveryAt).toBe(computeDeliveryHHMM(1800));
});
test('advance posune sekvenci na preparing', async () => {
await checkBoltTracking();
advanceBoltSimulation(groupId);
await checkBoltTracking();
expect((await getGroup()).boltOrderState).toBe('preparing');
});
test('ruční nastavení stavu (override) se projeví při pollu', async () => {
setBoltSimulationStep(groupId, { order_state: 'in_delivery', courier_state: 'heading_to_client', etaSeconds: 300 });
await checkBoltTracking();
const g = await getGroup();
expect(g.boltOrderState).toBe('in_delivery');
expect(g.boltCourierState).toBe('heading_to_client');
});
test('terminální stav delivered ukončí sledování (smaže token)', async () => {
setBoltSimulationStep(groupId, { order_state: 'delivered' });
await checkBoltTracking();
const g = await getGroup();
expect(g.boltOrderState).toBe('delivered');
expect(g.boltTrackingToken).toBeUndefined();
});
});
+34 -1
View File
@@ -1,6 +1,6 @@
import { resetMemoryStorage } from '../storage/memory'; import { resetMemoryStorage } from '../storage/memory';
import { getStores, addStore } from '../stores'; import { getStores, addStore } from '../stores';
import { createGroup, deleteGroup, addGroupMember, removeGroupMember, updateGroupMember, setGroupState, setGroupBoltTracking } from '../groups'; import { createGroup, deleteGroup, addGroupMember, removeGroupMember, updateGroupMember, setGroupState, setGroupBoltTracking, markGroupMemberPaid } from '../groups';
import { GroupState } from '../../../types/gen/types.gen'; import { GroupState } from '../../../types/gen/types.gen';
const CREATOR = 'tomas'; const CREATOR = 'tomas';
@@ -202,3 +202,36 @@ describe('setGroupState', () => {
expect(d.groups![0].boltTrackingToken).toBeUndefined(); expect(d.groups![0].boltTrackingToken).toBeUndefined();
}); });
}); });
describe('markGroupMemberPaid', () => {
test('označí člena jako zaplaceného pro daný den', async () => {
const d = await createGroup(CREATOR, STORE, TODAY);
const groupId = d.groups![0].id;
const result = await markGroupMemberPaid(CREATOR, groupId, TODAY);
expect(result).not.toBeNull();
expect(result!.groups![0].members[CREATOR].paid).toBe(true);
});
test('vrátí null pro neexistující skupinu', async () => {
const result = await markGroupMemberPaid(CREATOR, 'nonexistent', TODAY);
expect(result).toBeNull();
});
// Regrese: potvrzení platby jiný den, než vznikla objednávka, se musí zapsat
// ke dni objednávky jinak se příznak ztratí a zelené zatržítko se nezobrazí.
test('zapíše platbu ke dni objednávky i při potvrzení jiný den', async () => {
const orderDay = new Date('2025-01-10');
const d = await createGroup(CREATOR, STORE, orderDay);
const groupId = d.groups![0].id;
// Uživatel potvrzuje platbu jiný den, ale předáváme datum objednávky.
const result = await markGroupMemberPaid(CREATOR, groupId, orderDay);
expect(result).not.toBeNull();
expect(result!.groups![0].members[CREATOR].paid).toBe(true);
// Skupina pod jiným dnem neexistuje ověříme, že tam příznak omylem nevznikl.
const otherDay = new Date('2025-01-15');
const onOtherDay = await markGroupMemberPaid(CREATOR, groupId, otherDay);
expect(onOtherDay).toBeNull();
});
});
+8
View File
@@ -118,6 +118,14 @@ paths:
$ref: "./paths/dev/generate.yml" $ref: "./paths/dev/generate.yml"
/dev/clear: /dev/clear:
$ref: "./paths/dev/clear.yml" $ref: "./paths/dev/clear.yml"
/dev/bolt/simulate:
$ref: "./paths/dev/boltSimulate.yml"
/dev/bolt/advance:
$ref: "./paths/dev/boltAdvance.yml"
/dev/bolt/state:
$ref: "./paths/dev/boltState.yml"
/dev/bolt/poll:
$ref: "./paths/dev/boltPoll.yml"
components: components:
schemas: schemas:
+20
View File
@@ -0,0 +1,20 @@
post:
operationId: advanceBoltTracking
summary: Posun simulace sledování Bolt na další krok (pouze DEV režim)
requestBody:
required: true
content:
application/json:
schema:
$ref: "../../schemas/_index.yml#/BoltSimGroupRequest"
responses:
"200":
description: Simulace byla posunuta
content:
application/json:
schema:
$ref: "../../schemas/_index.yml#/BoltSimResponse"
"400":
description: Chybný požadavek
"403":
description: Endpoint není dostupný v tomto režimu
+15
View File
@@ -0,0 +1,15 @@
post:
operationId: pollBoltTracking
summary: Okamžité spuštění jednoho tiku scheduleru sledování Bolt (pouze DEV režim)
responses:
"200":
description: Poll proběhl
content:
application/json:
schema:
type: object
properties:
success:
type: boolean
"403":
description: Endpoint není dostupný v tomto režimu
+40
View File
@@ -0,0 +1,40 @@
post:
operationId: simulateBoltTracking
summary: Spuštění simulace sledování Bolt pro skupinu (pouze DEV režim)
requestBody:
required: true
content:
application/json:
schema:
$ref: "../../schemas/_index.yml#/BoltSimGroupRequest"
responses:
"200":
description: Simulace byla spuštěna
content:
application/json:
schema:
$ref: "../../schemas/_index.yml#/BoltSimResponse"
"400":
description: Chybný požadavek
"403":
description: Endpoint není dostupný v tomto režimu
delete:
operationId: stopBoltTrackingSimulation
summary: Ukončení simulace sledování Bolt pro skupinu (pouze DEV režim)
requestBody:
required: true
content:
application/json:
schema:
$ref: "../../schemas/_index.yml#/BoltSimGroupRequest"
responses:
"200":
description: Simulace byla ukončena
content:
application/json:
schema:
$ref: "../../schemas/_index.yml#/BoltSimResponse"
"400":
description: Chybný požadavek
"403":
description: Endpoint není dostupný v tomto režimu
+20
View File
@@ -0,0 +1,20 @@
post:
operationId: setBoltTrackingState
summary: Ruční nastavení konkrétního stavu simulace Bolt (pouze DEV režim)
requestBody:
required: true
content:
application/json:
schema:
$ref: "../../schemas/_index.yml#/BoltSimStateRequest"
responses:
"200":
description: Stav byl nastaven
content:
application/json:
schema:
$ref: "../../schemas/_index.yml#/BoltSimResponse"
"400":
description: Chybný požadavek
"403":
description: Endpoint není dostupný v tomto režimu
+80
View File
@@ -707,6 +707,86 @@ ClearMockDataRequest:
description: Index dne v týdnu (0 = pondělí, 4 = pátek). Pokud není zadán, použije se aktuální den. description: Index dne v týdnu (0 = pondělí, 4 = pátek). Pokud není zadán, použije se aktuální den.
$ref: "#/DayIndex" $ref: "#/DayIndex"
# --- DEV SIMULACE BOLT ---
BoltSimGroupRequest:
description: Request s identifikátorem skupiny pro DEV simulaci Bolt (pouze DEV režim)
type: object
additionalProperties: false
required:
- groupId
properties:
groupId:
description: ID skupiny, jejíž sledování Bolt se má simulovat
type: string
BoltSimStateRequest:
description: Request pro ruční nastavení konkrétního stavu simulace Bolt (pouze DEV režim)
type: object
additionalProperties: false
required:
- groupId
- order_state
properties:
groupId:
description: ID skupiny
type: string
order_state:
description: Stav objednávky (např. accepted, preparing, waiting_delivery, in_delivery, delivered, cancelled)
type: string
courier_state:
description: Stav kurýra (např. arrived_to_provider, heading_to_client)
type: string
etaSeconds:
description: Očekávaný čas do doručení v sekundách
type: integer
minimum: 0
BoltSimStep:
description: Aktuální krok simulace Bolt
type: object
additionalProperties: false
required:
- order_state
properties:
order_state:
type: string
courier_state:
type: string
etaSeconds:
type: integer
BoltSimStatus:
description: Stav simulace sledování Bolt pro skupinu
type: object
additionalProperties: false
required:
- token
- index
- total
- current
properties:
token:
description: Vygenerovaný sledovací token
type: string
index:
description: Index aktuálního kroku v sekvenci
type: integer
total:
description: Celkový počet kroků v sekvenci
type: integer
current:
$ref: "#/BoltSimStep"
BoltSimResponse:
description: Odpověď DEV endpointů simulace Bolt
type: object
additionalProperties: false
required:
- success
properties:
success:
type: boolean
token:
type: string
simulation:
$ref: "#/BoltSimStatus"
# --- SKUPINOVÉ OBJEDNÁVKY --- # --- SKUPINOVÉ OBJEDNÁVKY ---
Store: Store:
description: Povolený obchod/restaurace pro extra objednávky. description: Povolený obchod/restaurace pro extra objednávky.