@@ -67,10 +67,13 @@ class ActivityService implements IActivityService {
6767 try {
6868 const activities : Array < PgActivity > = await PgActivity . findAll ( {
6969 where : {
70- pet_id : pet_id ,
70+ pet_id,
7171 } ,
7272 raw : true ,
7373 } ) ;
74+ if ( ! activities [ 0 ] ) {
75+ throw new NotFoundError ( `No activities for pet id ${ pet_id } ` ) ;
76+ }
7477 return activities . map ( ( activity ) => ( {
7578 id : activity . id ,
7679 userId : activity . user_id ,
@@ -89,14 +92,19 @@ class ActivityService implements IActivityService {
8992 }
9093 }
9194
92- async getUserActivities ( user_id : string ) : Promise < Array < ActivityResponseDTO > > {
95+ async getUserActivities (
96+ user_id : string ,
97+ ) : Promise < Array < ActivityResponseDTO > > {
9398 try {
9499 const activities : Array < PgActivity > = await PgActivity . findAll ( {
95100 where : {
96- user_id : user_id ,
101+ user_id,
97102 } ,
98103 raw : true ,
99104 } ) ;
105+ if ( ! activities [ 0 ] ) {
106+ throw new NotFoundError ( `No activities for user id ${ user_id } ` ) ;
107+ }
100108 return activities . map ( ( activity ) => ( {
101109 id : activity . id ,
102110 userId : activity . user_id ,
@@ -115,7 +123,6 @@ class ActivityService implements IActivityService {
115123 }
116124 }
117125
118-
119126 async createActivity (
120127 activity : ActivityRequestDTO ,
121128 ) : Promise < ActivityResponseDTO > {
@@ -192,7 +199,7 @@ class ActivityService implements IActivityService {
192199
193200 async assignUser (
194201 id : string ,
195- user : ActivityUserPatchDTO
202+ user : ActivityUserPatchDTO ,
196203 ) : Promise < ActivityResponseDTO | null > {
197204 let resultingActivity : PgActivity | null ;
198205 let updateResult : [ number , PgActivity [ ] ] | null ;
@@ -228,7 +235,7 @@ class ActivityService implements IActivityService {
228235
229236 async scheduleActivity (
230237 id : string ,
231- schedule : ActivityTimePatchDTO
238+ schedule : ActivityTimePatchDTO ,
232239 ) : Promise < ActivityResponseDTO | null > {
233240 let resultingActivity : PgActivity | null ;
234241 let updateResult : [ number , PgActivity [ ] ] | null ;
@@ -261,84 +268,82 @@ class ActivityService implements IActivityService {
261268 notes : resultingActivity . notes ,
262269 } ;
263270 }
264-
265-
271+
266272 async startActivity (
267- id : string ,
268- startTime : ActivityTimePatchDTO
269- ) : Promise < ActivityResponseDTO | null > {
270- let resultingActivity : PgActivity | null ;
271- let updateResult : [ number , PgActivity [ ] ] | null ;
272- try {
273- updateResult = await PgActivity . update (
274- {
275- start_time : startTime . time ,
276- } ,
277- { where : { id } , returning : true } ,
278- ) ;
279-
280- if ( ! updateResult [ 0 ] ) {
281- throw new NotFoundError ( `Activity id ${ id } not found` ) ;
282- }
283- [ , [ resultingActivity ] ] = updateResult ;
284- } catch ( error : unknown ) {
285- Logger . error (
286- `Failed to update activity. Reason = ${ getErrorMessage ( error ) } ` ,
287- ) ;
288- throw error ;
273+ id : string ,
274+ startTime : ActivityTimePatchDTO ,
275+ ) : Promise < ActivityResponseDTO | null > {
276+ let resultingActivity : PgActivity | null ;
277+ let updateResult : [ number , PgActivity [ ] ] | null ;
278+ try {
279+ updateResult = await PgActivity . update (
280+ {
281+ start_time : startTime . time ,
282+ } ,
283+ { where : { id } , returning : true } ,
284+ ) ;
285+
286+ if ( ! updateResult [ 0 ] ) {
287+ throw new NotFoundError ( `Activity id ${ id } not found` ) ;
289288 }
290- return {
291- id : resultingActivity . id ,
292- userId : resultingActivity . user_id ,
293- petId : resultingActivity . pet_id ,
294- activityTypeId : resultingActivity . activity_type_id ,
295- scheduledStartTime : resultingActivity . scheduled_start_time ,
296- startTime : resultingActivity . start_time ,
297- endTime : resultingActivity . end_time ,
298- notes : resultingActivity . notes ,
299- } ;
289+ [ , [ resultingActivity ] ] = updateResult ;
290+ } catch ( error : unknown ) {
291+ Logger . error (
292+ `Failed to update activity. Reason = ${ getErrorMessage ( error ) } ` ,
293+ ) ;
294+ throw error ;
300295 }
301-
296+ return {
297+ id : resultingActivity . id ,
298+ userId : resultingActivity . user_id ,
299+ petId : resultingActivity . pet_id ,
300+ activityTypeId : resultingActivity . activity_type_id ,
301+ scheduledStartTime : resultingActivity . scheduled_start_time ,
302+ startTime : resultingActivity . start_time ,
303+ endTime : resultingActivity . end_time ,
304+ notes : resultingActivity . notes ,
305+ } ;
306+ }
307+
302308 async endActivity (
303- id : string ,
304- endTime : ActivityTimePatchDTO
305- ) : Promise < ActivityResponseDTO | null > {
306- let resultingActivity : PgActivity | null ;
307- let updateResult : [ number , PgActivity [ ] ] | null ;
308- try {
309- updateResult = await PgActivity . update (
310- {
311- end_time : endTime . time ,
312- } ,
313- { where : { id } , returning : true } ,
314- ) ;
315-
316- if ( ! updateResult [ 0 ] ) {
317- throw new NotFoundError ( `Activity id ${ id } not found` ) ;
318- }
319- [ , [ resultingActivity ] ] = updateResult ;
320- } catch ( error : unknown ) {
321- Logger . error (
322- `Failed to update activity. Reason = ${ getErrorMessage ( error ) } ` ,
323- ) ;
324- throw error ;
309+ id : string ,
310+ endTime : ActivityTimePatchDTO ,
311+ ) : Promise < ActivityResponseDTO | null > {
312+ let resultingActivity : PgActivity | null ;
313+ let updateResult : [ number , PgActivity [ ] ] | null ;
314+ try {
315+ updateResult = await PgActivity . update (
316+ {
317+ end_time : endTime . time ,
318+ } ,
319+ { where : { id } , returning : true } ,
320+ ) ;
321+
322+ if ( ! updateResult [ 0 ] ) {
323+ throw new NotFoundError ( `Activity id ${ id } not found` ) ;
325324 }
326- return {
327- id : resultingActivity . id ,
328- userId : resultingActivity . user_id ,
329- petId : resultingActivity . pet_id ,
330- activityTypeId : resultingActivity . activity_type_id ,
331- scheduledStartTime : resultingActivity . scheduled_start_time ,
332- startTime : resultingActivity . start_time ,
333- endTime : resultingActivity . end_time ,
334- notes : resultingActivity . notes ,
335- } ;
325+ [ , [ resultingActivity ] ] = updateResult ;
326+ } catch ( error : unknown ) {
327+ Logger . error (
328+ `Failed to update activity. Reason = ${ getErrorMessage ( error ) } ` ,
329+ ) ;
330+ throw error ;
336331 }
337-
338-
332+ return {
333+ id : resultingActivity . id ,
334+ userId : resultingActivity . user_id ,
335+ petId : resultingActivity . pet_id ,
336+ activityTypeId : resultingActivity . activity_type_id ,
337+ scheduledStartTime : resultingActivity . scheduled_start_time ,
338+ startTime : resultingActivity . start_time ,
339+ endTime : resultingActivity . end_time ,
340+ notes : resultingActivity . notes ,
341+ } ;
342+ }
343+
339344 async updateActivityNotes (
340345 id : string ,
341- notes : ActivityNotesPatchDTO
346+ notes : ActivityNotesPatchDTO ,
342347 ) : Promise < ActivityResponseDTO | null > {
343348 let resultingActivity : PgActivity | null ;
344349 let updateResult : [ number , PgActivity [ ] ] | null ;
0 commit comments