Skip to content

Support authentication configuration and updates to case-sensitive API calls. #225

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 2 commits into
base: main
Choose a base branch
from
Open

Support authentication configuration and updates to case-sensitive API calls. #225

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
5d647e0
Fix case-sensitive API calls and use pointer slices.
sob Feb 4, 2025
2d44b58
support for readarr authentication settings
sob Feb 4, 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
8 changes: 6 additions & 2 deletions internal/provider/author_data_source.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -97,14 +97,18 @@ func (d *AuthorDataSource) Read(ctx context.Context, req datasource.ReadRequest,
}

// Get authors current value
response, _, err := d.client.AuthorApi.ListAuthor(ctx).Execute()
response, _, err := d.client.AuthorAPI.ListAuthor(ctx).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Read, authorDataSourceName, err))

return
}

data.find(ctx, data.ForeignAuthorID.ValueString(), response, &resp.Diagnostics)
pointerResponse := make([]*readarr.AuthorResource, len(response))
for i := range response {
pointerResponse[i] = &response[i]
}
data.find(ctx, data.ForeignAuthorID.ValueString(), pointerResponse, &resp.Diagnostics)
tflog.Trace(ctx, "read "+authorDataSourceName)
// Map response body to resource schema attribute
resp.Diagnostics.Append(resp.State.Set(ctx, &data)...)
Expand Down
8 changes: 4 additions & 4 deletions internal/provider/author_resource.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -156,7 +156,7 @@ func (r *AuthorResource) Create(ctx context.Context, req resource.CreateRequest,
options.SetMonitor(readarr.MONITORTYPES_ALL)
options.SetSearchForMissingBooks(true)

response, _, err := r.client.AuthorApi.CreateAuthor(ctx).AuthorResource(*request).Execute()
response, _, err := r.client.AuthorAPI.CreateAuthor(ctx).AuthorResource(*request).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Create, authorResourceName, err))

Expand All @@ -180,7 +180,7 @@ func (r *AuthorResource) Read(ctx context.Context, req resource.ReadRequest, res
}

// Get author current value
response, _, err := r.client.AuthorApi.GetAuthorById(ctx, int32(author.ID.ValueInt64())).Execute()
response, _, err := r.client.AuthorAPI.GetAuthorById(ctx, int32(author.ID.ValueInt64())).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Read, authorResourceName, err))

Expand All @@ -206,7 +206,7 @@ func (r *AuthorResource) Update(ctx context.Context, req resource.UpdateRequest,
// Update Author
request := author.read(ctx, &resp.Diagnostics)

response, _, err := r.client.AuthorApi.UpdateAuthor(ctx, fmt.Sprint(request.GetId())).AuthorResource(*request).Execute()
response, _, err := r.client.AuthorAPI.UpdateAuthor(ctx, fmt.Sprint(request.GetId())).AuthorResource(*request).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Update, authorResourceName, err))

Expand All @@ -229,7 +229,7 @@ func (r *AuthorResource) Delete(ctx context.Context, req resource.DeleteRequest,
}

// Delete author current value
_, err := r.client.AuthorApi.DeleteAuthor(ctx, int32(ID)).Execute()
_, err := r.client.AuthorAPI.DeleteAuthor(ctx, int32(ID)).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Delete, authorResourceName, err))

Expand Down
14 changes: 9 additions & 5 deletions internal/provider/authors_data_source.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -107,17 +107,21 @@ func (d *AuthorsDataSource) Configure(ctx context.Context, req datasource.Config

func (d *AuthorsDataSource) Read(ctx context.Context, _ datasource.ReadRequest, resp *datasource.ReadResponse) {
// Get authors current value
response, _, err := d.client.AuthorApi.ListAuthor(ctx).Execute()
response, _, err := d.client.AuthorAPI.ListAuthor(ctx).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.List, authorsDataSourceName, err))

return
}

