Skip to content

Commit

Permalink
Fix bug in r2 client
Browse files Browse the repository at this point in the history
  • Loading branch information
dkeysil committed Mar 22, 2024
1 parent c3cb446 commit a3e1af6
Showing 1 changed file with 4 additions and 6 deletions.
10 changes: 4 additions & 6 deletions clients/blocksdata/r2_client.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,16 +21,14 @@ var (
)

type blocksDataClient struct {
dispatcherURL *url.URL
dispatcherPath string
dispatcherURL *url.URL
}

func NewBlocksDataClient(dispatcherURL string) *blocksDataClient {
u, _ := url.Parse(dispatcherURL)

return &blocksDataClient{
dispatcherURL: u,
dispatcherPath: u.Path,
dispatcherURL: u,
}
}

Expand All @@ -41,7 +39,7 @@ type PresignedURLItem struct {
}

func (c *blocksDataClient) GetBlocksData(bucket int64) (_ *protocol.BlocksData, err error) {
c.dispatcherURL.Path, err = url.JoinPath(c.dispatcherPath, fmt.Sprintf("%d", bucket))
dispatcherUrl, err := url.JoinPath(c.dispatcherURL.String(), fmt.Sprintf("%d", bucket))
if err != nil {
return nil, err
}
Expand All @@ -53,7 +51,7 @@ func (c *blocksDataClient) GetBlocksData(bucket int64) (_ *protocol.BlocksData,
var item PresignedURLItem

err = backoff.Retry(func() error {
resp, err := httpclient.Default.Get(c.dispatcherURL.String())
resp, err := httpclient.Default.Get(dispatcherUrl)
if err != nil {
return err
}
Expand Down

0 comments on commit a3e1af6

Please sign in to comment.