Compare commits
No commits in common. "ea7d9768d0782ff097a1f6f3db1419420750f0d8" and "5466a2881cd4370ba6ecd52ba4fd89b2ca621728" have entirely different histories.
ea7d9768d0
...
5466a2881c
|
@ -5,7 +5,6 @@ import (
|
||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
"net/http"
|
"net/http"
|
||||||
"net/url"
|
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
@ -211,20 +210,17 @@ func (c *Client) requestHttpViaNats(data model.CommunicationRequestHttp, res int
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("onpoint: request via nats %v", err)
|
return fmt.Errorf("onpoint: request via nats %v", err)
|
||||||
}
|
}
|
||||||
u, err := url.ParseRequestURI(data.Payload.URL)
|
qs := ""
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("onpoint: request via nats %v", err)
|
|
||||||
}
|
|
||||||
q := u.Query()
|
|
||||||
for k, v := range data.Payload.Query {
|
for k, v := range data.Payload.Query {
|
||||||
q.Set(k, v)
|
if qs != "" {
|
||||||
|
qs += "&"
|
||||||
|
}
|
||||||
|
qs += k + "=" + v
|
||||||
}
|
}
|
||||||
u.RawQuery = q.Encode()
|
|
||||||
|
|
||||||
now := time.Now().Unix()
|
now := time.Now().Unix()
|
||||||
ts := strconv.FormatInt(now, 10)
|
ts := strconv.FormatInt(now, 10)
|
||||||
arr := []string{
|
arr := []string{
|
||||||
u.RawQuery,
|
qs,
|
||||||
data.Payload.Data,
|
data.Payload.Data,
|
||||||
ts,
|
ts,
|
||||||
}
|
}
|
||||||
|
@ -239,7 +235,6 @@ func (c *Client) requestHttpViaNats(data model.CommunicationRequestHttp, res int
|
||||||
headerXTimestamp: ts,
|
headerXTimestamp: ts,
|
||||||
httputil.HeaderKeyContentType: httputil.HeaderValueApplicationJSON,
|
httputil.HeaderKeyContentType: httputil.HeaderValueApplicationJSON,
|
||||||
}
|
}
|
||||||
data.Payload.Query = map[string]string{}
|
|
||||||
|
|
||||||
return ec.Request(subject.Communication.RequestHTTP, data, res)
|
return ec.Request(subject.Communication.RequestHTTP, data, res)
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue