Merge pull request #4 from rarimo/feature/configurable-routing

Feature: configurable routing

config.yaml

@@ -8,6 +8,11 @@ db:
 listener:
   addr: :8000
 
+# Routing config is used for deploying several service instances under one domain to differentiate them
+# by configurable prefix. Note that prefix should be formatted as `/integrations/configured-service-prefix/`
+routing:
+  prefix: "/integrations/configured-service-prefix/"
+
 airdrop:
   amount: amount
   token_address: erc20_token_address
@@ -21,7 +26,7 @@ broadcaster:
 verifier:
   verification_key_path: "./verification_key.json"
   allowed_age: 18
-  allowed_citizenships: ["UKR"]
+  allowed_citizenships: [ "UKR" ]
   allowed_event_id: "event_id"
   allowed_query_selector: "query_selector"
   # at least one of these should be correct to pass:

internal/config/main.go

@@ -17,6 +17,7 @@ type Config struct {
 
 	airdrop  comfig.Once
 	verifier comfig.Once
+	routing  comfig.Once
 	getter   kv.Getter
 }
 

internal/config/routing.go

@@ -0,0 +1,29 @@
+package config
+
+import (
+	"gitlab.com/distributed_lab/figure/v3"
+	"gitlab.com/distributed_lab/kit/kv"
+	"gitlab.com/distributed_lab/logan/v3"
+	"gitlab.com/distributed_lab/logan/v3/errors"
+)
+
+const routingYamlKey = "routing"
+
+type Routing struct {
+	Prefix string `fig:"prefix,required"`
+}
+
+func (c *Config) NewRouting() Routing {
+	return c.routing.Do(func() interface{} {
+		var cfg Routing
+
+		err := figure.Out(&cfg).
+			From(kv.MustGetStringMap(c.getter, routingYamlKey)).
+			Please()
+		if err != nil {
+			panic(errors.Wrap(err, "failed to figure out config", logan.F{"key": routingYamlKey}))
+		}
+
+		return cfg
+	}).(Routing)
+}

internal/service/router.go

@@ -25,10 +25,12 @@ func Run(ctx context.Context, cfg *config.Config) {
 		),
 		handlers.DBCloneMiddleware(cfg.DB()),
 	)
-	r.Route("/integrations/evm-airdrop-svc/airdrops", func(r chi.Router) {
-		r.Post("/", handlers.CreateAirdrop)
-		r.Get("/{nullifier}", handlers.GetAirdrop)
-		r.Get("/params", handlers.GetAirdropParams)
+	r.Route(cfg.NewRouting().Prefix, func(r chi.Router) {
+		r.Route("/airdrops", func(r chi.Router) {
+			r.Post("/", handlers.CreateAirdrop)
+			r.Get("/{nullifier}", handlers.GetAirdrop)
+			r.Get("/params", handlers.GetAirdropParams)
+		})
 	})
 
 	cfg.Log().Info("Service started")