Development payments

backend/cmd/fix_rentables/main.go

@@ -4,6 +4,7 @@ import (
 	"flag"
 	"fmt"
 	"kubecloud/internal/core/models"
+	corepersistence "kubecloud/internal/core/persistence"
 	"kubecloud/internal/infrastructure/persistence"
 	"strings"
 
@@ -52,8 +53,9 @@ func main() {
 	defer substrateClient.Close()
 
 	// Get all user_nodes records
-	var allRecords []models.UserNodes
-	if err := db.GetDB().Order("created_at DESC, id DESC").Find(&allRecords).Error; err != nil {
+	contractsRepo := corepersistence.NewGormUserContractDataRepository(db)
+	allRecords, err := contractsRepo.ListAllReservedNodes()
+	if err != nil {
 		log.Error().Err(err).Msg("Failed to get user_nodes records")
 		return
 	}

backend/cmd/root.go

@@ -154,18 +154,28 @@ func addFlags() error {
 	}
 
 	// === Monitor Balance Interval In Hours ===
-	if err := bindIntFlag(rootCmd, "monitor_balance_interval_in_minutes", 1, "Number of minutes to monitor balance"); err != nil {
-		return fmt.Errorf("failed to bind monitor_balance_interval_in_minutes flag: %w", err)
+	if err := bindIntFlag(rootCmd, "settle_transfer_records_interval_in_minutes", 1, "Number of minutes to monitor balance"); err != nil {
+		return fmt.Errorf("failed to bind settle_transfer_records_interval_in_minutes flag: %w", err)
 	}
 
 	if err := bindIntFlag(rootCmd, "notify_admins_for_pending_records_in_hours", 1, "Number of hours to notify admins about pending records"); err != nil {
 		return fmt.Errorf("failed to bind notify_admins_for_pending_records_in_hours flag: %w", err)
 	}
 
+	// === Applied Discount ===
+	if err := bindStringFlag(rootCmd, "applied_discount", "", "Applied discount to fund users"); err != nil {
+		return fmt.Errorf("failed to bind applied_discount flag: %w", err)
+	}
+
+	if err := bindIntFlag(rootCmd, "minimum_tft_amount_in_wallet", 10, "Minimum TFT amount in wallet"); err != nil {
+		return fmt.Errorf("failed to bind minimum_tft_amount_in_wallet flag: %w", err)
+	}
+
 	// === Users Balance Check Interval In Hours ===
 	if err := bindIntFlag(rootCmd, "users_balance_check_interval_in_hours", 6, "Number of hours to check users balance"); err != nil {
 		return fmt.Errorf("failed to bind users_balance_check_interval_in_hours flag: %w", err)
 	}
+
 	if err := bindIntFlag(rootCmd, "check_user_debt_interval_in_hours", 48, "Number of upcoming hours to check user debt"); err != nil {
 		return fmt.Errorf("failed to bind check_user_debt_interval_in_hours flag: %w", err)
 	}

backend/config-example.json

@@ -49,7 +49,6 @@
   "debug": false,
   "disable_sentry": true,
   "dev_mode": false,
-  "monitor_balance_interval_in_minutes": 120,
   "notify_admins_for_pending_records_in_hours": 24,
   "cluster_health_check_interval_in_hours": 1,
 	"node_health_check"	: {
@@ -71,6 +70,9 @@
       "host": ""
     }
   },
+	"settle_transfer_records_interval_in_minutes": 5,
+  "applied_discount": "gold",
+	"minimum_tft_amount_in_wallet": 10,
   "telemetry": {
     "otlp_endpoint": "jaeger:4317"
   }