Import athlete weights

Author: robiningelbrecht

.env.test

@@ -14,4 +14,8 @@ FTP_VALUES='{
     "2023-08-01": 238,
     "2023-09-24": 250,
     "2024-03-26": 258
+}'
+ATHLETE_WEIGHTS='{
+    "2023-04-01": 74.6,
+    "2023-05-25": 70.3
 }'

config/services.yaml

@@ -74,6 +74,10 @@ services:
         factory: [ App\Domain\Strava\Athlete\AthleteBirthday, 'fromString' ]
         arguments: ['%env(resolve:ATHLETE_BIRTHDAY)%']
 
+    App\Domain\Strava\Athlete\Weight\ImportAthleteWeight\AthleteWeightsFromEnvFile:
+        factory: [ 'App\Domain\Strava\Athlete\Weight\ImportAthleteWeight\AthleteWeightsFromEnvFile', fromString ]
+        arguments: [ '%env(resolve:ATHLETE_WEIGHTS)%' ]
+
     App\Domain\Strava\Ftp\ImportFtp\FtpValuesFromEnvFile:
         factory: [ 'App\Domain\Strava\Ftp\ImportFtp\FtpValuesFromEnvFile', fromString ]
         arguments: [ '%env(resolve:FTP_VALUES)%' ]

src/Domain/Strava/Athlete/Weight/AthleteWeights.php

@@ -0,0 +1,15 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Domain\Strava\Athlete\Weight;
+
+use App\Infrastructure\ValueObject\Collection;
+
+final class AthleteWeights extends Collection
+{
+    public function getItemClassName(): string
+    {
+        return AthleteWeight::class;
+    }
+}

src/Domain/Strava/Athlete/Weight/ImportAthleteWeight/AthleteWeightsFromEnvFile.php

@@ -0,0 +1,43 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Domain\Strava\Athlete\Weight\ImportAthleteWeight;
+
+use App\Domain\Strava\Athlete\Weight\AthleteWeight;
+use App\Domain\Strava\Athlete\Weight\AthleteWeights;
+use App\Infrastructure\Serialization\Json;
+use App\Infrastructure\ValueObject\Time\SerializableDateTime;
+
+final readonly class AthleteWeightsFromEnvFile
+{
+    private AthleteWeights $weights;
+
+    /**
+     * @param array<string, float> $weightsInKg
+     */
+    private function __construct(
+        array $weightsInKg,
+    ) {
+        $this->weights = AthleteWeights::empty();
+
+        foreach ($weightsInKg as $on => $weightInKg) {
+            $this->weights->add(AthleteWeight::fromState(
+                on: SerializableDateTime::fromString($on),
+                weightInGrams: (int) ($weightInKg * 1000),
+            ));
+        }
+    }
+
+    public function getAll(): AthleteWeights
+    {
+        return $this->weights;
+    }
+
+    public static function fromString(string $values): self
+    {
+        return new self(
+            Json::decode($values)
+        );
+    }
+}

src/Domain/Strava/Athlete/Weight/ImportAthleteWeight/ImportAthleteWeight.php

@@ -0,0 +1,21 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Domain\Strava\Athlete\Weight\ImportAthleteWeight;
+
+use App\Infrastructure\CQRS\Bus\DomainCommand;
+use Symfony\Component\Console\Output\OutputInterface;
+
+final class ImportAthleteWeight extends DomainCommand
+{
+    public function __construct(
+        private readonly OutputInterface $output,
+    ) {
+    }
+
+    public function getOutput(): OutputInterface
+    {
+        return $this->output;
+    }
+}

src/Domain/Strava/Athlete/Weight/ImportAthleteWeight/ImportAthleteWeightCommandHandler.php

@@ -0,0 +1,40 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Domain\Strava\Athlete\Weight\ImportAthleteWeight;
+
+use App\Domain\Strava\Athlete\Weight\AthleteWeightRepository;
+use App\Infrastructure\CQRS\Bus\Command;
+use App\Infrastructure\CQRS\Bus\CommandHandler;
+
+final readonly class ImportAthleteWeightCommandHandler implements CommandHandler
+{
+    public function __construct(
+        private AthleteWeightsFromEnvFile $athleteWeightsFromEnvFile,
+        private AthleteWeightRepository $athleteWeightRepository,
+    ) {
+    }
+
+    public function handle(Command $command): void
+    {
+        assert($command instanceof ImportAthleteWeight);
+        $command->getOutput()->writeln('Importing weights...');
+
+        $this->athleteWeightRepository->removeAll();
+
+        if (!$athleteWeights = $this->athleteWeightsFromEnvFile->getAll()) {
+            $command->getOutput()->writeln('No athlete weights found. Will not be able to calculate relative power outputs');
+        }
+
+        /** @var \App\Domain\Strava\Athlete\Weight\AthleteWeight $weight */
+        foreach ($athleteWeights as $weight) {
+            $this->athleteWeightRepository->save($weight);
+            $command->getOutput()->writeln(sprintf(
+                '  => Imported weight set on %s (%s kg)...',
+                $weight->getOn()->format('d-m-Y'),
+                $weight->getWeightInKg()
+            ));
+        }
+    }
+}

tests/Domain/Strava/Athlete/Weight/ImportAthleteWeight/ImportAthleteWeightCommandHandlerTest.php

@@ -0,0 +1,35 @@
+<?php
+
+namespace App\Tests\Domain\Strava\Athlete\Weight\ImportAthleteWeight;
+
+use App\Domain\Strava\Athlete\Weight\ImportAthleteWeight\ImportAthleteWeight;
+use App\Domain\Strava\Strava;
+use App\Infrastructure\CQRS\Bus\CommandBus;
+use App\Tests\ContainerTestCase;
+use App\Tests\Domain\Strava\SpyStrava;
+use App\Tests\SpyOutput;
+use Spatie\Snapshots\MatchesSnapshots;
+
+class ImportAthleteWeightCommandHandlerTest extends ContainerTestCase
+{
+    use MatchesSnapshots;
+
+    private CommandBus $commandBus;
+    private SpyStrava $strava;
+
+    public function testHandle(): void
+    {
+        $output = new SpyOutput();
+        $this->commandBus->dispatch(new ImportAthleteWeight($output));
+
+        $this->assertMatchesTextSnapshot((string) $output);
+    }
+
+    protected function setUp(): void
+    {
+        parent::setUp();
+
+        $this->commandBus = $this->getContainer()->get(CommandBus::class);
+        $this->strava = $this->getContainer()->get(Strava::class);
+    }
+}

tests/Domain/Strava/Athlete/Weight/ImportAthleteWeight/__snapshots__/ImportAthleteWeightCommandHandlerTest__testHandle__1.txt

@@ -0,0 +1,3 @@
+Importing weights...
+  => Imported weight set on 01-04-2023 (74.6 kg)...
+  => Imported weight set on 25-05-2023 (70.3 kg)...