test_horizon_ingesting.go

package main

import (
	"encoding/json"
	"log"
	"net/http"
	"os"
	"time"
)

const timeout = 2 * time.Hour

type Root struct {
	HorizonSequence int32 `json:"history_latest_ledger"`
	CoreSequence    int32 `json:"core_latest_ledger"`
}

func main() {
	startTime := time.Now()

	for {
		time.Sleep(10 * time.Second)
		logLine("Waiting for Horizon to start ingesting")

		if time.Since(startTime) > timeout {
			logLine("Timeout")
			os.Exit(-1)
		}

		resp, err := http.Get("http://localhost:8000")
		if err != nil {
			logLine(err)
			continue
		}

		var root Root
		decoder := json.NewDecoder(resp.Body)
		err = decoder.Decode(&root)
		if err != nil {
			logLine(err)
			continue
		}

		if root.HorizonSequence > 0 {
			logLine("Horizon started ingesting!")
			os.Exit(0)
		}
	}
}

func logLine(text interface{}) {
	log.Println("\033[32;1m[test]\033[0m", text)
}