Compare commits
10 commits
69134b210a
...
ba03b6f097
Author | SHA1 | Date | |
---|---|---|---|
ba03b6f097 | |||
e738be4e13 | |||
c9b8c3090d | |||
a2cc408e85 | |||
d206d7a77c | |||
03036c8b77 | |||
1c6c123142 | |||
e1f6b36336 | |||
916a6da4a0 | |||
b1e949dce2 |
45 changed files with 145 additions and 147 deletions
|
@ -10,6 +10,7 @@ SERVER_PORT = portnumber
|
|||
JWT_SECRET = ABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890
|
||||
JWT_EXPIRATION = [0-9]*(y|d|h|m|s)
|
||||
REFRESH_EXPIRATION = [0-9]*(y|d|h|m|s)
|
||||
PWA_REFRESH_EXPIRATION = [0-9]*(y|d|h|m|s)
|
||||
|
||||
MAIL_USERNAME = mail_username
|
||||
MAIL_PASSWORD = mail_password
|
||||
|
|
13
README.md
13
README.md
|
@ -25,20 +25,21 @@ services:
|
|||
container_name: ff_member_administration_server
|
||||
restart: unless-stopped
|
||||
environment:
|
||||
- DB_TYPE=mysql
|
||||
- DB_TYPE=<mysql|sqlite> # default ist auf mysql gesetzt
|
||||
- DB_HOST=ffm-db
|
||||
- DB_PORT=<number> # fallback ist auf 3306 gesetzt
|
||||
- DB_PORT=<number> # default ist auf 3306 gesetzt
|
||||
- DB_NAME=ffadmin
|
||||
- DB_USERNAME=administration_backend
|
||||
- DB_PASSWORD=<dbuserpasswd>
|
||||
- JWT_SECRET=<tobemodified>
|
||||
- JWT_EXPIRATION=<number[m|d] - bsp.:15m>
|
||||
- REFRESH_EXPIRATION=<number[m|d] - bsp.:1d>
|
||||
- JWT_EXPIRATION=<number[m|d] - bsp.:15m> # default ist auf 15m gesetzt
|
||||
- REFRESH_EXPIRATION=<number[m|d] - bsp.:1d> # default ist auf 1d gesetzt
|
||||
- PWA_REFRESH_EXPIRATION=<number[m|d] - bsp.:5d> # default ist auf 5d gesetzt
|
||||
- MAIL_USERNAME=<mailadress|username>
|
||||
- MAIL_PASSWORD=<password>
|
||||
- MAIL_HOST=<url>
|
||||
- MAIL_PORT=<port>
|
||||
- MAIL_SECURE=<boolean>
|
||||
- MAIL_PORT=<port> # default ist auf 578 gesetzt
|
||||
- MAIL_SECURE=<boolean> # default ist auf false gesetzt
|
||||
- CLUB_NAME=<tobemodified>
|
||||
- CLUB_WEBSITE=<tobemodified>
|
||||
volumes:
|
||||
|
|
|
@ -43,7 +43,6 @@ export default abstract class MemberCommandHandler {
|
|||
* @returns {Promise<void>}
|
||||
*/
|
||||
static async update(updateMember: UpdateMemberCommand): Promise<void> {
|
||||
console.log(updateMember);
|
||||
return await dataSource
|
||||
.createQueryBuilder()
|
||||
.update(member)
|
||||
|
|
|
@ -31,7 +31,7 @@ export default abstract class MembershipCommandHandler {
|
|||
.createQueryBuilder()
|
||||
.update(membership)
|
||||
.set({
|
||||
end: new Date(createMembership.start).setDate(new Date(createMembership.start).getDate() - 1),
|
||||
end: new Date(new Date(createMembership.start).setDate(new Date(createMembership.start).getDate() - 1)),
|
||||
terminationReason: "beendet durch neuen Eintrag.",
|
||||
})
|
||||
.where("end IS NULL")
|
||||
|
|
|
@ -1,5 +1,6 @@
|
|||
export interface CreateRefreshCommand {
|
||||
userId: number;
|
||||
isFromPwa?: boolean;
|
||||
}
|
||||
|
||||
export interface DeleteRefreshCommand {
|
||||
|
|
|
@ -1,11 +1,9 @@
|
|||
import { dataSource } from "../data-source";
|
||||
import { refresh } from "../entity/refresh";
|
||||
import { REFRESH_EXPIRATION } from "../env.defaults";
|
||||
import { PWA_REFRESH_EXPIRATION, REFRESH_EXPIRATION } from "../env.defaults";
|
||||
import InternalException from "../exceptions/internalException";
|
||||
import { JWTHelper } from "../helpers/jwtHelper";
|
||||
import { StringHelper } from "../helpers/stringHelper";
|
||||
import UserService from "../service/user/userService";
|
||||
import { JWTRefresh } from "../type/jwtTypes";
|
||||
import { CreateRefreshCommand, DeleteRefreshCommand } from "./refreshCommand";
|
||||
import ms from "ms";
|
||||
|
||||
|
@ -16,10 +14,6 @@ export default abstract class RefreshCommandHandler {
|
|||
* @returns {Promise<string>}
|
||||
*/
|
||||
static async create(createRefresh: CreateRefreshCommand): Promise<string> {
|
||||
// let createRefreshToken: JWTRefresh = {
|
||||
// userId: createRefresh.userId,
|
||||
// };
|
||||
// const refreshToken = await JWTHelper.create(createRefreshToken);
|
||||
const refreshToken = StringHelper.random(32);
|
||||
|
||||
return await dataSource
|
||||
|
@ -29,7 +23,9 @@ export default abstract class RefreshCommandHandler {
|
|||
.values({
|
||||
token: refreshToken,
|
||||
user: await UserService.getById(createRefresh.userId),
|
||||
expiry: new Date(Date.now() + ms(REFRESH_EXPIRATION)),
|
||||
expiry: createRefresh.isFromPwa
|
||||
? new Date(Date.now() + ms(PWA_REFRESH_EXPIRATION))
|
||||
: new Date(Date.now() + ms(REFRESH_EXPIRATION)),
|
||||
})
|
||||
.execute()
|
||||
.then((result) => {
|
||||
|
|
|
@ -60,7 +60,10 @@ export default abstract class AwardCommandHandler {
|
|||
.execute()
|
||||
.then(() => {})
|
||||
.catch((err) => {
|
||||
throw new InternalException("Failed deleting award", err);
|
||||
throw new InternalException(
|
||||
`Failed deleting award ${err.code.includes("ER_ROW_IS_REFERENCED") ? " due to referenced data" : ""}`,
|
||||
err
|
||||
);
|
||||
});
|
||||
}
|
||||
}
|
||||
|
|
|
@ -66,7 +66,10 @@ export default abstract class CalendarTypeCommandHandler {
|
|||
.execute()
|
||||
.then(() => {})
|
||||
.catch((err) => {
|
||||
throw new InternalException("Failed deleting calendarType", err);
|
||||
throw new InternalException(
|
||||
`Failed deleting calendarType${err.code.includes("ER_ROW_IS_REFERENCED") ? " due to referenced data" : ""}`,
|
||||
err
|
||||
);
|
||||
});
|
||||
}
|
||||
}
|
||||
|
|
|
@ -66,7 +66,12 @@ export default abstract class CommunicationTypeCommandHandler {
|
|||
.execute()
|
||||
.then(() => {})
|
||||
.catch((err) => {
|
||||
throw new InternalException("Failed deleting communicationType", err);
|
||||
throw new InternalException(
|
||||
`Failed deleting communicationType${
|
||||
err.code.includes("ER_ROW_IS_REFERENCED") ? " due to referenced data" : ""
|
||||
}`,
|
||||
err
|
||||
);
|
||||
});
|
||||
}
|
||||
}
|
||||
|
|
|
@ -64,7 +64,12 @@ export default abstract class ExecutivePositionCommandHandler {
|
|||
.execute()
|
||||
.then(() => {})
|
||||
.catch((err) => {
|
||||
throw new InternalException("Failed deleting executivePosition", err);
|
||||
throw new InternalException(
|
||||
`Failed deleting executivePosition${
|
||||
err.code.includes("ER_ROW_IS_REFERENCED") ? " due to referenced data" : ""
|
||||
}`,
|
||||
err
|
||||
);
|
||||
});
|
||||
}
|
||||
}
|
||||
|
|
|
@ -64,7 +64,12 @@ export default abstract class MembershipStatusCommandHandler {
|
|||
.execute()
|
||||
.then(() => {})
|
||||
.catch((err) => {
|
||||
throw new InternalException("Failed deleting membershipStatus", err);
|
||||
throw new InternalException(
|
||||
`Failed deleting membershipStatus${
|
||||
err.code.includes("ER_ROW_IS_REFERENCED") ? " due to referenced data" : ""
|
||||
}`,
|
||||
err
|
||||
);
|
||||
});
|
||||
}
|
||||
}
|
||||
|
|
|
@ -4,7 +4,3 @@ export interface SetNewsletterConfigCommand {
|
|||
comTypeId: number;
|
||||
config: NewsletterConfigType;
|
||||
}
|
||||
|
||||
export interface DeleteNewsletterConfigCommand {
|
||||
comTypeId: number;
|
||||
}
|
||||
|
|
|
@ -1,7 +1,7 @@
|
|||
import { dataSource } from "../../../data-source";
|
||||
import { newsletterConfig } from "../../../entity/settings/newsletterConfig";
|
||||
import InternalException from "../../../exceptions/internalException";
|
||||
import { DeleteNewsletterConfigCommand, SetNewsletterConfigCommand } from "./newsletterConfigCommand";
|
||||
import { SetNewsletterConfigCommand } from "./newsletterConfigCommand";
|
||||
|
||||
export default abstract class NewsletterConfigCommandHandler {
|
||||
/**
|
||||
|
@ -27,21 +27,4 @@ export default abstract class NewsletterConfigCommandHandler {
|
|||
throw new InternalException("Failed setting newsletterConfig", err);
|
||||
});
|
||||
}
|
||||
/**
|
||||
* @description delete newsletterConfig
|
||||
* @param {DeleteNewsletterConfigCommand} deleteNewsletterConfig
|
||||
* @returns {Promise<void>}
|
||||
*/
|
||||
static async delete(deleteNewsletterConfig: DeleteNewsletterConfigCommand): Promise<void> {
|
||||
return await dataSource
|
||||
.createQueryBuilder()
|
||||
.delete()
|
||||
.from(newsletterConfig)
|
||||
.where("comTypeId = :comTypeId", { comTypeId: deleteNewsletterConfig.comTypeId })
|
||||
.execute()
|
||||
.then(() => {})
|
||||
.catch((err) => {
|
||||
throw new InternalException("Failed setting newsletterConfig", err);
|
||||
});
|
||||
}
|
||||
}
|
||||
|
|
|
@ -66,7 +66,10 @@ export default abstract class QualificationCommandHandler {
|
|||
.execute()
|
||||
.then(() => {})
|
||||
.catch((err) => {
|
||||
throw new InternalException("Failed deleting qualification", err);
|
||||
throw new InternalException(
|
||||
`Failed deleting qualification${err.code.includes("ER_ROW_IS_REFERENCED") ? " due to referenced data" : ""}`,
|
||||
err
|
||||
);
|
||||
});
|
||||
}
|
||||
}
|
||||
|
|
|
@ -63,7 +63,10 @@ export default abstract class QueryStoreCommandHandler {
|
|||
.execute()
|
||||
.then(() => {})
|
||||
.catch((err) => {
|
||||
throw new InternalException("Failed deleting queryStore", err);
|
||||
throw new InternalException(
|
||||
`Failed deleting queryStore${err.code.includes("ER_ROW_IS_REFERENCED") ? " due to referenced data" : ""}`,
|
||||
err
|
||||
);
|
||||
});
|
||||
}
|
||||
}
|
||||
|
|
|
@ -64,7 +64,10 @@ export default abstract class TemplateCommandHandler {
|
|||
.execute()
|
||||
.then(() => {})
|
||||
.catch((err) => {
|
||||
throw new InternalException("Failed deleting template", err);
|
||||
throw new InternalException(
|
||||
`Failed deleting template${err.code.includes("ER_ROW_IS_REFERENCED") ? " due to referenced data" : ""}`,
|
||||
err
|
||||
);
|
||||
});
|
||||
}
|
||||
}
|
||||
|
|
|
@ -6,7 +6,10 @@ import NewsletterDatesFactory from "../../../factory/admin/club/newsletter/newsl
|
|||
import NewsletterRecipientsService from "../../../service/club/newsletter/newsletterRecipientsService";
|
||||
import NewsletterRecipientsFactory from "../../../factory/admin/club/newsletter/newsletterRecipients";
|
||||
import { FileSystemHelper } from "../../../helpers/fileSystemHelper";
|
||||
import { CreateNewsletterCommand, SynchronizeNewsletterCommand } from "../../../command/club/newsletter/newsletterCommand";
|
||||
import {
|
||||
CreateNewsletterCommand,
|
||||
SynchronizeNewsletterCommand,
|
||||
} from "../../../command/club/newsletter/newsletterCommand";
|
||||
import NewsletterCommandHandler from "../../../command/club/newsletter/newsletterCommandHandler";
|
||||
import { SynchronizeNewsletterDatesCommand } from "../../../command/club/newsletter/newsletterDatesCommand";
|
||||
import NewsletterDatesCommandHandler from "../../../command/club/newsletter/newsletterDatesCommandHandler";
|
||||
|
@ -188,15 +191,14 @@ export async function createNewsletter(req: Request, res: Response): Promise<any
|
|||
export async function getNewsletterPrintoutProgressById(req: Request, res: Response): Promise<any> {
|
||||
let newsletterId = parseInt(req.params.newsletterId);
|
||||
|
||||
res.setHeader("Content-Type", "text/event-stream");
|
||||
res.setHeader("Cache-Control", "no-cache");
|
||||
res.setHeader("Connection", "keep-alive");
|
||||
|
||||
res.flushHeaders();
|
||||
res.writeHead(200, {
|
||||
"Content-Type": "text/plain",
|
||||
"Transfer-Encoding": "chunked",
|
||||
});
|
||||
|
||||
const progressHandler = (data: NewsletterEventType) => {
|
||||
if (data.newsletterId == newsletterId && data.kind == "pdf") {
|
||||
res.write(JSON.stringify(data));
|
||||
res.write(JSON.stringify(data) + "//");
|
||||
}
|
||||
};
|
||||
|
||||
|
@ -287,15 +289,14 @@ export async function sendNewsletterById(req: Request, res: Response): Promise<a
|
|||
export async function getNewsletterSendingProgressById(req: Request, res: Response): Promise<any> {
|
||||
let newsletterId = parseInt(req.params.newsletterId);
|
||||
|
||||
res.setHeader("Content-Type", "text/event-stream");
|
||||
res.setHeader("Cache-Control", "no-cache");
|
||||
res.setHeader("Connection", "keep-alive");
|
||||
|
||||
res.flushHeaders();
|
||||
res.writeHead(200, {
|
||||
"Content-Type": "text/plain",
|
||||
"Transfer-Encoding": "chunked",
|
||||
});
|
||||
|
||||
const progressHandler = (data: NewsletterEventType) => {
|
||||
if (data.newsletterId == newsletterId && data.kind == "mail") {
|
||||
res.write(JSON.stringify(data));
|
||||
res.write(JSON.stringify(data) + "//");
|
||||
}
|
||||
};
|
||||
|
||||
|
|
|
@ -2,7 +2,7 @@ import { Request, Response } from "express";
|
|||
import NewsletterConfigService from "../../../service/settings/newsletterConfigService";
|
||||
import NewsletterConfigFactory from "../../../factory/admin/settings/newsletterConfig";
|
||||
import NewsletterConfigCommandHandler from "../../../command/settings/newsletterConfig/newsletterConfigCommandHandler";
|
||||
import { DeleteNewsletterConfigCommand, SetNewsletterConfigCommand } from "../../../command/settings/newsletterConfig/newsletterConfigCommand";
|
||||
import { SetNewsletterConfigCommand } from "../../../command/settings/newsletterConfig/newsletterConfigCommand";
|
||||
|
||||
/**
|
||||
* @description get all newsletterConfigs
|
||||
|
@ -47,20 +47,3 @@ export async function setNewsletterConfig(req: Request, res: Response): Promise<
|
|||
|
||||
res.send(id);
|
||||
}
|
||||
|
||||
/**
|
||||
* @description delete award
|
||||
* @param req {Request} Express req object
|
||||
* @param res {Response} Express res object
|
||||
* @returns {Promise<*>}
|
||||
*/
|
||||
export async function deleteNewsletterConfig(req: Request, res: Response): Promise<any> {
|
||||
const comTypeId = parseInt(req.params.comTypeId);
|
||||
|
||||
let deleteNewsletterConfig: DeleteNewsletterConfigCommand = {
|
||||
comTypeId: comTypeId,
|
||||
};
|
||||
await NewsletterConfigCommandHandler.delete(deleteNewsletterConfig);
|
||||
|
||||
res.sendStatus(204);
|
||||
}
|
||||
|
|
|
@ -8,9 +8,6 @@ import UserService from "../service/user/userService";
|
|||
import speakeasy from "speakeasy";
|
||||
import UnauthorizedRequestException from "../exceptions/unauthorizedRequestException";
|
||||
import RefreshService from "../service/refreshService";
|
||||
import UserPermissionService from "../service/user/userPermissionService";
|
||||
import PermissionHelper from "../helpers/permissionHelper";
|
||||
import RolePermissionService from "../service/user/rolePermissionService";
|
||||
|
||||
/**
|
||||
* @description Check authentication status by token
|
||||
|
@ -39,6 +36,7 @@ export async function login(req: Request, res: Response): Promise<any> {
|
|||
|
||||
let refreshCommand: CreateRefreshCommand = {
|
||||
userId: id,
|
||||
isFromPwa: req.isPWA,
|
||||
};
|
||||
let refreshToken = await RefreshCommandHandler.create(refreshCommand);
|
||||
|
||||
|
@ -83,6 +81,7 @@ export async function refresh(req: Request, res: Response): Promise<any> {
|
|||
|
||||
let refreshCommand: CreateRefreshCommand = {
|
||||
userId: tokenUserId,
|
||||
isFromPwa: req.isPWA,
|
||||
};
|
||||
let refreshToken = await RefreshCommandHandler.create(refreshCommand);
|
||||
|
||||
|
|
|
@ -40,17 +40,17 @@ export class communication {
|
|||
@Column()
|
||||
typeId: number;
|
||||
|
||||
@ManyToOne(() => communicationType, (communicationType) => communicationType.communications, {
|
||||
nullable: false,
|
||||
onDelete: "RESTRICT",
|
||||
onUpdate: "RESTRICT",
|
||||
})
|
||||
type: communicationType;
|
||||
|
||||
@ManyToOne(() => member, (member) => member.awards, {
|
||||
nullable: false,
|
||||
onDelete: "CASCADE",
|
||||
onUpdate: "RESTRICT",
|
||||
})
|
||||
member: member;
|
||||
|
||||
@ManyToOne(() => communicationType, (communicationType) => communicationType.communications, {
|
||||
nullable: false,
|
||||
onDelete: "RESTRICT",
|
||||
onUpdate: "RESTRICT",
|
||||
})
|
||||
type: communicationType;
|
||||
}
|
||||
|
|
|
@ -9,7 +9,7 @@ export class protocolPrintout {
|
|||
@Column({ type: "varchar", length: 255 })
|
||||
title: string;
|
||||
|
||||
@Column({ type: "int" })
|
||||
@Column({ type: "int", default: "1" })
|
||||
iteration: number;
|
||||
|
||||
@Column({ type: "varchar", length: 255 })
|
||||
|
|
|
@ -13,6 +13,7 @@ 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_EXPIRATION = process.env.JWT_EXPIRATION ?? "15m";
|
||||
export const REFRESH_EXPIRATION = process.env.REFRESH_EXPIRATION ?? "1d";
|
||||
export const PWA_REFRESH_EXPIRATION = process.env.PWA_REFRESH_EXPIRATION ?? "5d";
|
||||
|
||||
export const MAIL_USERNAME = process.env.MAIL_USERNAME ?? "";
|
||||
export const MAIL_PASSWORD = process.env.MAIL_PASSWORD ?? "";
|
||||
|
@ -35,6 +36,7 @@ export function configCheck() {
|
|||
if (JWT_SECRET == "" || typeof JWT_SECRET != "string") throw new Error("set valid value to JWT_SECRET");
|
||||
checkMS(JWT_EXPIRATION, "JWT_EXPIRATION");
|
||||
checkMS(REFRESH_EXPIRATION, "REFRESH_EXPIRATION");
|
||||
checkMS(PWA_REFRESH_EXPIRATION, "PWA_REFRESH_EXPIRATION");
|
||||
|
||||
if (MAIL_USERNAME == "" || typeof MAIL_USERNAME != "string") throw new Error("set valid value to MAIL_USERNAME");
|
||||
if (MAIL_PASSWORD == "" || typeof MAIL_PASSWORD != "string") throw new Error("set valid value to MAIL_PASSWORD");
|
||||
|
@ -42,7 +44,6 @@ export function configCheck() {
|
|||
if (typeof MAIL_PORT != "number") throw new Error("set valid numeric value to MAIL_PORT");
|
||||
if (MAIL_SECURE != "true" && MAIL_SECURE != "false") throw new Error("set 'true' or 'false' to MAIL_SECURE");
|
||||
|
||||
console.log(CLUB_WEBSITE);
|
||||
if (
|
||||
CLUB_WEBSITE != "" &&
|
||||
!/^(http(s):\/\/.)[-a-zA-Z0-9@:%._\+~#=]{2,256}\.[a-z]{2,6}\b([-a-zA-Z0-9@:%_\+.~#?&//=]*)$/.test(CLUB_WEBSITE)
|
||||
|
|
|
@ -33,12 +33,21 @@ export abstract class NewsletterHelper {
|
|||
private static formatJobEmit(
|
||||
event: "progress" | "complete",
|
||||
kind: "pdf" | "mail",
|
||||
factor: "success" | "failed" | "info",
|
||||
newsletterId: number,
|
||||
total: number,
|
||||
iteration: number,
|
||||
msg: string
|
||||
) {
|
||||
this.jobStatus.emit<NewsletterEventType>(event, { kind, newsletterId, total, iteration, msg, date: new Date() });
|
||||
this.jobStatus.emit<NewsletterEventType>(event, {
|
||||
kind,
|
||||
newsletterId,
|
||||
factor,
|
||||
total,
|
||||
iteration,
|
||||
msg,
|
||||
date: new Date(),
|
||||
});
|
||||
}
|
||||
|
||||
public static buildData(
|
||||
|
@ -132,8 +141,6 @@ export abstract class NewsletterHelper {
|
|||
}
|
||||
}
|
||||
|
||||
console.log(queryMemberIds);
|
||||
|
||||
let members = await MemberService.getAll(0, 1000);
|
||||
|
||||
return members[0].filter((m) => queryMemberIds.includes(m.id));
|
||||
|
@ -171,18 +178,9 @@ export abstract class NewsletterHelper {
|
|||
allowedForMail.includes(m.sendNewsletter?.type?.id)
|
||||
);
|
||||
|
||||
this.formatJobEmit("progress", "mail", newsletterId, mailRecipients.length, 0, "starting sending");
|
||||
this.formatJobEmit("progress", "mail", "info", newsletterId, mailRecipients.length, 0, "starting sending");
|
||||
|
||||
for (const [index, rec] of mailRecipients.entries()) {
|
||||
this.formatJobEmit(
|
||||
"progress",
|
||||
"mail",
|
||||
newsletterId,
|
||||
mailRecipients.length,
|
||||
index,
|
||||
`start sending to ${rec.sendNewsletter.email}`
|
||||
);
|
||||
|
||||
let data = this.buildData(newsletter, dates, rec);
|
||||
|
||||
const { body } = await TemplateHelper.renderFileForModule({
|
||||
|
@ -197,9 +195,10 @@ export abstract class NewsletterHelper {
|
|||
this.formatJobEmit(
|
||||
"progress",
|
||||
"mail",
|
||||
"success",
|
||||
newsletterId,
|
||||
mailRecipients.length,
|
||||
index,
|
||||
index + 1,
|
||||
`successfully sent to ${rec.sendNewsletter.email}`
|
||||
);
|
||||
})
|
||||
|
@ -207,18 +206,19 @@ export abstract class NewsletterHelper {
|
|||
this.formatJobEmit(
|
||||
"progress",
|
||||
"mail",
|
||||
"failed",
|
||||
newsletterId,
|
||||
mailRecipients.length,
|
||||
index,
|
||||
index + 1,
|
||||
`failed to send to ${rec.sendNewsletter.email}`
|
||||
);
|
||||
console.log("mail send", err);
|
||||
});
|
||||
}
|
||||
|
||||
this.formatJobEmit(
|
||||
"complete",
|
||||
"mail",
|
||||
"info",
|
||||
newsletterId,
|
||||
mailRecipients.length,
|
||||
mailRecipients.length,
|
||||
|
@ -249,21 +249,12 @@ export abstract class NewsletterHelper {
|
|||
(m) => !notAllowedForPdf.includes(m.sendNewsletter?.type?.id) || m.sendNewsletter == null
|
||||
);
|
||||
|
||||
this.formatJobEmit("progress", "pdf", newsletterId, pdfRecipients.length, 0, "starting sending");
|
||||
this.formatJobEmit("progress", "pdf", "info", newsletterId, pdfRecipients.length + 1, 0, "starting sending");
|
||||
|
||||
for (const [index, rec] of [
|
||||
...pdfRecipients,
|
||||
{ id: 0, firstname: "Alle Mitglieder", lastname: CLUB_NAME } as member,
|
||||
].entries()) {
|
||||
this.formatJobEmit(
|
||||
"progress",
|
||||
"pdf",
|
||||
newsletterId,
|
||||
pdfRecipients.length,
|
||||
index,
|
||||
`start print for ${rec.lastname}, ${rec.firstname}`
|
||||
);
|
||||
|
||||
let data = this.buildData(newsletter, dates, rec, printWithAdress.includes(rec.sendNewsletter?.type?.id));
|
||||
|
||||
await PdfExport.renderFile({
|
||||
|
@ -277,9 +268,10 @@ export abstract class NewsletterHelper {
|
|||
this.formatJobEmit(
|
||||
"progress",
|
||||
"pdf",
|
||||
"success",
|
||||
newsletterId,
|
||||
pdfRecipients.length,
|
||||
index,
|
||||
pdfRecipients.length + 1,
|
||||
index + 1,
|
||||
`successfully printed for ${rec.lastname}, ${rec.firstname}`
|
||||
);
|
||||
})
|
||||
|
@ -287,24 +279,15 @@ export abstract class NewsletterHelper {
|
|||
this.formatJobEmit(
|
||||
"progress",
|
||||
"pdf",
|
||||
"failed",
|
||||
newsletterId,
|
||||
pdfRecipients.length,
|
||||
index,
|
||||
pdfRecipients.length + 1,
|
||||
index + 1,
|
||||
`failed print for ${rec.lastname}, ${rec.firstname}`
|
||||
);
|
||||
console.log("pdf print", err);
|
||||
});
|
||||
}
|
||||
|
||||
this.formatJobEmit(
|
||||
"progress",
|
||||
"pdf",
|
||||
newsletterId,
|
||||
pdfRecipients.length,
|
||||
pdfRecipients.length,
|
||||
"starting pdf combine"
|
||||
);
|
||||
|
||||
await PdfExport.sqashToSingleFile(
|
||||
`newsletter/${newsletter.id}_${newsletter.title.replace(" ", "")}`,
|
||||
"allPdfsTogether",
|
||||
|
@ -314,9 +297,10 @@ export abstract class NewsletterHelper {
|
|||
this.formatJobEmit(
|
||||
"progress",
|
||||
"pdf",
|
||||
"success",
|
||||
newsletterId,
|
||||
pdfRecipients.length,
|
||||
pdfRecipients.length,
|
||||
pdfRecipients.length + 1,
|
||||
pdfRecipients.length + 1,
|
||||
"sucessfully combined pdf"
|
||||
);
|
||||
})
|
||||
|
@ -324,20 +308,21 @@ export abstract class NewsletterHelper {
|
|||
this.formatJobEmit(
|
||||
"progress",
|
||||
"pdf",
|
||||
"failed",
|
||||
newsletterId,
|
||||
pdfRecipients.length,
|
||||
pdfRecipients.length,
|
||||
pdfRecipients.length + 1,
|
||||
pdfRecipients.length + 1,
|
||||
"failed combining pdf"
|
||||
);
|
||||
console.log("pdf squash", err);
|
||||
});
|
||||
|
||||
this.formatJobEmit(
|
||||
"complete",
|
||||
"pdf",
|
||||
"info",
|
||||
newsletterId,
|
||||
pdfRecipients.length,
|
||||
pdfRecipients.length,
|
||||
pdfRecipients.length + 1,
|
||||
pdfRecipients.length + 1,
|
||||
`completed printing process`
|
||||
);
|
||||
}
|
||||
|
|
|
@ -12,6 +12,7 @@ declare global {
|
|||
username: string;
|
||||
isOwner: boolean;
|
||||
permissions: PermissionObject;
|
||||
isPWA: boolean;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
11
src/middleware/detectPWA.ts
Normal file
11
src/middleware/detectPWA.ts
Normal file
|
@ -0,0 +1,11 @@
|
|||
import { Request, Response } from "express";
|
||||
|
||||
export default async function detectPWA(req: Request, res: Response, next: Function) {
|
||||
const userAgent = req.headers["user-agent"] || "";
|
||||
if ((userAgent.includes("Mobile") && userAgent.includes("Standalone")) || req.headers["x-pwa-client"] === "true") {
|
||||
req.isPWA = true;
|
||||
} else {
|
||||
req.isPWA = false;
|
||||
}
|
||||
next();
|
||||
}
|
|
@ -19,7 +19,6 @@ export class InternalId1735822722235 implements MigrationInterface {
|
|||
);
|
||||
|
||||
// let memberships = await queryRunner.manager.getRepository(membership).find();
|
||||
// console.log(memberships);
|
||||
// let internalIds = memberships.reduce<{ [key: number]: Array<string> }>((acc, cur) => {
|
||||
// let memberId = cur.memberId;
|
||||
// let setIds = acc[memberId] ?? [];
|
||||
|
@ -30,7 +29,6 @@ export class InternalId1735822722235 implements MigrationInterface {
|
|||
// return acc;
|
||||
// }, {});
|
||||
|
||||
// console.log(internalIds);
|
||||
// for (const [id, value] of Object.entries(internalIds)) {
|
||||
// const ids = value.filter((v) => v != null).join(", ");
|
||||
// if (ids) {
|
||||
|
|
|
@ -1,6 +1,5 @@
|
|||
import express, { Request, Response } from "express";
|
||||
import {
|
||||
deleteNewsletterConfig,
|
||||
getAllNewsletterConfigs,
|
||||
getNewsletterConfigById,
|
||||
setNewsletterConfig,
|
||||
|
@ -25,12 +24,4 @@ router.put(
|
|||
}
|
||||
);
|
||||
|
||||
router.delete(
|
||||
"/:comTypeId",
|
||||
PermissionHelper.passCheckMiddleware("create", "settings", "newsletter_config"),
|
||||
async (req: Request, res: Response) => {
|
||||
await deleteNewsletterConfig(req, res);
|
||||
}
|
||||
);
|
||||
|
||||
export default router;
|
||||
|
|
|
@ -13,6 +13,7 @@ import reset from "./reset";
|
|||
import auth from "./auth";
|
||||
import admin from "./admin/index";
|
||||
import user from "./user";
|
||||
import detectPWA from "../middleware/detectPWA";
|
||||
|
||||
export default (app: Express) => {
|
||||
app.set("query parser", "extended");
|
||||
|
@ -25,6 +26,7 @@ export default (app: Express) => {
|
|||
app.use(cors());
|
||||
app.options("*", cors());
|
||||
|
||||
app.use(detectPWA);
|
||||
app.use("/api/public", publicAvailable);
|
||||
app.use("/api/setup", allowSetup, setup);
|
||||
app.use("/api/reset", reset);
|
||||
|
|
|
@ -12,6 +12,7 @@ export default abstract class CalendarService {
|
|||
.getRepository(calendar)
|
||||
.createQueryBuilder("calendar")
|
||||
.leftJoinAndSelect("calendar.type", "type")
|
||||
.orderBy("starttime", "ASC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
|
@ -16,6 +16,7 @@ export default abstract class CommunicationService {
|
|||
.leftJoinAndSelect("communication.member", "member")
|
||||
.leftJoinAndSelect("member.sendNewsletter", "sendNewsletter")
|
||||
.where("communication.memberId = :memberId", { memberId: memberId })
|
||||
.orderBy("communicationType.type", "ASC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
|
@ -14,6 +14,7 @@ export default abstract class MemberAwardService {
|
|||
.createQueryBuilder("memberAwards")
|
||||
.leftJoinAndSelect("memberAwards.award", "award")
|
||||
.where("memberAwards.memberId = :memberId", { memberId: memberId })
|
||||
.orderBy("award.award", "ASC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
|
@ -14,6 +14,8 @@ export default abstract class MemberExecutivePositionService {
|
|||
.createQueryBuilder("memberExecutivePositions")
|
||||
.leftJoinAndSelect("memberExecutivePositions.executivePosition", "executivePosition")
|
||||
.where("memberExecutivePositions.memberId = :memberId", { memberId: memberId })
|
||||
.orderBy("executivePosition.position", "ASC")
|
||||
.addOrderBy("memberExecutivePositions.start", "DESC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
|
@ -14,6 +14,7 @@ export default abstract class MemberQualificationService {
|
|||
.createQueryBuilder("memberQualifications")
|
||||
.leftJoinAndSelect("memberQualifications.qualification", "qualification")
|
||||
.where("memberQualifications.memberId = :memberId", { memberId: memberId })
|
||||
.orderBy("qualification.qualification", "ASC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
|
@ -12,6 +12,7 @@ export default abstract class AwardService {
|
|||
return await dataSource
|
||||
.getRepository(award)
|
||||
.createQueryBuilder("award")
|
||||
.orderBy("award", "ASC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
|
@ -11,6 +11,7 @@ export default abstract class CalendarTypeService {
|
|||
return await dataSource
|
||||
.getRepository(calendarType)
|
||||
.createQueryBuilder("calendarType")
|
||||
.orderBy("type", "ASC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
|
@ -11,6 +11,7 @@ export default abstract class CommunicationTypeService {
|
|||
return await dataSource
|
||||
.getRepository(communicationType)
|
||||
.createQueryBuilder("communicationType")
|
||||
.orderBy("type", "ASC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
|
@ -12,6 +12,7 @@ export default abstract class ExecutivePositionService {
|
|||
return await dataSource
|
||||
.getRepository(executivePosition)
|
||||
.createQueryBuilder("executivePosition")
|
||||
.orderBy("position", "ASC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
|
@ -12,6 +12,7 @@ export default abstract class MembershipStatusService {
|
|||
return await dataSource
|
||||
.getRepository(membershipStatus)
|
||||
.createQueryBuilder("membershipStatus")
|
||||
.orderBy("status", "ASC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
|
@ -13,6 +13,7 @@ export default abstract class NewsletterConfigService {
|
|||
.getRepository(newsletterConfig)
|
||||
.createQueryBuilder("newsletterConfig")
|
||||
.leftJoinAndSelect("newsletterConfig.comType", "comType")
|
||||
.orderBy("comType.type", "ASC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
|
@ -13,6 +13,7 @@ export default abstract class QualificationService {
|
|||
return await dataSource
|
||||
.getRepository(qualification)
|
||||
.createQueryBuilder("qualification")
|
||||
.orderBy("qualification", "ASC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
|
@ -11,6 +11,7 @@ export default abstract class QueryStoreService {
|
|||
return await dataSource
|
||||
.getRepository(query)
|
||||
.createQueryBuilder("queryStore")
|
||||
.orderBy("title", "ASC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
|
@ -12,6 +12,7 @@ export default abstract class TemplateService {
|
|||
return await dataSource
|
||||
.getRepository(template)
|
||||
.createQueryBuilder("template")
|
||||
.orderBy("template", "ASC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
|
@ -14,6 +14,7 @@ export default abstract class TemplateUsageService {
|
|||
.leftJoinAndSelect("templateUsage.header", "headerTemplate")
|
||||
.leftJoinAndSelect("templateUsage.body", "bodyTemplate")
|
||||
.leftJoinAndSelect("templateUsage.footer", "footerTemplate")
|
||||
.orderBy("scope", "ASC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
|
@ -12,6 +12,7 @@ export default abstract class RoleService {
|
|||
.getRepository(role)
|
||||
.createQueryBuilder("role")
|
||||
.leftJoinAndSelect("role.permissions", "role_permissions")
|
||||
.orderBy("role", "ASC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
|
@ -15,6 +15,8 @@ export default abstract class UserService {
|
|||
.leftJoinAndSelect("user.roles", "roles")
|
||||
.leftJoinAndSelect("user.permissions", "permissions")
|
||||
.leftJoinAndSelect("roles.permissions", "role_permissions")
|
||||
.orderBy("firstname", "ASC")
|
||||
.addOrderBy("lastname", "ASC")
|
||||
.getMany()
|
||||
.then((res) => {
|
||||
return res;
|
||||
|
|
Loading…
Reference in a new issue