main.go

package main

import (
	"fmt"
	"log"
	"net/http"
	"os"

	"github.com/daniel-burghardt/ethereum-parser/data"
	"github.com/daniel-burghardt/ethereum-parser/ethrpc"
	"github.com/daniel-burghardt/ethereum-parser/httphandler"
	"github.com/daniel-burghardt/ethereum-parser/observer"
)

const serverPort = 3000

func main() {
	// Get ENVs
	ethServerUrl := os.Getenv("ETH_SERVER_URL")
	if ethServerUrl == "" {
		ethServerUrl = "https://cloudflare-eth.com"
	}
	webhookUrl := os.Getenv("WEBHOOK_URL")

	// Setup dependencies
	repo := data.NewInMemoryStorage()
	handler := httphandler.Handler{
		Repo: repo,
	}
	rpcService := ethrpc.Service{
		Url: ethServerUrl,
	}
	observerService := observer.Service{
		RPC:        rpcService,
		Repo:       repo,
		WebhookUrl: webhookUrl,
	}

	go func() {
		err := observerService.Start()
		if err != nil {
			log.Fatalf("observer killed: %v", err)
		}
	}()

	log.Printf("Starting the server on port %d...", serverPort)
	http.HandleFunc("/", http.NotFound)
	http.HandleFunc("GET /current-block", handler.GetCurrentBlock)
	http.HandleFunc("POST /subscribe/{address}", handler.PostSubscribe)
	http.HandleFunc("GET /transactions/{address}", handler.GetTransactions)
	http.ListenAndServe(fmt.Sprintf("localhost:%d", serverPort), nil)
}