File tree Expand file tree Collapse file tree
apps/web/app/(ee)/api/cron/rewards/process Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -6,7 +6,10 @@ import {
66import { isStaleRewardVersion } from "@/lib/api/rewards/reward-version" ;
77import { withCron } from "@/lib/cron/with-cron" ;
88import { 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" ;
1013import { REWARD_EVENT_COLUMN_MAPPING } from "@/lib/zod/schemas/rewards" ;
1114import { Prisma } from "@prisma/client" ;
1215import { 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 ,
You can’t perform that action at this time.
0 commit comments