refactor packages, flags, subscriptions

also DRY up builder tests

use mockgen

@@ -258,0 +251,4 @@
+Our Postgres schemas are built around a single IPFS backing Postgres IPLD blockstore table
+(`ipld.blocks`) that conforms with
+[go-ds-sql](https://github.com/ipfs/go-ds-sql/blob/master/postgres/postgres.go).  All IPLD objects
+are stored in this table, where `key` is the blockstore-prefixed multihash key for the IPLD object

@@ -30,3 +29,4 @@
 const APIName = "statediff"
 
 // APIVersion is the version of the state diffing service API
+// TODO: match package version?

@@ -57,2 +49,2 @@
-	// create subscription and start waiting for events
-	rpcSub := notifier.CreateSubscription()
+// Stream subscribes to statediff payloads as they are created.
+func (api *PublicAPI) Stream(ctx context.Context, params Params) (<-chan Payload, error) {

@@ -113,2 +91,2 @@
-	// create subscription and start waiting for events
-	rpcSub := notifier.CreateSubscription()
+// StreamCodeAndCodeHash writes all of the codehash=>code pairs at a given block to a websocket channel.
+func (api *PublicAPI) StreamCodeAndCodeHash(ctx context.Context, blockNumber uint64) (<-chan types.CodeAndCodeHash, error) {

@@ -0,0 +25,4 @@
+	GetBlockByNumber(number uint64) *types.Block
+	GetReceiptsByHash(hash common.Hash) types.Receipts
+	GetTd(hash common.Hash, number uint64) *big.Int
+	// TODO LockTrie is never used

@@ -0,0 +50,4 @@
+		for event := range bufferChan {
+			block := utils.MustDecode[types.Block](event.Block)
+			// TODO: apparently we ignore the logs
+			// logs := utils.MustDecode[types.Log](chainEvent.Logs)

@@ -286,3 +266,2 @@
+func (sdb *StateDiffBuilder) processStateValueNode(it trie.NodeIterator, parentBlob []byte) (*sdtypes.AccountWrapper, error) {
 	var account types.StateAccount
-	accountRLP := make([]byte, len(it.LeafBlob()))
-	copy(accountRLP, it.LeafBlob())

@@ -81,6 +81,31 @@ func processReceiptsAndLogs(rcts []*types.Receipt) ([]*EthReceipt, [][]*EthLog,
 	return ethRctNodes, ethLogNodes, nil
 }
 
+// // processReceiptsAndLogs will take in receipts

@@ -0,0 +25,4 @@
+func Initialize(ctx core.Context, pl core.PluginLoader, logger core.Logger) {
+	log.SetDefaultLogger(logger)
+
+	// lvl, err := strconv.ParseInt(ctx.String("verbosity"), 10, 8)