Update task IAM role model

ecs-agent/acs/session/session_test.go

@@ -95,7 +95,8 @@ const (
           "expiration": "2016-03-25T06:17:19.318+0000",
           "roleArn": "r1",
           "secretAccessKey": "secretAccessKey",
-          "sessionToken": "token"
+          "sessionToken": "token",
+		  "credentialScope": "scope"
         },
         "version": "3",
         "volumes": [],
@@ -125,7 +126,8 @@ const (
       "expiration": "later",
       "roleArn": "r1",
       "secretAccessKey": "newskid",
-      "sessionToken": "newstkn"
+      "sessionToken": "newstkn",
+	  "credentialScope": "cdsp"
     }
   }
 }
@@ -976,6 +978,7 @@ func TestStartSessionHandlesRefreshCredentialsMessages(t *testing.T) {
 						SessionToken:    "newstkn",
 						Expiration:      "later",
 						CredentialsID:   credentialsIdInRefreshMessage,
+						CredentialScope: "cdsp",
 						RoleType:        rolecredentials.ApplicationRoleType,
 					},
 				}

ecs-agent/credentials/manager.go

@@ -58,7 +58,8 @@ type IAMRoleCredentials struct {
 	// Expiration is a string instead of a timestamp. This is to avoid any loss of context
 	// while marshalling/unmarshalling this field in the agent. The agent just echo's
 	// whatever is sent by the backend.
-	Expiration string `json:"Expiration"`
+	Expiration      string `json:"Expiration"`
+	CredentialScope string `json:"CredentialScope"`
 	// RoleType distinguishes between TaskRole and ExecutionRole for the
 	// credentials that are sent from the backend
 	RoleType string `json:"-"`
@@ -100,6 +101,7 @@ func IAMRoleCredentialsFromACS(roleCredentials *ecsacs.IAMRoleCredentials, roleT
 		AccessKeyID:     aws.StringValue(roleCredentials.AccessKeyId),
 		SecretAccessKey: aws.StringValue(roleCredentials.SecretAccessKey),
 		Expiration:      aws.StringValue(roleCredentials.Expiration),
+		CredentialScope: aws.StringValue(roleCredentials.CredentialScope),
 		RoleType:        roleType,
 	}
 }

ecs-agent/credentials/manager_test.go

@@ -35,6 +35,7 @@ func TestIAMRoleCredentialsFromACS(t *testing.T) {
 		RoleArn:         aws.String("roleArn"),
 		SecretAccessKey: aws.String("OhhSecret"),
 		SessionToken:    aws.String("sessionToken"),
+		CredentialScope: aws.String("credentialScope"),
 	}
 
 	roleType := "roleType"
@@ -47,6 +48,7 @@ func TestIAMRoleCredentialsFromACS(t *testing.T) {
 		RoleArn:         "roleArn",
 		SecretAccessKey: "OhhSecret",
 		SessionToken:    "sessionToken",
+		CredentialScope: "credentialScope",
 		RoleType:        "roleType",
 	}
 	assert.Equal(t, credentials, expectedCredentials, "Mismatch between expected and constructed credentials")
@@ -99,6 +101,7 @@ func TestSetAndGetTaskCredentialsHappyPath(t *testing.T) {
 			SessionToken:    "stkn",
 			Expiration:      "ts",
 			CredentialsID:   "cid1",
+			CredentialScope: "cdsp",
 		},
 	}
 
@@ -118,6 +121,7 @@ func TestSetAndGetTaskCredentialsHappyPath(t *testing.T) {
 			SessionToken:    "stkn2",
 			Expiration:      "ts2",
 			CredentialsID:   "cid1",
+			CredentialScope: "cdsp",
 		},
 	}
 	err = manager.SetTaskCredentials(&updatedCredentials)
@@ -138,6 +142,7 @@ func TestGenerateCredentialsEndpointRelativeURI(t *testing.T) {
 		SessionToken:    "stkn",
 		Expiration:      "ts",
 		CredentialsID:   "cid1",
+		CredentialScope: "cdsp",
 	}
 	generatedURI := credentials.GenerateCredentialsEndpointRelativeURI()
 	expectedURI := fmt.Sprintf(credentialsEndpointRelativeURIFormat, CredentialsPath, "cid1")
@@ -157,6 +162,7 @@ func TestRemoveExistingCredentials(t *testing.T) {
 			SessionToken:    "stkn",
 			Expiration:      "ts",
 			CredentialsID:   "cid1",
+			CredentialScope: "cdsp",
 		},
 	}
 	err := manager.SetTaskCredentials(&credentials)

ecs-agent/tmds/handlers/credentials_handler_test.go

