Merge pull request #30 from necryin/new_currencies

new currrencies + auth errors

rest_domain.go

@@ -8,6 +8,12 @@ const (
 	RUB Currency = "RUB"
 	USD Currency = "USD"
 	EUR Currency = "EUR"
+	TRY Currency = "TRY"
+	JPY Currency = "JPY"
+	CNY Currency = "CNY"
+	CHF Currency = "CHF"
+	GBP Currency = "GBP"
+	HKD Currency = "HKD"
 )
 
 type OperationType string

streaming_client.go

@@ -169,6 +169,9 @@ func (c *StreamingClient) UnsubscribeInstrumentInfo(figi, requestID string) erro
 	return nil
 }
 
+var ErrForbidden = errors.New("invalid token")
+var ErrUnauthorized = errors.New("token not provided")
+
 func (c *StreamingClient) connect() (*websocket.Conn, error) {
 	dialer := websocket.Dialer{
 		Proxy:            http.ProxyFromEnvironment,
@@ -177,6 +180,16 @@ func (c *StreamingClient) connect() (*websocket.Conn, error) {
 
 	conn, resp, err := dialer.Dial(c.apiURL, http.Header{"Authorization": {"Bearer " + c.token}})
 	if err != nil {
+		if resp != nil {
+			if resp.StatusCode == http.StatusForbidden {
+				return nil, ErrForbidden
+			}
+			if resp.StatusCode == http.StatusUnauthorized {
+				return nil, ErrUnauthorized
+			}
+
+			return nil, errors.Wrapf(err, "can't connect to %s %s", c.apiURL, resp.Status)
+		}
 		return nil, errors.Wrapf(err, "can't connect to %s", c.apiURL)
 	}
 	defer resp.Body.Close()