feat: Data domain filtering

cmd/daserver/entrypoint.go

@@ -11,7 +11,7 @@ import (
 	"github.com/ethereum/go-ethereum/log"
 	"github.com/urfave/cli/v2"
 
-	proxy "github.com/Layr-Labs/op-plasma-eigenda"
+	proxy "github.com/Layr-Labs/op-plasma-eigenda/server"
 	oplog "github.com/ethereum-optimism/optimism/op-service/log"
 	"github.com/ethereum-optimism/optimism/op-service/opio"
 )

common/common.go

@@ -1,5 +1,34 @@
 package common
 
+import "fmt"
+
+var (
+	ErrInvalidDomainType = fmt.Errorf("invalid domain type")
+)
+
+// DomainType is a enumeration type for the different data domains for which a
+// blob can exist between
+type DomainType uint8
+
+const (
+	BinaryDomain DomainType = iota
+	PolyDomain
+	UnknownDomain
+)
+
+func StrToDomainType(s string) DomainType {
+	switch s {
+	case "binary":
+		return BinaryDomain
+	case "polynomial":
+		return PolyDomain
+	default:
+		return UnknownDomain
+	}
+}
+
+// Helper utility functions //
+
 func EqualSlices[P comparable](s1, s2 []P) bool {
 	if len(s1) != len(s2) {
 		return false

eigenda/commitment.go

@@ -4,6 +4,7 @@ import (
 	"errors"
 
 	op_plasma "github.com/ethereum-optimism/optimism/op-plasma"
+	"github.com/ethereum/go-ethereum/common/hexutil"
 )
 
 // ErrCommitmentLength is returned when the commitment length is invalid.
@@ -35,6 +36,11 @@ func (c Commitment) Encode() []byte {
 	return append([]byte{byte(EigenDA), byte(EigenV0)}, c...)
 }
 
+func StringToCommit(key string) (Commitment, error) {
+	comm, _ := hexutil.Decode(key)
+	return DecodeCommitment(comm)
+}
+
 // DecodeCommitment verifies and decodes an EigenDACommit from raw encoded bytes.
 func DecodeCommitment(commitment []byte) (Commitment, error) {
 	if len(commitment) <= 3 {

server/params.go

@@ -0,0 +1,28 @@
+package proxy
+
+import (
+	"net/http"
+
+	"github.com/Layr-Labs/op-plasma-eigenda/common"
+)
+
+const (
+	GetRoute = "/get"
+	PutRoute = "/put"
+
+	DomainFilterKey = "domain"
+)
+
+func ReadDomainFilter(r *http.Request) (common.DomainType, error) {
+	query := r.URL.Query()
+	key := query.Get(DomainFilterKey)
+	if key == "" { // default
+		return common.BinaryDomain, nil
+	}
+	dt := common.StrToDomainType(key)
+	if dt == common.UnknownDomain {
+		return common.UnknownDomain, common.ErrInvalidDomainType
+	}
+
+	return dt, nil
+}