Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions internal/tiger/analytics/analytics.go
Original file line number Diff line number Diff line change
Expand Up @@ -156,7 +156,7 @@ func (a *Analytics) Identify(options ...Option) {
defer cancel()

// Send the event
resp, err := a.client.PostAnalyticsIdentifyWithResponse(ctx, api.PostAnalyticsIdentifyJSONRequestBody{
resp, err := a.client.IdentifyUserWithResponse(ctx, api.IdentifyUserJSONRequestBody{
Properties: &properties,
})
if err != nil {
Expand Down Expand Up @@ -221,7 +221,7 @@ func (a *Analytics) Track(event string, options ...Option) {
defer cancel()

// Send the event
resp, err := a.client.PostAnalyticsTrackWithResponse(ctx, api.PostAnalyticsTrackJSONRequestBody{
resp, err := a.client.TrackEventWithResponse(ctx, api.TrackEventJSONRequestBody{
Event: event,
Properties: &properties,
})
Expand Down
1,508 changes: 754 additions & 754 deletions internal/tiger/api/client.go

Large diffs are not rendered by default.

4 changes: 2 additions & 2 deletions internal/tiger/api/client_util_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ func TestNewTigerClientUserAgent(t *testing.T) {

// Make a request to trigger the User-Agent header
ctx := context.Background()
_, err = client.GetProjectsProjectIdServicesWithResponse(ctx, "test-project-id")
_, err = client.GetServicesWithResponse(ctx, "test-project-id")
if err != nil {
t.Fatalf("Request failed: %v", err)
}
Expand Down Expand Up @@ -87,7 +87,7 @@ func TestNewTigerClientAuthorizationHeader(t *testing.T) {

// Make a request to trigger the Authorization header
ctx := context.Background()
_, err = client.GetProjectsProjectIdServicesWithResponse(ctx, "test-project-id")
_, err = client.GetServicesWithResponse(ctx, "test-project-id")
if err != nil {
t.Fatalf("Request failed: %v", err)
}
Expand Down
1,680 changes: 840 additions & 840 deletions internal/tiger/api/mocks/mock_client.go

Large diffs are not rendered by default.

72 changes: 36 additions & 36 deletions internal/tiger/api/types.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion internal/tiger/cmd/db.go
Original file line number Diff line number Diff line change
Expand Up @@ -781,7 +781,7 @@ func getServiceDetails(cmd *cobra.Command, cfg *common.Config, args []string) (a
ctx, cancel := context.WithTimeout(cmd.Context(), 30*time.Second)
defer cancel()

resp, err := cfg.Client.GetProjectsProjectIdServicesServiceIdWithResponse(ctx, cfg.ProjectID, serviceID)
resp, err := cfg.Client.GetServiceWithResponse(ctx, cfg.ProjectID, serviceID)
if err != nil {
return api.Service{}, fmt.Errorf("failed to fetch service details: %w", err)
}
Expand Down
2 changes: 1 addition & 1 deletion internal/tiger/cmd/password_recovery.go
Original file line number Diff line number Diff line change
Expand Up @@ -244,7 +244,7 @@ func updateAndSaveServicePassword(
) error {
// Call API to update password
updateReq := api.UpdatePasswordInput{Password: newPassword}
resp, err := client.PostProjectsProjectIdServicesServiceIdUpdatePasswordWithResponse(ctx, *service.ProjectId, *service.ServiceId, updateReq)
resp, err := client.UpdatePasswordWithResponse(ctx, *service.ProjectId, *service.ServiceId, updateReq)
if err != nil {
return fmt.Errorf("failed to update password: %w", err)
}
Expand Down
18 changes: 9 additions & 9 deletions internal/tiger/cmd/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ Examples:
ctx, cancel := context.WithTimeout(cmd.Context(), 30*time.Second)
defer cancel()

resp, err := cfg.Client.GetProjectsProjectIdServicesServiceIdWithResponse(ctx, cfg.ProjectID, serviceID)
resp, err := cfg.Client.GetServiceWithResponse(ctx, cfg.ProjectID, serviceID)
if err != nil {
return fmt.Errorf("failed to get service details: %w", err)
}
Expand Down Expand Up @@ -142,7 +142,7 @@ func buildServiceListCmd() *cobra.Command {
ctx, cancel := context.WithTimeout(cmd.Context(), 30*time.Second)
defer cancel()

resp, err := cfg.Client.GetProjectsProjectIdServicesWithResponse(ctx, cfg.ProjectID)
resp, err := cfg.Client.GetServicesWithResponse(ctx, cfg.ProjectID)
if err != nil {
return fmt.Errorf("failed to list services: %w", err)
}
Expand Down Expand Up @@ -313,7 +313,7 @@ Note: You can specify both CPU and memory together, or specify only one (the oth
} else {
fmt.Fprintf(statusOutput, "🚀 Creating service '%s' (auto-generated name)...\n", createServiceName)
}
resp, err := cfg.Client.PostProjectsProjectIdServicesWithResponse(ctx, cfg.ProjectID, serviceCreateReq)
resp, err := cfg.Client.CreateServiceWithResponse(ctx, cfg.ProjectID, serviceCreateReq)
if err != nil {
return fmt.Errorf("failed to create Service: %w", err)
}
Expand Down Expand Up @@ -465,7 +465,7 @@ Examples:
defer cancel()

// Fetch service details
serviceResp, err := cfg.Client.GetProjectsProjectIdServicesServiceIdWithResponse(ctx, cfg.ProjectID, serviceID)
serviceResp, err := cfg.Client.GetServiceWithResponse(ctx, cfg.ProjectID, serviceID)
if err != nil {
return fmt.Errorf("failed to get service details: %w", err)
}
Expand Down Expand Up @@ -848,7 +848,7 @@ Examples:
}

// Make the delete request
resp, err := cfg.Client.DeleteProjectsProjectIdServicesServiceIdWithResponse(
resp, err := cfg.Client.DeleteServiceWithResponse(
cmd.Context(),
api.ProjectId(cfg.ProjectID),
api.ServiceId(serviceID),
Expand Down Expand Up @@ -940,7 +940,7 @@ Examples:
cmd.SilenceUsage = true

// Make the start request
resp, err := cfg.Client.PostProjectsProjectIdServicesServiceIdStartWithResponse(
resp, err := cfg.Client.StartServiceWithResponse(
context.Background(),
api.ProjectId(cfg.ProjectID),
api.ServiceId(serviceID),
Expand Down Expand Up @@ -1036,7 +1036,7 @@ Examples:
cmd.SilenceUsage = true

// Make the stop request
resp, err := cfg.Client.PostProjectsProjectIdServicesServiceIdStopWithResponse(
resp, err := cfg.Client.StopServiceWithResponse(
context.Background(),
api.ProjectId(cfg.ProjectID),
api.ServiceId(serviceID),
Expand Down Expand Up @@ -1250,7 +1250,7 @@ Examples:
}

// Make API call to fork service
forkResp, err := cfg.Client.PostProjectsProjectIdServicesServiceIdForkServiceWithResponse(ctx, cfg.ProjectID, serviceID, forkReq)
forkResp, err := cfg.Client.ForkServiceWithResponse(ctx, cfg.ProjectID, serviceID, forkReq)
if err != nil {
return fmt.Errorf("failed to fork Service: %w", err)
}
Expand Down Expand Up @@ -1365,7 +1365,7 @@ func listServices(cmd *cobra.Command) ([]api.Service, error) {
ctx, cancel := context.WithTimeout(cmd.Context(), 30*time.Second)
defer cancel()

resp, err := cfg.Client.GetProjectsProjectIdServicesWithResponse(ctx, cfg.ProjectID)
resp, err := cfg.Client.GetServicesWithResponse(ctx, cfg.ProjectID)
if err != nil {
return nil, fmt.Errorf("failed to list services: %w", err)
}
Expand Down
8 changes: 4 additions & 4 deletions internal/tiger/common/wait.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ type WaitHandler interface {
// continue. It also returns an error, which is either immediately returned
// from WaitForService or temporarily shown next to the spinner depending
// on the first return value.
Check(resp *api.GetProjectsProjectIdServicesServiceIdResponse) (bool, error)
Check(resp *api.GetServiceResponse) (bool, error)
}

type WaitForServiceArgs struct {
Expand Down Expand Up @@ -56,7 +56,7 @@ func WaitForService(ctx context.Context, args WaitForServiceArgs) error {
return fmt.Errorf("error waiting - %s: %w", args.TimeoutMsg, ctx.Err())
}
case <-ticker.C:
resp, err := args.Client.GetProjectsProjectIdServicesServiceIdWithResponse(ctx, args.ProjectID, args.ServiceID)
resp, err := args.Client.GetServiceWithResponse(ctx, args.ProjectID, args.ServiceID)
if err != nil {
spinner.Update(fmt.Sprintf("Error checking service status: %s", err))
continue
Expand All @@ -83,7 +83,7 @@ func (h *StatusWaitHandler) Message() string {
return fmt.Sprintf("Service status: %s", util.DerefStr(h.Service.Status))
}

func (h *StatusWaitHandler) Check(resp *api.GetProjectsProjectIdServicesServiceIdResponse) (bool, error) {
func (h *StatusWaitHandler) Check(resp *api.GetServiceResponse) (bool, error) {
switch resp.StatusCode() {
case 200:
if resp.JSON200 == nil {
Expand Down Expand Up @@ -122,7 +122,7 @@ func (h *DeletionWaitHandler) Message() string {
return fmt.Sprintf("Waiting for service '%s' to be deleted", h.ServiceID)
}

func (h *DeletionWaitHandler) Check(resp *api.GetProjectsProjectIdServicesServiceIdResponse) (bool, error) {
func (h *DeletionWaitHandler) Check(resp *api.GetServiceResponse) (bool, error) {
switch resp.StatusCode() {
case 200:
return false, nil
Expand Down
2 changes: 1 addition & 1 deletion internal/tiger/mcp/db_tools.go
Original file line number Diff line number Diff line change
Expand Up @@ -145,7 +145,7 @@ func (s *Server) handleDBExecuteQuery(ctx context.Context, req *mcp.CallToolRequ
)

// Get service details to construct connection string
serviceResp, err := cfg.Client.GetProjectsProjectIdServicesServiceIdWithResponse(ctx, cfg.ProjectID, input.ServiceID)
serviceResp, err := cfg.Client.GetServiceWithResponse(ctx, cfg.ProjectID, input.ServiceID)
if err != nil {
return nil, DBExecuteQueryOutput{}, fmt.Errorf("failed to get service details: %w", err)
}
Expand Down
16 changes: 8 additions & 8 deletions internal/tiger/mcp/service_tools.go
Original file line number Diff line number Diff line change
Expand Up @@ -467,7 +467,7 @@ func (s *Server) handleServiceList(ctx context.Context, req *mcp.CallToolRequest
ctx, cancel := context.WithTimeout(ctx, 30*time.Second)
defer cancel()

resp, err := cfg.Client.GetProjectsProjectIdServicesWithResponse(ctx, cfg.ProjectID)
resp, err := cfg.Client.GetServicesWithResponse(ctx, cfg.ProjectID)
if err != nil {
return nil, ServiceListOutput{}, fmt.Errorf("failed to list services: %w", err)
}
Expand Down Expand Up @@ -509,7 +509,7 @@ func (s *Server) handleServiceGet(ctx context.Context, req *mcp.CallToolRequest,
ctx, cancel := context.WithTimeout(ctx, 30*time.Second)
defer cancel()

resp, err := cfg.Client.GetProjectsProjectIdServicesServiceIdWithResponse(ctx, cfg.ProjectID, input.ServiceID)
resp, err := cfg.Client.GetServiceWithResponse(ctx, cfg.ProjectID, input.ServiceID)
if err != nil {
return nil, ServiceGetOutput{}, fmt.Errorf("failed to get service details: %w", err)
}
Expand Down Expand Up @@ -577,7 +577,7 @@ func (s *Server) handleServiceCreate(ctx context.Context, req *mcp.CallToolReque
createCtx, cancel := context.WithTimeout(ctx, 30*time.Second)
defer cancel()

resp, err := cfg.Client.PostProjectsProjectIdServicesWithResponse(createCtx, cfg.ProjectID, serviceCreateReq)
resp, err := cfg.Client.CreateServiceWithResponse(createCtx, cfg.ProjectID, serviceCreateReq)
if err != nil {
return nil, ServiceCreateOutput{}, fmt.Errorf("failed to create service: %w", err)
}
Expand Down Expand Up @@ -699,7 +699,7 @@ func (s *Server) handleServiceFork(ctx context.Context, req *mcp.CallToolRequest
forkCtx, cancel := context.WithTimeout(ctx, 30*time.Second)
defer cancel()

resp, err := cfg.Client.PostProjectsProjectIdServicesServiceIdForkServiceWithResponse(forkCtx, cfg.ProjectID, input.ServiceID, forkReq)
resp, err := cfg.Client.ForkServiceWithResponse(forkCtx, cfg.ProjectID, input.ServiceID, forkReq)
if err != nil {
return nil, ServiceForkOutput{}, fmt.Errorf("failed to fork service: %w", err)
}
Expand Down Expand Up @@ -786,7 +786,7 @@ func (s *Server) handleServiceUpdatePassword(ctx context.Context, req *mcp.CallT
ctx, cancel := context.WithTimeout(ctx, 30*time.Second)
defer cancel()

resp, err := cfg.Client.PostProjectsProjectIdServicesServiceIdUpdatePasswordWithResponse(ctx, cfg.ProjectID, input.ServiceID, updateReq)
resp, err := cfg.Client.UpdatePasswordWithResponse(ctx, cfg.ProjectID, input.ServiceID, updateReq)
if err != nil {
return nil, ServiceUpdatePasswordOutput{}, fmt.Errorf("failed to update service password: %w", err)
}
Expand All @@ -798,7 +798,7 @@ func (s *Server) handleServiceUpdatePassword(ctx context.Context, req *mcp.CallT

// Get service details for password storage (similar to CLI implementation)
var passwordStorage *common.PasswordStorageResult
serviceResp, err := cfg.Client.GetProjectsProjectIdServicesServiceIdWithResponse(ctx, cfg.ProjectID, input.ServiceID)
serviceResp, err := cfg.Client.GetServiceWithResponse(ctx, cfg.ProjectID, input.ServiceID)
if err == nil && serviceResp.StatusCode() == 200 && serviceResp.JSON200 != nil {
// Save the new password using the shared util function
result, err := common.SavePasswordWithResult(api.Service(*serviceResp.JSON200), input.Password, "tsdbadmin")
Expand Down Expand Up @@ -834,7 +834,7 @@ func (s *Server) handleServiceStart(ctx context.Context, req *mcp.CallToolReques
startCtx, cancel := context.WithTimeout(ctx, 30*time.Second)
defer cancel()

resp, err := cfg.Client.PostProjectsProjectIdServicesServiceIdStartWithResponse(startCtx, cfg.ProjectID, input.ServiceID)
resp, err := cfg.Client.StartServiceWithResponse(startCtx, cfg.ProjectID, input.ServiceID)
if err != nil {
return nil, ServiceStartOutput{}, fmt.Errorf("failed to start service: %w", err)
}
Expand Down Expand Up @@ -891,7 +891,7 @@ func (s *Server) handleServiceStop(ctx context.Context, req *mcp.CallToolRequest
stopCtx, cancel := context.WithTimeout(ctx, 30*time.Second)
defer cancel()

resp, err := cfg.Client.PostProjectsProjectIdServicesServiceIdStopWithResponse(stopCtx, cfg.ProjectID, input.ServiceID)
resp, err := cfg.Client.StopServiceWithResponse(stopCtx, cfg.ProjectID, input.ServiceID)
if err != nil {
return nil, ServiceStopOutput{}, fmt.Errorf("failed to stop service: %w", err)
}
Expand Down
Loading