Merge pull request #2 from sumo-mcp/workspace

Add basho rikishi changes APIs

Author: matheuscscp

basho.go

@@ -12,8 +12,12 @@ type BashoID struct {
 	Month int // Month is 1-12.
 }
 
+func (b BashoID) String() string {
+	return fmt.Sprintf("%04d%02d", b.Year, b.Month)
+}
+
 func (b BashoID) MarshalJSON() ([]byte, error) {
-	return []byte(`"` + fmt.Sprintf("%04d%02d", b.Year, b.Month) + `"`), nil
+	return []byte(`"` + b.String() + `"`), nil
 }
 
 func (b *BashoID) UnmarshalJSON(data []byte) error {

basho_rikishi_id.go

@@ -7,11 +7,15 @@ import (
 	"io"
 	"net/http"
 	"net/url"
+	"strings"
 )
 
 // Client is a client for the Sumo API.
 type Client interface {
 	SearchRikishisAPI
+	ListRankChangesAPI
+	ListShikonaChangesAPI
+	ListMeasurementChangesAPI
 }
 
 type client struct {
@@ -39,13 +43,22 @@ func New(opts ...Option) Client {
 	return client
 }
 
-func doRequest[obj any](ctx context.Context, c *client, method, path string, query url.Values) (*obj, error) {
+func (c *client) doRequest(ctx context.Context, method, path string, query url.Values, obj any) ([]byte, error) {
 	u := fmt.Sprintf("https://sumo-api.com/api%s", path)
 	if len(query) > 0 {
 		u = fmt.Sprintf("%s?%s", u, query.Encode())
 	}
 
-	req, err := http.NewRequestWithContext(ctx, method, u, nil)
+	var body io.Reader
+	if obj != nil {
+		b, err := json.Marshal(obj)
+		if err != nil {
+			return nil, fmt.Errorf("error marshaling request body: %w", err)
+		}
+		body = strings.NewReader(string(b))
+	}
+
+	req, err := http.NewRequestWithContext(ctx, method, u, body)
 	if err != nil {
 		return nil, fmt.Errorf("error creating http request: %w", err)
 	}
@@ -74,10 +87,36 @@ func doRequest[obj any](ctx context.Context, c *client, method, path string, que
 		return nil, fmt.Errorf("error reading response body: %w", err)
 	}
 
+	return b, nil
+}
+
+func getObject[obj any](ctx context.Context, c *client, path string, query url.Values) (*obj, error) {
+	b, err := c.doRequest(ctx, http.MethodGet, path, query, nil)
+	if err != nil {
+		return nil, err
+	}
 	var o obj
 	if err := json.Unmarshal(b, &o); err != nil {
 		return nil, fmt.Errorf("error unmarshaling response body: %w", err)
 	}
-
 	return &o, nil
 }
+
+func listObjects[obj any](ctx context.Context, c *client, path string, query url.Values) ([]obj, error) {
+	b, err := c.doRequest(ctx, http.MethodGet, path, query, nil)
+	if err != nil {
+		return nil, err
+	}
+	var l []obj
+	if err := json.Unmarshal(b, &l); err != nil {
+		return nil, fmt.Errorf("error unmarshaling response body: %w", err)
+	}
+	return l, nil
+}
+
+func getSortOrder(order string) string {
+	if o := strings.ToLower(strings.TrimSpace(order)); o == "asc" || o == "desc" {
+		return o
+	}
+	return ""
+}

basho_rikishi_id_test.go

@@ -0,0 +1,13 @@
+package sumoapi
+
+import "context"
+
+// ListMeasurementChangesAPI defines the methods available for listing Rikishi measurement changes across bashos (sumo tournaments).
+type ListMeasurementChangesAPI interface {
+	// ListMeasurementChanges calls the GET /api/measurements endpoint.
+	ListMeasurementChanges(ctx context.Context, req ListRikishiChangesRequest) ([]Measurement, error)
+}
+
+func (c *client) ListMeasurementChanges(ctx context.Context, req ListRikishiChangesRequest) ([]Measurement, error) {
+	return listRikishiChanges[Measurement](ctx, c, "/measurements", req)
+}