tflog.Trace(ctx, "read "+authorsDataSourceName)
// Map response body to resource schema attribute
authors := make([]Author, len(response))
for i, m := range response {

pointerResponse := make([]*readarr.AuthorResource, len(response))
for i := range response {
pointerResponse[i] = &response[i]
}

authors := make([]Author, len(pointerResponse))
for i, m := range pointerResponse {
authors[i].write(ctx, m, &resp.Diagnostics)
}

Expand Down
14 changes: 12 additions & 2 deletions internal/provider/custom_format_condition_data_source.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -150,7 +150,11 @@ func (c *CustomFormatCondition) write(ctx context.Context, spec *readarr.CustomF
c.Name = types.StringValue(spec.GetName())
c.Negate = types.BoolValue(spec.GetNegate())
c.Required = types.BoolValue(spec.GetRequired())
helpers.WriteFields(ctx, c, spec.GetFields(), customFormatFields)
pointerFields := make([]*readarr.Field, len(spec.GetFields()))
for i := range spec.GetFields() {
pointerFields[i] = &spec.GetFields()[i]
}
helpers.WriteFields(ctx, c, pointerFields, customFormatFields)
}

func (c *CustomFormatCondition) read(ctx context.Context) *readarr.CustomFormatSpecificationSchema {
Expand All @@ -160,7 +164,13 @@ func (c *CustomFormatCondition) read(ctx context.Context) *readarr.CustomFormatS
spec.SetImplementation(c.Implementation.ValueString())
spec.SetNegate(c.Negate.ValueBool())
spec.SetRequired(c.Required.ValueBool())
spec.SetFields(helpers.ReadFields(ctx, c, customFormatFields))

pointerFields := helpers.ReadFields(ctx, c, customFormatFields)
var fields []readarr.Field
for _, f := range pointerFields {
fields = append(fields, *f)
}
spec.SetFields(fields)

return spec
}
8 changes: 6 additions & 2 deletions internal/provider/custom_format_data_source.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -102,14 +102,18 @@ func (d *CustomFormatDataSource) Read(ctx context.Context, req datasource.ReadRe
return
}
// Get customFormat current value
response, _, err := d.client.CustomFormatApi.ListCustomFormat(ctx).Execute()
response, _, err := d.client.CustomFormatAPI.ListCustomFormat(ctx).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Read, customFormatDataSourceName, err))

return
}

data.find(ctx, data.Name.ValueString(), response, &resp.Diagnostics)
pointerResponse := make([]*readarr.CustomFormatResource, len(response))
for i := range response {
pointerResponse[i] = &response[i]
}
data.find(ctx, data.Name.ValueString(), pointerResponse, &resp.Diagnostics)
tflog.Trace(ctx, "read "+customFormatDataSourceName)
resp.Diagnostics.Append(resp.State.Set(ctx, &data)...)
}
Expand Down
15 changes: 8 additions & 7 deletions internal/provider/custom_format_resource.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -149,7 +149,7 @@ func (r *CustomFormatResource) Create(ctx context.Context, req resource.CreateRe
// Create new CustomFormat
request := format.read(ctx, &resp.Diagnostics)

response, _, err := r.client.CustomFormatApi.CreateCustomFormat(ctx).CustomFormatResource(*request).Execute()
response, _, err := r.client.CustomFormatAPI.CreateCustomFormat(ctx).CustomFormatResource(*request).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Create, customFormatResourceName, err))

Expand All @@ -176,7 +176,7 @@ func (r *CustomFormatResource) Read(ctx context.Context, req resource.ReadReques
}

// Get CustomFormat current value
response, _, err := r.client.CustomFormatApi.GetCustomFormatById(ctx, int32(format.ID.ValueInt64())).Execute()
response, _, err := r.client.CustomFormatAPI.GetCustomFormatById(ctx, int32(format.ID.ValueInt64())).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Read, customFormatResourceName, err))

Expand Down Expand Up @@ -205,7 +205,7 @@ func (r *CustomFormatResource) Update(ctx context.Context, req resource.UpdateRe
// Update CustomFormat
request := format.read(ctx, &resp.Diagnostics)

response, _, err := r.client.CustomFormatApi.UpdateCustomFormat(ctx, strconv.Itoa(int(request.GetId()))).CustomFormatResource(*request).Execute()
response, _, err := r.client.CustomFormatAPI.UpdateCustomFormat(ctx, strconv.Itoa(int(request.GetId()))).CustomFormatResource(*request).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Update, customFormatResourceName, err))

Expand All @@ -231,7 +231,7 @@ func (r *CustomFormatResource) Delete(ctx context.Context, req resource.DeleteRe
}

// Delete CustomFormat current value
_, err := r.client.CustomFormatApi.DeleteCustomFormat(ctx, int32(ID)).Execute()
_, err := r.client.CustomFormatAPI.DeleteCustomFormat(ctx, int32(ID)).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Delete, customFormatResourceName, err))

