hotfix: insert or update with postgres

src/command/club/protocol/protocolAgendaCommand.ts

@@ -1,7 +1,7 @@
 export interface SynchronizeProtocolAgendaCommand {
-  id?: number;
+  id: number;
   topic: string;
   context: string;
-  sort?: number;
+  sort: number;
   protocolId: number;
 }

src/command/club/protocol/protocolAgendaCommandHandler.ts

@@ -39,13 +39,16 @@ export default abstract class ProtocolAgendaCommandHandler {
    */
   static async sync(syncProtocolAgenda: Array<SynchronizeProtocolAgendaCommand>): Promise<void> {
     return await dataSource
-      .createQueryBuilder()
-      .insert()
-      .into(protocolAgenda)
-      .values(syncProtocolAgenda)
-      .orUpdate(["topic", "context", "sort"], ["id"])
-      .execute()
-      .then(() => {})
+      .transaction(async (transactionalEntityManager) => {
+        for (const agenda of syncProtocolAgenda) {
+          await transactionalEntityManager
+            .createQueryBuilder()
+            .update(protocolAgenda)
+            .set(agenda)
+            .where({ id: agenda.id })
+            .execute();
+        }
+      })
       .catch((err) => {
         throw new DatabaseActionException("SYNC", "protocolAgenda", err);
       });

src/command/club/protocol/protocolDecisionCommand.ts

@@ -1,7 +1,7 @@
 export interface SynchronizeProtocolDecisionCommand {
-  id?: number;
+  id: number;
   topic: string;
   context: string;
-  sort?: number;
+  sort: number;
   protocolId: number;
 }

src/command/club/protocol/protocolDecisionCommandHandler.ts

@@ -38,12 +38,16 @@ export default abstract class ProtocolDecisionCommandHandler {
    */
   static async sync(syncProtocolDecisions: Array<SynchronizeProtocolDecisionCommand>): Promise<void> {
     return await dataSource
-      .createQueryBuilder()
-      .insert()
-      .into(protocolDecision)
-      .values(syncProtocolDecisions)
-      .orUpdate(["topic", "context", "sort"], ["id"])
-      .execute()
+      .transaction(async (transactionalEntityManager) => {
+        for (const decision of syncProtocolDecisions) {
+          await transactionalEntityManager
+            .createQueryBuilder()
+            .update(protocolDecision)
+            .set(decision)
+            .where({ id: decision.id })
+            .execute();
+        }
+      })
       .then(() => {})
       .catch((err) => {
         throw new DatabaseActionException("SYNC", "protocolDecision", err);

src/command/club/protocol/protocolVotingCommand.ts

@@ -5,6 +5,6 @@ export interface SynchronizeProtocolVotingCommand {
   favour: number;
   abstain: number;
   against: number;
-  sort?: number;
+  sort: number;
   protocolId: number;
 }

src/command/club/protocol/protocolVotingCommandHandler.ts

@@ -38,12 +38,16 @@ export default abstract class ProtocolVotingCommandHandler {
    */
   static async sync(syncProtocolVotings: Array<SynchronizeProtocolVotingCommand>): Promise<void> {
     return await dataSource
-      .createQueryBuilder()
-      .insert()
-      .into(protocolVoting)
-      .values(syncProtocolVotings)
-      .orUpdate(["topic", "context", "favour", "abstain", "against", "sort"], ["id"])
-      .execute()
+      .transaction(async (transactionalEntityManager) => {
+        for (const voting of syncProtocolVotings) {
+          await transactionalEntityManager
+            .createQueryBuilder()
+            .update(protocolVoting)
+            .set(voting)
+            .where({ id: voting.id })
+            .execute();
+        }
+      })
       .then(() => {})
       .catch((err) => {
         throw new DatabaseActionException("SYNC", "protocolVoting", err);

src/command/configuration/newsletterConfig/newsletterConfigCommandHandler.ts

@@ -19,7 +19,7 @@ export default abstract class NewsletterConfigCommandHandler {
         comTypeId: setNewsletterConfig.comTypeId,
         config: setNewsletterConfig.config,
       })
-      .orUpdate(["config"], "comTypeId")
+      .orUpdate(["config"], ["comTypeId"])
       .execute()
       .then((result) => {})
       .catch((err) => {