fix: HASSUYP-279: Nähtävilläolo aineisto ei lataudu (#1260)

backend/src/HyvaksymisEsitys/s3Calls/persistFile.ts

@@ -5,6 +5,7 @@ import { CopyObjectCommand } from "@aws-sdk/client-s3";
 import { config } from "../../config";
 import { log } from "../../logger";
 import { assertIsDefined } from "../../util/assertions";
+import { NotFoundError } from "hassu-common/error";
 
 /**
  * Persistoi yksittäisen tiedoston, joka on tallennettu uploads-kansioon, annetun vaiheen alle ylläpito-bucketiin
@@ -29,6 +30,9 @@ export async function persistFile({
   const { tiedosto, nimi, avain } = ladattuTiedosto;
   assertIsDefined(tiedosto, "Tiedoston on oltava  määritelty");
   const sourceFileProperties = await getUploadedSourceFileInformation(tiedosto);
+  if (!sourceFileProperties) {
+    throw new NotFoundError(`Tiedostoa ${tiedosto} ei löydy`);
+  }
   const targetPath = joinPath(getYllapitoPathForProjekti(oid), vaihePrefix, avain, adaptFileName(nimi));
   try {
     await getS3Client().send(

backend/src/archive/projektiArchiveService.ts

@@ -3,12 +3,18 @@ import { testProjektiDatabase } from "../database/testProjektiDatabase";
 import { projektiSchedulerService } from "../sqsEvents/projektiSchedulerService";
 import { omistajaDatabase } from "../database/omistajaDatabase";
 import { muistuttajaDatabase } from "../database/muistuttajaDatabase";
+import { log } from "../logger";
 
 class ProjektiArchiveService {
   async archiveProjekti(oid: string): Promise<string> {
     await testProjektiDatabase.deleteProjektiByOid(oid);
     await fileService.deleteProjekti(oid);
-    await projektiSchedulerService.deleteAllSchedules(oid);
+    try {
+      await projektiSchedulerService.deleteAllSchedules(oid);
+    } catch (e) {
+      // tämä saattaa epäonnistua development modessa koska arkistointia kutsutaan kahteen kertaan
+      log.error("Ajastuksien poisto epäonnistui");
+    }
     await omistajaDatabase.deleteOmistajatByOid(oid);
     await muistuttajaDatabase.deleteMuistuttajatByOid(oid);
     return oid;

backend/src/files/fileService.ts

@@ -149,10 +149,12 @@ export class FileService {
   /**
    * Moves a file from temporary upload location to a permanent location under a projekti
    */
-  async persistFileToProjekti(param: PersistFileProperties): Promise<string> {
+  async persistFileToProjekti(param: PersistFileProperties): Promise<string | undefined> {
     const filePath = FileService.removePrefixFromFile(param.uploadedFileSource);
     const sourceFileProperties = await getUploadedSourceFileInformation(filePath);
-
+    if (!sourceFileProperties) {
+      return;
+    }
     const fileNameFromUpload = removeBucketFromPath(filePath);
     const targetPath = `/${param.targetFilePathInProjekti}/${fileNameFromUpload}`;
     const targetBucketPath = new ProjektiPaths(param.oid).yllapitoFullPath + targetPath;
@@ -707,7 +709,7 @@ export class FileService {
   }
 }
 
-export async function getUploadedSourceFileInformation(uploadedFileSource: string): Promise<{ ContentType: string; CopySource: string }> {
+export async function getUploadedSourceFileInformation(uploadedFileSource: string): Promise<{ ContentType: string; CopySource: string } | undefined> {
   if (!config.uploadBucketName) {
     throw new Error("config.uploadBucketName määrittelemättä");
   }
@@ -724,8 +726,12 @@ export async function getUploadedSourceFileInformation(uploadedFileSource: strin
       CopySource: encodeURIComponent(config.uploadBucketName + "/" + uploadedFileSource),
     };
   } catch (e) {
-    log.error(e);
-    throw new NotFoundError("Uploaded file " + uploadedFileSource + " not found.");
+    if (e instanceof NotFound) {
+      log.error("Uploaded file " + uploadedFileSource + " not found.");
+    } else {
+      log.error("Getting uploaded file " + uploadedFileSource + " failed", { error: e });
+      throw e; 
+    }
   }
 }
 

backend/src/files/persistFiles.ts

@@ -16,14 +16,17 @@ export async function persistLadattuTiedosto({
   targetFilePathInProjekti: string;
   asiakirjaTyyppi?: AsiakirjaTyyppi;
   kieli?: Kieli;
-}): Promise<LadattuTiedosto> {
-  const uploadedFile: string = await fileService.persistFileToProjekti({
+}): Promise<LadattuTiedosto | undefined> {
+  const uploadedFile = await fileService.persistFileToProjekti({
     uploadedFileSource: ladattuTiedosto.tiedosto,
     oid,
     targetFilePathInProjekti,
     asiakirjaTyyppi,
     kieli,
   });
+  if (!uploadedFile) {
+    return;
+  }
 
   const fileName = uploadedFile.split("/").pop();
   assertIsDefined(fileName, "tiedostonimi pitäisi löytyä aina");

backend/src/muistutus/muistutusHandler.ts

@@ -119,12 +119,17 @@ class MuistutusHandler {
 
     return await Promise.all(
       liitteet.map(
-        async (liite) =>
-          await fileService.persistFileToProjekti({
+        async (liite) => {
+          const tiedosto = await fileService.persistFileToProjekti({
             uploadedFileSource: liite,
             oid,
             targetFilePathInProjekti: "muistutukset/" + muistutusId,
-          })
+          });
+          if (!tiedosto) {
+            throw new NotFoundError("Liitettä ei löydy");
+          }
+          return tiedosto;
+        }
       )
     );
   }

backend/src/palaute/palauteHandlerJulkinen.ts

@@ -31,6 +31,9 @@ class PalauteHandlerJulkinen {
         oid,
         targetFilePathInProjekti: "palautteet/" + palaute.id,
       });
+      if (!liite) {
+        throw new NotFoundError("Liitettä ei löydy");
+      }
       palaute.liite = liite;
       await virusScanService.runScanOnFile(
         config.yllapitoBucketName,

backend/src/projekti/projektiHandler.ts

@@ -470,6 +470,9 @@ async function handleSuunnitteluSopimusFile(input: API.TallennaProjektiInput) {
       oid: input.oid,
       targetFilePathInProjekti: "suunnittelusopimus",
     });
+    if (!input.suunnitteluSopimus.logo.SUOMI) {
+      throw new NotFoundError("Logoa ei löydy");
+    }
   }
 
   if (input.suunnitteluSopimus?.logo?.RUOTSI) {
@@ -478,6 +481,9 @@ async function handleSuunnitteluSopimusFile(input: API.TallennaProjektiInput) {
       oid: input.oid,
       targetFilePathInProjekti: "suunnittelusopimus",
     });
+    if (!input.suunnitteluSopimus.logo.RUOTSI) {
+      throw new NotFoundError("Logoa ei löydy");
+    }
   }
 }
 
