feat: implement standing order feature with creation, listing, and deletion commands

.gitignore

@@ -5,4 +5,6 @@ data/*
 LightningTipBot
 LightningTipBot.exe
 BitcoinDeepaBot
-test_pay_api.sh
+test_pay_api.sh
+
+.DS_Store

internal/lnbits/types.go

@@ -193,3 +193,15 @@ type SavingsPot struct {
 	UpdatedAt time.Time `json:"updated_at" gorm:"autoUpdateTime"`
 	User      *User     `gorm:"foreignKey:UserID;references:ID"`
 }
+
+type StandingOrder struct {
+	ID             string     `json:"id" gorm:"primaryKey"`
+	UserID         string     `json:"user_id" gorm:"index"`
+	PotName        string     `json:"pot_name"`
+	DayOfMonth     int        `json:"day_of_month"`
+	Amount         int64      `json:"amount"`
+	Active         bool       `json:"active" gorm:"default:true"`
+	LastExecutedAt *time.Time `json:"last_executed_at"`
+	CreatedAt      time.Time  `json:"created_at" gorm:"autoCreateTime"`
+	UpdatedAt      time.Time  `json:"updated_at" gorm:"autoUpdateTime"`
+}

internal/telegram/bot.go

@@ -126,6 +126,9 @@ func (bot *TipBot) Start() {
 	// register telegram handlers
 	bot.registerTelegramHandlers()
 
+	// start standing order scheduler
+	NewStandingOrderScheduler(bot).Start()
+
 	// download bot avatar once
 	bot.downloadMyProfilePicture()
 

internal/telegram/database.go

@@ -121,6 +121,10 @@ func AutoMigration() *Databases {
 	if err != nil {
 		panic(err)
 	}
+	err = orm.AutoMigrate(&lnbits.StandingOrder{})
+	if err != nil {
+		panic(err)
+	}
 
 	txLogger, err := gorm.Open(sqlite.Open(internal.Configuration.Database.TransactionsPath), &gorm.Config{DisableForeignKeyConstraintWhenMigrating: true, FullSaveAssociations: true})
 	if err != nil {

internal/telegram/handler.go

@@ -372,6 +372,22 @@ func (bot TipBot) getHandler() []InterceptionWrapper {
 				},
 			},
 		},
+		{
+			Endpoints: []interface{}{"/so"},
+			Handler:   bot.soHandler,
+			Interceptor: &Interceptor{
+				Before: []intercept.Func{
+					bot.requirePrivateChatInterceptor,
+					bot.localizerInterceptor,
+					bot.logMessageInterceptor,
+					bot.requireUserInterceptor,
+					bot.lockInterceptor,
+				},
+				OnDefer: []intercept.Func{
+					bot.unlockInterceptor,
+				},
+			},
+		},
 		{
 			Endpoints: []interface{}{"/send", &btnSendMenuEnter},
 			Handler:   bot.sendHandler,

internal/telegram/standing_order_scheduler.go

@@ -0,0 +1,127 @@
+package telegram
+
+import (
+	"fmt"
+	"time"
+
+	"github.com/LightningTipBot/LightningTipBot/internal/lnbits"
+	"github.com/LightningTipBot/LightningTipBot/internal/utils"
+	log "github.com/sirupsen/logrus"
+)
+
+// StandingOrderScheduler runs hourly and executes standing orders on the
+// configured day of month, clamping days 29–31 to the last day of short months.
+type StandingOrderScheduler struct {
+	bot           *TipBot
+	CheckInterval time.Duration
+}
+
+func NewStandingOrderScheduler(bot *TipBot) *StandingOrderScheduler {
+	return &StandingOrderScheduler{
+		bot:           bot,
+		CheckInterval: 1 * time.Hour,
+	}
+}
+
+func (s *StandingOrderScheduler) Start() {
+	go s.run()
+}
+
+func (s *StandingOrderScheduler) run() {
+	for {
+		s.processDueOrders()
+		time.Sleep(s.CheckInterval)
+	}
+}
+
+// effectiveDayForMonth returns the day the order should fire in the given month.
+// If the configured day exceeds the month's last day (e.g. day 31 in April),
+// it clamps to the last day so salary-day users are never skipped.
+func effectiveDayForMonth(configuredDay int, t time.Time) int {
+	// time.Date with day=0 of next month gives last day of current month
+	lastDay := time.Date(t.Year(), t.Month()+1, 0, 0, 0, 0, 0, t.Location()).Day()
+	if configuredDay > lastDay {
+		return lastDay
+	}
+	return configuredDay
+}
+
+// shouldExecuteToday returns true if the order has not already run today.
+// Protects against double-execution when the bot restarts mid-day.
+func shouldExecuteToday(order lnbits.StandingOrder, now time.Time) bool {
+	if order.LastExecutedAt == nil {
+		return true
+	}
+	last := *order.LastExecutedAt
+	return last.Year() != now.Year() || last.Month() != now.Month() || last.Day() != now.Day()
+}
+
+func (s *StandingOrderScheduler) processDueOrders() {
+	now := time.Now()
+	today := now.Day()
+
+	var orders []lnbits.StandingOrder
+	if err := s.bot.DB.Users.Where("active = true").Find(&orders).Error; err != nil {
+		log.Errorf("[StandingOrderScheduler] Failed to fetch orders: %v", err)
+		return
+	}
+
+	for _, order := range orders {
+		if effectiveDayForMonth(order.DayOfMonth, now) != today {
+			continue
+		}
+		if !shouldExecuteToday(order, now) {
+			continue
+		}
+
+		// Load the user
+		var user lnbits.User
+		if err := s.bot.DB.Users.Where("id = ?", order.UserID).First(&user).Error; err != nil {
+			log.Errorf("[StandingOrderScheduler] User not found for order %s: %v", order.ID, err)
+			continue
+		}
+
+		// Skip banned or wallet-less users silently
+		if user.Banned || user.Wallet == nil {
+			continue
+		}
+
+		if err := s.executeOrder(&order, &user); err != nil {
+			s.notifyFailure(&user, order, err)
+		} else {
+			s.notifySuccess(&user, order)
+		}
+	}
+}
+
+func (s *StandingOrderScheduler) executeOrder(order *lnbits.StandingOrder, user *lnbits.User) error {
+	if err := s.bot.TransferToPot(user, order.PotName, order.Amount); err != nil {
+		return err
+	}
+
+	now := time.Now()
+	order.LastExecutedAt = &now
+	if err := s.bot.DB.Users.Save(order).Error; err != nil {
+		log.Errorf("[StandingOrderScheduler] Failed to update LastExecutedAt for order %s: %v", order.ID, err)
+	}
+	return nil
+}
+
+func (s *StandingOrderScheduler) notifySuccess(user *lnbits.User, order lnbits.StandingOrder) {
+	log.Infof("[StandingOrderScheduler] Executed order %s for user %s: %s → pot '%s'",
+		order.ID, user.Name, utils.FormatSats(order.Amount), order.PotName)
+	msg := fmt.Sprintf(
+		"✅ *Standing Order Executed*\n\n📅 Day %d of month\n💰 *%s* transferred to pot *'%s'*",
+		order.DayOfMonth, utils.FormatSats(order.Amount), order.PotName,
+	)
+	s.bot.trySendMessage(user.Telegram, msg)
+}
+
+func (s *StandingOrderScheduler) notifyFailure(user *lnbits.User, order lnbits.StandingOrder, err error) {
+	log.Errorf("[StandingOrderScheduler] Failed to execute order %s for user %s: %v", order.ID, user.Name, err)
+	msg := fmt.Sprintf(
+		"⚠️ *Standing Order Failed*\n\n📅 Day %d of month\n💰 %s → pot *'%s'*\n\n🚫 Reason: %s",
+		order.DayOfMonth, utils.FormatSats(order.Amount), order.PotName, err.Error(),
+	)
+	s.bot.trySendMessage(user.Telegram, msg)
+}