Merge pull request #324 from bitcoin-sv/refactor/metamorph-processor

Refactor/metamorph processor
bitcoin-sv · Mar 11, 2024 · c3f10b3 · c3f10b3
2 parents 14ea662 + 8b7fb62
commit c3f10b3
Show file tree

Hide file tree

Showing 9 changed files with 331 additions and 317 deletions.
diff --git a/cmd/metamorph.go b/cmd/metamorph.go
@@ -120,6 +120,13 @@ func StartMetamorph(logger *slog.Logger) (func(), error) {
 		metamorph.WithProcessStatusUpdatesInterval(processStatusUpdateInterval),
 	)
 
+	metamorphProcessor.StartLockTransactions()
+	time.Sleep(200 * time.Millisecond) // wait a short time so that process expired transactions will start shortly after lock transactions go routine
+
+	metamorphProcessor.StartProcessExpiredTransactions()
+	metamorphProcessor.StartProcessStatusUpdatesInStorage()
+	metamorphProcessor.StartProcessMinedCallbacks()
+
 	http.HandleFunc("/pstats", metamorphProcessor.HandleStats)
 
 	go func() {

diff --git a/metamorph/mocks/store_mock.go b/metamorph/mocks/store_mock.go