Aggiornamento Versione 2.3

openapi/.swagger-codegen-ignore

@@ -0,0 +1,23 @@
+# Swagger Codegen Ignore
+# Generated by swagger-codegen https://github.com/swagger-api/swagger-codegen
+
+# Use this file to prevent files from being overwritten by the generator.
+# The patterns follow closely to .gitignore or .dockerignore.
+
+# As an example, the C# client generator defines ApiClient.cs.
+# You can make changes and tell Swagger Codgen to ignore just this file by uncommenting the following line:
+#ApiClient.cs
+
+# You can match any string of characters against a directory, file or extension with a single asterisk (*):
+#foo/*/qux
+# The above matches foo/bar/qux and foo/baz/qux, but not foo/bar/baz/qux
+
+# You can recursively match patterns against a directory, file or extension with a double asterisk (**):
+#foo/**/qux
+# This matches foo/bar/qux, foo/baz/qux, and foo/bar/baz/qux
+
+# You can also negate patterns with an exclamation (!).
+# For example, you can ignore all files in a docs folder with the file extension .md:
+#docs/*.md
+# Then explicitly reverse the ignore rule for a single file:
+#!docs/README.md

openapi/.swagger-codegen/VERSION

@@ -0,0 +1 @@
+3.0.35

openapi/how-to-generate-the-bundled-openapi-definition.md

@@ -10,9 +10,9 @@
         ```
           curl https://repo1.maven.org/maven2/io/swagger/codegen/v3/swagger-codegen-cli/3.0.35/swagger-codegen-cli-3.0.35.jar -O
         ```
-    3.  Run the command to generate the 'bundled-api-external-b2b-pa-v2-1.yaml'
+    3.  Run the command to generate the 'bundled-api-external-b2b-pa-v2-3.yaml'
           ```
-          java -jar swagger-codegen-cli-3.0.35.jar generate -l openapi-yaml -i https://raw.githubusercontent.com/pagopa/pn-delivery/develop/docs/openapi/api-external-b2b-pa-bundle.yaml -o . -DoutputFile=bundled-api-external-b2b-pa-v2-1.yaml
+          java -jar swagger-codegen-cli-3.0.35.jar generate -l openapi-yaml -i https://raw.githubusercontent.com/pagopa/pn-delivery/develop/docs/openapi/api-external-b2b-pa-bundle.yaml -o . -DoutputFile=bundled-api-external-b2b-pa-v2-3.yaml
           ```
 3. Then do the modification as below to the generated file.
 4. Add to the `Problem` and `ProblemError` the `type: object` property

package.json

