Route53 updater

bin/build

@@ -3,3 +3,4 @@ set -e
 
 bin/build_bin_data
 go install github.com/Originate/exosphere/src/cmd/exo
+go install github.com/Originate/exosphere/resources/update-route53

bin/cross-compile

@@ -14,3 +14,8 @@ gox -ldflags "-X github.com/Originate/exosphere/cmd.Version=$TRAVIS_TAG -X githu
     -osarch "darwin/386 darwin/amd64 linux/386 linux/amd64 linux/arm windows/386 windows/amd64" \
     -output "dist/exo-{{.OS}}-{{.Arch}}" \
     github.com/Originate/exosphere/src/cmd/exo
+
+gox -ldflags "-X github.com/Originate/exosphere/cmd.Version=$TRAVIS_TAG -X github.com/Originate/exosphere/cmd.BuildTime=$timestamp) -X github.com/Originate/exosphere/cmd.GitHash=$sha" \
+    -osarch "linux/386 linux/amd64 linux/arm" \
+    -output "dist/update-route53-{{.OS}}-{{.Arch}}" \
+    github.com/Originate/exosphere/resources/update-route53

resources/update-route53/main.go

@@ -0,0 +1,67 @@
+package main
+
+import (
+	"errors"
+	"fmt"
+	"os"
+	"os/exec"
+
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/aws/session"
+	"github.com/aws/aws-sdk-go/service/route53"
+)
+
+func main() {
+	if len(os.Args) < 3 {
+		panic(errors.New("Not enough arguments. Arguments must be non-empty strings passed into 'route53-updater <service-role> <internal-hosted-zone-name>'"))
+	}
+	serviceRole := os.Args[1]
+	internalHostedZoneName := os.Args[2]
+	if serviceRole == "" || internalHostedZoneName == "" {
+		panic(errors.New("Service role or internal hosted zone name missing. Both arguments must be non-empty strings passed into 'route53-updater <service-role> <internal-hosted-zone-name>'"))
+	}
+	internalIP, err := exec.Command("curl", "-fsSL", "http://169.254.169.254/latest/meta-data/local-ipv4").Output()
+	if err != nil {
+		panic(err)
+	}
+
+	awsClient := route53.New(session.New())
+	hostedZones, err := awsClient.ListHostedZones(&route53.ListHostedZonesInput{})
+	if err != nil {
+		panic(err)
+	}
+	var hostedZoneId *string
+	var hostedZoneFound bool
+	for _, hostedZone := range hostedZones.HostedZones {
+		if *hostedZone.Name == fmt.Sprintf("%s.", internalHostedZoneName) {
+			hostedZoneId = hostedZone.Id
+			hostedZoneFound = true
+		}
+	}
+	if !hostedZoneFound {
+		panic(fmt.Errorf("Hosted zone name '%s' not found.", internalHostedZoneName))
+	}
+
+	_, err = awsClient.ChangeResourceRecordSets(&route53.ChangeResourceRecordSetsInput{
+		HostedZoneId: hostedZoneId,
+		ChangeBatch: &route53.ChangeBatch{
+			Comment: aws.String("Update dns record"),
+			Changes: []*route53.Change{
+				{
+					Action: aws.String("UPSERT"),
+					ResourceRecordSet: &route53.ResourceRecordSet{
+						Name: aws.String(fmt.Sprintf("%s.%s", serviceRole, internalHostedZoneName)),
+						Type: aws.String("A"),
+						TTL:  aws.Int64(int64(300)),
+						ResourceRecords: []*route53.ResourceRecord{
+							{Value: aws.String(string(internalIP))},
+						},
+					},
+				},
+			},
+		},
+	})
+	if err != nil {
+		panic(err)
+	}
+}

terraform/aws/ecs-cluster/iam.tf

@@ -43,7 +43,9 @@ resource "aws_iam_role_policy" "ecs_instance" {
         "ecr:GetDownloadUrlForLayer",
         "ecr:BatchGetImage",
         "ecs:StartTask",
-        "autoscaling:*"
+        "autoscaling:*",
+        "route53:ChangeResourceRecordSets",
+        "route53:ListHostedZones"
       ],
       "Resource": "*"
     },