exchanges: Update exchange templates

cmd/exchange_template/exchange_template.go

@@ -100,15 +100,6 @@ func main() {
 	if err != nil {
 		log.Fatal(err)
 	}
-
-	fmt.Println(`GoCryptoTrader: Exchange templating tool service complete
-Add appropriate exchange config settings, particularly enabled and available assets and pairs, to config_example.json for proper functionality (it has been automatically be added to testdata/configtest.json)
-When the exchange code implementation has been completed (REST/Websocket/wrappers and tests), please add the exchange to engine/exchange.go
-Increment the available exchanges counter in config/config_test.go
-Add the exchange name to exchanges/support.go
-Ensure go test ./... -race passes
-Open a pull request
-If help is needed, please post a message in Slack.`)
 }
 
 func checkExchangeName(exchName string) error {

cmd/exchange_template/rest.tmpl

@@ -15,7 +15,7 @@ type Exchange struct {
 }
 
 const (
-	apiURL = ""
+	apiURL     = ""
 	apiVersion = ""
 
 	// Public endpoints
@@ -26,8 +26,8 @@ const (
 // SendHTTPRequest sends an unauthenticated HTTP request
 func (e *Exchange) SendHTTPRequest(ctx context.Context, path string, result any) error {
 	// This is used to generate the *http.Request, used in conjunction with the
-	// generate functionality below. 
-	item := &request.Item{  
+	// generate functionality below.
+	item := &request.Item{
 		Method:        http.MethodGet,
 		Path:          path,
 		Result:        result,
@@ -37,12 +37,12 @@ func (e *Exchange) SendHTTPRequest(ctx context.Context, path string, result any)
 	}
 
 	// Request function that closes over the above request.Item values, which
-	// executes on every attempt after rate limiting. 
+	// executes on every attempt after rate limiting.
 	generate := func() (*request.Item, error) { return item, nil }
 
-	endpoint := request.Unset // Used in conjunction with the rate limiting 
+	endpoint := request.Unset // Used in conjunction with the rate limiting
 	// system defined in the exchange package to slow down outbound requests
-	// depending on each individual endpoint. 
+	// depending on each individual endpoint.
 	return e.SendPayload(ctx, endpoint, generate, request.UnauthenticatedRequest)
 }
 

cmd/exchange_template/subscriptions.tmpl

@@ -11,5 +11,4 @@ var defaultSubscriptions = subscription.List{
 	{Enabled: true, Asset: asset.All, Channel: subscription.TickerChannel},
 	{Enabled: true, Asset: asset.All, Channel: subscription.OrderbookChannel, Interval: kline.HundredMilliseconds},
 }
-
 {{end}}

cmd/exchange_template/types.tmpl

@@ -1,7 +1,8 @@
 {{define "types"}}
 package {{.Name}}
-{{end}}
-For efficiency, a JSON to Golang converter can be used: https://mholt.github.io/json-to-go/.
+/* For efficiency, a JSON to Golang converter can be used: https://mholt.github.io/json-to-go/.
 However, great care must be taken as to the values which are autogenerated. The JSON converter tool will default to whatever type it detects, 
 but ultimately conversions to a more useful variable type would be better. For example, price and quantity on some exchange API's provide these as strings. Internally, 
-it would be better if they're converted to the more useful float64 var type.
+it would be better if they're converted to the more useful float64 var type.
+*/
+{{end}}

cmd/exchange_template/websocket.tmpl

@@ -21,16 +21,16 @@ func (e *Exchange) WsConnect() error {
 	if !e.Websocket.IsEnabled() || !e.IsEnabled() {
 		return websocket.ErrWebsocketNotEnabled
 	}
-	var dialer gws.Dialer
-	dialer.HandshakeTimeout = e.Config.HTTPTimeout
-	dialer.Proxy = http.ProxyFromEnvironment
-
+	dialer := gws.Dialer{
+		HandshakeTimeout: e.Config.HTTPTimeout,
+		Proxy:            http.ProxyFromEnvironment,
+	}
+
 	if e.Websocket.CanUseAuthenticatedEndpoints() {
-        // Add WebSocket authentication logic here.
+		// Add WebSocket authentication logic here.
 	}
 
-	err := e.Websocket.Conn.Dial(ctx, &dialer, http.Header{})
-	if err != nil {
+	if err := e.Websocket.Conn.Dial(ctx, &dialer, http.Header{}); err != nil {
 		return fmt.Errorf("%v - Unable to connect to Websocket. Error: %s", e.Name, err)
 	}
 
@@ -39,7 +39,6 @@ func (e *Exchange) WsConnect() error {
 	return nil
 }
 
-
 // Subscribe sends a websocket message to receive data from the channel
 func (e *Exchange) Subscribe(_ subscription.List) error {
 	// ctx := context.TODO()
@@ -60,16 +59,15 @@ func (e *Exchange) wsReadData(ctx context.Context) {
 		if resp.Raw == nil {
 			return
 		}
-		err := e.wsHandleData(ctx, resp.Raw)
-		if err != nil {
-		    // e.Websocket.DataHandler <- err
+		if err := e.wsHandleData(ctx, resp.Raw); err != nil {
+			// e.Websocket.DataHandler &lt;- err
 		}
 	}
 }
 
 // wsHandleData processes a websocket incoming data.
 func (e *Exchange) wsHandleData(ctx context.Context, respData []byte) error {
-    // Implement message parsing and handling logic here.
+	// Implement message parsing and handling logic here.
 	return nil
 }