urdt/term
5
0
Fork 0
Code Issues 2 Pull Requests Actions Packages Projects Releases Wiki Activity

Add processvoucher routine

Browse Source
This commit is contained in:
lash
2024-11-02 16:08:05 +00:00
parent a414327dc5
commit d3d42ec6a2
8 changed files with 50 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
event/custodial_registration.go
View File

@@ -32,7 +32,7 @@ func asCustodialRegistrationEvent(gev *geEvent.Event) (*eventCustodialRegistrati
return &ev, true
}
func handleCustodialRegistration(ctx context.Context, store common.UserDataStore, ev *eventCustodialRegistration) error {
func handleCustodialRegistration(ctx context.Context, store *common.UserDataStore, ev *eventCustodialRegistration) error {
identity, err := lookup.IdentityFromAddress(ctx, store, ev.Account)
if err != nil {
return err

2
event/nats/nats.go
View File

@@ -30,7 +30,7 @@ type NatsSubscription struct {
func NewNatsSubscription(store db.Db) *NatsSubscription {
return &NatsSubscription{
Router: event.Router{
Store: common.UserDataStore{
Store: &common.UserDataStore{
Db: store,
},
},

2
event/route.go
View File

@@ -21,7 +21,7 @@ var (
)
type Router struct {
Store common.UserDataStore
Store *common.UserDataStore
}
func(r *Router) Route(ctx context.Context, gev *geEvent.Event) error {

44
event/token.go
View File

@@ -11,6 +11,8 @@ import (
const (
evTransfer = "TOKEN_TRANSFER"
// TODO: use export from urdt storage
DATATYPE_USERSUB = 64
)
type eventTokenTransfer struct {
@@ -23,8 +25,42 @@ type eventTokenTransfer struct {
// return nil
//}
func updateTokenList(ctx context.Context, api remote.AccountServiceInterface, store common.UserDataStore, identity lookup.Identity) error {
api.FetchVouchers(ctx, identity.ChecksumAddress)
func updateTokenList(ctx context.Context, api remote.AccountServiceInterface, store *common.UserDataStore, identity lookup.Identity) error {
holdings, err := api.FetchVouchers(ctx, identity.ChecksumAddress)
if err != nil {
return err
}
metadata := common.ProcessVouchers(holdings)
_ = metadata
// TODO: export subprefixdb and use that instead
// TODO: make sure subprefixdb is thread safe when using gdbm
store.Db.SetPrefix(DATATYPE_USERSUB)
k := append([]byte("vouchers"), []byte("sym")...)
err = store.Db.Put(ctx, k, []byte(metadata.Symbols))
if err != nil {
return err
}
k = append([]byte("vouchers"), []byte("bal")...)
err = store.Db.Put(ctx, k, []byte(metadata.Balances))
if err != nil {
return err
}
k = append([]byte("vouchers"), []byte("deci")...)
err = store.Db.Put(ctx, k, []byte(metadata.Decimals))
if err != nil {
return err
}
k = append([]byte("vouchers"), []byte("addr")...)
err = store.Db.Put(ctx, k, []byte(metadata.Addresses))
if err != nil {
return err
}
return nil
}
@@ -41,7 +77,7 @@ func updateTokenList(ctx context.Context, api remote.AccountServiceInterface, st
//
//}
func updateToken(ctx context.Context, store common.UserDataStore, identity lookup.Identity) error {
func updateToken(ctx context.Context, store *common.UserDataStore, identity lookup.Identity) error {
var api remote.AccountService
err := updateTokenList(ctx, &api, store, identity)
@@ -73,7 +109,7 @@ func updateToken(ctx context.Context, store common.UserDataStore, identity looku
return nil
}
func handleTokenTransfer(ctx context.Context, store common.UserDataStore, ev *eventTokenTransfer) error {
func handleTokenTransfer(ctx context.Context, store *common.UserDataStore, ev *eventTokenTransfer) error {
identity, err := lookup.IdentityFromAddress(ctx, store, ev.From)
if err != nil {
if !db.IsNotFound(err) {