resolved linting issues
This commit is contained in:
@@ -27,7 +27,9 @@ func (m *MockRegistryClient) Subscribe(ctx context.Context, subscription *model.
|
|||||||
func TestSubscribeSuccess(t *testing.T) {
|
func TestSubscribeSuccess(t *testing.T) {
|
||||||
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
w.WriteHeader(http.StatusOK)
|
w.WriteHeader(http.StatusOK)
|
||||||
w.Write([]byte("{}"))
|
if _, err := w.Write([]byte("{}")); err != nil {
|
||||||
|
t.Errorf("failed to write response: %v", err)
|
||||||
|
}
|
||||||
}))
|
}))
|
||||||
defer server.Close()
|
defer server.Close()
|
||||||
|
|
||||||
@@ -125,7 +127,9 @@ func TestLookupSuccess(t *testing.T) {
|
|||||||
},
|
},
|
||||||
}
|
}
|
||||||
bodyBytes, _ := json.Marshal(response)
|
bodyBytes, _ := json.Marshal(response)
|
||||||
w.Write(bodyBytes)
|
if _, err := w.Write(bodyBytes); err != nil {
|
||||||
|
t.Errorf("failed to write response: %v", err)
|
||||||
|
}
|
||||||
}))
|
}))
|
||||||
defer server.Close()
|
defer server.Close()
|
||||||
|
|
||||||
@@ -194,10 +198,14 @@ func TestLookupFailure(t *testing.T) {
|
|||||||
}
|
}
|
||||||
if tc.responseBody != nil {
|
if tc.responseBody != nil {
|
||||||
if str, ok := tc.responseBody.(string); ok {
|
if str, ok := tc.responseBody.(string); ok {
|
||||||
w.Write([]byte(str))
|
if _, err := w.Write([]byte(str)); err != nil {
|
||||||
|
t.Errorf("failed to write response: %v", err)
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
bodyBytes, _ := json.Marshal(tc.responseBody)
|
bodyBytes, _ := json.Marshal(tc.responseBody)
|
||||||
w.Write(bodyBytes)
|
if _, err := w.Write(bodyBytes); err != nil {
|
||||||
|
t.Errorf("failed to write response: %v", err)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}))
|
}))
|
||||||
|
|||||||
@@ -9,7 +9,6 @@ import (
|
|||||||
"path"
|
"path"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
"github.com/beckn/beckn-onix/pkg/log"
|
|
||||||
"github.com/beckn/beckn-onix/pkg/model"
|
"github.com/beckn/beckn-onix/pkg/model"
|
||||||
|
|
||||||
"gopkg.in/yaml.v3"
|
"gopkg.in/yaml.v3"
|
||||||
@@ -213,7 +212,6 @@ func (r *Router) Route(ctx context.Context, url *url.URL, body []byte) (*model.R
|
|||||||
if err := json.Unmarshal(body, &requestBody); err != nil {
|
if err := json.Unmarshal(body, &requestBody); err != nil {
|
||||||
return nil, fmt.Errorf("error parsing request body: %w", err)
|
return nil, fmt.Errorf("error parsing request body: %w", err)
|
||||||
}
|
}
|
||||||
log.Debugf(ctx, "In Router: Routing request with %v and body: %v", url, requestBody)
|
|
||||||
|
|
||||||
// Extract the endpoint from the URL
|
// Extract the endpoint from the URL
|
||||||
endpoint := path.Base(url.Path)
|
endpoint := path.Base(url.Path)
|
||||||
|
|||||||
Reference in New Issue
Block a user