Skip to content

Commit

Permalink
add cleanup gateway
Browse files Browse the repository at this point in the history
  • Loading branch information
aayushrangwala committed Jan 30, 2024
1 parent 280a232 commit cdd963f
Show file tree
Hide file tree
Showing 4 changed files with 13 additions and 13 deletions.
2 changes: 1 addition & 1 deletion test/e2e/gateways/bgp-dynamic-neighbour/delete_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ func TestBgpDynamicNeighbors_Delete(t *testing.T) {
vrf := helper.CreateTestVrfs(t, project.GetId(), "test-vrf-"+randomStr, vlan.GetVxlan())
vrfIpRes := helper.CreateTestVrfIpRequest(t, project.GetId(), vrf.GetId())
gway := helper.CreateTestVrfGateway(t, project.GetId(), vrfIpRes.VrfIpReservation.GetId(), vlan.GetId())
bgpDynamicNeighbor := helper.CreateTestBgpDynamicNeighbour(t, gway.GetId(), gway.IpReservation.GetAddress(), 65000)
bgpDynamicNeighbor := helper.CreateTestBgpDynamicNeighbor(t, gway.GetId(), gway.IpReservation.GetAddress(), 65000)

tests := []struct {
name string
Expand Down
2 changes: 1 addition & 1 deletion test/e2e/gateways/bgp-dynamic-neighbour/get_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ func TestBgpDynamicNeighbors_Get(t *testing.T) {
vrf := helper.CreateTestVrfs(t, project.GetId(), "test-vrf-"+randomStr, vlan.GetVxlan())
vrfIpRes := helper.CreateTestVrfIpRequest(t, project.GetId(), vrf.GetId())
gway := helper.CreateTestVrfGateway(t, project.GetId(), vrfIpRes.VrfIpReservation.GetId(), vlan.GetId())
bgpDynamicNeighbor := helper.CreateTestBgpDynamicNeighbour(t, gway.GetId(), gway.IpReservation.GetAddress(), 65000)
bgpDynamicNeighbor := helper.CreateTestBgpDynamicNeighbor(t, gway.GetId(), gway.IpReservation.GetAddress(), 65000)

tests := []struct {
name string
Expand Down
2 changes: 1 addition & 1 deletion test/e2e/gateways/bgp-dynamic-neighbour/list_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ func TestBgpDynamicNeighbors_List(t *testing.T) {
vrf := helper.CreateTestVrfs(t, project.GetId(), "test-vrf-"+randomStr, vlan.GetVxlan())
vrfIpRes := helper.CreateTestVrfIpRequest(t, project.GetId(), vrf.GetId())
gway := helper.CreateTestVrfGateway(t, project.GetId(), vrfIpRes.VrfIpReservation.GetId(), vlan.GetId())
bgpDynamicNeighbor := helper.CreateTestBgpDynamicNeighbour(t, gway.GetId(), gway.IpReservation.GetAddress(), 65000)
bgpDynamicNeighbor := helper.CreateTestBgpDynamicNeighbor(t, gway.GetId(), gway.IpReservation.GetAddress(), 65000)

tests := []struct {
name string
Expand Down
20 changes: 10 additions & 10 deletions test/helper/helper.go
Original file line number Diff line number Diff line change
Expand Up @@ -127,6 +127,10 @@ func CreateTestGateway(t *testing.T, projectId, vlanId string, privateIPv4Subnet
t.Fatal("Nil gateway returned. Error when calling `MetalGatewaysApi.CreateMetalGateway`")
}

t.Cleanup(func() {
CleanTestGateway(t, gateway.MetalGateway.GetId())
})

return gateway.MetalGateway
}

Expand Down Expand Up @@ -401,18 +405,17 @@ func AssertPortCmdOutput(t *testing.T, port *metalv1.Port, out, networkType stri
}
}

func CleanTestGateway(t *testing.T, gatewayId string) error {
func CleanTestGateway(t *testing.T, gatewayId string) {
t.Helper()

TestApiClient := TestClient()
_, _, err := TestApiClient.MetalGatewaysApi.
_, resp, err := TestApiClient.MetalGatewaysApi.
DeleteMetalGateway(context.Background(), gatewayId).
Include([]string{"ip_reservation"}).
Execute()
if err != nil {
return fmt.Errorf("Error when calling `MetalGatewaysApi.DeleteMetalGateway`` for %v: %v\n", gatewayId, err)
if err != nil && resp.StatusCode != http.StatusNotFound {
t.Fatalf("Error when calling `MetalGatewaysApi.DeleteMetalGateway`` for %v: %v\n", gatewayId, err)
}
return nil
}

func CreateTestInterConnection(t *testing.T, projectId, name string) *metalv1.Interconnection {
Expand Down Expand Up @@ -675,7 +678,7 @@ func CleanTestVrfs(t *testing.T, vrfId string) {

resp, err := TestApiClient.VRFsApi.DeleteVrf(context.Background(), vrfId).Execute()
if err != nil && resp.StatusCode != http.StatusNotFound {
t.Fatalf("Error when calling `VRFsApi.DeleteVrf`` for %v: %v\n", vrfId, err)
t.Fatalf("Error when calling `VRFsApi.DeleteVrf`` for ID: %v: with error: %v\n", vrfId, err)
}
}

Expand Down Expand Up @@ -713,7 +716,6 @@ func CleanTestVrfIpRequest(t *testing.T, IPReservationId string) {
}
}

<<<<<<< HEAD
func CreateTestVrfRoute(t *testing.T, vrfId string) *metalv1.VrfRoute {
t.Helper()
TestApiClient := TestClient()
Expand Down Expand Up @@ -782,10 +784,8 @@ func CleanTestVrfGateway(t *testing.T, gatewayId string) {
t.Fatalf("Error when calling `MetalGatewaysApi.DeleteMetalGateway`` for %v: %v\n", gatewayId, err)
}
}
func CreateTestBgpDynamicNeighbour(t *testing.T, gatewayId, iprange string, asn int32) *metalv1.BgpDynamicNeighbor {
=======

func CreateTestBgpDynamicNeighbor(t *testing.T, gatewayId, iprange string, asn int32) *metalv1.BgpDynamicNeighbor {
>>>>>>> e44373e (Fix review comments)
TestApiClient := TestClient()
t.Helper()

Expand Down

0 comments on commit cdd963f

Please sign in to comment.