From a99a568f391b9ea16ed5ee354c03260364d392fd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Claus-Peter=20H=C3=BCbner?= <claus-peter.huebner@email.de>
Date: Tue, 5 Jul 2022 04:20:54 +0200
Subject: [PATCH] emit Redeem-Events

---
 backend/src/graphql/model/Event.ts           | 57 ++++++++++++++++++++
 backend/src/graphql/resolver/UserResolver.ts | 15 +++++-
 2 files changed, 70 insertions(+), 2 deletions(-)
 create mode 100644 backend/src/graphql/model/Event.ts

diff --git a/backend/src/graphql/model/Event.ts b/backend/src/graphql/model/Event.ts
new file mode 100644
index 000000000..a8c0ef885
--- /dev/null
+++ b/backend/src/graphql/model/Event.ts
@@ -0,0 +1,57 @@
+import { ObjectType, Field } from 'type-graphql'
+import { EventProtocol } from '@entity/EventProtocol'
+import { EventProtocolType } from '@/event/EventProtocolType'
+import Decimal from 'decimal.js-light'
+
+export interface EventInterface {
+  type: string
+  createdAt: Date
+  userId: number
+  xUserId?: number
+  xCommunityId?: number
+  transactionId?: number
+  contributionId?: number
+  amount?: Decimal
+}
+
+@ObjectType()
+export class Event {
+  constructor(event: EventProtocol) {
+    this.id = event.id
+    this.type = event.type
+    this.createdAt = event.createdAt
+    this.userId = event.userId
+    this.xUserId = event.xUserId
+    this.xCommunityId = event.xCommunityId
+    this.transactionId = event.transactionId
+    this.contributionId = event.contributionId
+    this.amount = event.amount
+  }
+
+  @Field(() => Number)
+  id: number
+
+  @Field(() => EventProtocolType)
+  type: string
+
+  @Field(() => Date)
+  createdAt: Date
+
+  @Field(() => Number)
+  userId: number
+
+  @Field(() => Number, { nullable: true })
+  xUserId: number | null
+
+  @Field(() => Number, { nullable: true })
+  xCommunityId: number | null
+
+  @Field(() => Number, { nullable: true })
+  transactionId: number | null
+
+  @Field(() => Number, { nullable: true })
+  contributionId: number | null
+
+  @Field(() => Decimal)
+  amount: Decimal | null
+}
diff --git a/backend/src/graphql/resolver/UserResolver.ts b/backend/src/graphql/resolver/UserResolver.ts
index f7ccb170b..ea4006779 100644
--- a/backend/src/graphql/resolver/UserResolver.ts
+++ b/backend/src/graphql/resolver/UserResolver.ts
@@ -23,7 +23,7 @@ import { sendAccountMultiRegistrationEmail } from '@/mailer/sendAccountMultiRegi
 import { klicktippSignIn } from '@/apis/KlicktippController'
 import { RIGHTS } from '@/auth/RIGHTS'
 import { hasElopageBuys } from '@/util/hasElopageBuys'
-import { eventProtocol } from '@/event/EventProtocolEmitter'
+import { EventInterface, eventProtocol } from '@/event/EventProtocolEmitter'
 import { EventProtocolType } from '@/event/EventProtocolType'
 
 // eslint-disable-next-line @typescript-eslint/no-var-requires
@@ -374,6 +374,9 @@ export class UserResolver {
     // const encryptedPrivkey = SecretKeyCryptographyEncrypt(keyPair[1], passwordHash[1])
     const emailHash = getEmailHash(email)
 
+    let eventType = EventProtocolType.REGISTER
+    let eventContributionId = null
+    let eventTransactionId = null
     const dbUser = new DbUser()
     dbUser.email = email
     dbUser.firstName = firstName
@@ -391,6 +394,8 @@ export class UserResolver {
         logger.info('redeemCode found contributionLink=' + contributionLink)
         if (contributionLink) {
           dbUser.contributionLinkId = contributionLink.id
+          eventType = EventProtocolType.REDEEM_REGISTER
+          eventContributionId = contributionLink.id
           /* eventProtocol.emit(
             EventProtocolType.REDEEM_REGISTER,
             new Date(Date.now()),
@@ -404,6 +409,8 @@ export class UserResolver {
         logger.info('redeemCode found transactionLink=' + transactionLink)
         if (transactionLink) {
           dbUser.referrerId = transactionLink.userId
+          eventType = EventProtocolType.REDEEM_REGISTER
+          eventTransactionId = transactionLink.id
           /* eventProtocol.emit(
             EventProtocolType.REDEEM_REGISTER,
             new Date(Date.now()),
@@ -467,9 +474,13 @@ export class UserResolver {
     logger.info('createUser() successful...')
 
     eventProtocol.emit('writeEvent', {
-      type: EventProtocolType.REGISTER,
+      type: eventType,
       createdAt: new Date(),
       userId: dbUser.id,
+      xUserId: null,
+      xCommunityId: null,
+      transactionId: eventTransactionId,
+      contributionId: eventContributionId,
     })
 
     return new User(dbUser)