Function main

tools/testserver/main.go:67–241

()

}

func main() {
	db := postgres.NewDB(context.Background())
	rdb := redis.Client()
	cdb, err := couchdb.DefaultDatabase()
	if err != nil {
		log.Fatal(err)
	}
	_, err = objstore.Client()
	if err != nil {
		log.Fatal(err)
	}

	ap, err := failover.NewActivePassive("testserver", time.Second*10, rdb)
	if err != nil {
		log.Fatal(err)
	}
	go ap.Run(log.WithContext(context.Background())) // nolint: errcheck

	h := pacehttp.Router()
	servicehealthcheck.RegisterHealthCheckFunc("fail-50", func(ctx context.Context) (r servicehealthcheck.HealthCheckResult) {
		if time.Now().Unix()%2 == 0 {
			panic("boom")
		}
		r.Msg = "Foo"
		r.State = servicehealthcheck.Ok
		return
	})

	h.Handle("/pay/beta/test", simple.Router(new(TestService)))

	h.HandleFunc("/test", func(w http.ResponseWriter, r *http.Request) {
		ctx := r.Context()

		span := sentry.StartSpan(ctx, "TestHandler")
		defer span.Finish()

		ctx = span.Context()

		// do dummy database query
		var result struct {
			Calc int //nolint
		}
		res, err := db.NewSelect().Model(&result).ColumnExpr("? + ? AS Calc", 10, 10).Exec(ctx)
		if err != nil {
			log.Ctx(ctx).Debug().Err(err).Msg("Calc failed")
			return
		}

		count, err := res.RowsAffected()
		if err != nil {
			log.Ctx(ctx).Debug().Err(err).Msg("RowsAffected failed")
			return
		}

		log.Ctx(ctx).Debug().Int64("rows_affected", count).Msg("Calc done")

		// do dummy redis query
		crdb := redis.WithContext(ctx, rdb)