From 92f2b90f755f79254737eec394232066d5eb73a0 Mon Sep 17 00:00:00 2001
From: bayang <wabayang@gmail.com>
Date: Fri, 13 May 2022 12:02:53 +0200
Subject: [PATCH] fix: on import do not try to fetch metadata if binary not
 configured #3

---
 build.gradle.kts                              |  6 +++-
 src/jelu-ui/src/components/Imports.vue        | 26 +++++++++++++--
 .../jelu/service/imports/CsvImportService.kt  | 16 ++++++----
 .../service/imports/CsvImportServiceTest.kt   | 32 +++++++++++++++++++
 4 files changed, 70 insertions(+), 10 deletions(-)

diff --git a/build.gradle.kts b/build.gradle.kts
index adab0e04..92550c62 100644
--- a/build.gradle.kts
+++ b/build.gradle.kts
@@ -69,7 +69,11 @@ dependencies {
 
     implementation("org.apache.commons:commons-csv:1.9.0")
 
-    testImplementation("org.springframework.boot:spring-boot-starter-test")
+    testImplementation("org.springframework.boot:spring-boot-starter-test") {
+        exclude(module = "mockito-core")
+    }
+    testImplementation("io.mockk:mockk:1.12.4")
+    testImplementation("com.ninja-squad:springmockk:3.1.1")
     testImplementation("io.projectreactor:reactor-test")
 
     val springdocVersion = "1.6.6"
diff --git a/src/jelu-ui/src/components/Imports.vue b/src/jelu-ui/src/components/Imports.vue
index 9ba46146..d4421922 100644
--- a/src/jelu-ui/src/components/Imports.vue
+++ b/src/jelu-ui/src/components/Imports.vue
@@ -1,5 +1,7 @@
 <script setup lang="ts">
-import { ref } from "vue";
+import { computed, ref } from "vue";
+import { useStore } from 'vuex'
+import { key } from '../store'
 import { ImportSource } from "../model/ImportConfiguration";
 import dataService from "../services/DataService";
 import { useTitle } from '@vueuse/core'
@@ -12,6 +14,7 @@ const { t } = useI18n({
 
 useTitle('Jelu | Imports')
 
+const store = useStore(key)
 const file = ref(new File([], "dummy"));
 const importSource = ref(ImportSource.GOODREADS);
 const fetchMetadata = ref(true)
@@ -54,6 +57,14 @@ const exportFile =async () => {
   }
 }
 
+let fetchCoversDisabled = computed(() => {
+  if (store != null && !store.getters.getMetadataFetchEnabled) {
+    return true
+  } else {
+    return !fetchMetadata.value
+  }
+}) 
+
 </script>
 
 <template>
@@ -62,6 +73,12 @@ const exportFile =async () => {
       {{ t('csv_import.import_csv') }}
     </h1>
     <div class="w-11/12 sm:w-8/12">
+      <div
+        v-if="store != null && !store.getters.getMetadataFetchEnabled"
+        class="mb-3 text-warning font-bold"
+      >
+        !! {{ t('labels.auto_import_disabled') }}
+      </div>
       <div class="form-control">
         <o-field
           horizontal
@@ -83,7 +100,10 @@ const exportFile =async () => {
           :label="t('csv_import.auto_fetch_online')"
           class="capitalize"
         >
-          <o-checkbox v-model="fetchMetadata">
+          <o-checkbox
+            v-model="fetchMetadata"
+            :disabled="store != null && !store.getters.getMetadataFetchEnabled"
+          >
             {{ fetchMetadata }}
           </o-checkbox>
         </o-field>
@@ -96,7 +116,7 @@ const exportFile =async () => {
         >
           <o-checkbox
             v-model="fetchCovers" 
-            :disabled="!fetchMetadata"
+            :disabled="fetchCoversDisabled"
           >
             {{ fetchCovers }}
           </o-checkbox>
diff --git a/src/main/kotlin/io/github/bayang/jelu/service/imports/CsvImportService.kt b/src/main/kotlin/io/github/bayang/jelu/service/imports/CsvImportService.kt
index 66b451ae..d6257a83 100644
--- a/src/main/kotlin/io/github/bayang/jelu/service/imports/CsvImportService.kt
+++ b/src/main/kotlin/io/github/bayang/jelu/service/imports/CsvImportService.kt
@@ -89,10 +89,12 @@ class CsvImportService(
         try {
             userMessageService.save(
                 CreateUserMessageDto(
-                "Import started at $nowString",
-                null,
-                MessageCategory.INFO
-            ), userEntity)
+                    "Import started at $nowString",
+                    null,
+                    MessageCategory.INFO
+                ),
+                userEntity
+            )
         } catch (e: Exception) {
             logger.error(e) { "failed to save message for ${file.absolutePath} import" }
         }
@@ -116,7 +118,9 @@ class CsvImportService(
                     "Import for ${file.absolutePath} ended after : $deltaInSec seconds, with $success imports and $failures failures",
                     null,
                     MessageCategory.SUCCESS
-                ), userEntity)
+                ),
+                userEntity
+            )
         } catch (e: Exception) {
             logger.error(e) { "failed to save message for ${file.absolutePath} import" }
         }
