Sync <-> Async bridge - REST Gateway for messages/event correlation about firefly HOT 1 CLOSED

title Sync <-> Async Example: Unpinned request, pinned response

participant "Member1 App\nRequester" as app1
database "FireFly DB" as db1
boundary "FireFly Core\n(Multiparty GW API)" as firefly1
entity "Data\nExchange 1" as dx1

entity "Blockchain" as blockchain

entity "Data\nExchange 2" as dx2
boundary "FireFly Core\n(Multiparty GW Proxy)" as firefly2
database "FireFly DB" as db2
participant "Member2 App\nResponder" as app2

app1->firefly1: POST /call/tag/my-request

activate firefly1 #20639b
activate firefly2 #20639b
firefly1-->firefly1: Sync<->Async\nsetup for reply
firefly1<->db1: Store\n"my-request"\nrequest
group Unpinned request
firefly1->dx1: Send message
dx1-->dx2: Secure private transfer
dx2->firefly2: New message
firefly2<->db2: Store\n"/my-request"\nrequest [EVENT]
end
firefly2<->firefly2: Match subscription\non "webhook"\ntransport
firefly2->app2: POST webhook "/my-request"
deactivate firefly1
deactivate firefly2

group Responder app
app2<->app2: Awesome app\nprocessing
end

app2->firefly2: POST [200]\n(with data)
activate firefly2 #20639b
activate firefly1 #20639b
firefly2<->db2: Store\n"my-response"\nresponse
group Pinned response
firefly2->dx2: Send message
firefly2->blockchain: Pin response\nto blockchain
group The order of these events is non-deterministic
dx2-->dx1: Secure private transfer
dx1-->firefly1: New message
firefly1<-->db1: Interim DB updates 
blockchain-->firefly1: Detect pin
firefly1<-->db1: Interim DB updates 
end
firefly1->firefly1: aggregate pin\nand data
firefly1<->db1: Store confirmed\n"my-response"\nresponse [EVENT]
end
firefly1-->firefly1: Sync<->Async\ncorrelation with\nrequest msg
firefly1->app1: POST [200]\n(with data)
deactivate firefly2
deactivate firefly1