From 14bc11f4bd87574526b453339e4b079967216b83 Mon Sep 17 00:00:00 2001
From: lash <dev@holbrook.no>
Date: Sat, 2 Nov 2024 16:38:29 +0000
Subject: [PATCH] Add transaction getter

---
 common/db.go             |  2 +-
 common/vouchers.go       |  9 +++++++++
 remote/accountservice.go | 36 ++++++++++++++++++++++++++++++++++--
 3 files changed, 44 insertions(+), 3 deletions(-)

diff --git a/common/db.go b/common/db.go
index 58fd3a1..06d9607 100644
--- a/common/db.go
+++ b/common/db.go
@@ -30,7 +30,7 @@ const (
 	DATA_PUBLIC_KEY_REVERSE
 	DATA_ACTIVE_DECIMAL
 	DATA_ACTIVE_ADDRESS
-
+	DATA_TRANSACTIONS
 )
 
 func typToBytes(typ DataTyp) []byte {
diff --git a/common/vouchers.go b/common/vouchers.go
index 9ca6277..cd76060 100644
--- a/common/vouchers.go
+++ b/common/vouchers.go
@@ -37,6 +37,15 @@ func ProcessVouchers(holdings []dataserviceapi.TokenHoldings) VoucherMetadata {
 	return data
 }
 
+//func StoreVouchers(db storage.PrefixDb, data VoucherMetadata) {
+//		value, err := db.Put(ctx, []byte(key))
+//		if err != nil {
+//			return nil, fmt.Errorf("failed to get %s: %v", key, err)
+//		}
+//		data[key] = string(value)
+//	}
+//}
+
 // GetVoucherData retrieves and matches voucher data
 func GetVoucherData(ctx context.Context, db storage.PrefixDb, input string) (*dataserviceapi.TokenHoldings, error) {
 	keys := []string{"sym", "bal", "deci", "addr"}
diff --git a/remote/accountservice.go b/remote/accountservice.go
index bc6a448..d0d7e9b 100644
--- a/remote/accountservice.go
+++ b/remote/accountservice.go
@@ -22,6 +22,7 @@ type AccountServiceInterface interface {
 	CreateAccount(ctx context.Context) (*models.AccountResult, error)
 	TrackAccountStatus(ctx context.Context, publicKey string) (*models.TrackStatusResult, error)
 	FetchVouchers(ctx context.Context, publicKey string) ([]dataserviceapi.TokenHoldings, error)
+	FetchTransactions(ctx context.Context, publicKey string) ([]dataserviceapi.Last10TxResponse, error)
 }
 
 type AccountService struct {
@@ -100,13 +101,18 @@ func (as *AccountService) CreateAccount(ctx context.Context) (*models.AccountRes
 	return &r, nil
 }
 
-// FetchVouchers retrieves the token holdings for a given public key from the custodial holdings API endpoint
+// FetchVouchers retrieves the token holdings for a given public key from the data indexer API endpoint
 // Parameters:
 //   - publicKey: The public key associated with the account.
 func (as *AccountService) FetchVouchers(ctx context.Context, publicKey string) ([]dataserviceapi.TokenHoldings, error) {
 	var r []dataserviceapi.TokenHoldings
 
-	req, err := http.NewRequest("GET", config.VoucherHoldingsURL, nil)
+	ep, err := url.JoinPath(config.VoucherHoldingsURL, publicKey)
+	if err != nil {
+		return nil, err
+	}
+
+	req, err := http.NewRequest("GET", ep, nil)
 	if err != nil {
 		return nil, err
 	}
@@ -119,6 +125,32 @@ func (as *AccountService) FetchVouchers(ctx context.Context, publicKey string) (
 	return r, nil
 }
 
+
+// FetchTransactions retrieves the last 10 transactions for a given public key from the data indexer API endpoint
+// Parameters:
+//   - publicKey: The public key associated with the account.
+func (as *AccountService) FetchTransactions(ctx context.Context, publicKey string) ([]dataserviceapi.Last10TxResponse, error) {
+	var r []dataserviceapi.Last10TxResponse
+
+	ep, err := url.JoinPath(config.VoucherTransfersURL, publicKey)
+	if err != nil {
+		return nil, err
+	}
+
+	req, err := http.NewRequest("GET", ep, nil)
+	if err != nil {
+		return nil, err
+	}
+
+	_, err =  doDataRequest(ctx, req, r)
+	if err != nil {
+		return nil, err
+	}
+
+	return r, nil
+}
+
+
 func doRequest(ctx context.Context, req *http.Request, rcpt any) (*api.OKResponse, error) {
 	var okResponse  api.OKResponse
 	var errResponse api.ErrResponse