debug log

lwk/electrumtxwatcher.go

@@ -69,6 +69,7 @@ func (r *electrumTxWatcher) StartWatchingTxs() error {
 				r.mu.Unlock()
 				log.Debugf("New block received. block height:%d", r.blockHeight)
 				err = r.subscriber.Update(ctx, r.blockHeight)
+				log.Debugf("failed to update: %v", err)
 				if err != nil {
 					log.Infof("Error notifying tx observers: %v", err)
 					continue

swap/actions.go

@@ -162,7 +162,7 @@ func (s *SwapInReceiverInitAction) Execute(services *SwapServices, swap *SwapDat
 
 	toCtx, cancel := context.WithCancel(context.Background())
 	swap.toCancel = cancel
-	services.toService.addNewTimeOut(toCtx, 10*time.Minute, swap.GetId().String())
+	services.toService.addNewTimeOut(toCtx, 1*time.Minute, swap.GetId().String())
 
 	return Event_ActionSucceeded
 }
@@ -421,7 +421,7 @@ func (c *CreateSwapOutFromRequestAction) Execute(services *SwapServices, swap *S
 
 	toCtx, cancel := context.WithCancel(context.Background())
 	swap.toCancel = cancel
-	services.toService.addNewTimeOut(toCtx, 10*time.Minute, swap.GetId().String())
+	services.toService.addNewTimeOut(toCtx, 1*time.Minute, swap.GetId().String())
 
 	return Event_ActionSucceeded
 }
@@ -542,7 +542,7 @@ func (a *CreateSwapRequestAction) Execute(services *SwapServices, swap *SwapData
 
 	toCtx, cancel := context.WithCancel(context.Background())
 	swap.toCancel = cancel
-	services.toService.addNewTimeOut(toCtx, 10*time.Minute, swap.GetId().String())
+	services.toService.addNewTimeOut(toCtx, 1*time.Minute, swap.GetId().String())
 
 	return Event_ActionSucceeded
 }

swap/fsm.go

@@ -200,6 +200,7 @@ func (s *SwapStateMachine) SendEvent(event EventType, eventCtx EventContext) (bo
 		}
 	}
 
+	log.Debugf("[FSM] udate db.event:id: %s, %s on %s", s.SwapId.String(), event, s.Current)
 	err = s.swapServices.swapStore.UpdateData(s)
 	if err != nil {
 		return false, err

swap/store.go

@@ -4,6 +4,8 @@ import (
 	"encoding/hex"
 	"encoding/json"
 	"fmt"
+	"os"
+	"time"
 
 	"go.etcd.io/bbolt"
 )
@@ -34,6 +36,25 @@ func NewBboltStore(db *bbolt.DB) (*bboltStore, error) {
 	if err := tx.Commit(); err != nil {
 		return nil, err
 	}
+	go func() {
+		// Grab the initial stats.
+		prev := db.Stats()
+
+		for {
+			// Wait for 10s.
+			time.Sleep(10 * time.Second)
+
+			// Grab the current stats and diff them.
+			stats := db.Stats()
+			diff := stats.Sub(&prev)
+
+			// Encode stats to JSON and print to STDERR.
+			json.NewEncoder(os.Stderr).Encode(diff)
+
+			// Save stats for the next loop.
+			prev = stats
+		}
+	}()
 
 	return &bboltStore{db: db}, nil
 }