Skip to content

Commit

Permalink
fix: lieu de formation optionnel (#3903)
Browse files Browse the repository at this point in the history
Co-authored-by: Paul Gaucher <[email protected]>
  • Loading branch information
Pomarom and Pomarom authored Nov 20, 2024
1 parent 02f2535 commit 2113e3c
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 33 deletions.
2 changes: 0 additions & 2 deletions server/src/common/actions/organismes/organismes.actions.ts
Original file line number Diff line number Diff line change
Expand Up @@ -1031,7 +1031,6 @@ export async function getInvalidUaisFromDossierApprenant(data: Partial<IEffectif
const uais = new Set<string>();
for (const dossier of data) {
if (dossier.etablissement_formateur_uai) uais.add(dossier.etablissement_formateur_uai);
if (dossier.etablissement_lieu_de_formation_uai) uais.add(dossier.etablissement_lieu_de_formation_uai);
if (dossier.etablissement_responsable_uai) uais.add(dossier.etablissement_responsable_uai);
}
const invalidsUais: string[] = [];
Expand All @@ -1048,7 +1047,6 @@ export async function getInvalidSiretsFromDossierApprenant(data: Partial<IEffect
const sirets = new Set<string>();
for (const dossier of data) {
if (dossier.etablissement_formateur_siret) sirets.add(dossier.etablissement_formateur_siret);
if (dossier.etablissement_lieu_de_formation_siret) sirets.add(dossier.etablissement_lieu_de_formation_siret);
if (dossier.etablissement_responsable_siret) sirets.add(dossier.etablissement_responsable_siret);
}
const invalidsSirets: string[] = [];
Expand Down
10 changes: 2 additions & 8 deletions server/src/common/validation/dossierApprenantSchemaV3.ts
Original file line number Diff line number Diff line change
Expand Up @@ -98,8 +98,8 @@ export const dossierApprenantSchemaV3Base = () =>
etablissement_responsable_siret: primitivesV1.etablissement_responsable.siret,
etablissement_formateur_uai: primitivesV1.etablissement_formateur.uai,
etablissement_formateur_siret: primitivesV1.etablissement_formateur.siret,
etablissement_lieu_de_formation_uai: primitivesV1.etablissement_lieu_de_formation.uai,
etablissement_lieu_de_formation_siret: primitivesV1.etablissement_lieu_de_formation.siret,
etablissement_lieu_de_formation_uai: primitivesV1.etablissement_lieu_de_formation.uai.optional(),
etablissement_lieu_de_formation_siret: primitivesV1.etablissement_lieu_de_formation.siret.optional(),
etablissement_lieu_de_formation_adresse: primitivesV1.etablissement_lieu_de_formation.adresse.optional(),
etablissement_lieu_de_formation_code_postal: primitivesV1.etablissement_lieu_de_formation.code_postal.optional(),

Expand Down Expand Up @@ -191,12 +191,6 @@ export function dossierApprenantSchemaV3WithMoreRequiredFieldsValidatingUAISiret
etablissement_formateur_siret: primitivesV1.etablissement_formateur.siret.refine(validateSiret, {
message: messageSiret,
}),
etablissement_lieu_de_formation_uai: primitivesV1.etablissement_lieu_de_formation.uai.refine(validateUAI, {
message: messageUai,
}),
etablissement_lieu_de_formation_siret: primitivesV1.etablissement_lieu_de_formation.siret.refine(validateSiret, {
message: messageSiret,
}),
})
);
}
Expand Down
25 changes: 2 additions & 23 deletions server/src/jobs/ingestion/process-ingestion.ts
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@ import { SOURCE_APPRENANT } from "shared/constants";
import {
IEffectif,
ORGANISME_FORMATEUR_NOT_FOUND,
ORGANISME_LIEU_NOT_FOUND,
ORGANISME_RESPONSABLE_NOT_FOUND,
createCustomEffectifIssue,
} from "shared/models/data/effectifs.model";
Expand Down Expand Up @@ -276,18 +275,10 @@ async function transformEffectifQueueV3ToEffectif(rawEffectifQueued: IEffectifQu

const result = await dossierApprenantSchemaV3()
.transform(async (effectifQueued, ctx) => {
const [effectif, organismeLieu, organismeFormateur, organismeResponsable, formation] = await Promise.all([
const [effectif, organismeFormateur, organismeResponsable, formation] = await Promise.all([
(async () => {
return await transformEffectifQueueToEffectif(effectifQueued);
})(),
(async () => {
const { organisme, stats } = await findOrganismeWithStats(
effectifQueued?.etablissement_lieu_de_formation_uai,
effectifQueued?.etablissement_lieu_de_formation_siret
);
Object.assign(itemProcessingInfos, addPrefixToProperties("organisme_lieu_", stats));
return organisme;
})(),
(async () => {
const { organisme, stats } = await findOrganismeWithStats(
effectifQueued?.etablissement_formateur_uai,
Expand Down Expand Up @@ -318,18 +309,6 @@ async function transformEffectifQueueV3ToEffectif(rawEffectifQueued: IEffectifQu
})(),
]);

if (!organismeLieu) {
ctx.addIssue(
createCustomEffectifIssue(
ORGANISME_LIEU_NOT_FOUND,
["etablissement_lieu_de_formation_uai", "etablissement_lieu_de_formation_siret"],
{
uai: effectifQueued.etablissement_lieu_de_formation_uai,
siret: effectifQueued.etablissement_lieu_de_formation_siret,
}
)
);
}
if (!organismeFormateur) {
ctx.addIssue(
createCustomEffectifIssue(
Expand Down Expand Up @@ -359,7 +338,7 @@ async function transformEffectifQueueV3ToEffectif(rawEffectifQueued: IEffectifQu
validateContrat(effectifQueued, "_3", ctx);
validateContrat(effectifQueued, "_4", ctx);

if (!organismeLieu || !organismeFormateur || !organismeResponsable) {
if (!organismeFormateur || !organismeResponsable) {
return NEVER;
}

Expand Down

0 comments on commit 2113e3c

Please sign in to comment.