From 4da30fe9d07a43bce7dc36c3c02e559aa67511a5 Mon Sep 17 00:00:00 2001 From: Peter Broadhurst Date: Sun, 19 Dec 2021 19:55:21 -0500 Subject: [PATCH] Fabric connector needs to subscribe from zero Signed-off-by: Peter Broadhurst --- internal/blockchain/fabric/eventstream.go | 1 + internal/blockchain/fabric/fabric_test.go | 1 + 2 files changed, 2 insertions(+) diff --git a/internal/blockchain/fabric/eventstream.go b/internal/blockchain/fabric/eventstream.go index f17fe08cf4..9f0aad8e63 100644 --- a/internal/blockchain/fabric/eventstream.go +++ b/internal/blockchain/fabric/eventstream.go @@ -118,6 +118,7 @@ func (s *streamManager) createSubscription(name, stream, event string) (*subscri ChaincodeID: s.chaincode, EventFilter: event, }, + FromBlock: "0", } res, err := s.client.R(). SetContext(s.ctx). diff --git a/internal/blockchain/fabric/fabric_test.go b/internal/blockchain/fabric/fabric_test.go index 724d032dd2..efe749ed7a 100644 --- a/internal/blockchain/fabric/fabric_test.go +++ b/internal/blockchain/fabric/fabric_test.go @@ -132,6 +132,7 @@ func TestInitAllNewStreamsAndWSEvent(t *testing.T) { var body map[string]interface{} json.NewDecoder(req.Body).Decode(&body) assert.Equal(t, "es12345", body["stream"]) + assert.Equal(t, "0", body["fromBlock"]) return httpmock.NewJsonResponderOrPanic(200, subscription{ID: "sub12345"})(req) })