diff --git a/src/common/achievement/index.ts b/src/common/achievement/index.ts index 0ad97e829a..d37b1b51ec 100644 --- a/src/common/achievement/index.ts +++ b/src/common/achievement/index.ts @@ -269,6 +269,7 @@ export async function checkAchievementProgress( } const absoluteValueEventTypes: AchievementEventType[] = [ + AchievementEventType.FollowerGain, AchievementEventType.ReferralCount, AchievementEventType.ReputationGain, AchievementEventType.ReadingStreak, diff --git a/src/workers/cdc/primary.ts b/src/workers/cdc/primary.ts index f562db75b2..409b0644a1 100644 --- a/src/workers/cdc/primary.ts +++ b/src/workers/cdc/primary.ts @@ -108,7 +108,7 @@ import { triggerTypedEvent, } from '../../common'; import { ChangeMessage, ChangeObject, CoresRole, UserVote } from '../../types'; -import { DataSource, IsNull } from 'typeorm'; +import { DataSource, In, IsNull } from 'typeorm'; import { FastifyBaseLogger } from 'fastify'; import { updateAlerts } from '../../schema/alerts'; import { CommentReport } from '../../entity/CommentReport'; @@ -2178,7 +2178,10 @@ const onContentPreferenceChange = async ( where: { referenceId: contentPreferenceUser.referenceId, type: ContentPreferenceType.User, - status: ContentPreferenceStatus.Follow, + status: In([ + ContentPreferenceStatus.Follow, + ContentPreferenceStatus.Subscribed, + ]), }, }); await checkAchievementProgress(