Compare commits

...

7 Commits

Author SHA1 Message Date
alfred-mk
7fdc734c7f Merge branch 'master' into send-max-amount-hotfix
Some checks failed
release / docker (push) Has been cancelled
2026-03-03 12:14:06 +03:00
bf75d2cea4 Merge pull request 'shorten-menus' (#119) from shorten-menus into master
Reviewed-on: #119
2026-03-03 10:13:05 +01:00
alfred-mk
5b995c9d9c log the error for new user cases and return nil 2026-03-03 11:48:59 +03:00
alfred-mk
1a7d160ae6 return a normal transaction if the recipient isn't registered on the USSD 2026-03-03 10:01:50 +03:00
alfred-mk
2b4aefdbc9 include the active pool symbol in the balance response
Some checks failed
release / docker (push) Has been cancelled
2026-03-02 12:39:52 +03:00
alfred-mk
549f2d023b rename the menu nodes to shorten the content 2026-03-02 12:28:34 +03:00
7bf71cbfff Merge pull request 'allow-stables-direct-to-mpesa' (#118) from allow-stables-direct-to-mpesa into master
Reviewed-on: #118
2026-02-26 18:17:42 +01:00
8 changed files with 31 additions and 21 deletions

View File

@@ -13,8 +13,7 @@ import (
"gopkg.in/leonelquinteros/gotext.v1"
)
// CheckBalance retrieves the balance of the active voucher and sets
// the balance as the result content.
// CheckBalance retrieves the balance of the active voucher, alias and pool symbol
func (h *MenuHandlers) CheckBalance(ctx context.Context, sym string, input []byte) (resource.Result, error) {
var (
res resource.Result
@@ -38,7 +37,6 @@ func (h *MenuHandlers) CheckBalance(ctx context.Context, sym string, input []byt
return res, err
}
}
activeBal, err := store.ReadEntry(ctx, sessionId, storedb.DATA_ACTIVE_BAL)
if err != nil {
if !db.IsNotFound(err) {
@@ -47,6 +45,7 @@ func (h *MenuHandlers) CheckBalance(ctx context.Context, sym string, input []byt
}
}
// get the account alias
accAlias, err := store.ReadEntry(ctx, sessionId, storedb.DATA_ACCOUNT_ALIAS)
if err != nil {
if !db.IsNotFound(err) {
@@ -55,7 +54,13 @@ func (h *MenuHandlers) CheckBalance(ctx context.Context, sym string, input []byt
}
}
content, err = loadUserContent(ctx, string(activeSym), string(activeBal), string(accAlias))
// Resolve active pool
_, activePoolSymbol, err := h.resolveActivePoolDetails(ctx, sessionId)
if err != nil {
return res, err
}
content, err = loadUserContent(ctx, string(activeSym), string(activeBal), string(accAlias), string(activePoolSymbol))
if err != nil {
return res, err
}
@@ -65,7 +70,7 @@ func (h *MenuHandlers) CheckBalance(ctx context.Context, sym string, input []byt
}
// loadUserContent loads the main user content in the main menu: the alias, balance and active symbol associated with active voucher
func loadUserContent(ctx context.Context, activeSym, balance, alias string) (string, error) {
func loadUserContent(ctx context.Context, activeSym, balance, alias, activePoolSymbol string) (string, error) {
var content string
code := codeFromCtx(ctx)
@@ -82,9 +87,9 @@ func loadUserContent(ctx context.Context, activeSym, balance, alias string) (str
balStr := fmt.Sprintf("%s %s", formattedAmount, activeSym)
if alias != "" {
content = l.Get("%s\nBalance: %s\n", alias, balStr)
content = l.Get("%s\n%s\nPool: %s\n", alias, balStr, activePoolSymbol)
} else {
content = l.Get("Balance: %s\n", balStr)
content = l.Get("%s\nPool: %s\n", balStr, activePoolSymbol)
}
return content, nil
}

View File

@@ -242,7 +242,9 @@ func (h *MenuHandlers) determineAndSaveTransactionType(
// fetch data for use (to_voucher data)
recipientActiveSym, recipientActiveAddress, recipientActiveDecimal, err := h.getRecipientData(ctx, string(recipientPhoneNumber))
if err != nil {
return err
// missing key (case for new users)
logg.ErrorCtxf(ctx, "failed on getRecipientData", "error", err)
return nil
}
swapMetadata := &dataserviceapi.TokenHoldings{
TokenAddress: string(recipientActiveAddress),
@@ -373,13 +375,6 @@ func (h *MenuHandlers) MaxAmount(ctx context.Context, sym string, input []byte)
// Format the active balance amount to 2 decimal places
formattedBalance, _ := store.TruncateDecimalString(string(activeBal), 2)
// confirm the transaction type
swapToVoucher, err := store.ReadSwapToVoucher(ctx, h.userdataStore, sessionId)
if err != nil {
logg.ErrorCtxf(ctx, "failed on ReadSwapFromVoucher", "error", err)
return res, err
}
// Case for M-Pesa
// if the recipient is Mpesa (address), check if the sender's voucher is a stable coin
recipientAddress, err := userStore.ReadEntry(ctx, sessionId, storedb.DATA_RECIPIENT)
@@ -393,6 +388,16 @@ func (h *MenuHandlers) MaxAmount(ctx context.Context, sym string, input []byte)
return res, nil
}
// confirm the transaction type
swapToVoucher, err := store.ReadSwapToVoucher(ctx, h.userdataStore, sessionId)
if err != nil {
logg.ErrorCtxf(ctx, "failed on ReadSwapFromVoucher", "error", err)
// switch to normal transaction as the recipient isn't registered (pool or alias only on sarafu)
res.FlagReset = append(res.FlagReset, flag_swap_transaction)
res.Content = l.Get("Maximum amount: %s %s\nEnter amount:", formattedBalance, string(activeSym))
return res, nil
}
if string(swapToVoucher.TokenAddress) == string(activeAddress) {
// recipient has active token same as selected token → normal transaction
transactionType = []byte("normal")

View File

@@ -1 +1 @@
My Account
Account

View File

@@ -1 +1 @@
Akaunti yangu
Akaunti

View File

@@ -1 +1 @@
Select pool
Pool

View File

@@ -1 +1 @@
Chagua Bwawa
Bwawa

View File

@@ -1 +1 @@
My Vouchers
Vouchers

View File

@@ -1 +1 @@
Sarafu yangu
Sarafu