Skip to content
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

WIP: Change eliminate maps from rack_type schema - step 1 links #337

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

WIP: Change eliminate maps from rack_type schema - step 1 links #337

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
093a6d2
convert as and gs `links` from map to set
chrismarget-j Aug 30, 2023
7809f63
make docs
chrismarget-j Aug 30, 2023
8d088df
eliminate unnecessary `GetLinks()` method
chrismarget-j Aug 31, 2023
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
71 changes: 24 additions & 47 deletions apstra/design/rack_type_access_switch.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@ import (
"github.com/Juniper/apstra-go-sdk/apstra"
"github.com/Juniper/terraform-provider-apstra/apstra/utils"
"github.com/hashicorp/terraform-plugin-framework-validators/int64validator"
"github.com/hashicorp/terraform-plugin-framework-validators/mapvalidator"
"github.com/hashicorp/terraform-plugin-framework-validators/setvalidator"
"github.com/hashicorp/terraform-plugin-framework-validators/stringvalidator"
"github.com/hashicorp/terraform-plugin-framework/attr"
Expand Down Expand Up @@ -41,7 +40,7 @@ type AccessSwitch struct {
EsiLagInfo types.Object `tfsdk:"esi_lag_info"`
RedundancyProtocol types.String `tfsdk:"redundancy_protocol"`
Count types.Int64 `tfsdk:"count"`
Links types.Map `tfsdk:"links"`
Links types.Set `tfsdk:"links"`
TagIds types.Set `tfsdk:"tag_ids"`
Tags types.Set `tfsdk:"tags"`
}
Expand Down Expand Up @@ -70,10 +69,9 @@ func (o AccessSwitch) DataSourceAttributes() map[string]dataSourceSchema.Attribu
MarkdownDescription: "Count of Access Switches of this type.",
Computed: true,
},
"links": dataSourceSchema.MapNestedAttribute{
"links": dataSourceSchema.SetNestedAttribute{
MarkdownDescription: "Details links from this Access Switch to upstream switches within this Rack Type.",
Computed: true,
Validators: []validator.Map{mapvalidator.SizeAtLeast(1)},
NestedObject: dataSourceSchema.NestedAttributeObject{
Attributes: RackLink{}.DataSourceAttributes(),
},
Expand Down Expand Up @@ -119,10 +117,10 @@ func (o AccessSwitch) ResourceAttributes() map[string]resourceSchema.Attribute {
Required: true,
Validators: []validator.Int64{int64validator.AtLeast(1)},
},
"links": resourceSchema.MapNestedAttribute{
"links": resourceSchema.SetNestedAttribute{
MarkdownDescription: "Each Access Switch is required to have at least one Link to a Leaf Switch.",
Required: true,
Validators: []validator.Map{mapvalidator.SizeAtLeast(1)},
Validators: []validator.Set{setvalidator.SizeAtLeast(1)},
NestedObject: resourceSchema.NestedAttributeObject{
Attributes: RackLink{}.ResourceAttributes(),
},
Expand Down Expand Up @@ -168,7 +166,7 @@ func (o AccessSwitch) ResourceAttributesNested() map[string]resourceSchema.Attri
MarkdownDescription: "Number of Access Switches of this type.",
Computed: true,
},
"links": resourceSchema.MapNestedAttribute{
"links": resourceSchema.SetNestedAttribute{
MarkdownDescription: "Each Access Switch is required to have at least one Link to a Leaf Switch.",
Computed: true,
NestedObject: resourceSchema.NestedAttributeObject{
Expand Down Expand Up @@ -197,7 +195,7 @@ func (o AccessSwitch) AttrTypes() map[string]attr.Type {
"esi_lag_info": types.ObjectType{AttrTypes: EsiLagInfo{}.AttrTypes()},
"redundancy_protocol": types.StringType,
"count": types.Int64Type,
"links": types.MapType{ElemType: types.ObjectType{AttrTypes: RackLink{}.AttrTypes()}},
"links": types.SetType{ElemType: types.ObjectType{AttrTypes: RackLink{}.AttrTypes()}},
"tag_ids": types.SetType{ElemType: types.StringType},
"tags": types.SetType{ElemType: types.ObjectType{AttrTypes: Tag{}.AttrTypes()}},
}
Expand All @@ -211,26 +209,21 @@ func (o *AccessSwitch) Request(ctx context.Context, path path.Path, rack *RackTy

lacpActive := apstra.RackLinkLagModeActive.String()

links := o.GetLinks(ctx, diags)
links := make([]RackLink, len(o.Links.Elements()))
diags.Append(o.Links.ElementsAs(ctx, &links, false)...)
if diags.HasError() {
return nil
}

linkRequests := make([]apstra.RackLinkRequest, len(links))
i := 0
for name, link := range links {
for i, link := range links {
link.LagMode = types.StringValue(lacpActive)
lr := link.Request(ctx, path.AtName("links").AtMapKey(name), rack, diags)
if diags.HasError() {
return nil
}
lr.Label = name
lr := link.Request(ctx, path.AtName("links").AtListIndex(i), rack, diags)
if diags.HasError() {
return nil
}

linkRequests[i] = *lr
i++
}

tagIds := make([]apstra.ObjectId, len(o.TagIds.Elements()))
Expand Down Expand Up @@ -265,26 +258,11 @@ func (o *AccessSwitch) LoadApiData(ctx context.Context, in *apstra.RackElementAc
o.EsiLagInfo = NewEsiLagInfo(ctx, in.EsiLagInfo, diags)
o.RedundancyProtocol = utils.StringValueWithNull(ctx, in.RedundancyProtocol.String(), apstra.AccessRedundancyProtocolNone.String(), diags)
o.Count = types.Int64Value(int64(in.InstanceCount))
o.Links = NewLinkMap(ctx, in.Links, diags)
o.Links = NewLinkSet(ctx, in.Links, diags)
o.TagIds = types.SetNull(types.StringType)
o.Tags = NewTagSet(ctx, in.Tags, diags)
}

func (o *AccessSwitch) GetLinks(ctx context.Context, diags *diag.Diagnostics) map[string]RackLink {
links := make(map[string]RackLink, len(o.Links.Elements()))
d := o.Links.ElementsAs(ctx, &links, false)
diags.Append(d...)
if diags.HasError() {
return nil
}

// copy the link name from the map key into the object's Name field
for name, link := range links {
links[name] = link
}
return links
}

func (o *AccessSwitch) CopyWriteOnlyElements(ctx context.Context, src *AccessSwitch, diags *diag.Diagnostics) {
if src == nil {
diags.AddError(errProviderBug, "AccessSwitch.CopyWriteOnlyElements: attempt to copy from nil source")
Expand All @@ -294,30 +272,29 @@ func (o *AccessSwitch) CopyWriteOnlyElements(ctx context.Context, src *AccessSwi
o.LogicalDeviceId = types.StringValue(src.LogicalDeviceId.ValueString())
o.TagIds = utils.SetValueOrNull(ctx, types.StringType, src.TagIds.Elements(), diags)

var d diag.Diagnostics

srcLinks := make(map[string]RackLink, len(src.Links.Elements()))
d = src.Links.ElementsAs(ctx, &srcLinks, false)
diags.Append(d...)
// extract the source links because we need the tag IDs
srcLinks := make([]RackLink, len(src.Links.Elements()))
diags.Append(src.Links.ElementsAs(ctx, &srcLinks, false)...)
if diags.HasError() {
return
}

dstLinks := make(map[string]RackLink, len(o.Links.Elements()))
d = o.Links.ElementsAs(ctx, &dstLinks, false)
diags.Append(d...)
// extract the destination links because we'll copy the tag IDs here
dstLinks := make([]RackLink, len(o.Links.Elements()))
diags.Append(o.Links.ElementsAs(ctx, &dstLinks, false)...)
if diags.HasError() {
return
}

for name, dstLink := range dstLinks {
if srcLink, ok := srcLinks[name]; ok {
dstLink.CopyWriteOnlyElements(ctx, &srcLink, diags)
dstLinks[name] = dstLink
}
// copy from each source to each destination
for i := range dstLinks[:utils.Min(len(srcLinks), len(dstLinks))] {
dstLinks[i].CopyWriteOnlyElements(ctx, &srcLinks[i], diags)
}
if diags.HasError() {
return
}

o.Links = utils.MapValueOrNull(ctx, types.ObjectType{AttrTypes: RackLink{}.AttrTypes()}, dstLinks, diags)
o.Links = utils.SetValueOrNull(ctx, types.ObjectType{AttrTypes: RackLink{}.AttrTypes()}, dstLinks, diags)
if diags.HasError() {
return
}
Expand Down
72 changes: 24 additions & 48 deletions apstra/design/rack_type_generic_system.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@ import (
"github.com/Juniper/apstra-go-sdk/apstra"
"github.com/Juniper/terraform-provider-apstra/apstra/utils"
"github.com/hashicorp/terraform-plugin-framework-validators/int64validator"
"github.com/hashicorp/terraform-plugin-framework-validators/mapvalidator"
"github.com/hashicorp/terraform-plugin-framework-validators/setvalidator"
"github.com/hashicorp/terraform-plugin-framework-validators/stringvalidator"
"github.com/hashicorp/terraform-plugin-framework/attr"
Expand Down Expand Up @@ -34,7 +33,7 @@ type GenericSystem struct {
PortChannelIdMin types.Int64 `tfsdk:"port_channel_id_min"`
PortChannelIdMax types.Int64 `tfsdk:"port_channel_id_max"`
Count types.Int64 `tfsdk:"count"`
Links types.Map `tfsdk:"links"`
Links types.Set `tfsdk:"links"`
TagIds types.Set `tfsdk:"tag_ids"`
Tags types.Set `tfsdk:"tags"`
}
Expand Down Expand Up @@ -62,10 +61,9 @@ func (o GenericSystem) DataSourceAttributes() map[string]dataSourceSchema.Attrib
MarkdownDescription: "Number of Generic Systems of this type.",
Computed: true,
},
"links": dataSourceSchema.MapNestedAttribute{
"links": dataSourceSchema.SetNestedAttribute{
MarkdownDescription: "Details links from this Generic System to upstream switches within this Rack Type.",
Computed: true,
Validators: []validator.Map{mapvalidator.SizeAtLeast(1)},
NestedObject: dataSourceSchema.NestedAttributeObject{
Attributes: RackLink{}.DataSourceAttributes(),
},
Expand Down Expand Up @@ -122,10 +120,10 @@ func (o GenericSystem) ResourceAttributes() map[string]resourceSchema.Attribute
Required: true,
Validators: []validator.Int64{int64validator.AtLeast(1)},
},
"links": resourceSchema.MapNestedAttribute{
"links": resourceSchema.SetNestedAttribute{
MarkdownDescription: "Each Generic System is required to have at least one Link to a Leaf Switch or Access Switch.",
Required: true,
Validators: []validator.Map{mapvalidator.SizeAtLeast(1)},
Validators: []validator.Set{setvalidator.SizeAtLeast(1)},
NestedObject: resourceSchema.NestedAttributeObject{
Attributes: RackLink{}.ResourceAttributes(),
},
Expand Down Expand Up @@ -169,7 +167,7 @@ func (o GenericSystem) ResourceAttributesNested() map[string]resourceSchema.Attr
MarkdownDescription: "Number of Generic Systems of this type.",
Computed: true,
},
"links": resourceSchema.MapNestedAttribute{
"links": resourceSchema.SetNestedAttribute{
MarkdownDescription: "Each Generic System is required to have at least one Link to a Leaf Switch or Access Switch.",
Computed: true,
NestedObject: resourceSchema.NestedAttributeObject{
Expand Down Expand Up @@ -198,7 +196,7 @@ func (o GenericSystem) AttrTypes() map[string]attr.Type {
"port_channel_id_min": types.Int64Type,
"port_channel_id_max": types.Int64Type,
"count": types.Int64Type,
"links": types.MapType{ElemType: types.ObjectType{AttrTypes: RackLink{}.AttrTypes()}},
"links": types.SetType{ElemType: types.ObjectType{AttrTypes: RackLink{}.AttrTypes()}},
"tag_ids": types.SetType{ElemType: types.StringType},
"tags": types.SetType{ElemType: types.ObjectType{AttrTypes: Tag{}.AttrTypes()}},
}
Expand All @@ -213,25 +211,20 @@ func (o *GenericSystem) Request(ctx context.Context, path path.Path, rack *RackT
poIdMaxVal = int(o.PortChannelIdMax.ValueInt64())
}

links := o.GetLinks(ctx, diags)
links := make([]RackLink, len(o.Links.Elements()))
diags.Append(o.Links.ElementsAs(ctx, &links, false)...)
if diags.HasError() {
return nil
}

linkRequests := make([]apstra.RackLinkRequest, len(links))
i := 0
for name, link := range links {
lr := link.Request(ctx, path.AtName("links").AtMapKey(name), rack, diags)
if diags.HasError() {
return nil
}
lr.Label = name
for i, link := range links {
lr := link.Request(ctx, path.AtName("links").AtListIndex(i), rack, diags)
if diags.HasError() {
return nil
}

linkRequests[i] = *lr
i++
}

tagIds := make([]apstra.ObjectId, len(o.TagIds.Elements()))
Expand All @@ -256,26 +249,11 @@ func (o *GenericSystem) LoadApiData(ctx context.Context, in *apstra.RackElementG
o.PortChannelIdMin = types.Int64Value(int64(in.PortChannelIdMin))
o.PortChannelIdMax = types.Int64Value(int64(in.PortChannelIdMax))
o.Count = types.Int64Value(int64(in.Count))
o.Links = NewLinkMap(ctx, in.Links, diags)
o.Links = NewLinkSet(ctx, in.Links, diags)
o.TagIds = types.SetNull(types.StringType)
o.Tags = NewTagSet(ctx, in.Tags, diags)
}

func (o *GenericSystem) GetLinks(ctx context.Context, diags *diag.Diagnostics) map[string]RackLink {
links := make(map[string]RackLink, len(o.Links.Elements()))
d := o.Links.ElementsAs(ctx, &links, false)
diags.Append(d...)
if diags.HasError() {
return nil
}

// copy the link name from the map key into the object's Name field
for name, link := range links {
links[name] = link
}
return links
}

func (o *GenericSystem) CopyWriteOnlyElements(ctx context.Context, src *GenericSystem, diags *diag.Diagnostics) {
if src == nil {
diags.AddError(errProviderBug, "GenericSystem.CopyWriteOnlyElements: attempt to copy from nil source")
Expand All @@ -285,34 +263,32 @@ func (o *GenericSystem) CopyWriteOnlyElements(ctx context.Context, src *GenericS
o.LogicalDeviceId = types.StringValue(src.LogicalDeviceId.ValueString())
o.TagIds = utils.SetValueOrNull(ctx, types.StringType, src.TagIds.Elements(), diags)

var d diag.Diagnostics

srcLinks := make(map[string]RackLink, len(src.Links.Elements()))
d = src.Links.ElementsAs(ctx, &srcLinks, false)
diags.Append(d...)
// extract the source links because we need the tag IDs
srcLinks := make([]RackLink, len(src.Links.Elements()))
diags.Append(src.Links.ElementsAs(ctx, &srcLinks, false)...)
if diags.HasError() {
return
}

dstLinks := make(map[string]RackLink, len(o.Links.Elements()))
d = o.Links.ElementsAs(ctx, &dstLinks, false)
diags.Append(d...)
// extract the destination links because we'll copy the tag IDs here
dstLinks := make([]RackLink, len(o.Links.Elements()))
diags.Append(o.Links.ElementsAs(ctx, &dstLinks, false)...)
if diags.HasError() {
return
}

for name, dstLink := range dstLinks {
if srcLink, ok := srcLinks[name]; ok {
dstLink.CopyWriteOnlyElements(ctx, &srcLink, diags)
dstLinks[name] = dstLink
}
// copy from each source to each destination
for i := range dstLinks[:utils.Min(len(srcLinks), len(dstLinks))] {
dstLinks[i].CopyWriteOnlyElements(ctx, &srcLinks[i], diags)
}

o.Links = utils.MapValueOrNull(ctx, types.ObjectType{AttrTypes: RackLink{}.AttrTypes()}, dstLinks, diags)
if diags.HasError() {
return
}

o.Links = utils.SetValueOrNull(ctx, types.ObjectType{AttrTypes: RackLink{}.AttrTypes()}, dstLinks, diags)
if diags.HasError() {
return
}
}

func NewGenericSystemMap(ctx context.Context, in []apstra.RackElementGenericSystem, diags *diag.Diagnostics) types.Map {
Expand Down
Loading