Publish changes

clashperk · Apr 7, 2024 · 76bcb83 · 76bcb83
1 parent 780985e
commit 76bcb83
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 1 deletion.
diff --git a/apps/service-auth/src/consumer/consumer.service.ts b/apps/service-auth/src/consumer/consumer.service.ts
@@ -14,7 +14,7 @@ export class ConsumerService {
  constructor(@Inject(KAFKA_CONSUMER) private consumer: Consumer) {}
 
  async onModuleInit() {
- this.consumer.subscribe({ topics: Object.values(LogType), fromBeginning: true });
+ await this.consumer.subscribe({ topics: Object.values(LogType), fromBeginning: true });
 
  await this.consumer.run({
  eachMessage: async ({ message, topic }) => {

diff --git a/apps/service-clans/src/service-clans.service.ts b/apps/service-clans/src/service-clans.service.ts
@@ -262,6 +262,20 @@ export class ClansService {
  });
  }
 
+ if (
+ payload.donationsLog.length ||
+ payload.donationsReceivedLog ||
+ payload.leagueChangeLog ||
+ payload.memberJoinedLog ||
+ payload.memberLeftLog ||
+ payload.reJoinedLog ||
+ payload.nameChangeLog ||
+ payload.townHallChangeLog ||
+ payload.roleChangeLog
+ ) {
+ this.publish(LogType.CLAN_MEMBER_CHANGE, payload);
+ }
+
  return payload;
  }