add assignment completion api

backend/app/Schedule/EloquentScheduleRepository.php

@@ -5,6 +5,7 @@ namespace App\Schedule;
 use App\User\User;
 use DateTimeImmutable;
 use DateTimeZone;
+use DomainException;
 use Illuminate\Support\Facades\DB;
 
 class EloquentScheduleRepository implements ScheduleRepository
@@ -29,6 +30,7 @@ class EloquentScheduleRepository implements ScheduleRepository
                     'scheduled_date' => $assignmentDto->scheduledDate
                         ->format('Y-m-d'),
                     'position' => $assignmentDto->position,
+                    'completed_at' => null,
                 ]);
             }
 
@@ -77,6 +79,7 @@ class EloquentScheduleRepository implements ScheduleRepository
             ->where('schedule_assignments.scheduled_date', $date->format(
                 'Y-m-d',
             ))
+            ->whereNull('schedule_assignments.completed_at')
             ->with('schedule')
             ->orderByDesc('schedules.id')
             ->orderBy('schedule_assignments.position')
@@ -95,6 +98,50 @@ class EloquentScheduleRepository implements ScheduleRepository
         return $assignments;
     }
 
+    public function findAssignmentForUser(
+        int $id,
+        User $user,
+    ): ?ScheduleAssignment {
+        $model = ScheduleAssignmentModel::query()
+            ->select('schedule_assignments.*')
+            ->join(
+                'schedules',
+                'schedules.id',
+                '=',
+                'schedule_assignments.schedule_id',
+            )
+            ->where('schedule_assignments.id', $id)
+            ->where('schedules.user_id', $user->getId())
+            ->first();
+
+        return $model === null
+            ? null
+            : $this->assignmentToDomain($model);
+    }
+
+    public function updateAssignment(
+        ScheduleAssignment $assignment,
+    ): ScheduleAssignment {
+        $query = ScheduleAssignmentModel::query()
+            ->whereKey($assignment->getId());
+        if ($assignment->getCompletedAt() === null) {
+            $query->update(['completed_at' => null]);
+        } else {
+            $query->whereNull('completed_at')->update([
+                'completed_at' => $assignment->getCompletedAt(),
+            ]);
+        }
+
+        $model = ScheduleAssignmentModel::find($assignment->getId());
+        if ($model === null) {
+            throw new DomainException(
+                "Assignment with id {$assignment->getId()} not found",
+            );
+        }
+
+        return $this->assignmentToDomain($model);
+    }
+
     private function toDomain(ScheduleModel $model, User $user): Schedule
     {
         $assignmentModels = ScheduleAssignmentModel::query()
@@ -129,6 +176,9 @@ class EloquentScheduleRepository implements ScheduleRepository
             path: $model->element_path,
             scheduledDate: $this->date($model->scheduled_date),
             position: $model->position,
+            completedAt: $model->completed_at === null
+                ? null
+                : $this->dateTime($model->completed_at),
         );
     }
 
@@ -136,4 +186,10 @@ class EloquentScheduleRepository implements ScheduleRepository
     {
         return new DateTimeImmutable($value, new DateTimeZone('UTC'));
     }
+
+    private function dateTime(DateTimeImmutable $value): DateTimeImmutable
+    {
+        return DateTimeImmutable::createFromInterface($value)
+            ->setTimezone(new DateTimeZone('UTC'));
+    }
 }