@@ -1,11 +1,11 @@
 {
   "name": "pn-local-validator",
-  "version": "2.1.3.1",
+  "version": "2.3",
   "description": "A system that emulates some features of Piattaforma Notifiche platform.",
   "main": "dist/main.js",
   "scripts": {
     "generate": "npm run generate:api && npm run generate:pnapi",
-    "generate:pnapi": "shx rm -rf ./src/generated/pnapi && shx mkdir -p ./src/generated/pnapi && gen-api-models --api-spec ./openapi/bundled-api-external-b2b-pa-v2-1.yaml --no-strict --out-dir ./src/generated/pnapi --request-types --response-decoders",
+    "generate:pnapi": "shx rm -rf ./src/generated/pnapi && shx mkdir -p ./src/generated/pnapi && gen-api-models --api-spec ./openapi/bundled-api-external-b2b-pa-v2-3.yaml --no-strict --out-dir ./src/generated/pnapi --request-types --response-decoders",
     "generate:api": "shx rm -rf ./src/generated/api && shx mkdir -p ./src/generated/api && gen-api-models --api-spec ./openapi/internal.yaml --no-strict --out-dir ./src/generated/api",
     "clean": "tsc --build --clean",
     "postcompile": "shx cp -R ./src/adapters/http/download/exampledocuments ./dist/adapters/http/download/exampledocuments",

src/adapters/http/checkNotificationStatus/__tests__/router.test.ts

@@ -29,7 +29,7 @@ describe('Notification Status Router', () => {
 
   it('should return a 400 response with some data', async () => {
     const response = await supertest(app)
-      .get('/api/delivery/v2.1/requests')
+      .get('/api/delivery/v2.3/requests')
       .query({
         notificationRequestId: '123',
       });

src/adapters/http/checkNotificationStatus/router.ts

@@ -46,7 +46,7 @@ const handler =
 export const makeNotificationStatusRouter = (env: SystemEnv): express.Router => {
   const router = express.Router();
 
-  router.get('/delivery/v2.1/requests', toExpressHandler(handler(env)));
+  router.get('/delivery/v2.3/requests', toExpressHandler(handler(env)));
 
   return router;
 };

src/adapters/http/checklist/router.ts

@@ -9,7 +9,7 @@ import { evaluateReport } from '../../../domain/reportengine/reportengine';
 import { report } from '../../../domain/checks/report';
 import { SystemEnv } from '../../../useCases/SystemEnv';
 
-const appVersion = '2.1.3';
+const appVersion = '2.3';
 
 const handler =
   (env: SystemEnv): Handler =>

src/adapters/http/consumeEventStream/__tests__/router.test.ts

@@ -30,7 +30,7 @@ describe('Consume Event Stream Router', () => {
 
   it('should return a 400 response with some data', async () => {
     const response = await supertest(app)
-      .get('/api/delivery-progresses/streams/someStreamId/events')
+      .get('/api/delivery-progresses/v2.3/streams/someStreamId/events')
       .query({
         lastEventId: '123',
       });

src/adapters/http/consumeEventStream/router.ts

@@ -33,7 +33,7 @@ const handler =
 export const makeConsumeEventStreamRouter = (env: SystemEnv): express.Router => {
   const router = express.Router();
 
-  router.get('/delivery-progresses/streams/:streamId/events', toExpressHandler(handler(env)));
+  router.get('/delivery-progresses/v2.3/streams/:streamId/events', toExpressHandler(handler(env)));
 
   return router;
 };

src/adapters/http/createEventStream/__tests__/router.test.ts

@@ -29,7 +29,7 @@ describe('Create Event Stream Router', () => {
 
   it('should return a 400 response with some data', async () => {
     const response = await supertest(app)
-      .post('/api/delivery-progresses/streams')
+      .post('/api/delivery-progresses/v2.3/streams')
       .send({});
 
     expect(response.status).toBe(400);

src/adapters/http/createEventStream/router.ts

@@ -35,7 +35,7 @@ const handler =
 export const makeCreateEventStreamRouter = (env: SystemEnv): express.Router => {
   const router = express.Router();
 
-  router.post('/delivery-progresses/streams', toExpressHandler(handler(env)));
+  router.post('/delivery-progresses/v2.3/streams', toExpressHandler(handler(env)));
 
   return router;
 };

src/adapters/http/deleteEventStream/__tests__/router.test.ts

@@ -29,7 +29,7 @@ describe('Delete Event Stream Router', () => {
 
   it('should return a 500 response with some data', async () => {
     const response = await supertest(app)
-      .delete('/api/delivery-progresses/streams/123')
+      .delete('/api/delivery-progresses/v2.3/streams/123')
 
     expect(response.status).toBe(500);
   });

src/adapters/http/deleteEventStream/router.ts

@@ -31,7 +31,7 @@ const handler =
 export const makeDeleteEventStreamRouter = (env: SystemEnv): express.Router => {
   const router = express.Router();
 
-  router.delete('/delivery-progresses/streams/:streamId', toExpressHandler(handler(env)));
+  router.delete('/delivery-progresses/v2.3/streams/:streamId', toExpressHandler(handler(env)));
 
   return router;
 };

src/adapters/http/deleteNotification/router.ts

@@ -31,6 +31,6 @@ const handler =
 
 export const makeDeleteNotificationRouter = (env: SystemEnv): express.Router => {
   const router = express.Router();
-  router.put('/delivery-push/v2.1/notifications/cancel/:iun', toExpressHandler(handler(env)));
+  router.put('/delivery-push/v2.3/notifications/cancel/:iun', toExpressHandler(handler(env)));
   return router;
 };

src/adapters/http/getNotificationDetail/__tests__/router.test.ts

@@ -30,7 +30,7 @@ describe('Get Notification Detail Router', () => {
 
   it('should return a 400 response with some data', async () => {
     const response = await supertest(app)
-      .get('/api/delivery/v2.1/notifications/sent/1A')
+      .get('/api/delivery/v2.3/notifications/sent/1A')
       .query({
         notificationRequestId: '123',
       });

src/adapters/http/getNotificationDetail/router.ts

@@ -33,7 +33,7 @@ const handler =
 export const makeGetNotificationDetailRouter = (env: SystemEnv): express.Router => {
   const router = express.Router();
 
-  router.get('/delivery/v2.1/notifications/sent/:iun', toExpressHandler(handler(env)));
+  router.get('/delivery/v2.3/notifications/sent/:iun', toExpressHandler(handler(env)));
 
   return router;
 };

src/adapters/http/getNotificationPrice/__tests__/router.test.ts

@@ -30,7 +30,7 @@ describe('Get Notification Price Metadata Router', () => {
 
   it('should return a 400 response with some data', async () => {
     const response = await supertest(app)
-      .get('/api/delivery/price/3C/1A')
+      .get('/api/delivery/v2.3/price/3C/1A')
       .query({
         notificationRequestId: '123',
       });

src/adapters/http/getNotificationPrice/router.ts

@@ -32,7 +32,7 @@ const handler =
 export const makeGetNotificationPriceRouter = (env: SystemEnv): express.Router => {
   const router = express.Router();
 
-  router.get('/delivery/price/:paTaxId/:noticeCode', toExpressHandler(handler(env)));
+  router.get('/delivery/v2.3/price/:paTaxId/:noticeCode', toExpressHandler(handler(env)));
 
   return router;
 };

src/adapters/http/getStreamById/__tests__/router.test.ts

@@ -30,7 +30,7 @@ describe('Get Stream By Id Router', () => {
 
   it('should return a 400 response with some data', async () => {
     const response = await supertest(app)
-      .get('/api/delivery-progresses/streams/1A')
+      .get('/api/delivery-progresses/v2.3/streams/1A')
       .query({
         notificationRequestId: '123',
       });

src/adapters/http/getStreamById/router.ts

@@ -32,7 +32,7 @@ const handler =
 export const makeGetEventStreamByIdRouter = (env: SystemEnv): express.Router => {
   const router = express.Router();
 
-  router.get('/delivery-progresses/streams/:streamId', toExpressHandler(handler(env)));
+  router.get('/delivery-progresses/v2.3/streams/:streamId', toExpressHandler(handler(env)));
 
   return router;
 };

src/adapters/http/listEventStream/__test__/router.test.ts

@@ -12,7 +12,7 @@ describe("ListEventStream router", () => {
 
     it("With empty body response should be 404", async () => {
         const response = await supertest(app)
-                        .post('/delivery-progresses/streams')
+                        .post('/delivery-progresses/v2.3/streams')
                         .set('x-api-key', data.apiKey.valid)
                         .send();
 

src/adapters/http/listEventStream/router.ts

@@ -30,7 +30,7 @@ const handler =
 export const makeListEventStreamRouter = (env: SystemEnv): express.Router => {
   const router = express.Router();
 
-  router.get('/delivery-progresses/streams', toExpressHandler(handler(env)));
+  router.get('/delivery-progresses/2.3/streams', toExpressHandler(handler(env)));
 
   return router;
 };

src/adapters/http/sendNotification/__test__/router.test.ts

@@ -12,7 +12,7 @@ describe("sendNotification router", () => {
 
     it("With empty body response should be 400", async () => {
         const response = await supertest(app)
-                        .post('/delivery/v2.1/requests')
+                        .post('/delivery/v2.3/requests')
                         .set('x-api-key', data.apiKey.valid)
                         .send();
 

src/adapters/http/sendNotification/router.ts

@@ -11,15 +11,15 @@ import { Handler, toExpressHandler, removeNullValues } from '../Handler';
 import { SystemEnv } from '../../../useCases/SystemEnv';
 import { persistRecord } from '../../../useCases/PersistRecord';
 import { makeNewNotificationRecord } from '../../../domain/NewNotificationRecord';
-import { NewNotificationRequestV21 } from '../../../generated/pnapi/NewNotificationRequestV21';
+import { NewNotificationRequestV23 } from '../../../generated/pnapi/NewNotificationRequestV23';
 
 const handler =
   (env: SystemEnv): Handler =>
   (req, res) =>
     pipe(
       Apply.sequenceS(E.Apply)({
         apiKey: t.string.decode(req.headers['x-api-key']),
-        body: NewNotificationRequestV21.decode(removeNullValues(req.body)),
+        body: NewNotificationRequestV23.decode(removeNullValues(req.body)),
       }),
       E.map(flow(makeNewNotificationRecord(env), constant, persistRecord(env))),
       E.map(
@@ -33,7 +33,7 @@ const handler =
 export const makeSendNotificationRouter = (env: SystemEnv): express.Router => {
   const router = express.Router();
 
-  router.post('/delivery/v2.1/requests', toExpressHandler(handler(env)));
+  router.post('/delivery/v2.3/requests', toExpressHandler(handler(env)));
 
   return router;
 };

src/adapters/http/updateEventStream/__test__/router.test.ts

@@ -12,7 +12,7 @@ describe("sendNotification router", () => {
 
     it("With empty body response should be 404", async () => {
         const response = await supertest(app)
-            .post('/delivery/requests')
+            .post('/delivery/v2.3/requests')
             .set('x-api-key', data.apiKey.valid)
             .send();
 

src/adapters/http/updateEventStream/router.ts

@@ -33,7 +33,7 @@ const handler =
 export const makeUpdateEventStreamRouter = (env: SystemEnv): express.Router => {
   const router = express.Router();
 
-  router.put('/delivery-progresses/streams/:streamId', toExpressHandler(handler(env)));
+  router.put('/delivery-progresses/2.3/streams/:streamId', toExpressHandler(handler(env)));
 
   return router;
 };

src/domain/CheckNotificationStatusRecord.ts

@@ -3,7 +3,7 @@ import * as O from 'fp-ts/Option';
 import * as RA from 'fp-ts/ReadonlyArray';
 import { flow, identity, pipe } from 'fp-ts/function';
 import * as t from 'io-ts';
-import { NewNotificationRequestStatusResponseV21 } from '../generated/pnapi/NewNotificationRequestStatusResponseV21';
+import { NewNotificationRequestStatusResponseV23 } from '../generated/pnapi/NewNotificationRequestStatusResponseV23';
 import { NotificationDocument } from '../generated/pnapi/NotificationDocument';
 import { PreLoadResponse } from '../generated/pnapi/PreLoadResponse';
 import { SystemEnv } from '../useCases/SystemEnv';
@@ -22,8 +22,8 @@ export type CheckNotificationStatusRecord = AuditRecord & {
     body: { paProtocolNumber: string; idempotenceToken?: string } | { notificationRequestId: string };
   };
   output:
-  | Response<200, NewNotificationRequestStatusResponseV21>
-  | Response<500, NewNotificationRequestStatusResponseV21>
+  | Response<200, NewNotificationRequestStatusResponseV23>
+  | Response<500, NewNotificationRequestStatusResponseV23>
   | Response<403, UnauthorizedMessageBody>
   | Response<404>;
 };
@@ -56,18 +56,18 @@ export const makeCheckNotificationStatusRecord =
                 E.fold(
                   (nr) => ({ ...nr, notificationRequestStatus: 'WAITING' }),
                   (n) =>
-                    t.exact(NewNotificationRequestStatusResponseV21).encode({ ...n, notificationRequestStatus: 'ACCEPTED' })
+                    t.exact(NewNotificationRequestStatusResponseV23).encode({ ...n, notificationRequestStatus: 'ACCEPTED' })
                 )
               ),
               O.map((response) =>
                 pipe(
                   response.recipients,
                   RA.reduce(response, function (res, invalidRec) {
-                    const newRes = t.exact(NewNotificationRequestStatusResponseV21).encode(res as NewNotificationRequestStatusResponseV21);
+                    const newRes = t.exact(NewNotificationRequestStatusResponseV23).encode(res as NewNotificationRequestStatusResponseV23);
                     const pastErrors = newRes.errors ? newRes.errors : [];
                     if (!VALID_CAPS[invalidRec.physicalAddress.zip as keyof typeof VALID_CAPS]) {
-                      return t.exact(NewNotificationRequestStatusResponseV21).encode({
-                        ...res as NewNotificationRequestStatusResponseV21,
+                      return t.exact(NewNotificationRequestStatusResponseV23).encode({
+                        ...res as NewNotificationRequestStatusResponseV23,
                         notificationRequestStatus: 'REFUSED',
                         errors: [
                           ...pastErrors,
@@ -87,7 +87,7 @@ export const makeCheckNotificationStatusRecord =
                   response.documents,
                   // Scroll throw the documents of the responce
                   RA.reduce(response, (respAccrRaw, docRespRaw) => {
-                    const respAccr = t.exact(NewNotificationRequestStatusResponseV21).encode(respAccrRaw as NewNotificationRequestStatusResponseV21);
+                    const respAccr = t.exact(NewNotificationRequestStatusResponseV23).encode(respAccrRaw as NewNotificationRequestStatusResponseV23);
                     const docResp = docRespRaw as NotificationDocument;
 
                     const key = docResp.ref.key;
@@ -140,7 +140,7 @@ export const makeCheckNotificationStatusRecord =
 
                     if (!matchFound) {
                       const pastErrors = respAccr.errors ? respAccr.errors : [];
-                      return t.exact(NewNotificationRequestStatusResponseV21).encode({
+                      return t.exact(NewNotificationRequestStatusResponseV23).encode({
                         ...respAccr,
                         notificationRequestStatus: 'REFUSED',
                         errors: [

src/domain/DomainEnv.ts

@@ -13,6 +13,10 @@ export type DomainEnv = {
   uploadToS3URL: URL;
   retryAfterMs: number;
   notificationPrice: number;
+  analogCost: number;
+  totalPrice: number;
+  partialPrice: number;
+  sendFee: number;
   // generators
   iunGenerator: IO<IUN>;
   dateGenerator: IO<Date>;