improve cors

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
improve cors
2024-03-18 16:38:18 +03:00 · 2024-03-18 16:25:52 +03:00 · 2024-03-18 15:57:08 +03:00 · 2024-03-18 15:45:43 +03:00 · 2024-03-18 14:51:40 +03:00 · 2024-03-12 22:05:32 +03:00
27 changed files with 710 additions and 310 deletions
--- a/README.md
+++ b/README.md
@@ -9,8 +9,8 @@ to create a HTTP Server that could potentially be used for REST based API servic
 import (
 	"net/http"

-	"go.unistack.org/micro/v4/server"
-	httpServer "go.unistack.org/micro-server-http/v4"
+	"github.com/unistack-org/micro/v3/server"
+	httpServer "github.com/unistack-org/micro-server-http"
 )

 func main() {
@@ -37,9 +37,9 @@ Or as part of a service
 import (
 	"net/http"

-	"go.unistack.org/micro/v4"
-	"go.unistack.org/micro/v4/server"
-	httpServer "go.unistack.org/micro-server-http/v4"
+	"github.com/unistack-org/micro/v3"
+	"github.com/unistack-org/micro/v3/server"
+	httpServer "github.com/unistack-org/micro-server-http"
 )

 func main() {
--- a/go.mod
+++ b/go.mod
@@ -1,23 +1,21 @@
-module go.unistack.org/micro-server-http/v4
+module go.unistack.org/micro-server-http/v3

-go 1.19
+go 1.18

 require (
-	go.unistack.org/micro-codec-yaml/v4 v4.0.0
-	go.unistack.org/micro-proto/v4 v4.0.1
-	go.unistack.org/micro/v4 v4.0.17
-	go.unistack.org/protoc-gen-go-micro/v4 v4.0.13
+	go.unistack.org/micro-codec-yaml/v3 v3.10.0
+	go.unistack.org/micro-proto/v3 v3.3.1
+	go.unistack.org/micro/v3 v3.10.52
 	golang.org/x/net v0.22.0
 )

 require (
-	github.com/fatih/structtag v1.2.0 // indirect
 	github.com/golang/protobuf v1.5.4 // indirect
 	github.com/google/gnostic v0.7.0 // indirect
 	github.com/google/gnostic-models v0.6.9-0.20230804172637-c7be7c783f49 // indirect
-	golang.org/x/mod v0.16.0 // indirect
 	golang.org/x/sys v0.18.0 // indirect
-	golang.org/x/tools v0.19.0 // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20240314234333-6e1732d8331c // indirect
+	google.golang.org/grpc v1.62.1 // indirect
 	google.golang.org/protobuf v1.33.0 // indirect
 	gopkg.in/yaml.v2 v2.4.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
--- a/go.sum
+++ b/go.sum
@@ -651,8 +651,6 @@ github.com/envoyproxy/go-control-plane v0.10.3/go.mod h1:fJJn/j26vwOu972OllsvAgJ
 github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c=
 github.com/envoyproxy/protoc-gen-validate v0.6.7/go.mod h1:dyJXwwfPK2VSqiB9Klm1J6romD608Ba7Hij42vrOBCo=
 github.com/envoyproxy/protoc-gen-validate v0.9.1/go.mod h1:OKNgG7TCp5pF4d6XftA0++PMirau2/yoOwVac3AbF2w=
-github.com/fatih/structtag v1.2.0 h1:/OdNE99OxoI/PqaW/SuSK9uxxT3f/tcSZgon/ssNSx4=
-github.com/fatih/structtag v1.2.0/go.mod h1:mBJUNpUnHmRKrKlQQlmCrh5PuhftFbNv8Ys4/aAZl94=
 github.com/flowstack/go-jsonschema v0.1.1/go.mod h1:yL7fNggx1o8rm9RlgXv7hTBWxdBM0rVwpMwimd3F3N0=
 github.com/fogleman/gg v1.2.1-0.20190220221249-0403632d5b90/go.mod h1:R/bRT+9gY/C5z7JzPU0zXsXHKM4/ayA+zqcVNZzPa1k=
 github.com/fogleman/gg v1.3.0/go.mod h1:R/bRT+9gY/C5z7JzPU0zXsXHKM4/ayA+zqcVNZzPa1k=
@@ -727,11 +725,11 @@ github.com/google/go-cmp v0.5.1/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/
 github.com/google/go-cmp v0.5.2/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/google/go-cmp v0.5.3/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/google/go-cmp v0.5.4/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
-github.com/google/go-cmp v0.5.5 h1:Khx7svrCpmxxtHBq5j2mp/xVjsi8hQMfNLvJFAlrGgU=
 github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/google/go-cmp v0.5.6/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/google/go-cmp v0.5.7/go.mod h1:n+brtR0CgQNWTVd5ZUFpTBC8YFBDLK/h/bpaJ8/DtOE=
 github.com/google/go-cmp v0.5.8/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
+github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38=
 github.com/google/go-cmp v0.5.9/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
 github.com/google/martian v2.1.0+incompatible/go.mod h1:9I4somxYTbIHy5NJKHRl3wXiIaQGbYVAs8BPL6v8lEs=
 github.com/google/martian/v3 v3.0.0/go.mod h1:y5Zk1BBys9G+gd6Jrk0W3cC1+ELVxBWuIGO+w/tUAp0=
@@ -782,6 +780,7 @@ github.com/hashicorp/golang-lru v0.5.1/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ
 github.com/iancoleman/strcase v0.2.0/go.mod h1:iwCmte+B7n89clKwxIoIXy/HfoL7AsD47ZCWhYzw7ho=
 github.com/ianlancetaylor/demangle v0.0.0-20181102032728-5e5cf60278f6/go.mod h1:aSSvb/t6k1mPoxDqO4vJh6VOCGPwU4O0C2/Eqndh1Sc=
 github.com/ianlancetaylor/demangle v0.0.0-20200824232613-28f6c0f3b639/go.mod h1:aSSvb/t6k1mPoxDqO4vJh6VOCGPwU4O0C2/Eqndh1Sc=
+github.com/imdario/mergo v0.3.13/go.mod h1:4lJ1jqUDcsbIECGy0RUJAXNIhg+6ocWgb1ALK2O4oXg=
 github.com/jstemmer/go-junit-report v0.0.0-20190106144839-af01ea7f8024/go.mod h1:6v2b51hI/fHJwM22ozAgKL4VKDeJcHhJFhtBdhmNjmU=
 github.com/jstemmer/go-junit-report v0.9.1/go.mod h1:Brl9GWCQeLvo8nXZwPNNblvFj/XSXhF0NWZEnDohbsk=
 github.com/jung-kurt/gofpdf v1.0.0/go.mod h1:7Id9E/uU8ce6rXgefFLlgrJj/GYY22cpxn+r32jIOes=
@@ -808,6 +807,7 @@ github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/
 github.com/mattn/go-sqlite3 v1.14.14/go.mod h1:NyWgC/yNuGj7Q9rpYnZvas74GogHl5/Z4A/KQRfk6bU=
 github.com/minio/asm2plan9s v0.0.0-20200509001527-cdd76441f9d8/go.mod h1:mC1jAcsrzbxHt8iiaC+zU4b1ylILSosueou12R++wfY=
 github.com/minio/c2goasm v0.0.0-20190812172519-36a3d3bbc4f3/go.mod h1:RagcQ7I8IeTMnF8JTXieKnO4Z6JCsikNEzj0DwauVzE=
+github.com/patrickmn/go-cache v2.1.0+incompatible/go.mod h1:3Qf8kWWT7OJRJbdiICTKqZju1ZixQ/KpMGzzAfe6+WQ=
 github.com/phpdave11/gofpdf v1.4.2/go.mod h1:zpO6xFn9yxo3YLyMvW8HcKWVdbNqgIfOOp2dXMnm1mY=
 github.com/phpdave11/gofpdi v1.0.12/go.mod h1:vBmVV0Do6hSBHC8uKUQ71JGW+ZGQq74llk/7bXwjDoI=
 github.com/phpdave11/gofpdi v1.0.13/go.mod h1:vBmVV0Do6hSBHC8uKUQ71JGW+ZGQq74llk/7bXwjDoI=
@@ -827,6 +827,7 @@ github.com/rogpeppe/go-internal v1.6.1/go.mod h1:xXDCJY+GAPziupqXw64V24skbSoqbTE
 github.com/rogpeppe/go-internal v1.9.0/go.mod h1:WtVeX8xhTBvf0smdhujwtBcq4Qrzq/fJaraNFVN+nFs=
 github.com/ruudk/golang-pdf417 v0.0.0-20181029194003-1af4ab5afa58/go.mod h1:6lfFZQK844Gfx8o5WFuvpxWRwnSoipWe/p622j1v06w=
 github.com/ruudk/golang-pdf417 v0.0.0-20201230142125-a7e3863a1245/go.mod h1:pQAZKsJ8yyVxGRWYNEm9oFB8ieLgKFnamEyDmSA0BRk=
+github.com/silas/dag v0.0.0-20211117232152-9d50aa809f35/go.mod h1:7RTUFBdIRC9nZ7/3RyRNH1bdqIShrDejd1YbLwgPS+I=
 github.com/spaolacci/murmur3 v0.0.0-20180118202830-f09979ecbc72/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=
 github.com/spf13/afero v1.3.3/go.mod h1:5KUK8ByomD5Ti5Artl0RtHeI5pTF7MIDuXL3yY520V4=
 github.com/spf13/afero v1.6.0/go.mod h1:Ai8FlHk4v/PARR026UzYexafAt9roJ7LcLMAmO6Z93I=
@@ -866,16 +867,15 @@ go.opencensus.io v0.23.0/go.mod h1:XItmlyltB5F7CS4xOC1DcqMoFqwtC6OG2xF7mCv7P7E=
 go.opencensus.io v0.24.0/go.mod h1:vNK8G9p7aAivkbmorf4v+7Hgx+Zs0yY+0fOtgBfjQKo=
 go.opentelemetry.io/proto/otlp v0.7.0/go.mod h1:PqfVotwruBrMGOCsRd/89rSnXhoiJIqeYNgFYFoEGnI=
 go.opentelemetry.io/proto/otlp v0.15.0/go.mod h1:H7XAot3MsfNsj7EXtrA2q5xSNQ10UqI405h3+duxN4U=
-go.unistack.org/micro-codec-yaml/v4 v4.0.0 h1:DK/+fA69gmnvYmGHe3kqVR0pukS8ank5lPG4MfdPQEk=
-go.unistack.org/micro-codec-yaml/v4 v4.0.0/go.mod h1:UG4ouILbUfgNL7nvp7CpmD2IIzO8bQHjzDIahOvIAgM=
-go.unistack.org/micro-proto/v4 v4.0.1 h1:2RKHgtCOOcAFgKsnngGK5bqM/6MWXOjVCdw03dbuoF8=
-go.unistack.org/micro-proto/v4 v4.0.1/go.mod h1:ArmK7o+uFvxSY3dbJhKBBX4Pm1rhWdLEFf3LxBrMtec=
-go.unistack.org/micro/v4 v4.0.17 h1:mF7uM+J4ILdG+1fcwzKYCwDlxhdbF/e1WnGzKKLnIXc=
-go.unistack.org/micro/v4 v4.0.17/go.mod h1:ZDgU9931vm2l7X6RN/6UuwRIVp24GRdmQ7dKmegArk4=
-go.unistack.org/protoc-gen-go-micro/v4 v4.0.7 h1:c3CeBvjWV9MBrGGPaQCcHZrnuLY9sVJHv7vACI/dvuM=
-go.unistack.org/protoc-gen-go-micro/v4 v4.0.7/go.mod h1:9bsKAlESlPXPBSmY/NDLL//smZbhnEMrnWyG+M8zVFA=
-go.unistack.org/protoc-gen-go-micro/v4 v4.0.13 h1:7iqOK75ErgGJK6c7SjL7rDy9DBv2IjSFw2OZx5waUo8=
-go.unistack.org/protoc-gen-go-micro/v4 v4.0.13/go.mod h1:9bsKAlESlPXPBSmY/NDLL//smZbhnEMrnWyG+M8zVFA=
+go.unistack.org/micro-codec-yaml/v3 v3.10.0 h1:cnNiWQZ3F+jsCX9DhEHBdIw8CjBItxb+TrKGGdlQ8F8=
+go.unistack.org/micro-codec-yaml/v3 v3.10.0/go.mod h1:UzwC3QZZ6+PgKSudlGZNLkugXzOFkp3sxhs/CctEwBY=
+go.unistack.org/micro-proto/v3 v3.3.1 h1:nQ0MtWvP2G3QrpOgawVOPhpZZYkq6umTGDqs8FxJYIo=
+go.unistack.org/micro-proto/v3 v3.3.1/go.mod h1:cwRyv8uInM2I7EbU7O8Fx2Ls3N90Uw9UCCcq4olOdfE=
+go.unistack.org/micro/v3 v3.10.14/go.mod h1:uMAc0U/x7dmtICCrblGf0ZLgYegu3VwQAquu+OFCw1Q=
+go.unistack.org/micro/v3 v3.10.42 h1:A0nA6WT6wNq5fyQyzliX70Bj5/SGj5kadLSOySX4hro=
+go.unistack.org/micro/v3 v3.10.42/go.mod h1:CSmEf5ddmft94MyKHnUSMM0W5dpmmTVbgImbgQWV5Ak=
+go.unistack.org/micro/v3 v3.10.52 h1:6LlAvLLlf+3JLCEQEVNQWi7DXCoI1ocuOqqoEPj5S+k=
+go.unistack.org/micro/v3 v3.10.52/go.mod h1:erMgt3Bl7vQQ0e9UpQyR5NlLiZ9pKeEJ9+1tfYFaqUg=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
 golang.org/x/crypto v0.0.0-20190510104115-cbcb75029529/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
 golang.org/x/crypto v0.0.0-20190605123033-f99c8df09eb5/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
@@ -941,10 +941,6 @@ golang.org/x/mod v0.5.1/go.mod h1:5OXOZSfqPIIbmVBIIKWRFfZjPR0E5r58TLhUjH0a2Ro=
 golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4=
 golang.org/x/mod v0.7.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs=
 golang.org/x/mod v0.8.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs=
-golang.org/x/mod v0.12.0 h1:rmsUpXtvNzj340zd98LZ4KntptpfRHwpFOHG188oHXc=
-golang.org/x/mod v0.12.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs=
-golang.org/x/mod v0.16.0 h1:QX4fJ0Rr5cPQCF7O9lh9Se4pmwfwskqZfq5moyldzic=
-golang.org/x/mod v0.16.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c=
 golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
 golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
 golang.org/x/net v0.0.0-20190108225652-1e06a53dbb7e/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
@@ -1001,8 +997,8 @@ golang.org/x/net v0.5.0/go.mod h1:DivGGAXEgPSlEBzxGzZI+ZLohi+xUj054jfeKui00ws=
 golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs=
 golang.org/x/net v0.7.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs=
 golang.org/x/net v0.8.0/go.mod h1:QVkue5JL9kW//ek3r6jTKnTFis1tRmNAW2P1shuFdJc=
-golang.org/x/net v0.15.0 h1:ugBLEUaxABaB5AJqW9enI0ACdci2RUd4eP51NTBvuJ8=
-golang.org/x/net v0.15.0/go.mod h1:idbUs1IY1+zTqbi8yxTbhexhEEk5ur9LInksu6HrEpk=
+golang.org/x/net v0.14.0 h1:BONx9s002vGdD9umnlX1Po8vOZmrgH34qlHcD1MfK14=
+golang.org/x/net v0.14.0/go.mod h1:PpSgVXXLK0OxS0F31C1/tv6XNguvCrnXIDrFMspZIUI=
 golang.org/x/net v0.22.0 h1:9sGLhx7iRIHEiX0oAJ3MRZMUCElJgy7Br1nO+AMN3Tc=
 golang.org/x/net v0.22.0/go.mod h1:JKghWKKOSdJwpW2GEx0Ja7fmaKnMsbu+MWVZTokSYmg=
 golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
@@ -1049,7 +1045,6 @@ golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJ
 golang.org/x/sync v0.0.0-20220819030929-7fc1605a5dde/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20220929204114-8fcdb60fdcc0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.3.0 h1:ftCYgMx6zT/asHUrPw8BLLscYtGznsLAnjq5RH9P66E=
 golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20190312061237-fead79001313/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -1125,8 +1120,7 @@ golang.org/x/sys v0.2.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.4.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.12.0 h1:CM0HF96J0hcLAwsHPJZjfdNzs0gftsLfgKt57wWHJ0o=
-golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.11.0 h1:eG7RXZHdqOJ1i+0lgLgCpSXAp6M3LYlAo6osgSi0xOM=
 golang.org/x/sys v0.18.0 h1:DBdB3niSjOA/O0blCZBqDefyWNYveAYMNF1Wum0DYQ4=
 golang.org/x/sys v0.18.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
@@ -1150,6 +1144,7 @@ golang.org/x/text v0.5.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
 golang.org/x/text v0.6.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
 golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
 golang.org/x/text v0.8.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8=
+golang.org/x/text v0.12.0 h1:k+n5B8goJNdU7hSvEtMUz3d1Q6D/XW4COJSJR6fN0mc=
 golang.org/x/time v0.0.0-20181108054448-85acf8d2951c/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
 golang.org/x/time v0.0.0-20190308202827-9d24e82272b4/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
 golang.org/x/time v0.0.0-20191024005414-555d28b269f0/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
@@ -1216,14 +1211,9 @@ golang.org/x/tools v0.1.9/go.mod h1:nABZi5QlRsZVlzPpHl034qft6wpY4eDcsTt5AaioBiU=
 golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc=
 golang.org/x/tools v0.3.0/go.mod h1:/rWhSS2+zyEVwoJf8YAX6L2f0ntZ7Kn/mGgAWcipA5k=
 golang.org/x/tools v0.6.0/go.mod h1:Xwgl3UAJ/d3gWutnCtw505GrjyAbvKui8lOU390QaIU=
-golang.org/x/tools v0.11.0 h1:EMCa6U9S2LtZXLAMoWiR/R8dAQFRqbAitmbJ2UKhoi8=
-golang.org/x/tools v0.11.0/go.mod h1:anzJrxPjNtfgiYQYirP2CPGzGLxrH2u2QBhn6Bf3qY8=
-golang.org/x/tools v0.19.0 h1:tfGCXNR1OsFG+sVdLAitlpjAvD/I6dHDKnYrpEZUHkw=
-golang.org/x/tools v0.19.0/go.mod h1:qoJWxmGSIBmAeriMx19ogtrEPrGtDbPK634QFIcLAhc=
 golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 h1:go1bK/D/BFZV2I8cIQd1NKEZ+0owSTG1fDTci4IqFcE=
 golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20220411194840-2f41105eb62f/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20220517211312-f3a8303e98df/go.mod h1:K8+ghG5WaK9qNqU5K3HdILfMLy1f3aNYFI/wnl100a8=
@@ -1439,6 +1429,10 @@ google.golang.org/genproto/googleapis/api v0.0.0-20230525234020-1aefcd67740a/go.
 google.golang.org/genproto/googleapis/api v0.0.0-20230525234035-dd9d682886f9/go.mod h1:vHYtlOoi6TsQ3Uk2yxR7NI5z8uoV+3pZtR4jmHIkRig=
 google.golang.org/genproto/googleapis/rpc v0.0.0-20230525234015-3fc162c6f38a/go.mod h1:xURIpW9ES5+/GZhnV6beoEtxQrnkRGIfP5VQG2tCBLc=
 google.golang.org/genproto/googleapis/rpc v0.0.0-20230525234030-28d5490b6b19/go.mod h1:66JfowdXAEgad5O9NnYcsNPLCPZJD++2L9X0PCMODrA=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20230526203410-71b5a4ffd15e h1:NumxXLPfHSndr3wBBdeKiVHjGVFzi9RX2HwwQke94iY=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20230526203410-71b5a4ffd15e/go.mod h1:66JfowdXAEgad5O9NnYcsNPLCPZJD++2L9X0PCMODrA=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20240314234333-6e1732d8331c h1:lfpJ/2rWPa/kJgxyyXM8PrNnfCzcmxJ265mADgwmvLI=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20240314234333-6e1732d8331c/go.mod h1:WtryC6hu0hhx87FDGxWCDptyssuo68sk10vYjF+T9fY=
 google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
 google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38=
 google.golang.org/grpc v1.21.1/go.mod h1:oYelfM1adQP15Ek0mdvEgi9Df8B9CZIaU1084ijfRaM=
@@ -1478,6 +1472,10 @@ google.golang.org/grpc v1.50.1/go.mod h1:ZgQEeidpAuNRZ8iRrlBKXZQP1ghovWIVhdJRyCD
 google.golang.org/grpc v1.51.0/go.mod h1:wgNDFcnuBGmxLKI/qn4T+m5BtEBYXJPvibbUPsAIPww=
 google.golang.org/grpc v1.53.0/go.mod h1:OnIrk0ipVdj4N5d9IUoFUx72/VlD7+jUsHwZgwSMQpw=
 google.golang.org/grpc v1.54.0/go.mod h1:PUSEXI6iWghWaB6lXM4knEgpJNu2qUcKfDtNci3EC2g=
+google.golang.org/grpc v1.57.0 h1:kfzNeI/klCGD2YPMUlaGNT3pxvYfga7smW3Vth8Zsiw=
+google.golang.org/grpc v1.57.0/go.mod h1:Sd+9RMTACXwmub0zcNY2c4arhtrbBYD1AUHI/dt16Mo=
+google.golang.org/grpc v1.62.1 h1:B4n+nfKzOICUXMgyrNd19h/I9oH0L1pizfk1d4zSgTk=
+google.golang.org/grpc v1.62.1/go.mod h1:IWTG0VlJLCh1SkC58F7np9ka9mx/WNkjl4PGJaiq+QE=
 google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.1.0/go.mod h1:6Kw0yEErY5E/yWrBtf03jp27GLLJujG4z/JK95pnjjw=
 google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8=
 google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0=
@@ -1513,6 +1511,7 @@ gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.0-20200615113413-eeeca48fe776/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gopkg.in/yaml.v3 v3.0.0/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
--- a/handler.go
+++ b/handler.go
@@ -9,20 +9,20 @@ import (
 	"strings"
 	"sync"

-	"go.unistack.org/micro/v4/errors"
-	"go.unistack.org/micro/v4/logger"
-	"go.unistack.org/micro/v4/metadata"
-	"go.unistack.org/micro/v4/register"
-	"go.unistack.org/micro/v4/server"
-	rhttp "go.unistack.org/micro/v4/util/http"
-	rflutil "go.unistack.org/micro/v4/util/reflect"
+	"go.unistack.org/micro/v3/errors"
+	"go.unistack.org/micro/v3/logger"
+	"go.unistack.org/micro/v3/metadata"
+	"go.unistack.org/micro/v3/register"
+	"go.unistack.org/micro/v3/server"
+	rhttp "go.unistack.org/micro/v3/util/http"
+	rflutil "go.unistack.org/micro/v3/util/reflect"
 )

 var (
-	DefaultErrorHandler = func(ctx context.Context, s interface{}, w http.ResponseWriter, r *http.Request, err error, status int) {
+	DefaultErrorHandler = func(ctx context.Context, s server.Handler, w http.ResponseWriter, r *http.Request, err error, status int) {
 		w.WriteHeader(status)
 		if _, cerr := w.Write([]byte(err.Error())); cerr != nil {
-			logger.DefaultLogger.Error(ctx, fmt.Sprintf("write failed: %v", cerr))
+			logger.DefaultLogger.Errorf(ctx, "write failed: %v", cerr)
 		}
 	}
 	DefaultContentType = "application/json"
@@ -35,7 +35,7 @@ type patHandler struct {
 }

 type httpHandler struct {
-	opts     server.HandleOptions
+	opts     server.HandlerOptions
 	hd       interface{}
 	handlers *rhttp.Trie
 	name     string
@@ -56,7 +56,7 @@ func (h *httpHandler) Endpoints() []*register.Endpoint {
 	return h.eps
 }

-func (h *httpHandler) Options() server.HandleOptions {
+func (h *httpHandler) Options() server.HandlerOptions {
 	return h.opts
 }

@@ -109,20 +109,20 @@ func (h *Server) HTTPHandlerFunc(handler interface{}) (http.HandlerFunc, error)
 			md = metadata.New(len(r.Header) + 8)
 		}
 		for k, v := range r.Header {
-			md[k] = v
+			md[k] = strings.Join(v, ", ")
 		}
-		md["RemoteAddr"] = []string{r.RemoteAddr}
-		md["Method"] = []string{r.Method}
-		md["URL"] = []string{r.URL.String()}
-		md["Proto"] = []string{r.Proto}
-		md["Content-Length"] = []string{fmt.Sprintf("%d", r.ContentLength)}
-		md["Transfer-Encoding"] = r.TransferEncoding
-		md["Host"] = []string{r.Host}
-		md["RequestURI"] = []string{r.RequestURI}
+		md["RemoteAddr"] = r.RemoteAddr
+		md["Method"] = r.Method
+		md["URL"] = r.URL.String()
+		md["Proto"] = r.Proto
+		md["Content-Length"] = fmt.Sprintf("%d", r.ContentLength)
+		md["Transfer-Encoding"] = strings.Join(r.TransferEncoding, ",")
+		md["Host"] = r.Host
+		md["RequestURI"] = r.RequestURI
 		if r.TLS != nil {
-			md["TLS"] = []string{"true"}
-			md["TLS-ALPN"] = []string{r.TLS.NegotiatedProtocol}
-			md["TLS-ServerName"] = []string{r.TLS.ServerName}
+			md["TLS"] = "true"
+			md["TLS-ALPN"] = r.TLS.NegotiatedProtocol
+			md["TLS-ServerName"] = r.TLS.ServerName
 		}

 		ctx = metadata.NewIncomingContext(ctx, md)
@@ -263,17 +263,18 @@ func (h *Server) HTTPHandlerFunc(handler interface{}) (http.HandlerFunc, error)
 			}
 			if nmd, ok := metadata.FromOutgoingContext(fctx); ok {
 				for k, v := range nmd {
-					md[k] = v
+					md.Set(k, v)
 				}
 			}
+			metadata.SetOutgoingContext(ctx, md)

 			return err
 		}

 		// wrap the handler func
-		// for i := len(handler.sopts.Hooks); i > 0; i-- {
-		//	fn = handler.sopts.Hooks[i-1](fn)
-		// }
+		for i := len(handler.sopts.HdlrWrappers); i > 0; i-- {
+			fn = handler.sopts.HdlrWrappers[i-1](fn)
+		}

 		if ct == "application/x-www-form-urlencoded" {
 			cf, err = h.newCodec(DefaultContentType)
@@ -290,12 +291,14 @@ func (h *Server) HTTPHandlerFunc(handler interface{}) (http.HandlerFunc, error)
 		w.Header().Set(metadata.HeaderContentType, ct)
 		if md, ok := metadata.FromOutgoingContext(ctx); ok {
 			for k, v := range md {
-				w.Header()[k] = v
+				w.Header().Set(k, v)
 			}
 		}
 		if md := getRspHeader(ctx); md != nil {
 			for k, v := range md {
-				w.Header()[k] = v
+				for _, vv := range v {
+					w.Header().Add(k, vv)
+				}
 			}
 		}
 		if nct := w.Header().Get(metadata.HeaderContentType); nct != ct {
@@ -321,7 +324,7 @@ func (h *Server) HTTPHandlerFunc(handler interface{}) (http.HandlerFunc, error)
 		}

 		if err != nil && handler.sopts.Logger.V(logger.ErrorLevel) {
-			handler.sopts.Logger.Error(handler.sopts.Context, fmt.Sprintf("handler err: %v", err))
+			handler.sopts.Logger.Errorf(handler.sopts.Context, "handler err: %v", err)
 			return
 		}

@@ -331,7 +334,7 @@ func (h *Server) HTTPHandlerFunc(handler interface{}) (http.HandlerFunc, error)
 		w.WriteHeader(scode)

 		if _, cerr := w.Write(buf); cerr != nil {
-			handler.sopts.Logger.Error(ctx, fmt.Sprintf("write failed: %v", cerr))
+			handler.sopts.Logger.Errorf(ctx, "write failed: %v", cerr)
 		}
 	}, nil
 }
@@ -349,23 +352,23 @@ func (h *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 		md = metadata.New(len(r.Header) + 8)
 	}
 	for k, v := range r.Header {
-		md[k] = v
+		md[k] = strings.Join(v, ", ")
 	}
-	md["RemoteAddr"] = []string{r.RemoteAddr}
+	md["RemoteAddr"] = r.RemoteAddr
 	if r.TLS != nil {
-		md["Scheme"] = []string{"https"}
+		md["Scheme"] = "https"
 	} else {
-		md["Scheme"] = []string{"http"}
+		md["Scheme"] = "http"
 	}
-	md["Method"] = []string{r.Method}
-	md["URL"] = []string{r.URL.String()}
-	md["Proto"] = []string{r.Proto}
-	md["Content-Length"] = []string{fmt.Sprintf("%d", r.ContentLength)}
+	md["Method"] = r.Method
+	md["URL"] = r.URL.String()
+	md["Proto"] = r.Proto
+	md["ContentLength"] = fmt.Sprintf("%d", r.ContentLength)
 	if len(r.TransferEncoding) > 0 {
-		md["Transfer-Encoding"] = r.TransferEncoding
+		md["TransferEncoding"] = strings.Join(r.TransferEncoding, ",")
 	}
-	md["Host"] = []string{r.Host}
-	md["RequestURI"] = []string{r.RequestURI}
+	md["Host"] = r.Host
+	md["RequestURI"] = r.RequestURI
 	ctx = metadata.NewIncomingContext(ctx, md)

 	path := r.URL.Path
@@ -419,7 +422,7 @@ func (h *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	}

 	if !match && h.hd != nil {
-		if hdlr, ok := h.hd.(http.Handler); ok {
+		if hdlr, ok := h.hd.Handler().(http.Handler); ok {
 			hdlr.ServeHTTP(w, r)
 			return
 		}
@@ -523,17 +526,18 @@ func (h *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 		}
 		if nmd, ok := metadata.FromOutgoingContext(fctx); ok {
 			for k, v := range nmd {
-				md[k] = v
+				md.Set(k, v)
 			}
 		}
+		metadata.SetOutgoingContext(ctx, md)

 		return err
 	}

 	// wrap the handler func
-	// for i := len(handler.sopts.HdlrWrappers); i > 0; i-- {
-	//	fn = handler.sopts.HdlrWrappers[i-1](fn)
-	// }
+	for i := len(handler.sopts.HdlrWrappers); i > 0; i-- {
+		fn = handler.sopts.HdlrWrappers[i-1](fn)
+	}

 	if ct == "application/x-www-form-urlencoded" {
 		cf, err = h.newCodec(DefaultContentType)
@@ -550,7 +554,7 @@ func (h *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	w.Header().Set(metadata.HeaderContentType, ct)
 	if md, ok := metadata.FromOutgoingContext(ctx); ok {
 		for k, v := range md {
-			w.Header()[k] = v
+			w.Header().Set(k, v)
 		}
 	}
 	if md := getRspHeader(ctx); md != nil {
@@ -583,7 +587,7 @@ func (h *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	}

 	if err != nil && handler.sopts.Logger.V(logger.ErrorLevel) {
-		handler.sopts.Logger.Error(handler.sopts.Context, fmt.Sprintf("handler err: %v", err))
+		handler.sopts.Logger.Errorf(handler.sopts.Context, "handler err: %v", err)
 		return
 	}

@@ -593,6 +597,6 @@ func (h *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	w.WriteHeader(scode)

 	if _, cerr := w.Write(buf); cerr != nil {
-		handler.sopts.Logger.Error(ctx, fmt.Sprintf("write failed: %v", cerr))
+		handler.sopts.Logger.Errorf(ctx, "write failed: %v", cerr)
 	}
 }
--- a/handler/generate.go
+++ b/handler/generate.go
@@ -2,11 +2,11 @@ package handler

 import (
 	// import required packages
-	_ "go.unistack.org/micro-proto/v4/openapiv3"
+	_ "go.unistack.org/micro-proto/v3/openapiv3"
 )

 //go:generate sh -c "curl -L https://github.com/swagger-api/swagger-ui/archive/refs/tags/v4.18.3.zip -o - | bsdtar -C swagger-ui --strip-components=2 -xv swagger-ui-4.18.3/dist && rm swagger-ui/*.map swagger-ui/*-es-*.js swagger-ui/swagger-ui.js swagger-ui/swagger-initializer.js"

-//go:generate sh -c "protoc -I./ -I$(go list -f '{{ .Dir }}' -m go.unistack.org/micro-proto/v4) --go-micro_out='components=micro|http|server',standalone=false,debug=true,paths=source_relative:./ ./meter/meter.proto"
+//go:generate sh -c "protoc -I./ -I$(go list -f '{{ .Dir }}' -m go.unistack.org/micro-proto/v3) --go-micro_out='components=micro|http|server',standalone=false,debug=true,paths=source_relative:./ ./meter/meter.proto"

-//go:generate sh -c "protoc -I./ -I$(go list -f '{{ .Dir }}' -m go.unistack.org/micro-proto/v4) --go-micro_out='components=micro|http|server',standalone=false,debug=true,paths=source_relative:./ ./health/health.proto"
+//go:generate sh -c "protoc -I./ -I$(go list -f '{{ .Dir }}' -m go.unistack.org/micro-proto/v3) --go-micro_out='components=micro|http|server',standalone=false,debug=true,paths=source_relative:./ ./health/health.proto"
--- a/handler/health/health.go
+++ b/handler/health/health.go
@@ -1,13 +1,13 @@
-package health // import "go.unistack.org/micro-server-http/v4/handler/health"
+package health // import "go.unistack.org/micro-server-http/v3/handler/health"

 import (
 	"context"

-	codecpb "go.unistack.org/micro-proto/v4/codec"
-	"go.unistack.org/micro/v4/errors"
+	codecpb "go.unistack.org/micro-proto/v3/codec"
+	"go.unistack.org/micro/v3/errors"
 )

-var _ HealthServiceServer = (*Handler)(nil)
+var _ HealthServiceServer = &Handler{}

 type Handler struct {
 	opts Options
--- a/handler/health/health.proto
+++ b/handler/health/health.proto
@@ -1,7 +1,7 @@
 syntax = "proto3";

-package micro.server.http.v4.handler.health;
-option go_package = "go.unistack.org/micro-server-http/v4/handler/health;health";
+package micro.server.http.v3.handler.health;
+option go_package = "go.unistack.org/micro-server-http/v3/handler/health;health";

 import "api/annotations.proto";
 import "openapiv3/annotations.proto";
--- a/handler/health/health_micro.pb.go
+++ b/handler/health/health_micro.pb.go
@@ -1,19 +1,45 @@
 // Code generated by protoc-gen-go-micro. DO NOT EDIT.
 // versions:
-// - protoc-gen-go-micro v4.0.2
-// - protoc              v4.23.4
-// source: health/health.proto
+// - protoc-gen-go-micro v3.10.2
+// - protoc              v3.21.12
+// source: health.proto

 package health

 import (
 	context "context"
-	codec "go.unistack.org/micro-proto/v4/codec"
+	codec "go.unistack.org/micro-proto/v3/codec"
+	v3 "go.unistack.org/micro-server-http/v3"
 )

 var (
 	HealthServiceName = "HealthService"
 )
+var (
+	HealthServiceServerEndpoints = []v3.EndpointMetadata{
+		{
+			Name:   "HealthService.Live",
+			Path:   "/live",
+			Method: "GET",
+			Body:   "",
+			Stream: false,
+		},
+		{
+			Name:   "HealthService.Ready",
+			Path:   "/ready",
+			Method: "GET",
+			Body:   "",
+			Stream: false,
+		},
+		{
+			Name:   "HealthService.Version",
+			Path:   "/version",
+			Method: "GET",
+			Body:   "",
+			Stream: false,
+		},
+	}
+)

 type HealthServiceServer interface {
 	Live(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error
--- a/handler/health/health_micro_http.pb.go
+++ b/handler/health/health_micro_http.pb.go
@@ -1,41 +1,14 @@
 // Code generated by protoc-gen-go-micro. DO NOT EDIT.
-// protoc-gen-go-micro version: v4.0.2
-// source: health/health.proto
+// protoc-gen-go-micro version: v3.10.2
+// source: health.proto

 package health

 import (
 	context "context"
-	codec "go.unistack.org/micro-proto/v4/codec"
-	v4 "go.unistack.org/micro-server-http/v4"
-	options "go.unistack.org/micro/v4/options"
-	server "go.unistack.org/micro/v4/server"
-)
-
-var (
-	HealthServiceServerEndpoints = []v4.EndpointMetadata{
-		{
-			Name:   "HealthService.Live",
-			Path:   "/live",
-			Method: "GET",
-			Body:   "",
-			Stream: false,
-		},
-		{
-			Name:   "HealthService.Ready",
-			Path:   "/ready",
-			Method: "GET",
-			Body:   "",
-			Stream: false,
-		},
-		{
-			Name:   "HealthService.Version",
-			Path:   "/version",
-			Method: "GET",
-			Body:   "",
-			Stream: false,
-		},
-	}
+	codec "go.unistack.org/micro-proto/v3/codec"
+	v3 "go.unistack.org/micro-server-http/v3"
+	server "go.unistack.org/micro/v3/server"
 )

 type healthServiceServer struct {
@@ -54,7 +27,7 @@ func (h *healthServiceServer) Version(ctx context.Context, req *codec.Frame, rsp
 	return h.HealthServiceServer.Version(ctx, req, rsp)
 }

-func RegisterHealthServiceServer(s server.Server, sh HealthServiceServer, opts ...options.Option) error {
+func RegisterHealthServiceServer(s server.Server, sh HealthServiceServer, opts ...server.HandlerOption) error {
 	type healthService interface {
 		Live(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error
 		Ready(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error
@@ -64,7 +37,7 @@ func RegisterHealthServiceServer(s server.Server, sh HealthServiceServer, opts .
 		healthService
 	}
 	h := &healthServiceServer{sh}
-	var nopts []options.Option
-	nopts = append(nopts, v4.HandlerEndpoints(HealthServiceServerEndpoints))
-	return s.Handle(&HealthService{h}, append(nopts, opts...)...)
+	var nopts []server.HandlerOption
+	nopts = append(nopts, v3.HandlerEndpoints(HealthServiceServerEndpoints))
+	return s.Handle(s.NewHandler(&HealthService{h}, append(nopts, opts...)...))
 }
--- a/handler/meter/meter.go
+++ b/handler/meter/meter.go
@@ -1,4 +1,4 @@
-package meter // import "go.unistack.org/micro-server-http/v4/handler/meter"
+package meter // import "go.unistack.org/micro-server-http/v3/handler/meter"

 import (
 	"bytes"
@@ -8,11 +8,10 @@ import (
 	"strings"
 	"sync"

-	codecpb "go.unistack.org/micro-proto/v4/codec"
-	"go.unistack.org/micro/v4/logger"
-	"go.unistack.org/micro/v4/metadata"
-	"go.unistack.org/micro/v4/meter"
-	"go.unistack.org/micro/v4/options"
+	codecpb "go.unistack.org/micro-proto/v3/codec"
+	"go.unistack.org/micro/v3/logger"
+	"go.unistack.org/micro/v3/metadata"
+	"go.unistack.org/micro/v3/meter"
 )

 const (
@@ -33,7 +32,7 @@ var bufPool = sync.Pool{
 }

 // guard to fail early
-var _ MeterServiceServer = (*Handler)(nil)
+var _ MeterServiceServer = &Handler{}

 type Handler struct {
 	opts Options
@@ -44,7 +43,7 @@ type Option func(*Options)
 type Options struct {
 	Meter        meter.Meter
 	Name         string
-	MeterOptions []options.Option
+	MeterOptions []meter.Option
 }

 func Meter(m meter.Meter) Option {
@@ -59,7 +58,7 @@ func Name(name string) Option {
 	}
 }

-func MeterOptions(opts ...options.Option) Option {
+func MeterOptions(opts ...meter.Option) Option {
 	return func(o *Options) {
 		o.MeterOptions = append(o.MeterOptions, opts...)
 	}
@@ -90,7 +89,7 @@ func (h *Handler) Metrics(ctx context.Context, req *codecpb.Frame, rsp *codecpb.

 	w := io.Writer(buf)

-	if md, ok := metadata.FromContext(ctx); gzipAccepted(md) && ok {
+	if md, ok := metadata.FromIncomingContext(ctx); gzipAccepted(md) && ok {
 		md.Set(contentEncodingHeader, "gzip")
 		gz := gzipPool.Get().(*gzip.Writer)
 		defer gzipPool.Put(gz)
@@ -102,7 +101,7 @@ func (h *Handler) Metrics(ctx context.Context, req *codecpb.Frame, rsp *codecpb.
 	}

 	if err := h.opts.Meter.Write(w, h.opts.MeterOptions...); err != nil {
-		log.Error(ctx, "http/meter: write failed", err)
+		log.Error(ctx, "http/meter write failed", err)
 		return nil
 	}

--- a/handler/meter/meter.proto
+++ b/handler/meter/meter.proto
@@ -1,7 +1,7 @@
 syntax = "proto3";

-package micro.server.http.v4.handler.meter;
-option go_package = "go.unistack.org/micro-server-http/v4/handler/meter;meter";
+package micro.server.http.v3.handler.meter;
+option go_package = "go.unistack.org/micro-server-http/v3/handler/meter;meter";

 import "api/annotations.proto";
 import "openapiv3/annotations.proto";
--- a/handler/meter/meter_micro.pb.go
+++ b/handler/meter/meter_micro.pb.go
@@ -1,19 +1,31 @@
 // Code generated by protoc-gen-go-micro. DO NOT EDIT.
 // versions:
-// - protoc-gen-go-micro v4.0.2
-// - protoc              v4.23.4
-// source: meter/meter.proto
+// - protoc-gen-go-micro v3.10.2
+// - protoc              v3.21.12
+// source: meter.proto

 package meter

 import (
 	context "context"
-	codec "go.unistack.org/micro-proto/v4/codec"
+	codec "go.unistack.org/micro-proto/v3/codec"
+	v3 "go.unistack.org/micro-server-http/v3"
 )

 var (
 	MeterServiceName = "MeterService"
 )
+var (
+	MeterServiceServerEndpoints = []v3.EndpointMetadata{
+		{
+			Name:   "MeterService.Metrics",
+			Path:   "/metrics",
+			Method: "GET",
+			Body:   "",
+			Stream: false,
+		},
+	}
+)

 type MeterServiceServer interface {
 	Metrics(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error
--- a/handler/meter/meter_micro_http.pb.go
+++ b/handler/meter/meter_micro_http.pb.go
@@ -1,27 +1,14 @@
 // Code generated by protoc-gen-go-micro. DO NOT EDIT.
-// protoc-gen-go-micro version: v4.0.2
-// source: meter/meter.proto
+// protoc-gen-go-micro version: v3.10.2
+// source: meter.proto

 package meter

 import (
 	context "context"
-	codec "go.unistack.org/micro-proto/v4/codec"
-	v4 "go.unistack.org/micro-server-http/v4"
-	options "go.unistack.org/micro/v4/options"
-	server "go.unistack.org/micro/v4/server"
-)
-
-var (
-	MeterServiceServerEndpoints = []v4.EndpointMetadata{
-		{
-			Name:   "MeterService.Metrics",
-			Path:   "/metrics",
-			Method: "GET",
-			Body:   "",
-			Stream: false,
-		},
-	}
+	codec "go.unistack.org/micro-proto/v3/codec"
+	v3 "go.unistack.org/micro-server-http/v3"
+	server "go.unistack.org/micro/v3/server"
 )

 type meterServiceServer struct {
@@ -32,7 +19,7 @@ func (h *meterServiceServer) Metrics(ctx context.Context, req *codec.Frame, rsp
 	return h.MeterServiceServer.Metrics(ctx, req, rsp)
 }

-func RegisterMeterServiceServer(s server.Server, sh MeterServiceServer, opts ...options.Option) error {
+func RegisterMeterServiceServer(s server.Server, sh MeterServiceServer, opts ...server.HandlerOption) error {
 	type meterService interface {
 		Metrics(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error
 	}
@@ -40,7 +27,7 @@ func RegisterMeterServiceServer(s server.Server, sh MeterServiceServer, opts ...
 		meterService
 	}
 	h := &meterServiceServer{sh}
-	var nopts []options.Option
-	nopts = append(nopts, v4.HandlerEndpoints(MeterServiceServerEndpoints))
-	return s.Handle(&MeterService{h}, append(nopts, opts...)...)
+	var nopts []server.HandlerOption
+	nopts = append(nopts, v3.HandlerEndpoints(MeterServiceServerEndpoints))
+	return s.Handle(s.NewHandler(&MeterService{h}, append(nopts, opts...)...))
 }
--- a/handler/pprof/pprof.go
+++ b/handler/pprof/pprof.go
@@ -0,0 +1,46 @@
+package pprof
+
+import (
+	"expvar"
+	"net/http"
+	"net/http/pprof"
+	"path"
+	"strings"
+)
+
+func NewHandler(prefixPath string, initFuncs ...func()) http.HandlerFunc {
+	for _, fn := range initFuncs {
+		fn()
+	}
+
+	return func(w http.ResponseWriter, r *http.Request) {
+		switch {
+		case strings.EqualFold(r.RequestURI, prefixPath) && r.RequestURI[len(r.RequestURI)-1] != '/':
+			http.Redirect(w, r, r.RequestURI+"/", http.StatusMovedPermanently)
+		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "cmdline")):
+			pprof.Cmdline(w, r)
+		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "profile")):
+			pprof.Profile(w, r)
+		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "symbol")):
+			pprof.Symbol(w, r)
+		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "trace")):
+			pprof.Trace(w, r)
+		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "goroutine")):
+			pprof.Handler("goroutine").ServeHTTP(w, r)
+		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "threadcreate")):
+			pprof.Handler("threadcreate").ServeHTTP(w, r)
+		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "mutex")):
+			pprof.Handler("mutex").ServeHTTP(w, r)
+		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "heap")):
+			pprof.Handler("heap").ServeHTTP(w, r)
+		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "block")):
+			pprof.Handler("block").ServeHTTP(w, r)
+		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "allocs")):
+			pprof.Handler("allocs").ServeHTTP(w, r)
+		case strings.HasPrefix(r.RequestURI, path.Join(prefixPath, "vars")):
+			expvar.Handler().ServeHTTP(w, r)
+		default:
+			pprof.Index(w, r)
+		}
+	}
+}
--- a/handler/spa/spa.go
+++ b/handler/spa/spa.go
@@ -1,19 +0,0 @@
-package spa
-
-import (
-	"io/fs"
-	"net/http"
-	"strings"
-)
-
-// Handler serve files from dir and redirect to index if file not exists
-var Handler = func(prefix string, dir fs.FS) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		f := http.StripPrefix(prefix, http.FileServer(http.FS(dir)))
-		if _, err := fs.Stat(dir, strings.TrimPrefix(r.RequestURI, prefix)); err != nil {
-			r.RequestURI = prefix
-			r.URL.Path = prefix
-		}
-		f.ServeHTTP(w, r)
-	}
-}
--- a/handler/swagger-ui/swagger-initializer.js
+++ b/handler/swagger-ui/swagger-initializer.js
@@ -0,0 +1,20 @@
+window.onload = function() {
+  //<editor-fold desc="Changeable Configuration Block">
+
+  // the following lines will be replaced by docker/configurator, when it runs in a docker-container
+  window.ui = SwaggerUIBundle({
+    url: "{{ .SWAGGER }}",
+    dom_id: '#swagger-ui',
+    deepLinking: true,
+    presets: [
+      SwaggerUIBundle.presets.apis,
+      SwaggerUIStandalonePreset
+    ],
+    plugins: [
+      SwaggerUIBundle.plugins.DownloadUrl
+    ],
+    layout: "StandaloneLayout"
+  });
+
+  //</editor-fold>
+};
--- a/handler/swagger-ui/swaggerui.go
+++ b/handler/swagger-ui/swaggerui.go
@@ -1,4 +1,4 @@
-package swaggerui // import "go.unistack.org/micro-server-http/v4/handler/swagger-ui"
+package swaggerui // import "go.unistack.org/micro-server-http/v3/handler/swagger-ui"

 import (
 	"embed"
--- a/handler/swagger/swagger.go
+++ b/handler/swagger/swagger.go
@@ -4,8 +4,8 @@ import (
 	"io/fs"
 	"net/http"

-	yamlcodec "go.unistack.org/micro-codec-yaml/v4"
-	rutil "go.unistack.org/micro/v4/util/reflect"
+	yamlcodec "go.unistack.org/micro-codec-yaml/v3"
+	rutil "go.unistack.org/micro/v3/util/reflect"
 )

 // Handler append to generated swagger data from dst map[string]interface{}
--- a/http.go
+++ b/http.go
@@ -1,5 +1,5 @@
 // Package http implements a go-micro.Server
-package http // import "go.unistack.org/micro-server-http/v4"
+package http // import "go.unistack.org/micro-server-http/v3"

 import (
 	"context"
@@ -9,30 +9,33 @@ import (
 	"net"
 	"net/http"
 	"reflect"
+	"sort"
 	"strings"
 	"sync"
 	"time"

-	"go.unistack.org/micro/v4/codec"
-	"go.unistack.org/micro/v4/logger"
-	"go.unistack.org/micro/v4/options"
-	"go.unistack.org/micro/v4/register"
-	"go.unistack.org/micro/v4/server"
-	rhttp "go.unistack.org/micro/v4/util/http"
+	"go.unistack.org/micro/v3/broker"
+	"go.unistack.org/micro/v3/codec"
+	"go.unistack.org/micro/v3/logger"
+	"go.unistack.org/micro/v3/register"
+	"go.unistack.org/micro/v3/server"
+	rhttp "go.unistack.org/micro/v3/util/http"
 	"golang.org/x/net/netutil"
 )

 var _ server.Server = (*Server)(nil)

 type Server struct {
-	hd           interface{}
+	hd           server.Handler
 	rsvc         *register.Service
-	handlers     map[string]interface{}
+	handlers     map[string]server.Handler
 	exit         chan chan error
-	errorHandler func(context.Context, interface{}, http.ResponseWriter, *http.Request, error, int)
+	subscribers  map[*httpSubscriber][]broker.Subscriber
+	errorHandler func(context.Context, server.Handler, http.ResponseWriter, *http.Request, error, int)
 	pathHandlers *rhttp.Trie
 	opts         server.Options
 	registerRPC  bool
+	registerCORS bool
 	sync.RWMutex
 	registered bool
 	init       bool
@@ -58,7 +61,7 @@ func (h *Server) Options() server.Options {
 	return opts
 }

-func (h *Server) Init(opts ...options.Option) error {
+func (h *Server) Init(opts ...server.Option) error {
 	if len(opts) == 0 && h.init {
 		return nil
 	}
@@ -68,11 +71,11 @@ func (h *Server) Init(opts ...options.Option) error {
 	for _, o := range opts {
 		o(&h.opts)
 	}
-	if fn, ok := h.opts.Context.Value(errorHandlerKey{}).(func(ctx context.Context, s interface{}, w http.ResponseWriter, r *http.Request, err error, status int)); ok && fn != nil {
+	if fn, ok := h.opts.Context.Value(errorHandlerKey{}).(func(ctx context.Context, s server.Handler, w http.ResponseWriter, r *http.Request, err error, status int)); ok && fn != nil {
 		h.errorHandler = fn
 	}
 	if h.handlers == nil {
-		h.handlers = make(map[string]interface{})
+		h.handlers = make(map[string]server.Handler)
 	}
 	if h.pathHandlers == nil {
 		h.pathHandlers = rhttp.NewTrie()
@@ -82,6 +85,10 @@ func (h *Server) Init(opts ...options.Option) error {
 		h.registerRPC = v
 	}

+	if v, ok := h.opts.Context.Value(registerCORSHandlerKey{}).(bool); ok {
+		h.registerCORS = v
+	}
+
 	if phs, ok := h.opts.Context.Value(pathHandlerKey{}).(*pathHandlerVal); ok && phs.h != nil {
 		for pm, ps := range phs.h {
 			for pp, ph := range ps {
@@ -99,6 +106,10 @@ func (h *Server) Init(opts ...options.Option) error {
 		h.RUnlock()
 		return err
 	}
+	if err := h.opts.Broker.Init(); err != nil {
+		h.RUnlock()
+		return err
+	}
 	if err := h.opts.Tracer.Init(); err != nil {
 		h.RUnlock()
 		return err
@@ -111,6 +122,10 @@ func (h *Server) Init(opts ...options.Option) error {
 		h.RUnlock()
 		return err
 	}
+	if err := h.opts.Transport.Init(); err != nil {
+		h.RUnlock()
+		return err
+	}
 	h.RUnlock()

 	h.Lock()
@@ -120,24 +135,12 @@ func (h *Server) Init(opts ...options.Option) error {
 	return nil
 }

-func (h *Server) Handle(handler interface{}, opts ...options.Option) error {
-	options := server.NewHandleOptions(opts...)
-	var endpointMetadata []EndpointMetadata
-
-	if v, ok := options.Context.Value(handlerEndpointsKey{}).([]EndpointMetadata); ok {
-		endpointMetadata = v
-	}
-
+func (h *Server) Handle(handler server.Handler) error {
 	// passed unknown handler
 	hdlr, ok := handler.(*httpHandler)
 	if !ok {
 		h.Lock()
-		if h.handlers == nil {
-			h.handlers = make(map[string]interface{})
-		}
-		for _, v := range endpointMetadata {
-			h.handlers[v.Name] = h.newHTTPHandler(handler, opts...)
-		}
+		h.hd = handler
 		h.Unlock()
 		return nil
 	}
@@ -150,11 +153,19 @@ func (h *Server) Handle(handler interface{}, opts ...options.Option) error {
 		return nil
 	}

+	// passed micro compat handler
+	h.Lock()
+	if h.handlers == nil {
+		h.handlers = make(map[string]server.Handler)
+	}
+	h.handlers[handler.Name()] = handler
+	h.Unlock()
+
 	return nil
 }

-func (h *Server) newHTTPHandler(handler interface{}, opts ...options.Option) *httpHandler {
-	options := server.NewHandleOptions(opts...)
+func (h *Server) NewHandler(handler interface{}, opts ...server.HandlerOption) server.Handler {
+	options := server.NewHandlerOptions(opts...)

 	eps := make([]*register.Endpoint, 0, len(options.Metadata))
 	for name, metadata := range options.Metadata {
@@ -198,16 +209,16 @@ func (h *Server) newHTTPHandler(handler interface{}, opts ...options.Option) *ht
 		}

 		if method.Name == "" && h.opts.Logger.V(logger.ErrorLevel) {
-			h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("nil method for %s", mname))
+			h.opts.Logger.Errorf(h.opts.Context, "nil method for %s", mname)
 			continue
 		}

 		mtype, err := prepareEndpoint(method)
 		if err != nil && h.opts.Logger.V(logger.ErrorLevel) {
-			h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("%v", err))
+			h.opts.Logger.Errorf(h.opts.Context, "%v", err)
 			continue
 		} else if mtype == nil {
-			h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("nil mtype for %s", mname))
+			h.opts.Logger.Errorf(h.opts.Context, "nil mtype for %s", mname)
 			continue
 		}

@@ -217,14 +228,30 @@ func (h *Server) newHTTPHandler(handler interface{}, opts ...options.Option) *ht
 		pth := &patHandler{mtype: mtype, name: name, rcvr: rcvr}
 		hdlr.name = name

-		if err := hdlr.handlers.Insert(md["Method"], md["Path"][0], pth); err != nil {
-			h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("cant add handler for %s %s", md["Method"][0], md["Path"][0]))
+		methods := []string{md["Method"]}
+		if h.registerCORS {
+			logger.Infof(h.opts.Context, "register cors handler for http.MethodOptions %s", md["Path"])
+			methods = append(methods, http.MethodOptions)
+		} else {
+			logger.Infof(h.opts.Context, "not register cors handler for http.MethodOptions %s", md["Path"])
 		}

+		if err := hdlr.handlers.Insert(methods, md["Path"], pth); err != nil {
+			logger.Errorf(h.opts.Context, "cant add handler for %v %s", methods, md["Path"])
+		}
+
+		logger.Infof(h.opts.Context, fmt.Sprintf("try to detect rpc handlers usage %v", h.registerRPC))
 		if h.registerRPC {
-			h.opts.Logger.Info(h.opts.Context, fmt.Sprintf("register rpc handler for http.MethodPost %s /%s", hn, hn))
-			if err := hdlr.handlers.Insert([]string{http.MethodPost}, "/"+hn, pth); err != nil {
-				h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("cant add rpc handler for http.MethodPost %s /%s", hn, hn))
+			methods := []string{http.MethodPost}
+			if h.registerCORS {
+				logger.Infof(h.opts.Context, "register cors handler for %v %s", methods, "/"+hn)
+				methods = append(methods, http.MethodOptions)
+			} else {
+				logger.Infof(h.opts.Context, "not register cors handler for %v %s", methods, "/"+hn)
+			}
+
+			if err := hdlr.handlers.Insert(methods, "/"+hn, pth); err != nil {
+				h.opts.Logger.Errorf(h.opts.Context, "cant add rpc handler for http.MethodPost %s /%s", hn, hn)
 			}
 		}
 	}
@@ -248,16 +275,16 @@ func (h *Server) newHTTPHandler(handler interface{}, opts ...options.Option) *ht
 		}

 		if method.Name == "" && h.opts.Logger.V(logger.ErrorLevel) {
-			h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("nil method for %s", mname))
+			h.opts.Logger.Errorf(h.opts.Context, "nil method for %s", mname)
 			continue
 		}

 		mtype, err := prepareEndpoint(method)
 		if err != nil && h.opts.Logger.V(logger.ErrorLevel) {
-			h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("%v", err))
+			h.opts.Logger.Errorf(h.opts.Context, "%v", err)
 			continue
 		} else if mtype == nil {
-			h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("nil mtype for %s", mname))
+			h.opts.Logger.Errorf(h.opts.Context, "nil mtype for %s", mname)
 			continue
 		}

@@ -268,13 +295,13 @@ func (h *Server) newHTTPHandler(handler interface{}, opts ...options.Option) *ht
 		hdlr.name = name

 		if err := hdlr.handlers.Insert([]string{md.Method}, md.Path, pth); err != nil {
-			h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("cant add handler for %s %s", md.Method, md.Path))
+			h.opts.Logger.Errorf(h.opts.Context, "cant add handler for %s %s", md.Method, md.Path)
 		}

 		if h.registerRPC {
-			h.opts.Logger.Info(h.opts.Context, fmt.Sprintf("register rpc handler for http.MethodPost %s /%s", hn, hn))
+			h.opts.Logger.Infof(h.opts.Context, "register rpc handler for http.MethodPost %s /%s", hn, hn)
 			if err := hdlr.handlers.Insert([]string{http.MethodPost}, "/"+hn, pth); err != nil {
-				h.opts.Logger.Error(h.opts.Context, fmt.Sprintf("cant add rpc handler for http.MethodPost %s /%s", hn, hn))
+				h.opts.Logger.Errorf(h.opts.Context, "cant add rpc handler for http.MethodPost %s /%s", hn, hn)
 			}
 		}
 	}
@@ -282,15 +309,40 @@ func (h *Server) newHTTPHandler(handler interface{}, opts ...options.Option) *ht
 	return hdlr
 }

+func (h *Server) NewSubscriber(topic string, handler interface{}, opts ...server.SubscriberOption) server.Subscriber {
+	return newSubscriber(topic, handler, opts...)
+}
+
+func (h *Server) Subscribe(sb server.Subscriber) error {
+	sub, ok := sb.(*httpSubscriber)
+	if !ok {
+		return fmt.Errorf("invalid subscriber: expected *httpSubscriber")
+	}
+	if len(sub.handlers) == 0 {
+		return fmt.Errorf("invalid subscriber: no handler functions")
+	}
+
+	if err := server.ValidateSubscriber(sb); err != nil {
+		return err
+	}
+
+	h.RLock()
+	_, ok = h.subscribers[sub]
+	h.RUnlock()
+	if ok {
+		return fmt.Errorf("subscriber %v already exists", h)
+	}
+	h.Lock()
+	h.subscribers[sub] = nil
+	h.Unlock()
+	return nil
+}
+
 func (h *Server) Register() error {
 	var eps []*register.Endpoint
 	h.RLock()
 	for _, hdlr := range h.handlers {
-		hd, ok := hdlr.(*httpHandler)
-		if !ok {
-			continue
-		}
-		eps = append(eps, hd.Endpoints()...)
+		eps = append(eps, hdlr.Endpoints()...)
 	}
 	rsvc := h.rsvc
 	config := h.opts
@@ -308,16 +360,31 @@ func (h *Server) Register() error {
 	if err != nil {
 		return err
 	}
-	service.Nodes[0].Metadata.Set("protocol", "http")
+	service.Nodes[0].Metadata["protocol"] = "http"
 	service.Endpoints = eps

+	h.Lock()
+	subscriberList := make([]*httpSubscriber, 0, len(h.subscribers))
+	for e := range h.subscribers {
+		// Only advertise non internal subscribers
+		subscriberList = append(subscriberList, e)
+	}
+	sort.Slice(subscriberList, func(i, j int) bool {
+		return subscriberList[i].topic > subscriberList[j].topic
+	})
+
+	for _, e := range subscriberList {
+		service.Endpoints = append(service.Endpoints, e.Endpoints()...)
+	}
+	h.Unlock()
+
 	h.RLock()
 	registered := h.registered
 	h.RUnlock()

 	if !registered {
 		if config.Logger.V(logger.InfoLevel) {
-			config.Logger.Info(config.Context, fmt.Sprintf("Register [%s] Registering node: %s", config.Register.String(), service.Nodes[0].ID))
+			config.Logger.Infof(config.Context, "Register [%s] Registering node: %s", config.Register.String(), service.Nodes[0].ID)
 		}
 	}

@@ -332,6 +399,7 @@ func (h *Server) Register() error {
 	}

 	h.Lock()
+
 	h.registered = true
 	h.rsvc = service
 	h.Unlock()
@@ -339,6 +407,35 @@ func (h *Server) Register() error {
 	return nil
 }

+func (h *Server) subscribe() error {
+	config := h.opts
+
+	for sb := range h.subscribers {
+		handler := h.createSubHandler(sb, config)
+		var opts []broker.SubscribeOption
+		if queue := sb.Options().Queue; len(queue) > 0 {
+			opts = append(opts, broker.SubscribeGroup(queue))
+		}
+
+		subCtx := config.Context
+		if cx := sb.Options().Context; cx != nil {
+			subCtx = cx
+		}
+		opts = append(opts, broker.SubscribeContext(subCtx))
+		opts = append(opts, broker.SubscribeAutoAck(sb.Options().AutoAck))
+		opts = append(opts, broker.SubscribeBodyOnly(sb.Options().BodyOnly))
+
+		sub, err := config.Broker.Subscribe(subCtx, sb.Topic(), handler, opts...)
+		if err != nil {
+			h.Unlock()
+			return err
+		}
+		h.subscribers[sb] = []broker.Subscriber{sub}
+	}
+
+	return nil
+}
+
 func (h *Server) Deregister() error {
 	h.RLock()
 	config := h.opts
@@ -350,7 +447,7 @@ func (h *Server) Deregister() error {
 	}

 	if config.Logger.V(logger.InfoLevel) {
-		config.Logger.Info(config.Context, fmt.Sprintf("Deregistering node: %s", service.Nodes[0].ID))
+		config.Logger.Infof(config.Context, "Deregistering node: %s", service.Nodes[0].ID)
 	}

 	if err := server.DefaultDeregisterFunc(service, config); err != nil {
@@ -366,6 +463,23 @@ func (h *Server) Deregister() error {
 	}

 	h.registered = false
+
+	subCtx := h.opts.Context
+	for sb, subs := range h.subscribers {
+		if cx := sb.Options().Context; cx != nil {
+			subCtx = cx
+		}
+
+		for _, sub := range subs {
+			config.Logger.Infof(config.Context, "Unsubscribing from topic: %s", sub.Topic())
+			if err := sub.Unsubscribe(subCtx); err != nil {
+				h.Unlock()
+				config.Logger.Errorf(config.Context, "failed to unsubscribe topic: %s, error: %v", sb.Topic(), err)
+				return err
+			}
+		}
+		h.subscribers[sb] = nil
+	}
 	h.Unlock()
 	return nil
 }
@@ -400,7 +514,7 @@ func (h *Server) Start() error {
 	}

 	if config.Logger.V(logger.InfoLevel) {
-		config.Logger.Info(config.Context, fmt.Sprintf("Listening on %s", ts.Addr().String()))
+		config.Logger.Infof(config.Context, "Listening on %s", ts.Addr().String())
 	}

 	h.Lock()
@@ -413,7 +527,7 @@ func (h *Server) Start() error {
 	if h.opts.Context != nil {
 		if hs, ok := h.opts.Context.Value(serverKey{}).(*http.Server); ok && hs != nil {
 			if hs.Handler == nil && h.hd != nil {
-				if hdlr, ok := h.hd.(http.Handler); ok {
+				if hdlr, ok := h.hd.Handler().(http.Handler); ok {
 					hs.Handler = hdlr
 					handler = hs.Handler
 				}
@@ -429,7 +543,7 @@ func (h *Server) Start() error {
 	case len(h.handlers) > 0 && h.hd != nil:
 		handler = h
 	case handler == nil && h.hd != nil:
-		if hdlr, ok := h.hd.(http.Handler); ok {
+		if hdlr, ok := h.hd.Handler().(http.Handler); ok {
 			handler = hdlr
 		}
 	}
@@ -438,9 +552,13 @@ func (h *Server) Start() error {
 		return fmt.Errorf("cant process with nil handler")
 	}

+	if err := config.Broker.Connect(h.opts.Context); err != nil {
+		return err
+	}
+
 	if err := config.RegisterCheck(h.opts.Context); err != nil {
 		if config.Logger.V(logger.ErrorLevel) {
-			config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register check error: %s", config.Name, config.ID, err))
+			config.Logger.Errorf(config.Context, "Server %s-%s register check error: %s", config.Name, config.ID, err)
 		}
 	} else {
 		if err = h.Register(); err != nil {
@@ -448,6 +566,10 @@ func (h *Server) Start() error {
 		}
 	}

+	if err := h.subscribe(); err != nil {
+		return err
+	}
+
 	fn := handler

 	var hs *http.Server
@@ -468,7 +590,7 @@ func (h *Server) Start() error {

 	go func() {
 		if cerr := hs.Serve(ts); cerr != nil && !errors.Is(cerr, net.ErrClosed) {
-			h.opts.Logger.Error(h.opts.Context, fmt.Sprint(cerr))
+			h.opts.Logger.Error(h.opts.Context, cerr)
 		}
 	}()

@@ -496,28 +618,28 @@ func (h *Server) Start() error {
 				// nolint: nestif
 				if rerr != nil && registered {
 					if config.Logger.V(logger.ErrorLevel) {
-						config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register check error: %s, deregister it", config.Name, config.ID, rerr))
+						config.Logger.Errorf(config.Context, "Server %s-%s register check error: %s, deregister it", config.Name, config.ID, rerr)
 					}
 					// deregister self in case of error
 					if err := h.Deregister(); err != nil {
 						if config.Logger.V(logger.ErrorLevel) {
-							config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s deregister error: %s", config.Name, config.ID, err))
+							config.Logger.Errorf(config.Context, "Server %s-%s deregister error: %s", config.Name, config.ID, err)
 						}
 					}
 				} else if rerr != nil && !registered {
 					if config.Logger.V(logger.ErrorLevel) {
-						config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register check error: %s", config.Name, config.ID, rerr))
+						config.Logger.Errorf(config.Context, "Server %s-%s register check error: %s", config.Name, config.ID, rerr)
 					}
 					continue
 				}
 				if err := h.Register(); err != nil {
 					if config.Logger.V(logger.ErrorLevel) {
-						config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register error: %s", config.Name, config.ID, err))
+						config.Logger.Errorf(config.Context, "Server %s-%s register error: %s", config.Name, config.ID, err)
 					}
 				}

 				if err := h.Register(); err != nil {
-					config.Logger.Error(config.Context, fmt.Sprintf("Server register error: %s", err))
+					config.Logger.Errorf(config.Context, "Server register error: %s", err)
 				}
 			// wait for exit
 			case ch = <-h.exit:
@@ -527,7 +649,11 @@ func (h *Server) Start() error {

 		// deregister
 		if err := h.Deregister(); err != nil {
-			config.Logger.Error(config.Context, fmt.Sprintf("Server deregister error: %s", err))
+			config.Logger.Errorf(config.Context, "Server deregister error: %s", err)
+		}
+
+		if err := config.Broker.Disconnect(config.Context); err != nil {
+			config.Logger.Errorf(config.Context, "Broker disconnect error: %s", err)
 		}

 		ctx, cancel := context.WithTimeout(context.Background(), h.opts.GracefulTimeout)
@@ -558,7 +684,7 @@ func (h *Server) Name() string {
 	return h.opts.Name
 }

-func NewServer(opts ...options.Option) *Server {
+func NewServer(opts ...server.Option) *Server {
 	options := server.NewOptions(opts...)
 	eh := DefaultErrorHandler
 	if v, ok := options.Context.Value(errorHandlerKey{}).(errorHandler); ok && v != nil {
@@ -567,6 +693,7 @@ func NewServer(opts ...options.Option) *Server {
 	return &Server{
 		opts:         options,
 		exit:         make(chan chan error),
+		subscribers:  make(map[*httpSubscriber][]broker.Subscriber),
 		errorHandler: eh,
 		pathHandlers: rhttp.NewTrie(),
 	}
--- a/message.go
+++ b/message.go
@@ -1,8 +1,8 @@
 package http

 import (
-	"go.unistack.org/micro/v4/codec"
-	"go.unistack.org/micro/v4/metadata"
+	"go.unistack.org/micro/v3/codec"
+	"go.unistack.org/micro/v3/metadata"
 )

 type httpMessage struct {
--- a/options.go
+++ b/options.go
@@ -5,7 +5,7 @@ import (
 	"fmt"
 	"net/http"

-	"go.unistack.org/micro/v4/options"
+	"go.unistack.org/micro/v3/server"
 )

 // SetError pass error to caller
@@ -79,24 +79,24 @@ func GetRspCode(ctx context.Context) int {
 type middlewareKey struct{}

 // Middleware passes http middlewares
-func Middleware(mw ...func(http.Handler) http.Handler) options.Option {
-	return options.ContextOption(middlewareKey{}, mw)
+func Middleware(mw ...func(http.Handler) http.Handler) server.Option {
+	return server.SetOption(middlewareKey{}, mw)
 }

 type serverKey struct{}

 // HTTPServer provide ability to pass *http.Server
-func HTTPServer(hs *http.Server) options.Option {
-	return options.ContextOption(serverKey{}, hs)
+func HTTPServer(hs *http.Server) server.Option {
+	return server.SetOption(serverKey{}, hs)
 }

-type errorHandler func(ctx context.Context, s interface{}, w http.ResponseWriter, r *http.Request, err error, status int)
+type errorHandler func(ctx context.Context, s server.Handler, w http.ResponseWriter, r *http.Request, err error, status int)

 type errorHandlerKey struct{}

 // ErrorHandler specifies handler for errors
-func ErrorHandler(fn errorHandler) options.Option {
-	return options.ContextOption(errorHandlerKey{}, fn)
+func ErrorHandler(fn errorHandler) server.Option {
+	return server.SetOption(errorHandlerKey{}, fn)
 }

 type (
@@ -107,18 +107,12 @@ type (
 )

 // PathHandler specifies http handler for path regexp
-func PathHandler(method, path string, handler http.HandlerFunc) options.Option {
-	return func(src interface{}) error {
-		vctx, err := options.Get(src, ".Context")
-		if err != nil {
-			return err
+func PathHandler(method, path string, handler http.HandlerFunc) server.Option {
+	return func(o *server.Options) {
+		if o.Context == nil {
+			o.Context = context.Background()
 		}
-		ctx, ok := vctx.(context.Context)
-		if !ok {
-			return fmt.Errorf("invalid option")
-		}
-
-		v, ok := ctx.Value(pathHandlerKey{}).(*pathHandlerVal)
+		v, ok := o.Context.Value(pathHandlerKey{}).(*pathHandlerVal)
 		if !ok {
 			v = &pathHandlerVal{h: make(map[string]map[string]http.HandlerFunc)}
 		}
@@ -127,17 +121,23 @@ func PathHandler(method, path string, handler http.HandlerFunc) options.Option {
 			m = make(map[string]http.HandlerFunc)
 			v.h[method] = m
 		}
-		ctx = context.WithValue(ctx, pathHandlerKey{}, v)
 		m[path] = handler
-		return options.Set(src, ctx, ".Context")
+		o.Context = context.WithValue(o.Context, pathHandlerKey{}, v)
 	}
 }

 type registerRPCHandlerKey struct{}

 // RegisterRPCHandler registers compatibility endpoints with /ServiceName.ServiceEndpoint method POST
-func RegisterRPCHandler(b bool) options.Option {
-	return options.ContextOption(registerRPCHandlerKey{}, b)
+func RegisterRPCHandler(b bool) server.Option {
+	return server.SetOption(registerRPCHandlerKey{}, b)
+}
+
+type registerCORSHandlerKey struct{}
+
+// RegisterCORSHandler registers cors endpoints with /ServiceName.ServiceEndpoint method POPTIONSOST
+func RegisterCORSHandler(b bool) server.Option {
+	return server.SetOption(registerCORSHandlerKey{}, b)
 }

 type handlerEndpointsKey struct{}
@@ -150,8 +150,8 @@ type EndpointMetadata struct {
 	Stream bool
 }

-func HandlerEndpoints(md []EndpointMetadata) options.Option {
-	return options.ContextOption(handlerEndpointsKey{}, md)
+func HandlerEndpoints(md []EndpointMetadata) server.HandlerOption {
+	return server.SetHandlerOption(handlerEndpointsKey{}, md)
 }

 type handlerOptions struct {
--- a/request.go
+++ b/request.go
@@ -3,12 +3,15 @@ package http
 import (
 	"io"

-	"go.unistack.org/micro/v4/codec"
-	"go.unistack.org/micro/v4/metadata"
-	"go.unistack.org/micro/v4/server"
+	"go.unistack.org/micro/v3/codec"
+	"go.unistack.org/micro/v3/metadata"
+	"go.unistack.org/micro/v3/server"
 )

-var _ server.Request = &rpcRequest{}
+var (
+	_ server.Request = &rpcRequest{}
+	_ server.Message = &rpcMessage{}
+)

 type rpcRequest struct {
 	rw          io.ReadWriter
@@ -22,6 +25,14 @@ type rpcRequest struct {
 	stream      bool
 }

+type rpcMessage struct {
+	payload     interface{}
+	codec       codec.Codec
+	header      metadata.Metadata
+	topic       string
+	contentType string
+}
+
 func (r *rpcRequest) ContentType() string {
 	return r.contentType
 }
@@ -61,3 +72,23 @@ func (r *rpcRequest) Stream() bool {
 func (r *rpcRequest) Body() interface{} {
 	return r.payload
 }
+
+func (r *rpcMessage) ContentType() string {
+	return r.contentType
+}
+
+func (r *rpcMessage) Topic() string {
+	return r.topic
+}
+
+func (r *rpcMessage) Body() interface{} {
+	return r.payload
+}
+
+func (r *rpcMessage) Header() metadata.Metadata {
+	return r.header
+}
+
+func (r *rpcMessage) Codec() codec.Codec {
+	return r.codec
+}
--- a/server.go
+++ b/server.go
@@ -7,11 +7,9 @@ import (
 	"unicode"
 	"unicode/utf8"

-	"go.unistack.org/micro/v4/server"
+	"go.unistack.org/micro/v3/server"
 )

-var typeOfError = reflect.TypeOf((*error)(nil)).Elem()
-
 type methodType struct {
 	ArgType     reflect.Type
 	ReplyType   reflect.Type
--- a/subscriber.go
+++ b/subscriber.go
@@ -0,0 +1,207 @@
+package http
+
+import (
+	"bytes"
+	"context"
+	"fmt"
+	"reflect"
+	"strings"
+
+	"go.unistack.org/micro/v3/broker"
+	"go.unistack.org/micro/v3/codec"
+	"go.unistack.org/micro/v3/metadata"
+	"go.unistack.org/micro/v3/register"
+	"go.unistack.org/micro/v3/server"
+)
+
+var typeOfError = reflect.TypeOf((*error)(nil)).Elem()
+
+type handler struct {
+	reqType reflect.Type
+	ctxType reflect.Type
+	method  reflect.Value
+}
+
+type httpSubscriber struct {
+	topic      string
+	rcvr       reflect.Value
+	typ        reflect.Type
+	subscriber interface{}
+	handlers   []*handler
+	endpoints  []*register.Endpoint
+	opts       server.SubscriberOptions
+}
+
+func newSubscriber(topic string, sub interface{}, opts ...server.SubscriberOption) server.Subscriber {
+	options := server.NewSubscriberOptions(opts...)
+
+	var endpoints []*register.Endpoint
+	var handlers []*handler
+
+	if typ := reflect.TypeOf(sub); typ.Kind() == reflect.Func {
+		h := &handler{
+			method: reflect.ValueOf(sub),
+		}
+
+		switch typ.NumIn() {
+		case 1:
+			h.reqType = typ.In(0)
+		case 2:
+			h.ctxType = typ.In(0)
+			h.reqType = typ.In(1)
+		}
+
+		handlers = append(handlers, h)
+		ep := &register.Endpoint{
+			Name:     "Func",
+			Request:  register.ExtractSubValue(typ),
+			Metadata: metadata.New(2),
+		}
+		ep.Metadata.Set("topic", topic)
+		ep.Metadata.Set("subscriber", "true")
+		endpoints = append(endpoints, ep)
+	} else {
+		hdlr := reflect.ValueOf(sub)
+		name := reflect.Indirect(hdlr).Type().Name()
+
+		for m := 0; m < typ.NumMethod(); m++ {
+			method := typ.Method(m)
+			h := &handler{
+				method: method.Func,
+			}
+
+			switch method.Type.NumIn() {
+			case 2:
+				h.reqType = method.Type.In(1)
+			case 3:
+				h.ctxType = method.Type.In(1)
+				h.reqType = method.Type.In(2)
+			}
+
+			handlers = append(handlers, h)
+			ep := &register.Endpoint{
+				Name:     name + "." + method.Name,
+				Request:  register.ExtractSubValue(method.Type),
+				Metadata: metadata.New(2),
+			}
+			ep.Metadata.Set("topic", topic)
+			ep.Metadata.Set("subscriber", "true")
+			endpoints = append(endpoints, ep)
+		}
+	}
+
+	return &httpSubscriber{
+		rcvr:       reflect.ValueOf(sub),
+		typ:        reflect.TypeOf(sub),
+		topic:      topic,
+		subscriber: sub,
+		handlers:   handlers,
+		endpoints:  endpoints,
+		opts:       options,
+	}
+}
+
+func (s *Server) createSubHandler(sb *httpSubscriber, opts server.Options) broker.Handler {
+	return func(p broker.Event) error {
+		msg := p.Message()
+		ct := msg.Header["Content-Type"]
+		cf, err := s.newCodec(ct)
+		if err != nil {
+			return err
+		}
+
+		hdr := metadata.Copy(msg.Header)
+		ctx := metadata.NewIncomingContext(context.Background(), hdr)
+
+		results := make(chan error, len(sb.handlers))
+
+		for i := 0; i < len(sb.handlers); i++ {
+			handler := sb.handlers[i]
+
+			var isVal bool
+			var req reflect.Value
+
+			if handler.reqType.Kind() == reflect.Ptr {
+				req = reflect.New(handler.reqType.Elem())
+			} else {
+				req = reflect.New(handler.reqType)
+				isVal = true
+			}
+			if isVal {
+				req = req.Elem()
+			}
+
+			buf := bytes.NewBuffer(msg.Body)
+
+			if err := cf.ReadHeader(buf, &codec.Message{}, codec.Event); err != nil {
+				return err
+			}
+
+			if err := cf.ReadBody(buf, req.Interface()); err != nil {
+				return err
+			}
+
+			fn := func(ctx context.Context, msg server.Message) error {
+				var vals []reflect.Value
+				if sb.typ.Kind() != reflect.Func {
+					vals = append(vals, sb.rcvr)
+				}
+				if handler.ctxType != nil {
+					vals = append(vals, reflect.ValueOf(ctx))
+				}
+
+				vals = append(vals, reflect.ValueOf(msg.Body()))
+
+				returnValues := handler.method.Call(vals)
+				if err := returnValues[0].Interface(); err != nil {
+					return err.(error)
+				}
+				return nil
+			}
+
+			for i := len(opts.SubWrappers); i > 0; i-- {
+				fn = opts.SubWrappers[i-1](fn)
+			}
+
+			go func() {
+				results <- fn(ctx, &httpMessage{
+					topic:       sb.topic,
+					contentType: ct,
+					payload:     req.Interface(),
+					header:      msg.Header,
+					codec:       cf,
+				})
+			}()
+		}
+
+		var errors []string
+
+		for i := 0; i < len(sb.handlers); i++ {
+			if err := <-results; err != nil {
+				errors = append(errors, err.Error())
+			}
+		}
+
+		if len(errors) > 0 {
+			return fmt.Errorf("subscriber error: %s", strings.Join(errors, "\n"))
+		}
+
+		return nil
+	}
+}
+
+func (s *httpSubscriber) Topic() string {
+	return s.topic
+}
+
+func (s *httpSubscriber) Subscriber() interface{} {
+	return s.subscriber
+}
+
+func (s *httpSubscriber) Endpoints() []*register.Endpoint {
+	return s.endpoints
+}
+
+func (s *httpSubscriber) Options() server.SubscriberOptions {
+	return s.opts
+}
--- a/tools.go
+++ b/tools.go
@@ -1,8 +0,0 @@
-//go:build tools
-
-package http
-
-import (
-	_ "go.unistack.org/micro-proto/v4"
-	_ "go.unistack.org/protoc-gen-go-micro/v4"
-)
--- a/util.go
+++ b/util.go
@@ -5,8 +5,8 @@ import (
 	"net/http"
 	"strings"

-	"go.unistack.org/micro/v4/metadata"
-	rutil "go.unistack.org/micro/v4/util/reflect"
+	"go.unistack.org/micro/v3/metadata"
+	rutil "go.unistack.org/micro/v3/util/reflect"
 )

 func FillRequest(ctx context.Context, req interface{}, opts ...FillRequestOption) error {
@@ -31,7 +31,7 @@ func FillRequest(ctx context.Context, req interface{}, opts ...FillRequestOption
 		}
 	}

-	cookies := md["Cookie"]
+	cookies := strings.Split(md["Cookie"], ";")
 	cmd := make(map[string]string, len(cookies))
 	for _, cookie := range cookies {
 		kv := strings.Split(cookie, "=")
--- a/util_test.go
+++ b/util_test.go
@@ -7,7 +7,7 @@ import (
 	"strings"
 	"testing"

-	"go.unistack.org/micro/v4/metadata"
+	"go.unistack.org/micro/v3/metadata"
 )

 func TestFillrequest(t *testing.T) {
Author	SHA1	Message	Date
Vasiliy Tolstov	542d4cec00	improve cors Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2024-03-18 16:38:18 +03:00
Vasiliy Tolstov	0ecd1da0dc	improve cors Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2024-03-18 16:25:52 +03:00
Vasiliy Tolstov	0a8755ecb7	fixup Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2024-03-18 15:57:08 +03:00
Vasiliy Tolstov	9c29d92d7f	fixup cors path handler Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2024-03-18 15:45:43 +03:00
Vasiliy Tolstov	b871c1be38	add cors option Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2024-03-18 14:51:40 +03:00
Василий Толстов	74bb12e75e	Merge pull request 'fix nil ptr' (#184 ) from devstigneev/micro-server-http:issue_179_v3 into v3 Reviewed-on: #184	2024-03-12 22:05:32 +03:00
Evstigneev Denis	49a95c183b	Merge remote-tracking branch 'main/v3' into issue_179_v3 # Conflicts: # http.go	2024-03-12 16:48:51 +03:00
Evstigneev Denis	5e6bd93a6b	fix nil ptr	2024-03-12 16:44:34 +03:00
Vasiliy Tolstov	9ef26caf40	fixup panic Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2024-03-12 00:50:08 +03:00
Vasiliy Tolstov	b3e58d2cb6	fixup handlers Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2024-03-12 00:03:51 +03:00
Vasiliy Tolstov	b89d9fdc5b	fixup headers Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2024-03-11 23:30:37 +03:00
Кирилл Горбунов	95dcdd6025	gzip for v3 #153 (#183 ) Co-authored-by: Кирилл Горбунов <kirya_gorbunov_2015@mail.ru> Co-committed-by: Кирилл Горбунов <kirya_gorbunov_2015@mail.ru>	2024-03-11 13:21:11 +03:00
Василий Толстов	abe5be3ddc	Merge pull request 'prepare for v3' (#181 ) from devstigneev/micro-server-http:issue_179_v3 into v3 Reviewed-on: #181	2024-03-09 13:59:21 +03:00
Evstigneev Denis	c3e6cdd973	prepare for v3	2024-03-09 10:06:13 +03:00
Vasiliy Tolstov	76dcf3af67	fixup redirect Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2024-02-10 23:46:19 +03:00
Vasiliy Tolstov	3e30960694	handler/pprof: clean prefix Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2024-02-09 00:16:34 +03:00
Василий Толстов	1643393377	Merge pull request 'handler/pprof: initial import' (#178 ) from pprof into v3 Reviewed-on: #178	2024-02-08 23:49:17 +03:00
Vasiliy Tolstov	313ae201af	handler/pprof: initial import Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2024-02-08 23:48:33 +03:00
Vasiliy Tolstov	069eaf4485	Merge pull request 'copy incoming content-type' (#177 ) from ct into v3 Reviewed-on: #177	2023-12-20 09:26:28 +03:00
Vasiliy Tolstov	fd670155aa	copy incoming content-type Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-12-20 09:26:06 +03:00
Vasiliy Tolstov	0e3a199e16	Merge pull request 'fix swagger handler' (#172 ) from handler-swagger into v3 Reviewed-on: #172	2023-08-14 13:43:50 +03:00
Vasiliy Tolstov	a665b69706	fix swagger handler Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-08-14 13:43:19 +03:00
Vasiliy Tolstov	90b7b7ec1c	fix swagger handler Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-08-14 13:42:51 +03:00
Vasiliy Tolstov	63ae848043	Merge pull request 'add tls headers' (#170 ) from tls_header into v3 Reviewed-on: #170	2023-08-03 10:43:47 +03:00
Vasiliy Tolstov	4d378bbd51	add tls headers Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-08-03 10:43:33 +03:00
Vasiliy Tolstov	60d165f907	add tls headers Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-08-03 10:42:54 +03:00
Vasiliy Tolstov	5a37de7d74	Merge pull request 'handler/swagger: initial import' (#169 ) from swagger into v3 Reviewed-on: #169	2023-06-18 17:29:16 +03:00
Vasiliy Tolstov	c7d8b6a3a4	handler/swagger: initial import Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-06-18 17:28:29 +03:00
Vasiliy Tolstov	cd3e2526b4	Merge pull request 'fix query param struct filling' (#167 ) from matchesfix into v3 Reviewed-on: #167	2023-05-29 12:27:16 +03:00
Vasiliy Tolstov	10ae1741fc	fix query param struct filling Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-05-29 12:26:56 +03:00
Vasiliy Tolstov	ca6cea861f	Merge pull request 'add scheme to metadata' (#165 ) from scheme-v3 into v3 Reviewed-on: #165	2023-05-19 23:25:59 +03:00
Vasiliy Tolstov	002d5c9c53	add scheme to metadata Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-05-19 23:25:22 +03:00
Vasiliy Tolstov	1d25e59860	Merge pull request 'move down path handler after specific handler' (#163 ) from path-handler-v3 into v3 Reviewed-on: #163	2023-05-19 23:04:16 +03:00
Vasiliy Tolstov	ce26e8bf63	move down path handler after specific handler Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-05-19 23:03:04 +03:00
Vasiliy Tolstov	8e09142b90	Merge pull request 'check subscribe errors' (#162 ) from subscribeerr into v3 Reviewed-on: #162	2023-05-13 16:09:47 +03:00
Vasiliy Tolstov	13bf2bbb1e	check subscribe errors Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-05-13 16:09:21 +03:00
Vasiliy Tolstov	ba292901d7	fixup build Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-05-09 21:14:55 +03:00
Vasiliy Tolstov	6d1b6c7014	allow to expose some method via http.HandlerFunc Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-05-09 21:13:11 +03:00
Vasiliy Tolstov	1276f99159	export Server to allow to cast Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-05-09 21:12:47 +03:00
Vasiliy Tolstov	ee5cbbbcb6	Merge pull request 'issue-155: add swagger-ui handler' (#157 ) from swaggerui into v3 Reviewed-on: #157	2023-05-04 06:51:42 +03:00
Vasiliy Tolstov	ce0abd2de3	issue-155: add swagger-ui handler Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2023-05-04 06:48:09 +03:00