@@ -505,6 +511,9 @@ async function persistFiles<T extends Record<string, LadattuTiedosto | null>, K
           asiakirjaTyyppi: asiakirjaTyypit[i],
           kieli: kielet[i],
         });
+        if (!palautus[key]) {
+          throw new NotFoundError("Tiedostoa ei löydy");
+        }
         break;
       case API.LadattuTiedostoTila.ODOTTAA_POISTOA:
         await deleteFile({
@@ -560,6 +569,9 @@ async function handleVuorovaikutusSaamePDF(dbProjekti: DBProjekti) {
             asiakirjaTyyppi: API.AsiakirjaTyyppi.YLEISOTILAISUUS_KUTSU,
             kieli: API.Kieli.POHJOISSAAME,
           });
+          if (!dbProjekti.vuorovaikutusKierros.vuorovaikutusSaamePDFt[kieli]) {
+            throw new NotFoundError("Tiedostoa ei löydy");
+          }
           break;
         case API.LadattuTiedostoTila.ODOTTAA_POISTOA:
           await deleteFile({
@@ -675,6 +687,9 @@ async function handleEuLogoFiles(input: API.TallennaProjektiInput) {
       oid: input.oid,
       targetFilePathInProjekti: "euLogot/FI",
     });
+    if (!input.euRahoitusLogot.SUOMI) {
+      throw new NotFoundError("Logoa ei löydy");
+    }
   }
 
   if (input.euRahoitusLogot?.RUOTSI) {
@@ -683,6 +698,9 @@ async function handleEuLogoFiles(input: API.TallennaProjektiInput) {
       oid: input.oid,
       targetFilePathInProjekti: "euLogot/SV",
     });
+    if (!input.euRahoitusLogot.RUOTSI) {
+      throw new NotFoundError("Logoa ei löydy");
+    }
   }
 }
 

backend/src/tiedostot/ProjektiTiedostoManager/util.ts

@@ -98,15 +98,16 @@ export async function handleTiedostot(oid: string, tiedostot: LadattuTiedosto[]
     }
   );
   await Promise.all(poistettavat.map((tiedosto) => deleteFile({ oid, tiedosto })));
-  const persistoidutTiedostot = await Promise.all(
+  // ignoorataan virheelliset latausviittaukset jotta ei aiheuta projektin lukitusta 4 päiväksi kun sanoman käsittely ei onnistu
+  const persistoidutTiedostot = (await Promise.all(
     persistoitavat.map((tiedosto) =>
       persistLadattuTiedosto({
         oid,
         ladattuTiedosto: tiedosto,
         targetFilePathInProjekti: paths.yllapitoPath,
       })
     )
-  );
+  )).filter(t => t !== undefined);
   tiedostot.push(...valmiit.concat(persistoidutTiedostot).sort((a, b) => (a.jarjestys ?? 0) - (b.jarjestys ?? 0)));
   if (poistettavat.length || persistoitavat.length) {
     return true;

backend/src/user/signedCookie.ts

@@ -10,7 +10,7 @@ export async function createSignedCookies(): Promise<string[]> {
         Resource: `*`,
         Condition: {
           DateLessThan: {
-            "AWS:EpochTime": Math.floor(new Date().getTime() / 1000) + 3600,
+            "AWS:EpochTime": Math.floor(new Date().getTime() / 1000) + (3600 * 8),
           },
         },
       },