Advertisement
Guest User

Untitled

a guest
Aug 28th, 2015
115
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.18 KB | None | 0 0
  1. // in smsService
  2. exports.messageJobToDrivers = function(data){
  3. return new Promise(function(resolve,reject){
  4. driverService.find().then(function(drivers){
  5. Promise.map(drivers, function(driver){
  6. if (driver && driver.phoneNumber) {
  7. return exports.sendSms(({
  8. to: driver.phoneNumber,
  9. body: "There is a new Get Me request in the job queue"
  10. })).then(function () {
  11. logger.debug("Job message sent to " + driver.phoneNumber);
  12. return;
  13. }).catch(function (err) {
  14. logger.warn("Job message failed to " + driver.phoneNumber);
  15. return;
  16. })
  17. }
  18. }) //no catch here because it can't error
  19. })
  20. //resolve here so that we don't wait for all text messages to go out
  21. resolve(data);
  22. })
  23. }
  24.  
  25.  
  26. //in rideService
  27. exports.createRide = function(data) {
  28. return new Promise(function(resolve, reject) {
  29. if(!data || Object.keys(data).length === 0) {
  30. return reject(new errors.InvalidDataError("Invalid data"));
  31. }
  32.  
  33. data.validation = {
  34. vehicleRequired: true
  35. };
  36.  
  37. // Set requested time
  38. data.requestedTime = new Date();
  39.  
  40. processAndValidateData(data, rideRequestType.create)
  41. .then(saveChargeHold)
  42. .then(createNewRequest)
  43. .then(smsService.messageJobToDrivers)
  44. .then(resolve)
  45. .catch(reject);
  46. });
  47.  
  48. }
  49.  
  50.  
  51. //in deliveryService
  52. create: function(requestBody) {
  53. return new Promise(function(resolve, reject) {
  54. if(!requestBody || Object.keys(requestBody).length === 0) {
  55. return reject(new errors.InvalidDataError('Invalid requestBody'));
  56. }
  57.  
  58. requestBody.requestType = deliveryRequestType.create;
  59.  
  60. processAndValidateData(requestBody)
  61. .then(createPaymentHold)
  62. .then(createNewRequest)
  63. .then(smsService.messageJobToDrivers)
  64. .then(resolve)
  65. .catch(reject);
  66. });
  67. },
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement