Marbes/Luncher
5
2
Fork 0
Code Issues 22 Pull Requests Packages Projects Releases Wiki Activity

Zavedení podpory pro Redis, agnostické úložiště dat

Browse Source
This commit is contained in:
Martin Berka
2023-08-06 17:46:51 +02:00
parent 8a75c98c9a
commit 37542499a9
11 changed files with 282 additions and 97 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
server/src/database.ts
View File

@@ -1,3 +0,0 @@
import JSONdb from 'simple-json-db';
export const db = new JSONdb('./data.json');

80
server/src/index.ts
View File

@@ -105,8 +105,8 @@ app.use((req, res, next) => {
});
/** Vrátí data pro aktuální den. */
app.get("/api/data", (req, res) => {
res.status(200).json(getData());
app.get("/api/data", async (req, res) => {
res.status(200).json(await getData());
});
/** Vrátí obědové menu pro dostupné podniky. */
@@ -122,29 +122,28 @@ app.get("/api/food", async (req, res) => {
});
/** Vrátí seznam dostupných pizz. */
app.get("/api/pizza", (req, res) => {
fetchPizzy().then(pizzaList => {
// console.log("Výsledek", pizzaList);
res.status(200).json(pizzaList);
});
app.get("/api/pizza", async (req, res) => {
const pizzaList = await fetchPizzy();
// console.log("Výsledek", pizzaList);
res.status(200).json(pizzaList);
});
/** Založí pizza day pro aktuální den, za předpokladu že dosud neexistuje. */
app.post("/api/createPizzaDay", (req, res) => {
app.post("/api/createPizzaDay", async (req, res) => {
const login = getLogin(parseToken(req));
const data = createPizzaDay(login);
const data = await createPizzaDay(login);
res.status(200).json(data);
io.emit("message", data);
});
/** Smaže pizza day pro aktuální den, za předpokladu že existuje. */
app.post("/api/deletePizzaDay", (req, res) => {
app.post("/api/deletePizzaDay", async (req, res) => {
const login = getLogin(parseToken(req));
const data = deletePizzaDay(login);
const data = await deletePizzaDay(login);
io.emit("message", data);
});
app.post("/api/addPizza", (req, res) => {
app.post("/api/addPizza", async (req, res) => {
const login = getLogin(parseToken(req));
if (isNaN(req.body?.pizzaIndex)) {
throw Error("Nebyl předán index pizzy");
@@ -154,88 +153,87 @@ app.post("/api/addPizza", (req, res) => {
throw Error("Nebyl předán index velikosti pizzy");
}
const pizzaSizeIndex = req.body.pizzaSizeIndex;
fetchPizzy().then(pizzy => {
if (!pizzy[pizzaIndex]) {
throw Error("Neplatný index pizzy: " + pizzaIndex);
}
if (!pizzy[pizzaIndex].sizes[pizzaSizeIndex]) {
throw Error("Neplatný index velikosti pizzy: " + pizzaSizeIndex);
}
const data = addPizzaOrder(login, pizzy[pizzaIndex], pizzy[pizzaIndex].sizes[pizzaSizeIndex]);
io.emit("message", data);
res.status(200).json({});
})
const pizzy = await fetchPizzy();
if (!pizzy[pizzaIndex]) {
throw Error("Neplatný index pizzy: " + pizzaIndex);
}
if (!pizzy[pizzaIndex].sizes[pizzaSizeIndex]) {
throw Error("Neplatný index velikosti pizzy: " + pizzaSizeIndex);
}
const data = await addPizzaOrder(login, pizzy[pizzaIndex], pizzy[pizzaIndex].sizes[pizzaSizeIndex]);
io.emit("message", data);
res.status(200).json({});
});
app.post("/api/removePizza", (req, res) => {
app.post("/api/removePizza", async (req, res) => {
const login = getLogin(parseToken(req));
if (!req.body?.pizzaOrder) {
throw Error("Nebyla předána objednávka");
}
const data = removePizzaOrder(login, req.body?.pizzaOrder);
const data = await removePizzaOrder(login, req.body?.pizzaOrder);
io.emit("message", data);
res.status(200).json({});
});
app.post("/api/lockPizzaDay", (req, res) => {
app.post("/api/lockPizzaDay", async (req, res) => {
const login = getLogin(parseToken(req));
const data = lockPizzaDay(login);
const data = await lockPizzaDay(login);
io.emit("message", data);
res.status(200).json({});
});
app.post("/api/unlockPizzaDay", (req, res) => {
app.post("/api/unlockPizzaDay", async (req, res) => {
const login = getLogin(parseToken(req));
const data = unlockPizzaDay(login);
const data = await unlockPizzaDay(login);
io.emit("message", data);
res.status(200).json({});
});
app.post("/api/finishOrder", (req, res) => {
app.post("/api/finishOrder", async (req, res) => {
const login = getLogin(parseToken(req));
const data = finishPizzaOrder(login);
const data = await finishPizzaOrder(login);
io.emit("message", data);
res.status(200).json({});
});
app.post("/api/finishDelivery", (req, res) => {
app.post("/api/finishDelivery", async (req, res) => {
const login = getLogin(parseToken(req));
const data = finishPizzaDelivery(login, req.body.bankAccount, req.body.bankAccountHolder);
const data = await finishPizzaDelivery(login, req.body.bankAccount, req.body.bankAccountHolder);
io.emit("message", data);
res.status(200).json({});
});
app.post("/api/addChoice", (req, res) => {
app.post("/api/addChoice", async (req, res) => {
const login = getLogin(parseToken(req));
const trusted = getTrusted(parseToken(req));
if (req.body.locationIndex > -1) {
const data = addChoice(login, trusted, req.body.locationIndex, req.body.foodIndex);
const data = await addChoice(login, trusted, req.body.locationIndex, req.body.foodIndex);
io.emit("message", data);
res.status(200).json(data);
}
res.status(400); // TODO přidat popis chyby
});
app.post("/api/removeChoices", (req, res) => {
app.post("/api/removeChoices", async (req, res) => {
const login = getLogin(parseToken(req));
const data = removeChoices(login, req.body.locationIndex);
const data = await removeChoices(login, req.body.locationIndex);
io.emit("message", data);
res.status(200).json(data);
});
app.post("/api/removeChoice", (req, res) => {
app.post("/api/removeChoice", async (req, res) => {
const login = getLogin(parseToken(req));
const data = removeChoice(login, req.body.locationIndex, req.body.foodIndex);
const data = await removeChoice(login, req.body.locationIndex, req.body.foodIndex);
io.emit("message", data);
res.status(200).json(data);
});
app.post("/api/updateNote", (req, res) => {
app.post("/api/updateNote", async (req, res) => {
const login = getLogin(parseToken(req));
if (req.body.note && req.body.note.length > 100) {
throw Error("Poznámka může mít maximálně 100 znaků");
}
const data = updateNote(login, req.body.note);
const data = await updateNote(login, req.body.note);
io.emit("message", data);
res.status(200).json(data);
});

100
server/src/service.ts
View File

@@ -1,8 +1,10 @@
import { db } from "./database";
import { formatDate, getHumanDate, getIsWeekend } from "./utils";
import { callNotifikace } from "./notifikace";
import { generateQr } from "./qr";
import { ClientData, PizzaDayState, UdalostEnum, Pizza, PizzaSize, Order, PizzaOrder, Locations } from "../../types";
import getStorage from "./storage";
const storage = getStorage();
/** Vrátí dnešní datum, případně fiktivní datum pro účely vývoje a testování. */
function getToday(): Date {
@@ -20,23 +22,22 @@ function getEmptyData(): ClientData {
/**
* Vrátí veškerá klientská data pro aktuální den.
*/
export function getData(): ClientData {
const data = db.get(formatDate(getToday())) || getEmptyData();
return data;
export async function getData(): Promise<ClientData> {
return await storage.getData(formatDate(getToday())) || getEmptyData();
}
/**
* Vytvoří pizza day pro aktuální den a vrátí data pro klienta.
*/
export function createPizzaDay(creator: string): ClientData {
initIfNeeded();
export async function createPizzaDay(creator: string): Promise<ClientData> {
await initIfNeeded();
const today = formatDate(getToday());
const clientData: ClientData = db.get(today);
const clientData: ClientData = await storage.getData(today);
if (clientData.pizzaDay) {
throw Error("Pizza day pro dnešní den již existuje");
}
const data: ClientData = { pizzaDay: { state: PizzaDayState.CREATED, creator, orders: [] }, ...clientData };
db.set(today, data);
await storage.setData(today, data);
callNotifikace({ input: { udalost: UdalostEnum.ZAHAJENA_PIZZA, user: creator } })
return data;
}
@@ -44,9 +45,9 @@ export function createPizzaDay(creator: string): ClientData {
/**
* Smaže pizza day pro aktuální den.
*/
export function deletePizzaDay(login: string) {
export async function deletePizzaDay(login: string): Promise<ClientData> {
const today = formatDate(getToday());
const clientData: ClientData = db.get(today);
const clientData: ClientData = await storage.getData(today);
if (!clientData.pizzaDay) {
throw Error("Pizza day pro dnešní den neexistuje");
}
@@ -54,7 +55,7 @@ export function deletePizzaDay(login: string) {
throw Error("Login uživatele se neshoduje se zakladatelem Pizza Day");
}
delete clientData.pizzaDay;
db.set(today, clientData);
await storage.setData(today, clientData);
return clientData;
}
@@ -65,9 +66,9 @@ export function deletePizzaDay(login: string) {
* @param pizza zvolená pizza
* @param size zvolená velikost pizzy
*/
export function addPizzaOrder(login: string, pizza: Pizza, size: PizzaSize) {
export async function addPizzaOrder(login: string, pizza: Pizza, size: PizzaSize) {
const today = formatDate(getToday());
const clientData: ClientData = db.get(today);
const clientData: ClientData = await storage.getData(today);
if (!clientData.pizzaDay) {
throw Error("Pizza day pro dnešní den neexistuje");
}
@@ -91,7 +92,7 @@ export function addPizzaOrder(login: string, pizza: Pizza, size: PizzaSize) {
}
order.pizzaList.push(pizzaOrder);
order.totalPrice += pizzaOrder.price;
db.set(today, clientData);
await storage.setData(today, clientData);
return clientData;
}
@@ -101,9 +102,9 @@ export function addPizzaOrder(login: string, pizza: Pizza, size: PizzaSize) {
* @param login login uživatele
* @param pizzaOrder objednávka pizzy
*/
export function removePizzaOrder(login: string, pizzaOrder: PizzaOrder) {
export async function removePizzaOrder(login: string, pizzaOrder: PizzaOrder) {
const today = formatDate(getToday());
const clientData: ClientData = db.get(today);
const clientData: ClientData = await storage.getData(today);
if (!clientData.pizzaDay) {
throw Error("Pizza day pro dnešní den neexistuje");
}
@@ -122,7 +123,7 @@ export function removePizzaOrder(login: string, pizzaOrder: PizzaOrder) {
if (order.pizzaList.length == 0) {
clientData.pizzaDay.orders.splice(orderIndex, 1);
}
db.set(today, clientData);
await storage.setData(today, clientData);
return clientData;
}
@@ -132,9 +133,9 @@ export function removePizzaOrder(login: string, pizzaOrder: PizzaOrder) {
* @param login login uživatele
* @returns aktuální data pro uživatele
*/
export function lockPizzaDay(login: string) {
export async function lockPizzaDay(login: string) {
const today = formatDate(getToday());
const clientData: ClientData = db.get(today);
const clientData: ClientData = await storage.getData(today);
if (!clientData.pizzaDay) {
throw Error("Pizza day pro dnešní den neexistuje");
}
@@ -145,7 +146,7 @@ export function lockPizzaDay(login: string) {
throw Error("Pizza day není ve stavu " + PizzaDayState.CREATED + " nebo " + PizzaDayState.ORDERED);
}
clientData.pizzaDay.state = PizzaDayState.LOCKED;
db.set(today, clientData);
await storage.setData(today, clientData);
return clientData;
}
@@ -155,9 +156,9 @@ export function lockPizzaDay(login: string) {
* @param login login uživatele
* @returns aktuální data pro uživatele
*/
export function unlockPizzaDay(login: string) {
export async function unlockPizzaDay(login: string) {
const today = formatDate(getToday());
const clientData: ClientData = db.get(today);
const clientData: ClientData = await storage.getData(today);
if (!clientData.pizzaDay) {
throw Error("Pizza day pro dnešní den neexistuje");
}
@@ -168,7 +169,7 @@ export function unlockPizzaDay(login: string) {
throw Error("Pizza day není ve stavu " + PizzaDayState.LOCKED);
}
clientData.pizzaDay.state = PizzaDayState.CREATED;
db.set(today, clientData);
await storage.setData(today, clientData);
return clientData;
}
@@ -178,9 +179,9 @@ export function unlockPizzaDay(login: string) {
* @param login login uživatele
* @returns aktuální data pro uživatele
*/
export function finishPizzaOrder(login: string) {
export async function finishPizzaOrder(login: string) {
const today = formatDate(getToday());
const clientData: ClientData = db.get(today);
const clientData: ClientData = await storage.getData(today);
if (!clientData.pizzaDay) {
throw Error("Pizza day pro dnešní den neexistuje");
}
@@ -191,7 +192,7 @@ export function finishPizzaOrder(login: string) {
throw Error("Pizza day není ve stavu " + PizzaDayState.LOCKED);
}
clientData.pizzaDay.state = PizzaDayState.ORDERED;
db.set(today, clientData);
await storage.setData(today, clientData);
callNotifikace({ input: { udalost: UdalostEnum.OBJEDNANA_PIZZA, user: clientData?.pizzaDay?.creator } })
return clientData;
}
@@ -203,9 +204,9 @@ export function finishPizzaOrder(login: string) {
* @param login login uživatele
* @returns aktuální data pro uživatele
*/
export function finishPizzaDelivery(login: string, bankAccount?: string, bankAccountHolder?: string) {
export async function finishPizzaDelivery(login: string, bankAccount?: string, bankAccountHolder?: string) {
const today = formatDate(getToday());
const clientData: ClientData = db.get(today);
const clientData: ClientData = await storage.getData(today);
if (!clientData.pizzaDay) {
throw Error("Pizza day pro dnešní den neexistuje");
}
@@ -228,14 +229,15 @@ export function finishPizzaDelivery(login: string, bankAccount?: string, bankAcc
}
}
}
db.set(today, clientData);
await storage.setData(today, clientData);
return clientData;
}
export function initIfNeeded() {
export async function initIfNeeded() {
const today = formatDate(getToday());
if (!db.has(today)) {
db.set(today, getEmptyData());
const hasData = await storage.hasData(today);
if (!hasData) {
await storage.setData(today, getEmptyData());
}
}
@@ -246,9 +248,9 @@ export function initIfNeeded() {
* @param location vybrané "umístění"
* @returns
*/
export function removeChoices(login: string, location: Locations) {
export async function removeChoices(login: string, location: Locations) {
const today = formatDate(getToday());
let data: ClientData = db.get(today);
let data: ClientData = await storage.getData(today);
// TODO zajistit, že neověřený uživatel se stejným loginem nemůže mazat volby ověřeného
if (location in data.choices) {
if (login in data.choices[location]) {
@@ -256,7 +258,7 @@ export function removeChoices(login: string, location: Locations) {
if (Object.keys(data.choices[location]).length === 0) {
delete data.choices[location]
}
db.set(today, data);
await storage.setData(today, data);
}
}
return data;
@@ -271,16 +273,16 @@ export function removeChoices(login: string, location: Locations) {
* @param foodIndex index jídla v jídelním lístku daného umístění, pokud existuje
* @returns
*/
export function removeChoice(login: string, location: Locations, foodIndex: number) {
export async function removeChoice(login: string, location: Locations, foodIndex: number) {
const today = formatDate(getToday());
let data: ClientData = db.get(today);
let data: ClientData = await storage.getData(today);
// TODO řešit ověření uživatele
if (location in data.choices) {
if (login in data.choices[location]) {
const index = data.choices[location][login].options.indexOf(foodIndex);
if (index > -1) {
data.choices[location][login].options.splice(index, 1)
db.set(today, data);
await storage.setData(today, data);
}
}
}
@@ -292,17 +294,19 @@ export function removeChoice(login: string, location: Locations, foodIndex: numb
*
* @param login login uživatele
*/
function removeChoiceIfPresent(login: string) {
async function removeChoiceIfPresent(login: string) {
const today = formatDate(getToday());
let data: ClientData = db.get(today);
let data: ClientData = await storage.getData(today);
for (const key of Object.keys(data.choices)) {
if (login in data.choices[key]) {
delete data.choices[key][login];
if (Object.keys(data.choices[key]).length === 0) {
delete data.choices[key];
}
await storage.setData(today, data);
}
}
return data;
}
/**
@@ -314,10 +318,10 @@ function removeChoiceIfPresent(login: string) {
* @param trusted příznak, zda se jedná o ověřeného uživatele
* @returns aktuální data
*/
export function addChoice(login: string, trusted: boolean, location: Locations, foodIndex?: number) {
initIfNeeded();
export async function addChoice(login: string, trusted: boolean, location: Locations, foodIndex?: number) {
await initIfNeeded();
const today = formatDate(getToday());
let data: ClientData = db.get(today);
let data: ClientData = await storage.getData(today);
// Ověření, že se neověřený užívatel nepokouší přepsat údaje ověřeného
const locations = Object.values(data?.choices);
let found = false;
@@ -333,7 +337,7 @@ export function addChoice(login: string, trusted: boolean, location: Locations,
}
// Pokud měníme pouze lokaci, mažeme případné předchozí
if (foodIndex == null) {
removeChoiceIfPresent(login);
data = await removeChoiceIfPresent(login);
}
if (!(location in data.choices)) {
data.choices[location] = {};
@@ -347,14 +351,14 @@ export function addChoice(login: string, trusted: boolean, location: Locations,
if (foodIndex != null && !data.choices[location][login].options.includes(foodIndex)) {
data.choices[location][login].options.push(foodIndex);
}
db.set(today, data);
await storage.setData(today, data);
return data;
}
// TODO přejmenovat, ať je jasné že to patří k pizza day
export function updateNote(login: string, note?: string) {
export async function updateNote(login: string, note?: string) {
const today = formatDate(getToday());
let clientData: ClientData = db.get(today);
let clientData: ClientData = await storage.getData(today);
if (!clientData.pizzaDay) {
throw Error("Pizza day pro dnešní den neexistuje");
}
@@ -366,6 +370,6 @@ export function updateNote(login: string, note?: string) {
throw Error("Pizza day neobsahuje žádné objednávky uživatele " + login);
}
myOrder.note = note;
db.set(today, clientData);
await storage.setData(today, clientData);
return clientData;
}

28
server/src/storage/StorageInterface.ts Normal file
View File

@@ -0,0 +1,28 @@
import { ClientData } from "../../../types";
/**
* Interface pro úložiště dat.
*
* Aktuálně pouze "primitivní" has, get a set odrážející původní JSON DB.
* Postupem času lze předělat pro efektivnější využití Redis.
*/
export interface StorageInterface {
/**
* Vrátí příznak, zda existují data pro předané datum.
* @param date datum, pro které zjišťujeme data
*/
hasData(date: string): Promise<boolean>;
/**
* Vrátí veškerá data pro předané datum.
* @param date datum, pro které vrátit data
*/
getData(date: string): Promise<ClientData>;
/**
* Uloží data pro předané datum.
* @param date datum, kterému patří ukládaná data
* @param data data pro uložení
*/
setData(date: string, data: ClientData): Promise<void>;
}

19
server/src/storage/index.ts Normal file
View File

@@ -0,0 +1,19 @@
import { StorageInterface } from "./StorageInterface";
import JsonStorage from "./json";
import RedisStorage from "./redis";
const JSON_KEY = 'json';
const REDIS_KEY = 'redis';
let storage: StorageInterface;
if (!process.env.STORAGE || process.env.STORAGE?.toLowerCase() === JSON_KEY) {
storage = new JsonStorage();
} else if (process.env.STORAGE?.toLowerCase() === REDIS_KEY) {
storage = new RedisStorage();
} else {
throw Error("Nepodporovaná hodnota proměnné STORAGE: " + process.env.STORAGE + ", podporované jsou 'json' nebo 'redis'");
}
export default function getStorage(): StorageInterface {
return storage;
}

24
server/src/storage/json.ts Normal file
View File

@@ -0,0 +1,24 @@
import JSONdb from 'simple-json-db';
import { ClientData } from "../../../types";
import { StorageInterface } from "./StorageInterface";
const db = new JSONdb('./data.json');
/**
* Implementace úložiště používající JSON soubor.
*/
export default class JsonStorage implements StorageInterface {
hasData(date: string): Promise<boolean> {
return Promise.resolve(db.has(date));
}
getData(date: string): Promise<ClientData> {
return db.get(date);
}
setData(date: string, data: ClientData): Promise<void> {
db.set(date, data);
return Promise.resolve();
}
}

32
server/src/storage/redis.ts Normal file
View File

@@ -0,0 +1,32 @@
import { RedisClientType, createClient } from 'redis';
import { StorageInterface } from "./StorageInterface";
import { ClientData } from '../../../types';
let client: RedisClientType;
/**
* Implementace úložiště využívající Redis server.
*/
export default class RedisStorage implements StorageInterface {
constructor() {
const HOST = process.env.REDIS_HOST || 'localhost';
const PORT = process.env.REDIS_PORT || 6379;
client = createClient({ url: `redis://${HOST}:${PORT}` });
client.connect();
}
async hasData(date: string) {
const data = await client.json.get(date);
return (data ? true : false);
}
async getData(date: string) {
const data = await client.json.get(date, { path: '.' });
return data as unknown as ClientData;
}
async setData(date: string, data: ClientData) {
await client.json.set(date, '.', data as any);
const check = await client.json.get(date);
}
}