Compare commits
5 Commits
aa00542a03
...
feat/jdeme
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
2f39d04120 | ||
|
|
8137ca6fc0 | ||
|
|
3817126ac0 | ||
|
|
c1856b2eee | ||
|
|
eaf0bc353d |
@@ -189,7 +189,7 @@ function App() {
|
||||
}
|
||||
}, [auth?.login, easterEgg?.duration, easterEgg?.url, eggImage]);
|
||||
|
||||
const doAddClickFoodChoice = async (location: Locations, foodIndex: number) => {
|
||||
const doAddClickFoodChoice = async (location: Locations, foodIndex?: number) => {
|
||||
const locationKey = Object.keys(Locations).find(key => Locations[key as keyof typeof Locations] === location) as LocationKey;
|
||||
if (auth?.login) {
|
||||
await errorHandler(() => addChoice(locationKey, foodIndex, dayIndex));
|
||||
@@ -206,9 +206,9 @@ function App() {
|
||||
}
|
||||
}
|
||||
|
||||
const doJdemeObed = async () => {
|
||||
const doJdemeObed = async (locationKey: LocationKey) => {
|
||||
if (auth?.login) {
|
||||
await jdemeObed();
|
||||
await jdemeObed(locationKey);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -338,15 +338,16 @@ function App() {
|
||||
}
|
||||
}
|
||||
|
||||
const renderFoodTable = (name: string, location: Locations, menu: DayMenu) => {
|
||||
const renderFoodTable = (location: Locations, menu: DayMenu) => {
|
||||
let content;
|
||||
if (menu?.closed) {
|
||||
content = <h3>Zavřeno</h3>
|
||||
} else if (menu?.food?.length > 0) {
|
||||
const hideSoups = settings?.hideSoups;
|
||||
content = <Table striped bordered hover>
|
||||
<tbody style={{ cursor: 'pointer' }}>
|
||||
{menu.food.filter(f => (settings?.hideSoups ? !f.isSoup : true)).map((f: any, index: number) =>
|
||||
<tr key={index} onClick={() => doAddClickFoodChoice(location, index)}>
|
||||
{menu.food.filter(f => (hideSoups ? !f.isSoup : true)).map((f: any, index: number) =>
|
||||
<tr key={index} onClick={() => doAddClickFoodChoice(location, hideSoups ? index + 1 : index)}>
|
||||
<td>{f.amount}</td>
|
||||
<td>{f.name}</td>
|
||||
<td>{f.price}</td>
|
||||
@@ -358,7 +359,7 @@ function App() {
|
||||
content = <h3>Chyba načtení dat</h3>
|
||||
}
|
||||
return <Col md={12} lg={3} className='mt-3'>
|
||||
<h3>{name}</h3>
|
||||
<h3 style={{ cursor: 'pointer' }} onClick={() => doAddClickFoodChoice(location, undefined)}>{location}</h3>
|
||||
{menu?.lastUpdate && <small>Poslední aktualizace: {getHumanDateTime(new Date(menu.lastUpdate))}</small>}
|
||||
{content}
|
||||
</Col>
|
||||
@@ -420,11 +421,11 @@ function App() {
|
||||
</div>
|
||||
}
|
||||
<Row className='food-tables'>
|
||||
{food[Restaurants.SLADOVNICKA] && renderFoodTable('Sladovnická', Locations.SLADOVNICKA, food[Restaurants.SLADOVNICKA])}
|
||||
{/* {food[Restaurants.UMOTLIKU] && renderFoodTable('U Motlíků', food[Restaurants.UMOTLIKU])} */}
|
||||
{food[Restaurants.TECHTOWER] && renderFoodTable('TechTower', Locations.TECHTOWER, food[Restaurants.TECHTOWER])}
|
||||
{food[Restaurants.ZASTAVKAUMICHALA] && renderFoodTable('Zastávka u Michala', Locations.ZASTAVKAUMICHALA, food[Restaurants.ZASTAVKAUMICHALA])}
|
||||
{food[Restaurants.SENKSERIKOVA] && renderFoodTable('Pivovarský šenk Šeříková', Locations.SENKSERIKOVA, food[Restaurants.SENKSERIKOVA])}
|
||||
{food[Restaurants.SLADOVNICKA] && renderFoodTable(Locations.SLADOVNICKA, food[Restaurants.SLADOVNICKA])}
|
||||
{/* {food[Restaurants.UMOTLIKU] && renderFoodTable(food[Restaurants.UMOTLIKU])} */}
|
||||
{food[Restaurants.TECHTOWER] && renderFoodTable(Locations.TECHTOWER, food[Restaurants.TECHTOWER])}
|
||||
{food[Restaurants.ZASTAVKAUMICHALA] && renderFoodTable(Locations.ZASTAVKAUMICHALA, food[Restaurants.ZASTAVKAUMICHALA])}
|
||||
{food[Restaurants.SENKSERIKOVA] && renderFoodTable(Locations.SENKSERIKOVA, food[Restaurants.SENKSERIKOVA])}
|
||||
</Row>
|
||||
<div className='content-wrapper'>
|
||||
<div className='content'>
|
||||
@@ -470,6 +471,7 @@ function App() {
|
||||
return;
|
||||
}
|
||||
const locationLoginList = Object.entries(loginObject);
|
||||
const disabled = false;
|
||||
return (
|
||||
<tr key={key}>
|
||||
<td>{locationName}</td>
|
||||
@@ -518,6 +520,9 @@ function App() {
|
||||
</tbody>
|
||||
</Table>
|
||||
</td>
|
||||
<td>
|
||||
<Button onClick={() => doJdemeObed(locationKey)} disabled={false}>Jdeme na oběd</Button>
|
||||
</td>
|
||||
</tr>)
|
||||
}
|
||||
)}
|
||||
@@ -541,7 +546,6 @@ function App() {
|
||||
setLoadingPizzaDay(true);
|
||||
await createPizzaDay().then(() => setLoadingPizzaDay(false));
|
||||
}}>Založit Pizza day</Button>
|
||||
<Button onClick={doJdemeObed} style={{ marginLeft: "14px" }}>Jdeme na oběd !</Button>
|
||||
</>
|
||||
}
|
||||
</div>
|
||||
|
||||
@@ -1,4 +1,12 @@
|
||||
import { AddChoiceRequest, ChangeDepartureTimeRequest, LocationKey, RemoveChoiceRequest, RemoveChoicesRequest, UpdateNoteRequest } from "../../../types";
|
||||
import {
|
||||
AddChoiceRequest,
|
||||
ChangeDepartureTimeRequest,
|
||||
JdemeObedRequest,
|
||||
LocationKey,
|
||||
RemoveChoiceRequest,
|
||||
RemoveChoicesRequest,
|
||||
UpdateNoteRequest
|
||||
} from "../../../types";
|
||||
import { api } from "./Api";
|
||||
|
||||
const FOOD_API_PREFIX = '/api/food';
|
||||
@@ -23,6 +31,6 @@ export const changeDepartureTime = async (time: string, dayIndex?: number) => {
|
||||
return await api.post<ChangeDepartureTimeRequest, void>(`${FOOD_API_PREFIX}/changeDepartureTime`, { time, dayIndex });
|
||||
}
|
||||
|
||||
export const jdemeObed = async () => {
|
||||
return await api.post<undefined, void>(`${FOOD_API_PREFIX}/jdemeObed`);
|
||||
export const jdemeObed = async (locationKey: LocationKey) => {
|
||||
return await api.post<JdemeObedRequest, void>(`${FOOD_API_PREFIX}/jdemeObed`, { locationKey });
|
||||
}
|
||||
|
||||
@@ -1,58 +1,58 @@
|
||||
/** Notifikace pro gotify*/
|
||||
import { ClientData, GotifyServer, NotififaceInput, NotifikaceData } from '../../types';
|
||||
import axios, { AxiosError } from 'axios';
|
||||
/** Notifikace */
|
||||
import {ClientData, Locations, NotififaceInput} from '../../types';
|
||||
import axios from 'axios';
|
||||
import dotenv from 'dotenv';
|
||||
import path from 'path';
|
||||
import { getToday } from "./service";
|
||||
import { formatDate, getUsersByLocation } from "./utils";
|
||||
import {formatDate, getUsersByLocation, getHumanTime} from "./utils";
|
||||
import getStorage from "./storage";
|
||||
|
||||
const storage = getStorage();
|
||||
const ENVIRONMENT = process.env.NODE_ENV || 'production'
|
||||
dotenv.config({ path: path.resolve(__dirname, `../.env.${ENVIRONMENT}`) });
|
||||
|
||||
const gotifyDataRaw = process.env.GOTIFY_SERVERS_AND_KEYS || "{}";
|
||||
const gotifyData: GotifyServer[] = JSON.parse(gotifyDataRaw);
|
||||
export const gotifyCall = async (data: NotififaceInput, gotifyServers?: GotifyServer[]): Promise<any[]> => {
|
||||
if (!Array.isArray(gotifyServers)) {
|
||||
return []
|
||||
}
|
||||
const urls = gotifyServers.flatMap(gotifyServer =>
|
||||
gotifyServer.api_keys.map(apiKey => `${gotifyServer.server}/message?token=${apiKey}`));
|
||||
|
||||
const dataPayload = {
|
||||
title: "Luncher",
|
||||
message: `${data.udalost} - spustil:${data.user}`,
|
||||
priority: 7,
|
||||
};
|
||||
|
||||
const headers = { "Content-Type": "application/json" };
|
||||
|
||||
const promises = urls.map(url =>
|
||||
axios.post(url, dataPayload, { headers }).then(response => {
|
||||
response.data = {
|
||||
success: true,
|
||||
message: "Notifikace doručena",
|
||||
};
|
||||
return response;
|
||||
}).catch(error => {
|
||||
if (axios.isAxiosError(error)) {
|
||||
const axiosError = error as AxiosError;
|
||||
if (axiosError.response) {
|
||||
axiosError.response.data = {
|
||||
success: false,
|
||||
message: "fail",
|
||||
};
|
||||
console.log(error)
|
||||
return axiosError.response;
|
||||
}
|
||||
}
|
||||
// Handle unknown error without a response
|
||||
console.log(error, "unknown error");
|
||||
})
|
||||
);
|
||||
return promises;
|
||||
};
|
||||
// const gotifyDataRaw = process.env.GOTIFY_SERVERS_AND_KEYS || "{}";
|
||||
// const gotifyData: GotifyServer[] = JSON.parse(gotifyDataRaw);
|
||||
// export const gotifyCall = async (data: NotififaceInput, gotifyServers?: GotifyServer[]): Promise<any[]> => {
|
||||
// if (!Array.isArray(gotifyServers)) {
|
||||
// return []
|
||||
// }
|
||||
// const urls = gotifyServers.flatMap(gotifyServer =>
|
||||
// gotifyServer.api_keys.map(apiKey => `${gotifyServer.server}/message?token=${apiKey}`));
|
||||
//
|
||||
// const dataPayload = {
|
||||
// title: "Luncher",
|
||||
// message: `${data.udalost} - spustil:${data.user}`,
|
||||
// priority: 7,
|
||||
// };
|
||||
//
|
||||
// const headers = { "Content-Type": "application/json" };
|
||||
//
|
||||
// const promises = urls.map(url =>
|
||||
// axios.post(url, dataPayload, { headers }).then(response => {
|
||||
// response.data = {
|
||||
// success: true,
|
||||
// message: "Notifikace doručena",
|
||||
// };
|
||||
// return response;
|
||||
// }).catch(error => {
|
||||
// if (axios.isAxiosError(error)) {
|
||||
// const axiosError = error as AxiosError;
|
||||
// if (axiosError.response) {
|
||||
// axiosError.response.data = {
|
||||
// success: false,
|
||||
// message: "fail",
|
||||
// };
|
||||
// console.log(error)
|
||||
// return axiosError.response;
|
||||
// }
|
||||
// }
|
||||
// // Handle unknown error without a response
|
||||
// console.log(error, "unknown error");
|
||||
// })
|
||||
// );
|
||||
// return promises;
|
||||
// };
|
||||
|
||||
export const ntfyCall = async (data: NotififaceInput) => {
|
||||
const url = process.env.NTFY_HOST
|
||||
@@ -72,10 +72,10 @@ export const ntfyCall = async (data: NotififaceInput) => {
|
||||
}
|
||||
const today = formatDate(getToday());
|
||||
let clientData: ClientData = await storage.getData(today);
|
||||
const userByCLocation = getUsersByLocation(clientData.choices, data.user)
|
||||
const usersByLocation = getUsersByLocation(clientData.choices, data.user)
|
||||
|
||||
const token = Buffer.from(`${username}:${password}`, 'utf8').toString('base64');
|
||||
const promises = userByCLocation.map(async user => {
|
||||
const promises = usersByLocation.map(async user => {
|
||||
try {
|
||||
// Odstraníme mezery a diakritiku a převedeme na lowercase
|
||||
const topic = user.normalize('NFD').replace(' ', '').replace(/[\u0300-\u036f]/g, '').toLowerCase();
|
||||
@@ -97,27 +97,64 @@ export const ntfyCall = async (data: NotififaceInput) => {
|
||||
return promises;
|
||||
|
||||
}
|
||||
|
||||
export const teamsCall = async (data: NotififaceInput) => {
|
||||
const url = process.env.TEAMS_WEBHOOK_URL;
|
||||
if (!url) {
|
||||
console.log("TEAMS_WEBHOOK_URL není definován v env")
|
||||
return
|
||||
}
|
||||
const title = data.udalost;
|
||||
// const today = formatDate(getToday());
|
||||
// let clientData: ClientData = await storage.getData(today);
|
||||
// const usersByLocation = getUsersByLocation(clientData.choices, data.user)
|
||||
let location = data.locationKey ? ` odcházíme do ${Locations[data.locationKey] ?? ''}` : ' jdeme na oběd';
|
||||
const message = 'V ' + getHumanTime(getToday()) + location;
|
||||
const card = {
|
||||
'@type': 'MessageCard',
|
||||
'@context': 'http://schema.org/extensions',
|
||||
'themeColor': "0072C6", // light blue
|
||||
summary: 'Summary description',
|
||||
sections: [
|
||||
{
|
||||
activityTitle: title,
|
||||
text: message,
|
||||
},
|
||||
],
|
||||
};
|
||||
|
||||
if (!url) {
|
||||
console.log("TEAMS_WEBHOOK_URL není definován v env")
|
||||
return
|
||||
}
|
||||
|
||||
try {
|
||||
const response = await axios.post(url, card, {
|
||||
headers: {
|
||||
'content-type': 'application/vnd.microsoft.teams.card.o365connector'
|
||||
},
|
||||
});
|
||||
return `${response.status} - ${response.statusText}`;
|
||||
} catch (err) {
|
||||
return err;
|
||||
}
|
||||
}
|
||||
|
||||
/** Zavolá notifikace na všechny konfigurované způsoby notifikace, přetížení proměných na false pro jednotlivé způsoby je vypne*/
|
||||
export const callNotifikace = async ({ input, teams = true, gotify = false, ntfy = true }: NotifikaceData) => {
|
||||
export const callNotifikace = async (input: NotififaceInput) => {
|
||||
const notifications = [];
|
||||
if (ntfy) {
|
||||
|
||||
const ntfyPromises = await ntfyCall(input);
|
||||
if (ntfyPromises) {
|
||||
notifications.push(...ntfyPromises);
|
||||
}
|
||||
const teamsPromises = await teamsCall(input);
|
||||
if (teamsPromises) {
|
||||
notifications.push(teamsPromises);
|
||||
}
|
||||
/* Zatím není
|
||||
if (teams) {
|
||||
notifications.push(teamsCall(input));
|
||||
}*/
|
||||
|
||||
// Add more notifications as necessary
|
||||
|
||||
// gotify bych řekl, že už je deprecated
|
||||
if (gotify) {
|
||||
const gotifyPromises = await gotifyCall(input, gotifyData);
|
||||
notifications.push(...gotifyPromises);
|
||||
}
|
||||
// const gotifyPromises = await gotifyCall(input, gotifyData);
|
||||
// notifications.push(...gotifyPromises);
|
||||
|
||||
try {
|
||||
const results = await Promise.all(notifications);
|
||||
|
||||
@@ -52,7 +52,7 @@ export async function createPizzaDay(creator: string): Promise<ClientData> {
|
||||
const pizzaList = await getPizzaList();
|
||||
const data: ClientData = { pizzaDay: { state: PizzaDayState.CREATED, creator, orders: [] }, pizzaList, ...clientData };
|
||||
await storage.setData(today, data);
|
||||
callNotifikace({ input: { udalost: UdalostEnum.ZAHAJENA_PIZZA, user: creator } })
|
||||
callNotifikace({ udalost: UdalostEnum.ZAHAJENA_PIZZA, user: creator })
|
||||
return data;
|
||||
}
|
||||
|
||||
@@ -207,7 +207,7 @@ export async function finishPizzaOrder(login: string) {
|
||||
}
|
||||
clientData.pizzaDay.state = PizzaDayState.ORDERED;
|
||||
await storage.setData(today, clientData);
|
||||
callNotifikace({ input: { udalost: UdalostEnum.OBJEDNANA_PIZZA, user: clientData?.pizzaDay?.creator } })
|
||||
callNotifikace({ udalost: UdalostEnum.OBJEDNANA_PIZZA, user: clientData?.pizzaDay?.creator })
|
||||
return clientData;
|
||||
}
|
||||
|
||||
|
||||
@@ -4,7 +4,16 @@ import { addChoice, addVolatileData, getDateForWeekIndex, getToday, removeChoice
|
||||
import { getDayOfWeekIndex, parseToken } from "../utils";
|
||||
import { getWebsocket } from "../websocket";
|
||||
import { callNotifikace } from "../notifikace";
|
||||
import { AddChoiceRequest, ChangeDepartureTimeRequest, IDayIndex, RemoveChoiceRequest, RemoveChoicesRequest, UdalostEnum, UpdateNoteRequest } from "../../../types";
|
||||
import {
|
||||
AddChoiceRequest,
|
||||
ChangeDepartureTimeRequest,
|
||||
IDayIndex,
|
||||
JdemeObedRequest,
|
||||
RemoveChoiceRequest,
|
||||
RemoveChoicesRequest,
|
||||
UdalostEnum,
|
||||
UpdateNoteRequest
|
||||
} from "../../../types";
|
||||
|
||||
/**
|
||||
* Ověří a vrátí index dne v týdnu z požadavku, za předpokladu, že byl předán, a je zároveň
|
||||
@@ -133,10 +142,10 @@ router.post("/changeDepartureTime", async (req: Request<{}, any, ChangeDeparture
|
||||
} catch (e: any) { next(e) }
|
||||
});
|
||||
|
||||
router.post("/jdemeObed", async (req, res, next) => {
|
||||
router.post("/jdemeObed", async (req: Request<{}, any, JdemeObedRequest>, res, next) => {
|
||||
const login = getLogin(parseToken(req));
|
||||
try {
|
||||
await callNotifikace({ input: { user: login, udalost: UdalostEnum.JDEME_OBED }, gotify: false })
|
||||
await callNotifikace({ user: login, udalost: UdalostEnum.JDEME_OBED, locationKey: req.body.locationKey });
|
||||
res.status(200).json({});
|
||||
} catch (e: any) { next(e) }
|
||||
});
|
||||
|
||||
@@ -18,6 +18,8 @@ export type RemoveChoiceRequest = IDayIndex & ILocationKey & {
|
||||
foodIndex: number,
|
||||
}
|
||||
|
||||
export type JdemeObedRequest = ILocationKey;
|
||||
|
||||
export type UpdateNoteRequest = IDayIndex & {
|
||||
note?: string,
|
||||
}
|
||||
|
||||
@@ -131,21 +131,15 @@ export type LocationKey = keyof typeof Locations;
|
||||
export enum UdalostEnum {
|
||||
ZAHAJENA_PIZZA = "Zahájen pizza day",
|
||||
OBJEDNANA_PIZZA = "Objednána pizza",
|
||||
JDEME_OBED = "Jdeme oběd",
|
||||
JDEME_OBED = "Jdeme na oběd",
|
||||
}
|
||||
|
||||
export type NotififaceInput = {
|
||||
locationKey?: LocationKey,
|
||||
udalost: UdalostEnum,
|
||||
user: string,
|
||||
}
|
||||
|
||||
export type NotifikaceData = {
|
||||
input: NotififaceInput,
|
||||
gotify?: boolean,
|
||||
teams?: boolean,
|
||||
ntfy?: boolean,
|
||||
}
|
||||
|
||||
export type GotifyServer = {
|
||||
server: string;
|
||||
api_keys: string[];
|
||||
|
||||
Reference in New Issue
Block a user