[BUGFIX] Revert la migration des Job/handler PE (PIX-12850)

 #9194

Author: pix-service-auto-merge

api/src/prescription/campaign-participation/application/pole-emploi-route.js api/lib/application/pole-emploi/index.js

@@ -1,7 +1,7 @@
 import Joi from 'joi';
 
-import { erreurDoc } from '../../../shared/infrastructure/open-api-doc/erreur-doc.js';
-import { poleEmploiEnvoisDoc } from '../infrastructure/open-api-doc/pole-emploi-sendings-doc.js';
+import { poleEmploiEnvoisDoc } from '../../infrastructure/open-api-doc/pole-emploi/envois-doc.js';
+import { erreurDoc } from '../../infrastructure/open-api-doc/pole-emploi/erreur-doc.js';
 import { poleEmploiController } from './pole-emploi-controller.js';
 
 const register = async function (server) {

api/src/prescription/campaign-participation/application/pole-emploi-controller.js api/lib/application/pole-emploi/pole-emploi-controller.js

@@ -1,6 +1,6 @@
-import { UnprocessableEntityError } from '../../../shared/application/http-errors.js';
-import * as poleEmploiService from '../domain/services/pole-emploi-service.js';
-import { usecases } from '../domain/usecases/index.js';
+import * as poleEmploiService from '../../domain/services/pole-emploi-service.js';
+import { usecases } from '../../domain/usecases/index.js';
+import { UnprocessableEntityError } from '../http-errors.js';
 
 const getSendings = async function (request, h, dependencies = { poleEmploiService }) {
   let cursorData;

api/src/prescription/campaign-participation/domain/events/handle-pole-emploi-participation-finished.js api/lib/domain/events/handle-pole-emploi-participation-finished.js

@@ -1,10 +1,10 @@
-import { AssessmentCompleted } from '../../../../../lib/domain/events/AssessmentCompleted.js';
-import { checkEventTypes } from '../../../../../lib/domain/events/check-event-types.js';
-import * as httpErrorsHelper from '../../../../../lib/infrastructure/http/errors-helper.js';
-import { httpAgent } from '../../../../../lib/infrastructure/http/http-agent.js';
-import { monitoringTools } from '../../../../../lib/infrastructure/monitoring-tools.js';
-import { PoleEmploiPayload } from '../../infrastructure/externals/PoleEmploiPayload.js';
+import { PoleEmploiPayload } from '../../infrastructure/externals/pole-emploi/PoleEmploiPayload.js';
+import * as httpErrorsHelper from '../../infrastructure/http/errors-helper.js';
+import { httpAgent } from '../../infrastructure/http/http-agent.js';
+import * as monitoringTools from '../../infrastructure/monitoring-tools.js';
 import { PoleEmploiSending } from '../models/PoleEmploiSending.js';
+import { AssessmentCompleted } from './AssessmentCompleted.js';
+import { checkEventTypes } from './check-event-types.js';
 
 const eventTypes = [AssessmentCompleted];
 

api/src/prescription/campaign-participation/domain/events/handle-pole-emploi-participation-started.js api/lib/domain/events/handle-pole-emploi-participation-started.js

@@ -1,10 +1,11 @@
-import { CampaignParticipationStarted } from '../../../../../lib/domain/events/CampaignParticipationStarted.js';
-import { checkEventTypes } from '../../../../../lib/domain/events/check-event-types.js';
-import * as httpErrorsHelper from '../../../../../lib/infrastructure/http/errors-helper.js';
-import { httpAgent } from '../../../../../lib/infrastructure/http/http-agent.js';
-import { monitoringTools } from '../../../../../lib/infrastructure/monitoring-tools.js';
-import { PoleEmploiPayload } from '../../infrastructure/externals/PoleEmploiPayload.js';
+import { PoleEmploiPayload } from '../../infrastructure/externals/pole-emploi/PoleEmploiPayload.js';
+import * as httpErrorsHelper from '../../infrastructure/http/errors-helper.js';
+import { httpAgent } from '../../infrastructure/http/http-agent.js';
+import * as monitoringTools from '../../infrastructure/monitoring-tools.js';
 import { PoleEmploiSending } from '../models/PoleEmploiSending.js';
+import { CampaignParticipationStarted } from './CampaignParticipationStarted.js';
+import { checkEventTypes } from './check-event-types.js';
+
 const eventTypes = [CampaignParticipationStarted];
 
 async function handlePoleEmploiParticipationStarted({

api/lib/domain/events/index.js

@@ -30,6 +30,8 @@ import { config } from '../../config.js';
 import * as eventBusBuilder from '../../infrastructure/events/EventBusBuilder.js';
 import { EventDispatcher } from '../../infrastructure/events/EventDispatcher.js';
 import { EventDispatcherLogger } from '../../infrastructure/events/EventDispatcherLogger.js';
+import * as disabledPoleEmploiNotifier from '../../infrastructure/externals/pole-emploi/disabled-pole-emploi-notifier.js';
+import * as poleEmploiNotifier from '../../infrastructure/externals/pole-emploi/pole-emploi-notifier.js';
 import { monitoringTools as MonitoringTools } from '../../infrastructure/monitoring-tools.js';
 import * as badgeAcquisitionRepository from '../../infrastructure/repositories/badge-acquisition-repository.js';
 import * as campaignParticipationRepository from '../../infrastructure/repositories/campaign-participation-repository.js';
@@ -41,16 +43,27 @@ import * as complementaryCertificationScoringCriteriaRepository from '../../infr
 import * as juryCertificationSummaryRepository from '../../infrastructure/repositories/jury-certification-summary-repository.js';
 import * as knowledgeElementRepository from '../../infrastructure/repositories/knowledge-element-repository.js';
 import { participantResultsSharedRepository } from '../../infrastructure/repositories/participant-results-shared-repository.js';
+import * as poleEmploiSendingRepository from '../../infrastructure/repositories/pole-emploi-sending-repository.js';
 import * as targetProfileRepository from '../../infrastructure/repositories/target-profile-repository.js';
 import * as scoringCertificationService from '../services/scoring/scoring-certification-service.js';
 import { handleAutoJury } from './handle-auto-jury.js';
 import { handleCertificationRescoring } from './handle-certification-rescoring.js';
 import { handleCertificationScoring } from './handle-certification-scoring.js';
 import { handleComplementaryCertificationsScoring } from './handle-complementary-certifications-scoring.js';
+import { handlePoleEmploiParticipationFinished } from './handle-pole-emploi-participation-finished.js';
+import { handlePoleEmploiParticipationStarted } from './handle-pole-emploi-participation-started.js';
 import { handleSessionFinalized } from './handle-session-finalized.js';
 
 const { performance } = perf_hooks;
 
+function requirePoleEmploiNotifier() {
+  if (config.poleEmploi.pushEnabled) {
+    return poleEmploiNotifier;
+  } else {
+    return disabledPoleEmploiNotifier;
+  }
+}
+
 const dependencies = {
   answerRepository,
   assessmentRepository,
@@ -80,6 +93,8 @@ const dependencies = {
   logger,
   organizationRepository,
   participantResultsSharedRepository,
+  poleEmploiNotifier: requirePoleEmploiNotifier(),
+  poleEmploiSendingRepository,
   scoringCertificationService,
   scoringDegradationService,
   skillRepository,
@@ -94,6 +109,8 @@ const handlersToBeInjected = {
   handleCertificationScoring,
   handleCertificationRescoring,
   handleComplementaryCertificationsScoring,
+  handlePoleEmploiParticipationFinished,
+  handlePoleEmploiParticipationStarted,
   handleSessionFinalized,
 };
 

api/src/prescription/campaign-participation/domain/models/PoleEmploiSending.js api/lib/domain/models/PoleEmploiSending.js

@@ -30,7 +30,6 @@ import { CampaignForArchiving } from '../../../src/prescription/campaign/domain/
 import { CampaignForCreation } from '../../../src/prescription/campaign/domain/models/CampaignForCreation.js';
 import { Group } from '../../../src/prescription/campaign/domain/models/Group.js';
 import { CampaignToStartParticipation } from '../../../src/prescription/campaign-participation/domain/models/CampaignToStartParticipation.js';
-import { PoleEmploiSending } from '../../../src/prescription/campaign-participation/domain/models/PoleEmploiSending.js';
 import { OrganizationPlacesLot } from '../../../src/prescription/organization-place/domain/models/OrganizationPlacesLot.js';
 import { CampaignParticipationStatuses, CampaignTypes } from '../../../src/prescription/shared/domain/constants.js';
 import { OrganizationsToAttachToTargetProfile } from '../../../src/prescription/target-profile/domain/models/OrganizationsToAttachToTargetProfile.js';
@@ -96,6 +95,7 @@ import { OrganizationTag } from './OrganizationTag.js';
 import { ParticipantResultsShared } from './ParticipantResultsShared.js';
 import { PartnerCertificationScoring } from './PartnerCertificationScoring.js';
 import { PlacementProfile } from './PlacementProfile.js';
+import { PoleEmploiSending } from './PoleEmploiSending.js';
 import { PrivateCertificate } from './PrivateCertificate.js';
 import { ReproducibilityRate } from './ReproducibilityRate.js';
 import { ResultCompetence } from './ResultCompetence.js';

api/lib/domain/models/index.js

@@ -1,4 +1,4 @@
-import { config } from '../../../../../lib/config.js';
+import { config } from '../../config.js';
 
 function generateLink(sending, filters = {}) {
   const host = config.apiManager.url;

api/src/prescription/campaign-participation/domain/services/pole-emploi-service.js api/lib/domain/services/pole-emploi-service.js

@@ -1,4 +1,4 @@
-import * as poleEmploiService from '../services/pole-emploi-service.js';
+import * as poleEmploiService from '../../domain/services/pole-emploi-service.js';
 
 const getPoleEmploiSendings = async function ({ cursorData, poleEmploiSendingRepository, filters }) {
   const sendings = await poleEmploiSendingRepository.find(cursorData, filters);

api/src/prescription/campaign-participation/domain/usecases/get-pole-emploi-sendings.js api/lib/domain/usecases/get-pole-emploi-sendings.js

@@ -59,7 +59,6 @@ import * as campaignAssessmentParticipationRepository from '../../../src/prescri
 import * as campaignAssessmentParticipationResultRepository from '../../../src/prescription/campaign-participation/infrastructure/repositories/campaign-assessment-participation-result-repository.js';
 import * as campaignParticipationBCRepository from '../../../src/prescription/campaign-participation/infrastructure/repositories/campaign-participation-repository.js';
 import * as campaignProfileRepository from '../../../src/prescription/campaign-participation/infrastructure/repositories/campaign-profile-repository.js';
-import * as poleEmploiSendingRepository from '../../../src/prescription/campaign-participation/infrastructure/repositories/pole-emploi-sending-repository.js';
 import * as supOrganizationLearnerRepository from '../../../src/prescription/learner-management/infrastructure/repositories/sup-organization-learner-repository.js';
 import * as organizationLearnerActivityRepository from '../../../src/prescription/organization-learner/infrastructure/repositories/organization-learner-activity-repository.js';
 import * as activityAnswerRepository from '../../../src/school/infrastructure/repositories/activity-answer-repository.js';
@@ -109,6 +108,8 @@ import * as resetPasswordService from '../../domain/services/reset-password-serv
 import * as scoringCertificationService from '../../domain/services/scoring/scoring-certification-service.js';
 import * as sessionPublicationService from '../../domain/services/session-publication-service.js';
 import * as verifyCertificateCodeService from '../../domain/services/verify-certificate-code-service.js';
+import * as disabledPoleEmploiNotifier from '../../infrastructure/externals/pole-emploi/disabled-pole-emploi-notifier.js';
+import * as poleEmploiNotifier from '../../infrastructure/externals/pole-emploi/pole-emploi-notifier.js';
 import * as accountRecoveryDemandRepository from '../../infrastructure/repositories/account-recovery-demand-repository.js';
 import * as attachableTargetProfileRepository from '../../infrastructure/repositories/attachable-target-profiles-repository.js';
 import * as badgeAcquisitionRepository from '../../infrastructure/repositories/badge-acquisition-repository.js';
@@ -150,6 +151,7 @@ import * as organizationMemberIdentityRepository from '../../infrastructure/repo
 import * as organizationTagRepository from '../../infrastructure/repositories/organization-tag-repository.js';
 import * as participantResultRepository from '../../infrastructure/repositories/participant-result-repository.js';
 import { participantResultsSharedRepository } from '../../infrastructure/repositories/participant-results-shared-repository.js';
+import * as poleEmploiSendingRepository from '../../infrastructure/repositories/pole-emploi-sending-repository.js';
 import * as resetPasswordDemandRepository from '../../infrastructure/repositories/reset-password-demands-repository.js';
 import * as scoCertificationCandidateRepository from '../../infrastructure/repositories/sco-certification-candidate-repository.js';
 import * as studentRepository from '../../infrastructure/repositories/student-repository.js';
@@ -171,8 +173,17 @@ import * as userReconciliationService from '../services/user-reconciliation-serv
 import * as organizationCreationValidator from '../validators/organization-creation-validator.js';
 import * as organizationValidator from '../validators/organization-with-tags-and-target-profiles-script.js';
 import { findTargetProfileOrganizations as findPaginatedFilteredTargetProfileOrganizations } from './find-paginated-filtered-target-profile-organizations.js';
+
 const oidcAuthenticationServiceRegistry = new OidcAuthenticationServiceRegistry({ oidcProviderRepository });
 
+function requirePoleEmploiNotifier() {
+  if (config.poleEmploi.pushEnabled) {
+    return poleEmploiNotifier;
+  } else {
+    return disabledPoleEmploiNotifier;
+  }
+}
+
 /**
  * Using {@link https://jsdoc.app/tags-type "Closure Compiler's syntax"} to document injected dependencies
  *
@@ -302,6 +313,7 @@ const dependencies = {
   pickChallengeService,
   pixAuthenticationService,
   placementProfileService,
+  poleEmploiNotifier: requirePoleEmploiNotifier(),
   poleEmploiSendingRepository,
   refreshTokenService,
   resetPasswordDemandRepository,

api/lib/domain/usecases/index.js

@@ -1,7 +1,7 @@
-import * as httpErrorsHelper from '../../../../../lib/infrastructure/http/errors-helper.js';
-import { httpAgent } from '../../../../../lib/infrastructure/http/http-agent.js';
-import * as monitoringTools from '../../../../../lib/infrastructure/monitoring-tools.js';
-import { PoleEmploiPayload } from '../../infrastructure/externals/PoleEmploiPayload.js';
+import { PoleEmploiPayload } from '../../infrastructure/externals/pole-emploi/PoleEmploiPayload.js';
+import * as httpErrorsHelper from '../../infrastructure/http/errors-helper.js';
+import { httpAgent } from '../../infrastructure/http/http-agent.js';
+import * as monitoringTools from '../../infrastructure/monitoring-tools.js';
 import { PoleEmploiSending } from '../models/PoleEmploiSending.js';
 
 const sendSharedParticipationResultsToPoleEmploi = async ({

api/src/prescription/campaign-participation/domain/usecases/send-shared-participation-results-to-pole-emploi.js api/lib/domain/usecases/send-shared-participation-results-to-pole-emploi.js

@@ -1,6 +1,6 @@
 import _ from 'lodash';
 
-import { config } from '../../../../shared/config.js';
+import { config } from '../../../config.js';
 
 const CAMPAIGN_TYPE = 'EVALUATION';
 const STRUCTURE_NAME = 'Pix';

api/src/prescription/campaign-participation/infrastructure/externals/PoleEmploiPayload.js api/lib/infrastructure/externals/pole-emploi/PoleEmploiPayload.js

@@ -6,10 +6,10 @@ import querystring from 'node:querystring';
 
 import dayjs from 'dayjs';
 
-import { UnexpectedUserAccountError } from '../../../../../lib/domain/errors.js';
-import * as OidcIdentityProviders from '../../../../identity-access-management/domain/constants/oidc-identity-providers.js';
-import { AuthenticationMethod } from '../../../../identity-access-management/domain/models/AuthenticationMethod.js';
-import { config } from '../../../../shared/config.js';
+import * as OidcIdentityProviders from '../../../../src/identity-access-management/domain/constants/oidc-identity-providers.js';
+import { AuthenticationMethod } from '../../../../src/identity-access-management/domain/models/AuthenticationMethod.js';
+import { config } from '../../../config.js';
+import { UnexpectedUserAccountError } from '../../../domain/errors.js';
 
 const notify = async (userId, payload, dependencies) => {
   const { authenticationMethodRepository, httpAgent, httpErrorsHelper, monitoringTools } = dependencies;

api/src/prescription/campaign-participation/infrastructure/externals/disabled-pole-emploi-notifier.js api/lib/infrastructure/externals/pole-emploi/disabled-pole-emploi-notifier.js

@@ -1,4 +1,4 @@
-import { usecases } from '../../../../src/prescription/campaign-participation/domain/usecases/index.js';
+import { usecases } from '../../../domain/usecases/index.js';
 import { SendSharedParticipationResultsToPoleEmploiJob } from './SendSharedParticipationResultsToPoleEmploiJob.js';
 
 class SendSharedParticipationResultsToPoleEmploiHandler {

api/src/prescription/campaign-participation/infrastructure/externals/pole-emploi-notifier.js api/lib/infrastructure/externals/pole-emploi/pole-emploi-notifier.js

@@ -1,6 +1,6 @@
-import { knex } from '../../../../../db/knex-database-connection.js';
-import { config } from '../../../../../lib/config.js';
-import * as OidcIdentityProviders from '../../../../identity-access-management/domain/constants/oidc-identity-providers.js';
+import { knex } from '../../../db/knex-database-connection.js';
+import { config } from '../../../lib/config.js';
+import * as OidcIdentityProviders from '../../../src/identity-access-management/domain/constants/oidc-identity-providers.js';
 
 const create = function ({ poleEmploiSending }) {
   return knex('pole-emploi-sendings').insert({ ...poleEmploiSending });

api/lib/infrastructure/jobs/campaign-result/SendSharedParticipationResultsToPoleEmploiHandler.js

@@ -27,6 +27,7 @@ import * as organizationLearners from './application/organization-learners/index
 import * as organizations from './application/organizations/index.js';
 import * as organizationsAdministration from './application/organizations-administration/index.js';
 import * as passwords from './application/passwords/index.js';
+import * as poleEmploi from './application/pole-emploi/index.js';
 import * as scoOrganizationLearners from './application/sco-organization-learners/index.js';
 import * as sessions from './application/sessions/index.js';
 import * as supOrganizationLearners from './application/sup-organization-learners/index.js';
@@ -63,6 +64,7 @@ const routes = [
   organizations,
   organizationsAdministration,
   passwords,
+  poleEmploi,
   organizationInvitations,
   scoOrganizationLearners,
   supOrganizationLearners,

api/src/prescription/campaign-participation/infrastructure/open-api-doc/pole-emploi-sendings-doc.js api/lib/infrastructure/open-api-doc/pole-emploi/envois-doc.js

@@ -1,8 +1,8 @@
 import Joi from 'joi';
 
+import { erreurDoc } from '../../../../lib/infrastructure/open-api-doc/pole-emploi/erreur-doc.js';
 import { securityPreHandlers } from '../../../shared/application/security-pre-handlers.js';
 import { identifiersType } from '../../../shared/domain/types/identifiers-type.js';
-import { erreurDoc } from '../../../shared/infrastructure/open-api-doc/erreur-doc.js';
 import { attachTargetProfileController } from './attach-target-profile-controller.js';
 
 const register = async function (server) {