[SDK] Update tx/vtxo management in tx feed (#468)

* Update bg handler for tx feed

* Fix + debug logs

* Update store interface

* Drop Transaction.SpentBy

* Fixes

* Fixes

* Add log

* Fixes

* Fixes

* Fix

* Rename api

Author: altafan

pkg/client-sdk/ark_sdk.go

@@ -32,7 +32,7 @@ type ArkClient interface {
 	ListVtxos(ctx context.Context) (spendable, spent []client.Vtxo, err error)
 	Dump(ctx context.Context) (seed string, err error)
 	GetTransactionHistory(ctx context.Context) ([]types.Transaction, error)
-	GetTransactionEventChannel() chan types.TransactionEvent
+	GetTransactionChannel() chan types.Transaction
 	RedeemNotes(ctx context.Context, notes []string, opts ...Option) (string, error)
 	SetNostrNotificationRecipient(ctx context.Context, nostrRecipient string) error
 	SignTransaction(ctx context.Context, tx string) (string, error)

pkg/client-sdk/client.go

@@ -99,7 +99,7 @@ func (a *arkClient) Receive(ctx context.Context) (string, string, error) {
 	return offchainAddr.Address, boardingAddr.Address, nil
 }
 
-func (a *arkClient) GetTransactionEventChannel() chan types.TransactionEvent {
+func (a *arkClient) GetTransactionChannel() chan types.Transaction {
 	return a.store.TransactionStore().GetEventChannel()
 }
 
@@ -373,10 +373,6 @@ func getWalletStore(storeType, datadir string) (walletstore.WalletStore, error)
 	}
 }
 
-func getCreatedAtFromExpiry(vtxoTreeExpiry common.RelativeLocktime, expiry time.Time) time.Time {
-	return expiry.Add(-time.Duration(vtxoTreeExpiry.Seconds()) * time.Second)
-}
-
 func filterByOutpoints(vtxos []client.Vtxo, outpoints []client.Outpoint) []client.Vtxo {
 	filtered := make([]client.Vtxo, 0, len(vtxos))
 	for _, vtxo := range vtxos {

pkg/client-sdk/covenant_client.go

@@ -1827,7 +1827,7 @@ func vtxosToTxsCovenant(
 			},
 			Amount:    uint64(math.Abs(float64(amount))),
 			Type:      txType,
-			CreatedAt: getCreatedAtFromExpiry(vtxoTreeExpiry, v.ExpiresAt),
+			CreatedAt: v.CreatedAt,
 		})
 	}