Fixed import lock

Author: korridor

app/Service/Import/ImportService.php

@@ -31,10 +31,13 @@ public function import(Organization $organization, string $importerType, string
         $lock = Cache::lock('import:'.$organization->getKey(), config('octane.max_execution_time', 60) + 1);
 
         if ($lock->get()) {
-            DB::transaction(function () use (&$importer, &$data, &$timezone): void {
-                $importer->importData($data, $timezone);
-            });
-            $lock->release();
+            try {
+                DB::transaction(function () use (&$importer, &$data, &$timezone): void {
+                    $importer->importData($data, $timezone);
+                });
+            } finally {
+                $lock->release();
+            }
         } else {
             throw new ImportException('Import is already in progress');
         }

tests/Unit/Endpoint/Api/V1/ImportEndpointTest.php

@@ -78,6 +78,7 @@ public function test_import_fails_if_user_does_not_have_permission(): void
 
     public function test_import_fails_if_data_can_not_be_base64_decoded(): void
     {
+        // Arrange
         $user = $this->createUserWithPermission([
             'import',
         ]);
@@ -98,6 +99,7 @@ public function test_import_fails_if_data_can_not_be_base64_decoded(): void
 
     public function test_import_return_error_message_if_import_fails(): void
     {
+        // Arrange
         $user = $this->createUserWithPermission([
             'import',
         ]);

tests/Unit/Service/Import/ImportServiceTest.php

@@ -35,6 +35,8 @@ public function test_import_gets_importer_from_provider_runs_importer_and_return
         $report = $importService->import($organization, 'toggl_time_entries', $data, $timezone);
 
         // Assert
+        $lock = Cache::lock('import:'.$organization->getKey());
+        $this->assertTrue($lock->get());
         $this->assertSame(2, $report->timeEntriesCreated);
         $this->assertSame(2, $report->tagsCreated);
         $this->assertSame(1, $report->tasksCreated);
@@ -43,6 +45,25 @@ public function test_import_gets_importer_from_provider_runs_importer_and_return
         $this->assertSame(1, $report->clientsCreated);
     }
 
+    public function test_import_releases_lock_if_an_exception_happens_during_the_import(): void
+    {
+        // Arrange
+        Storage::fake(config('filesystems.default'));
+        $organization = Organization::factory()->create();
+        $timezone = 'Europe/Vienna';
+        $data = 'Invalid CSV data';
+
+        // Act
+        $importService = app(ImportService::class);
+        try {
+            $importService->import($organization, 'toggl_time_entries', $data, $timezone);
+        } catch (ImportException) {
+            // Assert
+            $lock = Cache::lock('import:'.$organization->getKey());
+            $this->assertTrue($lock->get());
+        }
+    }
+
     public function test_import_throws_exception_if_import_is_already_in_progress(): void
     {
         // Arrange