Skip to content

Commit 1b33134

Browse files
Fix: JSON RPC
1 parent c14f87d commit 1b33134

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

cmd/jsonrpc/init.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -190,6 +190,13 @@ func initBlobReceiver(ctx context.Context, cfg Config) (node.DalApi, error) {
190190
})
191191
err := r2.Init(ctx)
192192
return r2, err
193+
case "celenium_blobs":
194+
datasource, ok := cfg.DataSources[cfg.JsonRpcConfig.BlobReceiver]
195+
if !ok {
196+
return nil, errors.Errorf("unknown data source pointed in blob_receiver: %s", cfg.JsonRpcConfig.BlobReceiver)
197+
}
198+
celeniumBlobReceiver := blob.NewCelenium(datasource)
199+
return celeniumBlobReceiver, nil
193200
default:
194201
datasource, ok := cfg.DataSources[cfg.JsonRpcConfig.BlobReceiver]
195202
if !ok {

0 commit comments

Comments
 (0)