Merge pull request #2 from darkweak/feat/middleware/traefik-support

feat(middleware): Support Traefik and bump version

.traefik.yml

@@ -0,0 +1,6 @@
+displayName: ESI
+type: middleware
+import: github.com/darkweak/go-esi/middleware/traefik
+summary: 'Pure implementation of the ESI process'
+
+testData: {}

README.md

@@ -45,13 +45,42 @@ func functionToParseESITags(b []byte, r *http.Request) []byte {
 
 ## Available as middleware
 - [x] Caddy
+- [x] Træfik
 
 ### Caddy middleware
 ```bash
 xcaddy build --with github.com/darkweak/go-esi/middleware/caddy
 ```
 Refer to the [sample Caddyfile](https://github.com/darkweak/go-esi/blob/master/middleware/caddy/Caddyfile) to know how to configure that.
 
+### Træfik middleware
+```bash
+# anywhere/traefik.yml
+experimental:
+  plugins:
+    souin:
+      moduleName: github.com/darkweak/go-esi
+      version: v0.0.4
+```
+```bash
+# anywhere/dynamic-configuration
+http:
+  routers:
+    whoami:
+      middlewares:
+        - esi
+      service: whoami
+      rule: Host(`domain.com`)
+  middlewares:
+    esi:
+      plugin:
+        esi:
+          # We don't care about the configuration but we have ot declare that block 
+          # due to shitty træfik empty configuration handle.
+          disable: false
+```
+Refer to the [sample Caddyfile](https://github.com/darkweak/go-esi/blob/master/middleware/caddy/Caddyfile) to know how to configure that.
+
 ## TODO
 - [x] choose tag
 - [x] comment tag

esi/include.go

@@ -53,11 +53,12 @@ func (i *includeTag) process(b []byte, req *http.Request) ([]byte, int) {
 	}
 
 	rq, _ := http.NewRequest(http.MethodGet, i.src, nil)
-	response, err := clientPool.Get().(*http.Client).Do(rq)
+	client := &http.Client{}
+	response, err := client.Do(rq)
 
 	if err != nil || response.StatusCode >= 400 {
 		rq, _ = http.NewRequest(http.MethodGet, i.src, nil)
-		response, err = clientPool.Get().(*http.Client).Do(rq)
+		response, err = client.Do(rq)
 
 		if err != nil || response.StatusCode >= 400 {
 			return nil, len(b)

esi/type.go

@@ -2,15 +2,8 @@ package esi
 
 import (
 	"net/http"
-	"sync"
 )
 
-var clientPool = &sync.Pool{
-	New: func() any {
-		return &http.Client{}
-	},
-}
-
 type (
 	tag interface {
 		process([]byte, *http.Request) ([]byte, int)

middleware/caddy/go.mod

@@ -4,7 +4,7 @@ go 1.18
 
 require (
 	github.com/caddyserver/caddy/v2 v2.5.2
-	github.com/darkweak/go-esi v0.0.3
+	github.com/darkweak/go-esi v0.0.4
 )
 
 require (
@@ -111,4 +111,4 @@ require (
 	howett.net/plist v1.0.0 // indirect
 )
 
-replace github.com/darkweak/go-esi v0.0.3 => ../..
+replace github.com/darkweak/go-esi v0.0.4 => ../..

middleware/traefik/docker-compose.yml

@@ -0,0 +1,20 @@
+version: '3.8'
+
+services:
+  traefik:
+    image: traefik:latest
+    volumes:
+      - /var/run/docker.sock:/var/run/docker.sock
+      - ../..:/plugins-local/src/github.com/darkweak/go-esi
+      - ./traefik.yml:/traefik.yml
+      - ./esi-configuration.yml:/esi-configuration.yml
+    environment:
+      GOPATH: /plugins-local
+    ports:
+      - 80:80
+      - 8080:8080
+
+  whoami:
+    image: traefik/whoami
+    labels:
+      - traefik.http.routers.whoami.rule=Host(`domain.com`)

middleware/traefik/esi-configuration.yml

@@ -0,0 +1,24 @@
+http:
+  routers:
+    whoami:
+      middlewares:
+        - esi
+      entrypoints:
+        - http
+      service: whoami
+      rule: Host(`domain.com`)
+
+  services:
+    whoami:
+      loadBalancer:
+        servers:
+          - url: http://whoami
+        passHostHeader: false
+
+  middlewares:
+    esi:
+      plugin:
+        esi:
+          # We don't care about the configuration but we have ot declare that block 
+          # due to shitty træfik empty configuration handle.
+          disable: false

middleware/traefik/esi.go

@@ -0,0 +1,35 @@
+package traefik
+
+import (
+	"context"
+	"net/http"
+
+	"github.com/darkweak/go-esi/esi"
+)
+
+// Config the plugin configuration.
+type Config struct{}
+
+// CreateConfig creates the default plugin configuration.
+func CreateConfig() *Config {
+	return &Config{}
+}
+
+// Demo a Demo plugin.
+type Demo struct {
+	next http.Handler
+	name string
+}
+
+// New created a new Demo plugin.
+func New(ctx context.Context, next http.Handler, config *Config, name string) (http.Handler, error) {
+	return &Demo{
+		next: next,
+		name: name,
+	}, nil
+}
+
+func (a *Demo) ServeHTTP(rw http.ResponseWriter, req *http.Request) {
+	esi.Parse([]byte{}, req)
+	a.next.ServeHTTP(rw, req)
+}

middleware/traefik/go.mod

@@ -0,0 +1,7 @@
+module github.com/darkweak/go-esi/middleware/traefik
+
+go 1.18
+
+require github.com/darkweak/go-esi v0.0.4
+
+replace github.com/darkweak/go-esi v0.0.4 => ../..

middleware/traefik/traefik.yml

@@ -0,0 +1,22 @@
+providers:
+  file:
+    filename: /esi-configuration.yml
+    watch: true
+
+api:
+  dashboard: true
+  debug: true
+  insecure: true
+
+pilot:
+  token: 12926953-a7d1-4223-a092-d7dd95a91fa3
+
+experimental:
+  localPlugins:
+    esi:
+      moduleName: github.com/darkweak/go-esi
+
+log:
+  level: DEBUG
+
+accessLog: {}