Expand All @@ -252,7 +252,8 @@ func (c *CustomFormat) write(ctx context.Context, customFormat *readarr.CustomFo

specs := make([]CustomFormatCondition, len(customFormat.Specifications))
for n, s := range customFormat.Specifications {
specs[n].write(ctx, s)
specs[n] = CustomFormatCondition{}
specs[n].write(ctx, &s)
}

c.ID = types.Int64Value(int64(customFormat.GetId()))
Expand All @@ -265,10 +266,10 @@ func (c *CustomFormat) write(ctx context.Context, customFormat *readarr.CustomFo
func (c *CustomFormat) read(ctx context.Context, diags *diag.Diagnostics) *readarr.CustomFormatResource {
specifications := make([]CustomFormatCondition, len(c.Specifications.Elements()))
diags.Append(c.Specifications.ElementsAs(ctx, &specifications, false)...)
specs := make([]*readarr.CustomFormatSpecificationSchema, len(specifications))
specs := make([]readarr.CustomFormatSpecificationSchema, len(specifications))

for n, s := range specifications {
specs[n] = s.read(ctx)
specs[n] = *s.read(ctx)
}

format := readarr.NewCustomFormatResource()
Expand Down
15 changes: 10 additions & 5 deletions internal/provider/custom_formats_data_source.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -113,18 +113,23 @@ func (d *CustomFormatsDataSource) Configure(ctx context.Context, req datasource.
}

func (d *CustomFormatsDataSource) Read(ctx context.Context, _ datasource.ReadRequest, resp *datasource.ReadResponse) {
// Get custom formatss current value
response, _, err := d.client.CustomFormatApi.ListCustomFormat(ctx).Execute()
// Get custom formats current value
response, _, err := d.client.CustomFormatAPI.ListCustomFormat(ctx).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.List, customFormatsDataSourceName, err))

return
}

tflog.Trace(ctx, "read "+customFormatsDataSourceName)
// Map response body to resource schema attribute
formats := make([]CustomFormat, len(response))
for i, p := range response {

pointerResponse := make([]*readarr.CustomFormatResource, len(response))
for i := range response {
pointerResponse[i] = &response[i]
}

formats := make([]CustomFormat, len(pointerResponse))
for i, p := range pointerResponse {
Comment on lines +126 to +132
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I'd like to align this provider's code with the other ones instead of doing this. Do you mind changing only the API case in this commit? I'll then add few commits to align with the other providers

formats[i].write(ctx, p, &resp.Diagnostics)
}

Expand Down
8 changes: 6 additions & 2 deletions internal/provider/delay_profile_data_source.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -88,14 +88,18 @@ func (d *DelayProfileDataSource) Read(ctx context.Context, req datasource.ReadRe
return
}
// Get delayprofiles current value
response, _, err := d.client.DelayProfileApi.ListDelayProfile(ctx).Execute()
response, _, err := d.client.DelayProfileAPI.ListDelayProfile(ctx).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Read, delayProfileDataSourceName, err))

return
}

data.find(ctx, data.ID.ValueInt64(), response, &resp.Diagnostics)
profiles := make([]*readarr.DelayProfileResource, len(response))
for i := range response {
profiles[i] = &response[i]
}
data.find(ctx, data.ID.ValueInt64(), profiles, &resp.Diagnostics)

tflog.Trace(ctx, "read "+delayProfileDataSourceName)
// Map response body to resource schema attribute
Expand Down
10 changes: 5 additions & 5 deletions internal/provider/delay_profile_resource.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -139,7 +139,7 @@ func (r *DelayProfileResource) Create(ctx context.Context, req resource.CreateRe
request := profile.read(ctx, &resp.Diagnostics)

// Create new DelayProfile
response, _, err := r.client.DelayProfileApi.CreateDelayProfile(ctx).DelayProfileResource(*request).Execute()
response, _, err := r.client.DelayProfileAPI.CreateDelayProfile(ctx).DelayProfileResource(*request).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Create, delayProfileResourceName, err))

