@@ -25,8 +25,8 @@ import (
2525 acpErrors "github.com/sourcenetwork/acp_core/pkg/errors"
2626 coreTypes "github.com/sourcenetwork/acp_core/pkg/types"
2727 "github.com/sourcenetwork/immutable"
28- sourcehub "github.com/sourcenetwork/sourcehub /sdk"
29- sourcehubTypes "github.com/sourcenetwork/sourcehub /x/acp/types"
28+ vera "github.com/sourcenetwork/vera /sdk"
29+ veraTypes "github.com/sourcenetwork/vera /x/acp/types"
3030
3131 "github.com/sourcenetwork/defradb/acp/identity"
3232 acpTypes "github.com/sourcenetwork/defradb/acp/types"
@@ -36,7 +36,7 @@ func NewSourceHubACP(
3636 chainID string ,
3737 grpcAddress string ,
3838 cometRPCAddress string ,
39- signer sourcehub .TxSigner ,
39+ signer vera .TxSigner ,
4040) (DocumentACP , error ) {
4141 acpSourceHub , err := NewACPSourceHub (chainID , grpcAddress , cometRPCAddress , signer )
4242 if err != nil {
@@ -49,29 +49,29 @@ func NewSourceHubACP(
4949}
5050
5151type SourceHubDocumentACP struct {
52- client * sourcehub .Client
53- txBuilder * sourcehub .TxBuilder
54- signer sourcehub .TxSigner
52+ client * vera .Client
53+ txBuilder * vera .TxBuilder
54+ signer vera .TxSigner
5555}
5656
5757func NewACPSourceHub (
5858 chainID string ,
5959 grpcAddress string ,
6060 cometRPCAddress string ,
61- signer sourcehub .TxSigner ,
61+ signer vera .TxSigner ,
6262) (* SourceHubDocumentACP , error ) {
63- client , err := sourcehub .NewClient (
64- sourcehub .WithGRPCAddr (grpcAddress ),
65- sourcehub .WithCometRPCAddr (cometRPCAddress ),
63+ client , err := vera .NewClient (
64+ vera .WithGRPCAddr (grpcAddress ),
65+ vera .WithCometRPCAddr (cometRPCAddress ),
6666 )
6767 if err != nil {
6868 return nil , err
6969 }
7070
71- txBuilder , err := sourcehub .NewTxBuilder (
72- sourcehub .WithSDKClient (client ),
73- sourcehub .WithChainID (chainID ),
74- sourcehub .WithGasLimit (400000 ),
71+ txBuilder , err := vera .NewTxBuilder (
72+ vera .WithSDKClient (client ),
73+ vera .WithChainID (chainID ),
74+ vera .WithGasLimit (400000 ),
7575 )
7676 if err != nil {
7777 return nil , err
@@ -95,9 +95,9 @@ func (a *SourceHubDocumentACP) AddPolicy(
9595 policyMarshalType acpTypes.PolicyMarshalType ,
9696 creationTime * protoTypes.Timestamp ,
9797) (string , error ) {
98- msgSet := sourcehub .MsgSet {}
98+ msgSet := vera .MsgSet {}
9999 policyMapper := msgSet .WithCreatePolicy (
100- sourcehubTypes .NewMsgCreatePolicy (
100+ veraTypes .NewMsgCreatePolicy (
101101 a .signer .GetAccAddress (),
102102 policy ,
103103 coreTypes .PolicyMarshalingType (policyMarshalType ),
@@ -135,7 +135,7 @@ func (a *SourceHubDocumentACP) Policy(
135135) (immutable.Option [acpTypes.Policy ], error ) {
136136 response , err := a .client .ACPQueryClient ().Policy (
137137 ctx ,
138- & sourcehubTypes .QueryPolicyRequest {Id : policyID },
138+ & veraTypes .QueryPolicyRequest {Id : policyID },
139139 )
140140 if err != nil {
141141 // todo: https://github.com/sourcenetwork/defradb/issues/2826
@@ -202,12 +202,12 @@ func (a *SourceHubDocumentACP) RegisterObject(
202202 return identity .ErrMustBeTokenIdentity
203203 }
204204
205- msgSet := sourcehub .MsgSet {}
206- cmdMapper := msgSet .WithBearerPolicyCmd (& sourcehubTypes .MsgBearerPolicyCmd {
205+ msgSet := vera .MsgSet {}
206+ cmdMapper := msgSet .WithBearerPolicyCmd (& veraTypes .MsgBearerPolicyCmd {
207207 Creator : a .signer .GetAccAddress (),
208208 BearerToken : tokenIdentity .BearerToken (),
209209 PolicyId : policyID ,
210- Cmd : sourcehubTypes .NewRegisterObjectCmd (coreTypes .NewObject (resourceName , objectID )),
210+ Cmd : veraTypes .NewRegisterObjectCmd (coreTypes .NewObject (resourceName , objectID )),
211211 })
212212 tx , err := a .txBuilder .Build (ctx , a .signer , & msgSet )
213213 if err != nil {
@@ -241,7 +241,7 @@ func (a *SourceHubDocumentACP) ObjectOwner(
241241
242242 resp , err := a .client .ACPQueryClient ().ObjectOwner (
243243 ctx ,
244- & sourcehubTypes .QueryObjectOwnerRequest {
244+ & veraTypes .QueryObjectOwnerRequest {
245245 PolicyId : policyID ,
246246 Object : coreTypes .NewObject (resourceName , objectID ),
247247 },
@@ -269,7 +269,7 @@ func (a *SourceHubDocumentACP) VerifyAccessRequest(
269269
270270 checkDocResponse , err := a .client .ACPQueryClient ().VerifyAccessRequest (
271271 ctx ,
272- & sourcehubTypes .QueryVerifyAccessRequestRequest {
272+ & veraTypes .QueryVerifyAccessRequestRequest {
273273 PolicyId : policyID ,
274274 AccessRequest : & coreTypes.AccessRequest {
275275 Operations : []* coreTypes.Operation {
@@ -317,7 +317,7 @@ func (a *SourceHubDocumentACP) AddActorRelationship(
317317 return false , identity .ErrMustBeTokenIdentity
318318 }
319319
320- msgSet := sourcehub .MsgSet {}
320+ msgSet := vera .MsgSet {}
321321
322322 var newActorRelationship * coreTypes.Relationship
323323 if targetActor == "*" {
@@ -335,11 +335,11 @@ func (a *SourceHubDocumentACP) AddActorRelationship(
335335 )
336336 }
337337
338- cmdMapper := msgSet .WithBearerPolicyCmd (& sourcehubTypes .MsgBearerPolicyCmd {
338+ cmdMapper := msgSet .WithBearerPolicyCmd (& veraTypes .MsgBearerPolicyCmd {
339339 Creator : a .signer .GetAccAddress (),
340340 BearerToken : tokenIdentity .BearerToken (),
341341 PolicyId : policyID ,
342- Cmd : sourcehubTypes .NewSetRelationshipCmd (newActorRelationship ),
342+ Cmd : veraTypes .NewSetRelationshipCmd (newActorRelationship ),
343343 })
344344 tx , err := a .txBuilder .Build (ctx , a .signer , & msgSet )
345345 if err != nil {
@@ -384,7 +384,7 @@ func (a *SourceHubDocumentACP) DeleteActorRelationship(
384384 return false , identity .ErrMustBeTokenIdentity
385385 }
386386
387- msgSet := sourcehub .MsgSet {}
387+ msgSet := vera .MsgSet {}
388388
389389 var newActorRelationship * coreTypes.Relationship
390390 if targetActor == "*" {
@@ -402,11 +402,11 @@ func (a *SourceHubDocumentACP) DeleteActorRelationship(
402402 )
403403 }
404404
405- cmdMapper := msgSet .WithBearerPolicyCmd (& sourcehubTypes .MsgBearerPolicyCmd {
405+ cmdMapper := msgSet .WithBearerPolicyCmd (& veraTypes .MsgBearerPolicyCmd {
406406 Creator : a .signer .GetAccAddress (),
407407 BearerToken : tokenIdentity .BearerToken (),
408408 PolicyId : policyID ,
409- Cmd : sourcehubTypes .NewDeleteRelationshipCmd (newActorRelationship ),
409+ Cmd : veraTypes .NewDeleteRelationshipCmd (newActorRelationship ),
410410 })
411411 tx , err := a .txBuilder .Build (ctx , a .signer , & msgSet )
412412 if err != nil {
0 commit comments