From d248a1050e5ee12b6ef6df680b60c4cfb532b6dd Mon Sep 17 00:00:00 2001 From: Ian Norden Date: Mon, 15 Apr 2019 11:29:22 -0500 Subject: [PATCH] syncer - interface for syncing with a statediff subscription --- pkg/ipfs/syncer.go | 44 ++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 44 insertions(+) create mode 100644 pkg/ipfs/syncer.go diff --git a/pkg/ipfs/syncer.go b/pkg/ipfs/syncer.go new file mode 100644 index 00000000..87f6a19a --- /dev/null +++ b/pkg/ipfs/syncer.go @@ -0,0 +1,44 @@ +// VulcanizeDB +// Copyright © 2019 Vulcanize + +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU Affero General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. + +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +// GNU Affero General Public License for more details. + +// You should have received a copy of the GNU Affero General Public License +// along with this program. If not, see . + +package ipfs + +import ( + "github.com/ethereum/go-ethereum/rpc" + "github.com/ethereum/go-ethereum/statediff" + + "github.com/vulcanize/vulcanizedb/pkg/core" +) + +type Syncer interface { + Sync(payloadChan chan statediff.Payload) (*rpc.ClientSubscription, error) +} + +type StateDiffSyncer struct { + Client core.RpcClient + PayloadChan chan statediff.Payload +} + +func NewStateDiffSyncer(client core.RpcClient) *StateDiffSyncer { + return &StateDiffSyncer{ + Client: client, + } +} + +// Sync is the main loop for subscribing to data from the Geth state diff process +func (i *StateDiffSyncer) Sync(payloadChan chan statediff.Payload) (*rpc.ClientSubscription, error) { + return i.Client.Subscribe("statediff", i.PayloadChan) +} \ No newline at end of file