Inserimento e creazione stream con il comando curl

Descrizione step-by-step per l'inserimento e la creazione dello stream utilizzando il comando curl

NOTA: i comandi che verranno descritti di seguito dovranno essere lanciati con un terminal SSH, su OS Windows si può utilizzare ad esempio git bash.

1) Creazione e configurazione dello stream

Creare lo stream andando a configurare l'eventType con uno dei seguenti:

• STATUS: per registrare gli eventi di cambiamento di stato delle notifiche

• TIMELINE: per registrare gli eventi di timeline.

All'interno del filterValues è possibile inserire un array di eventi di tipo STATUS/TIMELINE che verranno utilizzati per filtrare e registrare nello stream solo questi eventi; se invece si inserisce un array vuoto: [] lo stream registrerà tutti gli eventi. Lanciare il seguente comando:

curl --location 'https://<baseurlAmbiente>/delivery-progresses/streams' \
--header 'Content-Type: application/json' \
--header 'Accept: application/json' \
--header 'x-api-key: <apiKey>' \
--header 'Authorization: Bearer <PDNDVoucher>' \
--data '{
"title": "<title>",
"eventType": "<eventType>",
"filterValues": <filterValues>
}'

NOTA: sostituire i seguenti:

• <baseurlAmbiente>: inserire la url dell'ambiente di riferimento, nel caso di UAT è il seguente: https://api.uat.notifichedigitali.it

• <apiKey>: inserire la apiKey dell'Ente di riferimento, precedentemente generata su PND

• <PDNDVoucher>: inserire inserire il Voucher generato su PDND Interoperabilità, assicurandosi che non sia scaduto

• <title>: inserire un titolo da attribuire a questo stream

• <eventType>: inserire la tipologia di stream a scelta tra STATUS e TIMELINE

• <filterValues>: inserire un array di eventi che verranno utilizzati come filtro. Se valorizzato con array vuoto: [] lo stream registrerà tutti gli eventi.

Nella response di questo servizio, si otterrà il seguente payload:

{
    "title": "<title>",
    "eventType": "<eventType>",
    "filterValues": <filterValues>,
    "streamId": "<streamId>",
    "activationDate": "<activationDate>"
}

• <streamId>: id dello stream che viene autogenerato dal servizio

• <activationDate>: data di attivazione dello stream autogenerata dal servizio

NOTA: Una volta creata la stream verranno registrati tutti gli eventi emessi dalle notifiche a seguito della loro creazione, di conseguenza si consiglia di creare le stream prima di inserire le notifiche.

2) Prima interrogazione dello stream

La prima interrogazione dello stream permetterà di ricevere i primi 50 eventi registrati dallo stream. E' importante lanciare la curl con il --verbose che permetterà di visualizzare nell'header della response il valore "retry-after" utile per la prossima chiamata. Lanciare il seguente comando:

curl --location 'https://<baseurlAmbiente>/delivery-progresses/streams/<streamId>/events' \
--header 'Accept: application/json' \
--header 'x-api-key: <api-key>' \
--header 'Authorization: Bearer <PDNDVoucher>' \
--verbose

NOTA: sostituire i seguenti:

• <baseurlAmbiente>: inserire la url dell'ambiente di riferimento, nel caso di UAT è il seguente: https://api.uat.notifichedigitali.it

• <apiKey>: inserire la apiKey dell'Ente di riferimento, precedentemente generata su PND

• <PDNDVoucher>: inserire inserire il Voucher generato su PDND Interoperabilità, assicurandosi che non sia scaduto

• <streamId>: inserire l'id dello stream che si vuole interrogare

Nella response di questo servizio, si otterrà il seguente payload che rappresenta tutti gli eventi:

