WilliesSchematicsWorld/schematic-service-go/api/endpoints.go

package api

import (
	"log"
	"net/http"
	"time"

	"github.com/go-chi/chi"
	"github.com/go-chi/render"
	"github.com/willie68/schematic-service-go/dao"
)

// TenantHeader in this header thr right tenant should be inserted
const TenantHeader = "X-es-tenant"
const timeout = 1 * time.Minute

//APIKey the apikey of this service
var APIKey string

//SystemID the systemid of this service
var SystemID string

/*
ConfigDescription describres all metadata of a config
*/
type ConfigDescription struct {
	StoreID  string `json:"storeid"`
	TenantID string `json:"tenantID"`
	Size     int    `json:"size"`
}

/*
ConfigRoutes getting all routes for the config endpoint
*/
func ConfigRoutes() *chi.Mux {
	router := chi.NewRouter()
	router.Post("/", PostConfigEndpoint)
	router.Get("/", GetConfigEndpoint)
	router.Delete("/", DeleteConfigEndpoint)
	router.Get("/size", GetConfigSizeEndpoint)
	router.Delete("/dropall", DropAllEndpoint)
	return router
}

/*
GetConfigEndpoint getting if a store for a tenant is initialised
because of the automatic store creation, the value is more likely that data is stored for this tenant
*/
func GetConfigEndpoint(response http.ResponseWriter, req *http.Request) {
	tenant := getTenant(req)
	if tenant == "" {
		Msg(response, http.StatusBadRequest, "tenant not set")
		return
	}
	c := ConfigDescription{
		StoreID:  "myNewStore",
		TenantID: tenant,
		Size:     1234567,
	}
	render.JSON(response, req, c)
}

/*
PostConfigEndpoint create a new store for a tenant
because of the automatic store creation, this method will always return 201
*/
func PostConfigEndpoint(response http.ResponseWriter, req *http.Request) {
	tenant := getTenant(req)
	if tenant == "" {
		Msg(response, http.StatusBadRequest, "tenant not set")
		return
	}
	log.Printf("create store for tenant %s", tenant)
	render.Status(req, http.StatusCreated)
	render.JSON(response, req, tenant)
}

/*
DeleteConfigEndpoint deleting store for a tenant, this will automatically delete all data in the store
*/
func DeleteConfigEndpoint(response http.ResponseWriter, req *http.Request) {
	tenant := getTenant(req)
	if tenant == "" {
		Msg(response, http.StatusBadRequest, "tenant not set")
		return
	}
	render.JSON(response, req, tenant)
}

/*
GetConfigSizeEndpoint size of the store for a tenant
*/
func GetConfigSizeEndpoint(response http.ResponseWriter, req *http.Request) {
	tenant := getTenant(req)
	if tenant == "" {
		Msg(response, http.StatusBadRequest, "tenant not set")
		return
	}

	render.JSON(response, req, tenant)
}

/*
getTenant getting the tenant from the request
*/
func getTenant(req *http.Request) string {
	return req.Header.Get(TenantHeader)
}

//DropAllEndpoint dropping all data
func DropAllEndpoint(response http.ResponseWriter, req *http.Request) {
	dao.DropAll()
	render.JSON(response, req, "")
}