Compare commits

...

41 commits

Author SHA1 Message Date
fa5e778d0c 1.4.2 2025-04-18 11:10:45 +02:00
c2c782985c Merge pull request 'patches v1.4.2' (#91) from develop into main
Reviewed-on: #91
2025-04-18 09:10:13 +00:00
57848ff29b Merge branch 'main' into develop 2025-04-18 09:09:40 +00:00
3a956919b2 hotfix: template backup restore 2025-04-17 13:41:04 +02:00
77fd3697b3 1.4.1 2025-04-17 09:26:21 +02:00
412871842f Merge pull request 'patches v1.4.1' (#90) from develop into main
Reviewed-on: #90
2025-04-17 07:24:34 +00:00
7910b561ea Merge branch 'main' into develop 2025-04-17 07:24:25 +00:00
097236c3e0 hotfix: backup failed of queryId 2025-04-17 09:22:41 +02:00
8bee509090 fix: pass updatedAt in response 2025-04-17 09:17:31 +02:00
7e66353da1 1.4.0 2025-04-16 17:02:29 +02:00
839360f380 Merge pull request 'minor v1.4.0' (#89) from develop into main
Reviewed-on: #89
2025-04-16 15:01:05 +00:00
a43d755fe8 Merge branch 'main' into develop 2025-04-16 15:00:47 +00:00
78d0e9b8a9 Merge pull request 'feature/#42-query-builder-joins' (#88) from feature/#42-query-builder-joins into develop
Reviewed-on: #88
2025-04-16 14:39:48 +00:00
fd2f49f175 custom join by condition 2025-04-16 16:35:03 +02:00
6d5d8d9ded extend join structure for custom join 2025-04-16 16:11:33 +02:00
f1ed6d095a enhance: add updateAt column to query 2025-04-16 11:33:11 +02:00
9fefd93f09 Merge pull request '#41-query-builder-sorting' (#87) from #41-query-builder-sorting into develop
Reviewed-on: #87
2025-04-15 08:47:22 +00:00
68ddd4dec4 query builder where clause error 2025-04-15 10:29:40 +02:00
e08b7e8683 compatability layer 2025-04-15 10:09:08 +02:00
dbafd568dd sort by new query structure 2025-04-15 10:02:15 +02:00
16f6846d89 enhance: add endpoint to fetch query data by query store id 2025-04-14 09:28:26 +02:00
fdf67d4763 Merge pull request 'version-update' (#86) from version-update into develop
Reviewed-on: #86
2025-04-13 14:39:36 +00:00
55d7ce2eee update 2025-04-13 16:28:47 +02:00
5923e650fa update packages 2025-04-12 15:18:31 +02:00
d6ae83415d 1.3.12 2025-04-11 08:14:58 +02:00
dff3e49aeb Merge pull request 'patches v1.3.12' (#84) from develop into main
Reviewed-on: #84
2025-04-11 06:13:56 +00:00
f914cf25a6 Merge branch 'main' into develop 2025-04-11 06:13:52 +00:00
b934953aca hotfix: column type of newsletter texts 2025-04-11 08:13:55 +02:00
427e5d9288 1.3.11 2025-04-10 12:48:32 +02:00
81ecfcee1e Merge pull request 'patches v1.3.11' (#83) from develop into main
Reviewed-on: #83
2025-04-10 10:47:12 +00:00
cee8912191 Merge branch 'main' into develop 2025-04-10 10:47:00 +00:00
2e88c8db54 undo: count of print 2025-04-10 12:45:29 +02:00
2a7a0ad523 fix: name of job emit 2025-04-10 12:32:08 +02:00
2942d9a059 fix: sort dates in newsletter print 2025-04-10 12:28:41 +02:00
8e80901c0f optimize: browser open / close at sequential printing 2025-04-10 12:28:26 +02:00
e3ff3456ad fix: member commumication update 2025-04-10 10:02:32 +02:00
a660642bbb fix: string replacement on all occurances 2025-04-10 08:07:11 +02:00
8c333b1b89 enhance: provide count of receivers at newsletter 2025-04-10 08:02:32 +02:00
43f397f0e2 fix: prevent whitespace in printout filename 2025-04-09 20:08:19 +02:00
a05e7fcf63 fix: prevent print all by empty ids array 2025-04-09 20:07:56 +02:00
74ff6838cc populate Admin Rights by Ownership to permission object 2025-04-08 09:26:18 +02:00
27 changed files with 2040 additions and 1896 deletions

View file

@ -1,4 +1,4 @@
FROM node:18-alpine AS build FROM node:22-alpine AS build
RUN apk add --no-cache \ RUN apk add --no-cache \
chromium \ chromium \
@ -20,7 +20,7 @@ COPY . /app
RUN npm run build RUN npm run build
FROM node:18-alpine AS prod FROM node:22-alpine AS prod
RUN apk add --no-cache \ RUN apk add --no-cache \
chromium \ chromium \

3251
package-lock.json generated

File diff suppressed because it is too large Load diff

View file

@ -1,6 +1,6 @@
{ {
"name": "ff-admin-server", "name": "ff-admin-server",
"version": "1.3.10", "version": "1.4.2",
"description": "Feuerwehr/Verein Mitgliederverwaltung Server", "description": "Feuerwehr/Verein Mitgliederverwaltung Server",
"main": "dist/index.js", "main": "dist/index.js",
"scripts": { "scripts": {
@ -26,7 +26,7 @@
"dependencies": { "dependencies": {
"cors": "^2.8.5", "cors": "^2.8.5",
"dotenv": "^16.4.5", "dotenv": "^16.4.5",
"express": "^5.0.0-beta.3", "express": "^5.1.0",
"express-rate-limit": "^7.5.0", "express-rate-limit": "^7.5.0",
"express-validator": "^7.2.1", "express-validator": "^7.2.1",
"handlebars": "^4.7.8", "handlebars": "^4.7.8",
@ -41,10 +41,10 @@
"multer": "^1.4.5-lts.1", "multer": "^1.4.5-lts.1",
"mysql": "^2.18.1", "mysql": "^2.18.1",
"node-schedule": "^2.1.1", "node-schedule": "^2.1.1",
"nodemailer": "^6.9.14", "nodemailer": "^6.10.1",
"pdf-lib": "^1.17.1", "pdf-lib": "^1.17.1",
"pg": "^8.13.1", "pg": "^8.13.1",
"puppeteer": "^23.11.1", "puppeteer": "^24.6.1",
"qrcode": "^1.5.4", "qrcode": "^1.5.4",
"reflect-metadata": "^0.2.2", "reflect-metadata": "^0.2.2",
"rss-parser": "^3.13.0", "rss-parser": "^3.13.0",
@ -52,25 +52,26 @@
"speakeasy": "^2.0.0", "speakeasy": "^2.0.0",
"sqlite3": "^5.1.7", "sqlite3": "^5.1.7",
"typeorm": "^0.3.20", "typeorm": "^0.3.20",
"uuid": "^10.0.0" "uuid": "^11.1.0"
}, },
"devDependencies": { "devDependencies": {
"@types/cors": "^2.8.14", "@types/cors": "^2.8.14",
"@types/express": "^4.17.17", "@types/express": "^5.0.1",
"@types/ip": "^1.1.3", "@types/ip": "^1.1.3",
"@types/jsonwebtoken": "^9.0.6", "@types/jsonwebtoken": "^9.0.6",
"@types/lodash.uniqby": "^4.7.9", "@types/lodash.uniqby": "^4.7.9",
"@types/morgan": "^1.9.9", "@types/morgan": "^1.9.9",
"@types/ms": "^0.7.34", "@types/ms": "^2.1.0",
"@types/multer": "^1.4.12", "@types/multer": "^1.4.12",
"@types/mysql": "^2.15.21", "@types/mysql": "^2.15.21",
"@types/node": "^16.18.41", "@types/node": "^22.14.1",
"@types/node-schedule": "^2.1.6", "@types/node-schedule": "^2.1.6",
"@types/nodemailer": "^6.4.14", "@types/nodemailer": "^6.4.14",
"@types/pg": "~8.11.12",
"@types/qrcode": "~1.5.5", "@types/qrcode": "~1.5.5",
"@types/speakeasy": "^2.0.10", "@types/speakeasy": "^2.0.10",
"@types/uuid": "^9.0.2", "@types/uuid": "^10.0.0",
"ts-node": "10.7.0", "ts-node": "10.9.2",
"typescript": "^4.5.2" "typescript": "^5.8.3"
} }
} }

View file

@ -18,6 +18,17 @@ export default abstract class CommunicationCommandHandler {
let insertId = -1; let insertId = -1;
return await dataSource return await dataSource
.transaction(async (manager) => { .transaction(async (manager) => {
if (createCommunication.isSendNewsletter) {
await manager
.createQueryBuilder()
.update(communication)
.set({
isSendNewsletter: false,
})
.where("memberId = :memberId", { memberId: createCommunication.memberId })
.execute();
}
await manager await manager
.createQueryBuilder() .createQueryBuilder()
.insert() .insert()
@ -40,16 +51,6 @@ export default abstract class CommunicationCommandHandler {
.then((result) => { .then((result) => {
insertId = result.identifiers[0].id; insertId = result.identifiers[0].id;
}); });
await manager
.createQueryBuilder()
.update(communication)
.set({
isSendNewsletter: false,
})
.where("memberId = :memberId", { memberId: createCommunication.memberId })
.andWhere("id <> :id", { id: insertId })
.execute();
}) })
.then(() => { .then(() => {
return insertId; return insertId;
@ -67,6 +68,17 @@ export default abstract class CommunicationCommandHandler {
static async update(updateCommunication: UpdateCommunicationCommand): Promise<void> { static async update(updateCommunication: UpdateCommunicationCommand): Promise<void> {
return await dataSource return await dataSource
.transaction(async (manager) => { .transaction(async (manager) => {
if (updateCommunication.isSendNewsletter) {
await manager
.createQueryBuilder()
.update(communication)
.set({
isSendNewsletter: false,
})
.where("memberId = :memberId", { memberId: updateCommunication.memberId })
.execute();
}
await manager await manager
.createQueryBuilder() .createQueryBuilder()
.update(communication) .update(communication)
@ -85,16 +97,6 @@ export default abstract class CommunicationCommandHandler {
.where("id = :id", { id: updateCommunication.id }) .where("id = :id", { id: updateCommunication.id })
.andWhere("memberId = :memberId", { memberId: updateCommunication.memberId }) .andWhere("memberId = :memberId", { memberId: updateCommunication.memberId })
.execute(); .execute();
await manager
.createQueryBuilder()
.update(communication)
.set({
isSendNewsletter: false,
})
.where("memberId = :memberId", { memberId: updateCommunication.memberId })
.andWhere("id <> :id", { id: updateCommunication.id })
.execute();
}) })
.then(() => {}) .then(() => {})
.catch((err) => { .catch((err) => {

View file

@ -94,7 +94,7 @@ export async function getNewsletterPrintoutsById(req: Request, res: Response): P
let newsletter = await NewsletterService.getById(newsletterId); let newsletter = await NewsletterService.getById(newsletterId);
let filesInFolder = FileSystemHelper.getFilesInDirectory( let filesInFolder = FileSystemHelper.getFilesInDirectory(
`newsletter/${newsletter.id}_${newsletter.title.replace(" ", "")}` `newsletter/${newsletter.id}_${newsletter.title.replaceAll(" ", "")}`
); );
res.json(filesInFolder); res.json(filesInFolder);
@ -114,7 +114,7 @@ export async function getNewsletterPrintoutByIdAndPrint(req: Request, res: Respo
let filepath = FileSystemHelper.formatPath( let filepath = FileSystemHelper.formatPath(
"newsletter", "newsletter",
`${newsletter.id}_${newsletter.title.replace(" ", "")}`, `${newsletter.id}_${newsletter.title.replaceAll(" ", "")}`,
filename filename
); );
@ -164,6 +164,34 @@ export async function createNewsletterPrintoutPreviewById(req: Request, res: Res
res.send(pdfbuffer); res.send(pdfbuffer);
} }
/**
* @description get all members receiving a newsletter printout by id
* @param req {Request} Express req object
* @param res {Response} Express res object
* @returns {Promise<*>}
*/
export async function getNewsletterPrintReceiversById(req: Request, res: Response): Promise<any> {
let newsletterId = parseInt(req.params.newsletterId);
let recipients = await NewsletterHelper.getPrintRecipients(newsletterId);
res.json(recipients);
}
/**
* @description get all members receiving a newsletter mail by id
* @param req {Request} Express req object
* @param res {Response} Express res object
* @returns {Promise<*>}
*/
export async function getNewsletterMailReceiversById(req: Request, res: Response): Promise<any> {
let newsletterId = parseInt(req.params.newsletterId);
let recipients = await NewsletterHelper.getMailRecipients(newsletterId);
res.json(recipients);
}
/** /**
* @description create newsletter * @description create newsletter
* @param req {Request} Express req object * @param req {Request} Express req object

View file

@ -235,7 +235,7 @@ export async function createProtocolPrintoutById(req: Request, res: Response): P
year: "numeric", year: "numeric",
})}`; })}`;
let filename = `${new Date().toISOString().split("T")[0]}_${iteration + 1}_Protokoll_${protocol.title.replace( let filename = `${new Date().toISOString().split("T")[0]}_${iteration + 1}_Protokoll_${protocol.title.replaceAll(
/[^a-zA-Z0-9]/g, /[^a-zA-Z0-9]/g,
"" ""
)}`; )}`;

View file

@ -1,6 +1,7 @@
import { Request, Response } from "express"; import { Request, Response } from "express";
import DynamicQueryBuilder from "../../../helpers/dynamicQueryBuilder"; import DynamicQueryBuilder from "../../../helpers/dynamicQueryBuilder";
import { dataSource } from "../../../data-source"; import { dataSource } from "../../../data-source";
import QueryStoreService from "../../../service/configuration/queryStoreService";
/** /**
* @description get all table metas * @description get all table metas
@ -43,3 +44,23 @@ export async function executeQuery(req: Request, res: Response): Promise<any> {
res.json(result); res.json(result);
} }
/**
* @description execute Query by StoreId
* @param req {Request} Express req object
* @param res {Response} Express res object
* @returns {Promise<*>}
*/
export async function executeQueryByStoreId(req: Request, res: Response): Promise<any> {
let offset = parseInt((req.query.offset as string) ?? "0");
let count = parseInt((req.query.count as string) ?? "25");
let noLimit = req.query.noLimit === "true";
const storeId = req.params.storeId;
let queryStore = await QueryStoreService.getById(storeId);
let query = queryStore.query.startsWith("{") ? JSON.parse(queryStore.query) : queryStore.query;
let result = await DynamicQueryBuilder.executeQuery({ query, offset, count, noLimit });
res.json(result);
}

View file

@ -49,6 +49,8 @@ import { BackupAndResetDatabase1738166124200 } from "./migrations/1738166124200-
import { CreateSchema1738166167472 } from "./migrations/1738166167472-CreateSchema"; import { CreateSchema1738166167472 } from "./migrations/1738166167472-CreateSchema";
import { TemplatesAndProtocolSort1742549956787 } from "./migrations/1742549956787-templatesAndProtocolSort"; import { TemplatesAndProtocolSort1742549956787 } from "./migrations/1742549956787-templatesAndProtocolSort";
import { QueryToUUID1742922178643 } from "./migrations/1742922178643-queryToUUID"; import { QueryToUUID1742922178643 } from "./migrations/1742922178643-queryToUUID";
import { NewsletterColumnType1744351418751 } from "./migrations/1744351418751-newsletterColumnType";
import { QueryUpdatedAt1744795756230 } from "./migrations/1744795756230-QueryUpdatedAt";
const dataSource = new DataSource({ const dataSource = new DataSource({
type: DB_TYPE as any, type: DB_TYPE as any,
@ -107,6 +109,8 @@ const dataSource = new DataSource({
CreateSchema1738166167472, CreateSchema1738166167472,
TemplatesAndProtocolSort1742549956787, TemplatesAndProtocolSort1742549956787,
QueryToUUID1742922178643, QueryToUUID1742922178643,
NewsletterColumnType1744351418751,
QueryUpdatedAt1744795756230,
], ],
migrationsRun: true, migrationsRun: true,
migrationsTransactionMode: "each", migrationsTransactionMode: "each",

View file

@ -14,13 +14,13 @@ export class newsletter {
@Column({ type: "varchar", length: 255, default: "" }) @Column({ type: "varchar", length: 255, default: "" })
description: string; description: string;
@Column({ type: "varchar", length: 255, default: "" }) @Column({ type: "text", default: "" })
newsletterTitle: string; newsletterTitle: string;
@Column({ type: "text", default: "" }) @Column({ type: "text", default: "" })
newsletterText: string; newsletterText: string;
@Column({ type: "varchar", length: 255, default: "" }) @Column({ type: "text", default: "" })
newsletterSignatur: string; newsletterSignatur: string;
@Column({ type: "boolean", default: false }) @Column({ type: "boolean", default: false })

View file

@ -1,4 +1,4 @@
import { Column, Entity, PrimaryColumn } from "typeorm"; import { Column, Entity, PrimaryColumn, UpdateDateColumn } from "typeorm";
@Entity() @Entity()
export class query { export class query {
@ -10,4 +10,7 @@ export class query {
@Column({ type: "text", default: "" }) @Column({ type: "text", default: "" })
query: string; query: string;
@UpdateDateColumn()
updatedAt: Date;
} }

View file

@ -12,9 +12,9 @@ export const DB_PASSWORD = process.env.DB_PASSWORD ?? "";
export const SERVER_PORT = Number(process.env.SERVER_PORT ?? 5000); export const SERVER_PORT = Number(process.env.SERVER_PORT ?? 5000);
export const JWT_SECRET = process.env.JWT_SECRET ?? "my_jwt_secret_string_ilughfnadiuhgq§$IUZGFVRweiouarbt1oub3h5q4a"; export const JWT_SECRET = process.env.JWT_SECRET ?? "my_jwt_secret_string_ilughfnadiuhgq§$IUZGFVRweiouarbt1oub3h5q4a";
export const JWT_EXPIRATION = process.env.JWT_EXPIRATION ?? "15m"; export const JWT_EXPIRATION = (process.env.JWT_EXPIRATION ?? "15m") as ms.StringValue;
export const REFRESH_EXPIRATION = process.env.REFRESH_EXPIRATION ?? "1d"; export const REFRESH_EXPIRATION = (process.env.REFRESH_EXPIRATION ?? "1d") as ms.StringValue;
export const PWA_REFRESH_EXPIRATION = process.env.PWA_REFRESH_EXPIRATION ?? "5d"; export const PWA_REFRESH_EXPIRATION = (process.env.PWA_REFRESH_EXPIRATION ?? "5d") as ms.StringValue;
export const MAIL_USERNAME = process.env.MAIL_USERNAME ?? ""; export const MAIL_USERNAME = process.env.MAIL_USERNAME ?? "";
export const MAIL_PASSWORD = process.env.MAIL_PASSWORD ?? ""; export const MAIL_PASSWORD = process.env.MAIL_PASSWORD ?? "";
@ -30,10 +30,10 @@ export const BACKUP_COPIES = Number(process.env.BACKUP_COPIES ?? "7");
export const BACKUP_AUTO_RESTORE = process.env.BACKUP_AUTO_RESTORE ?? "true"; export const BACKUP_AUTO_RESTORE = process.env.BACKUP_AUTO_RESTORE ?? "true";
export const USE_SECURITY_STRICT_LIMIT = process.env.USE_SECURITY_STRICT_LIMIT ?? "true"; export const USE_SECURITY_STRICT_LIMIT = process.env.USE_SECURITY_STRICT_LIMIT ?? "true";
export const SECURITY_STRICT_LIMIT_WINDOW = process.env.SECURITY_STRICT_LIMIT_WINDOW ?? "15m"; export const SECURITY_STRICT_LIMIT_WINDOW = (process.env.SECURITY_STRICT_LIMIT_WINDOW ?? "15m") as ms.StringValue;
export const SECURITY_STRICT_LIMIT_REQUEST_COUNT = Number(process.env.SECURITY_STRICT_LIMIT_REQUEST_COUNT ?? "15"); export const SECURITY_STRICT_LIMIT_REQUEST_COUNT = Number(process.env.SECURITY_STRICT_LIMIT_REQUEST_COUNT ?? "15");
export const USE_SECURITY_LIMIT = process.env.USE_SECURITY_LIMIT ?? "true"; export const USE_SECURITY_LIMIT = process.env.USE_SECURITY_LIMIT ?? "true";
export const SECURITY_LIMIT_WINDOW = process.env.SECURITY_LIMIT_WINDOW ?? "1m"; export const SECURITY_LIMIT_WINDOW = (process.env.SECURITY_LIMIT_WINDOW ?? "1m") as ms.StringValue;
export const SECURITY_LIMIT_REQUEST_COUNT = Number(process.env.SECURITY_LIMIT_REQUEST_COUNT ?? "500"); export const SECURITY_LIMIT_REQUEST_COUNT = Number(process.env.SECURITY_LIMIT_REQUEST_COUNT ?? "500");
export const TRUST_PROXY = ((): Array<string> | string | boolean | number | null => { export const TRUST_PROXY = ((): Array<string> | string | boolean | number | null => {
@ -104,7 +104,7 @@ export function configCheck() {
} }
} }
function checkMS(input: string, origin: string) { function checkMS(input: ms.StringValue, origin: string) {
try { try {
const result = ms(input); const result = ms(input);
if (result === undefined) { if (result === undefined) {

View file

@ -12,6 +12,7 @@ export default abstract class QueryStoreFactory {
id: record.id, id: record.id,
title: record.title, title: record.title,
query: record.query.startsWith("{") ? JSON.parse(record.query) : record.query, query: record.query.startsWith("{") ? JSON.parse(record.query) : record.query,
updatedAt: record.updatedAt,
}; };
} }

View file

@ -349,7 +349,12 @@ export default abstract class BackupHelper {
"member.birthdate", "member.birthdate",
"member.internalId", "member.internalId",
]) ])
.addSelect([...(collectIds ? ["query.id"] : []), "recipientsByQuery.title", "recipientsByQuery.query"]) .addSelect([
...(collectIds ? ["recipientsByQuery.id"] : []),
"recipientsByQuery.title",
"recipientsByQuery.query",
"recipientsByQuery.updatedAt",
])
.getMany() .getMany()
.then((res: any) => .then((res: any) =>
res.map((n: any) => ({ res.map((n: any) => ({
@ -750,11 +755,11 @@ export default abstract class BackupHelper {
.filter((d) => availableTemplates.includes(d.scope)) .filter((d) => availableTemplates.includes(d.scope))
.map((d) => ({ .map((d) => ({
...d, ...d,
headerHeightId: templates.find((template) => template.template == d.headerHeight.template)?.id ?? null, headerHeightId: templates.find((template) => template.template == d.headerHeight)?.id ?? null,
footerHeightId: templates.find((template) => template.template == d.footerHeight.template)?.id ?? null, footerHeightId: templates.find((template) => template.template == d.footerHeight)?.id ?? null,
headerId: templates.find((template) => template.template == d.header.template)?.id ?? null, headerId: templates.find((template) => template.template == d.header?.template)?.id ?? null,
bodyId: templates.find((template) => template.template == d.body.template)?.id ?? null, bodyId: templates.find((template) => template.template == d.body?.template)?.id ?? null,
footerId: templates.find((template) => template.template == d.footer.template)?.id ?? null, footerId: templates.find((template) => template.template == d.footer?.template)?.id ?? null,
})); }));
availableTemplates.forEach((at) => { availableTemplates.forEach((at) => {
if (!dataWithMappedId.some((d) => d.scope == at)) { if (!dataWithMappedId.some((d) => d.scope == at)) {

View file

@ -2,6 +2,7 @@ import { Brackets, DataSource, NotBrackets, ObjectLiteral, SelectQueryBuilder, W
import { dataSource } from "../data-source"; import { dataSource } from "../data-source";
import { ConditionStructure, DynamicQueryStructure, FieldType, QueryResult } from "../type/dynamicQueries"; import { ConditionStructure, DynamicQueryStructure, FieldType, QueryResult } from "../type/dynamicQueries";
import { TableMeta } from "../type/tableMeta"; import { TableMeta } from "../type/tableMeta";
import { StringHelper } from "./stringHelper";
export default abstract class DynamicQueryBuilder { export default abstract class DynamicQueryBuilder {
public static allowedTables: Array<string> = [ public static allowedTables: Array<string> = [
@ -62,11 +63,18 @@ export default abstract class DynamicQueryBuilder {
count?: number; count?: number;
noLimit?: boolean; noLimit?: boolean;
}): SelectQueryBuilder<ObjectLiteral> { }): SelectQueryBuilder<ObjectLiteral> {
let affix = Math.random().toString(36).substring(2); let affix = queryObj.id ?? StringHelper.random(10);
let query = dataSource.getRepository(queryObj.table).createQueryBuilder(`${queryObj.table}_${affix}`); let query = dataSource.getRepository(queryObj.table).createQueryBuilder(`${affix}_${queryObj.table}`);
this.buildDynamicQuery(query, queryObj, affix); this.buildDynamicQuery(query, queryObj, affix);
if (queryObj.orderBy) {
queryObj.orderBy.forEach((order) => {
// compatability layer for none id (old) queries
if (order.id) query.addOrderBy(`${order.id}_${order.table}.${order.column}`, order.order);
});
}
if (!noLimit) { if (!noLimit) {
query.offset(offset); query.offset(offset);
query.limit(count); query.limit(count);
@ -78,10 +86,10 @@ export default abstract class DynamicQueryBuilder {
private static buildDynamicQuery( private static buildDynamicQuery(
query: SelectQueryBuilder<ObjectLiteral>, query: SelectQueryBuilder<ObjectLiteral>,
queryObject: DynamicQueryStructure, queryObject: DynamicQueryStructure,
affix: string = "", affix: string = "", // table id
depth: number = 0 depth: number = 0
): void { ): void {
const alias = queryObject.table + "_" + affix; const alias = `${affix}_${queryObject.table}`;
let firstSelect = true; let firstSelect = true;
let selects: Array<string> = []; let selects: Array<string> = [];
@ -108,18 +116,21 @@ export default abstract class DynamicQueryBuilder {
if (queryObject.join) { if (queryObject.join) {
for (const join of queryObject.join) { for (const join of queryObject.join) {
let subaffix = Math.random().toString(36).substring(2); let subaffix = join.id ?? StringHelper.random(10);
query.leftJoin(`${alias}.${join.foreignColumn}`, join.table + "_" + subaffix); if (join.type == undefined) join.type = "defined";
if (join.type == "defined") {
query.innerJoin(`${alias}.${join.foreignColumn}`, `${subaffix}_${join.table}`);
} else {
let condition = join.condition
.replaceAll(`${join.table}.`, `${subaffix}_${join.table}.`)
.replaceAll(`${queryObject.table}.`, `${alias}.`);
query.innerJoin(join.table, `${subaffix}_${join.table}`, condition);
}
this.buildDynamicQuery(query, join, subaffix, depth + 1); this.buildDynamicQuery(query, join, subaffix, depth + 1);
} }
} }
if (queryObject.orderBy) {
queryObject.orderBy.forEach((order) => {
query.addOrderBy(`${alias}.${order.column}`, order.order);
});
}
} }
public static applyWhere( public static applyWhere(
@ -166,7 +177,7 @@ export default abstract class DynamicQueryBuilder {
condition: ConditionStructure & { structureType: "condition" }, condition: ConditionStructure & { structureType: "condition" },
alias: string alias: string
): { query: string; parameters: Record<string, unknown> } { ): { query: string; parameters: Record<string, unknown> } {
const parameterKey = `${alias}_${condition.column}_${Math.random().toString(36).substring(2)}`; const parameterKey = `${condition.column}_${Math.random().toString(36).substring(2)}`;
let query = `${alias}.${condition.column}`; let query = `${alias}.${condition.column}`;
let parameters: Record<string, unknown> = {}; let parameters: Record<string, unknown> = {};
@ -379,6 +390,7 @@ export default abstract class DynamicQueryBuilder {
count: noLimit ? total : count, count: noLimit ? total : count,
}; };
} catch (error) { } catch (error) {
console.log(error);
return { return {
stats: "error", stats: "error",
sql: error.sql, sql: error.sql,
@ -391,27 +403,31 @@ export default abstract class DynamicQueryBuilder {
} }
const memberQuery: DynamicQueryStructure = { const memberQuery: DynamicQueryStructure = {
id: "memberId",
select: "*", select: "*",
table: "member", table: "member",
orderBy: [ orderBy: [
{ column: "lastname", order: "ASC" }, { id: "memberId", depth: 0, table: "member", column: "lastname", order: "ASC" },
{ column: "firstname", order: "ASC" }, { id: "memberId", depth: 0, table: "member", column: "firstname", order: "ASC" },
], ],
}; };
const memberByRunningMembershipQuery: DynamicQueryStructure = { const memberByRunningMembershipQuery: DynamicQueryStructure = {
id: "memberId",
select: "*", select: "*",
table: "member", table: "member",
join: [ join: [
{ {
id: "membershipId",
select: "*", select: "*",
table: "membership", table: "membership",
where: [{ structureType: "condition", concat: "_", operation: "null", column: "end", value: "" }], where: [{ structureType: "condition", concat: "_", operation: "null", column: "end", value: "" }],
foreignColumn: "memberships", foreignColumn: "memberships",
type: "defined",
}, },
], ],
orderBy: [ orderBy: [
{ column: "lastname", order: "ASC" }, { id: "memberId", depth: 0, table: "member", column: "lastname", order: "ASC" },
{ column: "firstname", order: "ASC" }, { id: "memberId", depth: 0, table: "member", column: "firstname", order: "ASC" },
], ],
}; };

View file

@ -58,7 +58,10 @@ export abstract class JWTHelper {
let rolePermissions = let rolePermissions =
userRoles.length != 0 ? await RolePermissionService.getByRoles(userRoles.map((e) => e.id)) : []; userRoles.length != 0 ? await RolePermissionService.getByRoles(userRoles.map((e) => e.id)) : [];
let rolePermissionStrings = rolePermissions.map((e) => e.permission); let rolePermissionStrings = rolePermissions.map((e) => e.permission);
let permissionObject = PermissionHelper.convertToObject([...userPermissionStrings, ...rolePermissionStrings]); let permissionObject = PermissionHelper.convertToObject(
[...userPermissionStrings, ...rolePermissionStrings],
isOwner
);
let jwtData: JWTToken = { let jwtData: JWTToken = {
userId: id, userId: id,

View file

@ -1,4 +1,3 @@
import Mail from "nodemailer/lib/mailer";
import { member } from "../entity/club/member/member"; import { member } from "../entity/club/member/member";
import { newsletter } from "../entity/club/newsletter/newsletter"; import { newsletter } from "../entity/club/newsletter/newsletter";
import { newsletterDates } from "../entity/club/newsletter/newsletterDates"; import { newsletterDates } from "../entity/club/newsletter/newsletterDates";
@ -62,39 +61,41 @@ export abstract class NewsletterHelper {
newsletterTitle: newsletter.newsletterTitle, newsletterTitle: newsletter.newsletterTitle,
newsletterText: newsletter.newsletterText, newsletterText: newsletter.newsletterText,
newsletterSignatur: newsletter.newsletterSignatur, newsletterSignatur: newsletter.newsletterSignatur,
dates: dates.map((d) => ({ dates: dates
title: d.diffTitle || d.calendar.title, .map((d) => ({
content: d.diffDescription || d.calendar.content, title: d.diffTitle || d.calendar.title,
starttime: d.calendar.starttime, content: d.diffDescription || d.calendar.content,
formattedStarttime: new Date(d.calendar.starttime).toLocaleDateString("de-DE", { starttime: d.calendar.starttime,
weekday: "long", formattedStarttime: new Date(d.calendar.starttime).toLocaleDateString("de-DE", {
day: "2-digit", weekday: "long",
month: "long", day: "2-digit",
}), month: "long",
formattedFullStarttime: new Date(d.calendar.starttime).toLocaleDateString("de-DE", { }),
weekday: "long", formattedFullStarttime: new Date(d.calendar.starttime).toLocaleDateString("de-DE", {
day: "2-digit", weekday: "long",
month: "long", day: "2-digit",
year: "numeric", month: "long",
hour: "2-digit", year: "numeric",
minute: "2-digit", hour: "2-digit",
}), minute: "2-digit",
endtime: d.calendar.endtime, }),
formattedEndtime: new Date(d.calendar.endtime).toLocaleDateString("de-DE", { endtime: d.calendar.endtime,
weekday: "long", formattedEndtime: new Date(d.calendar.endtime).toLocaleDateString("de-DE", {
day: "2-digit", weekday: "long",
month: "long", day: "2-digit",
}), month: "long",
formattedFullEndtime: new Date(d.calendar.endtime).toLocaleDateString("de-DE", { }),
weekday: "long", formattedFullEndtime: new Date(d.calendar.endtime).toLocaleDateString("de-DE", {
day: "2-digit", weekday: "long",
month: "long", day: "2-digit",
year: "numeric", month: "long",
hour: "2-digit", year: "numeric",
minute: "2-digit", hour: "2-digit",
}), minute: "2-digit",
location: d.calendar.location, }),
})), location: d.calendar.location,
}))
.sort((a, b) => a.starttime.getTime() - b.starttime.getTime()),
...(recipient ...(recipient
? { ? {
recipient: { recipient: {
@ -140,33 +141,19 @@ export abstract class NewsletterHelper {
} }
} }
let members = await MemberService.getAll({ noLimit: true, ids: queryMemberIds }); if (queryMemberIds.length == 0) {
return [];
return members[0]; } else {
let members = await MemberService.getAll({ noLimit: true, ids: queryMemberIds });
return members[0];
}
} }
public static getICSFilePath(newsletter: newsletter) { public static async getMailRecipients(newsletterId: number) {
return FileSystemHelper.formatPath(
"newsletter",
`${newsletter.id}_${newsletter.title.replace(" ", "")}`,
`events.ics`
);
}
public static saveIcsToFile(newsletter: newsletter, ics: string) {
FileSystemHelper.writeFile(`newsletter/${newsletter.id}_${newsletter.title.replace(" ", "")}`, "events.ics", ics);
}
public static async sendMails(newsletterId: number) {
let newsletter = await NewsletterService.getById(newsletterId); let newsletter = await NewsletterService.getById(newsletterId);
let dates = await NewsletterDatesService.getAll(newsletterId);
let recipients = await NewsletterRecipientsService.getAll(newsletterId); let recipients = await NewsletterRecipientsService.getAll(newsletterId);
let config = await NewsletterConfigService.getAll(); let config = await NewsletterConfigService.getAll();
const { value, error } = CalendarHelper.buildICS(dates.map((r) => r.calendar));
if (error) throw new InternalException("Failed Building ICS form Mail", error);
this.saveIcsToFile(newsletter, value);
let allowedForMail = config.filter((c) => c.config == NewsletterConfigType.mail).map((c) => c.comTypeId); let allowedForMail = config.filter((c) => c.config == NewsletterConfigType.mail).map((c) => c.comTypeId);
const members = await this.transformRecipientsToMembers(newsletter, recipients); const members = await this.transformRecipientsToMembers(newsletter, recipients);
@ -177,6 +164,58 @@ export abstract class NewsletterHelper {
allowedForMail.includes(m.sendNewsletter?.type?.id) allowedForMail.includes(m.sendNewsletter?.type?.id)
); );
return mailRecipients;
}
public static async getPrintRecipients(newsletterId: number) {
let newsletter = await NewsletterService.getById(newsletterId);
let recipients = await NewsletterRecipientsService.getAll(newsletterId);
let config = await NewsletterConfigService.getAll();
let notAllowedForPdf = config.filter((c) => c.config == NewsletterConfigType.mail).map((c) => c.comTypeId);
const members = await this.transformRecipientsToMembers(newsletter, recipients);
const pdfRecipients = members.filter(
(m) => !notAllowedForPdf.includes(m.sendNewsletter?.type?.id) || m.sendNewsletter == null
);
pdfRecipients.unshift({
id: "0",
firstname: "Alle Mitglieder",
lastname: CLUB_NAME,
nameaffix: "",
salutation: { salutation: "" },
} as member);
return pdfRecipients;
}
public static getICSFilePath(newsletter: newsletter) {
return FileSystemHelper.formatPath(
"newsletter",
`${newsletter.id}_${newsletter.title.replaceAll(" ", "")}`,
`events.ics`
);
}
public static saveIcsToFile(newsletter: newsletter, ics: string) {
FileSystemHelper.writeFile(
`newsletter/${newsletter.id}_${newsletter.title.replaceAll(" ", "")}`,
"events.ics",
ics
);
}
public static async sendMails(newsletterId: number) {
let newsletter = await NewsletterService.getById(newsletterId);
let dates = await NewsletterDatesService.getAll(newsletterId);
const { value, error } = CalendarHelper.buildICS(dates.map((r) => r.calendar));
if (error) throw new InternalException("Failed Building ICS form Mail", error);
this.saveIcsToFile(newsletter, value);
const mailRecipients = await this.getMailRecipients(newsletterId);
this.formatJobEmit("progress", "mail", "info", newsletterId, mailRecipients.length, 0, "starting sending"); this.formatJobEmit("progress", "mail", "info", newsletterId, mailRecipients.length, 0, "starting sending");
for (const [index, rec] of mailRecipients.entries()) { for (const [index, rec] of mailRecipients.entries()) {
@ -228,11 +267,10 @@ export abstract class NewsletterHelper {
public static async printPdfs(newsletterId: number) { public static async printPdfs(newsletterId: number) {
let newsletter = await NewsletterService.getById(newsletterId); let newsletter = await NewsletterService.getById(newsletterId);
let dates = await NewsletterDatesService.getAll(newsletterId); let dates = await NewsletterDatesService.getAll(newsletterId);
let recipients = await NewsletterRecipientsService.getAll(newsletterId);
let config = await NewsletterConfigService.getAll(); let config = await NewsletterConfigService.getAll();
FileSystemHelper.clearDirectoryByFiletype( FileSystemHelper.clearDirectoryByFiletype(
`newsletter/${newsletter.id}_${newsletter.title.replace(" ", "")}`, `newsletter/${newsletter.id}_${newsletter.title.replaceAll(" ", "")}`,
".pdf" ".pdf"
); );
@ -240,33 +278,20 @@ export abstract class NewsletterHelper {
if (error) throw new InternalException("Failed Building ICS form Pdf", error); if (error) throw new InternalException("Failed Building ICS form Pdf", error);
this.saveIcsToFile(newsletter, value); this.saveIcsToFile(newsletter, value);
let notAllowedForPdf = config.filter((c) => c.config == NewsletterConfigType.mail).map((c) => c.comTypeId);
let printWithAdress = config.filter((c) => c.config == NewsletterConfigType.pdf).map((c) => c.comTypeId); let printWithAdress = config.filter((c) => c.config == NewsletterConfigType.pdf).map((c) => c.comTypeId);
const members = await this.transformRecipientsToMembers(newsletter, recipients); const pdfRecipients = await this.getPrintRecipients(newsletterId);
const pdfRecipients = members.filter(
(m) => !notAllowedForPdf.includes(m.sendNewsletter?.type?.id) || m.sendNewsletter == null
);
this.formatJobEmit("progress", "pdf", "info", newsletterId, pdfRecipients.length + 1, 0, "starting sending"); this.formatJobEmit("progress", "pdf", "info", newsletterId, pdfRecipients.length, 0, "starting printing");
for (const [index, rec] of [ for (const [index, rec] of pdfRecipients.entries()) {
...pdfRecipients,
{
id: "0",
firstname: "Alle Mitglieder",
lastname: CLUB_NAME,
nameaffix: "",
salutation: { salutation: "" },
} as member,
].entries()) {
let data = this.buildData(newsletter, dates, rec, printWithAdress.includes(rec.sendNewsletter?.type?.id)); let data = this.buildData(newsletter, dates, rec, printWithAdress.includes(rec.sendNewsletter?.type?.id));
await PdfExport.renderFile({ await PdfExport.renderFile({
template: "newsletter", template: "newsletter",
title: `Newsletter von ${CLUB_NAME}`, title: `Newsletter von ${CLUB_NAME}`,
filename: `${rec.lastname}_${rec.firstname}_${rec.id}`, filename: `${rec.lastname}_${rec.firstname}_${rec.id}`.replaceAll(" ", "-"),
folder: `newsletter/${newsletter.id}_${newsletter.title.replace(" ", "")}`, folder: `newsletter/${newsletter.id}_${newsletter.title.replaceAll(" ", "")}`,
data: data, data: data,
}) })
.then(() => { .then(() => {
@ -294,9 +319,9 @@ export abstract class NewsletterHelper {
} }
await PdfExport.sqashToSingleFile( await PdfExport.sqashToSingleFile(
`newsletter/${newsletter.id}_${newsletter.title.replace(" ", "")}`, `newsletter/${newsletter.id}_${newsletter.title.replaceAll(" ", "")}`,
"allPdfsTogether", "allPdfsTogether",
`newsletter/${newsletter.id}_${newsletter.title.replace(" ", "")}` `newsletter/${newsletter.id}_${newsletter.title.replaceAll(" ", "")}`
) )
.then(() => { .then(() => {
this.formatJobEmit( this.formatJobEmit(

View file

@ -1,10 +1,47 @@
import puppeteer from "puppeteer"; import puppeteer, { Browser } from "puppeteer";
import { TemplateHelper } from "./templateHelper"; import { TemplateHelper } from "./templateHelper";
import { PermissionModule } from "../type/permissionTypes"; import { PermissionModule } from "../type/permissionTypes";
import { FileSystemHelper } from "./fileSystemHelper"; import { FileSystemHelper } from "./fileSystemHelper";
import { PDFDocument } from "pdf-lib"; import { PDFDocument } from "pdf-lib";
import { StringHelper } from "./stringHelper";
export abstract class PdfExport { export abstract class PdfExport {
private static browserInstance: undefined | Browser = undefined;
private static timeout: undefined | NodeJS.Timeout = undefined;
private static printing = new Map<string, string>();
private static async renderTemplate(
template: `${PermissionModule}` | `${PermissionModule}.${string}`,
title: string,
data: any,
customTemplate?: {
headerId?: number;
footerId?: number;
bodyId?: string | number;
headerHeight: number;
footerHeight: number;
}
): Promise<{ header: string; footer: string; body: string; headerMargin?: number; footerMargin?: number }> {
if (!customTemplate) {
return await TemplateHelper.renderFileForModule({
module: template,
headerData: data,
bodyData: data,
footerData: data,
title: title,
});
} else {
return await TemplateHelper.renderFileForCustom({
module: template,
customTemplate,
headerData: data,
bodyData: data,
footerData: data,
title: title,
});
}
}
static async renderFile({ static async renderFile({
template, template,
title = "pdf-export FF Admin", title = "pdf-export FF Admin",
@ -28,33 +65,25 @@ export abstract class PdfExport {
footerHeight: number; footerHeight: number;
}; };
}) { }) {
try {
clearTimeout(this.timeout);
} catch (err) {}
let id = StringHelper.random(32);
this.printing.set(id, "printing");
if (folder != "") FileSystemHelper.createFolder(folder); if (folder != "") FileSystemHelper.createFolder(folder);
let header: string, footer: string, body: string, headerMargin: number, footerMargin: number; const renderedTemplate = await this.renderTemplate(template, title, data, customTemplate);
if (!customTemplate) { let { header, footer, body, headerMargin, footerMargin } = renderedTemplate;
({ header, footer, body, headerMargin, footerMargin } = await TemplateHelper.renderFileForModule({
module: template, if (!this.browserInstance || !this.browserInstance.connected) {
headerData: data, this.browserInstance = await puppeteer.launch({
bodyData: data, headless: true,
footerData: data, args: ["--no-sandbox", "--disable-gpu", "--disable-setuid-sandbox"],
title: title, });
}));
} else {
({ header, footer, body, headerMargin, footerMargin } = await TemplateHelper.renderFileForCustom({
module: template,
customTemplate,
headerData: data,
bodyData: data,
footerData: data,
title: title,
}));
} }
const browser = await puppeteer.launch({ const page = await this.browserInstance.newPage();
headless: true,
args: ["--no-sandbox", "--disable-gpu", "--disable-setuid-sandbox"],
});
const page = await browser.newPage();
await page.setContent(body, { waitUntil: "domcontentloaded" }); await page.setContent(body, { waitUntil: "domcontentloaded" });
const exportPath = FileSystemHelper.formatPath(folder, `${filename}.pdf`); const exportPath = FileSystemHelper.formatPath(folder, `${filename}.pdf`);
@ -74,7 +103,16 @@ export abstract class PdfExport {
footerTemplate: footer, footerTemplate: footer,
}); });
await browser.close(); await page.close();
this.printing.delete(id);
if (this.printing.size == 0) {
this.timeout = setTimeout(() => {
this.browserInstance.close();
this.browserInstance = undefined;
}, 5000);
}
return pdf; return pdf;
} }

View file

@ -4,9 +4,11 @@ import {
permissionModules, permissionModules,
PermissionObject, PermissionObject,
PermissionSection, PermissionSection,
permissionSections,
PermissionString, PermissionString,
PermissionType, PermissionType,
permissionTypes, permissionTypes,
sectionsAndModules,
} from "../type/permissionTypes"; } from "../type/permissionTypes";
import ForbiddenRequestException from "../exceptions/forbiddenRequestException"; import ForbiddenRequestException from "../exceptions/forbiddenRequestException";
@ -17,8 +19,8 @@ export default class PermissionHelper {
section: PermissionSection, section: PermissionSection,
module?: PermissionModule module?: PermissionModule
) { ) {
if (type == "admin") return permissions?.admin ?? false; if (type == "admin") return permissions?.admin ?? permissions?.adminByOwner ?? false;
if (permissions?.admin) return true; if (permissions?.admin || permissions?.adminByOwner) return true;
if ( if (
(!module && (!module &&
permissions[section] != undefined && permissions[section] != undefined &&
@ -50,8 +52,8 @@ export default class PermissionHelper {
type: PermissionType | "admin", type: PermissionType | "admin",
section: PermissionSection section: PermissionSection
): boolean { ): boolean {
if (type == "admin") return permissions?.admin ?? false; if (type == "admin") return permissions?.admin ?? permissions?.adminByOwner ?? false;
if (permissions?.admin) return true; if (permissions?.admin || permissions?.adminByOwner) return true;
if ( if (
permissions[section]?.all == "*" || permissions[section]?.all == "*" ||
permissions[section]?.all?.includes(type) || permissions[section]?.all?.includes(type) ||
@ -73,6 +75,11 @@ export default class PermissionHelper {
}, false); }, false);
} }
static canValue(permissions: PermissionObject, key: string, emptyIfAdmin: boolean = false): string {
if (emptyIfAdmin && (permissions.admin || permissions.adminByOwner)) return "";
return permissions?.additional?.[key] ?? "";
}
static passCheckMiddleware( static passCheckMiddleware(
requiredPermissions: PermissionType | "admin", requiredPermissions: PermissionType | "admin",
section: PermissionSection, section: PermissionSection,
@ -159,14 +166,28 @@ export default class PermissionHelper {
}; };
} }
static convertToObject(permissions: Array<PermissionString>): PermissionObject { static convertToObject(permissions: Array<PermissionString>, isOwner: boolean = false): PermissionObject {
if (permissions.includes("*")) { let isAdmin = permissions.includes("*");
let additional: { [key: string]: string } = {};
let additionalPermissions = permissions.map((e) => e.split(".")).filter((e) => e[0] == "additional") as Array<
["additional", string, string]
>;
for (let split of additionalPermissions) {
let module = sectionsAndModules.additional.find((a) => a.key == split[1]);
if (!isAdmin || (isAdmin && !module.emptyIfAdmin)) additional[split[1]] = split[2];
}
if (isAdmin) {
return { return {
admin: true, admin: true,
adminByOwner: isOwner,
...(Object.keys(additional).length > 0 && { additional }),
}; };
} }
let output: PermissionObject = {}; let output: PermissionObject = {};
let splitPermissions = permissions.map((e) => e.split(".")) as Array< let splitPermissions = permissions.map((e) => e.split(".")).filter((e) => e[0] != "additional") as Array<
[PermissionSection, PermissionModule | PermissionType | "*", PermissionType | "*"] [PermissionSection, PermissionModule | PermissionType | "*", PermissionType | "*"]
>; >;
for (let split of splitPermissions) { for (let split of splitPermissions) {
@ -208,15 +229,31 @@ export default class PermissionHelper {
} }
} }
} }
return output;
return {
adminByOwner: isOwner,
...output,
...(Object.keys(additional).length > 0 && { additional }),
};
} }
static convertToStringArray(permissions: PermissionObject): Array<PermissionString> { static convertToStringArray(permissions: PermissionObject): Array<PermissionString> {
if (permissions?.admin) { let isAdmin = permissions?.admin;
return ["*"];
let additional: Array<PermissionString> = [];
let additionalPermissions = Object.entries(permissions?.additional ?? {});
for (let add of additionalPermissions) {
additional.push(`additional.${add[0]}.${add[1]}`);
} }
if (isAdmin) {
return ["*", ...additional];
}
let output: Array<PermissionString> = []; let output: Array<PermissionString> = [];
let sections = Object.keys(permissions) as Array<PermissionSection>; let sections = Object.keys(permissions).filter((m: PermissionSection) =>
permissionSections.includes(m)
) as Array<PermissionSection>;
for (let section of sections) { for (let section of sections) {
if (permissions[section].all) { if (permissions[section].all) {
let types = permissions[section].all; let types = permissions[section].all;
@ -242,7 +279,8 @@ export default class PermissionHelper {
} }
} }
} }
return output;
return [...output, ...additional];
} }
static getWhatToAdd(before: Array<PermissionString>, after: Array<PermissionString>): Array<PermissionString> { static getWhatToAdd(before: Array<PermissionString>, after: Array<PermissionString>): Array<PermissionString> {

View file

@ -11,7 +11,9 @@ export abstract class TemplateHelper {
try { try {
tmpFile = FileSystemHelper.readTemplateFile(`/src/templates/${template}.template.html`); tmpFile = FileSystemHelper.readTemplateFile(`/src/templates/${template}.template.html`);
} catch (err) { } catch (err) {
tmpFile = FileSystemHelper.readTemplateFile(`/src/templates/${template.split(".")[1]}.template.html`); tmpFile = FileSystemHelper.readTemplateFile(
`/src/templates/${template.split(".")[template.split(".").length - 1]}.template.html`
);
} }
return tmpFile; return tmpFile;
} }
@ -27,9 +29,9 @@ export abstract class TemplateHelper {
} }
static normalizeTemplate(template: string): string { static normalizeTemplate(template: string): string {
template = template.replace(/<listend>.*?<\/listend>/g, "{{/each}}"); template = template.replaceAll(/<listend>.*?<\/listend>/g, "{{/each}}");
template = template.replace(/<liststart\b[^>]*>(WDH Start: )?/g, "{{#each "); template = template.replaceAll(/<liststart\b[^>]*>(WDH Start: )?/g, "{{#each ");
template = template.replace(/<\/liststart>/g, "}}"); template = template.replaceAll(/<\/liststart>/g, "}}");
return template; return template;
} }

View file

@ -0,0 +1,43 @@
import { MigrationInterface, QueryRunner, TableColumn } from "typeorm";
import { getDefaultByORM, getTypeByORM } from "./ormHelper";
import { newsletter } from "../entity/club/newsletter/newsletter";
export class NewsletterColumnType1744351418751 implements MigrationInterface {
name = "NewsletterColumnType1744351418751";
public async up(queryRunner: QueryRunner): Promise<void> {
let newsletters = await queryRunner.manager.getRepository("newsletter").find();
await queryRunner.dropColumn("newsletter", "newsletterTitle");
await queryRunner.dropColumn("newsletter", "newsletterSignatur");
await queryRunner.addColumn(
"newsletter",
new TableColumn({ name: "newsletterTitle", ...getTypeByORM("text"), default: getDefaultByORM("string") })
);
await queryRunner.addColumn(
"newsletter",
new TableColumn({ name: "newsletterSignatur", ...getTypeByORM("text"), default: getDefaultByORM("string") })
);
await queryRunner.manager.getRepository("newsletter").save(newsletters);
}
public async down(queryRunner: QueryRunner): Promise<void> {
let newsletters = await queryRunner.manager.getRepository("newsletter").find();
await queryRunner.dropColumn("newsletter", "newsletterTitle");
await queryRunner.dropColumn("newsletter", "newsletterSignatur");
await queryRunner.addColumn(
"newsletter",
new TableColumn({ name: "newsletterTitle", ...getTypeByORM("varchar"), default: getDefaultByORM("string") })
);
await queryRunner.addColumn(
"newsletter",
new TableColumn({ name: "newsletterSignatur", ...getTypeByORM("varchar"), default: getDefaultByORM("string") })
);
await queryRunner.manager.getRepository("newsletter").save(newsletters);
}
}

View file

@ -0,0 +1,22 @@
import { MigrationInterface, QueryRunner, TableColumn } from "typeorm";
import { getTypeByORM, getDefaultByORM } from "./ormHelper";
export class QueryUpdatedAt1744795756230 implements MigrationInterface {
name = "QueryUpdatedAt1744795756230";
public async up(queryRunner: QueryRunner): Promise<void> {
await queryRunner.addColumn(
"query",
new TableColumn({
name: "updatedAt",
...getTypeByORM("datetime", false, 6),
default: getDefaultByORM("currentTimestamp", 6),
onUpdate: getDefaultByORM<string>("currentTimestamp", 6),
})
);
}
public async down(queryRunner: QueryRunner): Promise<void> {
await queryRunner.dropColumn("query", "updatedAt");
}
}

View file

@ -16,6 +16,8 @@ import {
createNewsletterPrintoutPreviewById, createNewsletterPrintoutPreviewById,
getNewsletterPrintoutProgressById, getNewsletterPrintoutProgressById,
getNewsletterSendingProgressById, getNewsletterSendingProgressById,
getNewsletterMailReceiversById,
getNewsletterPrintReceiversById,
} from "../../../controller/admin/club/newsletterController"; } from "../../../controller/admin/club/newsletterController";
import PermissionHelper from "../../../helpers/permissionHelper"; import PermissionHelper from "../../../helpers/permissionHelper";
@ -57,6 +59,14 @@ router.get("/:newsletterId/sendprogress", async (req: Request, res: Response) =>
await getNewsletterSendingProgressById(req, res); await getNewsletterSendingProgressById(req, res);
}); });
router.get("/:newsletterId/printrecipients", async (req: Request, res: Response) => {
await getNewsletterPrintReceiversById(req, res);
});
router.get("/:newsletterId/mailrecipients", async (req: Request, res: Response) => {
await getNewsletterMailReceiversById(req, res);
});
router.post( router.post(
"/", "/",
PermissionHelper.passCheckMiddleware("create", "club", "protocol"), PermissionHelper.passCheckMiddleware("create", "club", "protocol"),

View file

@ -1,5 +1,10 @@
import express, { Request, Response } from "express"; import express, { Request, Response } from "express";
import { executeQuery, getAllTableMeta, getTableMetaByTablename } from "../../../controller/admin/club/queryBuilderController"; import {
executeQuery,
executeQueryByStoreId,
getAllTableMeta,
getTableMetaByTablename,
} from "../../../controller/admin/club/queryBuilderController";
var router = express.Router({ mergeParams: true }); var router = express.Router({ mergeParams: true });
@ -15,4 +20,8 @@ router.post("/query", async (req: Request, res: Response) => {
await executeQuery(req, res); await executeQuery(req, res);
}); });
router.post("/query/:storeId", async (req: Request, res: Response) => {
await executeQueryByStoreId(req, res);
});
export default router; export default router;

View file

@ -68,7 +68,7 @@ export default (app: Express) => {
} }
app.set("query parser", "extended"); app.set("query parser", "extended");
app.use(cors()); app.use(cors());
app.options("*", cors()); app.options("*splat", cors());
app.use(helmet()); app.use(helmet());
app.use(morgan("short")); app.use(morgan("short"));
app.use(express.json()); app.use(express.json());

View file

@ -1,9 +1,10 @@
export interface DynamicQueryStructure { export interface DynamicQueryStructure {
id: string;
select: string[] | "*"; select: string[] | "*";
table: string; table: string;
where?: Array<ConditionStructure>; where?: Array<ConditionStructure>;
join?: Array<DynamicQueryStructure & { foreignColumn: string }>; join?: Array<DynamicQueryStructure & JoinStructure>;
orderBy?: Array<OrderByStructure>; orderBy?: Array<OrderByStructure>; // only at top level
} }
export type ConditionStructure = ( export type ConditionStructure = (
@ -47,7 +48,12 @@ export type WhereOperation =
| "timespanEq"; // Date before x years (YYYY-01-01 <bis> YYYY-12-31) | "timespanEq"; // Date before x years (YYYY-01-01 <bis> YYYY-12-31)
// TODO: age between | age equals | age greater | age smaller // TODO: age between | age equals | age greater | age smaller
export type JoinStructure = { foreignColumn: string; type: "defined" } | { condition: string; type: "custom" };
export type OrderByStructure = { export type OrderByStructure = {
id: string;
depth: number;
table: string;
column: string; column: string;
order: OrderByType; order: OrderByType;
}; };
@ -59,6 +65,7 @@ export type QueryResult = {
}; };
export const exampleQuery: DynamicQueryStructure = { export const exampleQuery: DynamicQueryStructure = {
id: "1234",
select: ["firstname", "lastname"], select: ["firstname", "lastname"],
table: "member", table: "member",
where: [ where: [
@ -92,19 +99,25 @@ export const exampleQuery: DynamicQueryStructure = {
], ],
join: [ join: [
{ {
id: "5678",
select: "*", select: "*",
table: "communication", table: "communication",
foreignColumn: "sendNewsletter", foreignColumn: "sendNewsletter",
type: "defined",
}, },
{ {
id: "91011",
select: "*", select: "*",
table: "membership", table: "membership",
foreignColumn: "memberships", foreignColumn: "memberships",
type: "defined",
join: [ join: [
{ {
id: "121314",
select: "*", select: "*",
table: "membership_status", table: "membership_status",
foreignColumn: "status", foreignColumn: "status",
type: "defined",
where: [ where: [
{ {
structureType: "condition", structureType: "condition",
@ -120,10 +133,16 @@ export const exampleQuery: DynamicQueryStructure = {
], ],
orderBy: [ orderBy: [
{ {
id: "1234",
depth: 0,
table: "member",
column: "firstname", column: "firstname",
order: "ASC", order: "ASC",
}, },
{ {
id: "1234",
depth: 0,
table: "member",
column: "lastname", column: "lastname",
order: "ASC", order: "ASC",
}, },

View file

@ -30,6 +30,7 @@ export type PermissionString =
| `${PermissionSection}.${PermissionModule}.*` // für alle Berechtigungen in einem Modul | `${PermissionSection}.${PermissionModule}.*` // für alle Berechtigungen in einem Modul
| `${PermissionSection}.${PermissionType}` // für spezifische Berechtigungen in einem Abschnitt | `${PermissionSection}.${PermissionType}` // für spezifische Berechtigungen in einem Abschnitt
| `${PermissionSection}.*` // für alle Berechtigungen in einem Abschnitt | `${PermissionSection}.*` // für alle Berechtigungen in einem Abschnitt
| `additional.${string}.${string}` // additional
| "*"; // für Admin | "*"; // für Admin
export type PermissionObject = { export type PermissionObject = {
@ -38,10 +39,20 @@ export type PermissionObject = {
} & { all?: Array<PermissionType> | "*" }; } & { all?: Array<PermissionType> | "*" };
} & { } & {
admin?: boolean; admin?: boolean;
adminByOwner?: boolean;
} & {
additional?: { [key: string]: string };
}; };
export type SectionsAndModulesObject = { export type SectionsAndModulesObject = {
[section in PermissionSection]: Array<PermissionModule>; [section in PermissionSection]: Array<PermissionModule>;
} & {
additional?: Array<{
key: string;
name: string;
type: "number" | "string";
emptyIfAdmin: boolean;
}>;
}; };
export const permissionSections: Array<PermissionSection> = ["club", "configuration", "management"]; export const permissionSections: Array<PermissionSection> = ["club", "configuration", "management"];
@ -85,4 +96,5 @@ export const sectionsAndModules: SectionsAndModulesObject = {
"newsletter_config", "newsletter_config",
], ],
management: ["user", "role", "webapi", "backup"], management: ["user", "role", "webapi", "backup"],
additional: [],
}; };

View file

@ -4,4 +4,5 @@ export interface QueryStoreViewModel {
id: string; id: string;
title: string; title: string;
query: string | DynamicQueryStructure; query: string | DynamicQueryStructure;
updatedAt: Date;
} }