{
    "eventId": "00000000000000000000000000000000000001",
    "timestamp": "<timestamp>",
    "notificationRequestId": "<notificationRequestId>",
    "iun": "<iun>",
    "newStatus": "<newStatus>",
    "timelineEventCategory": "<timelineEventCategory>",
    "recipientIndex": "<recipientIndex>",
    "analogCost": <analogCost>,
    "channel": "<channel>",
    "legalfactIds": ["<legalfactIds>"],
    "validationErrors": <validationErrors>
},
[... altri eventi...]
{
    "eventId": "00000000000000000000000000000000000049",
    "timestamp": "<timestamp>",
    "notificationRequestId": "<notificationRequestId>",
    "iun": "<iun>",
    "newStatus": "<newStatus>",
    "timelineEventCategory": "<timelineEventCategory>",
    "recipientIndex": "<recipientIndex>",
    "analogCost": <analogCost>,
    "channel": "<channel>",
    "legalfactIds": ["<legalfactIds>"],
    "validationErrors": <validationErrors>
},

Gli eventi ottenuti dovranno essere memorizzati dal client poichè nelle successive chiamate i risultati ottenuti verranno consumati e cancellati dallo stream per lasciare il posto agli eventi successivi.

NOTA: nell'header della response ottenuta fare attenzione al campo "retry-after" che deve essere memorizzato per le successive chiamate:

• seretryAfter = 0 è possibile richiamare immediatamente il servizio per ottenere gli eventi successivi se invece

• seretryAfter ≠ 0 è necessario attendere la quantità di tempo (espressa in millisecondi) del valore restituito, prima di richiamare di nuovo il servizio

E' quindi fondamentale rispettare la logica che viene rappresentata dal campo retry-after il quale fornisce l'indicazione al client su quando richiamare il servizio; pertanto si sconsiglia di creare dei processi di batch che effettuino la chiamata in un momento fisso e/o ripetuto nei giorni.

3) Interrogazione dello stream successive alla prima

Dalle interrogazioni successive alla prima dello stream, si otterranno i 50 eventi successivi a quello del lastEventId (l'eventId dell'ultimo evento ottenuto nelle precedenti chiamate). Anche in questo caso è importante lanciare la curl con il --verbose che permetterà di visualizzare nell'header della response il valore "retry-after" utile per le chiamate successive. Lanciare il seguente comando:

curl --location 'https://<baseurlAmbiente>/delivery-progresses/streams/<streamId>/events?lastEventId=<lastEventId>' \
--header 'Accept: application/json' \
--header 'x-api-key: <api-key>' \
--header 'Authorization: Bearer <PDNDVoucher>' \
--verbose

NOTA: sostituire i seguenti:

• <baseurlAmbiente>: inserire la url dell'ambiente di riferimento, nel caso di UAT è il seguente: https://api.uat.notifichedigitali.it

• <apiKey>: inserire la apiKey dell'Ente di riferimento, precedentemente generata su PND

• <PDNDVoucher>: inserire inserire il Voucher generato su PDND Interoperabilità, assicurandosi che non sia scaduto

• <streamId>: inserire l'id dello stream che si vuole interrogare

• <lastEventId>: inserire l'eventId dell'ultimo evento ottenuto nella precedente chiamata

Gli eventi ottenuti dovranno essere memorizzati dal client poichè nelle successive chiamate i risultati ottenuti verranno consumati e cancellati dallo stream per lasciare il posto agli eventi successivi.

NOTA: nella response ottenuta fare attenzione al campo "retry-after" che deve essere memorizzato per le successive chiamate:

• seretryAfter = 0 è possibile richiamare immediatamente il servizio per ottenere gli eventi successivi se invece

• seretryAfter ≠ 0 è necessario attendere la quantità di tempo (espressa in millisecondi) del valore restituito, prima di richiamare di nuovo il servizio

E' quindi fondamentale rispettare la logica che viene rappresentata dal campo "retry-after" il quale fornisce l'indicazione al client su quando richiamare il servizio; pertanto si sconsiglia di creare dei processi di batch che effettuino la chiamata in un momento fisso e/o ripetuto nei giorni.