totole/m3o-go
1
0
Fork 0
mirror of https://github.com/kevin-DL/m3o-go.git synced 2026-01-22 22:55:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2 from m3o/fix-stream

Browse Source 
use v1 api for stream
This commit is contained in:
Asim Aslam
2021-04-21 13:53:14 +01:00
committed by GitHub
parent f7f75653ba 7b553cd374
commit 8d0170e51c
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
client/client.go
View File

@@ -92,7 +92,8 @@ func (client *Client) Call(service, endpoint string, request, response interface
if err != nil { if err != nil {
return err return err
} }
// TODO: make optional
// set the url to go through the v1 api
uri.Path = "/v1/" + service + "/" + endpoint uri.Path = "/v1/" + service + "/" + endpoint
b, err := marshalRequest(service, endpoint, request) b, err := marshalRequest(service, endpoint, request)
@@ -140,8 +141,9 @@ func (client *Client) Stream(service, endpoint string, request interface{}) (*St
if err != nil { if err != nil {
return nil, err return nil, err
} }
// TODO: make optional
uri.Path = "/client/stream" // set the url to go through the v1 api
uri.Path = "/v1/" + service + "/" + endpoint
// replace http with websocket // replace http with websocket
uri.Scheme = strings.Replace(uri.Scheme, "http", "ws", 1) uri.Scheme = strings.Replace(uri.Scheme, "http", "ws", 1)