#24: Upload bytes to s3

sqs/sqs.go

@@ -131,7 +131,7 @@ func SendSQSMessage(msgr Messenger, objectToSend interface{}, currentRequestID *
 		id := uuid.New()
 		filename := fmt.Sprintf("%v-%v", sqsType, id.String())
 
-		err := uploadMessageToS3(msgr.S3Session, msgr.S3BucketName, filename, objectToSend)
+		err := uploadMessageToS3(msgr.S3Session, msgr.S3BucketName, filename, jsonBytes)
 		if err != nil {
 			return err
 		}
@@ -149,12 +149,7 @@ func SendSQSMessage(msgr Messenger, objectToSend interface{}, currentRequestID *
 	return nil
 }
 
-func uploadMessageToS3(session *s3.SessionWithHelpers, bucket string, name string, object interface{}) error {
-	messageBytes, err := json.Marshal(object)
-	if err != nil {
-		return err
-	}
-
+func uploadMessageToS3(session *s3.SessionWithHelpers, bucket string, name string, messageBytes []byte) error {
 	// Upload message
 	expiry := 24 * 7 * time.Hour // 3 days
 	_, err = session.UploadWithSettings(messageBytes, bucket, name, s3.S3UploadSettings{