Rough sketch showing how the two servers interact with each other. We only expose the EventsServer.

fab-7069.txt

                                        ┌──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┐
                                        │                                                                 peer                                                                 │
                                        │                                                                                                                                      │
┌───────────────┐                       │                                                                                                                                      │
│               │                       │                                                                                                                                      │
│               │                       │                                                                                                                                      │
│               │                       │                                                                                                                                      │
│               │                       │                                                                                                                                      │
│               │                       │     ┌────────────────────────────────────────────────┐                                                                               │
│               │         1. invoke     │     │         ┌───────────────────────────┐          │                                                                               │
│         ──────┼─────peer.Deliver RPC──┼─────┼──▶      │                           │          │                                                                               │
│               │     (sends Envelope)  │     │         │                           │          │                                                                               │
│               │                       │     │         │2. record requested filter │          │                                                                               │
│               │                       │     │         │3. is the client authorized│          │                                                                               │
│               │                       │     │         │   for this request? [*]   │          │                                 ┌──────────────────────────────────────────┐  │
│               │                       │     │         │                           │          │  4. peer internally invokes     │                                          │  │
│               │                       │     │         │                           │   ───────┼────────ab.Deliver RPC───────────┼───▶                                      │  │
│               │                       │     │         │                           │          │                                 │                                          │  │
│               │                       │     │         └───────────────────────────┘          │                                 │                                          │  │
│               │                       │     │               peer.EventsServer                │                                 │                                          │  │
│    client     │                       │     │                                                │                                 │                                          │  │
│               │                       │     │         (implements peer.Deliver RPC)          │                                 │         ab.AtomicBroadcastServer         │  │
│               │                       │     │                                                │                                 │                                          │  │
│               │                       │     │         ┌───────────────────────────┐          │                                 │       (implements ab.Deliver RPC)        │  │
│               │                       │     │         │                           │          │                                 │                                          │  │
│               │                       │     │         │                           │          │                                 │                                          │  │
│               │                       │     │         │6. transform/scrub received│          │                                 │                                          │  │
│               │                       │     │         │ block based on requested  │          │                                 │                                          │  │
│               │                       │     │         │          filter           │          │        5. peer receives         │                                          │  │
│               │                       │     │         │                           │   ◀──────┼─────ab.Deliver RPC response─────┼────                                      │  │
│               │         7. return     │     │         │                           │          │                                 │                                          │  │
│         ◀─────┼─peer.Deliver RPC response───┼───      │                           │          │                                 └──────────────────────────────────────────┘  │
│               │  (sends DeliverResponse)    │         └───────────────────────────┘          │                                                                               │
│               │                       │     └────────────────────────────────────────────────┘                                                                               │
│               │                       │                                                                                                                                      │
│               │                       │                                                                                                                                      │
│               │                       │                                                                                                                                      │
└───────────────┘                       │                                                                                                                                      │
                                        │                                                                                                                                      │
                                        │                                                                                                                                      │
                                        └──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┘