feat: generování mock dat ve vývoji pro objednávky
CI / Generate TypeScript types (push) Successful in 11s
CI / Server unit tests (push) Successful in 27s
CI / Build server (push) Successful in 29s
CI / Build client (push) Successful in 42s
CI / Playwright E2E tests (push) Successful in 1m43s
CI / Build and push Docker image (push) Successful in 46s
CI / Notify (push) Successful in 2s

This commit is contained in:
2026-09-04 16:57:10 +02:00
parent 1af40bd572
commit ecc28ee82d
7 changed files with 574 additions and 5 deletions
+142 -1
View File
@@ -6,7 +6,9 @@ import { getWebsocket } from "../websocket";
import { getLogin } from "../auth";
import { parseToken } from "../utils";
import webpush from 'web-push';
import { ClientData, GroupState, TrackingProvider } from "../../../types/gen/types.gen";
import { ClientData, GroupState, MealSlot, OrderGroupMember, TrackingProvider } from "../../../types/gen/types.gen";
import { getStores } from "../stores";
import { createGroup } from "../groups";
import {
startBoltSimulation, advanceBoltSimulation, setBoltSimulationStep,
stopBoltSimulationByGroup, getBoltSimulation,
@@ -36,6 +38,39 @@ const LUNCH_CHOICES = [
'ROZHODUJI',
];
// Náhodné názvy jídel do poznámek mock objednávek
const MOCK_ORDER_FOODS = [
'Malá kuřecí tortilla',
'Jalapenos burger',
'Chicken Palak',
'Pad Thai s kuřecím',
'Bún bò nam bo',
'Trhané hovězí v bulce',
'Caesar salát s kuřetem',
'Kuřecí vindaloo',
'Smažený sýr s hranolkami',
'Pizza Diavola',
'Burrito s trhaným masem',
'Ramen s vepřovým bůčkem',
'Falafel wrap v pitě',
'Krůtí steak s bramborovou kaší',
'Gyros se zeleninou',
'Losos s grilovanou zeleninou',
'Svíčková na smetaně s knedlíkem',
'Kuřecí kung pao',
'Poke bowl s tuňákem',
'Vepřový řízek s bramborovým salátem',
];
/** Výchozí hodnoty dialogu pro generování mock objednávek. */
const DEFAULT_ORDER_MEMBER_COUNT = 3;
const DEFAULT_MIN_AMOUNT = 100;
const DEFAULT_MAX_AMOUNT = 1000;
/** Nejvyšší povolený počet osob doplněných do jedné skupiny. */
const MAX_ORDER_MEMBER_COUNT = 50;
/** Nejvyšší povolená částka (v Kč) — musí odpovídat OpenAPI definici. */
const MAX_ORDER_AMOUNT = 100000;
// Restaurace s menu
const RESTAURANTS_WITH_MENU = [
'SLADOVNICKA',
@@ -249,6 +284,112 @@ router.post("/testPush", async (req, res, next) => {
} catch (e: any) { next(e) }
});
// --- DEV mock data pro sekci Objednání ---
/** Vrátí náhodné celé číslo z intervalu <min, max>. */
function randomInt(min: number, max: number): number {
return min + Math.floor(Math.random() * (max - min + 1));
}
/** Vrátí náhodný prvek neprázdného pole. */
function randomItem<Type>(items: Type[]): Type {
return items[randomInt(0, items.length - 1)];
}
/**
* Vybere jméno, které ve skupině ještě není použité.
* Po vyčerpání seznamu jmen přidává číselný sufix (Alice2, Alice3, …).
*/
function pickMemberName(members: Record<string, OrderGroupMember>): string {
const free = MOCK_NAMES.filter(name => !members[name]);
if (free.length > 0) {
return randomItem(free);
}
const base = randomItem(MOCK_NAMES);
let suffix = 2;
while (members[`${base}${suffix}`]) {
suffix++;
}
return `${base}${suffix}`;
}
/** Rozešle klientům aktuální data sekce Objednání (dnešní den). */
async function broadcastExtra() {
getWebsocket().emit("message", await getData(getToday(), MealSlot.EXTRA));
}
/**
* Vygeneruje mock data pro sekci Objednání — vždy jen pro aktuální den.
* Do každé existující skupiny doplní zadaný počet osob s náhodnou částkou
* a názvem náhodného jídla v poznámce. Pokud žádná skupina neexistuje,
* založí jednu z náhodně vybraného obchodu.
*/
router.post("/generateOrders", async (req: Request<{}, any, any>, res, next) => {
try {
const login = getLogin(parseToken(req));
const count: number = req.body?.count ?? DEFAULT_ORDER_MEMBER_COUNT;
const minAmount: number = req.body?.minAmount ?? DEFAULT_MIN_AMOUNT;
const maxAmount: number = req.body?.maxAmount ?? DEFAULT_MAX_AMOUNT;
if (!Number.isInteger(count) || count < 1 || count > MAX_ORDER_MEMBER_COUNT) {
return res.status(400).json({ error: `Počet osob musí být celé číslo mezi 1 a ${MAX_ORDER_MEMBER_COUNT}` });
}
if (!Number.isInteger(minAmount) || !Number.isInteger(maxAmount)
|| minAmount < 0 || maxAmount > MAX_ORDER_AMOUNT || minAmount > maxAmount) {
return res.status(400).json({ error: 'Neplatný rozsah částek' });
}
const stores = await getStores();
if (stores.length === 0) {
return res.status(400).json({ error: 'Není nadefinován žádný obchod — mock data pro objednávání nelze vygenerovat' });
}
const key = `${formatDate(getToday())}_extra`;
const existing = await storage.getData<ClientData>(key);
let createdGroupId: string | undefined;
// Bez skupiny není kam objednávky doplnit — jednu založíme z náhodně vybraného obchodu
if (!existing?.groups?.length) {
const store = randomItem(stores);
const urls = store.urls ?? [];
const created = await createGroup(login, store.name, undefined, urls.length > 0 ? randomItem(urls) : undefined);
createdGroupId = created.groups?.[created.groups.length - 1]?.id;
}
const results: { id: string, name: string, added: number, created?: boolean }[] = [];
await storage.updateData<ClientData>(key, current => {
const data = current!;
// Mutátor může být (u Redis) zavolán opakovaně — výsledky proto vždy sestavíme znovu
results.length = 0;
for (const group of data.groups ?? []) {
for (let i = 0; i < count; i++) {
group.members[pickMemberName(group.members)] = {
amount: randomInt(minAmount, maxAmount) * 100,
note: randomItem(MOCK_ORDER_FOODS),
};
}
results.push({
id: group.id,
name: group.name,
added: count,
...(group.id === createdGroupId ? { created: true } : {}),
});
}
return data;
});
await broadcastExtra();
res.status(200).json({
success: true,
count: results.reduce((sum, group) => sum + group.added, 0),
groups: results,
});
} catch (e: any) {
next(e);
}
});
// --- DEV simulace sledování Bolt Food (Wolt simulaci zatím nemá) ---
/** Nastaví/zruší sledovací token skupiny a zajistí stav ORDERED. Vrátí aktualizovaná data. */
+157
View File
@@ -0,0 +1,157 @@
import express from 'express';
import request from 'supertest';
import bodyParser from 'body-parser';
import { generateToken } from '../auth';
import { resetMemoryStorage } from '../storage/memory';
import getStorage from '../storage';
import devRouter from '../routes/devRoutes';
import { createGroup } from '../groups';
import { ClientData, Store } from '../../../types/gen/types.gen';
import { formatDate } from '../utils';
import { getToday } from '../service';
// Websocket v testech neexistuje broadcast jen odchytíme
jest.mock('../websocket', () => ({
getWebsocket: () => ({ emit: jest.fn() }),
emitToUser: jest.fn(),
}));
const storage = getStorage();
const TOKEN = `Bearer ${generateToken('testuser')}`;
function buildApp() {
const app = express();
app.use(bodyParser.json());
app.use('/api/dev', devRouter);
app.use((err: any, _req: any, res: any, _next: any) => {
res.status(400).json({ error: err.message });
});
return app;
}
/** Vrátí uložená data sekce Objednání pro dnešní den. */
async function getExtra(): Promise<ClientData | undefined> {
return storage.getData<ClientData>(`${formatDate(getToday())}_extra`);
}
async function setStores(stores: Store[]) {
await storage.setData('stores', stores);
}
beforeEach(() => {
resetMemoryStorage();
});
test('POST /dev/generateOrders bez nadefinovaného obchodu vrátí 400', async () => {
const res = await request(buildApp())
.post('/api/dev/generateOrders')
.set('Authorization', TOKEN)
.send({});
expect(res.status).toBe(400);
});
test('POST /dev/generateOrders bez existující skupiny založí jednu a doplní do ní osoby', async () => {
await setStores([{ name: 'Bistro', urls: ['https://example.com/bistro'] }]);
const res = await request(buildApp())
.post('/api/dev/generateOrders')
.set('Authorization', TOKEN)
.send({ count: 4, minAmount: 100, maxAmount: 1000 });
expect(res.status).toBe(200);
expect(res.body.count).toBe(4);
expect(res.body.groups).toHaveLength(1);
expect(res.body.groups[0].created).toBe(true);
const data = await getExtra();
const group = data?.groups?.[0];
expect(group?.name).toBe('Bistro');
expect(group?.url).toBe('https://example.com/bistro');
// Zakladatel (přihlášený uživatel) + 4 doplněné osoby
const members = Object.entries(group!.members);
expect(members).toHaveLength(5);
const mockMembers = members.filter(([login]) => login !== 'testuser');
expect(mockMembers).toHaveLength(4);
for (const [, member] of mockMembers) {
expect(member.amount).toBeGreaterThanOrEqual(100 * 100);
expect(member.amount).toBeLessThanOrEqual(1000 * 100);
expect(member.note).toBeTruthy();
}
});
test('POST /dev/generateOrders doplní osoby do všech existujících skupin', async () => {
await setStores([{ name: 'Bistro' }, { name: 'Pizzerie' }]);
await createGroup('testuser', 'Bistro');
await createGroup('kolega', 'Pizzerie');
const res = await request(buildApp())
.post('/api/dev/generateOrders')
.set('Authorization', TOKEN)
.send({ count: 2 });
expect(res.status).toBe(200);
expect(res.body.count).toBe(4);
expect(res.body.groups).toHaveLength(2);
expect(res.body.groups.every((g: any) => g.created === undefined)).toBe(true);
const data = await getExtra();
expect(data?.groups).toHaveLength(2);
for (const group of data!.groups!) {
// Zakladatel + 2 doplněné osoby
expect(Object.keys(group.members)).toHaveLength(3);
}
});
test('POST /dev/generateOrders použije výchozí hodnoty, když nejsou zadány', async () => {
await setStores([{ name: 'Bistro' }]);
const res = await request(buildApp())
.post('/api/dev/generateOrders')
.set('Authorization', TOKEN)
.send({});
expect(res.status).toBe(200);
// Výchozí počet osob je 3
expect(res.body.count).toBe(3);
const data = await getExtra();
for (const [login, member] of Object.entries(data!.groups![0].members)) {
if (login === 'testuser') continue;
// Výchozí rozsah částek je 1001000 Kč
expect(member.amount).toBeGreaterThanOrEqual(100 * 100);
expect(member.amount).toBeLessThanOrEqual(1000 * 100);
}
});
test('POST /dev/generateOrders zvládne počet osob přesahující seznam jmen', async () => {
await setStores([{ name: 'Bistro' }]);
const res = await request(buildApp())
.post('/api/dev/generateOrders')
.set('Authorization', TOKEN)
.send({ count: 50 });
expect(res.status).toBe(200);
expect(res.body.count).toBe(50);
const data = await getExtra();
// Všechna jména musí být unikátní (zakladatel + 50 doplněných osob)
expect(Object.keys(data!.groups![0].members)).toHaveLength(51);
});
test('POST /dev/generateOrders odmítne neplatný počet osob a rozsah částek', async () => {
await setStores([{ name: 'Bistro' }]);
const app = buildApp();
const badCount = await request(app)
.post('/api/dev/generateOrders')
.set('Authorization', TOKEN)
.send({ count: 0 });
expect(badCount.status).toBe(400);
const badRange = await request(app)
.post('/api/dev/generateOrders')
.set('Authorization', TOKEN)
.send({ minAmount: 500, maxAmount: 100 });
expect(badRange.status).toBe(400);
});