@@ -331,7 +331,7 @@ async function createResource (currentUser, resource) {
331
331
332
332
// handle doesn't change in current version
333
333
// Seems we don't need handle auto-correction(e.g. "THomaskranitsas"->"thomaskranitsas")
334
- const { resources, memberId } = await init ( currentUser , challengeId , resource , true )
334
+ const { resources, memberId, handle , email , challenge } = await init ( currentUser , challengeId , resource , true )
335
335
336
336
if ( _ . reduce ( resources ,
337
337
( result , r ) => _ . toString ( r . memberId ) === _ . toString ( memberId ) && r . roleId === resource . roleId ? true : result ,
@@ -358,6 +358,25 @@ async function createResource (currentUser, resource) {
358
358
359
359
logger . debug ( `Created resource: ${ JSON . stringify ( _ . pick ( ret , payloadFields ) ) } ` )
360
360
await helper . postEvent ( config . RESOURCE_CREATE_TOPIC , _ . pick ( ret , payloadFields ) )
361
+ if ( ! _ . get ( challenge , 'task.isTask' , false ) && resource . roleId === config . SUBMITTER_RESOURCE_ROLE_ID ) {
362
+ await helper . postEvent ( config . EMAIL_NOTIFICATIN_TOPIC , {
363
+ from : config . REGISTRATION_EMAIL . EMAIL_FROM ,
364
+ replyTo : config . REGISTRATION_EMAIL . EMAIL_FROM ,
365
+ recipients : [ email ] ,
366
+ data : {
367
+ handle,
368
+ challengeName : challenge . name ,
369
+ forum : _ . get ( challenge , 'discussions[0].url' ) ,
370
+ submissionEndTime : _ . get ( _ . find ( challenge . phases , phase => phase . name === "Submission" ) , 'scheduledEndDate' ) ,
371
+ submitUrl : _ . replace ( config . REGISTRATION_EMAIL . SUBMIT_URL , ':id' , challengeId ) ,
372
+ reviewAppUrl : config . REGISTRATION_EMAIL . REVIEW_APP_URL ,
373
+ helpUrl : config . REGISTRATION_EMAIL . HELP_URL ,
374
+ support : config . REGISTRATION_EMAIL . SUPPORT_EMAIL
375
+ } ,
376
+ sendgrid_template_id : config . REGISTRATION_EMAIL . SENDGRID_TEMPLATE_ID ,
377
+ version : "v3"
378
+ } )
379
+ }
361
380
362
381
return ret
363
382
} catch ( err ) {
0 commit comments