@@ -268,6 +268,7 @@ func testCredentialsHandlerSuccess(t *testing.T, makePath MakePath, makeHandler
 		SecretAccessKey: "secret_access_key",
 		SessionToken:    "session_token",
 		Expiration:      "expiration",
+		CredentialScope: "credential_scope",
 		RoleType:        credentials.ApplicationRoleType,
 	}
 
@@ -278,6 +279,7 @@ func testCredentialsHandlerSuccess(t *testing.T, makePath MakePath, makeHandler
 		SecretAccessKey: "secret_access_key",
 		SessionToken:    "session_token",
 		Expiration:      "expiration",
+		CredentialScope: "credential_scope",
 	}
 
 	auditLogger.EXPECT().Log(

ecs-agent/tmds/handlers/v1/credentials_handler.go

@@ -20,11 +20,11 @@ import (
 	"net/http"
 
 	"github.com/aws/amazon-ecs-agent/ecs-agent/credentials"
+	"github.com/aws/amazon-ecs-agent/ecs-agent/logger"
 	auditinterface "github.com/aws/amazon-ecs-agent/ecs-agent/logger/audit"
 	"github.com/aws/amazon-ecs-agent/ecs-agent/logger/audit/request"
 	handlersutils "github.com/aws/amazon-ecs-agent/ecs-agent/tmds/handlers/utils"
 	"github.com/aws/amazon-ecs-agent/ecs-agent/utils"
-	"github.com/cihub/seelog"
 )
 
 const (
@@ -104,7 +104,7 @@ func processCredentialsRequest(
 ) ([]byte, string, string, *handlersutils.ErrorMessage, error) {
 	if credentialsID == "" {
 		errText := errPrefix + "No Credential ID in the request"
-		seelog.Errorf("Error processing credential request: %s", errText)
+		logger.Error(fmt.Sprintf("Error processing credential request: %s", errText))
 		msg := &handlersutils.ErrorMessage{
 			Code:          ErrNoIDInRequest,
 			Message:       errText,
@@ -116,7 +116,7 @@ func processCredentialsRequest(
 	credentials, ok := credentialsManager.GetTaskCredentials(credentialsID)
 	if !ok {
 		errText := errPrefix + "Credentials not found"
-		seelog.Errorf("Error processing credential request: %s", errText)
+		logger.Error(fmt.Sprintf("Error processing credential request: %s", errText))
 		msg := &handlersutils.ErrorMessage{
 			Code:          ErrInvalidIDInRequest,
 			Message:       errText,
@@ -125,14 +125,14 @@ func processCredentialsRequest(
 		return nil, "", "", msg, errors.New(errText)
 	}
 
-	seelog.Infof("Processing credential request, credentialType=%s taskARN=%s",
-		credentials.IAMRoleCredentials.RoleType, credentials.ARN)
+	logger.Debug("Processing credential request, credentialType=%s taskARN=%s credentialScope=%s",
+		credentials.IAMRoleCredentials.RoleType, credentials.ARN, credentials.IAMRoleCredentials.CredentialScope)
 
 	if utils.ZeroOrNil(credentials.ARN) && utils.ZeroOrNil(credentials.IAMRoleCredentials) {
 		// This can happen when the agent is restarted and is reconciling its state.
 		errText := errPrefix + "Credentials uninitialized for ID"
-		seelog.Errorf("Error processing credential request credentialType=%s taskARN=%s: %s",
-			credentials.IAMRoleCredentials.RoleType, credentials.ARN, errText)
+		logger.Error(fmt.Sprintf("Error processing credential request credentialType=%s taskARN=%s credentialScope=%s: %s",
+			credentials.IAMRoleCredentials.RoleType, credentials.ARN, credentials.IAMRoleCredentials.CredentialScope, errText))
 		msg := &handlersutils.ErrorMessage{
 			Code:          ErrCredentialsUninitialized,
 			Message:       errText,
@@ -144,8 +144,8 @@ func processCredentialsRequest(
 	credentialsJSON, err := json.Marshal(credentials.IAMRoleCredentials)
 	if err != nil {
 		errText := errPrefix + "Error marshaling credentials"
-		seelog.Errorf("Error processing credential request credentialType=%s taskARN=%s: %s",
-			credentials.IAMRoleCredentials.RoleType, credentials.ARN, errText)
+		logger.Error(fmt.Sprintf("Error processing credential request credentialType=%s taskARN=%s credentialScope=%s: %s",
+			credentials.IAMRoleCredentials.RoleType, credentials.ARN, credentials.IAMRoleCredentials.CredentialScope, errText))
 		msg := &handlersutils.ErrorMessage{
 			Code:          ErrInternalServer,
 			Message:       "Internal server error",