fix: check AWS credentials and notify about missing environment variables

agneum · agneum · commit beb806daa5b8 · 2020-07-31T16:30:42.000+07:00
diff --git a/pkg/retrieval/engine/postgres/initialize/logical/dump_rds.go b/pkg/retrieval/engine/postgres/initialize/logical/dump_rds.go
@@ -68,6 +68,14 @@ func newRDSDumper(rdsCfg *RDSConfig) (*rdsDumper, error) {
 		return nil, errors.Wrap(err, "failed to start AWS session")
 	}
 
+	credentials, err := awsSession.Config.Credentials.Get()
+	if err != nil || !credentials.HasKeys() {
+		log.Dbg(err)
+
+		return nil, errors.New(`failed to check AWS credentials.
+Set up valid environment variables AWS_ACCESS_KEY_ID and AWS_SECRET_ACCESS_KEY`)
+	}
+
 	return &rdsDumper{
 		rdsCfg: rdsCfg,
 		iamSvc: iam.New(awsSession, aws.NewConfig()),
