package horizon

import (
	"github.com/stellar/horizon/db"
	"github.com/stellar/horizon/txsub"
	"net/http"
	"time"
)

func initSubmissionSystem(app *App) {
	app.submitter = &txsub.System{
		Pending:   txsub.NewDefaultSubmissionList(),
		Submitter: txsub.NewDefaultSubmitter(http.DefaultClient, app.config.StellarCoreUrl),
		Results: &db.ResultProvider{
			Ctx:     app.ctx,
			Core:    app.coreDb,
			History: app.historyDb,
		},
		NetworkPassphrase: app.networkPassphrase,
	}

	//TODO: bundle this with the ledger close pump system
	go func() {
		for {
			<-time.After(1 * time.Second)
			app.submitter.Tick(app.ctx)
		}
	}()
}

func init() {
	appInit.Add("txsub", initSubmissionSystem, "app-context", "log", "history-db", "core-db")
}

package horizon

import (
	"github.com/stellar/horizon/db"
	"github.com/stellar/horizon/txsub"
	"net/http"
)

func initSubmissionSystem(app *App) {
	app.submitter = &txsub.System{
		Pending:   txsub.NewDefaultSubmissionList(),
		Submitter: txsub.NewDefaultSubmitter(http.DefaultClient, app.config.StellarCoreUrl),
		Results: &db.ResultProvider{
			Ctx:     app.ctx,
			Core:    app.coreDb,
			History: app.historyDb,
		},
		NetworkPassphrase: app.networkPassphrase,
	}
}

func init() {
	appInit.Add("txsub", initSubmissionSystem, "app-context", "log", "history-db", "core-db")
}

--- 
+++ 
@@ -4,6 +4,7 @@
 	"github.com/stellar/horizon/db"
 	"github.com/stellar/horizon/txsub"
 	"net/http"
+	"time"
 )
 
 func initSubmissionSystem(app *App) {
@@ -17,6 +18,14 @@
 		},
 		NetworkPassphrase: app.networkPassphrase,
 	}
+
+	//TODO: bundle this with the ledger close pump system
+	go func() {
+		for {
+			<-time.After(1 * time.Second)
+			app.submitter.Tick(app.ctx)
+		}
+	}()
 }
 
 func init() {
Add janky Ticker for txsub system
