adyxax/spacetraders
1
0
Fork 0
Code Issues Activity

[golang] simplified the api design some more

Browse source
This commit is contained in:
Julien Dessaux 2024-05-30 08:05:03 +02:00
parent 860984057d
commit 4069b524b2
Signed by: adyxax
GPG key ID: F92E51B86E07177E
7 changed files with 56 additions and 86 deletions
Download patch file Download diff file Expand all files Collapse all files

21
golang/pkg/api/api.go
View file

@ -43,7 +43,7 @@ type Response struct {
Err error
}
func (c *Client) Send(method string, uriRef *url.URL, payload any) (*APIMessage, error) {
func (c *Client) Send(method string, uriRef *url.URL, payload any, response any) error {
responseChannel := make(chan *Response)
c.requestsChannel <- &Request{
method: method,
@ -53,7 +53,24 @@ func (c *Client) Send(method string, uriRef *url.URL, payload any) (*APIMessage,
uri: c.baseURI.ResolveReference(uriRef),
}
res := <-responseChannel
return res.Message, res.Err
if res.Err != nil {
return res.Err
}
err := res.Message.Error
if err != nil {
switch err.Code {
case 4214:
e := decodeShipInTransitError(err.Data)
time.Sleep(e.SecondsToArrival.Duration() * time.Second)
return c.Send(method, uriRef, payload, response)
default:
return err
}
}
if err := json.Unmarshal(res.Message.Data, &response); err != nil {
return fmt.Errorf("failed to unmarshal message: %w", err)
}
return nil
}
func queueProcessor(client *Client) {