feat(dataverse): implement get resource gov addr

Author: bdeneux

dataverse/client.go

@@ -2,8 +2,9 @@ package dataverse
 
 import (
 	"context"
+	"encoding/json"
 	"fmt"
-
+	cgschema "github.com/axone-protocol/axone-contract-schema/go/cognitarium-schema/v5"
 	dvschema "github.com/axone-protocol/axone-contract-schema/go/dataverse-schema/v5"
 	"google.golang.org/grpc"
 )
@@ -14,18 +15,20 @@ type Client interface {
 }
 
 type client struct {
-	dataverseClient dvschema.QueryClient
-	cognitariumAddr string
+	dataverseClient   dvschema.QueryClient
+	cognitariumClient cgschema.QueryClient
+	cognitariumAddr   string
 }
 
-func NewDataverseClient(ctx context.Context, dataverseClient dvschema.QueryClient) (Client, error) {
+func NewDataverseClient(ctx context.Context, dataverseClient dvschema.QueryClient, cognitariumClient cgschema.QueryClient) (Client, error) {
 	cognitariumAddr, err := getCognitariumAddr(ctx, dataverseClient)
 	if err != nil {
 		return nil, fmt.Errorf("failed to get cognitarium address: %w", err)
 	}
 
 	return &client{
 		dataverseClient,
+		cognitariumClient,
 		cognitariumAddr,
 	}, nil
 }
@@ -39,11 +42,45 @@ func NewClient(ctx context.Context,
 		return nil, fmt.Errorf("failed to create dataverse client: %w", err)
 	}
 
-	return NewDataverseClient(ctx, dataverseClient)
+	cognitariumAddr, err := getCognitariumAddr(ctx, dataverseClient)
+	if err != nil {
+		return nil, fmt.Errorf("failed to get cognitarium address: %w", err)
+	}
+
+	cognitariumClient, err := cgschema.NewQueryClient(grpcAddr, cognitariumAddr, opts...)
+	if err != nil {
+		return nil, fmt.Errorf("failed to create cognitarium client: %w", err)
+	}
+
+	return &client{
+		dataverseClient,
+		cognitariumClient,
+		cognitariumAddr,
+	}, nil
 }
 
-func (c *client) GetResourceGovAddr(_ context.Context, _ string) (string, error) {
-	panic("not implemented")
+func (c *client) GetResourceGovAddr(_ context.Context, resourceDID string) (string, error) {
+	query := buildGetResourceGovAddrRequest(resourceDID)
+	queryB, _ := json.Marshal(query)
+	fmt.Printf("query : %s", queryB)
+	response, err := c.cognitariumClient.Select(context.Background(), &cgschema.QueryMsg_Select{Query: query})
+	if err != nil {
+		return "", err
+	}
+
+	if len(response.Results.Bindings) != 1 {
+		return "", fmt.Errorf("could not find governance code")
+	}
+
+	codeBinding, ok := response.Results.Bindings[0]["code"]
+	if !ok {
+		return "", fmt.Errorf("could not find governance code")
+	}
+	code, ok := codeBinding.ValueType.(cgschema.URI)
+	if !ok {
+		return "", fmt.Errorf("could not decode governance code")
+	}
+	return string(*code.Value.Full), nil
 }
 
 func (c *client) ExecGov(_ context.Context, _ string, _ string) (interface{}, error) {

dataverse/predicate.go

@@ -0,0 +1,9 @@
+package dataverse
+
+import cgschema "github.com/axone-protocol/axone-contract-schema/go/cognitarium-schema/v5"
+
+var (
+	VcBodySubject = cgschema.IRI_Full("dataverse:credential:body#subject")
+	VcBodyType    = cgschema.IRI_Full("dataverse:credential:body#type")
+	VcBodyClaim   = cgschema.IRI_Full("dataverse:credential:body#claim")
+)

dataverse/query.go

@@ -0,0 +1,63 @@
+package dataverse
+
+import cgschema "github.com/axone-protocol/axone-contract-schema/go/cognitarium-schema/v5"
+
+func buildGetResourceGovAddrRequest(resource string) cgschema.SelectQuery {
+	limit := 1
+	selectVar := cgschema.SelectItem_Variable("code")
+	codeVarOrNodeOrLit := cgschema.VarOrNodeOrLiteral_Variable("code")
+	credId := cgschema.VarOrNode_Variable("credId")
+	resourceIRI := cgschema.IRI_Full(resource)
+	govType := cgschema.IRI_Prefixed("gov:GovernanceTextCredential")
+	claimVar := cgschema.VarOrNode_Variable("claim")
+	claimVarOrNode := cgschema.VarOrNodeOrLiteral_Variable("claim")
+	isGovernedBy := cgschema.IRI_Prefixed("gov:isGovernedBy")
+	fromGovernance := cgschema.IRI_Prefixed("gov:fromGovernance")
+	govVarOrNodeOrLit := cgschema.VarOrNodeOrLiteral_Variable("gov")
+	govVar := cgschema.VarOrNode_Variable("gov")
+	return cgschema.SelectQuery{
+		Limit: &limit,
+		Prefixes: []cgschema.Prefix{
+			{
+				Prefix:    "gov",
+				Namespace: "https://w3id.org/axone/ontology/v4/schema/credential/governance/text/",
+			},
+		},
+		Select: []cgschema.SelectItem{
+			{
+				Variable: &selectVar,
+			},
+		},
+		Where: cgschema.WhereClause{
+			Bgp: &cgschema.WhereClause_Bgp{
+				Patterns: []cgschema.TriplePattern{
+					{
+						Subject:   cgschema.VarOrNode{Variable: &credId},
+						Predicate: cgschema.VarOrNamedNode{NamedNode: &cgschema.VarOrNamedNode_NamedNode{Full: &VcBodySubject}},
+						Object:    cgschema.VarOrNodeOrLiteral{Node: &cgschema.VarOrNodeOrLiteral_Node{NamedNode: &cgschema.Node_NamedNode{Full: &resourceIRI}}},
+					},
+					{
+						Subject:   cgschema.VarOrNode{Variable: &credId},
+						Predicate: cgschema.VarOrNamedNode{NamedNode: &cgschema.VarOrNamedNode_NamedNode{Full: &VcBodyType}},
+						Object:    cgschema.VarOrNodeOrLiteral{Node: &cgschema.VarOrNodeOrLiteral_Node{NamedNode: &cgschema.Node_NamedNode{Prefixed: &govType}}},
+					},
+					{
+						Subject:   cgschema.VarOrNode{Variable: &credId},
+						Predicate: cgschema.VarOrNamedNode{NamedNode: &cgschema.VarOrNamedNode_NamedNode{Full: &VcBodyClaim}},
+						Object:    cgschema.VarOrNodeOrLiteral{Variable: &claimVarOrNode},
+					},
+					{
+						Subject:   cgschema.VarOrNode{Variable: &claimVar},
+						Predicate: cgschema.VarOrNamedNode{NamedNode: &cgschema.VarOrNamedNode_NamedNode{Prefixed: &isGovernedBy}},
+						Object:    cgschema.VarOrNodeOrLiteral{Variable: &govVarOrNodeOrLit},
+					},
+					{
+						Subject:   cgschema.VarOrNode{Variable: &govVar},
+						Predicate: cgschema.VarOrNamedNode{NamedNode: &cgschema.VarOrNamedNode_NamedNode{Prefixed: &fromGovernance}},
+						Object:    cgschema.VarOrNodeOrLiteral{Variable: &codeVarOrNodeOrLit},
+					},
+				},
+			},
+		},
+	}
+}