66import org .avni_integration_service .avni .repository .AvniQueryRepository ;
77import org .avni_integration_service .rwb .config .RwbContextProvider ;
88import org .avni_integration_service .rwb .dto .NudgeUserRequestDTO ;
9+ import org .joda .time .DateTime ;
910import org .springframework .stereotype .Component ;
1011
1112@ Component
@@ -22,18 +23,19 @@ public AvniRwbUserNudgeRepository(AvniMessageRepository avniMessageRepository, A
2223 this .rwbContextProvider = rwbContextProvider ;
2324 }
2425
25- public SendMessageResponse startFlowForContact (NudgeUserRequestDTO nudgeUserRequestDTO ) {
26- return avniMessageRepository .startFlowForContact (createMessageRequestToNudgeUser (nudgeUserRequestDTO ));
26+ public SendMessageResponse sendMessage (NudgeUserRequestDTO nudgeUserRequestDTO ) {
27+ return avniMessageRepository .sendMessage (createMessageRequestToNudgeUser (nudgeUserRequestDTO ));
2728 }
2829
29- private StartFlowForContactRequest createMessageRequestToNudgeUser (NudgeUserRequestDTO nudgeUserRequestDTO ) {
30- StartFlowForContactRequest startFlowForContactRequest = new StartFlowForContactRequest ();
31- startFlowForContactRequest .setReceiverId (nudgeUserRequestDTO .getUserId ());
32- startFlowForContactRequest .setReceiverType (ReceiverType .User );
33- startFlowForContactRequest . setFlowId (rwbContextProvider .get ().getFlowId ());
34- startFlowForContactRequest .setParameters (new String []{
30+ private ManualMessageContract createMessageRequestToNudgeUser (NudgeUserRequestDTO nudgeUserRequestDTO ) {
31+ ManualMessageContract manualMessageContract = new ManualMessageContract ();
32+ manualMessageContract .setReceiverId (nudgeUserRequestDTO .getUserId ());
33+ manualMessageContract .setReceiverType (ReceiverType .User );
34+ manualMessageContract . setMessageTemplateId (rwbContextProvider .get ().getMsgTemplateId ());
35+ manualMessageContract .setParameters (new String []{
3536 nudgeUserRequestDTO .getUserName (), nudgeUserRequestDTO .getSinceNoOfDays (), nudgeUserRequestDTO .getWithinNoOfDays ()});
36- return startFlowForContactRequest ;
37+ manualMessageContract .setScheduledDateTime (new DateTime ()); //set current date time
38+ return manualMessageContract ;
3739 }
3840
3941 public CustomQueryResponse executeCustomQuery (CustomQueryRequest customQueryRequest ) {
0 commit comments