2014-11-30 12:38:45 +01:00
|
|
|
package aws
|
|
|
|
|
|
|
|
import (
|
|
|
|
"reflect"
|
|
|
|
"testing"
|
|
|
|
|
2015-04-13 18:14:21 +02:00
|
|
|
"github.com/awslabs/aws-sdk-go/aws"
|
|
|
|
"github.com/awslabs/aws-sdk-go/service/ec2"
|
2014-11-30 12:38:45 +01:00
|
|
|
)
|
|
|
|
|
2015-03-11 21:01:07 +01:00
|
|
|
func Test_expandNetworkACLEntry(t *testing.T) {
|
2014-11-30 12:38:45 +01:00
|
|
|
input := []interface{}{
|
|
|
|
map[string]interface{}{
|
2014-12-01 09:49:05 +01:00
|
|
|
"protocol": "tcp",
|
|
|
|
"from_port": 22,
|
|
|
|
"to_port": 22,
|
2014-11-30 12:38:45 +01:00
|
|
|
"cidr_block": "0.0.0.0/0",
|
2014-12-01 09:49:05 +01:00
|
|
|
"action": "deny",
|
|
|
|
"rule_no": 1,
|
2014-11-30 12:38:45 +01:00
|
|
|
},
|
|
|
|
map[string]interface{}{
|
2014-12-01 09:49:05 +01:00
|
|
|
"protocol": "tcp",
|
|
|
|
"from_port": 443,
|
|
|
|
"to_port": 443,
|
2014-11-30 12:38:45 +01:00
|
|
|
"cidr_block": "0.0.0.0/0",
|
2014-12-01 09:49:05 +01:00
|
|
|
"action": "deny",
|
|
|
|
"rule_no": 2,
|
2014-11-30 12:38:45 +01:00
|
|
|
},
|
2015-04-22 12:35:23 +02:00
|
|
|
map[string]interface{}{
|
|
|
|
"protocol": "-1",
|
|
|
|
"from_port": 443,
|
|
|
|
"to_port": 443,
|
|
|
|
"cidr_block": "0.0.0.0/0",
|
|
|
|
"action": "deny",
|
|
|
|
"rule_no": 2,
|
|
|
|
},
|
2014-11-30 12:38:45 +01:00
|
|
|
}
|
2014-12-08 11:48:39 +01:00
|
|
|
expanded, _ := expandNetworkAclEntries(input, "egress")
|
2014-11-30 12:38:45 +01:00
|
|
|
|
2015-04-13 18:14:21 +02:00
|
|
|
expected := []*ec2.NetworkACLEntry{
|
|
|
|
&ec2.NetworkACLEntry{
|
2015-03-11 22:21:22 +01:00
|
|
|
Protocol: aws.String("6"),
|
2015-03-11 21:01:07 +01:00
|
|
|
PortRange: &ec2.PortRange{
|
2015-04-13 18:14:21 +02:00
|
|
|
From: aws.Long(22),
|
|
|
|
To: aws.Long(22),
|
2015-03-11 21:01:07 +01:00
|
|
|
},
|
|
|
|
RuleAction: aws.String("deny"),
|
2015-04-13 18:14:21 +02:00
|
|
|
RuleNumber: aws.Long(1),
|
2015-03-11 21:01:07 +01:00
|
|
|
CIDRBlock: aws.String("0.0.0.0/0"),
|
|
|
|
Egress: aws.Boolean(true),
|
2014-11-30 12:38:45 +01:00
|
|
|
},
|
2015-04-13 18:14:21 +02:00
|
|
|
&ec2.NetworkACLEntry{
|
2015-03-11 22:21:22 +01:00
|
|
|
Protocol: aws.String("6"),
|
2015-03-11 21:01:07 +01:00
|
|
|
PortRange: &ec2.PortRange{
|
2015-04-13 18:14:21 +02:00
|
|
|
From: aws.Long(443),
|
|
|
|
To: aws.Long(443),
|
2015-03-11 21:01:07 +01:00
|
|
|
},
|
|
|
|
RuleAction: aws.String("deny"),
|
2015-04-13 18:14:21 +02:00
|
|
|
RuleNumber: aws.Long(2),
|
2015-03-11 21:01:07 +01:00
|
|
|
CIDRBlock: aws.String("0.0.0.0/0"),
|
|
|
|
Egress: aws.Boolean(true),
|
2014-11-30 12:38:45 +01:00
|
|
|
},
|
2015-04-22 12:35:23 +02:00
|
|
|
&ec2.NetworkACLEntry{
|
|
|
|
Protocol: aws.String("-1"),
|
|
|
|
PortRange: &ec2.PortRange{
|
|
|
|
From: aws.Long(443),
|
|
|
|
To: aws.Long(443),
|
|
|
|
},
|
|
|
|
RuleAction: aws.String("deny"),
|
|
|
|
RuleNumber: aws.Long(2),
|
|
|
|
CIDRBlock: aws.String("0.0.0.0/0"),
|
|
|
|
Egress: aws.Boolean(true),
|
|
|
|
},
|
2014-12-01 09:49:05 +01:00
|
|
|
}
|
2014-11-30 12:38:45 +01:00
|
|
|
|
|
|
|
if !reflect.DeepEqual(expanded, expected) {
|
|
|
|
t.Fatalf(
|
|
|
|
"Got:\n\n%#v\n\nExpected:\n\n%#v\n",
|
2014-12-01 09:49:05 +01:00
|
|
|
expanded,
|
2014-11-30 12:38:45 +01:00
|
|
|
expected)
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
2015-03-11 21:01:07 +01:00
|
|
|
func Test_flattenNetworkACLEntry(t *testing.T) {
|
2014-12-01 09:49:05 +01:00
|
|
|
|
2015-04-13 18:14:21 +02:00
|
|
|
apiInput := []*ec2.NetworkACLEntry{
|
|
|
|
&ec2.NetworkACLEntry{
|
2015-03-11 21:01:07 +01:00
|
|
|
Protocol: aws.String("tcp"),
|
|
|
|
PortRange: &ec2.PortRange{
|
2015-04-13 18:14:21 +02:00
|
|
|
From: aws.Long(22),
|
|
|
|
To: aws.Long(22),
|
2014-11-30 12:38:45 +01:00
|
|
|
},
|
2015-03-11 21:01:07 +01:00
|
|
|
RuleAction: aws.String("deny"),
|
2015-04-13 18:14:21 +02:00
|
|
|
RuleNumber: aws.Long(1),
|
2015-03-11 21:01:07 +01:00
|
|
|
CIDRBlock: aws.String("0.0.0.0/0"),
|
2014-11-30 12:38:45 +01:00
|
|
|
},
|
2015-04-13 18:14:21 +02:00
|
|
|
&ec2.NetworkACLEntry{
|
2015-03-11 21:01:07 +01:00
|
|
|
Protocol: aws.String("tcp"),
|
|
|
|
PortRange: &ec2.PortRange{
|
2015-04-13 18:14:21 +02:00
|
|
|
From: aws.Long(443),
|
|
|
|
To: aws.Long(443),
|
2014-12-01 09:49:05 +01:00
|
|
|
},
|
2015-03-11 21:01:07 +01:00
|
|
|
RuleAction: aws.String("deny"),
|
2015-04-13 18:14:21 +02:00
|
|
|
RuleNumber: aws.Long(2),
|
2015-03-11 21:01:07 +01:00
|
|
|
CIDRBlock: aws.String("0.0.0.0/0"),
|
2014-11-30 12:38:45 +01:00
|
|
|
},
|
|
|
|
}
|
|
|
|
flattened := flattenNetworkAclEntries(apiInput)
|
|
|
|
|
|
|
|
expected := []map[string]interface{}{
|
2014-12-01 09:49:05 +01:00
|
|
|
map[string]interface{}{
|
|
|
|
"protocol": "tcp",
|
2015-04-13 18:14:21 +02:00
|
|
|
"from_port": int64(22),
|
|
|
|
"to_port": int64(22),
|
2014-11-30 12:38:45 +01:00
|
|
|
"cidr_block": "0.0.0.0/0",
|
2014-12-01 09:49:05 +01:00
|
|
|
"action": "deny",
|
2015-04-13 18:14:21 +02:00
|
|
|
"rule_no": int64(1),
|
2014-11-30 12:38:45 +01:00
|
|
|
},
|
|
|
|
map[string]interface{}{
|
2014-12-01 09:49:05 +01:00
|
|
|
"protocol": "tcp",
|
2015-04-13 18:14:21 +02:00
|
|
|
"from_port": int64(443),
|
|
|
|
"to_port": int64(443),
|
2014-11-30 12:38:45 +01:00
|
|
|
"cidr_block": "0.0.0.0/0",
|
2014-12-01 09:49:05 +01:00
|
|
|
"action": "deny",
|
2015-04-13 18:14:21 +02:00
|
|
|
"rule_no": int64(2),
|
2014-11-30 12:38:45 +01:00
|
|
|
},
|
|
|
|
}
|
|
|
|
|
|
|
|
if !reflect.DeepEqual(flattened, expected) {
|
|
|
|
t.Fatalf(
|
|
|
|
"Got:\n\n%#v\n\nExpected:\n\n%#v\n",
|
2015-04-13 18:14:21 +02:00
|
|
|
flattened,
|
2014-11-30 12:38:45 +01:00
|
|
|
expected)
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
2015-05-06 15:14:33 +02:00
|
|
|
|
|
|
|
func Test_validatePorts(t *testing.T) {
|
|
|
|
for _, ts := range []struct {
|
|
|
|
to int64
|
|
|
|
from int64
|
|
|
|
expected *expectedPortPair
|
|
|
|
wanted bool
|
|
|
|
}{
|
|
|
|
{0, 0, &expectedPortPair{0, 0}, true},
|
|
|
|
{0, 1, &expectedPortPair{0, 0}, false},
|
|
|
|
} {
|
|
|
|
got := validatePorts(ts.to, ts.from, *ts.expected)
|
|
|
|
if got != ts.wanted {
|
|
|
|
t.Fatalf("Got: %t; Expected: %t\n", got, ts.wanted)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|