Expand All @@ -152,7 +152,7 @@ func (r *DelayProfileResource) Create(ctx context.Context, req resource.CreateRe
if !profile.Order.IsUnknown() {
response.Order = request.Order

response, _, err = r.client.DelayProfileApi.UpdateDelayProfile(ctx, strconv.Itoa(int(response.GetId()))).DelayProfileResource(*response).Execute()
response, _, err = r.client.DelayProfileAPI.UpdateDelayProfile(ctx, strconv.Itoa(int(response.GetId()))).DelayProfileResource(*response).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Update, delayProfileResourceName, err))

Expand All @@ -176,7 +176,7 @@ func (r *DelayProfileResource) Read(ctx context.Context, req resource.ReadReques
}

// Get delayprofile current value
response, _, err := r.client.DelayProfileApi.GetDelayProfileById(ctx, int32(profile.ID.ValueInt64())).Execute()
response, _, err := r.client.DelayProfileAPI.GetDelayProfileById(ctx, int32(profile.ID.ValueInt64())).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Read, delayProfileResourceName, err))

Expand All @@ -203,7 +203,7 @@ func (r *DelayProfileResource) Update(ctx context.Context, req resource.UpdateRe
request := profile.read(ctx, &resp.Diagnostics)

// Update DelayProfile
response, _, err := r.client.DelayProfileApi.UpdateDelayProfile(ctx, strconv.Itoa(int(request.GetId()))).DelayProfileResource(*request).Execute()
response, _, err := r.client.DelayProfileAPI.UpdateDelayProfile(ctx, strconv.Itoa(int(request.GetId()))).DelayProfileResource(*request).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Update, delayProfileResourceName, err))

Expand All @@ -226,7 +226,7 @@ func (r *DelayProfileResource) Delete(ctx context.Context, req resource.DeleteRe
}

// Delete delayprofile current value
_, err := r.client.DelayProfileApi.DeleteDelayProfile(ctx, int32(ID)).Execute()
_, err := r.client.DelayProfileAPI.DeleteDelayProfile(ctx, int32(ID)).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Delete, delayProfileResourceName, err))

Expand Down
4 changes: 2 additions & 2 deletions internal/provider/delay_profiles_data_source.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ func (d *DelayProfilesDataSource) Configure(ctx context.Context, req datasource.

func (d *DelayProfilesDataSource) Read(ctx context.Context, _ datasource.ReadRequest, resp *datasource.ReadResponse) {
// Get delayprofiles current value
response, _, err := d.client.DelayProfileApi.ListDelayProfile(ctx).Execute()
response, _, err := d.client.DelayProfileAPI.ListDelayProfile(ctx).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.List, delayProfileResourceName, err))

Expand All @@ -109,7 +109,7 @@ func (d *DelayProfilesDataSource) Read(ctx context.Context, _ datasource.ReadReq
// Map response body to resource schema attribute
profiles := make([]DelayProfile, len(response))
for i, p := range response {
profiles[i].write(ctx, p, &resp.Diagnostics)
profiles[i].write(ctx, &p, &resp.Diagnostics)
}

profileList, diags := types.SetValueFrom(ctx, DelayProfile{}.getType(), profiles)
Expand Down
8 changes: 4 additions & 4 deletions internal/provider/download_client_aria2_resource.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -183,7 +183,7 @@ func (r *DownloadClientAria2Resource) Create(ctx context.Context, req resource.C
// Create new DownloadClientAria2
request := client.read(ctx, &resp.Diagnostics)

response, _, err := r.client.DownloadClientApi.CreateDownloadClient(ctx).DownloadClientResource(*request).Execute()
response, _, err := r.client.DownloadClientAPI.CreateDownloadClient(ctx).DownloadClientResource(*request).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Create, downloadClientAria2ResourceName, err))

Expand All @@ -207,7 +207,7 @@ func (r *DownloadClientAria2Resource) Read(ctx context.Context, req resource.Rea
}

// Get DownloadClientAria2 current value
response, _, err := r.client.DownloadClientApi.GetDownloadClientById(ctx, int32(client.ID.ValueInt64())).Execute()
response, _, err := r.client.DownloadClientAPI.GetDownloadClientById(ctx, int32(client.ID.ValueInt64())).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Read, downloadClientAria2ResourceName, err))

