Add Hammerhead Karoo provider

.gitignore

@@ -1 +1,2 @@
 dist
+coverage.out

go.mod

@@ -1,6 +1,6 @@
 module github.com/bzimmer/activity
 
-go 1.26.2
+go 1.26.5
 
 require (
 	github.com/bzimmer/httpwares v0.1.3
@@ -17,8 +17,8 @@ require (
 require (
 	github.com/davecgh/go-spew v1.1.1 // indirect
 	github.com/pmezard/go-difflib v1.0.0 // indirect
-	golang.org/x/net v0.53.0 // indirect
-	golang.org/x/text v0.36.0 // indirect
+	golang.org/x/net v0.55.0 // indirect
+	golang.org/x/text v0.37.0 // indirect
 	gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )

go.sum

@@ -40,14 +40,14 @@ github.com/twpayne/go-gpx v1.5.0 h1:HvFSJ+0r0sbhOQ8mTvd0/n0FhcgjTFsKQGG6o7PV6G4=
 github.com/twpayne/go-gpx v1.5.0/go.mod h1:vjvu/125399qj6k+px2v2v8dm08DM4I4dFBJmHHt2TE=
 github.com/twpayne/go-polyline v1.1.1 h1:/tSF1BR7rN4HWj4XKqvRUNrCiYVMCvywxTFVofvDV0w=
 github.com/twpayne/go-polyline v1.1.1/go.mod h1:ybd9IWWivW/rlXPXuuckeKUyF3yrIim+iqA7kSl4NFY=
-golang.org/x/net v0.53.0 h1:d+qAbo5L0orcWAr0a9JweQpjXF19LMXJE8Ey7hwOdUA=
-golang.org/x/net v0.53.0/go.mod h1:JvMuJH7rrdiCfbeHoo3fCQU24Lf5JJwT9W3sJFulfgs=
+golang.org/x/net v0.55.0 h1:bcvxaJn3e1U6InsFWt1JUq1aSjnRxLzT2rtD2KfkDF8=
+golang.org/x/net v0.55.0/go.mod h1:L5U2KuzuOe1lY7Z+aWVIKK6qEeJXnXV9yzGA+WCHJww=
 golang.org/x/oauth2 v0.36.0 h1:peZ/1z27fi9hUOFCAZaHyrpWG5lwe0RJEEEeH0ThlIs=
 golang.org/x/oauth2 v0.36.0/go.mod h1:YDBUJMTkDnJS+A4BP4eZBjCqtokkg1hODuPjwiGPO7Q=
 golang.org/x/sync v0.20.0 h1:e0PTpb7pjO8GAtTs2dQ6jYa5BWYlMuX047Dco/pItO4=
 golang.org/x/sync v0.20.0/go.mod h1:9xrNwdLfx4jkKbNva9FpL6vEN7evnE43NNNJQ2LF3+0=
-golang.org/x/text v0.36.0 h1:JfKh3XmcRPqZPKevfXVpI1wXPTqbkE5f7JA92a55Yxg=
-golang.org/x/text v0.36.0/go.mod h1:NIdBknypM8iqVmPiuco0Dh6P5Jcdk8lJL0CUebqK164=
+golang.org/x/text v0.37.0 h1:Cqjiwd9eSg8e0QAkyCaQTNHFIIzWtidPahFWR83rTrc=
+golang.org/x/text v0.37.0/go.mod h1:a5sjxXGs9hsn/AJVwuElvCAo9v8QYLzvavO5z2PiM38=
 golang.org/x/time v0.15.0 h1:bbrp8t3bGUeFOx08pvsMYRTCVSMk89u4tKbNOZbp88U=
 golang.org/x/time v0.15.0/go.mod h1:Y4YMaQmXwGQZoFaVFk4YpCt4FLQMYKZe9oeV/f4MSno=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=

hammerhead/activities.go

@@ -0,0 +1,117 @@
+package hammerhead
+
+import (
+	"context"
+	"fmt"
+	"net/http"
+	"net/url"
+
+	"github.com/bzimmer/activity"
+)
+
+const pageSize = 100
+
+// ActivitiesService provides access to Hammerhead activity endpoints
+type ActivitiesService service
+
+type activitiesPaginator struct {
+	service    ActivitiesService
+	activities []*ActivitySummary
+	startDate  string
+}
+
+func (p *activitiesPaginator) PageSize() int {
+	return pageSize
+}
+
+func (p *activitiesPaginator) Count() int {
+	return len(p.activities)
+}
+
+func (p *activitiesPaginator) Do(ctx context.Context, spec activity.Pagination) (int, error) {
+	v := url.Values{}
+	v.Set("page", fmt.Sprintf("%d", spec.Start))
+	v.Set("perPage", fmt.Sprintf("%d", spec.Count))
+	if p.startDate != "" {
+		v.Set("startDate", p.startDate)
+	}
+	req, err := p.service.client.newAPIRequest(ctx, http.MethodGet, "activities?"+v.Encode())
+	if err != nil {
+		return 0, err
+	}
+	res := &ActivitiesPage{}
+	if err = p.service.client.do(req, res); err != nil {
+		return 0, err
+	}
+	if spec.Total > 0 && len(p.activities)+len(res.Data) > spec.Total {
+		res.Data = res.Data[:spec.Total-len(p.activities)]
+	}
+	p.activities = append(p.activities, res.Data...)
+	if res.CurrentPage >= res.TotalPages {
+		return 0, nil
+	}
+	return len(res.Data), nil
+}
+
+// Activities returns a slice of activity summaries
+func (s *ActivitiesService) Activities(
+	ctx context.Context, spec activity.Pagination, startDate string) ([]*ActivitySummary, error) {
+	p := &activitiesPaginator{
+		service:    *s,
+		startDate:  startDate,
+		activities: make([]*ActivitySummary, 0),
+	}
+	if err := activity.Paginate(ctx, p, spec); err != nil {
+		return nil, err
+	}
+	return p.activities, nil
+}
+
+// Activity returns a single activity by ID
+func (s *ActivitiesService) Activity(ctx context.Context, activityID string) (*Activity, error) {
+	req, err := s.client.newAPIRequest(ctx, http.MethodGet, fmt.Sprintf("activities/%s", activityID))
+	if err != nil {
+		return nil, err
+	}
+	res := &Activity{}
+	if err = s.client.do(req, res); err != nil {
+		return nil, err
+	}
+	return res, nil
+}
+
+// File downloads the original FIT file for an activity
+func (s *ActivitiesService) File(ctx context.Context, activityID string) (*activity.File, error) {
+	req, err := s.client.newAPIRequest(ctx, http.MethodGet, fmt.Sprintf("activities/%s/file", activityID))
+	if err != nil {
+		return nil, err
+	}
+	res, err := s.client.base.HTTP.Do(req)
+	if err != nil {
+		return nil, err
+	}
+	if res.StatusCode >= http.StatusBadRequest {
+		defer res.Body.Close()
+		f := &Fault{}
+		f.SetDefaults(res.StatusCode, http.StatusText(res.StatusCode))
+		return nil, f
+	}
+	return &activity.File{
+		Reader:   res.Body,
+		Filename: fmt.Sprintf("%s.fit", activityID),
+		Name:     activityID,
+		Format:   activity.FormatFIT,
+	}, nil
+}
+
+// Export implements activity.Exporter by downloading the FIT file for an activity.
+// The activityID is provided as an int64 but Hammerhead uses string IDs in their API;
+// the int64 value is formatted as a decimal string for the request.
+func (s *ActivitiesService) Export(ctx context.Context, activityID int64) (*activity.Export, error) {
+	id := fmt.Sprintf("%d", activityID)
+	f, err := s.File(ctx, id)
+	if err != nil {
+		return nil, err
+	}
+	return &activity.Export{File: f, ID: activityID}, nil
+}