@@ -2,2 +2,3 @@
 
-go 1.16
+go 1.17
+

@@ -2,2 +2,3 @@
 
-go 1.16
+go 1.17
+

@@ -0,0 +58,4 @@
+	BlockedChannels        map[string][]byte
+	FilteredStreams        map[string][]byte
+	FilteredChannels       map[string][]byte
+	ShutdownChan           chan struct{}

@@ -0,0 +66,4 @@
+type ResolveResult struct {
+	Name               string
+	NormalizedName     string
+	ClaimHash          []byte

@@ -0,0 +287,4 @@
+}
+
+func (ps *PathSegment) Normalized() string {
+	return internal.NormalizeName(ps.name)

@@ -0,0 +366,4 @@
+
+	ro := grocksdb.NewDefaultReadOptions()
+	/*
+		FIXME:

@@ -0,0 +435,4 @@
+}
+
+// GetProdDB returns a db that is used for production.
+func GetProdDB(name string, secondaryPath string) (*ReadOnlyDBColumnFamily, func(), error) {

@@ -0,0 +533,4 @@
+		db.InitHeaders()
+		db.InitTxCounts()
+	}
+	// TODO: assert tx_count not in self.db.tx_counts, f'boom {tx_count} in {len(self.db.tx_counts)} tx counts'

@@ -0,0 +711,4 @@
+		return err
+	}
+
+	//TODO: figure out a reasonable default and make it a constant

@@ -0,0 +68,4 @@
+)
+
+// GetPrefixes returns an array of all the byte prefix constants.
+func GetPrefixes() [][]byte {

@@ -0,0 +162,4 @@
+
+func (v *DBStateValue) PackValue() []byte {
+	// b'>32sLL32sLLBBlllL'
+	n := 32 + 4 + 4 + 32 + 4 + 4 + 1 + 1 + 4 + 4 + 4 + 4

@@ -0,0 +3398,4 @@
+}
+
+// generic simulates a generic key packing / unpacking function for the prefixes
+func generic(voidstar interface{}, firstByte byte, function byte, functionName string) (interface{}, error) {

@@ -9,4 +10,3 @@
 
 	pb "github.com/lbryio/hub/protobuf/go"
-	"github.com/lbryio/lbry.go/v2/extras/errors"
 )

@@ -0,0 +162,4 @@
+
+func (v *DBStateValue) PackValue() []byte {
+	// b'>32sLL32sLLBBlllL'
+	n := 32 + 4 + 4 + 32 + 4 + 4 + 1 + 1 + 4 + 4 + 4 + 4

@@ -0,0 +162,4 @@
+
+func (v *DBStateValue) PackValue() []byte {
+	// b'>32sLL32sLLBBlllL'
+	n := 32 + 4 + 4 + 32 + 4 + 4 + 1 + 1 + 4 + 4 + 4 + 4

@@ -0,0 +3398,4 @@
+}
+
+// generic simulates a generic key packing / unpacking function for the prefixes
+func generic(voidstar interface{}, firstByte byte, function byte, functionName string) (interface{}, error) {

@@ -0,0 +68,4 @@
+)
+
+// GetPrefixes returns an array of all the byte prefix constants.
+func GetPrefixes() [][]byte {

@@ -0,0 +435,4 @@
+}
+
+// GetProdDB returns a db that is used for production.
+func GetProdDB(name string, secondaryPath string) (*ReadOnlyDBColumnFamily, func(), error) {

@@ -0,0 +533,4 @@
+		db.InitHeaders()
+		db.InitTxCounts()
+	}
+	// TODO: assert tx_count not in self.db.tx_counts, f'boom {tx_count} in {len(self.db.tx_counts)} tx counts'

@@ -0,0 +19,4 @@
+
+// GetExpirationHeightFull returns the expiration height for the given height.
+// Takes boolean to indicated whether to use extended or original expiration time.
+func GetExpirationHeightFull(lastUpdatedHeight uint32, extended bool) uint32 {

@@ -0,0 +18,4 @@
+)
+
+// PrepareResolveResult prepares a ResolveResult to return
+func PrepareResolveResult(

@@ -0,0 +3,4 @@
+// internal types that need their own file to avoid circular imports.
+
+// HeightHash struct for the height subscription endpoint.
+type HeightHash struct {

@@ -7,2 +6,4 @@
 	"time"
 
+	_ "net/http/pprof"
+

@@ -0,0 +1,5 @@
+#!/bin/bash
+./protobuf/build.sh

@@ -12,46 +12,66 @@ import (
 const (
 	ServeCmd  = iota
 	SearchCmd = iota
+	DBCmd     = iota

@@ -0,0 +19,4 @@
+
+// GetExpirationHeightFull returns the expiration height for the given height.
+// Takes boolean to indicated whether to use extended or original expiration time.
+func GetExpirationHeightFull(lastUpdatedHeight uint32, extended bool) uint32 {

@@ -12,46 +12,66 @@ import (
 const (
 	ServeCmd  = iota
 	SearchCmd = iota
+	DBCmd     = iota

@@ -7,2 +6,4 @@
 	"time"
 
+	_ "net/http/pprof"
+