From 97c342a86d6214d05bd450c5f1bb4bc02634e532 Mon Sep 17 00:00:00 2001 From: Murad Biashimov Date: Wed, 7 Feb 2024 11:27:02 +0100 Subject: [PATCH] fix(generator): add missing err return --- client_generated.go | 1 + generator/main.go | 4 +- handler/account/account.go | 36 ++++++++++ .../accountauthentication.go | 12 ++++ handler/accountteam/accountteam.go | 12 ++++ .../accountteammember/accountteammember.go | 6 ++ handler/billinggroup/billinggroup.go | 30 ++++++++ handler/clickhouse/clickhouse.go | 6 ++ handler/cloud/cloud.go | 6 ++ handler/domain/domain.go | 12 ++++ handler/flink/flink.go | 3 + handler/flinkapplication/flinkapplication.go | 15 ++++ .../flinkapplicationdeployment.go | 18 +++++ .../flinkapplicationversion.go | 12 ++++ handler/flinkjob/flinkjob.go | 6 ++ handler/kafka/kafka.go | 24 +++++++ handler/kafkaconnect/kafkaconnect.go | 18 +++++ handler/kafkamirrormaker/kafkamirrormaker.go | 9 +++ .../kafkaschemaregistry.go | 33 +++++++++ handler/kafkatopic/kafkatopic.go | 12 ++++ handler/mysql/mysql.go | 3 + handler/opensearch/opensearch.go | 21 ++++++ handler/organization/organization.go | 21 ++++++ handler/organizationuser/organizationuser.go | 21 ++++++ handler/postgresql/postgresql.go | 9 +++ handler/privatelink/privatelink.go | 39 ++++++++++ handler/project/project.go | 36 ++++++++++ handler/projectbilling/projectbilling.go | 9 +++ handler/service/service.go | 72 +++++++++++++++++++ .../serviceintegration/serviceintegration.go | 30 ++++++++ handler/serviceuser/serviceuser.go | 12 ++++ handler/staticip/staticip.go | 21 ++++++ handler/user/user.go | 54 ++++++++++++++ handler/usergroup/usergroup.go | 15 ++++ handler/vpc/vpc.go | 27 +++++++ 35 files changed, 664 insertions(+), 1 deletion(-) diff --git a/client_generated.go b/client_generated.go index 7c67138..d692b7f 100644 --- a/client_generated.go +++ b/client_generated.go @@ -4,6 +4,7 @@ package aiven import ( "context" + account "github.com/aiven/go-client-codegen/handler/account" accountauthentication "github.com/aiven/go-client-codegen/handler/accountauthentication" accountteam "github.com/aiven/go-client-codegen/handler/accountteam" diff --git a/generator/main.go b/generator/main.go index b28dc9b..2144b82 100644 --- a/generator/main.go +++ b/generator/main.go @@ -314,9 +314,11 @@ func exec() error { ), } + ifErr := jen.If(jen.Err().Op("!=").Nil()).Block(returnErr) if rsp == nil { block = append(block, jen.Return(jen.Err())) } else { + block = append(block, ifErr) outReturn := jen.Id("out") if rsp.CamelName != schemaOut.CamelName { // Takes original name and turns to camel. @@ -333,7 +335,7 @@ func exec() error { block, jen.Id("out").Op(":=").New(jen.Id(schemaOut.CamelName)), jen.Err().Op("=").Qual("encoding/json", "Unmarshal").Call(jen.Id("b"), jen.Id("out")), - jen.If(jen.Err().Op("!=").Nil()).Block(returnErr), + ifErr, jen.Return(outReturn, jen.Nil()), ) } diff --git a/handler/account/account.go b/handler/account/account.go index fa61d27..026555f 100644 --- a/handler/account/account.go +++ b/handler/account/account.go @@ -96,6 +96,9 @@ type AccountHandler struct { func (h *AccountHandler) AccountAttachPaymentMethod(ctx context.Context, accountId string, in *AccountAttachPaymentMethodIn) (*AccountAttachPaymentMethodOut, error) { path := fmt.Sprintf("/account/%s/payment_methods", accountId) b, err := h.doer.Do(ctx, "AccountAttachPaymentMethod", "POST", path, in) + if err != nil { + return nil, err + } out := new(accountAttachPaymentMethodOut) err = json.Unmarshal(b, out) if err != nil { @@ -106,6 +109,9 @@ func (h *AccountHandler) AccountAttachPaymentMethod(ctx context.Context, account func (h *AccountHandler) AccountBillingGroupList(ctx context.Context, accountId string) ([]AccountBillingGroupOut, error) { path := fmt.Sprintf("/account/%s/billing-group", accountId) b, err := h.doer.Do(ctx, "AccountBillingGroupList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(accountBillingGroupListOut) err = json.Unmarshal(b, out) if err != nil { @@ -116,6 +122,9 @@ func (h *AccountHandler) AccountBillingGroupList(ctx context.Context, accountId func (h *AccountHandler) AccountCreate(ctx context.Context, in *AccountCreateIn) (*AccountCreateOut, error) { path := fmt.Sprintf("/account") b, err := h.doer.Do(ctx, "AccountCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(accountCreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -131,6 +140,9 @@ func (h *AccountHandler) AccountDelete(ctx context.Context, accountId string) er func (h *AccountHandler) AccountEventList(ctx context.Context, accountId string) ([]EventOut, error) { path := fmt.Sprintf("/account/%s/events", accountId) b, err := h.doer.Do(ctx, "AccountEventList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(accountEventListOut) err = json.Unmarshal(b, out) if err != nil { @@ -141,6 +153,9 @@ func (h *AccountHandler) AccountEventList(ctx context.Context, accountId string) func (h *AccountHandler) AccountGet(ctx context.Context, accountId string) (*AccountGetOut, error) { path := fmt.Sprintf("/account/%s", accountId) b, err := h.doer.Do(ctx, "AccountGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(accountGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -151,6 +166,9 @@ func (h *AccountHandler) AccountGet(ctx context.Context, accountId string) (*Acc func (h *AccountHandler) AccountList(ctx context.Context) ([]AccountOut, error) { path := fmt.Sprintf("/account") b, err := h.doer.Do(ctx, "AccountList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(accountListOut) err = json.Unmarshal(b, out) if err != nil { @@ -161,6 +179,9 @@ func (h *AccountHandler) AccountList(ctx context.Context) ([]AccountOut, error) func (h *AccountHandler) AccountMove(ctx context.Context, accountId string, in *AccountMoveIn) (*AccountMoveOut, error) { path := fmt.Sprintf("/account/%s/parent_account", accountId) b, err := h.doer.Do(ctx, "AccountMove", "PUT", path, in) + if err != nil { + return nil, err + } out := new(accountMoveOut) err = json.Unmarshal(b, out) if err != nil { @@ -176,6 +197,9 @@ func (h *AccountHandler) AccountPaymentMethodDelete(ctx context.Context, account func (h *AccountHandler) AccountPaymentMethodsList(ctx context.Context, accountId string) ([]CardOut, error) { path := fmt.Sprintf("/account/%s/payment_methods", accountId) b, err := h.doer.Do(ctx, "AccountPaymentMethodsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(accountPaymentMethodsListOut) err = json.Unmarshal(b, out) if err != nil { @@ -186,6 +210,9 @@ func (h *AccountHandler) AccountPaymentMethodsList(ctx context.Context, accountI func (h *AccountHandler) AccountProjectsList(ctx context.Context, accountId string) (*AccountProjectsListOut, error) { path := fmt.Sprintf("/account/%s/projects", accountId) b, err := h.doer.Do(ctx, "AccountProjectsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(AccountProjectsListOut) err = json.Unmarshal(b, out) if err != nil { @@ -196,6 +223,9 @@ func (h *AccountHandler) AccountProjectsList(ctx context.Context, accountId stri func (h *AccountHandler) AccountUpdate(ctx context.Context, accountId string, in *AccountUpdateIn) (*AccountUpdateOut, error) { path := fmt.Sprintf("/account/%s", accountId) b, err := h.doer.Do(ctx, "AccountUpdate", "PUT", path, in) + if err != nil { + return nil, err + } out := new(accountUpdateOut) err = json.Unmarshal(b, out) if err != nil { @@ -206,6 +236,9 @@ func (h *AccountHandler) AccountUpdate(ctx context.Context, accountId string, in func (h *AccountHandler) AccountUserProjectsList(ctx context.Context, accountId string, userId string) ([]UserProjectOut, error) { path := fmt.Sprintf("/account/%s/user/%s/projects", accountId, userId) b, err := h.doer.Do(ctx, "AccountUserProjectsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(accountUserProjectsListOut) err = json.Unmarshal(b, out) if err != nil { @@ -216,6 +249,9 @@ func (h *AccountHandler) AccountUserProjectsList(ctx context.Context, accountId func (h *AccountHandler) AccountUsersSearch(ctx context.Context, accountId string, in *AccountUsersSearchIn) ([]UserOut, error) { path := fmt.Sprintf("/account/%s/users/search", accountId) b, err := h.doer.Do(ctx, "AccountUsersSearch", "POST", path, in) + if err != nil { + return nil, err + } out := new(accountUsersSearchOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/accountauthentication/accountauthentication.go b/handler/accountauthentication/accountauthentication.go index dfc7bf0..af250ea 100644 --- a/handler/accountauthentication/accountauthentication.go +++ b/handler/accountauthentication/accountauthentication.go @@ -51,6 +51,9 @@ type AccountAuthenticationHandler struct { func (h *AccountAuthenticationHandler) AccountAuthenticationMethodCreate(ctx context.Context, accountId string, in *AccountAuthenticationMethodCreateIn) (*AccountAuthenticationMethodCreateOut, error) { path := fmt.Sprintf("/account/%s/authentication", accountId) b, err := h.doer.Do(ctx, "AccountAuthenticationMethodCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(accountAuthenticationMethodCreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -66,6 +69,9 @@ func (h *AccountAuthenticationHandler) AccountAuthenticationMethodDelete(ctx con func (h *AccountAuthenticationHandler) AccountAuthenticationMethodGet(ctx context.Context, accountId string, accountAuthenticationMethodId string) (*AccountAuthenticationMethodGetOut, error) { path := fmt.Sprintf("/account/%s/authentication/%s", accountId, accountAuthenticationMethodId) b, err := h.doer.Do(ctx, "AccountAuthenticationMethodGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(accountAuthenticationMethodGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -76,6 +82,9 @@ func (h *AccountAuthenticationHandler) AccountAuthenticationMethodGet(ctx contex func (h *AccountAuthenticationHandler) AccountAuthenticationMethodUpdate(ctx context.Context, accountId string, accountAuthenticationMethodId string, in *AccountAuthenticationMethodUpdateIn) (*AccountAuthenticationMethodUpdateOut, error) { path := fmt.Sprintf("/account/%s/authentication/%s", accountId, accountAuthenticationMethodId) b, err := h.doer.Do(ctx, "AccountAuthenticationMethodUpdate", "PUT", path, in) + if err != nil { + return nil, err + } out := new(accountAuthenticationMethodUpdateOut) err = json.Unmarshal(b, out) if err != nil { @@ -86,6 +95,9 @@ func (h *AccountAuthenticationHandler) AccountAuthenticationMethodUpdate(ctx con func (h *AccountAuthenticationHandler) AccountAuthenticationMethodsList(ctx context.Context, accountId string) ([]AuthenticationMethodOut, error) { path := fmt.Sprintf("/account/%s/authentication", accountId) b, err := h.doer.Do(ctx, "AccountAuthenticationMethodsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(accountAuthenticationMethodsListOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/accountteam/accountteam.go b/handler/accountteam/accountteam.go index e815e17..100efa2 100644 --- a/handler/accountteam/accountteam.go +++ b/handler/accountteam/accountteam.go @@ -66,6 +66,9 @@ func (h *AccountTeamHandler) AccountTeamDelete(ctx context.Context, accountId st func (h *AccountTeamHandler) AccountTeamGet(ctx context.Context, accountId string, teamId string) (*AccountTeamGetOut, error) { path := fmt.Sprintf("/account/%s/team/%s", accountId, teamId) b, err := h.doer.Do(ctx, "AccountTeamGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(accountTeamGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -76,6 +79,9 @@ func (h *AccountTeamHandler) AccountTeamGet(ctx context.Context, accountId strin func (h *AccountTeamHandler) AccountTeamInvitesList(ctx context.Context, accountId string, teamId string) ([]AccountInviteOut, error) { path := fmt.Sprintf("/account/%s/team/%s/invites", accountId, teamId) b, err := h.doer.Do(ctx, "AccountTeamInvitesList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(accountTeamInvitesListOut) err = json.Unmarshal(b, out) if err != nil { @@ -86,6 +92,9 @@ func (h *AccountTeamHandler) AccountTeamInvitesList(ctx context.Context, account func (h *AccountTeamHandler) AccountTeamList(ctx context.Context, accountId string) ([]TeamOut, error) { path := fmt.Sprintf("/account/%s/teams", accountId) b, err := h.doer.Do(ctx, "AccountTeamList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(accountTeamListOut) err = json.Unmarshal(b, out) if err != nil { @@ -106,6 +115,9 @@ func (h *AccountTeamHandler) AccountTeamProjectDisassociate(ctx context.Context, func (h *AccountTeamHandler) AccountTeamUpdate(ctx context.Context, accountId string, teamId string, in *AccountTeamUpdateIn) (*AccountTeamUpdateOut, error) { path := fmt.Sprintf("/account/%s/team/%s", accountId, teamId) b, err := h.doer.Do(ctx, "AccountTeamUpdate", "PUT", path, in) + if err != nil { + return nil, err + } out := new(accountTeamUpdateOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/accountteammember/accountteammember.go b/handler/accountteammember/accountteammember.go index 1eb63d1..ee8adeb 100644 --- a/handler/accountteammember/accountteammember.go +++ b/handler/accountteammember/accountteammember.go @@ -51,6 +51,9 @@ func (h *AccountTeamMemberHandler) AccountTeamMemberCancelInvite(ctx context.Con func (h *AccountTeamMemberHandler) AccountTeamMemberVerifyInvite(ctx context.Context, accountId string, inviteVerificationCode string) (*AccountTeamMemberVerifyInviteOut, error) { path := fmt.Sprintf("/account/%s/invite/%s", accountId, inviteVerificationCode) b, err := h.doer.Do(ctx, "AccountTeamMemberVerifyInvite", "POST", path, nil) + if err != nil { + return nil, err + } out := new(accountTeamMemberVerifyInviteOut) err = json.Unmarshal(b, out) if err != nil { @@ -66,6 +69,9 @@ func (h *AccountTeamMemberHandler) AccountTeamMembersInvite(ctx context.Context, func (h *AccountTeamMemberHandler) AccountTeamMembersList(ctx context.Context, accountId string, teamId string) ([]MemberOut, error) { path := fmt.Sprintf("/account/%s/team/%s/members", accountId, teamId) b, err := h.doer.Do(ctx, "AccountTeamMembersList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(accountTeamMembersListOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/billinggroup/billinggroup.go b/handler/billinggroup/billinggroup.go index 6a1cee3..e01eed0 100644 --- a/handler/billinggroup/billinggroup.go +++ b/handler/billinggroup/billinggroup.go @@ -91,6 +91,9 @@ type BillingGroupHandler struct { func (h *BillingGroupHandler) BillingGroupCreate(ctx context.Context, in *BillingGroupCreateIn) (*BillingGroupCreateOut, error) { path := fmt.Sprintf("/billing-group") b, err := h.doer.Do(ctx, "BillingGroupCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(billingGroupCreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -101,6 +104,9 @@ func (h *BillingGroupHandler) BillingGroupCreate(ctx context.Context, in *Billin func (h *BillingGroupHandler) BillingGroupCreditsClaim(ctx context.Context, billingGroupId string, in *BillingGroupCreditsClaimIn) (*BillingGroupCreditsClaimOut, error) { path := fmt.Sprintf("/billing-group/%s/credits", billingGroupId) b, err := h.doer.Do(ctx, "BillingGroupCreditsClaim", "POST", path, in) + if err != nil { + return nil, err + } out := new(billingGroupCreditsClaimOut) err = json.Unmarshal(b, out) if err != nil { @@ -111,6 +117,9 @@ func (h *BillingGroupHandler) BillingGroupCreditsClaim(ctx context.Context, bill func (h *BillingGroupHandler) BillingGroupCreditsList(ctx context.Context, billingGroupId string) ([]CreditOut, error) { path := fmt.Sprintf("/billing-group/%s/credits", billingGroupId) b, err := h.doer.Do(ctx, "BillingGroupCreditsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(billingGroupCreditsListOut) err = json.Unmarshal(b, out) if err != nil { @@ -126,6 +135,9 @@ func (h *BillingGroupHandler) BillingGroupDelete(ctx context.Context, billingGro func (h *BillingGroupHandler) BillingGroupEventList(ctx context.Context, billingGroupId string) ([]EventOut, error) { path := fmt.Sprintf("/billing-group/%s/events", billingGroupId) b, err := h.doer.Do(ctx, "BillingGroupEventList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(billingGroupEventListOut) err = json.Unmarshal(b, out) if err != nil { @@ -136,6 +148,9 @@ func (h *BillingGroupHandler) BillingGroupEventList(ctx context.Context, billing func (h *BillingGroupHandler) BillingGroupGet(ctx context.Context, billingGroupId string) (*BillingGroupGetOut, error) { path := fmt.Sprintf("/billing-group/%s", billingGroupId) b, err := h.doer.Do(ctx, "BillingGroupGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(billingGroupGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -146,6 +161,9 @@ func (h *BillingGroupHandler) BillingGroupGet(ctx context.Context, billingGroupI func (h *BillingGroupHandler) BillingGroupInvoiceLinesList(ctx context.Context, billingGroupId string, invoiceNumber string) ([]LineOut, error) { path := fmt.Sprintf("/billing-group/%s/invoice/%s/lines", billingGroupId, invoiceNumber) b, err := h.doer.Do(ctx, "BillingGroupInvoiceLinesList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(billingGroupInvoiceLinesListOut) err = json.Unmarshal(b, out) if err != nil { @@ -156,6 +174,9 @@ func (h *BillingGroupHandler) BillingGroupInvoiceLinesList(ctx context.Context, func (h *BillingGroupHandler) BillingGroupInvoiceList(ctx context.Context, billingGroupId string) ([]InvoiceOut, error) { path := fmt.Sprintf("/billing-group/%s/invoice", billingGroupId) b, err := h.doer.Do(ctx, "BillingGroupInvoiceList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(billingGroupInvoiceListOut) err = json.Unmarshal(b, out) if err != nil { @@ -166,6 +187,9 @@ func (h *BillingGroupHandler) BillingGroupInvoiceList(ctx context.Context, billi func (h *BillingGroupHandler) BillingGroupList(ctx context.Context) ([]BillingGroupOut, error) { path := fmt.Sprintf("/billing-group") b, err := h.doer.Do(ctx, "BillingGroupList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(billingGroupListOut) err = json.Unmarshal(b, out) if err != nil { @@ -181,6 +205,9 @@ func (h *BillingGroupHandler) BillingGroupProjectAssign(ctx context.Context, bil func (h *BillingGroupHandler) BillingGroupProjectList(ctx context.Context, billingGroupId string) ([]ProjectOut, error) { path := fmt.Sprintf("/billing-group/%s/projects", billingGroupId) b, err := h.doer.Do(ctx, "BillingGroupProjectList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(billingGroupProjectListOut) err = json.Unmarshal(b, out) if err != nil { @@ -196,6 +223,9 @@ func (h *BillingGroupHandler) BillingGroupProjectsAssign(ctx context.Context, bi func (h *BillingGroupHandler) BillingGroupUpdate(ctx context.Context, billingGroupId string, in *BillingGroupUpdateIn) (*BillingGroupUpdateOut, error) { path := fmt.Sprintf("/billing-group/%s", billingGroupId) b, err := h.doer.Do(ctx, "BillingGroupUpdate", "PUT", path, in) + if err != nil { + return nil, err + } out := new(billingGroupUpdateOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/clickhouse/clickhouse.go b/handler/clickhouse/clickhouse.go index bcb0f90..d45f10a 100644 --- a/handler/clickhouse/clickhouse.go +++ b/handler/clickhouse/clickhouse.go @@ -55,6 +55,9 @@ func (h *ClickHouseHandler) ServiceClickHouseDatabaseDelete(ctx context.Context, func (h *ClickHouseHandler) ServiceClickHouseQueryStats(ctx context.Context, project string, serviceName string) ([]QueryOut, error) { path := fmt.Sprintf("/project/%s/service/%s/clickhouse/query/stats", project, serviceName) b, err := h.doer.Do(ctx, "ServiceClickHouseQueryStats", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceClickHouseQueryStatsOut) err = json.Unmarshal(b, out) if err != nil { @@ -65,6 +68,9 @@ func (h *ClickHouseHandler) ServiceClickHouseQueryStats(ctx context.Context, pro func (h *ClickHouseHandler) ServiceClickHouseTieredStorageSummary(ctx context.Context, project string, serviceName string) (*ServiceClickHouseTieredStorageSummaryOut, error) { path := fmt.Sprintf("/project/%s/service/%s/clickhouse/tiered-storage/summary", project, serviceName) b, err := h.doer.Do(ctx, "ServiceClickHouseTieredStorageSummary", "GET", path, nil) + if err != nil { + return nil, err + } out := new(ServiceClickHouseTieredStorageSummaryOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/cloud/cloud.go b/handler/cloud/cloud.go index b1b9ade..ae37b37 100644 --- a/handler/cloud/cloud.go +++ b/handler/cloud/cloud.go @@ -35,6 +35,9 @@ type CloudHandler struct { func (h *CloudHandler) ListClouds(ctx context.Context) ([]CloudOut, error) { path := fmt.Sprintf("/clouds") b, err := h.doer.Do(ctx, "ListClouds", "GET", path, nil) + if err != nil { + return nil, err + } out := new(listCloudsOut) err = json.Unmarshal(b, out) if err != nil { @@ -45,6 +48,9 @@ func (h *CloudHandler) ListClouds(ctx context.Context) ([]CloudOut, error) { func (h *CloudHandler) ListProjectClouds(ctx context.Context, project string) ([]CloudOut, error) { path := fmt.Sprintf("/project/%s/clouds", project) b, err := h.doer.Do(ctx, "ListProjectClouds", "GET", path, nil) + if err != nil { + return nil, err + } out := new(listProjectCloudsOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/domain/domain.go b/handler/domain/domain.go index 8b38e4e..386bb25 100644 --- a/handler/domain/domain.go +++ b/handler/domain/domain.go @@ -51,6 +51,9 @@ type DomainHandler struct { func (h *DomainHandler) OrganizationDomainAdd(ctx context.Context, organizationId string, in *OrganizationDomainAddIn) (*OrganizationDomainAddOut, error) { path := fmt.Sprintf("/organization/%s/domains", organizationId) b, err := h.doer.Do(ctx, "OrganizationDomainAdd", "POST", path, in) + if err != nil { + return nil, err + } out := new(OrganizationDomainAddOut) err = json.Unmarshal(b, out) if err != nil { @@ -61,6 +64,9 @@ func (h *DomainHandler) OrganizationDomainAdd(ctx context.Context, organizationI func (h *DomainHandler) OrganizationDomainUpdate(ctx context.Context, organizationId string, domainId string, in *OrganizationDomainUpdateIn) (*OrganizationDomainUpdateOut, error) { path := fmt.Sprintf("/organization/%s/domains/%s", organizationId, domainId) b, err := h.doer.Do(ctx, "OrganizationDomainUpdate", "PATCH", path, in) + if err != nil { + return nil, err + } out := new(OrganizationDomainUpdateOut) err = json.Unmarshal(b, out) if err != nil { @@ -71,6 +77,9 @@ func (h *DomainHandler) OrganizationDomainUpdate(ctx context.Context, organizati func (h *DomainHandler) OrganizationDomainVerify(ctx context.Context, organizationId string, domainId string) (*OrganizationDomainVerifyOut, error) { path := fmt.Sprintf("/organization/%s/domains/%s/verify", organizationId, domainId) b, err := h.doer.Do(ctx, "OrganizationDomainVerify", "POST", path, nil) + if err != nil { + return nil, err + } out := new(OrganizationDomainVerifyOut) err = json.Unmarshal(b, out) if err != nil { @@ -81,6 +90,9 @@ func (h *DomainHandler) OrganizationDomainVerify(ctx context.Context, organizati func (h *DomainHandler) OrganizationDomainsList(ctx context.Context, organizationId string) ([]DomainOut, error) { path := fmt.Sprintf("/organization/%s/domains", organizationId) b, err := h.doer.Do(ctx, "OrganizationDomainsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(organizationDomainsListOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/flink/flink.go b/handler/flink/flink.go index 6c8ba90..5055ef2 100644 --- a/handler/flink/flink.go +++ b/handler/flink/flink.go @@ -30,6 +30,9 @@ type FlinkHandler struct { func (h *FlinkHandler) ServiceFlinkOverview(ctx context.Context, project string, serviceName string) (*ServiceFlinkOverviewOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/overview", project, serviceName) b, err := h.doer.Do(ctx, "ServiceFlinkOverview", "GET", path, nil) + if err != nil { + return nil, err + } out := new(ServiceFlinkOverviewOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/flinkapplication/flinkapplication.go b/handler/flinkapplication/flinkapplication.go index db3a652..8f7b2cb 100644 --- a/handler/flinkapplication/flinkapplication.go +++ b/handler/flinkapplication/flinkapplication.go @@ -51,6 +51,9 @@ type FlinkApplicationHandler struct { func (h *FlinkApplicationHandler) ServiceFlinkCreateApplication(ctx context.Context, project string, serviceName string, in *ServiceFlinkCreateApplicationIn) (*ServiceFlinkCreateApplicationOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/application", project, serviceName) b, err := h.doer.Do(ctx, "ServiceFlinkCreateApplication", "POST", path, in) + if err != nil { + return nil, err + } out := new(ServiceFlinkCreateApplicationOut) err = json.Unmarshal(b, out) if err != nil { @@ -61,6 +64,9 @@ func (h *FlinkApplicationHandler) ServiceFlinkCreateApplication(ctx context.Cont func (h *FlinkApplicationHandler) ServiceFlinkDeleteApplication(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkDeleteApplicationOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s", project, serviceName, applicationId) b, err := h.doer.Do(ctx, "ServiceFlinkDeleteApplication", "DELETE", path, nil) + if err != nil { + return nil, err + } out := new(ServiceFlinkDeleteApplicationOut) err = json.Unmarshal(b, out) if err != nil { @@ -71,6 +77,9 @@ func (h *FlinkApplicationHandler) ServiceFlinkDeleteApplication(ctx context.Cont func (h *FlinkApplicationHandler) ServiceFlinkGetApplication(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkGetApplicationOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s", project, serviceName, applicationId) b, err := h.doer.Do(ctx, "ServiceFlinkGetApplication", "GET", path, nil) + if err != nil { + return nil, err + } out := new(ServiceFlinkGetApplicationOut) err = json.Unmarshal(b, out) if err != nil { @@ -81,6 +90,9 @@ func (h *FlinkApplicationHandler) ServiceFlinkGetApplication(ctx context.Context func (h *FlinkApplicationHandler) ServiceFlinkListApplications(ctx context.Context, project string, serviceName string) ([]ApplicationOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/application", project, serviceName) b, err := h.doer.Do(ctx, "ServiceFlinkListApplications", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceFlinkListApplicationsOut) err = json.Unmarshal(b, out) if err != nil { @@ -91,6 +103,9 @@ func (h *FlinkApplicationHandler) ServiceFlinkListApplications(ctx context.Conte func (h *FlinkApplicationHandler) ServiceFlinkUpdateApplication(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkUpdateApplicationIn) (*ServiceFlinkUpdateApplicationOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s", project, serviceName, applicationId) b, err := h.doer.Do(ctx, "ServiceFlinkUpdateApplication", "PUT", path, in) + if err != nil { + return nil, err + } out := new(ServiceFlinkUpdateApplicationOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/flinkapplicationdeployment/flinkapplicationdeployment.go b/handler/flinkapplicationdeployment/flinkapplicationdeployment.go index 17a6755..518cff1 100644 --- a/handler/flinkapplicationdeployment/flinkapplicationdeployment.go +++ b/handler/flinkapplicationdeployment/flinkapplicationdeployment.go @@ -56,6 +56,9 @@ type FlinkApplicationDeploymentHandler struct { func (h *FlinkApplicationDeploymentHandler) ServiceFlinkCancelApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkCancelApplicationDeploymentOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/deployment/%s/cancel", project, serviceName, applicationId, deploymentId) b, err := h.doer.Do(ctx, "ServiceFlinkCancelApplicationDeployment", "POST", path, nil) + if err != nil { + return nil, err + } out := new(ServiceFlinkCancelApplicationDeploymentOut) err = json.Unmarshal(b, out) if err != nil { @@ -66,6 +69,9 @@ func (h *FlinkApplicationDeploymentHandler) ServiceFlinkCancelApplicationDeploym func (h *FlinkApplicationDeploymentHandler) ServiceFlinkCreateApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkCreateApplicationDeploymentIn) (*ServiceFlinkCreateApplicationDeploymentOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/deployment", project, serviceName, applicationId) b, err := h.doer.Do(ctx, "ServiceFlinkCreateApplicationDeployment", "POST", path, in) + if err != nil { + return nil, err + } out := new(ServiceFlinkCreateApplicationDeploymentOut) err = json.Unmarshal(b, out) if err != nil { @@ -76,6 +82,9 @@ func (h *FlinkApplicationDeploymentHandler) ServiceFlinkCreateApplicationDeploym func (h *FlinkApplicationDeploymentHandler) ServiceFlinkDeleteApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkDeleteApplicationDeploymentOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/deployment/%s", project, serviceName, applicationId, deploymentId) b, err := h.doer.Do(ctx, "ServiceFlinkDeleteApplicationDeployment", "DELETE", path, nil) + if err != nil { + return nil, err + } out := new(ServiceFlinkDeleteApplicationDeploymentOut) err = json.Unmarshal(b, out) if err != nil { @@ -86,6 +95,9 @@ func (h *FlinkApplicationDeploymentHandler) ServiceFlinkDeleteApplicationDeploym func (h *FlinkApplicationDeploymentHandler) ServiceFlinkGetApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkGetApplicationDeploymentOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/deployment/%s", project, serviceName, applicationId, deploymentId) b, err := h.doer.Do(ctx, "ServiceFlinkGetApplicationDeployment", "GET", path, nil) + if err != nil { + return nil, err + } out := new(ServiceFlinkGetApplicationDeploymentOut) err = json.Unmarshal(b, out) if err != nil { @@ -96,6 +108,9 @@ func (h *FlinkApplicationDeploymentHandler) ServiceFlinkGetApplicationDeployment func (h *FlinkApplicationDeploymentHandler) ServiceFlinkListApplicationDeployments(ctx context.Context, project string, serviceName string, applicationId string) ([]DeploymentOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/deployment", project, serviceName, applicationId) b, err := h.doer.Do(ctx, "ServiceFlinkListApplicationDeployments", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceFlinkListApplicationDeploymentsOut) err = json.Unmarshal(b, out) if err != nil { @@ -106,6 +121,9 @@ func (h *FlinkApplicationDeploymentHandler) ServiceFlinkListApplicationDeploymen func (h *FlinkApplicationDeploymentHandler) ServiceFlinkStopApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkStopApplicationDeploymentOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/deployment/%s/stop", project, serviceName, applicationId, deploymentId) b, err := h.doer.Do(ctx, "ServiceFlinkStopApplicationDeployment", "POST", path, nil) + if err != nil { + return nil, err + } out := new(ServiceFlinkStopApplicationDeploymentOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/flinkapplicationversion/flinkapplicationversion.go b/handler/flinkapplicationversion/flinkapplicationversion.go index f21e2bc..f4a52dc 100644 --- a/handler/flinkapplicationversion/flinkapplicationversion.go +++ b/handler/flinkapplicationversion/flinkapplicationversion.go @@ -46,6 +46,9 @@ type FlinkApplicationVersionHandler struct { func (h *FlinkApplicationVersionHandler) ServiceFlinkCreateApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkCreateApplicationVersionIn) (*ServiceFlinkCreateApplicationVersionOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/version", project, serviceName, applicationId) b, err := h.doer.Do(ctx, "ServiceFlinkCreateApplicationVersion", "POST", path, in) + if err != nil { + return nil, err + } out := new(ServiceFlinkCreateApplicationVersionOut) err = json.Unmarshal(b, out) if err != nil { @@ -56,6 +59,9 @@ func (h *FlinkApplicationVersionHandler) ServiceFlinkCreateApplicationVersion(ct func (h *FlinkApplicationVersionHandler) ServiceFlinkDeleteApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, applicationVersionId string) (*ServiceFlinkDeleteApplicationVersionOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/version/%s", project, serviceName, applicationId, applicationVersionId) b, err := h.doer.Do(ctx, "ServiceFlinkDeleteApplicationVersion", "DELETE", path, nil) + if err != nil { + return nil, err + } out := new(ServiceFlinkDeleteApplicationVersionOut) err = json.Unmarshal(b, out) if err != nil { @@ -66,6 +72,9 @@ func (h *FlinkApplicationVersionHandler) ServiceFlinkDeleteApplicationVersion(ct func (h *FlinkApplicationVersionHandler) ServiceFlinkGetApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, applicationVersionId string) (*ServiceFlinkGetApplicationVersionOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/version/%s", project, serviceName, applicationId, applicationVersionId) b, err := h.doer.Do(ctx, "ServiceFlinkGetApplicationVersion", "GET", path, nil) + if err != nil { + return nil, err + } out := new(ServiceFlinkGetApplicationVersionOut) err = json.Unmarshal(b, out) if err != nil { @@ -76,6 +85,9 @@ func (h *FlinkApplicationVersionHandler) ServiceFlinkGetApplicationVersion(ctx c func (h *FlinkApplicationVersionHandler) ServiceFlinkValidateApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkValidateApplicationVersionIn) (*ServiceFlinkValidateApplicationVersionOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/version/validate", project, serviceName, applicationId) b, err := h.doer.Do(ctx, "ServiceFlinkValidateApplicationVersion", "POST", path, in) + if err != nil { + return nil, err + } out := new(ServiceFlinkValidateApplicationVersionOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/flinkjob/flinkjob.go b/handler/flinkjob/flinkjob.go index 97feeb4..5d877f5 100644 --- a/handler/flinkjob/flinkjob.go +++ b/handler/flinkjob/flinkjob.go @@ -35,6 +35,9 @@ type FlinkJobHandler struct { func (h *FlinkJobHandler) ServiceFlinkJobDetails(ctx context.Context, project string, serviceName string, jobId string) (*ServiceFlinkJobDetailsOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/job/%s", project, serviceName, jobId) b, err := h.doer.Do(ctx, "ServiceFlinkJobDetails", "GET", path, nil) + if err != nil { + return nil, err + } out := new(ServiceFlinkJobDetailsOut) err = json.Unmarshal(b, out) if err != nil { @@ -45,6 +48,9 @@ func (h *FlinkJobHandler) ServiceFlinkJobDetails(ctx context.Context, project st func (h *FlinkJobHandler) ServiceFlinkJobsList(ctx context.Context, project string, serviceName string) ([]JobOut, error) { path := fmt.Sprintf("/project/%s/service/%s/flink/job", project, serviceName) b, err := h.doer.Do(ctx, "ServiceFlinkJobsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceFlinkJobsListOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/kafka/kafka.go b/handler/kafka/kafka.go index 06f0ea1..35a6e53 100644 --- a/handler/kafka/kafka.go +++ b/handler/kafka/kafka.go @@ -75,6 +75,9 @@ type KafkaHandler struct { func (h *KafkaHandler) ServiceKafkaAclAdd(ctx context.Context, project string, serviceName string, in *ServiceKafkaAclAddIn) ([]AclOut, error) { path := fmt.Sprintf("/project/%s/service/%s/acl", project, serviceName) b, err := h.doer.Do(ctx, "ServiceKafkaAclAdd", "POST", path, in) + if err != nil { + return nil, err + } out := new(serviceKafkaAclAddOut) err = json.Unmarshal(b, out) if err != nil { @@ -85,6 +88,9 @@ func (h *KafkaHandler) ServiceKafkaAclAdd(ctx context.Context, project string, s func (h *KafkaHandler) ServiceKafkaAclDelete(ctx context.Context, project string, serviceName string, kafkaAclId string) ([]AclOut, error) { path := fmt.Sprintf("/project/%s/service/%s/acl/%s", project, serviceName, kafkaAclId) b, err := h.doer.Do(ctx, "ServiceKafkaAclDelete", "DELETE", path, nil) + if err != nil { + return nil, err + } out := new(serviceKafkaAclDeleteOut) err = json.Unmarshal(b, out) if err != nil { @@ -95,6 +101,9 @@ func (h *KafkaHandler) ServiceKafkaAclDelete(ctx context.Context, project string func (h *KafkaHandler) ServiceKafkaAclList(ctx context.Context, project string, serviceName string) ([]AclOut, error) { path := fmt.Sprintf("/project/%s/service/%s/acl", project, serviceName) b, err := h.doer.Do(ctx, "ServiceKafkaAclList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceKafkaAclListOut) err = json.Unmarshal(b, out) if err != nil { @@ -115,6 +124,9 @@ func (h *KafkaHandler) ServiceKafkaQuotaDelete(ctx context.Context, project stri func (h *KafkaHandler) ServiceKafkaQuotaDescribe(ctx context.Context, project string, serviceName string) (*ServiceKafkaQuotaDescribeOut, error) { path := fmt.Sprintf("/project/%s/service/%s/quota/describe", project, serviceName) b, err := h.doer.Do(ctx, "ServiceKafkaQuotaDescribe", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceKafkaQuotaDescribeOut) err = json.Unmarshal(b, out) if err != nil { @@ -125,6 +137,9 @@ func (h *KafkaHandler) ServiceKafkaQuotaDescribe(ctx context.Context, project st func (h *KafkaHandler) ServiceKafkaQuotaList(ctx context.Context, project string, serviceName string) ([]QuotaOut, error) { path := fmt.Sprintf("/project/%s/service/%s/quota", project, serviceName) b, err := h.doer.Do(ctx, "ServiceKafkaQuotaList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceKafkaQuotaListOut) err = json.Unmarshal(b, out) if err != nil { @@ -135,6 +150,9 @@ func (h *KafkaHandler) ServiceKafkaQuotaList(ctx context.Context, project string func (h *KafkaHandler) ServiceKafkaTieredStorageStorageUsageByTopic(ctx context.Context, project string, serviceName string) (map[string]any, error) { path := fmt.Sprintf("/project/%s/service/%s/kafka/tiered-storage/storage-usage/by-topic", project, serviceName) b, err := h.doer.Do(ctx, "ServiceKafkaTieredStorageStorageUsageByTopic", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceKafkaTieredStorageStorageUsageByTopicOut) err = json.Unmarshal(b, out) if err != nil { @@ -145,6 +163,9 @@ func (h *KafkaHandler) ServiceKafkaTieredStorageStorageUsageByTopic(ctx context. func (h *KafkaHandler) ServiceKafkaTieredStorageStorageUsageTotal(ctx context.Context, project string, serviceName string) (int, error) { path := fmt.Sprintf("/project/%s/service/%s/kafka/tiered-storage/storage-usage/total", project, serviceName) b, err := h.doer.Do(ctx, "ServiceKafkaTieredStorageStorageUsageTotal", "GET", path, nil) + if err != nil { + return 0, err + } out := new(serviceKafkaTieredStorageStorageUsageTotalOut) err = json.Unmarshal(b, out) if err != nil { @@ -155,6 +176,9 @@ func (h *KafkaHandler) ServiceKafkaTieredStorageStorageUsageTotal(ctx context.Co func (h *KafkaHandler) ServiceKafkaTieredStorageSummary(ctx context.Context, project string, serviceName string) (*ServiceKafkaTieredStorageSummaryOut, error) { path := fmt.Sprintf("/project/%s/service/%s/kafka/tiered-storage/summary", project, serviceName) b, err := h.doer.Do(ctx, "ServiceKafkaTieredStorageSummary", "GET", path, nil) + if err != nil { + return nil, err + } out := new(ServiceKafkaTieredStorageSummaryOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/kafkaconnect/kafkaconnect.go b/handler/kafkaconnect/kafkaconnect.go index 2f77f5a..f101600 100644 --- a/handler/kafkaconnect/kafkaconnect.go +++ b/handler/kafkaconnect/kafkaconnect.go @@ -80,6 +80,9 @@ type KafkaConnectHandler struct { func (h *KafkaConnectHandler) ServiceKafkaConnectCreateConnector(ctx context.Context, project string, serviceName string, in *ServiceKafkaConnectCreateConnectorIn) (*ServiceKafkaConnectCreateConnectorOut, error) { path := fmt.Sprintf("/project/%s/service/%s/connectors", project, serviceName) b, err := h.doer.Do(ctx, "ServiceKafkaConnectCreateConnector", "POST", path, in) + if err != nil { + return nil, err + } out := new(serviceKafkaConnectCreateConnectorOut) err = json.Unmarshal(b, out) if err != nil { @@ -95,6 +98,9 @@ func (h *KafkaConnectHandler) ServiceKafkaConnectDeleteConnector(ctx context.Con func (h *KafkaConnectHandler) ServiceKafkaConnectEditConnector(ctx context.Context, project string, serviceName string, connectorName string, in *ServiceKafkaConnectEditConnectorIn) (*ServiceKafkaConnectEditConnectorOut, error) { path := fmt.Sprintf("/project/%s/service/%s/connectors/%s", project, serviceName, connectorName) b, err := h.doer.Do(ctx, "ServiceKafkaConnectEditConnector", "PUT", path, in) + if err != nil { + return nil, err + } out := new(serviceKafkaConnectEditConnectorOut) err = json.Unmarshal(b, out) if err != nil { @@ -105,6 +111,9 @@ func (h *KafkaConnectHandler) ServiceKafkaConnectEditConnector(ctx context.Conte func (h *KafkaConnectHandler) ServiceKafkaConnectGetAvailableConnectors(ctx context.Context, project string, serviceName string) ([]PluginOut, error) { path := fmt.Sprintf("/project/%s/service/%s/available-connectors", project, serviceName) b, err := h.doer.Do(ctx, "ServiceKafkaConnectGetAvailableConnectors", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceKafkaConnectGetAvailableConnectorsOut) err = json.Unmarshal(b, out) if err != nil { @@ -115,6 +124,9 @@ func (h *KafkaConnectHandler) ServiceKafkaConnectGetAvailableConnectors(ctx cont func (h *KafkaConnectHandler) ServiceKafkaConnectGetConnectorConfiguration(ctx context.Context, project string, serviceName string, connectorName string) ([]ConfigurationSchemaOut, error) { path := fmt.Sprintf("/project/%s/service/%s/connector-plugins/%s/configuration", project, serviceName, connectorName) b, err := h.doer.Do(ctx, "ServiceKafkaConnectGetConnectorConfiguration", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceKafkaConnectGetConnectorConfigurationOut) err = json.Unmarshal(b, out) if err != nil { @@ -125,6 +137,9 @@ func (h *KafkaConnectHandler) ServiceKafkaConnectGetConnectorConfiguration(ctx c func (h *KafkaConnectHandler) ServiceKafkaConnectGetConnectorStatus(ctx context.Context, project string, serviceName string, connectorName string) (*ServiceKafkaConnectGetConnectorStatusOut, error) { path := fmt.Sprintf("/project/%s/service/%s/connectors/%s/status", project, serviceName, connectorName) b, err := h.doer.Do(ctx, "ServiceKafkaConnectGetConnectorStatus", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceKafkaConnectGetConnectorStatusOut) err = json.Unmarshal(b, out) if err != nil { @@ -135,6 +150,9 @@ func (h *KafkaConnectHandler) ServiceKafkaConnectGetConnectorStatus(ctx context. func (h *KafkaConnectHandler) ServiceKafkaConnectList(ctx context.Context, project string, serviceName string) ([]ConnectorOut, error) { path := fmt.Sprintf("/project/%s/service/%s/connectors", project, serviceName) b, err := h.doer.Do(ctx, "ServiceKafkaConnectList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceKafkaConnectListOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/kafkamirrormaker/kafkamirrormaker.go b/handler/kafkamirrormaker/kafkamirrormaker.go index 38c1cfc..285ee3b 100644 --- a/handler/kafkamirrormaker/kafkamirrormaker.go +++ b/handler/kafkamirrormaker/kafkamirrormaker.go @@ -60,6 +60,9 @@ func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerDeleteReplicationFlow(c func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerGetReplicationFlow(ctx context.Context, project string, serviceName string, sourceCluster string, targetCluster string) (*ServiceKafkaMirrorMakerGetReplicationFlowOut, error) { path := fmt.Sprintf("/project/%s/service/%s/mirrormaker/replication-flows/%s/%s", project, serviceName, sourceCluster, targetCluster) b, err := h.doer.Do(ctx, "ServiceKafkaMirrorMakerGetReplicationFlow", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceKafkaMirrorMakerGetReplicationFlowOut) err = json.Unmarshal(b, out) if err != nil { @@ -70,6 +73,9 @@ func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerGetReplicationFlow(ctx func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerGetReplicationFlows(ctx context.Context, project string, serviceName string) ([]ReplicationFlowOut, error) { path := fmt.Sprintf("/project/%s/service/%s/mirrormaker/replication-flows", project, serviceName) b, err := h.doer.Do(ctx, "ServiceKafkaMirrorMakerGetReplicationFlows", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceKafkaMirrorMakerGetReplicationFlowsOut) err = json.Unmarshal(b, out) if err != nil { @@ -80,6 +86,9 @@ func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerGetReplicationFlows(ctx func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerPatchReplicationFlow(ctx context.Context, project string, serviceName string, sourceCluster string, targetCluster string, in *ServiceKafkaMirrorMakerPatchReplicationFlowIn) (*ServiceKafkaMirrorMakerPatchReplicationFlowOut, error) { path := fmt.Sprintf("/project/%s/service/%s/mirrormaker/replication-flows/%s/%s", project, serviceName, sourceCluster, targetCluster) b, err := h.doer.Do(ctx, "ServiceKafkaMirrorMakerPatchReplicationFlow", "PUT", path, in) + if err != nil { + return nil, err + } out := new(serviceKafkaMirrorMakerPatchReplicationFlowOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/kafkaschemaregistry/kafkaschemaregistry.go b/handler/kafkaschemaregistry/kafkaschemaregistry.go index c4f1962..4348e4a 100644 --- a/handler/kafkaschemaregistry/kafkaschemaregistry.go +++ b/handler/kafkaschemaregistry/kafkaschemaregistry.go @@ -100,6 +100,9 @@ type KafkaSchemaRegistryHandler struct { func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryAclAdd(ctx context.Context, project string, serviceName string, in *ServiceSchemaRegistryAclAddIn) ([]AclOut, error) { path := fmt.Sprintf("/project/%s/service/%s/kafka/schema-registry/acl", project, serviceName) b, err := h.doer.Do(ctx, "ServiceSchemaRegistryAclAdd", "POST", path, in) + if err != nil { + return nil, err + } out := new(serviceSchemaRegistryAclAddOut) err = json.Unmarshal(b, out) if err != nil { @@ -110,6 +113,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryAclAdd(ctx context.Con func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryAclDelete(ctx context.Context, project string, serviceName string, schemaRegistryAclId string) ([]AclOut, error) { path := fmt.Sprintf("/project/%s/service/%s/kafka/schema-registry/acl/%s", project, serviceName, schemaRegistryAclId) b, err := h.doer.Do(ctx, "ServiceSchemaRegistryAclDelete", "DELETE", path, nil) + if err != nil { + return nil, err + } out := new(serviceSchemaRegistryAclDeleteOut) err = json.Unmarshal(b, out) if err != nil { @@ -120,6 +126,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryAclDelete(ctx context. func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryAclList(ctx context.Context, project string, serviceName string) ([]AclOut, error) { path := fmt.Sprintf("/project/%s/service/%s/kafka/schema-registry/acl", project, serviceName) b, err := h.doer.Do(ctx, "ServiceSchemaRegistryAclList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceSchemaRegistryAclListOut) err = json.Unmarshal(b, out) if err != nil { @@ -130,6 +139,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryAclList(ctx context.Co func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryCompatibility(ctx context.Context, project string, serviceName string, subjectName string, versionId int, in *ServiceSchemaRegistryCompatibilityIn) (bool, error) { path := fmt.Sprintf("/project/%s/service/%s/kafka/schema/compatibility/subjects/%s/versions/%d", project, serviceName, subjectName, versionId) b, err := h.doer.Do(ctx, "ServiceSchemaRegistryCompatibility", "POST", path, in) + if err != nil { + return false, err + } out := new(serviceSchemaRegistryCompatibilityOut) err = json.Unmarshal(b, out) if err != nil { @@ -140,6 +152,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryCompatibility(ctx cont func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryGlobalConfigGet(ctx context.Context, project string, serviceName string) (string, error) { path := fmt.Sprintf("/project/%s/service/%s/kafka/schema/config", project, serviceName) b, err := h.doer.Do(ctx, "ServiceSchemaRegistryGlobalConfigGet", "GET", path, nil) + if err != nil { + return "", err + } out := new(serviceSchemaRegistryGlobalConfigGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -150,6 +165,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryGlobalConfigGet(ctx co func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryGlobalConfigPut(ctx context.Context, project string, serviceName string, in *ServiceSchemaRegistryGlobalConfigPutIn) (string, error) { path := fmt.Sprintf("/project/%s/service/%s/kafka/schema/config", project, serviceName) b, err := h.doer.Do(ctx, "ServiceSchemaRegistryGlobalConfigPut", "PUT", path, in) + if err != nil { + return "", err + } out := new(serviceSchemaRegistryGlobalConfigPutOut) err = json.Unmarshal(b, out) if err != nil { @@ -165,6 +183,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySchemaGet(ctx context. func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjectConfigGet(ctx context.Context, project string, serviceName string, subjectName string) (string, error) { path := fmt.Sprintf("/project/%s/service/%s/kafka/schema/config/%s", project, serviceName, subjectName) b, err := h.doer.Do(ctx, "ServiceSchemaRegistrySubjectConfigGet", "GET", path, nil) + if err != nil { + return "", err + } out := new(serviceSchemaRegistrySubjectConfigGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -175,6 +196,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjectConfigGet(ctx c func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjectConfigPut(ctx context.Context, project string, serviceName string, subjectName string, in *ServiceSchemaRegistrySubjectConfigPutIn) (string, error) { path := fmt.Sprintf("/project/%s/service/%s/kafka/schema/config/%s", project, serviceName, subjectName) b, err := h.doer.Do(ctx, "ServiceSchemaRegistrySubjectConfigPut", "PUT", path, in) + if err != nil { + return "", err + } out := new(serviceSchemaRegistrySubjectConfigPutOut) err = json.Unmarshal(b, out) if err != nil { @@ -200,6 +224,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjectVersionGet(ctx func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjectVersionPost(ctx context.Context, project string, serviceName string, subjectName string, in *ServiceSchemaRegistrySubjectVersionPostIn) (int, error) { path := fmt.Sprintf("/project/%s/service/%s/kafka/schema/subjects/%s/versions", project, serviceName, subjectName) b, err := h.doer.Do(ctx, "ServiceSchemaRegistrySubjectVersionPost", "POST", path, in) + if err != nil { + return 0, err + } out := new(serviceSchemaRegistrySubjectVersionPostOut) err = json.Unmarshal(b, out) if err != nil { @@ -210,6 +237,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjectVersionPost(ctx func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjectVersionsGet(ctx context.Context, project string, serviceName string, subjectName string) ([]int, error) { path := fmt.Sprintf("/project/%s/service/%s/kafka/schema/subjects/%s/versions", project, serviceName, subjectName) b, err := h.doer.Do(ctx, "ServiceSchemaRegistrySubjectVersionsGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceSchemaRegistrySubjectVersionsGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -220,6 +250,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjectVersionsGet(ctx func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjects(ctx context.Context, project string, serviceName string) ([]string, error) { path := fmt.Sprintf("/project/%s/service/%s/kafka/schema/subjects", project, serviceName) b, err := h.doer.Do(ctx, "ServiceSchemaRegistrySubjects", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceSchemaRegistrySubjectsOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/kafkatopic/kafkatopic.go b/handler/kafkatopic/kafkatopic.go index 1e9d7ce..4181702 100644 --- a/handler/kafkatopic/kafkatopic.go +++ b/handler/kafkatopic/kafkatopic.go @@ -70,6 +70,9 @@ func (h *KafkaTopicHandler) ServiceKafkaTopicDelete(ctx context.Context, project func (h *KafkaTopicHandler) ServiceKafkaTopicGet(ctx context.Context, project string, serviceName string, topicName string) (*ServiceKafkaTopicGetOut, error) { path := fmt.Sprintf("/project/%s/service/%s/topic/%s", project, serviceName, topicName) b, err := h.doer.Do(ctx, "ServiceKafkaTopicGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceKafkaTopicGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -80,6 +83,9 @@ func (h *KafkaTopicHandler) ServiceKafkaTopicGet(ctx context.Context, project st func (h *KafkaTopicHandler) ServiceKafkaTopicList(ctx context.Context, project string, serviceName string) ([]TopicOut, error) { path := fmt.Sprintf("/project/%s/service/%s/topic", project, serviceName) b, err := h.doer.Do(ctx, "ServiceKafkaTopicList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceKafkaTopicListOut) err = json.Unmarshal(b, out) if err != nil { @@ -90,6 +96,9 @@ func (h *KafkaTopicHandler) ServiceKafkaTopicList(ctx context.Context, project s func (h *KafkaTopicHandler) ServiceKafkaTopicMessageList(ctx context.Context, project string, serviceName string, topicName string, in *ServiceKafkaTopicMessageListIn) ([]MessageOut, error) { path := fmt.Sprintf("/project/%s/service/%s/kafka/rest/topics/%s/messages", project, serviceName, topicName) b, err := h.doer.Do(ctx, "ServiceKafkaTopicMessageList", "POST", path, in) + if err != nil { + return nil, err + } out := new(serviceKafkaTopicMessageListOut) err = json.Unmarshal(b, out) if err != nil { @@ -100,6 +109,9 @@ func (h *KafkaTopicHandler) ServiceKafkaTopicMessageList(ctx context.Context, pr func (h *KafkaTopicHandler) ServiceKafkaTopicMessageProduce(ctx context.Context, project string, serviceName string, topicName string, in *ServiceKafkaTopicMessageProduceIn) (*ServiceKafkaTopicMessageProduceOut, error) { path := fmt.Sprintf("/project/%s/service/%s/kafka/rest/topics/%s/produce", project, serviceName, topicName) b, err := h.doer.Do(ctx, "ServiceKafkaTopicMessageProduce", "POST", path, in) + if err != nil { + return nil, err + } out := new(ServiceKafkaTopicMessageProduceOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/mysql/mysql.go b/handler/mysql/mysql.go index 91f7fdd..f93c67b 100644 --- a/handler/mysql/mysql.go +++ b/handler/mysql/mysql.go @@ -30,6 +30,9 @@ type MySQLHandler struct { func (h *MySQLHandler) MySQLServiceQueryStatistics(ctx context.Context, project string, serviceName string, in *MySqlserviceQueryStatisticsIn) ([]QueryOut, error) { path := fmt.Sprintf("/project/%s/service/%s/mysql/query/stats", project, serviceName) b, err := h.doer.Do(ctx, "MySQLServiceQueryStatistics", "POST", path, in) + if err != nil { + return nil, err + } out := new(mySqlserviceQueryStatisticsOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/opensearch/opensearch.go b/handler/opensearch/opensearch.go index 9d853b2..755c050 100644 --- a/handler/opensearch/opensearch.go +++ b/handler/opensearch/opensearch.go @@ -66,6 +66,9 @@ type OpenSearchHandler struct { func (h *OpenSearchHandler) ServiceOpenSearchAclGet(ctx context.Context, project string, serviceName string) (*ServiceOpenSearchAclGetOut, error) { path := fmt.Sprintf("/project/%s/service/%s/opensearch/acl", project, serviceName) b, err := h.doer.Do(ctx, "ServiceOpenSearchAclGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceOpenSearchAclGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -76,6 +79,9 @@ func (h *OpenSearchHandler) ServiceOpenSearchAclGet(ctx context.Context, project func (h *OpenSearchHandler) ServiceOpenSearchAclSet(ctx context.Context, project string, serviceName string, in *ServiceOpenSearchAclSetIn) (*ServiceOpenSearchAclSetOut, error) { path := fmt.Sprintf("/project/%s/service/%s/opensearch/acl", project, serviceName) b, err := h.doer.Do(ctx, "ServiceOpenSearchAclSet", "POST", path, in) + if err != nil { + return nil, err + } out := new(serviceOpenSearchAclSetOut) err = json.Unmarshal(b, out) if err != nil { @@ -86,6 +92,9 @@ func (h *OpenSearchHandler) ServiceOpenSearchAclSet(ctx context.Context, project func (h *OpenSearchHandler) ServiceOpenSearchAclUpdate(ctx context.Context, project string, serviceName string, in *ServiceOpenSearchAclUpdateIn) (*ServiceOpenSearchAclUpdateOut, error) { path := fmt.Sprintf("/project/%s/service/%s/opensearch/acl", project, serviceName) b, err := h.doer.Do(ctx, "ServiceOpenSearchAclUpdate", "PUT", path, in) + if err != nil { + return nil, err + } out := new(serviceOpenSearchAclUpdateOut) err = json.Unmarshal(b, out) if err != nil { @@ -101,6 +110,9 @@ func (h *OpenSearchHandler) ServiceOpenSearchIndexDelete(ctx context.Context, pr func (h *OpenSearchHandler) ServiceOpenSearchIndexList(ctx context.Context, project string, serviceName string) ([]IndexeOut, error) { path := fmt.Sprintf("/project/%s/service/%s/index", project, serviceName) b, err := h.doer.Do(ctx, "ServiceOpenSearchIndexList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceOpenSearchIndexListOut) err = json.Unmarshal(b, out) if err != nil { @@ -111,6 +123,9 @@ func (h *OpenSearchHandler) ServiceOpenSearchIndexList(ctx context.Context, proj func (h *OpenSearchHandler) ServiceOpenSearchSecurityGet(ctx context.Context, project string, serviceName string) (*ServiceOpenSearchSecurityGetOut, error) { path := fmt.Sprintf("/project/%s/service/%s/opensearch/security", project, serviceName) b, err := h.doer.Do(ctx, "ServiceOpenSearchSecurityGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(ServiceOpenSearchSecurityGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -121,6 +136,9 @@ func (h *OpenSearchHandler) ServiceOpenSearchSecurityGet(ctx context.Context, pr func (h *OpenSearchHandler) ServiceOpenSearchSecurityReset(ctx context.Context, project string, serviceName string, in *ServiceOpenSearchSecurityResetIn) (*ServiceOpenSearchSecurityResetOut, error) { path := fmt.Sprintf("/project/%s/service/%s/opensearch/security/admin", project, serviceName) b, err := h.doer.Do(ctx, "ServiceOpenSearchSecurityReset", "PUT", path, in) + if err != nil { + return nil, err + } out := new(ServiceOpenSearchSecurityResetOut) err = json.Unmarshal(b, out) if err != nil { @@ -131,6 +149,9 @@ func (h *OpenSearchHandler) ServiceOpenSearchSecurityReset(ctx context.Context, func (h *OpenSearchHandler) ServiceOpenSearchSecuritySet(ctx context.Context, project string, serviceName string, in *ServiceOpenSearchSecuritySetIn) (*ServiceOpenSearchSecuritySetOut, error) { path := fmt.Sprintf("/project/%s/service/%s/opensearch/security/admin", project, serviceName) b, err := h.doer.Do(ctx, "ServiceOpenSearchSecuritySet", "POST", path, in) + if err != nil { + return nil, err + } out := new(ServiceOpenSearchSecuritySetOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/organization/organization.go b/handler/organization/organization.go index 297bde1..5b89998 100644 --- a/handler/organization/organization.go +++ b/handler/organization/organization.go @@ -61,6 +61,9 @@ type OrganizationHandler struct { func (h *OrganizationHandler) OrganizationAuthenticationConfigGet(ctx context.Context, organizationId string) (*OrganizationAuthenticationConfigGetOut, error) { path := fmt.Sprintf("/organization/%s/config/authentication", organizationId) b, err := h.doer.Do(ctx, "OrganizationAuthenticationConfigGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(OrganizationAuthenticationConfigGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -71,6 +74,9 @@ func (h *OrganizationHandler) OrganizationAuthenticationConfigGet(ctx context.Co func (h *OrganizationHandler) OrganizationAuthenticationConfigUpdate(ctx context.Context, organizationId string, in *OrganizationAuthenticationConfigUpdateIn) (*OrganizationAuthenticationConfigUpdateOut, error) { path := fmt.Sprintf("/organization/%s/config/authentication", organizationId) b, err := h.doer.Do(ctx, "OrganizationAuthenticationConfigUpdate", "PATCH", path, in) + if err != nil { + return nil, err + } out := new(OrganizationAuthenticationConfigUpdateOut) err = json.Unmarshal(b, out) if err != nil { @@ -81,6 +87,9 @@ func (h *OrganizationHandler) OrganizationAuthenticationConfigUpdate(ctx context func (h *OrganizationHandler) OrganizationGet(ctx context.Context, organizationId string) (*OrganizationGetOut, error) { path := fmt.Sprintf("/organization/%s", organizationId) b, err := h.doer.Do(ctx, "OrganizationGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(OrganizationGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -91,6 +100,9 @@ func (h *OrganizationHandler) OrganizationGet(ctx context.Context, organizationI func (h *OrganizationHandler) OrganizationProjectsList(ctx context.Context, organizationId string) (*OrganizationProjectsListOut, error) { path := fmt.Sprintf("/organization/%s/projects", organizationId) b, err := h.doer.Do(ctx, "OrganizationProjectsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(OrganizationProjectsListOut) err = json.Unmarshal(b, out) if err != nil { @@ -101,6 +113,9 @@ func (h *OrganizationHandler) OrganizationProjectsList(ctx context.Context, orga func (h *OrganizationHandler) OrganizationUpdate(ctx context.Context, organizationId string, in *OrganizationUpdateIn) (*OrganizationUpdateOut, error) { path := fmt.Sprintf("/organization/%s", organizationId) b, err := h.doer.Do(ctx, "OrganizationUpdate", "PATCH", path, in) + if err != nil { + return nil, err + } out := new(OrganizationUpdateOut) err = json.Unmarshal(b, out) if err != nil { @@ -111,6 +126,9 @@ func (h *OrganizationHandler) OrganizationUpdate(ctx context.Context, organizati func (h *OrganizationHandler) UserOrganizationCreate(ctx context.Context, in *UserOrganizationCreateIn) (*UserOrganizationCreateOut, error) { path := fmt.Sprintf("/organizations") b, err := h.doer.Do(ctx, "UserOrganizationCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(UserOrganizationCreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -121,6 +139,9 @@ func (h *OrganizationHandler) UserOrganizationCreate(ctx context.Context, in *Us func (h *OrganizationHandler) UserOrganizationsList(ctx context.Context) ([]OrganizationOut, error) { path := fmt.Sprintf("/organizations") b, err := h.doer.Do(ctx, "UserOrganizationsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(userOrganizationsListOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/organizationuser/organizationuser.go b/handler/organizationuser/organizationuser.go index 37b4fff..6aab601 100644 --- a/handler/organizationuser/organizationuser.go +++ b/handler/organizationuser/organizationuser.go @@ -91,6 +91,9 @@ type OrganizationUserHandler struct { func (h *OrganizationUserHandler) OrganizationUserAuthenticationMethodsList(ctx context.Context, organizationId string, memberUserId string) ([]AuthenticationMethodOut, error) { path := fmt.Sprintf("/organization/%s/user/%s/authentication_methods", organizationId, memberUserId) b, err := h.doer.Do(ctx, "OrganizationUserAuthenticationMethodsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(organizationUserAuthenticationMethodsListOut) err = json.Unmarshal(b, out) if err != nil { @@ -106,6 +109,9 @@ func (h *OrganizationUserHandler) OrganizationUserDelete(ctx context.Context, or func (h *OrganizationUserHandler) OrganizationUserGet(ctx context.Context, organizationId string, memberUserId string) (*OrganizationUserGetOut, error) { path := fmt.Sprintf("/organization/%s/user/%s", organizationId, memberUserId) b, err := h.doer.Do(ctx, "OrganizationUserGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(OrganizationUserGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -126,6 +132,9 @@ func (h *OrganizationUserHandler) OrganizationUserInvitationDelete(ctx context.C func (h *OrganizationUserHandler) OrganizationUserInvitationsList(ctx context.Context, organizationId string) ([]InvitationOut, error) { path := fmt.Sprintf("/organization/%s/invitation", organizationId) b, err := h.doer.Do(ctx, "OrganizationUserInvitationsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(organizationUserInvitationsListOut) err = json.Unmarshal(b, out) if err != nil { @@ -141,6 +150,9 @@ func (h *OrganizationUserHandler) OrganizationUserInvite(ctx context.Context, or func (h *OrganizationUserHandler) OrganizationUserList(ctx context.Context, organizationId string) ([]UserOut, error) { path := fmt.Sprintf("/organization/%s/user", organizationId) b, err := h.doer.Do(ctx, "OrganizationUserList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(organizationUserListOut) err = json.Unmarshal(b, out) if err != nil { @@ -161,6 +173,9 @@ func (h *OrganizationUserHandler) OrganizationUserRevokeToken(ctx context.Contex func (h *OrganizationUserHandler) OrganizationUserSet(ctx context.Context, organizationId string, memberUserId string) (*OrganizationUserSetOut, error) { path := fmt.Sprintf("/organization/%s/user/%s", organizationId, memberUserId) b, err := h.doer.Do(ctx, "OrganizationUserSet", "PUT", path, nil) + if err != nil { + return nil, err + } out := new(OrganizationUserSetOut) err = json.Unmarshal(b, out) if err != nil { @@ -171,6 +186,9 @@ func (h *OrganizationUserHandler) OrganizationUserSet(ctx context.Context, organ func (h *OrganizationUserHandler) OrganizationUserTokensList(ctx context.Context, organizationId string, memberUserId string) ([]TokenOut, error) { path := fmt.Sprintf("/organization/%s/user/%s/access-tokens", organizationId, memberUserId) b, err := h.doer.Do(ctx, "OrganizationUserTokensList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(organizationUserTokensListOut) err = json.Unmarshal(b, out) if err != nil { @@ -181,6 +199,9 @@ func (h *OrganizationUserHandler) OrganizationUserTokensList(ctx context.Context func (h *OrganizationUserHandler) OrganizationUserUpdate(ctx context.Context, organizationId string, memberUserId string, in *OrganizationUserUpdateIn) (*OrganizationUserUpdateOut, error) { path := fmt.Sprintf("/organization/%s/user/%s", organizationId, memberUserId) b, err := h.doer.Do(ctx, "OrganizationUserUpdate", "PATCH", path, in) + if err != nil { + return nil, err + } out := new(OrganizationUserUpdateOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/postgresql/postgresql.go b/handler/postgresql/postgresql.go index 254ea52..4440994 100644 --- a/handler/postgresql/postgresql.go +++ b/handler/postgresql/postgresql.go @@ -55,6 +55,9 @@ type PostgreSQLHandler struct { func (h *PostgreSQLHandler) PGServiceAvailableExtensions(ctx context.Context, project string, serviceName string) ([]ExtensionOut, error) { path := fmt.Sprintf("/project/%s/service/%s/pg/available-extensions", project, serviceName) b, err := h.doer.Do(ctx, "PGServiceAvailableExtensions", "GET", path, nil) + if err != nil { + return nil, err + } out := new(pgserviceAvailableExtensionsOut) err = json.Unmarshal(b, out) if err != nil { @@ -65,6 +68,9 @@ func (h *PostgreSQLHandler) PGServiceAvailableExtensions(ctx context.Context, pr func (h *PostgreSQLHandler) PGServiceQueryStatistics(ctx context.Context, project string, serviceName string, in *PgserviceQueryStatisticsIn) ([]QueryOut, error) { path := fmt.Sprintf("/project/%s/service/%s/pg/query/stats", project, serviceName) b, err := h.doer.Do(ctx, "PGServiceQueryStatistics", "POST", path, in) + if err != nil { + return nil, err + } out := new(pgserviceQueryStatisticsOut) err = json.Unmarshal(b, out) if err != nil { @@ -75,6 +81,9 @@ func (h *PostgreSQLHandler) PGServiceQueryStatistics(ctx context.Context, projec func (h *PostgreSQLHandler) PgAvailableExtensions(ctx context.Context, tenant string) ([]PgOut, error) { path := fmt.Sprintf("/tenants/%s/pg-available-extensions", tenant) b, err := h.doer.Do(ctx, "PgAvailableExtensions", "GET", path, nil) + if err != nil { + return nil, err + } out := new(pgAvailableExtensionsOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/privatelink/privatelink.go b/handler/privatelink/privatelink.go index 53fb665..1ac9aab 100644 --- a/handler/privatelink/privatelink.go +++ b/handler/privatelink/privatelink.go @@ -90,6 +90,9 @@ type PrivatelinkHandler struct { func (h *PrivatelinkHandler) PublicPrivatelinkAvailabilityList(ctx context.Context, tenant string) ([]PrivatelinkAvailabilityOut, error) { path := fmt.Sprintf("/tenants/%s/privatelink-availability", tenant) b, err := h.doer.Do(ctx, "PublicPrivatelinkAvailabilityList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(publicPrivatelinkAvailabilityListOut) err = json.Unmarshal(b, out) if err != nil { @@ -100,6 +103,9 @@ func (h *PrivatelinkHandler) PublicPrivatelinkAvailabilityList(ctx context.Conte func (h *PrivatelinkHandler) ServicePrivatelinkAWSConnectionList(ctx context.Context, project string, serviceName string) ([]ConnectionOut, error) { path := fmt.Sprintf("/project/%s/service/%s/privatelink/aws/connections", project, serviceName) b, err := h.doer.Do(ctx, "ServicePrivatelinkAWSConnectionList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(servicePrivatelinkAwsconnectionListOut) err = json.Unmarshal(b, out) if err != nil { @@ -110,6 +116,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAWSConnectionList(ctx context.Con func (h *PrivatelinkHandler) ServicePrivatelinkAWSCreate(ctx context.Context, project string, serviceName string, in *ServicePrivatelinkAwscreateIn) (*ServicePrivatelinkAwscreateOut, error) { path := fmt.Sprintf("/project/%s/service/%s/privatelink/aws", project, serviceName) b, err := h.doer.Do(ctx, "ServicePrivatelinkAWSCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(ServicePrivatelinkAwscreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -120,6 +129,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAWSCreate(ctx context.Context, pr func (h *PrivatelinkHandler) ServicePrivatelinkAWSDelete(ctx context.Context, project string, serviceName string) (*ServicePrivatelinkAwsdeleteOut, error) { path := fmt.Sprintf("/project/%s/service/%s/privatelink/aws", project, serviceName) b, err := h.doer.Do(ctx, "ServicePrivatelinkAWSDelete", "DELETE", path, nil) + if err != nil { + return nil, err + } out := new(ServicePrivatelinkAwsdeleteOut) err = json.Unmarshal(b, out) if err != nil { @@ -130,6 +142,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAWSDelete(ctx context.Context, pr func (h *PrivatelinkHandler) ServicePrivatelinkAWSGet(ctx context.Context, project string, serviceName string) (*ServicePrivatelinkAwsgetOut, error) { path := fmt.Sprintf("/project/%s/service/%s/privatelink/aws", project, serviceName) b, err := h.doer.Do(ctx, "ServicePrivatelinkAWSGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(ServicePrivatelinkAwsgetOut) err = json.Unmarshal(b, out) if err != nil { @@ -140,6 +155,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAWSGet(ctx context.Context, proje func (h *PrivatelinkHandler) ServicePrivatelinkAWSUpdate(ctx context.Context, project string, serviceName string, in *ServicePrivatelinkAwsupdateIn) (*ServicePrivatelinkAwsupdateOut, error) { path := fmt.Sprintf("/project/%s/service/%s/privatelink/aws", project, serviceName) b, err := h.doer.Do(ctx, "ServicePrivatelinkAWSUpdate", "PUT", path, in) + if err != nil { + return nil, err + } out := new(ServicePrivatelinkAwsupdateOut) err = json.Unmarshal(b, out) if err != nil { @@ -150,6 +168,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAWSUpdate(ctx context.Context, pr func (h *PrivatelinkHandler) ServicePrivatelinkAzureConnectionApproval(ctx context.Context, project string, serviceName string, privatelinkConnectionId string) (*ServicePrivatelinkAzureConnectionApprovalOut, error) { path := fmt.Sprintf("/project/%s/service/%s/privatelink/azure/connections/%s/approve", project, serviceName, privatelinkConnectionId) b, err := h.doer.Do(ctx, "ServicePrivatelinkAzureConnectionApproval", "POST", path, nil) + if err != nil { + return nil, err + } out := new(ServicePrivatelinkAzureConnectionApprovalOut) err = json.Unmarshal(b, out) if err != nil { @@ -160,6 +181,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAzureConnectionApproval(ctx conte func (h *PrivatelinkHandler) ServicePrivatelinkAzureConnectionList(ctx context.Context, project string, serviceName string) ([]ConnectionOutAlt, error) { path := fmt.Sprintf("/project/%s/service/%s/privatelink/azure/connections", project, serviceName) b, err := h.doer.Do(ctx, "ServicePrivatelinkAzureConnectionList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(servicePrivatelinkAzureConnectionListOut) err = json.Unmarshal(b, out) if err != nil { @@ -170,6 +194,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAzureConnectionList(ctx context.C func (h *PrivatelinkHandler) ServicePrivatelinkAzureConnectionUpdate(ctx context.Context, project string, serviceName string, privatelinkConnectionId string, in *ServicePrivatelinkAzureConnectionUpdateIn) (*ServicePrivatelinkAzureConnectionUpdateOut, error) { path := fmt.Sprintf("/project/%s/service/%s/privatelink/azure/connections/%s", project, serviceName, privatelinkConnectionId) b, err := h.doer.Do(ctx, "ServicePrivatelinkAzureConnectionUpdate", "PUT", path, in) + if err != nil { + return nil, err + } out := new(ServicePrivatelinkAzureConnectionUpdateOut) err = json.Unmarshal(b, out) if err != nil { @@ -180,6 +207,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAzureConnectionUpdate(ctx context func (h *PrivatelinkHandler) ServicePrivatelinkAzureCreate(ctx context.Context, project string, serviceName string, in *ServicePrivatelinkAzureCreateIn) (*ServicePrivatelinkAzureCreateOut, error) { path := fmt.Sprintf("/project/%s/service/%s/privatelink/azure", project, serviceName) b, err := h.doer.Do(ctx, "ServicePrivatelinkAzureCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(ServicePrivatelinkAzureCreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -190,6 +220,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAzureCreate(ctx context.Context, func (h *PrivatelinkHandler) ServicePrivatelinkAzureDelete(ctx context.Context, project string, serviceName string) (*ServicePrivatelinkAzureDeleteOut, error) { path := fmt.Sprintf("/project/%s/service/%s/privatelink/azure", project, serviceName) b, err := h.doer.Do(ctx, "ServicePrivatelinkAzureDelete", "DELETE", path, nil) + if err != nil { + return nil, err + } out := new(ServicePrivatelinkAzureDeleteOut) err = json.Unmarshal(b, out) if err != nil { @@ -200,6 +233,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAzureDelete(ctx context.Context, func (h *PrivatelinkHandler) ServicePrivatelinkAzureGet(ctx context.Context, project string, serviceName string) (*ServicePrivatelinkAzureGetOut, error) { path := fmt.Sprintf("/project/%s/service/%s/privatelink/azure", project, serviceName) b, err := h.doer.Do(ctx, "ServicePrivatelinkAzureGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(ServicePrivatelinkAzureGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -210,6 +246,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAzureGet(ctx context.Context, pro func (h *PrivatelinkHandler) ServicePrivatelinkAzureUpdate(ctx context.Context, project string, serviceName string, in *ServicePrivatelinkAzureUpdateIn) (*ServicePrivatelinkAzureUpdateOut, error) { path := fmt.Sprintf("/project/%s/service/%s/privatelink/azure", project, serviceName) b, err := h.doer.Do(ctx, "ServicePrivatelinkAzureUpdate", "PUT", path, in) + if err != nil { + return nil, err + } out := new(ServicePrivatelinkAzureUpdateOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/project/project.go b/handler/project/project.go index 226ea66..3096360 100644 --- a/handler/project/project.go +++ b/handler/project/project.go @@ -121,6 +121,9 @@ type ProjectHandler struct { func (h *ProjectHandler) ListProjectVpcPeeringConnectionTypes(ctx context.Context, project string) ([]VpcPeeringConnectionTypeOut, error) { path := fmt.Sprintf("/project/%s/vpc-peering-connection-types", project) b, err := h.doer.Do(ctx, "ListProjectVpcPeeringConnectionTypes", "GET", path, nil) + if err != nil { + return nil, err + } out := new(listProjectVpcPeeringConnectionTypesOut) err = json.Unmarshal(b, out) if err != nil { @@ -131,6 +134,9 @@ func (h *ProjectHandler) ListProjectVpcPeeringConnectionTypes(ctx context.Contex func (h *ProjectHandler) ProjectAlertsList(ctx context.Context, project string) ([]AlertOut, error) { path := fmt.Sprintf("/project/%s/alerts", project) b, err := h.doer.Do(ctx, "ProjectAlertsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(projectAlertsListOut) err = json.Unmarshal(b, out) if err != nil { @@ -141,6 +147,9 @@ func (h *ProjectHandler) ProjectAlertsList(ctx context.Context, project string) func (h *ProjectHandler) ProjectCreate(ctx context.Context, in *ProjectCreateIn) (*ProjectCreateOut, error) { path := fmt.Sprintf("/project") b, err := h.doer.Do(ctx, "ProjectCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(projectCreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -156,6 +165,9 @@ func (h *ProjectHandler) ProjectDelete(ctx context.Context, project string) erro func (h *ProjectHandler) ProjectGenerateSbomDownloadUrl(ctx context.Context, project string, fileFormat string) (string, error) { path := fmt.Sprintf("/project/%s/generate-sbom-download-url/%s", project, fileFormat) b, err := h.doer.Do(ctx, "ProjectGenerateSbomDownloadUrl", "GET", path, nil) + if err != nil { + return "", err + } out := new(projectGenerateSbomDownloadUrlOut) err = json.Unmarshal(b, out) if err != nil { @@ -166,6 +178,9 @@ func (h *ProjectHandler) ProjectGenerateSbomDownloadUrl(ctx context.Context, pro func (h *ProjectHandler) ProjectGet(ctx context.Context, project string) (*ProjectGetOut, error) { path := fmt.Sprintf("/project/%s", project) b, err := h.doer.Do(ctx, "ProjectGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(projectGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -176,6 +191,9 @@ func (h *ProjectHandler) ProjectGet(ctx context.Context, project string) (*Proje func (h *ProjectHandler) ProjectGetEventLogs(ctx context.Context, project string) ([]EventOut, error) { path := fmt.Sprintf("/project/%s/events", project) b, err := h.doer.Do(ctx, "ProjectGetEventLogs", "GET", path, nil) + if err != nil { + return nil, err + } out := new(projectGetEventLogsOut) err = json.Unmarshal(b, out) if err != nil { @@ -191,6 +209,9 @@ func (h *ProjectHandler) ProjectInvite(ctx context.Context, project string, in * func (h *ProjectHandler) ProjectInviteAccept(ctx context.Context, project string, inviteVerificationCode string) (*ProjectInviteAcceptOut, error) { path := fmt.Sprintf("/project/%s/invite/%s", project, inviteVerificationCode) b, err := h.doer.Do(ctx, "ProjectInviteAccept", "POST", path, nil) + if err != nil { + return nil, err + } out := new(projectInviteAcceptOut) err = json.Unmarshal(b, out) if err != nil { @@ -206,6 +227,9 @@ func (h *ProjectHandler) ProjectInviteDelete(ctx context.Context, project string func (h *ProjectHandler) ProjectList(ctx context.Context) (*ProjectListOut, error) { path := fmt.Sprintf("/project") b, err := h.doer.Do(ctx, "ProjectList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(ProjectListOut) err = json.Unmarshal(b, out) if err != nil { @@ -216,6 +240,9 @@ func (h *ProjectHandler) ProjectList(ctx context.Context) (*ProjectListOut, erro func (h *ProjectHandler) ProjectPrivatelinkAvailabilityList(ctx context.Context, project string) ([]PrivatelinkAvailabilityOut, error) { path := fmt.Sprintf("/project/%s/privatelink-availability", project) b, err := h.doer.Do(ctx, "ProjectPrivatelinkAvailabilityList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(projectPrivatelinkAvailabilityListOut) err = json.Unmarshal(b, out) if err != nil { @@ -226,6 +253,9 @@ func (h *ProjectHandler) ProjectPrivatelinkAvailabilityList(ctx context.Context, func (h *ProjectHandler) ProjectTagsList(ctx context.Context, project string) (map[string]string, error) { path := fmt.Sprintf("/project/%s/tags", project) b, err := h.doer.Do(ctx, "ProjectTagsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(projectTagsListOut) err = json.Unmarshal(b, out) if err != nil { @@ -246,6 +276,9 @@ func (h *ProjectHandler) ProjectTagsUpdate(ctx context.Context, project string, func (h *ProjectHandler) ProjectUpdate(ctx context.Context, project string, in *ProjectUpdateIn) (*ProjectUpdateOut, error) { path := fmt.Sprintf("/project/%s", project) b, err := h.doer.Do(ctx, "ProjectUpdate", "PUT", path, in) + if err != nil { + return nil, err + } out := new(projectUpdateOut) err = json.Unmarshal(b, out) if err != nil { @@ -256,6 +289,9 @@ func (h *ProjectHandler) ProjectUpdate(ctx context.Context, project string, in * func (h *ProjectHandler) ProjectUserList(ctx context.Context, project string) (*ProjectUserListOut, error) { path := fmt.Sprintf("/project/%s/users", project) b, err := h.doer.Do(ctx, "ProjectUserList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(ProjectUserListOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/projectbilling/projectbilling.go b/handler/projectbilling/projectbilling.go index bb3cf2f..cdfaf29 100644 --- a/handler/projectbilling/projectbilling.go +++ b/handler/projectbilling/projectbilling.go @@ -41,6 +41,9 @@ type ProjectBillingHandler struct { func (h *ProjectBillingHandler) ProjectCreditsClaim(ctx context.Context, project string, in *ProjectCreditsClaimIn) (*ProjectCreditsClaimOut, error) { path := fmt.Sprintf("/project/%s/credits", project) b, err := h.doer.Do(ctx, "ProjectCreditsClaim", "POST", path, in) + if err != nil { + return nil, err + } out := new(projectCreditsClaimOut) err = json.Unmarshal(b, out) if err != nil { @@ -51,6 +54,9 @@ func (h *ProjectBillingHandler) ProjectCreditsClaim(ctx context.Context, project func (h *ProjectBillingHandler) ProjectCreditsList(ctx context.Context, project string) ([]CreditOut, error) { path := fmt.Sprintf("/project/%s/credits", project) b, err := h.doer.Do(ctx, "ProjectCreditsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(projectCreditsListOut) err = json.Unmarshal(b, out) if err != nil { @@ -61,6 +67,9 @@ func (h *ProjectBillingHandler) ProjectCreditsList(ctx context.Context, project func (h *ProjectBillingHandler) ProjectInvoiceList(ctx context.Context, project string) ([]InvoiceOut, error) { path := fmt.Sprintf("/project/%s/invoice", project) b, err := h.doer.Do(ctx, "ProjectInvoiceList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(projectInvoiceListOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/service/service.go b/handler/service/service.go index 71c2871..4a9ea37 100644 --- a/handler/service/service.go +++ b/handler/service/service.go @@ -176,6 +176,9 @@ type ServiceHandler struct { func (h *ServiceHandler) ListProjectServiceTypes(ctx context.Context, project string) (*ListProjectServiceTypesOut, error) { path := fmt.Sprintf("/project/%s/service_types", project) b, err := h.doer.Do(ctx, "ListProjectServiceTypes", "GET", path, nil) + if err != nil { + return nil, err + } out := new(listProjectServiceTypesOut) err = json.Unmarshal(b, out) if err != nil { @@ -186,6 +189,9 @@ func (h *ServiceHandler) ListProjectServiceTypes(ctx context.Context, project st func (h *ServiceHandler) ListPublicServiceTypes(ctx context.Context) (*ListPublicServiceTypesOut, error) { path := fmt.Sprintf("/service_types") b, err := h.doer.Do(ctx, "ListPublicServiceTypes", "GET", path, nil) + if err != nil { + return nil, err + } out := new(listPublicServiceTypesOut) err = json.Unmarshal(b, out) if err != nil { @@ -196,6 +202,9 @@ func (h *ServiceHandler) ListPublicServiceTypes(ctx context.Context) (*ListPubli func (h *ServiceHandler) ListServiceVersions(ctx context.Context) ([]ServiceVersionOut, error) { path := fmt.Sprintf("/service_versions") b, err := h.doer.Do(ctx, "ListServiceVersions", "GET", path, nil) + if err != nil { + return nil, err + } out := new(listServiceVersionsOut) err = json.Unmarshal(b, out) if err != nil { @@ -206,6 +215,9 @@ func (h *ServiceHandler) ListServiceVersions(ctx context.Context) ([]ServiceVers func (h *ServiceHandler) ProjectGetServiceLogs(ctx context.Context, project string, serviceName string, in *ProjectGetServiceLogsIn) (*ProjectGetServiceLogsOut, error) { path := fmt.Sprintf("/project/%s/service/%s/logs", project, serviceName) b, err := h.doer.Do(ctx, "ProjectGetServiceLogs", "POST", path, in) + if err != nil { + return nil, err + } out := new(ProjectGetServiceLogsOut) err = json.Unmarshal(b, out) if err != nil { @@ -216,6 +228,9 @@ func (h *ServiceHandler) ProjectGetServiceLogs(ctx context.Context, project stri func (h *ServiceHandler) ProjectServiceTagsList(ctx context.Context, project string, serviceName string) (map[string]string, error) { path := fmt.Sprintf("/project/%s/service/%s/tags", project, serviceName) b, err := h.doer.Do(ctx, "ProjectServiceTagsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(projectServiceTagsListOut) err = json.Unmarshal(b, out) if err != nil { @@ -236,6 +251,9 @@ func (h *ServiceHandler) ProjectServiceTagsUpdate(ctx context.Context, project s func (h *ServiceHandler) ServiceAlertsList(ctx context.Context, project string, serviceName string) ([]AlertOut, error) { path := fmt.Sprintf("/project/%s/service/%s/alerts", project, serviceName) b, err := h.doer.Do(ctx, "ServiceAlertsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceAlertsListOut) err = json.Unmarshal(b, out) if err != nil { @@ -246,6 +264,9 @@ func (h *ServiceHandler) ServiceAlertsList(ctx context.Context, project string, func (h *ServiceHandler) ServiceBackupToAnotherRegionReport(ctx context.Context, project string, serviceName string, in *ServiceBackupToAnotherRegionReportIn) (map[string]any, error) { path := fmt.Sprintf("/project/%s/service/%s/backup_to_another_region/report", project, serviceName) b, err := h.doer.Do(ctx, "ServiceBackupToAnotherRegionReport", "POST", path, in) + if err != nil { + return nil, err + } out := new(serviceBackupToAnotherRegionReportOut) err = json.Unmarshal(b, out) if err != nil { @@ -256,6 +277,9 @@ func (h *ServiceHandler) ServiceBackupToAnotherRegionReport(ctx context.Context, func (h *ServiceHandler) ServiceBackupsGet(ctx context.Context, project string, serviceName string) ([]BackupOut, error) { path := fmt.Sprintf("/project/%s/service/%s/backups", project, serviceName) b, err := h.doer.Do(ctx, "ServiceBackupsGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceBackupsGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -266,6 +290,9 @@ func (h *ServiceHandler) ServiceBackupsGet(ctx context.Context, project string, func (h *ServiceHandler) ServiceCancelQuery(ctx context.Context, project string, serviceName string, in *ServiceCancelQueryIn) (bool, error) { path := fmt.Sprintf("/project/%s/service/%s/query/cancel", project, serviceName) b, err := h.doer.Do(ctx, "ServiceCancelQuery", "POST", path, in) + if err != nil { + return false, err + } out := new(serviceCancelQueryOut) err = json.Unmarshal(b, out) if err != nil { @@ -276,6 +303,9 @@ func (h *ServiceHandler) ServiceCancelQuery(ctx context.Context, project string, func (h *ServiceHandler) ServiceCreate(ctx context.Context, project string, in *ServiceCreateIn) (*ServiceCreateOut, error) { path := fmt.Sprintf("/project/%s/service", project) b, err := h.doer.Do(ctx, "ServiceCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(serviceCreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -296,6 +326,9 @@ func (h *ServiceHandler) ServiceDatabaseDelete(ctx context.Context, project stri func (h *ServiceHandler) ServiceDatabaseList(ctx context.Context, project string, serviceName string) ([]DatabaseOut, error) { path := fmt.Sprintf("/project/%s/service/%s/db", project, serviceName) b, err := h.doer.Do(ctx, "ServiceDatabaseList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceDatabaseListOut) err = json.Unmarshal(b, out) if err != nil { @@ -311,6 +344,9 @@ func (h *ServiceHandler) ServiceDelete(ctx context.Context, project string, serv func (h *ServiceHandler) ServiceEnableWrites(ctx context.Context, project string, serviceName string) (string, error) { path := fmt.Sprintf("/project/%s/service/%s/enable-writes", project, serviceName) b, err := h.doer.Do(ctx, "ServiceEnableWrites", "POST", path, nil) + if err != nil { + return "", err + } out := new(serviceEnableWritesOut) err = json.Unmarshal(b, out) if err != nil { @@ -321,6 +357,9 @@ func (h *ServiceHandler) ServiceEnableWrites(ctx context.Context, project string func (h *ServiceHandler) ServiceGet(ctx context.Context, project string, serviceName string) (*ServiceGetOut, error) { path := fmt.Sprintf("/project/%s/service/%s", project, serviceName) b, err := h.doer.Do(ctx, "ServiceGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -331,6 +370,9 @@ func (h *ServiceHandler) ServiceGet(ctx context.Context, project string, service func (h *ServiceHandler) ServiceGetMigrationStatus(ctx context.Context, project string, serviceName string) (*ServiceGetMigrationStatusOut, error) { path := fmt.Sprintf("/project/%s/service/%s/migration", project, serviceName) b, err := h.doer.Do(ctx, "ServiceGetMigrationStatus", "GET", path, nil) + if err != nil { + return nil, err + } out := new(ServiceGetMigrationStatusOut) err = json.Unmarshal(b, out) if err != nil { @@ -341,6 +383,9 @@ func (h *ServiceHandler) ServiceGetMigrationStatus(ctx context.Context, project func (h *ServiceHandler) ServiceInfluxDBStats(ctx context.Context, project string, serviceName string) (map[string]any, error) { path := fmt.Sprintf("/project/%s/service/%s/influxdb/stats", project, serviceName) b, err := h.doer.Do(ctx, "ServiceInfluxDBStats", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceInfluxDbstatsOut) err = json.Unmarshal(b, out) if err != nil { @@ -351,6 +396,9 @@ func (h *ServiceHandler) ServiceInfluxDBStats(ctx context.Context, project strin func (h *ServiceHandler) ServiceKmsGetCA(ctx context.Context, project string, serviceName string, caName string) (string, error) { path := fmt.Sprintf("/project/%s/service/%s/kms/ca/%s", project, serviceName, caName) b, err := h.doer.Do(ctx, "ServiceKmsGetCA", "GET", path, nil) + if err != nil { + return "", err + } out := new(serviceKmsGetCaOut) err = json.Unmarshal(b, out) if err != nil { @@ -361,6 +409,9 @@ func (h *ServiceHandler) ServiceKmsGetCA(ctx context.Context, project string, se func (h *ServiceHandler) ServiceKmsGetKeypair(ctx context.Context, project string, serviceName string, keypairName string) (*ServiceKmsGetKeypairOut, error) { path := fmt.Sprintf("/project/%s/service/%s/kms/keypairs/%s", project, serviceName, keypairName) b, err := h.doer.Do(ctx, "ServiceKmsGetKeypair", "GET", path, nil) + if err != nil { + return nil, err + } out := new(ServiceKmsGetKeypairOut) err = json.Unmarshal(b, out) if err != nil { @@ -371,6 +422,9 @@ func (h *ServiceHandler) ServiceKmsGetKeypair(ctx context.Context, project strin func (h *ServiceHandler) ServiceList(ctx context.Context, project string) ([]ServiceOut, error) { path := fmt.Sprintf("/project/%s/service", project) b, err := h.doer.Do(ctx, "ServiceList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceListOut) err = json.Unmarshal(b, out) if err != nil { @@ -386,6 +440,9 @@ func (h *ServiceHandler) ServiceMaintenanceStart(ctx context.Context, project st func (h *ServiceHandler) ServiceMetricsFetch(ctx context.Context, project string, serviceName string, in *ServiceMetricsFetchIn) (map[string]any, error) { path := fmt.Sprintf("/project/%s/service/%s/metrics", project, serviceName) b, err := h.doer.Do(ctx, "ServiceMetricsFetch", "POST", path, in) + if err != nil { + return nil, err + } out := new(serviceMetricsFetchOut) err = json.Unmarshal(b, out) if err != nil { @@ -396,6 +453,9 @@ func (h *ServiceHandler) ServiceMetricsFetch(ctx context.Context, project string func (h *ServiceHandler) ServiceQueryActivity(ctx context.Context, project string, serviceName string, in *ServiceQueryActivityIn) ([]QueryOut, error) { path := fmt.Sprintf("/project/%s/service/%s/query/activity", project, serviceName) b, err := h.doer.Do(ctx, "ServiceQueryActivity", "POST", path, in) + if err != nil { + return nil, err + } out := new(serviceQueryActivityOut) err = json.Unmarshal(b, out) if err != nil { @@ -406,6 +466,9 @@ func (h *ServiceHandler) ServiceQueryActivity(ctx context.Context, project strin func (h *ServiceHandler) ServiceQueryStatisticsReset(ctx context.Context, project string, serviceName string) ([]map[string]any, error) { path := fmt.Sprintf("/project/%s/service/%s/query/stats/reset", project, serviceName) b, err := h.doer.Do(ctx, "ServiceQueryStatisticsReset", "PUT", path, nil) + if err != nil { + return nil, err + } out := new(serviceQueryStatisticsResetOut) err = json.Unmarshal(b, out) if err != nil { @@ -416,6 +479,9 @@ func (h *ServiceHandler) ServiceQueryStatisticsReset(ctx context.Context, projec func (h *ServiceHandler) ServiceTaskCreate(ctx context.Context, project string, serviceName string, in *ServiceTaskCreateIn) (*ServiceTaskCreateOut, error) { path := fmt.Sprintf("/project/%s/service/%s/task", project, serviceName) b, err := h.doer.Do(ctx, "ServiceTaskCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(serviceTaskCreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -426,6 +492,9 @@ func (h *ServiceHandler) ServiceTaskCreate(ctx context.Context, project string, func (h *ServiceHandler) ServiceTaskGet(ctx context.Context, project string, serviceName string, taskId string) (*ServiceTaskGetOut, error) { path := fmt.Sprintf("/project/%s/service/%s/task/%s", project, serviceName, taskId) b, err := h.doer.Do(ctx, "ServiceTaskGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceTaskGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -436,6 +505,9 @@ func (h *ServiceHandler) ServiceTaskGet(ctx context.Context, project string, ser func (h *ServiceHandler) ServiceUpdate(ctx context.Context, project string, serviceName string, in *ServiceUpdateIn) (*ServiceUpdateOut, error) { path := fmt.Sprintf("/project/%s/service/%s", project, serviceName) b, err := h.doer.Do(ctx, "ServiceUpdate", "PUT", path, in) + if err != nil { + return nil, err + } out := new(serviceUpdateOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/serviceintegration/serviceintegration.go b/handler/serviceintegration/serviceintegration.go index b168c35..439b113 100644 --- a/handler/serviceintegration/serviceintegration.go +++ b/handler/serviceintegration/serviceintegration.go @@ -85,6 +85,9 @@ type ServiceIntegrationHandler struct { func (h *ServiceIntegrationHandler) ServiceIntegrationCreate(ctx context.Context, project string, in *ServiceIntegrationCreateIn) (*ServiceIntegrationCreateOut, error) { path := fmt.Sprintf("/project/%s/integration", project) b, err := h.doer.Do(ctx, "ServiceIntegrationCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(serviceIntegrationCreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -100,6 +103,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationDelete(ctx context.Context func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointCreate(ctx context.Context, project string, in *ServiceIntegrationEndpointCreateIn) (*ServiceIntegrationEndpointCreateOut, error) { path := fmt.Sprintf("/project/%s/integration_endpoint", project) b, err := h.doer.Do(ctx, "ServiceIntegrationEndpointCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(serviceIntegrationEndpointCreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -115,6 +121,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointDelete(ctx context func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointGet(ctx context.Context, project string, integrationEndpointId string) (*ServiceIntegrationEndpointGetOut, error) { path := fmt.Sprintf("/project/%s/integration_endpoint/%s", project, integrationEndpointId) b, err := h.doer.Do(ctx, "ServiceIntegrationEndpointGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceIntegrationEndpointGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -125,6 +134,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointGet(ctx context.Co func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointList(ctx context.Context, project string) ([]ServiceIntegrationEndpointOut, error) { path := fmt.Sprintf("/project/%s/integration_endpoint", project) b, err := h.doer.Do(ctx, "ServiceIntegrationEndpointList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceIntegrationEndpointListOut) err = json.Unmarshal(b, out) if err != nil { @@ -135,6 +147,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointList(ctx context.C func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointTypes(ctx context.Context, project string) ([]EndpointTypeOut, error) { path := fmt.Sprintf("/project/%s/integration_endpoint_types", project) b, err := h.doer.Do(ctx, "ServiceIntegrationEndpointTypes", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceIntegrationEndpointTypesOut) err = json.Unmarshal(b, out) if err != nil { @@ -145,6 +160,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointTypes(ctx context. func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointUpdate(ctx context.Context, project string, integrationEndpointId string, in *ServiceIntegrationEndpointUpdateIn) (*ServiceIntegrationEndpointUpdateOut, error) { path := fmt.Sprintf("/project/%s/integration_endpoint/%s", project, integrationEndpointId) b, err := h.doer.Do(ctx, "ServiceIntegrationEndpointUpdate", "PUT", path, in) + if err != nil { + return nil, err + } out := new(serviceIntegrationEndpointUpdateOut) err = json.Unmarshal(b, out) if err != nil { @@ -155,6 +173,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointUpdate(ctx context func (h *ServiceIntegrationHandler) ServiceIntegrationGet(ctx context.Context, project string, integrationId string) (*ServiceIntegrationGetOut, error) { path := fmt.Sprintf("/project/%s/integration/%s", project, integrationId) b, err := h.doer.Do(ctx, "ServiceIntegrationGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceIntegrationGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -165,6 +186,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationGet(ctx context.Context, p func (h *ServiceIntegrationHandler) ServiceIntegrationList(ctx context.Context, project string, serviceName string) ([]ServiceIntegrationOut, error) { path := fmt.Sprintf("/project/%s/service/%s/integration", project, serviceName) b, err := h.doer.Do(ctx, "ServiceIntegrationList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceIntegrationListOut) err = json.Unmarshal(b, out) if err != nil { @@ -175,6 +199,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationList(ctx context.Context, func (h *ServiceIntegrationHandler) ServiceIntegrationTypes(ctx context.Context, project string) ([]IntegrationTypeOut, error) { path := fmt.Sprintf("/project/%s/integration_types", project) b, err := h.doer.Do(ctx, "ServiceIntegrationTypes", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceIntegrationTypesOut) err = json.Unmarshal(b, out) if err != nil { @@ -185,6 +212,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationTypes(ctx context.Context, func (h *ServiceIntegrationHandler) ServiceIntegrationUpdate(ctx context.Context, project string, integrationId string, in *ServiceIntegrationUpdateIn) (*ServiceIntegrationUpdateOut, error) { path := fmt.Sprintf("/project/%s/integration/%s", project, integrationId) b, err := h.doer.Do(ctx, "ServiceIntegrationUpdate", "PUT", path, in) + if err != nil { + return nil, err + } out := new(serviceIntegrationUpdateOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/serviceuser/serviceuser.go b/handler/serviceuser/serviceuser.go index c8dead4..157bc9b 100644 --- a/handler/serviceuser/serviceuser.go +++ b/handler/serviceuser/serviceuser.go @@ -51,6 +51,9 @@ type ServiceUserHandler struct { func (h *ServiceUserHandler) ServiceUserCreate(ctx context.Context, project string, serviceName string, in *ServiceUserCreateIn) (*ServiceUserCreateOut, error) { path := fmt.Sprintf("/project/%s/service/%s/user", project, serviceName) b, err := h.doer.Do(ctx, "ServiceUserCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(serviceUserCreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -61,6 +64,9 @@ func (h *ServiceUserHandler) ServiceUserCreate(ctx context.Context, project stri func (h *ServiceUserHandler) ServiceUserCredentialsModify(ctx context.Context, project string, serviceName string, serviceUsername string, in *ServiceUserCredentialsModifyIn) (*ServiceUserCredentialsModifyOut, error) { path := fmt.Sprintf("/project/%s/service/%s/user/%s", project, serviceName, serviceUsername) b, err := h.doer.Do(ctx, "ServiceUserCredentialsModify", "PUT", path, in) + if err != nil { + return nil, err + } out := new(serviceUserCredentialsModifyOut) err = json.Unmarshal(b, out) if err != nil { @@ -71,6 +77,9 @@ func (h *ServiceUserHandler) ServiceUserCredentialsModify(ctx context.Context, p func (h *ServiceUserHandler) ServiceUserCredentialsReset(ctx context.Context, project string, serviceName string, serviceUsername string) (*ServiceUserCredentialsResetOut, error) { path := fmt.Sprintf("/project/%s/service/%s/user/%s/credentials/reset", project, serviceName, serviceUsername) b, err := h.doer.Do(ctx, "ServiceUserCredentialsReset", "PUT", path, nil) + if err != nil { + return nil, err + } out := new(serviceUserCredentialsResetOut) err = json.Unmarshal(b, out) if err != nil { @@ -86,6 +95,9 @@ func (h *ServiceUserHandler) ServiceUserDelete(ctx context.Context, project stri func (h *ServiceUserHandler) ServiceUserGet(ctx context.Context, project string, serviceName string, serviceUsername string) (*ServiceUserGetOut, error) { path := fmt.Sprintf("/project/%s/service/%s/user/%s", project, serviceName, serviceUsername) b, err := h.doer.Do(ctx, "ServiceUserGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(serviceUserGetOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/staticip/staticip.go b/handler/staticip/staticip.go index 9297dfe..cd98304 100644 --- a/handler/staticip/staticip.go +++ b/handler/staticip/staticip.go @@ -60,6 +60,9 @@ type StaticIPHandler struct { func (h *StaticIPHandler) ProjectStaticIPAssociate(ctx context.Context, project string, staticIpAddressId string, in *ProjectStaticIpassociateIn) (*ProjectStaticIpassociateOut, error) { path := fmt.Sprintf("/project/%s/static-ips/%s/association", project, staticIpAddressId) b, err := h.doer.Do(ctx, "ProjectStaticIPAssociate", "POST", path, in) + if err != nil { + return nil, err + } out := new(ProjectStaticIpassociateOut) err = json.Unmarshal(b, out) if err != nil { @@ -70,6 +73,9 @@ func (h *StaticIPHandler) ProjectStaticIPAssociate(ctx context.Context, project func (h *StaticIPHandler) ProjectStaticIPAvailabilityList(ctx context.Context, project string) ([]StaticIpAddressAvailabilityOut, error) { path := fmt.Sprintf("/project/%s/static-ip-availability", project) b, err := h.doer.Do(ctx, "ProjectStaticIPAvailabilityList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(projectStaticIpavailabilityListOut) err = json.Unmarshal(b, out) if err != nil { @@ -80,6 +86,9 @@ func (h *StaticIPHandler) ProjectStaticIPAvailabilityList(ctx context.Context, p func (h *StaticIPHandler) ProjectStaticIPDissociate(ctx context.Context, project string, staticIpAddressId string) (*ProjectStaticIpdissociateOut, error) { path := fmt.Sprintf("/project/%s/static-ips/%s/association", project, staticIpAddressId) b, err := h.doer.Do(ctx, "ProjectStaticIPDissociate", "DELETE", path, nil) + if err != nil { + return nil, err + } out := new(ProjectStaticIpdissociateOut) err = json.Unmarshal(b, out) if err != nil { @@ -90,6 +99,9 @@ func (h *StaticIPHandler) ProjectStaticIPDissociate(ctx context.Context, project func (h *StaticIPHandler) ProjectStaticIPPatch(ctx context.Context, project string, staticIpAddressId string, in *ProjectStaticIppatchIn) (*ProjectStaticIppatchOut, error) { path := fmt.Sprintf("/project/%s/static-ips/%s", project, staticIpAddressId) b, err := h.doer.Do(ctx, "ProjectStaticIPPatch", "PATCH", path, in) + if err != nil { + return nil, err + } out := new(ProjectStaticIppatchOut) err = json.Unmarshal(b, out) if err != nil { @@ -100,6 +112,9 @@ func (h *StaticIPHandler) ProjectStaticIPPatch(ctx context.Context, project stri func (h *StaticIPHandler) PublicStaticIPAvailabilityList(ctx context.Context, tenant string) ([]StaticIpAddressAvailabilityOut, error) { path := fmt.Sprintf("/tenants/%s/static-ip-availability", tenant) b, err := h.doer.Do(ctx, "PublicStaticIPAvailabilityList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(publicStaticIpavailabilityListOut) err = json.Unmarshal(b, out) if err != nil { @@ -110,6 +125,9 @@ func (h *StaticIPHandler) PublicStaticIPAvailabilityList(ctx context.Context, te func (h *StaticIPHandler) StaticIPCreate(ctx context.Context, project string, in *StaticIpcreateIn) (*StaticIpcreateOut, error) { path := fmt.Sprintf("/project/%s/static-ips", project) b, err := h.doer.Do(ctx, "StaticIPCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(StaticIpcreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -120,6 +138,9 @@ func (h *StaticIPHandler) StaticIPCreate(ctx context.Context, project string, in func (h *StaticIPHandler) StaticIPList(ctx context.Context, project string) ([]StaticIpOut, error) { path := fmt.Sprintf("/project/%s/static-ips", project) b, err := h.doer.Do(ctx, "StaticIPList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(staticIplistOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/user/user.go b/handler/user/user.go index e76f9a8..dfa753e 100644 --- a/handler/user/user.go +++ b/handler/user/user.go @@ -156,6 +156,9 @@ type UserHandler struct { func (h *UserHandler) AccessTokenCreate(ctx context.Context, in *AccessTokenCreateIn) (*AccessTokenCreateOut, error) { path := fmt.Sprintf("/access_token") b, err := h.doer.Do(ctx, "AccessTokenCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(AccessTokenCreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -166,6 +169,9 @@ func (h *UserHandler) AccessTokenCreate(ctx context.Context, in *AccessTokenCrea func (h *UserHandler) AccessTokenList(ctx context.Context) ([]TokenOut, error) { path := fmt.Sprintf("/access_token") b, err := h.doer.Do(ctx, "AccessTokenList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(accessTokenListOut) err = json.Unmarshal(b, out) if err != nil { @@ -181,6 +187,9 @@ func (h *UserHandler) AccessTokenRevoke(ctx context.Context, tokenPrefix string) func (h *UserHandler) AccessTokenUpdate(ctx context.Context, tokenPrefix string, in *AccessTokenUpdateIn) (*AccessTokenUpdateOut, error) { path := fmt.Sprintf("/access_token/%s", tokenPrefix) b, err := h.doer.Do(ctx, "AccessTokenUpdate", "PUT", path, in) + if err != nil { + return nil, err + } out := new(AccessTokenUpdateOut) err = json.Unmarshal(b, out) if err != nil { @@ -191,6 +200,9 @@ func (h *UserHandler) AccessTokenUpdate(ctx context.Context, tokenPrefix string, func (h *UserHandler) CheckPasswordStrengthExistingUser(ctx context.Context, in *CheckPasswordStrengthExistingUserIn) (*CheckPasswordStrengthExistingUserOut, error) { path := fmt.Sprintf("/me/password_strength") b, err := h.doer.Do(ctx, "CheckPasswordStrengthExistingUser", "POST", path, in) + if err != nil { + return nil, err + } out := new(checkPasswordStrengthExistingUserOut) err = json.Unmarshal(b, out) if err != nil { @@ -201,6 +213,9 @@ func (h *UserHandler) CheckPasswordStrengthExistingUser(ctx context.Context, in func (h *UserHandler) CheckPasswordStrengthNewUser(ctx context.Context, in *CheckPasswordStrengthNewUserIn) (*CheckPasswordStrengthNewUserOut, error) { path := fmt.Sprintf("/user/password_strength") b, err := h.doer.Do(ctx, "CheckPasswordStrengthNewUser", "POST", path, in) + if err != nil { + return nil, err + } out := new(checkPasswordStrengthNewUserOut) err = json.Unmarshal(b, out) if err != nil { @@ -211,6 +226,9 @@ func (h *UserHandler) CheckPasswordStrengthNewUser(ctx context.Context, in *Chec func (h *UserHandler) OrganizationMemberGroupsList(ctx context.Context, organizationId string, memberUserId string) ([]UserGroupOut, error) { path := fmt.Sprintf("/organization/%s/user/%s/user-groups", organizationId, memberUserId) b, err := h.doer.Do(ctx, "OrganizationMemberGroupsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(organizationMemberGroupsListOut) err = json.Unmarshal(b, out) if err != nil { @@ -221,6 +239,9 @@ func (h *UserHandler) OrganizationMemberGroupsList(ctx context.Context, organiza func (h *UserHandler) TwoFactorAuthConfigure(ctx context.Context, in *TwoFactorAuthConfigureIn) (*TwoFactorAuthConfigureOut, error) { path := fmt.Sprintf("/me/2fa") b, err := h.doer.Do(ctx, "TwoFactorAuthConfigure", "PUT", path, in) + if err != nil { + return nil, err + } out := new(TwoFactorAuthConfigureOut) err = json.Unmarshal(b, out) if err != nil { @@ -231,6 +252,9 @@ func (h *UserHandler) TwoFactorAuthConfigure(ctx context.Context, in *TwoFactorA func (h *UserHandler) TwoFactorAuthConfigureOTP(ctx context.Context, in *TwoFactorAuthConfigureOtpIn) (*TwoFactorAuthConfigureOtpOut, error) { path := fmt.Sprintf("/me/2fa/otp") b, err := h.doer.Do(ctx, "TwoFactorAuthConfigureOTP", "PUT", path, in) + if err != nil { + return nil, err + } out := new(TwoFactorAuthConfigureOtpOut) err = json.Unmarshal(b, out) if err != nil { @@ -241,6 +265,9 @@ func (h *UserHandler) TwoFactorAuthConfigureOTP(ctx context.Context, in *TwoFact func (h *UserHandler) UserAccountInvitesAccept(ctx context.Context, in *UserAccountInvitesAcceptIn) ([]AccountInviteOut, error) { path := fmt.Sprintf("/me/account/invites/accept") b, err := h.doer.Do(ctx, "UserAccountInvitesAccept", "POST", path, in) + if err != nil { + return nil, err + } out := new(userAccountInvitesAcceptOut) err = json.Unmarshal(b, out) if err != nil { @@ -251,6 +278,9 @@ func (h *UserHandler) UserAccountInvitesAccept(ctx context.Context, in *UserAcco func (h *UserHandler) UserAccountInvitesList(ctx context.Context) ([]AccountInviteOut, error) { path := fmt.Sprintf("/me/account/invites") b, err := h.doer.Do(ctx, "UserAccountInvitesList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(userAccountInvitesListOut) err = json.Unmarshal(b, out) if err != nil { @@ -261,6 +291,9 @@ func (h *UserHandler) UserAccountInvitesList(ctx context.Context) ([]AccountInvi func (h *UserHandler) UserAuth(ctx context.Context, in *UserAuthIn) (*UserAuthOut, error) { path := fmt.Sprintf("/userauth") b, err := h.doer.Do(ctx, "UserAuth", "POST", path, in) + if err != nil { + return nil, err + } out := new(UserAuthOut) err = json.Unmarshal(b, out) if err != nil { @@ -271,6 +304,9 @@ func (h *UserHandler) UserAuth(ctx context.Context, in *UserAuthIn) (*UserAuthOu func (h *UserHandler) UserAuthLoginOptions(ctx context.Context, in *UserAuthLoginOptionsIn) (*UserAuthLoginOptionsOut, error) { path := fmt.Sprintf("/userauth/login_options") b, err := h.doer.Do(ctx, "UserAuthLoginOptions", "POST", path, in) + if err != nil { + return nil, err + } out := new(UserAuthLoginOptionsOut) err = json.Unmarshal(b, out) if err != nil { @@ -286,6 +322,9 @@ func (h *UserHandler) UserAuthenticationMethodDelete(ctx context.Context, userAu func (h *UserHandler) UserAuthenticationMethodsList(ctx context.Context) ([]AuthenticationMethodOut, error) { path := fmt.Sprintf("/me/authentication_methods") b, err := h.doer.Do(ctx, "UserAuthenticationMethodsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(userAuthenticationMethodsListOut) err = json.Unmarshal(b, out) if err != nil { @@ -296,6 +335,9 @@ func (h *UserHandler) UserAuthenticationMethodsList(ctx context.Context) ([]Auth func (h *UserHandler) UserCreate(ctx context.Context, in *UserCreateIn) (*UserCreateOut, error) { path := fmt.Sprintf("/user") b, err := h.doer.Do(ctx, "UserCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(UserCreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -311,6 +353,9 @@ func (h *UserHandler) UserExpireTokens(ctx context.Context) error { func (h *UserHandler) UserInfo(ctx context.Context) (*UserInfoOut, error) { path := fmt.Sprintf("/me") b, err := h.doer.Do(ctx, "UserInfo", "GET", path, nil) + if err != nil { + return nil, err + } out := new(userInfoOut) err = json.Unmarshal(b, out) if err != nil { @@ -326,6 +371,9 @@ func (h *UserHandler) UserLogout(ctx context.Context) error { func (h *UserHandler) UserPasswordChange(ctx context.Context, in *UserPasswordChangeIn) (string, error) { path := fmt.Sprintf("/me/password") b, err := h.doer.Do(ctx, "UserPasswordChange", "PUT", path, in) + if err != nil { + return "", err + } out := new(userPasswordChangeOut) err = json.Unmarshal(b, out) if err != nil { @@ -346,6 +394,9 @@ func (h *UserHandler) UserPasswordResetRequest(ctx context.Context, in *UserPass func (h *UserHandler) UserUpdate(ctx context.Context, in *UserUpdateIn) (*UserUpdateOut, error) { path := fmt.Sprintf("/me") b, err := h.doer.Do(ctx, "UserUpdate", "PATCH", path, in) + if err != nil { + return nil, err + } out := new(userUpdateOut) err = json.Unmarshal(b, out) if err != nil { @@ -356,6 +407,9 @@ func (h *UserHandler) UserUpdate(ctx context.Context, in *UserUpdateIn) (*UserUp func (h *UserHandler) UserVerifyEmail(ctx context.Context, verificationCode string) (*UserVerifyEmailOut, error) { path := fmt.Sprintf("/user/verify_email/%s", verificationCode) b, err := h.doer.Do(ctx, "UserVerifyEmail", "POST", path, nil) + if err != nil { + return nil, err + } out := new(userVerifyEmailOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/usergroup/usergroup.go b/handler/usergroup/usergroup.go index 28e8d10..7b1ffc4 100644 --- a/handler/usergroup/usergroup.go +++ b/handler/usergroup/usergroup.go @@ -61,6 +61,9 @@ type UserGroupHandler struct { func (h *UserGroupHandler) UserGroupCreate(ctx context.Context, organizationId string, in *UserGroupCreateIn) (*UserGroupCreateOut, error) { path := fmt.Sprintf("/organization/%s/user-groups", organizationId) b, err := h.doer.Do(ctx, "UserGroupCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(UserGroupCreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -76,6 +79,9 @@ func (h *UserGroupHandler) UserGroupDelete(ctx context.Context, organizationId s func (h *UserGroupHandler) UserGroupGet(ctx context.Context, organizationId string, userGroupId string) (*UserGroupGetOut, error) { path := fmt.Sprintf("/organization/%s/user-groups/%s", organizationId, userGroupId) b, err := h.doer.Do(ctx, "UserGroupGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(UserGroupGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -86,6 +92,9 @@ func (h *UserGroupHandler) UserGroupGet(ctx context.Context, organizationId stri func (h *UserGroupHandler) UserGroupMemberList(ctx context.Context, organizationId string, userGroupId string) ([]MemberOut, error) { path := fmt.Sprintf("/organization/%s/user-groups/%s/members", organizationId, userGroupId) b, err := h.doer.Do(ctx, "UserGroupMemberList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(userGroupMemberListOut) err = json.Unmarshal(b, out) if err != nil { @@ -101,6 +110,9 @@ func (h *UserGroupHandler) UserGroupMembersUpdate(ctx context.Context, organizat func (h *UserGroupHandler) UserGroupUpdate(ctx context.Context, organizationId string, userGroupId string, in *UserGroupUpdateIn) (*UserGroupUpdateOut, error) { path := fmt.Sprintf("/organization/%s/user-groups/%s", organizationId, userGroupId) b, err := h.doer.Do(ctx, "UserGroupUpdate", "PATCH", path, in) + if err != nil { + return nil, err + } out := new(UserGroupUpdateOut) err = json.Unmarshal(b, out) if err != nil { @@ -111,6 +123,9 @@ func (h *UserGroupHandler) UserGroupUpdate(ctx context.Context, organizationId s func (h *UserGroupHandler) UserGroupsList(ctx context.Context, organizationId string) ([]UserGroupOut, error) { path := fmt.Sprintf("/organization/%s/user-groups", organizationId) b, err := h.doer.Do(ctx, "UserGroupsList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(userGroupsListOut) err = json.Unmarshal(b, out) if err != nil { diff --git a/handler/vpc/vpc.go b/handler/vpc/vpc.go index 8bfd737..29f9873 100644 --- a/handler/vpc/vpc.go +++ b/handler/vpc/vpc.go @@ -71,6 +71,9 @@ type VpcHandler struct { func (h *VpcHandler) VpcCreate(ctx context.Context, project string, in *VpcCreateIn) (*VpcCreateOut, error) { path := fmt.Sprintf("/project/%s/vpcs", project) b, err := h.doer.Do(ctx, "VpcCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(VpcCreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -81,6 +84,9 @@ func (h *VpcHandler) VpcCreate(ctx context.Context, project string, in *VpcCreat func (h *VpcHandler) VpcDelete(ctx context.Context, project string, projectVpcId string) (*VpcDeleteOut, error) { path := fmt.Sprintf("/project/%s/vpcs/%s", project, projectVpcId) b, err := h.doer.Do(ctx, "VpcDelete", "DELETE", path, nil) + if err != nil { + return nil, err + } out := new(VpcDeleteOut) err = json.Unmarshal(b, out) if err != nil { @@ -91,6 +97,9 @@ func (h *VpcHandler) VpcDelete(ctx context.Context, project string, projectVpcId func (h *VpcHandler) VpcGet(ctx context.Context, project string, projectVpcId string) (*VpcGetOut, error) { path := fmt.Sprintf("/project/%s/vpcs/%s", project, projectVpcId) b, err := h.doer.Do(ctx, "VpcGet", "GET", path, nil) + if err != nil { + return nil, err + } out := new(VpcGetOut) err = json.Unmarshal(b, out) if err != nil { @@ -101,6 +110,9 @@ func (h *VpcHandler) VpcGet(ctx context.Context, project string, projectVpcId st func (h *VpcHandler) VpcList(ctx context.Context, project string) ([]VpcOut, error) { path := fmt.Sprintf("/project/%s/vpcs", project) b, err := h.doer.Do(ctx, "VpcList", "GET", path, nil) + if err != nil { + return nil, err + } out := new(vpcListOut) err = json.Unmarshal(b, out) if err != nil { @@ -111,6 +123,9 @@ func (h *VpcHandler) VpcList(ctx context.Context, project string) ([]VpcOut, err func (h *VpcHandler) VpcPeeringConnectionCreate(ctx context.Context, project string, projectVpcId string, in *VpcPeeringConnectionCreateIn) (*VpcPeeringConnectionCreateOut, error) { path := fmt.Sprintf("/project/%s/vpcs/%s/peering-connections", project, projectVpcId) b, err := h.doer.Do(ctx, "VpcPeeringConnectionCreate", "POST", path, in) + if err != nil { + return nil, err + } out := new(VpcPeeringConnectionCreateOut) err = json.Unmarshal(b, out) if err != nil { @@ -121,6 +136,9 @@ func (h *VpcHandler) VpcPeeringConnectionCreate(ctx context.Context, project str func (h *VpcHandler) VpcPeeringConnectionDelete(ctx context.Context, project string, projectVpcId string, peerCloudAccount string, peerVpc string) (*VpcPeeringConnectionDeleteOut, error) { path := fmt.Sprintf("/project/%s/vpcs/%s/peering-connections/peer-accounts/%s/peer-vpcs/%s", project, projectVpcId, peerCloudAccount, peerVpc) b, err := h.doer.Do(ctx, "VpcPeeringConnectionDelete", "DELETE", path, nil) + if err != nil { + return nil, err + } out := new(VpcPeeringConnectionDeleteOut) err = json.Unmarshal(b, out) if err != nil { @@ -131,6 +149,9 @@ func (h *VpcHandler) VpcPeeringConnectionDelete(ctx context.Context, project str func (h *VpcHandler) VpcPeeringConnectionUpdate(ctx context.Context, project string, projectVpcId string, in *VpcPeeringConnectionUpdateIn) (*VpcPeeringConnectionUpdateOut, error) { path := fmt.Sprintf("/project/%s/vpcs/%s/user-peer-network-cidrs", project, projectVpcId) b, err := h.doer.Do(ctx, "VpcPeeringConnectionUpdate", "PUT", path, in) + if err != nil { + return nil, err + } out := new(VpcPeeringConnectionUpdateOut) err = json.Unmarshal(b, out) if err != nil { @@ -141,6 +162,9 @@ func (h *VpcHandler) VpcPeeringConnectionUpdate(ctx context.Context, project str func (h *VpcHandler) VpcPeeringConnectionWithRegionDelete(ctx context.Context, project string, projectVpcId string, peerCloudAccount string, peerVpc string, peerRegion string) (*VpcPeeringConnectionWithRegionDeleteOut, error) { path := fmt.Sprintf("/project/%s/vpcs/%s/peering-connections/peer-accounts/%s/peer-vpcs/%s/peer-regions/%s", project, projectVpcId, peerCloudAccount, peerVpc, peerRegion) b, err := h.doer.Do(ctx, "VpcPeeringConnectionWithRegionDelete", "DELETE", path, nil) + if err != nil { + return nil, err + } out := new(VpcPeeringConnectionWithRegionDeleteOut) err = json.Unmarshal(b, out) if err != nil { @@ -151,6 +175,9 @@ func (h *VpcHandler) VpcPeeringConnectionWithRegionDelete(ctx context.Context, p func (h *VpcHandler) VpcPeeringConnectionWithResourceGroupDelete(ctx context.Context, project string, projectVpcId string, peerCloudAccount string, peerResourceGroup string, peerVpc string) (*VpcPeeringConnectionWithResourceGroupDeleteOut, error) { path := fmt.Sprintf("/project/%s/vpcs/%s/peering-connections/peer-accounts/%s/peer-resource-groups/%s/peer-vpcs/%s", project, projectVpcId, peerCloudAccount, peerResourceGroup, peerVpc) b, err := h.doer.Do(ctx, "VpcPeeringConnectionWithResourceGroupDelete", "DELETE", path, nil) + if err != nil { + return nil, err + } out := new(VpcPeeringConnectionWithResourceGroupDeleteOut) err = json.Unmarshal(b, out) if err != nil {