@@ -13,30 +13,34 @@ const userModel = require("./users");
13
13
const fetchTaskRequests = async ( ) => {
14
14
const taskRequests = [ ] ;
15
15
16
- const taskRequestsSnapshots = ( await taskRequestsCollection . get ( ) ) . docs ;
16
+ try {
17
+ const taskRequestsSnapshots = ( await taskRequestsCollection . get ( ) ) . docs ;
17
18
18
- const taskPromises = [ ] ;
19
- const userPromises = [ ] ;
19
+ const taskPromises = [ ] ;
20
+ const userPromises = [ ] ;
20
21
21
- taskRequestsSnapshots . forEach ( ( taskRequestsSnapshot ) => {
22
- const taskRequestData = taskRequestsSnapshot . data ( ) ;
23
- taskRequestData . id = taskRequestsSnapshot . id ;
24
- taskRequestData . url = new URL ( `/taskRequests/${ taskRequestData . id } ` , config . get ( "services.rdsUi.baseUrl" ) ) ;
25
- const { requestors } = taskRequestData ;
22
+ taskRequestsSnapshots . forEach ( ( taskRequestsSnapshot ) => {
23
+ const taskRequestData = taskRequestsSnapshot . data ( ) ;
24
+ taskRequestData . id = taskRequestsSnapshot . id ;
25
+ taskRequestData . url = new URL ( `/taskRequests/${ taskRequestData . id } ` , config . get ( "services.rdsUi.baseUrl" ) ) ;
26
+ const { requestors } = taskRequestData ;
26
27
27
- taskPromises . push ( tasksModel . fetchTask ( taskRequestData . taskId ) ) ;
28
- userPromises . push ( Promise . all ( requestors . map ( ( requestor ) => userModel . fetchUser ( { userId : requestor } ) ) ) ) ;
28
+ taskPromises . push ( tasksModel . fetchTask ( taskRequestData . taskId ) ) ;
29
+ userPromises . push ( Promise . all ( requestors . map ( ( requestor ) => userModel . fetchUser ( { userId : requestor } ) ) ) ) ;
29
30
30
- taskRequests . push ( taskRequestData ) ;
31
- } ) ;
31
+ taskRequests . push ( taskRequestData ) ;
32
+ } ) ;
32
33
33
- const tasks = await Promise . all ( taskPromises ) ;
34
- const users = await Promise . all ( userPromises ) ;
34
+ const tasks = await Promise . all ( taskPromises ) ;
35
+ const users = await Promise . all ( userPromises ) ;
35
36
36
- taskRequests . forEach ( ( taskRequest , index ) => {
37
- taskRequest . task = tasks [ + index ] . taskData ;
38
- taskRequest . requestors = users [ + index ] ;
39
- } ) ;
37
+ taskRequests . forEach ( ( taskRequest , index ) => {
38
+ taskRequest . task = tasks [ + index ] . taskData ;
39
+ taskRequest . requestors = users [ + index ] ;
40
+ } ) ;
41
+ } catch ( err ) {
42
+ logger . error ( "Error in updating task" , err ) ;
43
+ }
40
44
41
45
return taskRequests ;
42
46
} ;
@@ -48,14 +52,25 @@ const fetchTaskRequests = async () => {
48
52
* @return Promise<{taskRequest: Object}>
49
53
*/
50
54
const fetchTaskRequestById = async ( taskRequestId ) => {
51
- const taskRequestSnapshot = await taskRequestsCollection . doc ( taskRequestId ) . get ( ) ;
52
- const taskRequestData = taskRequestSnapshot . data ( ) ;
55
+ try {
56
+ const taskRequestSnapshot = await taskRequestsCollection . doc ( taskRequestId ) . get ( ) ;
57
+ const taskRequestData = taskRequestSnapshot . data ( ) ;
53
58
54
- if ( taskRequestData ) {
55
- taskRequestData . id = taskRequestSnapshot . id ;
56
- taskRequestData . url = new URL ( `/taskRequests/${ taskRequestData . id } ` , config . get ( "services.rdsUi.baseUrl" ) ) ;
59
+ if ( taskRequestData ) {
60
+ taskRequestData . id = taskRequestSnapshot . id ;
61
+ taskRequestData . url = new URL ( `/taskRequests/${ taskRequestData . id } ` , config . get ( "services.rdsUi.baseUrl" ) ) ;
62
+ }
63
+ return {
64
+ taskRequestData,
65
+ taskRequestExists : true ,
66
+ } ;
67
+ } catch ( err ) {
68
+ logger . error ( "Error in updating task" , err ) ;
57
69
}
58
- return taskRequestData ;
70
+
71
+ return {
72
+ taskRequestExists : false ,
73
+ } ;
59
74
} ;
60
75
61
76
/**
0 commit comments