[WIP][IBC] Create the initial IBC module

build/config/config1.json

@@ -51,5 +51,9 @@
     "port": "50832",
     "timeout": 30000,
     "use_cors": false
+  },
+  "ibc": {
+    "host_enabled": true,
+    "stores_dir": "/var/ibc"
   }
 }

build/config/config2.json

@@ -51,5 +51,9 @@
     "port": "50832",
     "timeout": 30000,
     "use_cors": false
+  },
+  "ibc": {
+    "host_enabled": true,
+    "stores_dir": "/var/ibc"
   }
 }

build/config/config3.json

@@ -51,5 +51,9 @@
     "port": "50832",
     "timeout": 30000,
     "use_cors": false
+  },
+  "ibc": {
+    "host_enabled": true,
+    "stores_dir": "/var/ibc"
   }
 }

build/config/config4.json

@@ -51,5 +51,9 @@
     "port": "50832",
     "timeout": 30000,
     "use_cors": false
+  },
+  "ibc": {
+    "host_enabled": true,
+    "stores_dir": "/var/ibc"
   }
 }

go.mod

@@ -21,6 +21,7 @@ require (
 
 require (
 	github.com/benbjohnson/clock v1.3.0
+	github.com/cosmos/ics23/go v0.10.0
 	github.com/deepmap/oapi-codegen v1.12.4
 	github.com/dgraph-io/badger/v3 v3.2103.2
 	github.com/foxcpp/go-mockdns v1.0.0
@@ -72,7 +73,7 @@ require (
 	github.com/opencontainers/go-digest v1.0.0 // indirect
 	github.com/opencontainers/image-spec v1.1.0-rc2 // indirect
 	github.com/opencontainers/runc v1.1.4 // indirect
-	github.com/pkg/errors v0.9.1 // indirect
+	github.com/pkg/errors v0.9.1
 	github.com/prometheus/client_golang v1.14.0
 	github.com/sirupsen/logrus v1.9.0 // indirect
 	go.opencensus.io v0.24.0 // indirect
@@ -87,6 +88,7 @@ require (
 	github.com/cockroachdb/apd/v3 v3.1.0 // indirect
 	github.com/containerd/cgroups v1.0.4 // indirect
 	github.com/coreos/go-systemd/v22 v22.5.0 // indirect
+	github.com/cosmos/gogoproto v1.4.3 // indirect
 	github.com/cucumber/common/messages/go/v19 v19.1.2 // indirect
 	github.com/cucumber/gherkin/go/v26 v26.0.3 // indirect
 	github.com/cucumber/messages/go/v21 v21.0.1 // indirect

go.sum

@@ -126,6 +126,10 @@ github.com/coreos/go-systemd/v22 v22.3.2/go.mod h1:Y58oyj3AT4RCenI/lSvhwexgC+NSV
 github.com/coreos/go-systemd/v22 v22.3.3-0.20220203105225-a9a7ef127534/go.mod h1:Y58oyj3AT4RCenI/lSvhwexgC+NSVTIJ3seZv2GcEnc=
 github.com/coreos/go-systemd/v22 v22.5.0 h1:RrqgGjYQKalulkV8NGVIfkXQf6YYmOyiJKk8iXXhfZs=
 github.com/coreos/go-systemd/v22 v22.5.0/go.mod h1:Y58oyj3AT4RCenI/lSvhwexgC+NSVTIJ3seZv2GcEnc=
+github.com/cosmos/gogoproto v1.4.3 h1:RP3yyVREh9snv/lsOvmsAPQt8f44LgL281X0IOIhhcI=
+github.com/cosmos/gogoproto v1.4.3/go.mod h1:0hLIG5TR7IvV1fme1HCFKjfzW9X2x0Mo+RooWXCnOWU=
+github.com/cosmos/ics23/go v0.10.0 h1:iXqLLgp2Lp+EdpIuwXTYIQU+AiHj9mOC2X9ab++bZDM=
+github.com/cosmos/ics23/go v0.10.0/go.mod h1:ZfJSmng/TBNTBkFemHHHj5YY7VAU/MBU980F4VU1NG0=
 github.com/cpuguy83/go-md2man v1.0.10/go.mod h1:SmD6nW6nTyfqj6ABTjUi3V3JVMnlJmwcJI5acqYI6dE=
 github.com/cpuguy83/go-md2man/v2 v2.0.0-20190314233015-f79a8a8ca69d/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU=
 github.com/cpuguy83/go-md2man/v2 v2.0.0/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU=

ibc/host.go

@@ -0,0 +1,25 @@
+package ibc
+
+import (
+	"time"
+
+	"github.com/pokt-network/pocket/shared/modules"
+)
+
+var _ modules.IBCHost = (*Host)(nil)
+
+type Host struct {
+	logger *modules.Logger
+
+	stores modules.StoreManager
+}
+
+// GetStoreManager returns the store manager for the host
+func (h *Host) GetStoreManager() modules.StoreManager {
+	return h.stores
+}
+
+// GetTimestamp returns the current unix timestamp
+func (h *Host) GetTimestamp() uint64 {
+	return uint64(time.Now().Unix())
+}

ibc/host/identifiers.go

@@ -0,0 +1,100 @@
+package host
+
+import (
+	"fmt"
+	"math/rand"
+	"strings"
+	"time"
+
+	coreTypes "github.com/pokt-network/pocket/shared/core/types"
+)
+
+const (
+	defaultIdentifierLength = 32
+	identifierPrefix        = "#"
+	identifierCharset       = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789._+-#[]<>"
+	defaultMaxIdLength      = 64
+	portMaxIdLength         = 128
+)
+
+// basicValidation performs basic validation on the given identifier
+func basicValidation(id string, minLength, maxLength int) error {
+	if strings.TrimSpace(id) == "" {
+		return coreTypes.ErrIBCInvalidID(id, "cannot be blank")
+	}
+
+	if len(id) < minLength || len(id) > maxLength {
+		return coreTypes.ErrIBCInvalidID(id, fmt.Sprintf("length must be between %d and %d", minLength, maxLength))
+	}
+
+	if !strings.HasPrefix(id, identifierPrefix) {
+		return coreTypes.ErrIBCInvalidID(id, fmt.Sprintf("must start with '%s'", identifierPrefix))
+	}
+
+	if strings.Contains(id, "/") {
+		return coreTypes.ErrIBCInvalidID(id, "cannot contain '/'")
+	}
+
+	for _, c := range id {
+		if ok := strings.Contains(identifierCharset, string(c)); !ok {
+			return coreTypes.ErrIBCInvalidID(id, fmt.Sprintf("contains invalid character '%c'", c))
+		}
+	}
+
+	return nil
+}
+
+// ValidateClientID validates the client identifier string
+func ValidateClientID(id string) error {
+	return basicValidation(id, 9, defaultMaxIdLength)
+}
+
+// ValidateConnectionID validates the connection identifier string
+func ValidateConnectionID(id string) error {
+	return basicValidation(id, 10, defaultMaxIdLength)
+}
+
+// ValidateChannelID validates the channel identifier string
+func ValidateChannelID(id string) error {
+	return basicValidation(id, 8, defaultMaxIdLength)
+}
+
+// ValidatePortID validates the port identifier string
+func ValidatePortID(id string) error {
+	return basicValidation(id, 2, portMaxIdLength)
+}
+
+// generateNewIdentifier generates a new identifier in the given range with the identifier prefix
+func generateNewIdentifier(min, max int) string { //nolint:unparam // min is used although always the same
+	//nolint:gosec // weak random source okay - cryptographically secure randomness not required
+	r := rand.New(rand.NewSource(time.Now().UnixNano()))
+	size := r.Intn(max-1-min) + min // -1 for the prefix
+
+	b := make([]byte, size)
+
+	for i := range b {
+		b[i] = identifierCharset[r.Intn(len(identifierCharset))]
+	}
+
+	return identifierPrefix + string(b)
+}
+
+// GenerateClientIdentifier generates a new client identifier
+func GenerateClientIdentifier() string {
+	return generateNewIdentifier(defaultIdentifierLength, defaultMaxIdLength)
+}
+
+// GenerateConnectionIdentifier generates a new connection identifier
+func GenerateConnectionIdentifier() string {
+	return generateNewIdentifier(defaultIdentifierLength, defaultMaxIdLength)
+}
+
+// GenerateChannelIdentifier generates a new channel identifier
+func GenerateChannelIdentifier() string {
+	return generateNewIdentifier(defaultIdentifierLength, defaultMaxIdLength)
+}
+
+// GeneratePortIdentifier generates a new port identifier
+func GeneratePortIdentifier() string {
+	return generateNewIdentifier(defaultIdentifierLength, portMaxIdLength)
+}