main.go

package main

import (
	"context"
	"fmt"
	"log"
	"os"
	"time"

	"github.com/beatlabs/patron"
	"github.com/beatlabs/patron/cache/redis"
	"github.com/beatlabs/patron/component/http"
	httpcache "github.com/beatlabs/patron/component/http/cache"
)

func init() {
	err := os.Setenv("PATRON_LOG_LEVEL", "debug")
	if err != nil {
		fmt.Printf("failed to set log level env var: %v", err)
		os.Exit(1)
	}
	err = os.Setenv("PATRON_JAEGER_SAMPLER_PARAM", "1.0")
	if err != nil {
		fmt.Printf("failed to set sampler env vars: %v", err)
		os.Exit(1)
	}
	err = os.Setenv("PATRON_HTTP_DEFAULT_PORT", "50007")
	if err != nil {
		fmt.Printf("failed to set default patron port env vars: %v", err)
		os.Exit(1)
	}
}

func main() {
	name := "http-cache"
	version := "1.0.0"

	service, err := patron.New(name, version, patron.TextLogger())
	if err != nil {
		fmt.Printf("failed to set up service: %v", err)
		os.Exit(1)
	}

	ctx := context.Background()

	cache, err := redis.New(ctx, redis.Options{})
	if err != nil {
		fmt.Printf("failed to set up redis cache: %v", err)
		os.Exit(1)
	}

	routesBuilder := http.NewRoutesBuilder().
		Append(http.NewGetRouteBuilder("/", handler).
			WithRouteCache(cache, httpcache.Age{
				// we wont allow to override the cache more than once per 15 seconds
				Min: 15 * time.Second,
				// by default we might send stale response for up to 1 minute
				Max: 60 * time.Second,
			}))

	sig := func() {
		fmt.Println("exit gracefully...")
		os.Exit(0)
	}

	err = service.
		WithRoutesBuilder(routesBuilder).
		WithSIGHUP(sig).
		Run(ctx)
	if err != nil {
		log.Fatalf("failed to create and run service %v", err)
	}
}

// handler gives the 7 minute interval of the current unix timestamp
// since the response will be the same for the next 7 minutes, it s a good use-case to apply caching
func handler(_ context.Context, _ *http.Request) (*http.Response, error) {
	now := time.Now()
	minutes := now.Unix() / 60
	minuteInterval := minutes / 7
	return http.NewResponse(fmt.Sprintf("current unix 7-minute interval is (%d) called at %v", minuteInterval, now.Unix())), nil
}