fix(variations): emails for datasets

Author: ahonestla

client/src/pages/bso-local-variations/actions/edit-variations.ts

@@ -1,8 +1,15 @@
 import { postHeaders } from "../../../config/api"
+import { VariationsTypes } from "../types"
 
-export default async function editVariations(api: string, ids: Array<string>, inputs: Record<string, unknown>) {
+export default async function editVariations(
+  api: VariationsTypes,
+  ids: Array<string>,
+  inputs: Record<string, unknown>
+) {
   const singleId = ids.length === 1 ? ids[0] : null
-  const url = !!singleId ? `/api/bso-local-variations/${api}/${singleId}` : `/api/bso-local-variations/${api}`
+  const url = !!singleId
+    ? `/api/bso-local-variations/${api}/${singleId}`
+    : `/api/bso-local-variations/${api}`
   const data = !!singleId ? inputs : { data: inputs, ids: ids }
 
   await fetch(url, {

client/src/pages/bso-local-variations/actions/send-email.ts

@@ -1,14 +1,22 @@
 import { toast } from "react-toastify"
-import { Variation } from "../types"
+import { Variation, VariationsTypes } from "../types"
 import editVariations from "./edit-variations"
 import { notificationGetTemplate } from "../config/notifications"
 
 const messageTemplate = (variation: Variation) =>
-  `<ul><li>Nom de la structure: ${variation.structure.name}</li><li>Identifiant de la structure: ${
+  `<ul><li>Nom de la structure: ${
+    variation.structure.name
+  }</li><li>Identifiant de la structure: ${
     variation.structure?.id || "Non renseigné"
-  }</li><li>Date de la demande: ${new Date(variation.created_at).toLocaleDateString()}</li></ul>`
+  }</li><li>Date de la demande: ${new Date(
+    variation.created_at
+  ).toLocaleDateString()}</li></ul>`
 
-async function sendEmail(variation: Variation, response: string) {
+async function sendEmail(
+  api: VariationsTypes,
+  variation: Variation,
+  response: string
+) {
   const url = `/api/send-email`
   const selectedProfile = localStorage.getItem("selectedProfile")
   const formattedResponse = response.replace(/\n/g, "<br/>")
@@ -20,7 +28,7 @@ async function sendEmail(variation: Variation, response: string) {
     subject: `Réponse à votre demande de déclinaison locale, référence bso-${variation.id}`,
     userResponse: formattedResponse,
     message: messageTemplate(variation),
-    collectionName: "bso_local_variations_publications",
+    collectionName: `bso_local_variations_${api}`,
     selectedProfile,
   }
 
@@ -32,34 +40,44 @@ async function sendEmail(variation: Variation, response: string) {
     body: JSON.stringify(emailPayload),
   })
     .then((response) => {
-      if (!response.ok) throw new Error(`Error while sending email: ${response.status}`)
+      if (!response.ok)
+        throw new Error(`Error while sending email: ${response.status}`)
     })
     .catch((error) => {
       throw error
     })
 }
 
 export default async function sendEmails(
-  api: string,
+  api: VariationsTypes,
   variations: Array<Variation>,
   notification: string,
   response: string,
   useTemplate?: boolean,
   getCommentsName?: (id: string) => string
 ) {
   // Set status as treated if final notification sent
-  const inputs = { tags: { notification: notification }, status: notification === "done" ? "treated" : "ongoing" }
+  const inputs = {
+    tags: { notification: notification },
+    status: notification === "done" ? "treated" : "ongoing",
+  }
 
   // If single variation and notification is custom, set correct status (should only happen from email-box)
   if (variations.length === 1 && notification === "custom")
-    inputs.status = variations[0].tags?.notification === "done" ? "treated" : "ongoing"
+    inputs.status =
+      variations[0].tags?.notification === "done" ? "treated" : "ongoing"
 
   Promise.all(
     variations.map((variation) =>
       sendEmail(
+        api,
         variation,
         useTemplate
-          ? notificationGetTemplate(notification, variation.structure?.id, getCommentsName(variation.structure?.id))
+          ? notificationGetTemplate(
+              notification,
+              variation.structure?.id,
+              getCommentsName(variation.structure?.id)
+            )
           : response
       )
     )
@@ -73,7 +91,9 @@ export default async function sendEmails(
         )
       }
       toast.success(
-        variations?.length > 1 ? "Les emails ont été envoyés avec succès !" : "L'email à été envoyé avec succès !"
+        variations?.length > 1
+          ? "Les emails ont été envoyés avec succès !"
+          : "L'email à été envoyé avec succès !"
       )
     })
     .catch((error) => {

client/src/pages/bso-local-variations/actions/update-index.ts

@@ -1,8 +1,12 @@
 import { toast } from "react-toastify"
-import { Variation } from "../types"
+import { Variation, VariationsTypes } from "../types"
 import editVariations from "./edit-variations"
 
-export default async function updateIndex(api: string, variations: Array<Variation>, data: Record<string, unknown>) {
+export default async function updateIndex(
+  api: VariationsTypes,
+  variations: Array<Variation>,
+  data: Record<string, unknown>
+) {
   const indexName = data.index_name
   const url = `/api/bso-tasks`
 
@@ -22,7 +26,9 @@ export default async function updateIndex(api: string, variations: Array<Variati
         variations.map((variation) => variation.id),
         { tags: { index: data.id } }
       )
-      toast.success(`L'index ${indexName} a été lancé avec succès ! (id: ${data.id})`)
+      toast.success(
+        `L'index ${indexName} a été lancé avec succès ! (id: ${data.id})`
+      )
     })
     .catch((error) => {
       console.error("updateIndex error:", error.message)

client/src/pages/bso-local-variations/actions/upload-files.ts

@@ -1,9 +1,9 @@
 import { toast } from "react-toastify"
-import { Variation } from "../types"
+import { Variation, VariationsTypes } from "../types"
 import editVariations from "./edit-variations"
 import { getContainer } from "../config/containers"
 
-async function uploadFile(api: string, variation: Variation) {
+async function uploadFile(api: VariationsTypes, variation: Variation) {
   const container = getContainer(api)
   if (!container) {
     throw `uploadFile: Container not found for variations api ${api}`
@@ -26,14 +26,18 @@ async function uploadFile(api: string, variation: Variation) {
     body: JSON.stringify(data),
   })
     .then((response) => {
-      if (!response.ok) throw new Error(`Error while uploading file for id ${variation.id}`)
+      if (!response.ok)
+        throw new Error(`Error while uploading file for id ${variation.id}`)
     })
     .catch((error) => {
       throw error
     })
 }
 
-export default async function uploadFiles(api: string, variations: Array<Variation>) {
+export default async function uploadFiles(
+  api: VariationsTypes,
+  variations: Array<Variation>
+) {
   const inputs = { tags: { file: "uploaded" }, status: "ongoing" }
 
   Promise.all(variations.map((variation) => uploadFile(api, variation)))
@@ -51,6 +55,8 @@ export default async function uploadFiles(api: string, variations: Array<Variati
     })
     .catch((error) => {
       console.error("uploadFiles error:", error.message)
-      toast.error("Une erreur est survenue lors du chargement des fichiers sur OVH.")
+      toast.error(
+        "Une erreur est survenue lors du chargement des fichiers sur OVH."
+      )
     })
 }