@@ -149,7 +153,7 @@ class CsvImportService(
         try {
             importService.updateStatus(importEntity.id.value, ProcessingStatus.PROCESSING)
             var metadata = MetadataDto()
-            if (importEntity.shouldFetchMetadata) {
+            if (importEntity.shouldFetchMetadata && !properties.metadata.calibre.path.isNullOrBlank()) {
                 val isbn: String = getIsbn(importEntity)
                 if (isbn.isNotBlank()) {
                     metadata = fetchMetadataService.fetchMetadata(isbn, null, null, onlyUseCorePlugins = true, fetchCover = importConfig.shouldFetchCovers)
diff --git a/src/test/kotlin/io/github/bayang/jelu/service/imports/CsvImportServiceTest.kt b/src/test/kotlin/io/github/bayang/jelu/service/imports/CsvImportServiceTest.kt
index 40dbdeba..00e8c5f5 100644
--- a/src/test/kotlin/io/github/bayang/jelu/service/imports/CsvImportServiceTest.kt
+++ b/src/test/kotlin/io/github/bayang/jelu/service/imports/CsvImportServiceTest.kt
@@ -1,9 +1,12 @@
 package io.github.bayang.jelu.service.imports
 
+import com.ninjasquad.springmockk.MockkBean
 import io.github.bayang.jelu.config.JeluProperties
+import io.github.bayang.jelu.dao.ImportSource
 import io.github.bayang.jelu.dao.ProcessingStatus
 import io.github.bayang.jelu.dao.User
 import io.github.bayang.jelu.dto.CreateUserDto
+import io.github.bayang.jelu.dto.ImportConfigurationDto
 import io.github.bayang.jelu.dto.JeluUser
 import io.github.bayang.jelu.dto.UserBookWithoutEventsAndUserDto
 import io.github.bayang.jelu.importConfigurationDto
@@ -11,6 +14,8 @@ import io.github.bayang.jelu.service.BookService
 import io.github.bayang.jelu.service.ImportService
 import io.github.bayang.jelu.service.ReadingEventService
 import io.github.bayang.jelu.service.UserService
+import io.github.bayang.jelu.service.metadata.FetchMetadataService
+import io.mockk.verify
 import org.junit.jupiter.api.AfterAll
 import org.junit.jupiter.api.AfterEach
 import org.junit.jupiter.api.Assertions
@@ -67,6 +72,9 @@ class CsvImportServiceTest(
         }
     }
 
+    @MockkBean
+    private lateinit var fetchMetadataService: FetchMetadataService
+
     @Test
     fun testParse() {
         val userId = user().id.value
@@ -85,6 +93,29 @@ class CsvImportServiceTest(
         }
     }
 
+    @Test
+    fun testParseAndImport() {
+        val userId = user().id.value
+        val csv = File(this::class.java.getResource("/csv-import/goodreads1.csv").file)
+        // shouldFetchMetadata true but binary path is null so we shouldn't try to call fetchMetadata
+        csvImportService.parse(csv, userId, ImportConfigurationDto(shouldFetchMetadata = true, shouldFetchCovers = false, ImportSource.GOODREADS))
+        val nb = importService.countByprocessingStatusAndUser(ProcessingStatus.SAVED, userId)
+        Assertions.assertEquals(10, nb)
+        val dtos = importService.getByprocessingStatusAndUser(ProcessingStatus.SAVED, userId)
+        dtos.forEach {
+            if (it.title.equals("La somme de nos folies")) {
+                Assertions.assertEquals("9782843048302", it.isbn13)
+                Assertions.assertEquals("Éditions Zulma", it.publisher)
+                val shelves = it.tags?.split(",")
+                Assertions.assertEquals(3, shelves?.size)
+            }
+        }
+        val (success, failures) = csvImportService.importFromDb(userId, importConfigurationDto())
+        Assertions.assertEquals(10, success)
+        Assertions.assertEquals(0, failures)
+        verify(exactly = 0) { fetchMetadataService.fetchMetadata(any(), any(), any(), any(), any()) }
+    }
+
     @Test
     fun testNoDuplicates() {
         val userId = user().id.value
@@ -106,6 +137,7 @@ class CsvImportServiceTest(
                 Assertions.assertEquals(1, userbook.readingEvents?.size)
             }
         }
+        verify(exactly = 0) { fetchMetadataService.fetchMetadata(any(), any(), any(), any(), any()) }
     }
 
     fun user(): User {