Expand All @@ -233,7 +233,7 @@ func (r *DownloadClientAria2Resource) Update(ctx context.Context, req resource.U
// Update DownloadClientAria2
request := client.read(ctx, &resp.Diagnostics)

response, _, err := r.client.DownloadClientApi.UpdateDownloadClient(ctx, strconv.Itoa(int(request.GetId()))).DownloadClientResource(*request).Execute()
response, _, err := r.client.DownloadClientAPI.UpdateDownloadClient(ctx, strconv.Itoa(int(request.GetId()))).DownloadClientResource(*request).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Update, downloadClientAria2ResourceName, err))

Expand All @@ -256,7 +256,7 @@ func (r *DownloadClientAria2Resource) Delete(ctx context.Context, req resource.D
}

// Delete DownloadClientAria2 current value
_, err := r.client.DownloadClientApi.DeleteDownloadClient(ctx, int32(ID)).Execute()
_, err := r.client.DownloadClientAPI.DeleteDownloadClient(ctx, int32(ID)).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Delete, downloadClientAria2ResourceName, err))

Expand Down
2 changes: 1 addition & 1 deletion internal/provider/download_client_config_data_source.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ func (d *DownloadClientConfigDataSource) Configure(ctx context.Context, req data

func (d *DownloadClientConfigDataSource) Read(ctx context.Context, _ datasource.ReadRequest, resp *datasource.ReadResponse) {
// Get indexer config current value
response, _, err := d.client.DownloadClientConfigApi.GetDownloadClientConfig(ctx).Execute()
response, _, err := d.client.DownloadClientConfigAPI.GetDownloadClientConfig(ctx).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Read, downloadClientConfigDataSourceName, err))

Expand Down
6 changes: 3 additions & 3 deletions internal/provider/download_client_config_resource.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -92,7 +92,7 @@ func (r *DownloadClientConfigResource) Create(ctx context.Context, req resource.
request.SetId(1)

// Create new DownloadClientConfig
response, _, err := r.client.DownloadClientConfigApi.UpdateDownloadClientConfig(ctx, strconv.Itoa(int(request.GetId()))).DownloadClientConfigResource(*request).Execute()
response, _, err := r.client.DownloadClientConfigAPI.UpdateDownloadClientConfig(ctx, strconv.Itoa(int(request.GetId()))).DownloadClientConfigResource(*request).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Create, downloadClientConfigResourceName, err))

Expand All @@ -116,7 +116,7 @@ func (r *DownloadClientConfigResource) Read(ctx context.Context, req resource.Re
}

// Get downloadClientConfig current value
response, _, err := r.client.DownloadClientConfigApi.GetDownloadClientConfig(ctx).Execute()
response, _, err := r.client.DownloadClientConfigAPI.GetDownloadClientConfig(ctx).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Read, downloadClientConfigResourceName, err))

Expand All @@ -143,7 +143,7 @@ func (r *DownloadClientConfigResource) Update(ctx context.Context, req resource.
request := config.read()

// Update DownloadClientConfig
response, _, err := r.client.DownloadClientConfigApi.UpdateDownloadClientConfig(ctx, strconv.Itoa(int(request.GetId()))).DownloadClientConfigResource(*request).Execute()
response, _, err := r.client.DownloadClientConfigAPI.UpdateDownloadClientConfig(ctx, strconv.Itoa(int(request.GetId()))).DownloadClientConfigResource(*request).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Update, downloadClientConfigResourceName, err))

Expand Down
8 changes: 6 additions & 2 deletions internal/provider/download_client_data_source.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -236,14 +236,18 @@ func (d *DownloadClientDataSource) Read(ctx context.Context, req datasource.Read
return
}
// Get downloadClient current value
response, _, err := d.client.DownloadClientApi.ListDownloadClient(ctx).Execute()
response, _, err := d.client.DownloadClientAPI.ListDownloadClient(ctx).Execute()
if err != nil {
resp.Diagnostics.AddError(helpers.ClientError, helpers.ParseClientError(helpers.Read, downloadClientDataSourceName, err))

return
}

data.find(ctx, data.Name.ValueString(), response, &resp.Diagnostics)
clients := make([]*readarr.DownloadClientResource, len(response))
for i := range response {
clients[i] = &response[i]
}
data.find(ctx, data.Name.ValueString(), clients, &resp.Diagnostics)
tflog.Trace(ctx, "read "+downloadClientDataSourceName)
// Map response body to resource schema attribute
resp.Diagnostics.Append(resp.State.Set(ctx, &data)...)
Expand Down
Loading