Skip to content

Commit 4a6d2a5

Browse files
authored
Merge pull request #4111 from dubinc/reward-update-email-active-enrollments-only
Reward update emails to active enrollments
2 parents f03c444 + 860398c commit 4a6d2a5

1 file changed

Lines changed: 8 additions & 4 deletions

File tree

  • apps/web/app/(ee)/api/cron/rewards/process

apps/web/app/(ee)/api/cron/rewards/process/route.ts

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,10 @@ import {
66
import { isStaleRewardVersion } from "@/lib/api/rewards/reward-version";
77
import { withCron } from "@/lib/cron/with-cron";
88
import { prisma } from "@/lib/prisma";
9-
import { INACTIVE_ENROLLMENT_STATUSES } from "@/lib/zod/schemas/partners";
9+
import {
10+
ACTIVE_ENROLLMENT_STATUSES,
11+
INACTIVE_ENROLLMENT_STATUSES,
12+
} from "@/lib/zod/schemas/partners";
1013
import { REWARD_EVENT_COLUMN_MAPPING } from "@/lib/zod/schemas/rewards";
1114
import { Prisma } from "@prisma/client";
1215
import { logAndRespond } from "../../utils";
@@ -113,6 +116,7 @@ export const POST = withCron(async ({ rawBody }) => {
113116
},
114117
select: {
115118
id: true,
119+
status: true,
116120
partner: {
117121
select: {
118122
users: {
@@ -161,9 +165,9 @@ export const POST = withCron(async ({ rawBody }) => {
161165
}
162166

163167
if (shouldNotify) {
164-
const users = programEnrollments.flatMap(({ partner }) =>
165-
partner.users.map(({ user }) => user),
166-
);
168+
const users = programEnrollments
169+
.filter(({ status }) => ACTIVE_ENROLLMENT_STATUSES.includes(status))
170+
.flatMap(({ partner }) => partner.users.map(({ user }) => user));
167171

168172
await notifyPartnerRewardChange({
169173
action: event,

0 commit comments

Comments
 (0)