soapproxy

README

soapproxy

A simple SOAP <-> gRPC proxy.

1. Generate the WSDL

with ./protoc-gen-wsdl:

protoc --wsdl_out=myproxy -I $GOPATH/src $GOPATH/src/unosoft.hu/ws/bruno/pb/dealer/dealer.proto

will create myproxy/dealer.wsdl and myproxy/dealer.wsdl.go.

2. Generate the Client code

with github.com/UNO-SOFT/gprcer/protoc-gen-grpcer:

protoc --grpcer_out=myproxy -I $GOPATH/src $GOPATH/src/unosoft.hu/ws/bruno/pb/dealer/dealer.proto

will create myproxy/dealer.grpcer.go, with grpc.Client implementation in it.

3. Profit!

Then use the SOAPHandler in myproxy/main.go (see ./example/example.go):

cc, err := grpcer.Connect("grpc-host:port", "ca.pem", "localhost")
if err != nil {
	log.Fatal(err)
}
http.ListenAndServe(
	":8080",
	soapproxy.SOAPHandler{Client:NewClient(cc), WSDL:soapproxy.Ungzb64(WSDLgzb64)},
)

Documentation

Index

• Constants
• Variables
• func FilterEmptyTags(w io.Writer, r io.Reader) error
• func FindBody(dec *xml.Decoder) (xml.StartElement, error)
• func SOAPCall(ctx context.Context, destURL, action string, reqBody string, resp interface{}, ...) error
• func SOAPCallWithHeader(ctx context.Context, destURL string, customize func(req *http.Request), ...) error
• func SOAPCallWithHeaderClient(ctx context.Context, client *http.Client, destURL string, ...) error
• func Ungzb64(s string) string
• type Annotation
• type SOAPFault
• type SOAPHandler
  • func (h *SOAPHandler) DecodeRequest(ctx context.Context, r *http.Request) (grpcer.RequestInfo, interface{}, error)
  • func (h *SOAPHandler) Input(name string) interface{}
  • func (h *SOAPHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

Constants

const (
	SOAPHeader = `` /* 130-byte string literal not displayed */
	SOAPBody   = `</soapenv:Header><soapenv:Body>`
	SOAPFooter = `</soapenv:Body></soapenv:Envelope>`
)

Variables

var (
	DefaultCallTimeout = time.Minute
)

var DefaultTimeout = 5 * time.Minute

Functions

func FilterEmptyTags

func FilterEmptyTags(w io.Writer, r io.Reader) error

func FindBody

func FindBody(dec *xml.Decoder) (xml.StartElement, error)

FindBody will find the first StartElement after soap:Body.

func SOAPCall

func SOAPCall(ctx context.Context, destURL, action string, reqBody string, resp interface{}, Log func(...interface{}) error) error

SOAPCall destURL with SOAPAction=action, decoding the response body into resp.

func SOAPCallWithHeader

func SOAPCallWithHeader(ctx context.Context,
	destURL string, customize func(req *http.Request),
	action, soapHeader, reqBody string, resp interface{},
	Log func(...interface{}) error,
) error

SOAPCallWithHeader calls with the given SOAP- and extra header and action.

func SOAPCallWithHeaderClient

func SOAPCallWithHeaderClient(ctx context.Context,
	client *http.Client,
	destURL string, customize func(req *http.Request),
	action, soapHeader, reqBody string, resp interface{},
	Log func(...interface{}) error,
) error

SOAPCallWithHeader calls with the given SOAP- and extra header and action.

func Ungzb64

func Ungzb64(s string) string

Ungzb64 decodes-decompresses the given gzipped-base64-encoded string. Esp. useful for reading the WSDLgzb64 from protoc-gen-wsdl embedded WSDL strings.

Types

type Annotation

type Annotation struct {
	Raw      bool
	RemoveNS bool
}

type SOAPFault

type SOAPFault struct {
	XMLName xml.Name `xml:"SOAP-ENV:Fault"`
	Code    string   `xml:"faultcode,omitempty"`
	String  string   `xml:"faultstring,omitempty"`
	Actor   string   `xml:"faultactor,omitempty"`
	Detail  string   `xml:"detail>ExceptionDetail,omitempty"`
}

SOAPFault fault

type SOAPHandler

type SOAPHandler struct {
	grpcer.Client
	WSDL         string
	Log          func(keyvals ...interface{}) error
	Locations    []string
	DecodeInput  func(*string, *xml.Decoder, *xml.StartElement) (interface{}, error)
	EncodeOutput func(*xml.Encoder, interface{}) error
	DecodeHeader func(context.Context, *xml.Decoder, *xml.StartElement) (context.Context, func(context.Context, io.Writer, error) error, error)

	Timeout time.Duration
	// contains filtered or unexported fields
}

SOAPHandler is a http.Handler which proxies SOAP requests to the Client. WSDL is served on GET requests.

func (*SOAPHandler) DecodeRequest

func (h *SOAPHandler) DecodeRequest(ctx context.Context, r *http.Request) (grpcer.RequestInfo, interface{}, error)

func (*SOAPHandler) Input

func (h *SOAPHandler) Input(name string) interface{}

func (*SOAPHandler) ServeHTTP

func (h *SOAPHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)