Compare commits
38 Commits
v0.2.90
...
e97a13d1e8
| Author | SHA1 | Date | |
|---|---|---|---|
| e97a13d1e8 | |||
| e0d270a2eb | |||
| b829092503 | |||
| e16021ee49 | |||
| 69797a214f | |||
| 53e2d49e36 | |||
| f2ab6a94d5 | |||
| 1954182e1c | |||
| b5852a3e61 | |||
| 0456346b45 | |||
| e6b03fdd02 | |||
| 1018e24060 | |||
| ebef6e138d | |||
| 7bd8f754d8 | |||
| 43574a1d1c | |||
| f130eaedd7 | |||
| 8394feaec7 | |||
|
|
68e6e3ef55 | ||
|
|
feff40bf55 | ||
| eb1e8a9cb0 | |||
| 2c797164e0 | |||
| 7725e5dd65 | |||
| 07c0cd6f2e | |||
| d29bd0810b | |||
| b62c0e5a8c | |||
| a9eb0d0732 | |||
| 92b84685c9 | |||
| cd6e62e3bc | |||
| 7cf2d91fd8 | |||
| 936982731d | |||
| 33759c87db | |||
| 974f82e9be | |||
| d7dc75c18f | |||
| c62c63249c | |||
| 6c290eb66b | |||
| 31ce7fc48e | |||
| 99957861dc | |||
| 19d27b4ff6 |
@@ -3,7 +3,8 @@ package api
|
||||
import (
|
||||
"fmt"
|
||||
|
||||
def "git.pbiernat.io/egommerce/api-entities/http"
|
||||
"git.ego.freeddns.org/egommerce/api-entities/basket"
|
||||
basket "git.ego.freeddns.org/egommerce/api-entities/basket/dto"
|
||||
"github.com/go-redis/redis/v8"
|
||||
)
|
||||
|
||||
@@ -15,9 +16,9 @@ type BasketAPI struct {
|
||||
httpClient *HttpClient
|
||||
}
|
||||
|
||||
func (a *BasketAPI) GetBasket(basketID string) (*def.GetBasketResponse, error) {
|
||||
req := &def.GetBasketRequest{BasketID: basketID}
|
||||
res := new(def.GetBasketResponse)
|
||||
func (a *BasketAPI) GetBasket(basketID string) (*basket.GetBasketResponseDTO, error) {
|
||||
req := &basket.GetBasketRequestDTO{BasketID: basketID}
|
||||
res := new(basket.GetBasketResponse)
|
||||
if err := a.httpClient.SendGet("basket-svc", "/api/v1/basket", req, res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -25,9 +26,9 @@ func (a *BasketAPI) GetBasket(basketID string) (*def.GetBasketResponse, error) {
|
||||
return res, nil
|
||||
}
|
||||
|
||||
func (a *BasketAPI) GetBasketItems(basketID string) ([]*def.GetBasketItemsResponse, error) {
|
||||
func (a *BasketAPI) GetBasketItems(basketID string) ([]*basket.GetBasketItemsResponseDTO, error) {
|
||||
url := fmt.Sprintf("/api/v1/basket/%s/items", basketID)
|
||||
var res []*def.GetBasketItemsResponse
|
||||
var res []*basket.GetBasketItemsResponseDTO
|
||||
if err := a.httpClient.SendGet("basket-svc", url, nil, &res); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
@@ -1,223 +0,0 @@
|
||||
package consul
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"net/http"
|
||||
"strconv"
|
||||
"time"
|
||||
|
||||
"git.pbiernat.io/egommerce/go-api-pkg/config"
|
||||
consul "github.com/hashicorp/consul/api"
|
||||
"github.com/hashicorp/consul/connect"
|
||||
)
|
||||
|
||||
type Service struct {
|
||||
Name string
|
||||
Address string
|
||||
appID string
|
||||
domain string
|
||||
pathPrefix string
|
||||
port int
|
||||
ttl time.Duration
|
||||
client *consul.Client
|
||||
agent *consul.Agent
|
||||
connect *connect.Service
|
||||
kv *consul.KV
|
||||
|
||||
hcTicker *time.Ticker
|
||||
ttlTicker *time.Ticker
|
||||
}
|
||||
|
||||
var ErrServiceUnavailable = fmt.Errorf("Service is unavailable")
|
||||
|
||||
func NewService(servAddr, id, name, useDomainOverIp, addr, domain, pathPrefix string, appPort int) (*Service, error) {
|
||||
s := new(Service)
|
||||
s.Name = name
|
||||
s.Address = addr
|
||||
s.appID = id
|
||||
s.domain = domain
|
||||
s.pathPrefix = pathPrefix
|
||||
s.port = appPort
|
||||
s.ttl = time.Second * 10
|
||||
|
||||
if useDomainOverIp == "true" { // FIXME types...
|
||||
s.Address = domain
|
||||
}
|
||||
|
||||
client, err := consul.NewClient(newClientConfig(servAddr))
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
s.client = client
|
||||
s.agent = client.Agent()
|
||||
s.kv = client.KV()
|
||||
|
||||
return s, nil
|
||||
}
|
||||
|
||||
func newClientConfig(serverAddr string) *consul.Config {
|
||||
conf := consul.DefaultConfig()
|
||||
conf.Address = serverAddr
|
||||
|
||||
return conf
|
||||
}
|
||||
|
||||
func (s *Service) GetID() string {
|
||||
return fmt.Sprintf("%s:%s", s.Name, s.appID)
|
||||
}
|
||||
|
||||
func (s *Service) GetFullAddr() string {
|
||||
isTLS := s.port == 443
|
||||
proto := "http"
|
||||
if isTLS {
|
||||
proto = "https"
|
||||
}
|
||||
return fmt.Sprintf("%s://%s:%d/", proto, s.Address, s.port)
|
||||
}
|
||||
|
||||
func (s *Service) Register() error {
|
||||
def := &consul.AgentServiceRegistration{
|
||||
ID: s.GetID(),
|
||||
// Kind: consul.ServiceKindConnectProxy,
|
||||
Name: s.Name,
|
||||
Address: s.Address,
|
||||
Port: s.port,
|
||||
Tags: s.getTags(),
|
||||
// Connect: &consul.AgentServiceConnect{Native: true},
|
||||
// Proxy: &consul.AgentServiceConnectProxyConfig{
|
||||
// DestinationServiceName: s.Name,
|
||||
// },
|
||||
Check: &consul.AgentServiceCheck{
|
||||
TTL: s.ttl.String(),
|
||||
Status: "passing",
|
||||
DeregisterCriticalServiceAfter: "10s",
|
||||
},
|
||||
}
|
||||
|
||||
if err := s.agent.ServiceRegister(def); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
func (s *Service) Unregister() error {
|
||||
// s.ttlTicker.Stop()
|
||||
// s.hcTicker.Stop()
|
||||
|
||||
s.client.Catalog().Deregister(&consul.CatalogDeregistration{
|
||||
Address: s.Address,
|
||||
ServiceID: s.GetID(),
|
||||
}, nil)
|
||||
|
||||
return s.agent.ServiceDeregister(s.GetID())
|
||||
}
|
||||
|
||||
func (s *Service) RegisterHealthChecks() {
|
||||
go func() { // startup register
|
||||
t := time.NewTicker(time.Second)
|
||||
for range t.C {
|
||||
if ok, _ := s.healthCheck(); ok {
|
||||
t.Stop()
|
||||
}
|
||||
}
|
||||
}()
|
||||
|
||||
go func() { // TTL
|
||||
t := time.NewTicker(s.ttl)
|
||||
for range t.C {
|
||||
if _, err := s.healthCheck(); err != nil {
|
||||
// fmt.Printf("HealthCheck endpoint not available (%s)#: %v\n", s.GetFullAddr(), err)
|
||||
t.Stop()
|
||||
}
|
||||
}
|
||||
}()
|
||||
}
|
||||
|
||||
func (s *Service) Connect() (*connect.Service, error) {
|
||||
// l := hclog.New(&hclog.LoggerOptions{
|
||||
// Name: "consul-registry",
|
||||
// Level: hclog.Trace,
|
||||
// })
|
||||
svc, err := connect.NewService(s.Name, s.client)
|
||||
s.connect = svc
|
||||
cnf := svc.ServerTLSConfig()
|
||||
fmt.Printf("CONNECT SERVER:: %s CONFIG:: %v\n", s.Name, cnf)
|
||||
for k, c := range cnf.Certificates {
|
||||
fmt.Printf("CONNECT CERT %d: %v", k, c)
|
||||
}
|
||||
|
||||
return svc, err
|
||||
}
|
||||
|
||||
func (s *Service) KV() *consul.KV {
|
||||
return s.kv
|
||||
}
|
||||
|
||||
func (s *Service) healthCheck() (bool, error) {
|
||||
alive := func() bool {
|
||||
client := &http.Client{}
|
||||
healthUrl := fmt.Sprintf("%s%s?name=%s", s.GetFullAddr(), "health", s.Name)
|
||||
fmt.Printf("HealthCheck URL: %s%s?name=%s", s.GetFullAddr(), "health", s.Name)
|
||||
req, err := http.NewRequest(http.MethodGet, healthUrl, nil)
|
||||
if err != nil {
|
||||
return false
|
||||
}
|
||||
req.Header.Set("User-Agent", "service/internal")
|
||||
|
||||
resp, err := client.Do(req)
|
||||
if err != nil {
|
||||
return false
|
||||
}
|
||||
defer resp.Body.Close()
|
||||
|
||||
var body []byte
|
||||
resp.Body.Read(body)
|
||||
|
||||
return resp.StatusCode == http.StatusOK
|
||||
}()
|
||||
|
||||
if alive {
|
||||
if err := s.agent.PassTTL("service:"+s.GetID(), "OK"); err != nil {
|
||||
fmt.Printf("Failed to pass TTL: %v", err)
|
||||
return false, err
|
||||
}
|
||||
return true, nil
|
||||
}
|
||||
|
||||
if err := s.agent.FailTTL("service:"+s.GetID(), ErrServiceUnavailable.Error()); err != nil {
|
||||
return false, err
|
||||
}
|
||||
return false, ErrServiceUnavailable
|
||||
}
|
||||
|
||||
func (s *Service) getTags() []string {
|
||||
tags := []string{
|
||||
"traefik.enable=true",
|
||||
// "traefik.http.middlewares.auth_" + s.Name + ".forwardauth.trustForwardHeader=true",
|
||||
// "traefik.http.middlewares.auth_" + s.Name + ".forwardauth.authRequestHeaders=Cookie",
|
||||
// "traefik.http.middlewares.auth_" + s.Name + ".forwardauth.authResponseHeaders=Set-Cookie, Server",
|
||||
"traefik.http.middlewares.auth_" + s.Name + ".plugin.auth.handlerURL=" + config.GetEnv("AUTH_HANDLER_URL", "http://identity.service.ego.io/api/v1/traefik"),
|
||||
"traefik.http.middlewares.stripprefix_" + s.Name + ".stripprefix.prefixes=" + s.pathPrefix,
|
||||
"traefik.http.middlewares.requestid_" + s.Name + ".plugin.requestid.headerName=X-Request-ID",
|
||||
// "treafik.http.middlewares.retryif_" + s.Name + ".plugin.retryif.attempts=3",
|
||||
// "treafik.http.middlewares.retryif_" + s.Name + ".plugin.retryif.statusCode=503",
|
||||
"traefik.http.routers." + s.Name + ".rule=PathPrefix(`" + s.pathPrefix + "`)",
|
||||
// "traefik.http.routers." + s.Name + ".rule=Host(`" + s.domain + "`)",
|
||||
"traefik.http.routers." + s.Name + ".entryPoints=https",
|
||||
// "traefik.http.routers." + s.Name + ".tls=true",
|
||||
"traefik.http.routers." + s.Name + ".service=" + s.Name,
|
||||
// "traefik.http.routers." + s.Name + ".middlewares=auth_" + s.Name + ",stripprefix_" + s.Name,
|
||||
"traefik.http.routers." + s.Name + ".middlewares=auth_" + s.Name + ",stripprefix_" + s.Name + ",requestid_" + s.Name + "",
|
||||
"traefik.http.services." + s.Name + ".loadbalancer.server.scheme=http",
|
||||
"traefik.http.services." + s.Name + ".loadbalancer.server.port=" + strconv.Itoa(s.port),
|
||||
"traefik.http.services." + s.Name + ".loadbalancer.passhostheader=true",
|
||||
"traefik.http.services." + s.Name + ".loadbalancer.healthcheck.interval=1s",
|
||||
"traefik.http.services." + s.Name + ".loadbalancer.healthcheck.timeout=1s",
|
||||
"traefik.http.services." + s.Name + ".loadbalancer.healthcheck.path=/health",
|
||||
"traefik.tls.certificates.certfile=/certs/client.cert",
|
||||
"traefik.tls.certificates.keyfile=/certs/client.key",
|
||||
}
|
||||
|
||||
return tags
|
||||
}
|
||||
@@ -1,17 +0,0 @@
|
||||
package fluentd
|
||||
|
||||
import (
|
||||
"strconv"
|
||||
"strings"
|
||||
)
|
||||
|
||||
func ParseAddr(addr string) (string, int, error) {
|
||||
p := strings.Split(addr, ":")
|
||||
fHost := p[0]
|
||||
fPort, err := strconv.Atoi(p[1])
|
||||
if err != nil {
|
||||
return "", 0, err
|
||||
}
|
||||
|
||||
return fHost, fPort, nil
|
||||
}
|
||||
@@ -1,41 +0,0 @@
|
||||
package fluentd
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"log"
|
||||
|
||||
"github.com/fluent/fluent-logger-golang/fluent"
|
||||
)
|
||||
|
||||
type Logger struct {
|
||||
fluent *fluent.Fluent
|
||||
appName string
|
||||
}
|
||||
|
||||
func NewLogger(appName, fHost string, fPort int) (*Logger, error) {
|
||||
config := fluent.Config{
|
||||
FluentHost: fHost,
|
||||
FluentPort: fPort,
|
||||
// WriteTimeout: -1,
|
||||
}
|
||||
fluent, err := fluent.New(config)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &Logger{fluent, appName}, nil
|
||||
}
|
||||
|
||||
func (l *Logger) Log(format string, v ...any) {
|
||||
mapData := map[string]string{
|
||||
"message": fmt.Sprintf(format, v...),
|
||||
}
|
||||
err := l.fluent.Post(l.appName, mapData)
|
||||
if err != nil {
|
||||
log.Println("Error sending log: ", err)
|
||||
}
|
||||
}
|
||||
|
||||
func (l *Logger) Close() error {
|
||||
return l.fluent.Close()
|
||||
}
|
||||
6
go.mod
6
go.mod
@@ -1,9 +1,8 @@
|
||||
module git.pbiernat.io/egommerce/go-api-pkg
|
||||
module git.ego.freeddns.org/egommerce/go-api-pkg
|
||||
|
||||
go 1.18
|
||||
go 1.24
|
||||
|
||||
require (
|
||||
git.pbiernat.io/egommerce/api-entities v0.2.3
|
||||
github.com/fluent/fluent-logger-golang v1.9.0
|
||||
github.com/go-redis/redis/v8 v8.11.5
|
||||
github.com/hashicorp/consul v1.16.0
|
||||
@@ -12,6 +11,7 @@ require (
|
||||
)
|
||||
|
||||
require (
|
||||
git.ego.freeddns.org/egommerce/api-entities v0.3.0 // indirect
|
||||
github.com/DataDog/datadog-go v3.2.0+incompatible // indirect
|
||||
github.com/armon/go-metrics v0.4.1 // indirect
|
||||
github.com/armon/go-radix v1.0.0 // indirect
|
||||
|
||||
5
go.sum
5
go.sum
@@ -35,7 +35,10 @@ cloud.google.com/go/storage v1.6.0/go.mod h1:N7U0C8pVQ/+NIKOBQyamJIeKQKkZ+mxpohl
|
||||
cloud.google.com/go/storage v1.8.0/go.mod h1:Wv1Oy7z6Yz3DshWRJFhqM/UCfaWIRTdp0RXyy7KQOVs=
|
||||
cloud.google.com/go/storage v1.10.0/go.mod h1:FLPqc6j+Ki4BU591ie1oL6qBQGu2Bl/tZ9ullr3+Kg0=
|
||||
dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU=
|
||||
git.pbiernat.io/egommerce/api-entities v0.2.3/go.mod h1:INXAG5x4+i+vNwg1NpfPHiDW8nY1kn1K7pgLOtX+/I0=
|
||||
git.ego.freeddns.org/egommerce/api-entities v0.2.5 h1:A7KQNXLB3l0ck7/R6MzyU33H490feZOlEodnU6bC+DA=
|
||||
git.ego.freeddns.org/egommerce/api-entities v0.2.5/go.mod h1:xr9mW9DKq+oNO4cMqtqY3VCAVCn6iImw4MqNj51dTFc=
|
||||
git.ego.freeddns.org/egommerce/api-entities v0.3.0 h1:IhJNOfze8/D8Hgy8Mr9hoFEwrg45xeFSnVRUnUrC5xc=
|
||||
git.ego.freeddns.org/egommerce/api-entities v0.3.0/go.mod h1:IqynARw+06GOm4eZGZuepmbi7bUxWBnOB4jd5cI7jf8=
|
||||
github.com/Azure/azure-sdk-for-go v44.0.0+incompatible h1:e82Yv2HNpS0kuyeCrV29OPKvEiqfs2/uJHic3/3iKdg=
|
||||
github.com/Azure/go-autorest v14.2.0+incompatible h1:V5VMDjClD3GiElqLWO7mz2MxNAK/vTfRHdAubSIPRgs=
|
||||
github.com/Azure/go-autorest/autorest v0.11.18 h1:90Y4srNYrwOtAgVo3ndrQkTYn6kf1Eg/AjTFJ8Is2aM=
|
||||
|
||||
@@ -1,38 +0,0 @@
|
||||
package redis
|
||||
|
||||
// import (
|
||||
// "context"
|
||||
// "strconv"
|
||||
// "time"
|
||||
|
||||
// "github.com/go-redis/redis/v8"
|
||||
// )
|
||||
|
||||
// func NewCache(host string, port int, password string) *redis.Client {
|
||||
// redis := redis.NewClient(&redis.Options{
|
||||
// Addr: host + ":" + strconv.Itoa(port),
|
||||
// Password: password,
|
||||
// DB: 0,
|
||||
// })
|
||||
// defer redis.Close()
|
||||
|
||||
// return redis
|
||||
// }
|
||||
|
||||
// func Get(ctx context.Context, key string) (float64, error) {
|
||||
// // ctx := context.Background() // FIXME
|
||||
// price, err := s.cache.Get(ctx, key).Float64()
|
||||
// if err != nil {
|
||||
// s.log.Log("cache read error(key not exists): %#v", err)
|
||||
// return 0, err
|
||||
// }
|
||||
|
||||
// return price, nil
|
||||
// }
|
||||
|
||||
// func Set(ctx context.Context, key string, value any, exp time.Duration) error {
|
||||
// // ctx := context.Background() // FIXME
|
||||
// s.cache.Set(ctx, key, value, exp)
|
||||
|
||||
// return nil
|
||||
// }
|
||||
Reference in New Issue
Block a user