From e1df0a69d36b74bfdcaef543b9f6f2a18b97dbec Mon Sep 17 00:00:00 2001 From: bryan newbold Date: Wed, 16 Apr 2025 17:47:50 -0700 Subject: [PATCH] allow blocks in #sync output --- firehose.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/firehose.go b/firehose.go index ba5c3d0..1a76b41 100644 --- a/firehose.go +++ b/firehose.go @@ -277,10 +277,12 @@ func (gfc *GoatFirehoseConsumer) handleSyncEvent(ctx context.Context, evt *comat if gfc.Quiet { return nil } - evt.Blocks = nil + if !gfc.Blocks { + evt.Blocks = nil + } out := make(map[string]interface{}) out["type"] = "sync" - out["commit"] = commit.AsData() + out["commit"] = commit.AsData() // NOTE: funky, but helpful, to include this in output out["payload"] = evt b, err := json.Marshal(out) if err != nil { -- 2.51.2