Compare commits
No commits in common. "83c9d090e1dddb2b9f3a4a40b9e12bc8a0fac4be" and "ed9b7dafe025c69bc1ff0cf9c3581d17d0427b14" have entirely different histories.
83c9d090e1
...
ed9b7dafe0
|
@ -19,7 +19,7 @@
|
||||||
"cors": "^2.8.5",
|
"cors": "^2.8.5",
|
||||||
"debug": "^4.3.1",
|
"debug": "^4.3.1",
|
||||||
"dotenv": "^8.2.0",
|
"dotenv": "^8.2.0",
|
||||||
"express": "^4.18.2",
|
"express": "^4.17.1",
|
||||||
"guid-typescript": "^1.0.9",
|
"guid-typescript": "^1.0.9",
|
||||||
"mariadb": "^3.0.2",
|
"mariadb": "^3.0.2",
|
||||||
"random-words": "^1.1.1",
|
"random-words": "^1.1.1",
|
||||||
|
@ -31,9 +31,8 @@
|
||||||
"@types/app-root-path": "^1.2.4",
|
"@types/app-root-path": "^1.2.4",
|
||||||
"@types/bcrypt": "^3.0.1",
|
"@types/bcrypt": "^3.0.1",
|
||||||
"@types/debug": "^4.1.5",
|
"@types/debug": "^4.1.5",
|
||||||
"@types/express": "^4.17.15",
|
"@types/express": "^4.17.11",
|
||||||
"@types/jest": "^28.1.3",
|
"@types/jest": "^28.1.3",
|
||||||
"@types/node": "^18.11.17",
|
|
||||||
"@types/random-words": "^1.1.2",
|
"@types/random-words": "^1.1.2",
|
||||||
"@types/swagger-jsdoc": "^6.0.1",
|
"@types/swagger-jsdoc": "^6.0.1",
|
||||||
"@types/swagger-ui-express": "^4.1.3",
|
"@types/swagger-ui-express": "^4.1.3",
|
||||||
|
@ -44,7 +43,7 @@
|
||||||
"source-map-support": "^0.5.19",
|
"source-map-support": "^0.5.19",
|
||||||
"ts-jest": "^28.0.5",
|
"ts-jest": "^28.0.5",
|
||||||
"tslint": "^6.1.3",
|
"tslint": "^6.1.3",
|
||||||
"typescript": "^4.9.4"
|
"typescript": "^4.1.5"
|
||||||
},
|
},
|
||||||
"jestSonar": {
|
"jestSonar": {
|
||||||
"sonar56x": true,
|
"sonar56x": true,
|
||||||
|
|
|
@ -1,29 +0,0 @@
|
||||||
import * as dotenv from 'dotenv';
|
|
||||||
|
|
||||||
|
|
||||||
dotenv.config();
|
|
||||||
|
|
||||||
export const checkAdminPrivileges = (password: string) => {
|
|
||||||
return password == process.env.ADMIN_CREDENTIAL;
|
|
||||||
}
|
|
||||||
|
|
||||||
export const checkMemberPrivileges = (password: string) => {
|
|
||||||
return password == process.env.MEMBER_CREDENTIAL;
|
|
||||||
}
|
|
||||||
|
|
||||||
export const checkManagementPrivileges = (password: string) => {
|
|
||||||
return password == process.env.MANAGEMENT_CREDENTIAL;
|
|
||||||
}
|
|
||||||
|
|
||||||
export const hasAccess = (calendarName: string, password: string) => {
|
|
||||||
switch (calendarName) {
|
|
||||||
case 'public':
|
|
||||||
return true;
|
|
||||||
case 'members':
|
|
||||||
return checkMemberPrivileges(password);
|
|
||||||
case 'management':
|
|
||||||
return checkManagementPrivileges(password);
|
|
||||||
default:
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -3,10 +3,8 @@
|
||||||
*/
|
*/
|
||||||
|
|
||||||
import express, {Request, Response} from 'express';
|
import express, {Request, Response} from 'express';
|
||||||
import {Event} from './event.interface';
|
|
||||||
import * as EventService from './events.service';
|
import * as EventService from './events.service';
|
||||||
import * as iCalService from './icalgenerator.service';
|
import * as iCalService from './icalgenerator.service';
|
||||||
import * as CredentialService from './credentials.service';
|
|
||||||
import {Guid} from 'guid-typescript';
|
import {Guid} from 'guid-typescript';
|
||||||
import logger from '../../../middleware/logger';
|
import logger from '../../../middleware/logger';
|
||||||
|
|
||||||
|
@ -20,39 +18,17 @@ export const eventsRouter = express.Router();
|
||||||
/**
|
/**
|
||||||
* Constants
|
* Constants
|
||||||
*/
|
*/
|
||||||
export const calendarNames = new Map<string, any>([
|
const fileNames = ['Nachklang_calendar', 'Nachklang_internal_calendar', 'Nachklang_management_calendar'];
|
||||||
['public', {id: 1, name: 'Nachklang_calendar'}],
|
|
||||||
['members', {id: 2, name: 'Nachklang_internal_calendar'}],
|
|
||||||
['management', {id: 3, name: 'Nachklang_management_calendar'}]
|
|
||||||
]);
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Controller Definitions
|
* Controller Definitions
|
||||||
*/
|
*/
|
||||||
|
|
||||||
eventsRouter.get('/:calendar/json', async (req: Request, res: Response) => {
|
eventsRouter.get('/json', async (req: Request, res: Response) => {
|
||||||
try {
|
try {
|
||||||
// Get request params
|
// Get request params
|
||||||
let calendarName: string = req.params.calendar as string ?? '';
|
let calendarId: number = parseInt(req.query.calendar as string ?? '', 10);
|
||||||
let password: string = req.query.password as string ?? '';
|
|
||||||
|
|
||||||
if (calendarName.length < 1) {
|
|
||||||
res.status(401).send({'message': 'Please state the name of the calendar you want events from.'});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!Array.from(calendarNames.keys()).includes(calendarName)) {
|
|
||||||
res.status(401).send({'message': 'Unknown calendar.'});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
let calendarId: number = calendarNames.get(calendarName)!.id;
|
|
||||||
|
|
||||||
if (!CredentialService.hasAccess(calendarName, password)) {
|
|
||||||
res.status(401).send({'message': 'You do not have access to the specified calendar.'});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Get events
|
// Get events
|
||||||
let events = await EventService.getAllEvents(calendarId);
|
let events = await EventService.getAllEvents(calendarId);
|
||||||
|
@ -61,38 +37,20 @@ eventsRouter.get('/:calendar/json', async (req: Request, res: Response) => {
|
||||||
res.status(200).send(events);
|
res.status(200).send(events);
|
||||||
} catch (e: any) {
|
} catch (e: any) {
|
||||||
console.log('Error handling a request: ' + e.message);
|
console.log('Error handling a request: ' + e.message);
|
||||||
res.status(500).send({'message': 'Internal Server Error. Try again later.'});
|
res.status(500).send(JSON.stringify({'message': 'Internal Server Error. Try again later.'}));
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
eventsRouter.get('/:calendar/ical', async (req: Request, res: Response) => {
|
eventsRouter.get('/ical', async (req: Request, res: Response) => {
|
||||||
try {
|
try {
|
||||||
// Get request params
|
// Get request params
|
||||||
let calendarName: string = req.params.calendar as string ?? '';
|
let calendarId: number = parseInt(req.query.calendar as string ?? '', 10);
|
||||||
let password: string = req.query.password as string ?? '';
|
|
||||||
|
|
||||||
if (calendarName.length < 1) {
|
|
||||||
res.status(401).send({'message': 'Please state the name of the calendar you want events from.'});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!Array.from(calendarNames.keys()).includes(calendarName)) {
|
|
||||||
res.status(401).send({'message': 'Unknown calendar.'});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
let calendarId: number = calendarNames.get(calendarName)!.id;
|
|
||||||
|
|
||||||
if (!CredentialService.hasAccess(calendarName, password)) {
|
|
||||||
res.status(401).send({'message': 'You do not have access to the specified calendar.'});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Get events
|
// Get events
|
||||||
let events = await EventService.getAllEvents(calendarId);
|
let events = await EventService.getAllEvents(calendarId);
|
||||||
|
|
||||||
// generate file name
|
// generate file name
|
||||||
let fileName = calendarNames.get(calendarName)!.name;
|
let fileName = fileNames[calendarId];
|
||||||
let file = await iCalService.convertToIcal(events);
|
let file = await iCalService.convertToIcal(events);
|
||||||
|
|
||||||
// Send the ical file back
|
// Send the ical file back
|
||||||
|
@ -101,6 +59,7 @@ eventsRouter.get('/:calendar/ical', async (req: Request, res: Response) => {
|
||||||
} catch (e: any) {
|
} catch (e: any) {
|
||||||
let errorGuid = Guid.create().toString();
|
let errorGuid = Guid.create().toString();
|
||||||
logger.error('Error handling a request: ' + e.message, {reference: errorGuid});
|
logger.error('Error handling a request: ' + e.message, {reference: errorGuid});
|
||||||
|
logger.error('Stacktrace: ' + e.stack, {reference: errorGuid});
|
||||||
res.status(500).send({
|
res.status(500).send({
|
||||||
'status': 'PROCESSING_ERROR',
|
'status': 'PROCESSING_ERROR',
|
||||||
'message': 'Internal Server Error. Try again later.',
|
'message': 'Internal Server Error. Try again later.',
|
||||||
|
@ -108,109 +67,3 @@ eventsRouter.get('/:calendar/ical', async (req: Request, res: Response) => {
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
eventsRouter.post('/', async (req: Request, res: Response) => {
|
|
||||||
try {
|
|
||||||
// Get params
|
|
||||||
let password = req.body.password;
|
|
||||||
|
|
||||||
if (!CredentialService.checkAdminPrivileges(password)) {
|
|
||||||
res.status(403).send({'message': 'Insufficient privileges.'});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (
|
|
||||||
req.body.calendarId === undefined ||
|
|
||||||
isNullOrBlank(req.body.name) ||
|
|
||||||
req.body.startDateTime === undefined ||
|
|
||||||
req.body.endDateTime === undefined
|
|
||||||
) {
|
|
||||||
res.status(401).send({'message': 'Required parameters missing'});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
let event: Event = {
|
|
||||||
event_id: -1,
|
|
||||||
calendar_id: req.body.calendarId,
|
|
||||||
uuid: '',
|
|
||||||
name: req.body.name,
|
|
||||||
description: req.body.description ?? '',
|
|
||||||
start_datetime: new Date(req.body.startDateTime),
|
|
||||||
end_datetime: new Date(req.body.endDateTime),
|
|
||||||
created_date: new Date(),
|
|
||||||
location: req.body.location ?? '',
|
|
||||||
created_by: req.body.createdBy ?? '',
|
|
||||||
url: req.body.url ?? ''
|
|
||||||
};
|
|
||||||
|
|
||||||
let eventId = await EventService.createEvent(event);
|
|
||||||
|
|
||||||
res.status(201).send({'message': 'Event with id ' + eventId + ' was created successfully.'});
|
|
||||||
} catch (e: any) {
|
|
||||||
let errorGuid = Guid.create().toString();
|
|
||||||
logger.error('Error handling a request: ' + e.message, {reference: errorGuid});
|
|
||||||
res.status(500).send({
|
|
||||||
'status': 'PROCESSING_ERROR',
|
|
||||||
'message': 'Internal Server Error. Try again later.',
|
|
||||||
'reference': errorGuid
|
|
||||||
});
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
eventsRouter.put('/:eventId', async (req: Request, res: Response) => {
|
|
||||||
try {
|
|
||||||
// Get params
|
|
||||||
let password = req.body.password;
|
|
||||||
|
|
||||||
if (!CredentialService.checkAdminPrivileges(password)) {
|
|
||||||
res.status(403).send({'message': 'Insufficient privileges.'});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (
|
|
||||||
req.params.eventId === undefined ||
|
|
||||||
req.body.calendarId === undefined ||
|
|
||||||
isNullOrBlank(req.body.name) ||
|
|
||||||
req.body.startDateTime === undefined ||
|
|
||||||
req.body.endDateTime === undefined
|
|
||||||
) {
|
|
||||||
res.status(401).send({'message': 'Required parameters missing'});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
let event: Event = {
|
|
||||||
event_id: parseInt(req.params.eventId, 10),
|
|
||||||
calendar_id: req.body.calendarId,
|
|
||||||
uuid: '',
|
|
||||||
name: req.body.name,
|
|
||||||
description: req.body.description ?? '',
|
|
||||||
start_datetime: new Date(req.body.startDateTime),
|
|
||||||
end_datetime: new Date(req.body.endDateTime),
|
|
||||||
created_date: new Date(),
|
|
||||||
location: req.body.location ?? '',
|
|
||||||
created_by: req.body.createdBy ?? '',
|
|
||||||
url: req.body.url ?? ''
|
|
||||||
};
|
|
||||||
|
|
||||||
let success = await EventService.updateEvent(event);
|
|
||||||
|
|
||||||
|
|
||||||
res.status(200).send({'message': 'Event was successfully updated'});
|
|
||||||
} catch (e: any) {
|
|
||||||
let errorGuid = Guid.create().toString();
|
|
||||||
logger.error('Error handling a request: ' + e.message, {reference: errorGuid});
|
|
||||||
res.status(500).send({
|
|
||||||
'status': 'PROCESSING_ERROR',
|
|
||||||
'message': 'Internal Server Error. Try again later.',
|
|
||||||
'reference': errorGuid
|
|
||||||
});
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Checks if a given string is null, undefined or blank
|
|
||||||
* @param str The string to check
|
|
||||||
*/
|
|
||||||
function isNullOrBlank(str: string | null): boolean {
|
|
||||||
return str === null || str === undefined || str.trim() === '';
|
|
||||||
}
|
|
||||||
|
|
|
@ -1,4 +1,5 @@
|
||||||
import * as dotenv from 'dotenv';
|
import * as dotenv from 'dotenv';
|
||||||
|
import * as bcrypt from 'bcrypt';
|
||||||
import {Guid} from 'guid-typescript';
|
import {Guid} from 'guid-typescript';
|
||||||
import {Event} from './event.interface';
|
import {Event} from './event.interface';
|
||||||
import {NachklangCalendarDB} from '../Calendar.db';
|
import {NachklangCalendarDB} from '../Calendar.db';
|
||||||
|
@ -29,45 +30,3 @@ export const getAllEvents = async (calendarId: number): Promise<Event[]> => {
|
||||||
await conn.end();
|
await conn.end();
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
/**
|
|
||||||
* Create the given event in the database
|
|
||||||
* @param event The event to create
|
|
||||||
*/
|
|
||||||
export const createEvent = async (event: Event): Promise<number> => {
|
|
||||||
let conn = await NachklangCalendarDB.getConnection();
|
|
||||||
try {
|
|
||||||
let eventUUID = Guid.create().toString();
|
|
||||||
const eventsQuery = 'INSERT INTO events (calendar_id, uuid, name, description, start_datetime, end_datetime, location, created_by, url) VALUES (?,?,?,?,?,?,?,?,?) RETURNING event_id';
|
|
||||||
const eventsRes = await conn.query(eventsQuery, [event.calendar_id, eventUUID, event.name, event.description, event.start_datetime, event.end_datetime, event.location, event.created_by, event.url]);
|
|
||||||
|
|
||||||
return eventsRes[0].event_id;
|
|
||||||
} catch (err) {
|
|
||||||
throw err;
|
|
||||||
} finally {
|
|
||||||
// Return connection
|
|
||||||
await conn.end();
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Update the given event in the database
|
|
||||||
* @param event The event to update
|
|
||||||
*/
|
|
||||||
export const updateEvent = async (event: Event): Promise<boolean> => {
|
|
||||||
let conn = await NachklangCalendarDB.getConnection();
|
|
||||||
try {
|
|
||||||
let eventUUID = Guid.create().toString();
|
|
||||||
const eventsQuery = 'UPDATE events SET name = ?, description = ?, start_datetime = ?, end_datetime = ?, location = ?, created_by = ?, url = ? WHERE event_id = ?';
|
|
||||||
const eventsRes = await conn.query(eventsQuery, [event.name, event.description, event.start_datetime, event.end_datetime, event.location, event.created_by, event.url, event.event_id]);
|
|
||||||
|
|
||||||
console.log(eventsRes);
|
|
||||||
|
|
||||||
return eventsRes.affectedRows === 1;
|
|
||||||
} catch (err) {
|
|
||||||
throw err;
|
|
||||||
} finally {
|
|
||||||
// Return connection
|
|
||||||
await conn.end();
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
|
@ -49,7 +49,7 @@ const serializeIcalEvent = (icalevent: iCalEvent): string => {
|
||||||
const generateHeaderInfo = (ical: iCalFile) => {
|
const generateHeaderInfo = (ical: iCalFile) => {
|
||||||
ical.header = 'BEGIN:VCALENDAR\n' +
|
ical.header = 'BEGIN:VCALENDAR\n' +
|
||||||
'VERSION:2.0\n' +
|
'VERSION:2.0\n' +
|
||||||
'PRODID:-//Nachklang e.V./Nachklang Calendar//NONSGML v1.0//EN\n' +
|
'PRODID:-//hacksw/handcal//NONSGML v1.0//EN\n' +
|
||||||
'CALSCALE:GREGORIAN\n' +
|
'CALSCALE:GREGORIAN\n' +
|
||||||
'BEGIN:VTIMEZONE\n' +
|
'BEGIN:VTIMEZONE\n' +
|
||||||
'TZID:Europe/Berlin\n' +
|
'TZID:Europe/Berlin\n' +
|
||||||
|
|
Loading…
Reference in New Issue
Block a user