Skip to content

Commit

Permalink
🇺🇦 #StandWithUkraine Fix Bug In MemberService.syncAllWithSlack()
Browse files Browse the repository at this point in the history
  • Loading branch information
raycharius committed Mar 25, 2022
1 parent 55873c8 commit c5bd4ce
Show file tree
Hide file tree
Showing 3 changed files with 16 additions and 1 deletion.
9 changes: 9 additions & 0 deletions services/MemberProvider.ts
Original file line number Diff line number Diff line change
Expand Up @@ -78,6 +78,15 @@ export class MemberProvider extends PrismaService implements IMemberProvider {
return record && MemberProvider.getMemberFromRecord(record);
}

public async findAnyInSystemBySlackId(slackId: string): Promise<Nullable<Member>> {
const record = await this.connection.memberRecord.findFirst({
where: { slackId },
include: { ...this.globalInclude },
});

return record && MemberProvider.getMemberFromRecord(record);
}

public async getAll(): Promise<Member[]> {
const records = await this.connection.memberRecord.findMany({
where: { ...this.globalWhere },
Expand Down
6 changes: 5 additions & 1 deletion services/MemberService.ts
Original file line number Diff line number Diff line change
Expand Up @@ -84,6 +84,10 @@ export class MemberService implements IMemberService {
return this.memberProvider.findBySlackId(slackId);
}

public findAnyInSystemBySlackId(slackId: string): Promise<Nullable<Member>> {
return this.memberProvider.findAnyInSystemBySlackId(slackId);
}

public getAll(): Promise<Member[]> {
return this.memberProvider.getAll();
}
Expand Down Expand Up @@ -175,7 +179,7 @@ export class MemberService implements IMemberService {
const slackMembers = await this.slackMemberProvider.getAll();

for (const member of slackMembers) {
const existing = await this.findBySlackId(member.id);
const existing = await this.findAnyInSystemBySlackId(member.id);

if (existing) {
existing.setName(member.name);
Expand Down
2 changes: 2 additions & 0 deletions services/interfaces/IMemberProvider.ts
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,8 @@ export interface IMemberProvider {

findBySlackId(slackId: string): Promise<Nullable<Member>>;

findAnyInSystemBySlackId(slackId: string): Promise<Nullable<Member>>;

getAll(): Promise<Member[]>;

getAllCheckInNonNull(): Promise<Member[]>;
Expand Down

0 comments on commit c5bd4ce

Please sign in to comment.