-
Notifications
You must be signed in to change notification settings - Fork 53
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[BUGFIX] Désactiver complètement le push FT (#10090)
- Loading branch information
Showing
10 changed files
with
313 additions
and
712 deletions.
There are no files selected for viewing
58 changes: 58 additions & 0 deletions
58
api/lib/domain/usecases/send-completed-participation-results-to-pole-emploi.js
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,58 @@ | ||
| import { PoleEmploiSending } from '../../../src/shared/domain/models/PoleEmploiSending.js'; | ||
| import { logger } from '../../../src/shared/infrastructure/utils/logger.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'; | ||
|
|
||
| const sendCompletedParticipationResultsToPoleEmploi = async ({ | ||
| campaignParticipationId, | ||
| assessmentRepository, | ||
| authenticationMethodRepository, | ||
| campaignParticipationRepository, | ||
| campaignRepository, | ||
| organizationRepository, | ||
| poleEmploiNotifier, | ||
| poleEmploiSendingRepository, | ||
| targetProfileRepository, | ||
| userRepository, | ||
| notifierDependencies = { | ||
| httpAgent, | ||
| httpErrorsHelper, | ||
| logger, | ||
| }, | ||
| }) => { | ||
| if (!campaignParticipationId) return; | ||
|
|
||
| const participation = await campaignParticipationRepository.get(campaignParticipationId); | ||
| const campaign = await campaignRepository.get(participation.campaignId); | ||
| const organization = await organizationRepository.get(campaign.organizationId); | ||
|
|
||
| if (campaign.isAssessment() && organization.isPoleEmploi) { | ||
| const user = await userRepository.get(participation.userId); | ||
| const targetProfile = await targetProfileRepository.get(campaign.targetProfileId); | ||
| const assessment = await assessmentRepository.get(participation.lastAssessment.id); | ||
|
|
||
| const payload = PoleEmploiPayload.buildForParticipationFinished({ | ||
| user, | ||
| campaign, | ||
| targetProfile, | ||
| participation, | ||
| assessment, | ||
| }); | ||
| const response = await poleEmploiNotifier.notify(user.id, payload, { | ||
| authenticationMethodRepository: authenticationMethodRepository, | ||
| ...notifierDependencies, | ||
| }); | ||
|
|
||
| const poleEmploiSending = PoleEmploiSending.buildForParticipationFinished({ | ||
| campaignParticipationId, | ||
| payload: payload.toString(), | ||
| isSuccessful: response.isSuccessful, | ||
| responseCode: response.code, | ||
| }); | ||
|
|
||
| return poleEmploiSendingRepository.create({ poleEmploiSending }); | ||
| } | ||
| }; | ||
|
|
||
| export { sendCompletedParticipationResultsToPoleEmploi }; |
54 changes: 54 additions & 0 deletions
54
api/lib/domain/usecases/send-started-participation-results-to-pole-emploi.js
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,54 @@ | ||
| import { PoleEmploiSending } from '../../../src/shared/domain/models/PoleEmploiSending.js'; | ||
| import { logger } from '../../../src/shared/infrastructure/utils/logger.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'; | ||
|
|
||
| const sendStartedParticipationResultsToPoleEmploi = async ({ | ||
| campaignParticipationId, | ||
| authenticationMethodRepository, | ||
| campaignParticipationRepository, | ||
| campaignRepository, | ||
| organizationRepository, | ||
| poleEmploiNotifier, | ||
| poleEmploiSendingRepository, | ||
| targetProfileRepository, | ||
| userRepository, | ||
| notifierDependencies = { | ||
| httpAgent, | ||
| httpErrorsHelper, | ||
| logger, | ||
| }, | ||
| }) => { | ||
| const participation = await campaignParticipationRepository.get(campaignParticipationId); | ||
| const campaign = await campaignRepository.get(participation.campaignId); | ||
| const organization = await organizationRepository.get(campaign.organizationId); | ||
|
|
||
| if (campaign.isAssessment() && organization.isPoleEmploi) { | ||
| const user = await userRepository.get(participation.userId); | ||
| const targetProfile = await targetProfileRepository.get(campaign.targetProfileId); | ||
|
|
||
| const payload = PoleEmploiPayload.buildForParticipationStarted({ | ||
| user, | ||
| campaign, | ||
| targetProfile, | ||
| participation, | ||
| }); | ||
|
|
||
| const response = await poleEmploiNotifier.notify(user.id, payload, { | ||
| authenticationMethodRepository: authenticationMethodRepository, | ||
| ...notifierDependencies, | ||
| }); | ||
|
|
||
| const poleEmploiSending = PoleEmploiSending.buildForParticipationStarted({ | ||
| campaignParticipationId, | ||
| payload: payload.toString(), | ||
| isSuccessful: response.isSuccessful, | ||
| responseCode: response.code, | ||
| }); | ||
|
|
||
| await poleEmploiSendingRepository.create({ poleEmploiSending }); | ||
| } | ||
| }; | ||
|
|
||
| export { sendStartedParticipationResultsToPoleEmploi }; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
80 changes: 80 additions & 0 deletions
80
...s/integration/domain/usecases/send-completed-participation-results-to-pole-emploi_test.js
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,80 @@ | ||
| import { usecases } from '../../../../lib/domain/usecases/index.js'; | ||
| import * as poleEmploiNotifier from '../../../../lib/infrastructure/externals/pole-emploi/pole-emploi-notifier.js'; | ||
| import { | ||
| databaseBuilder, | ||
| expect, | ||
| knex, | ||
| learningContentBuilder, | ||
| mockLearningContent, | ||
| sinon, | ||
| } from '../../../test-helper.js'; | ||
|
|
||
| describe('Integration | Domain | UseCases | send-completed-participation-results-to-pole-emploi', function () { | ||
| let campaignParticipationId, userId, responseCode; | ||
| let httpAgentStub, httpErrorsHelperStub, loggerStub; | ||
|
|
||
| beforeEach(async function () { | ||
| httpAgentStub = { post: sinon.stub() }; | ||
| loggerStub = { info: sinon.stub(), error: sinon.stub() }; | ||
| httpErrorsHelperStub = { serializeHttpErrorResponse: sinon.stub() }; | ||
| responseCode = Symbol('responseCode'); | ||
|
|
||
| userId = databaseBuilder.factory.buildUser().id; | ||
| databaseBuilder.factory.buildAuthenticationMethod.withPoleEmploiAsIdentityProvider({ userId }); | ||
|
|
||
| const organizationId = databaseBuilder.factory.buildOrganization().id; | ||
| const tagId = databaseBuilder.factory.buildTag({ name: 'POLE EMPLOI' }).id; | ||
| databaseBuilder.factory.buildOrganizationTag({ organizationId, tagId }); | ||
| const campaignId = databaseBuilder.factory.buildCampaign({ organizationId }).id; | ||
| databaseBuilder.factory.buildCampaignSkill({ campaignId }); | ||
| campaignParticipationId = databaseBuilder.factory.buildCampaignParticipation({ campaignId, userId }).id; | ||
| databaseBuilder.factory.buildAssessment({ campaignParticipationId, userId }); | ||
| const learningContentObjects = learningContentBuilder.fromAreas([]); | ||
| mockLearningContent(learningContentObjects); | ||
| return databaseBuilder.commit(); | ||
| }); | ||
|
|
||
| it('should save success of this notification', async function () { | ||
| // given | ||
| httpAgentStub.post.resolves({ | ||
| isSuccessful: true, | ||
| code: responseCode, | ||
| data: { | ||
| access_token: 'token', | ||
| expires_in: new Date(), | ||
| refresh_token: 'refresh_token', | ||
| }, | ||
| }); | ||
|
|
||
| // when | ||
| await usecases.sendCompletedParticipationResultsToPoleEmploi({ | ||
| campaignParticipationId, | ||
| poleEmploiNotifier, | ||
| notifierDependencies: { | ||
| httpAgent: httpAgentStub, | ||
| httpErrorsHelper: httpErrorsHelperStub, | ||
| logger: loggerStub, | ||
| }, | ||
| }); | ||
|
|
||
| // then | ||
| const poleEmploiSendings = await knex('pole-emploi-sendings').where({ campaignParticipationId }); | ||
| expect(poleEmploiSendings.length).to.equal(1); | ||
| expect(poleEmploiSendings[0].responseCode).to.equal(responseCode.toString()); | ||
| expect(poleEmploiSendings[0].type).to.equal('CAMPAIGN_PARTICIPATION_COMPLETION'); | ||
| }); | ||
|
|
||
| it('should return a disable send notification by default (if push is disabled) ', async function () { | ||
| // when | ||
| await usecases.sendCompletedParticipationResultsToPoleEmploi({ | ||
| campaignParticipationId, | ||
| }); | ||
|
|
||
| // then | ||
| const poleEmploiSendings = await knex('pole-emploi-sendings').where({ campaignParticipationId }); | ||
| expect(poleEmploiSendings.length).to.equal(1); | ||
| expect(poleEmploiSendings[0].isSuccessful).to.be.false; | ||
| expect(poleEmploiSendings[0].responseCode).to.equal('SENDING-DISABLED'); | ||
| expect(poleEmploiSendings[0].type).to.equal('CAMPAIGN_PARTICIPATION_COMPLETION'); | ||
| }); | ||
| }); |
Oops, something went wrong.