fix: bugfixes

Signed-off-by: Uroš Marolt <uros@marolt.me>

Author: themarolt

services/apps/data_sink_worker/src/service/member.service.ts

@@ -326,6 +326,14 @@ export default class MemberService extends LoggerBase {
                 },
                 'Identity conflict during member creation — reusing existing member, scheduling orphan deletion',
               )
+              await logExecutionTimeV2(
+                () => this.memberRepo.addToSegments(existingMemberId, segmentIds),
+                this.log,
+                'memberService -> create -> addToSegments (conflict path)',
+              )
+              if (releaseMemberLock) {
+                await releaseMemberLock()
+              }
               await this.scheduleOrphanMemberDeletion(id)
               return existingMemberId
             }

services/libs/data-access-layer/src/members/identities.ts

@@ -194,7 +194,7 @@ export async function findMemberIdByVerifiedIdentity(
   qx: QueryExecutor,
   platform: string,
   value: string,
-  type: string,
+  type: MemberIdentityType,
 ): Promise<string | null> {
   const result = await qx.selectOneOrNone(
     `SELECT "memberId" FROM "memberIdentities"