go/sonr
1
0
Fork 0
mirror of https://github.com/sonr-io/sonr.git synced 2026-08-03 01:41:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: simplify verification method structure

Browse Source
This commit is contained in:
Prad Nukala
2024-09-14 14:59:10 -04:00
parent 8f234dc561
commit 954f334e3c
23 changed files with 2431 additions and 29841 deletions
Download Patch File Download Diff File Expand all files Collapse all files
api/did/v1/state.cosmos_orm.go
+43 -28
View File
@@ -26,18 +26,13 @@ type AccountTable interface {
HasByControllerChainCodeIndex(ctx context.Context, controller string, chain_code uint32, index uint32) (found bool, err error)
// GetByControllerChainCodeIndex returns nil and an error which responds true to ormerrors.IsNotFound() if the record was not found.
GetByControllerChainCodeIndex(ctx context.Context, controller string, chain_code uint32, index uint32) (*Account, error)
HasByNamespaceAddress(ctx context.Context, namespace string, address string) (found bool, err error)
// GetByNamespaceAddress returns nil and an error which responds true to ormerrors.IsNotFound() if the record was not found.
GetByNamespaceAddress(ctx context.Context, namespace string, address string) (*Account, error)
List(ctx context.Context, prefixKey AccountIndexKey, opts ...ormlist.Option) (AccountIterator, error)
ListRange(ctx context.Context, from, to AccountIndexKey, opts ...ormlist.Option) (AccountIterator, error)
DeleteBy(ctx context.Context, prefixKey AccountIndexKey) error
DeleteRange(ctx context.Context, from, to AccountIndexKey) error
Get(ctx context.Context, id string) (*Aliases, error)
HasBySubject(ctx context.Context, subject string) (found bool, err error)
// GetBySubject returns nil and an error which responds true to ormerrors.IsNotFound() if the record was not found.
GetBySubject(ctx context.Context, subject string) (*Aliases, error)
List(ctx context.Context, prefixKey AliasesIndexKey, opts ...ormlist.Option) (AliasesIterator, error)
ListRange(ctx context.Context, from, to AliasesIndexKey, opts ...ormlist.Option) (AliasesIterator, error)
DeleteBy(ctx context.Context, prefixKey AliasesIndexKey) error
DeleteRange(ctx context.Context, from, to AliasesIndexKey) error
doNotImplement()
}
@@ -84,16 +79,6 @@ func (x AccountControllerLabelIndexKey) accountIndexKey() {}
func (this AccountControllerLabelIndexKey) WithController(controller string) AccountControllerLabelIndexKey {
this.vs = []interface{}{controller}
type AliasesSubjectIndexKey struct {
vs []interface{}
}
func (x AliasesSubjectIndexKey) id() uint32 { return 1 }
func (x AliasesSubjectIndexKey) values() []interface{} { return x.vs }
func (x AliasesSubjectIndexKey) aliasesIndexKey() {}
func (this AliasesSubjectIndexKey) WithSubject(subject string) AliasesSubjectIndexKey {
this.vs = []interface{}{subject}
return this
}
@@ -143,6 +128,24 @@ func (this AccountControllerChainCodeIndexIndexKey) WithControllerChainCodeIndex
return this
}
type AccountNamespaceAddressIndexKey struct {
vs []interface{}
}
func (x AccountNamespaceAddressIndexKey) id() uint32 { return 4 }
func (x AccountNamespaceAddressIndexKey) values() []interface{} { return x.vs }
func (x AccountNamespaceAddressIndexKey) accountIndexKey() {}
func (this AccountNamespaceAddressIndexKey) WithNamespace(namespace string) AccountNamespaceAddressIndexKey {
this.vs = []interface{}{namespace}
return this
}
func (this AccountNamespaceAddressIndexKey) WithNamespaceAddress(namespace string, address string) AccountNamespaceAddressIndexKey {
this.vs = []interface{}{namespace, address}
return this
}
type accountTable struct {
table ormtable.Table
}
@@ -191,16 +194,6 @@ func (this accountTable) GetByControllerLabel(ctx context.Context, controller st
found, err := this.table.GetIndexByID(1).(ormtable.UniqueIndex).Get(ctx, &account,
controller,
label,
func (this aliasesTable) HasBySubject(ctx context.Context, subject string) (found bool, err error) {
return this.table.GetIndexByID(1).(ormtable.UniqueIndex).Has(ctx,
subject,
)
}
func (this aliasesTable) GetBySubject(ctx context.Context, subject string) (*Aliases, error) {
var aliases Aliases
found, err := this.table.GetIndexByID(1).(ormtable.UniqueIndex).Get(ctx, &aliases,
subject,
)
if err != nil {
return nil, err
@@ -257,6 +250,28 @@ func (this accountTable) GetByControllerChainCodeIndex(ctx context.Context, cont
return &account, nil
}
func (this accountTable) HasByNamespaceAddress(ctx context.Context, namespace string, address string) (found bool, err error) {
return this.table.GetIndexByID(4).(ormtable.UniqueIndex).Has(ctx,
namespace,
address,
)
}
func (this accountTable) GetByNamespaceAddress(ctx context.Context, namespace string, address string) (*Account, error) {
var account Account
found, err := this.table.GetIndexByID(4).(ormtable.UniqueIndex).Get(ctx, &account,
namespace,
address,
)
if err != nil {
return nil, err
}
if !found {
return nil, ormerrors.NotFound
}
return &account, nil
}
func (this accountTable) List(ctx context.Context, prefixKey AccountIndexKey, opts ...ormlist.Option) (AccountIterator, error) {
it, err := this.table.GetIndexByID(prefixKey.id()).List(ctx, prefixKey.values(), opts...)
return AccountIterator{it}, err