update aws sdk version

.github/workflows/go.yml

@@ -11,12 +11,12 @@ jobs:
   build:
     runs-on: ubuntu-latest
     steps:
-    - uses: actions/checkout@v2
+    - uses: actions/checkout@v4
 
     - name: Set up Go
-      uses: actions/setup-go@v2
+      uses: actions/setup-go@v5
       with:
-        go-version: 1.15
+        go-version: 1.22
 
     - name: Build
       run: go build -v ./...

.github/workflows/ship-latest.yml

@@ -10,20 +10,20 @@ jobs:
     steps:
       -
         name: Set up QEMU
-        uses: docker/setup-qemu-action@v1
+        uses: docker/setup-qemu-action@v3
       -
         name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v1
+        uses: docker/setup-buildx-action@v3
       -
         name: Login to DockerHub
-        uses: docker/login-action@v1
+        uses: docker/login-action@v3
         with:
           username: ${{ secrets.DOCKERHUB_USER }}
           password: ${{ secrets.DOCKERHUB_TOKEN }}
       -
         name: Build and push
         id: docker_build
-        uses: docker/build-push-action@v2
+        uses: docker/build-push-action@v6
         with:
           push: true
           tags: |
@@ -36,13 +36,13 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       -
-        uses: actions/checkout@v2
+        uses: actions/checkout@v4
 
       -
         name: Set up Go
-        uses: actions/setup-go@v2
+        uses: actions/setup-go@v5
         with:
-          go-version: 1.15
+          go-version: 1.22
 
       -
         name: Test

.github/workflows/ship-version.yml

@@ -10,26 +10,26 @@ jobs:
     steps:
       -
         name: Set up QEMU
-        uses: docker/setup-qemu-action@v1
+        uses: docker/setup-qemu-action@v3
       -
         name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v1
+        uses: docker/setup-buildx-action@v3
       -
         name: Login to DockerHub
-        uses: docker/login-action@v1
+        uses: docker/login-action@v3
         with:
           username: ${{ secrets.DOCKERHUB_USER }}
           password: ${{ secrets.DOCKERHUB_TOKEN }}
       -
         name: Build and push
         id: docker_build
-        uses: docker/build-push-action@v2
+        uses: docker/build-push-action@v6
         with:
           push: true
           tags: |
             nextroll/ecs-ship:v1
-            nextroll/ecs-ship:v1.0
-            nextroll/ecs-ship:v1.0.0
+            nextroll/ecs-ship:v1.2
+            nextroll/ecs-ship:v1.2.0
       -
         name: Image digest
         run: echo ${{ steps.docker_build.outputs.digest }}
@@ -38,13 +38,13 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       -
-        uses: actions/checkout@v2
+        uses: actions/checkout@v4
 
       -
         name: Set up Go
-        uses: actions/setup-go@v2
+        uses: actions/setup-go@v5
         with:
-          go-version: 1.15
+          go-version: 1.22
 
       -
         name: Test

Dockerfile

@@ -1,4 +1,4 @@
-FROM golang:1.15 AS builder
+FROM golang:1.22 AS builder
 COPY ./ /src/github.com/adroll/ecs-ship/
 RUN cd  /src/github.com/adroll/ecs-ship/ \
 			&& go test ./... \

action/ecs-deploy.go

@@ -1,23 +1,25 @@
 package action
 
 import (
+	"context"
 	"errors"
 	"log"
 	"time"
 
 	"github.com/adroll/ecs-ship/ecs"
-	ecssdk "github.com/aws/aws-sdk-go/service/ecs"
+	ecssdk "github.com/aws/aws-sdk-go-v2/service/ecs"
+	"github.com/aws/aws-sdk-go-v2/service/ecs/types"
 	"github.com/fatih/color"
 )
 
 // ECSDeployClient defines a simple interface for our required ecs stuffs
 type ECSDeployClient interface {
-	GetService(clusterName string, serviceName string) (*ecssdk.Service, error)
-	LooksGood(service *ecssdk.Service) (bool, error)
-	CopyTaskDefinition(service *ecssdk.Service) (*ecssdk.RegisterTaskDefinitionInput, *ecssdk.TaskDefinition, error)
-	WaitUntilGood(service *ecssdk.Service, timeout *time.Duration) error
-	RegisterTaskDefinition(input *ecssdk.RegisterTaskDefinitionInput) (*ecssdk.TaskDefinition, error)
-	UpdateTaskDefinition(service *ecssdk.Service, task *ecssdk.TaskDefinition) (*ecssdk.Service, error)
+	GetService(ctx context.Context, clusterName string, serviceName string) (*types.Service, error)
+	LooksGood(ctx context.Context, service *types.Service) (bool, error)
+	WaitUntilGood(ctx context.Context, service *types.Service, timeout *time.Duration) error
+	CopyTaskDefinition(ctx context.Context, service *types.Service) (*ecssdk.RegisterTaskDefinitionInput, *types.TaskDefinition, error)
+	RegisterTaskDefinition(ctx context.Context, input *ecssdk.RegisterTaskDefinitionInput) (*types.TaskDefinition, error)
+	UpdateTaskDefinition(ctx context.Context, service *types.Service, task *types.TaskDefinition) (*types.Service, error)
 }
 
 // ECSDeployTaskConfig defines a simple interface of how we want a config thing to do
