@@ -13,26 +13,26 @@ const insert = async (req, res) => {
13
13
await client . query ( 'begin' ) ;
14
14
const { notes, questionGroupId } = series ;
15
15
const { areaId, times, breakMinutes } = shift ;
16
- const seriesId = await db . value ( sql . shiftSeries . insert , [
17
- times . length === 1 ,
16
+ const seriesId = await db . value ( sql . shiftSeries . insert , {
17
+ isSingle : times . length === 1 ,
18
18
notes,
19
19
questionGroupId,
20
20
userId,
21
21
organisationId
22
- ] , client ) ;
23
- await Promise . all ( times . map ( t => db . empty ( sql . shifts . insert , [
22
+ } , client ) ;
23
+ await Promise . all ( times . map ( t => db . empty ( sql . shifts . insert , {
24
24
areaId,
25
- t . startTime ,
26
- t . endTime ,
25
+ startTime : t . startTime ,
26
+ endTime : t . endTime ,
27
27
breakMinutes,
28
28
seriesId,
29
29
organisationId
30
- ] , client ) ) ) ;
31
- await Promise . all ( shiftRoles . map ( sr => db . empty ( sql . shiftRoles . insert , [
32
- ...Object . values ( sr ) ,
30
+ } , client ) ) ) ;
31
+ await Promise . all ( shiftRoles . map ( shiftRole => db . empty ( sql . shiftRoles . insert , {
32
+ ...shiftRole ,
33
33
seriesId,
34
34
organisationId
35
- ] , client ) ) ) ;
35
+ } , client ) ) ) ;
36
36
await client . query ( 'commit' ) ;
37
37
return res . json ( { rowCount : 1 } ) ;
38
38
}
@@ -63,66 +63,66 @@ const update = async (req, res) => {
63
63
const promises = [ ] ;
64
64
let seriesId = initialSeries . id ;
65
65
if ( detach ) {
66
- seriesId = await db . value ( sql . shiftSeries . copy , [
67
- updatedSeries . id ,
66
+ seriesId = await db . value ( sql . shiftSeries . copy , {
67
+ seriesId : updatedSeries . id ,
68
68
organisationId
69
- ] , client ) ;
70
- await db . empty ( sql . shiftRoles . copy , [
71
- initialSeries . id ,
72
- seriesId ,
69
+ } , client ) ;
70
+ await db . empty ( sql . shiftRoles . copy , {
71
+ fromSeriesId : initialSeries . id ,
72
+ toSeriesId : seriesId ,
73
73
organisationId
74
- ] , client ) ;
75
- await db . empty ( sql . shifts . updateSeriesId , [
76
- initialShift . id ,
74
+ } , client ) ;
75
+ await db . empty ( sql . shifts . updateSeriesId , {
76
+ shiftId : initialShift . id ,
77
77
seriesId,
78
78
organisationId
79
- ] , client ) ;
80
- await db . empty ( sql . bookings . transfer , [
81
- initialShift . id ,
82
- seriesId ,
79
+ } , client ) ;
80
+ await db . empty ( sql . bookings . transfer , {
81
+ fromSeriesId : initialShift . id ,
82
+ toSeriesId : seriesId ,
83
83
organisationId
84
- ] , client ) ;
84
+ } , client ) ;
85
85
remove = remove . map ( sr => ( { ...sr , id : null , seriesId } ) ) ;
86
86
update = update . map ( sr => ( { ...sr , id : null , seriesId } ) ) ;
87
87
}
88
88
if ( initialSeries . notes !== updatedSeries . notes ) {
89
- const promise = db . empty ( sql . shiftSeries . update , [ ...Object . values ( updatedSeries ) , organisationId ] , client ) ;
89
+ const promise = db . empty ( sql . shiftSeries . update , { ...updatedSeries , organisationId } , client ) ;
90
90
promises . push ( promise ) ;
91
91
}
92
92
if (
93
93
initialShift . startTime !== updatedShift . startTime ||
94
94
initialShift . endTime !== updatedShift . endTime ||
95
95
initialShift . breakMinutes !== updatedShift . breakMinutes ) {
96
- const promise = db . empty ( sql . shifts . update , [
96
+ const promise = db . empty ( sql . shifts . update , {
97
97
seriesId,
98
- initialShift . startTime ,
99
- initialShift . endTime ,
100
- updatedShift . startTime ,
101
- updatedShift . endTime ,
102
- updatedShift . breakMinutes ,
98
+ initialStartTime : initialShift . startTime ,
99
+ initialEndTime : initialShift . endTime ,
100
+ updatedStartTime : updatedShift . startTime ,
101
+ updatedEndTime : updatedShift . endTime ,
102
+ breakMinutes : updatedShift . breakMinutes ,
103
103
organisationId
104
- ] , client ) ;
104
+ } , client ) ;
105
105
promises . push ( promise ) ;
106
106
}
107
107
for ( const shiftRole of remove ) {
108
108
const { id, seriesId, roleId } = shiftRole ;
109
109
const query = id ? sql . shiftRoles . remove : sql . shiftRoles . removeBySeriesId ;
110
- const params = id ? [ id , organisationId ] : [ seriesId , roleId , organisationId ] ;
110
+ const params = id ? { id, organisationId } : { seriesId, roleId, organisationId } ;
111
111
const promise = db . empty ( query , params , client ) ;
112
112
promises . push ( promise ) ;
113
113
}
114
114
for ( const shiftRole of add ) {
115
- const promise = db . empty ( sql . shiftRoles . insert , [
116
- ...Object . values ( shiftRole ) ,
117
- initialSeries . id ,
115
+ const promise = db . empty ( sql . shiftRoles . insert , {
116
+ ...shiftRole ,
117
+ seriesId : initialSeries . id ,
118
118
organisationId
119
- ] , client ) ;
119
+ } , client ) ;
120
120
promises . push ( promise ) ;
121
121
}
122
122
for ( const shiftRole of update ) {
123
123
const { id, seriesId, roleId, capacity } = shiftRole ;
124
124
const query = id ? sql . shiftRoles . update : sql . shiftRoles . updateBySeriesId ;
125
- const params = id ? [ id , capacity , organisationId ] : [ seriesId , roleId , capacity , organisationId ] ;
125
+ const params = id ? { id, capacity, organisationId } : { seriesId, roleId, capacity, organisationId } ;
126
126
const promise = db . empty ( query , params , client ) ;
127
127
promises . push ( promise ) ;
128
128
}
@@ -143,17 +143,17 @@ const find = async (req, res) => {
143
143
const organisationId = req . user . organisationId ;
144
144
let { areaId, startTime, endTime } = req . body ;
145
145
if ( ! areaId ) {
146
- const { id, timeZone } = await db . first ( sql . shifts . getFirstArea , [ organisationId ] ) ;
146
+ const { id, timeZone } = await db . first ( sql . shifts . getFirstArea , { organisationId } ) ;
147
147
areaId = id ;
148
148
startTime += timeZone ;
149
149
endTime += timeZone ;
150
150
}
151
- const shifts = await db . text ( sql . shifts . find , [
151
+ const shifts = await db . text ( sql . shifts . find , {
152
152
areaId,
153
153
startTime,
154
154
endTime,
155
155
organisationId
156
- ] ) ;
156
+ } ) ;
157
157
return res . send ( shifts ) ;
158
158
}
159
159
0 commit comments