Skip to content
This repository was archived by the owner on Feb 5, 2025. It is now read-only.

feat: SDK generated with 2025-01-01-next schema #24

Draft
alexluong wants to merge 2 commits into
base: master
Choose a base branch
from
Draft

feat: SDK generated with 2025-01-01-next schema #24

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
dbfbc80
feat: Generate new SDK with 2025-01-01-next schema
alexluong Jan 29, 2025
3de9c1a
fix: Generation issue with issue_trigger
alexluong Jan 29, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
64 changes: 64 additions & 0 deletions attempt.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,9 @@
package api

import (
json "encoding/json"
fmt "fmt"
internal "github.com/hookdeck/hookdeck-go-sdk/internal"
)

type AttemptListRequest struct {
Expand All @@ -15,6 +17,68 @@ type AttemptListRequest struct {
Prev *string `json:"-" url:"prev,omitempty"`
}

type EventAttemptPaginatedResult struct {
Pagination *SeekPagination `json:"pagination,omitempty" url:"pagination,omitempty"`
Count *int `json:"count,omitempty" url:"count,omitempty"`
Models []*EventAttempt `json:"models,omitempty" url:"models,omitempty"`

extraProperties map[string]interface{}
rawJSON json.RawMessage
}

func (e *EventAttemptPaginatedResult) GetPagination() *SeekPagination {
if e == nil {
return nil
}
return e.Pagination
}

func (e *EventAttemptPaginatedResult) GetCount() *int {
if e == nil {
return nil
}
return e.Count
}

func (e *EventAttemptPaginatedResult) GetModels() []*EventAttempt {
if e == nil {
return nil
}
return e.Models
}

func (e *EventAttemptPaginatedResult) GetExtraProperties() map[string]interface{} {
return e.extraProperties
}

func (e *EventAttemptPaginatedResult) UnmarshalJSON(data []byte) error {
type unmarshaler EventAttemptPaginatedResult
var value unmarshaler
if err := json.Unmarshal(data, &value); err != nil {
return err
}
*e = EventAttemptPaginatedResult(value)
extraProperties, err := internal.ExtractExtraProperties(data, *e)
if err != nil {
return err
}
e.extraProperties = extraProperties
e.rawJSON = json.RawMessage(data)
return nil
}

func (e *EventAttemptPaginatedResult) String() string {
if len(e.rawJSON) > 0 {
if value, err := internal.StringifyJSON(e.rawJSON); err == nil {
return value
}
}
if value, err := internal.StringifyJSON(e); err == nil {
return value
}
return fmt.Sprintf("%#v", e)
}

type AttemptListRequestDir string

const (
Expand Down
123 changes: 47 additions & 76 deletions attempt/client.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,29 +3,26 @@
package attempt

import (
bytes "bytes"
context "context"
json "encoding/json"
errors "errors"
hookdeckgosdk "github.com/hookdeck/hookdeck-go-sdk"
core "github.com/hookdeck/hookdeck-go-sdk/core"
internal "github.com/hookdeck/hookdeck-go-sdk/internal"
option "github.com/hookdeck/hookdeck-go-sdk/option"
io "io"
http "net/http"
)

type Client struct {
baseURL string
caller *core.Caller
caller *internal.Caller
header http.Header
}

func NewClient(opts ...option.RequestOption) *Client {
options := core.NewRequestOptions(opts...)
return &Client{
baseURL: options.BaseURL,
caller: core.NewCaller(
&core.CallerParams{
caller: internal.NewCaller(
&internal.CallerParams{
Client: options.HTTPClient,
MaxAttempts: options.MaxAttempts,
},
Expand All @@ -40,65 +37,49 @@ func (c *Client) List(
opts ...option.RequestOption,
) (*hookdeckgosdk.EventAttemptPaginatedResult, error) {
options := core.NewRequestOptions(opts...)

baseURL := "https://api.hookdeck.com/2024-09-01"
if c.baseURL != "" {
baseURL = c.baseURL
}
if options.BaseURL != "" {
baseURL = options.BaseURL
}
baseURL := internal.ResolveBaseURL(
options.BaseURL,
c.baseURL,
"https://api.hookdeck.com/2025-01-01-next",
)
endpointURL := baseURL + "/attempts"

queryParams, err := core.QueryValues(request)
queryParams, err := internal.QueryValues(request)
if err != nil {
return nil, err
}
if len(queryParams) > 0 {
endpointURL += "?" + queryParams.Encode()
}

headers := core.MergeHeaders(c.header.Clone(), options.ToHeader())

errorDecoder := func(statusCode int, body io.Reader) error {
raw, err := io.ReadAll(body)
if err != nil {
return err
}
apiError := core.NewAPIError(statusCode, errors.New(string(raw)))
decoder := json.NewDecoder(bytes.NewReader(raw))
switch statusCode {
case 400:
value := new(hookdeckgosdk.BadRequestError)
value.APIError = apiError
if err := decoder.Decode(value); err != nil {
return apiError
headers := internal.MergeHeaders(
c.header.Clone(),
options.ToHeader(),
)
errorCodes := internal.ErrorCodes{
400: func(apiError *core.APIError) error {
return &hookdeckgosdk.BadRequestError{
APIError: apiError,
}
return value
case 422:
value := new(hookdeckgosdk.UnprocessableEntityError)
value.APIError = apiError
if err := decoder.Decode(value); err != nil {
return apiError
},
422: func(apiError *core.APIError) error {
return &hookdeckgosdk.UnprocessableEntityError{
APIError: apiError,
}
return value
}
return apiError
},
}

var response *hookdeckgosdk.EventAttemptPaginatedResult
if err := c.caller.Call(
ctx,
&core.CallParams{
&internal.CallParams{
URL: endpointURL,
Method: http.MethodGet,
MaxAttempts: options.MaxAttempts,
Headers: headers,
MaxAttempts: options.MaxAttempts,
BodyProperties: options.BodyProperties,
QueryParameters: options.QueryParameters,
Client: options.HTTPClient,
Response: &response,
ErrorDecoder: errorDecoder,
ErrorDecoder: internal.NewErrorDecoder(errorCodes),
},
); err != nil {
return nil, err
Expand All @@ -112,51 +93,41 @@ func (c *Client) Retrieve(
opts ...option.RequestOption,
) (*hookdeckgosdk.EventAttempt, error) {
options := core.NewRequestOptions(opts...)

baseURL := "https://api.hookdeck.com/2024-09-01"
if c.baseURL != "" {
baseURL = c.baseURL
}
if options.BaseURL != "" {
baseURL = options.BaseURL
}
endpointURL := core.EncodeURL(baseURL+"/attempts/%v", id)

headers := core.MergeHeaders(c.header.Clone(), options.ToHeader())

errorDecoder := func(statusCode int, body io.Reader) error {
raw, err := io.ReadAll(body)
if err != nil {
return err
}
apiError := core.NewAPIError(statusCode, errors.New(string(raw)))
decoder := json.NewDecoder(bytes.NewReader(raw))
switch statusCode {
case 404:
value := new(hookdeckgosdk.NotFoundError)
value.APIError = apiError
if err := decoder.Decode(value); err != nil {
return apiError
baseURL := internal.ResolveBaseURL(
options.BaseURL,
c.baseURL,
"https://api.hookdeck.com/2025-01-01-next",
)
endpointURL := internal.EncodeURL(
baseURL+"/attempts/%v",
id,
)
headers := internal.MergeHeaders(
c.header.Clone(),
options.ToHeader(),
)
errorCodes := internal.ErrorCodes{
404: func(apiError *core.APIError) error {
return &hookdeckgosdk.NotFoundError{
APIError: apiError,
}
return value
}
return apiError
},
}

var response *hookdeckgosdk.EventAttempt
if err := c.caller.Call(
ctx,
&core.CallParams{
&internal.CallParams{
URL: endpointURL,
Method: http.MethodGet,
MaxAttempts: options.MaxAttempts,
Headers: headers,
MaxAttempts: options.MaxAttempts,
BodyProperties: options.BodyProperties,
QueryParameters: options.QueryParameters,
Client: options.HTTPClient,
Response: &response,
ResponseIsOptional: true,
ErrorDecoder: errorDecoder,
ErrorDecoder: internal.NewErrorDecoder(errorCodes),
},
); err != nil {
return nil, err
Expand Down
Loading