Pyxis
/
orion
17
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Create generic method to implements the request/response pattern

This commit is contained in:
wpetit 2018-09-20 17:20:52 +02:00
parent a44e40eea2
commit ba3d85f48b
3 changed files with 32 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
go.mod
View File

@ -6,6 +6,7 @@ require (
github.com/davecgh/go-spew v1.1.1 // indirect
github.com/go-chi/chi v3.3.3+incompatible
github.com/gorilla/websocket v1.4.0 // indirect
github.com/mitchellh/mapstructure v1.0.0
github.com/pkg/errors v0.8.0
github.com/pmezard/go-difflib v1.0.0 // indirect
github.com/stretchr/testify v1.2.2 // indirect

2
go.sum
View File

@ -8,6 +8,8 @@ github.com/go-chi/chi v3.3.3+incompatible h1:KHkmBEMNkwKuK4FdQL7N2wOeB9jnIx7jR5w
github.com/go-chi/chi v3.3.3+incompatible/go.mod h1:eB3wogJHnLi3x/kFX2A+IbTBlXxmMeXJVKy9tTv1XzQ=
github.com/gorilla/websocket v1.4.0 h1:WDFjx/TMzVgy9VdMMQi2K2Emtwi2QcUQsztZ/zLaH/Q=
github.com/gorilla/websocket v1.4.0/go.mod h1:E7qHFY5m1UJ88s3WnNqhKjPHQ0heANvMoAMk2YaljkQ=
github.com/mitchellh/mapstructure v1.0.0 h1:vVpGvMXJPqSDh2VYHF7gsfQj8Ncx+Xw5Y1KHeTRY+7I=
github.com/mitchellh/mapstructure v1.0.0/go.mod h1:FVVH3fgwuzCH5S8UJGiWEs2h04kUh9fWfEaFds41c1Y=
github.com/pkg/errors v0.8.0 h1:WdK/asTD0HN+q6hsWO3/vpuAkAr+tw6aNJNDFFf0+qw=
github.com/pkg/errors v0.8.0/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=

29
reach/client.go
View File

@ -5,6 +5,7 @@ import (
"forge.cadoles.com/Pyxis/golang-socketio"
"forge.cadoles.com/Pyxis/golang-socketio/transport"
"github.com/mitchellh/mapstructure"
"github.com/pkg/errors"
)
@ -72,6 +73,34 @@ func (c *client) Close() {
c.conn = nil
}
func (c *client) fetch(requestEvent string, requestData interface{}, responseEvent string, res interface{}) error {
var err error
var wg sync.WaitGroup
wg.Add(1)
err = c.conn.On(responseEvent, func(_ *gosocketio.Channel, data interface{}) {
err = mapstructure.Decode(data, res)
c.conn.Off(responseEvent)
wg.Done()
})
if err != nil {
return errors.Wrapf(err, "error while binding to '%s' event", responseEvent)
}
c.logf("sending '%s' event", requestEvent)
if err = c.conn.Emit(requestEvent, requestData); err != nil {
return errors.Wrapf(err, "error while emitting '%s' event", requestEvent)
}
c.logf("'%s' event sent", requestEvent)
wg.Wait()
return err
}
func (c *client) logf(format string, args ...interface{}) {
if c.opts.Logger == nil {
return