Move core utilities and services

core/services/platforms/aws/aws.go

@@ -0,0 +1,31 @@
+package aws
+
+import (
+	"fmt"
+
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/aws/session"
+)
+
+func failOnError(err error, msg string) {
+	if err != nil {
+		panic(fmt.Sprintf("%s: %s", msg, err))
+	}
+}
+
+// GetSession returns Session for AWS.
+func GetSession(profile string, region string) *session.Session {
+	sess, err := session.NewSessionWithOptions(session.Options{
+		Profile:           profile,
+		SharedConfigState: session.SharedConfigEnable,
+		Config: aws.Config{
+			Region: aws.String(region),
+		},
+	})
+
+	if err != nil {
+		failOnError(err, "Couldnot connect to AWS.")
+	}
+
+	return sess
+}

core/platforms/aws/config.go → core/services/platforms/aws/config.go

@@ -11,7 +11,7 @@ import (
 
 func handle(err error) {
 	if err != nil {
-		exit.Error(err)
+		exit.Error(err, "")
 	}
 }
 

core/services/slack/slack.go

@@ -0,0 +1,21 @@
+package slack
+
+import (
+	"fmt"
+	"strings"
+
+	"github.com/leapfrogtechnology/shift/deployment/utils/http"
+)
+
+// Notify sends data to slack webhook url
+func Notify(url string, text string, color string) {
+
+	message := strings.Replace(text, "\"", "'", -1)
+
+	content := fmt.Sprintf(`{"attachments": [{"text": %q, "color": "%s"}]}`, message, color)
+
+	http.Client.R().
+		SetHeader("Content-Type", "application/json").
+		SetBody([]byte(content)).
+		Post(url)
+}

core/utils/escape/escape.go

@@ -0,0 +1,14 @@
+package escape
+
+import (
+	"regexp"
+)
+
+const ansi = "[\u001B\u009B][[\\]()#;?]*(?:(?:(?:[a-zA-Z\\d]*(?:;[a-zA-Z\\d]*)*)?\u0007)|(?:(?:\\d{1,4}(?:;\\d{0,4})*)?[\\dA-PRZcf-ntqry=><~]))"
+
+var re = regexp.MustCompile(ansi)
+
+// Strip returns the same string by removeing ansi char.
+func Strip(str string) string {
+	return re.ReplaceAllString(str, "")
+}

core/utils/file/file.go

@@ -0,0 +1,19 @@
+package file
+
+import (
+	"mime"
+	"strings"
+)
+
+// GetFileContentType returns the content type of the file.
+func GetFileContentType(filename string) string {
+	split := strings.Split(filename, ".")
+
+	if len(split) == 0 {
+		return "binary/octet-stream"
+	}
+
+	ext := split[len(split)-1]
+
+	return mime.TypeByExtension("." + ext)
+}

core/utils/logger/logger.go

@@ -23,3 +23,18 @@ func LogOutput(msg string) {
 func LogInfo(msg string) {
 	log.Println(aurora.Blue(msg))
 }
+
+// Success logs msg with green color.
+func Success(msg string) {
+	log.Println(aurora.Green(msg))
+}
+
+// Info logs msg with blue color.
+func Info(msg string) {
+	log.Println(aurora.Cyan(msg))
+}
+
+// Error logs msg with Red color.
+func Error(err error, msg string) {
+	log.Printf("%s: %s", aurora.Red(msg), aurora.Red(err))
+}

core/utils/shell/shell.go

@@ -0,0 +1,34 @@
+package shell
+
+import (
+	"bytes"
+	"errors"
+	"fmt"
+	"os"
+	"os/exec"
+
+	"github.com/leapfrogtechnology/shift/deployment/utils/escape"
+)
+
+// Execute runs the process with the supplied environment.
+func Execute(command string) error {
+	cmd := exec.Command("bash", "-c", command)
+
+	var out bytes.Buffer
+	var stderr bytes.Buffer
+
+	cmd.Stderr = &stderr
+	cmd.Stdout = &out
+
+	cmd.Stdout = os.Stdout
+
+	err := cmd.Run()
+	if err != nil {
+		fmt.Println(stderr.String())
+
+		errorMessage := escape.Strip(err.Error() + " :- " + stderr.String())
+
+		return errors.New(errorMessage)
+	}
+	return nil
+}

core/utils/system/exit/exit.go

@@ -1,14 +1,14 @@
 package exit
 
 import (
-	"fmt"
 	"os"
+
+	"github.com/leapfrogtechnology/shift/core/utils/logger"
 )
 
 // Error exits the application by showing the given message.
-func Error(err interface{}) {
-	fmt.Println("Error")
-	fmt.Println(err)
+func Error(err error, msg string) {
+	logger.Error(err, msg)
 
 	os.Exit(1)
 }