Ehrenamt/ff-admin-server
2
0
Fork 0
Code Issues 16 Pull requests Projects Releases 35 Packages Wiki Activity Actions

protocol absence

Browse source
This commit is contained in:
Julian Krauser 2025-01-05 12:12:53 +01:00
parent 455589e2b5
commit 161a9dc51c
10 changed files with 86 additions and 23 deletions
Download patch file Download diff file Expand all files Collapse all files

7
src/command/protocolPresenceCommand.ts
View file

@ -1,4 +1,9 @@
export interface SynchronizeProtocolPresenceCommand {
memberIds: Array<number>;
members: Array<ProtocolPresenceCommand>;
protocolId: number;
}
export interface ProtocolPresenceCommand {
memberId: number;
absent: boolean;
}

49
src/command/protocolPresenceCommandHandler.ts
View file

@ -1,9 +1,9 @@
import { DeleteResult, EntityManager, InsertResult } from "typeorm";
import { DeleteResult, EntityManager, InsertResult, UpdateResult } from "typeorm";
import { dataSource } from "../data-source";
import { protocolPresence } from "../entity/protocolPresence";
import InternalException from "../exceptions/internalException";
import ProtocolPresenceService from "../service/protocolPrecenseService";
import { SynchronizeProtocolPresenceCommand } from "./protocolPresenceCommand";
import { ProtocolPresenceCommand, SynchronizeProtocolPresenceCommand } from "./protocolPresenceCommand";
export default abstract class ProtocolPresenceCommandHandler {
/**
@ -12,14 +12,21 @@ export default abstract class ProtocolPresenceCommandHandler {
* @returns {Promise<void>}
*/
static async sync(syncProtocolPresences: SynchronizeProtocolPresenceCommand): Promise<void> {
let currentPresence = (await ProtocolPresenceService.getAll(syncProtocolPresences.protocolId)).map(
(r) => r.memberId
);
let currentPresence = await ProtocolPresenceService.getAll(syncProtocolPresences.protocolId);
return await dataSource.manager
.transaction(async (manager) => {
let newMembers = syncProtocolPresences.memberIds.filter((r) => !currentPresence.includes(r));
let removeMembers = currentPresence.filter((r) => !syncProtocolPresences.memberIds.includes(r));
let newMembers = syncProtocolPresences.members.filter(
(r) => !currentPresence.some((cp) => cp.memberId == r.memberId)
);
let removeMembers = currentPresence.filter(
(r) => !syncProtocolPresences.members.some((cp) => cp.memberId == r.memberId)
);
let keptMembers = syncProtocolPresences.members.filter(
(m) =>
currentPresence.some((cd) => cd.memberId == m.memberId) &&
!removeMembers.some((cd) => cd.memberId == m.memberId)
);
if (newMembers.length != 0) {
await this.syncPresenceAdd(manager, syncProtocolPresences.protocolId, newMembers);
@ -28,6 +35,10 @@ export default abstract class ProtocolPresenceCommandHandler {
if (removeMembers.length != 0) {
await this.syncPresenceRemove(manager, syncProtocolPresences.protocolId, removeMembers);
}
for (const member of keptMembers) {
await this.syncPresenceUpdate(manager, syncProtocolPresences.protocolId, member);
}
})
.then(() => {})
.catch((err) => {
@ -38,7 +49,7 @@ export default abstract class ProtocolPresenceCommandHandler {
private static async syncPresenceAdd(
manager: EntityManager,
protocolId: number,
memberIds: Array<number>
memberIds: Array<ProtocolPresenceCommand>
): Promise<InsertResult> {
return await manager
.createQueryBuilder()
@ -46,23 +57,39 @@ export default abstract class ProtocolPresenceCommandHandler {
.into(protocolPresence)
.values(
memberIds.map((m) => ({
...m,
protocolId,
memberId: m,
}))
)
.execute();
}
private static async syncPresenceUpdate(
manager: EntityManager,
protocolId: number,
member: ProtocolPresenceCommand
): Promise<UpdateResult> {
return await manager
.createQueryBuilder()
.update(protocolPresence)
.set({
absent: member.absent,
})
.where("memberId = :memberId", { memberId: member.memberId })
.andWhere("protocolId = :protocolId", { protocolId })
.execute();
}
private static async syncPresenceRemove(
manager: EntityManager,
protocolId: number,
memberIds: Array<number>
members: Array<ProtocolPresenceCommand>
): Promise<DeleteResult> {
return await manager
.createQueryBuilder()
.delete()
.from(protocolPresence)
.where("memberId IN (:...ids)", { ids: memberIds })
.where("memberId IN (:...ids)", { ids: members.map((m) => m.memberId) })
.andWhere("protocolId = :protocolId", { protocolId })
.execute();
}