1571: fixed issues

administration/src/bp-modules/stores/StoresCSVInput.tsx

@@ -43,21 +43,15 @@ const lineToStoreEntry = (line: string[], headers: string[], fields: StoreFieldC
 
 const getStoreDuplicates = (stores: AcceptingStoreEntry[]): number[][] => {
   return Object.values(
-    stores.reduce((acc, entry, index) => {
+    stores.reduce((acc: Record<string, number[]>, entry, index) => {
       const { data } = entry
-      const groupKey = JSON.stringify([
-        data['name'],
-        data['street'],
-        data['houseNumber'],
-        data['postalCode'],
-        data['location'],
-      ])
+      const groupKey = JSON.stringify([data.name, data.street, data.houseNumber, data.postalCode, data.location])
       const entryNumber = index + 1
       if (acc[groupKey] === undefined) {
         return { ...acc, [groupKey]: [entryNumber] }
       }
       return { ...acc, [groupKey]: [...acc[groupKey], entryNumber] }
-    }, {} as { [key: string]: number[] })
+    }, {})
   ).filter(entryNumber => entryNumber.length > 1)
 }
 

administration/src/bp-modules/stores/StoresImportAlert.tsx

@@ -29,8 +29,8 @@ const StoresImportAlert = ({ dryRun, setDryRun, storesCount }: StoreImportAlertP
     <>
       {dryRun ? (
         <span data-testid='dry-run-alert'>
-          <b>Testlauf:</b> In diesem Testlauf wird nur simuliert, wie viele Stores geändert oder gelöscht werden würden.
-          Es werden keine Daten in die Datenbank geschrieben.
+          <b>Testlauf:</b> In diesem Testlauf wird nur simuliert, wie viele Akzeptanzpartner geändert oder gelöscht
+          werden würden. Es werden noch keine Änderungen an der Datenbank vorgenommen.
         </span>
       ) : (
         <>

administration/src/bp-modules/stores/StoresImportDuplicates.tsx

@@ -11,9 +11,10 @@ const StoresImportDuplicates = ({ entries }: StoresImportDuplicatesProps): React
   return (
     <Container>
       Die CSV enthält doppelte Einträge:
-      {entries.map((entry, index) => (
-        <span key={index}>Eintrag {entry.join(', ')} sind identisch.</span>
-      ))}
+      {entries.map(entry => {
+        const entries = entry.join(', ')
+        return <span key={entries}>Die Einträge {entries} sind identisch.</span>
+      })}
       Bitte löschen Sie die doppelten Einträge.
     </Container>
   )

administration/src/bp-modules/stores/__tests__/StoreImportAlert.test.tsx

@@ -9,7 +9,7 @@ const wrapper = ({ children }: { children: ReactElement }) => <ProjectConfigProv
 const setDryRun = jest.fn()
 describe('StoreImportAlert', () => {
   it('should show the correct alert information for dry run', () => {
-    const { getByTestId, queryByTestId } = render(
+    const { getByTestId, queryByTestId, getByText } = render(
       <StoresImportAlert dryRun setDryRun={setDryRun} storesCount={100} />,
       {
         wrapper,
@@ -18,8 +18,14 @@ describe('StoreImportAlert', () => {
     const infoSpanElement = getByTestId('dry-run-alert')
     expect(infoSpanElement).toBeTruthy()
     expect(infoSpanElement.textContent).toBe(
-      'Testlauf: In diesem Testlauf wird nur simuliert, wie viele Stores geändert oder gelöscht werden würden. Es werden keine Daten in die Datenbank geschrieben.'
+      'Testlauf: In diesem Testlauf wird nur simuliert, wie viele Akzeptanzpartner geändert oder gelöscht werden würden. Es werden noch keine Änderungen an der Datenbank vorgenommen.'
     )
+    expect(getByText('Testlauf:')).toBeTruthy()
+    expect(
+      getByText(
+        'In diesem Testlauf wird nur simuliert, wie viele Akzeptanzpartner geändert oder gelöscht werden würden. Es werden noch keine Änderungen an der Datenbank vorgenommen.'
+      )
+    ).toBeTruthy()
     const durationSpanElement = queryByTestId('duration-alert')
     expect(durationSpanElement).toBeFalsy()
   })

administration/src/errors/DefaultErrorMap.tsx

@@ -25,10 +25,6 @@ const defaultErrorMap = (extensions?: ErrorExtensions): GraphQLErrorMessage => {
 
   if (!extensions || !extensions['code']) return defaultError
   switch (extensions['code']) {
-    case GraphQlExceptionCode.DatabaseIo:
-      return {
-        title: 'Es ist unbekannter Datenbankfehler aufgetreten.',
-      }
     case GraphQlExceptionCode.EmailAlreadyExists:
       return {
         title: 'Die Email-Adresse wird bereits verwendet.',

backend/src/main/kotlin/app/ehrenamtskarte/backend/exception/webservice/schema/GraphQLExceptionCode.kt

@@ -1,7 +1,6 @@
 package app.ehrenamtskarte.backend.exception.webservice.schema
 
 enum class GraphQLExceptionCode {
-    DATABASE_IO,
     EMAIL_ALREADY_EXISTS,
     INVALID_INPUT,
     INVALID_CARD_HASH,

backend/src/main/kotlin/app/ehrenamtskarte/backend/stores/database/repos/AcceptingStoresRepository.kt

@@ -16,7 +16,7 @@ import app.ehrenamtskarte.backend.stores.importer.common.types.AcceptingStore
 import app.ehrenamtskarte.backend.stores.utils.mapCsvToStore
 import app.ehrenamtskarte.backend.stores.webservice.schema.types.CSVAcceptingStore
 import app.ehrenamtskarte.backend.stores.webservice.schema.types.Coordinates
-import app.ehrenamtskarte.backend.stores.webservice.schema.types.StoreImportResultModel
+import app.ehrenamtskarte.backend.stores.webservice.schema.types.StoreImportReturnResultModel
 import net.postgis.jdbc.geometry.Point
 import org.jetbrains.exposed.dao.id.EntityID
 import org.jetbrains.exposed.sql.ComparisonOp
@@ -114,26 +114,29 @@ object AcceptingStoresRepository {
             }.firstOrNull()?.let { it[AcceptingStores.id].value }
     }
 
-    fun getAcceptingStoreImportResult(stores: List<CSVAcceptingStore>, projectId: EntityID<Int>, dryRun: Boolean): StoreImportResultModel {
+    fun importAcceptingStores(stores: List<CSVAcceptingStore>, projectId: EntityID<Int>, dryRun: Boolean): StoreImportReturnResultModel {
         var numStoresCreated = 0
         var numStoresUntouched = 0
         val acceptingStoreIdsToRemove =
             AcceptingStores.slice(AcceptingStores.id).select { AcceptingStores.projectId eq projectId }
                 .map { it[AcceptingStores.id].value }.toMutableSet()
-        for (acceptingStore in stores) {
-            val existingStoreId: Int? =
-                getIdIfExists(mapCsvToStore(acceptingStore), projectId)
-            if (existingStoreId != null) {
+        stores.map { mapCsvToStore(it) }.forEach {
+            val existingStoreId = getIdIfExists(it, projectId)
+            if (existingStoreId == null) {
+                if (!dryRun) {
+                    createStore(it, projectId)
+                }
+                numStoresCreated += 1
+            } else {
                 acceptingStoreIdsToRemove.remove(existingStoreId)
                 numStoresUntouched += 1
-                continue
-            }
-            if (!dryRun) {
-                createStore(mapCsvToStore(acceptingStore), projectId)
             }
-            numStoresCreated += 1
         }
-        return StoreImportResultModel(numStoresCreated, acceptingStoreIdsToRemove, numStoresUntouched)
+        if (!dryRun) {
+            deleteStores(acceptingStoreIdsToRemove)
+        }
+
+        return StoreImportReturnResultModel(numStoresCreated, acceptingStoreIdsToRemove.size, numStoresUntouched)
     }
 
     fun createStore(acceptingStore: AcceptingStore, currentProjectId: EntityID<Int>) {

backend/src/main/kotlin/app/ehrenamtskarte/backend/stores/utils/StoreFieldCleaner.kt

@@ -1,12 +1,15 @@
 package app.ehrenamtskarte.backend.stores.utils
 
+import app.ehrenamtskarte.backend.stores.importer.replaceNa
+
 /** Returns null if string can't be trimmed f.e. empty string
  * Removes subsequent whitespaces
  * */
 fun String?.clean(removeSubsequentWhitespaces: Boolean = true): String? {
     if (this.isNullOrEmpty()) {
         return null
     }
+    this.replaceNa()
     val trimmed = this.trim()
     if (removeSubsequentWhitespaces) {
         return trimmed.replace(Regex("""\s{2,}"""), " ")

backend/src/main/kotlin/app/ehrenamtskarte/backend/stores/webservice/AcceptingStoresMutationService.kt

@@ -34,12 +34,9 @@ class AcceptingStoresMutationService {
             }
 
             val projectId = projectEntity.id
-            val (storesCreated, storesToDelete, storesUntouched) = AcceptingStoresRepository.getAcceptingStoreImportResult(stores, projectId, dryRun)
+            val (storesCreated, storesToDelete, storesUntouched) = AcceptingStoresRepository.importAcceptingStores(stores, projectId, dryRun)
 
-            if (!dryRun) {
-                AcceptingStoresRepository.deleteStores(storesToDelete)
-            }
-            return@transaction StoreImportReturnResultModel(storesCreated, storesToDelete.size, storesUntouched)
+            return@transaction StoreImportReturnResultModel(storesCreated, storesToDelete, storesUntouched)
         }
     }
 }

specs/backend-api.graphql

@@ -293,7 +293,6 @@ enum GoldenCardEntitlementType {
 }
 
 enum GraphQLExceptionCode {
-  DATABASE_IO
   EMAIL_ALREADY_EXISTS
   INVALID_CARD_HASH
   INVALID_CODE_TYPE