@@ -26,7 +28,7 @@ type ECSDeployTaskConfig interface {
 }
 
 // ECSDeploy deploy an ecs service
-func ECSDeploy(clusterName string, serviceName string, client ECSDeployClient, timeout time.Duration, config ECSDeployTaskConfig, dryRun bool, noWait bool) error {
+func ECSDeploy(ctx context.Context, clusterName string, serviceName string, client ECSDeployClient, timeout time.Duration, config ECSDeployTaskConfig, dryRun bool, noWait bool) error {
 	if len(clusterName) == 0 {
 		return errors.New("cluster was not provided")
 	}
@@ -40,14 +42,14 @@ func ECSDeploy(clusterName string, serviceName string, client ECSDeployClient, t
 		return errors.New("config was not provided")
 	}
 
-	service, err := client.GetService(clusterName, serviceName)
+	service, err := client.GetService(ctx, clusterName, serviceName)
 	if err != nil {
 		return err
 	}
 
 	log.Printf("Updating service:\n  Cluster: %s\n  Service: %s\n", clusterName, serviceName)
 
-	good, err := client.LooksGood(service)
+	good, err := client.LooksGood(ctx, service)
 	if err != nil {
 		return err
 	}
@@ -57,7 +59,7 @@ func ECSDeploy(clusterName string, serviceName string, client ECSDeployClient, t
 		log.Println(color.YellowString("The service doesn't look good to begin with"))
 	}
 
-	copyTask, oldTaskDefinition, err := client.CopyTaskDefinition(service)
+	copyTask, oldTaskDefinition, err := client.CopyTaskDefinition(ctx, service)
 	if err != nil {
 		return err
 	}
@@ -68,10 +70,6 @@ func ECSDeploy(clusterName string, serviceName string, client ECSDeployClient, t
 		return nil
 	}
 
-	if err := newTask.Validate(); err != nil {
-		return err
-	}
-
 	log.Println("These are the changes:")
 	log.Println(diff)
 
@@ -80,14 +78,14 @@ func ECSDeploy(clusterName string, serviceName string, client ECSDeployClient, t
 		return nil
 	}
 
-	newTaskDefinition, err := client.RegisterTaskDefinition(newTask)
+	newTaskDefinition, err := client.RegisterTaskDefinition(ctx, newTask)
 	if err != nil {
 		return err
 	}
 
 	log.Printf("Changing task definition\n  Old: %s\n  New: %s\n", *service.TaskDefinition, *newTaskDefinition.TaskDefinitionArn)
 
-	newService, err := client.UpdateTaskDefinition(service, newTaskDefinition)
+	newService, err := client.UpdateTaskDefinition(ctx, service, newTaskDefinition)
 	if err != nil {
 		return err
 	}
@@ -98,16 +96,16 @@ func ECSDeploy(clusterName string, serviceName string, client ECSDeployClient, t
 	}
 
 	log.Println("Waiting for the service to reflect the new changes...")
-	if originalErr := client.WaitUntilGood(newService, &timeout); originalErr != nil {
+	if originalErr := client.WaitUntilGood(ctx, newService, &timeout); originalErr != nil {
 		log.Println(color.RedString("There was an error updating the service :", originalErr.Error()))
 		log.Println(color.YellowString("we are trying to roll back changes..."))
-		rolledBackService, err := client.UpdateTaskDefinition(service, oldTaskDefinition)
+		rolledBackService, err := client.UpdateTaskDefinition(ctx, service, oldTaskDefinition)
 		if err != nil {
 			log.Println(color.RedString("You're unlucky we also failed to roll back the service with error:", err.Error()))
 			return originalErr
 		}
 		log.Println("Waiting for rollback service to reflect the new changes...")
-		if err = client.WaitUntilGood(rolledBackService, &timeout); good && err != nil {
+		if err = client.WaitUntilGood(ctx, rolledBackService, &timeout); good && err != nil {
 			log.Println(color.RedString("stopped waiting with error:", err.Error()))
 			return originalErr
 		}