v

.vscode/launch.json

@@ -0,0 +1,21 @@
+{
+    // Use IntelliSense to learn about possible attributes.
+    // Hover to view descriptions of existing attributes.
+    // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "name": "Launch",
+            "type": "go",
+            "request": "launch",
+            "mode": "debug",
+            "remotePath": "",
+            "port": 8081,
+            "host": "127.0.0.1",
+            "program": "${fileDirname}",
+            "env": {},
+            "args": [],
+            "showLog": true
+        }
+    ]
+}

src/config/config.go

@@ -9,3 +9,6 @@ const DATABASE_PORT = "3306"
 const DATABASE_USER = "hml"
 const DATABASE_PASS = "spr777hml"
 const DATABASE_SCHEMA = "hml_mkt_sprinta"
+
+/* SERVICES ENDPOINTS */
+const AUTHENTICATION_SERVICE = "http://208.97.141.22/api/sign/user_data"

src/controller/Test/Test.go

@@ -6,7 +6,7 @@ import (
 
 	req "../../../core/request"
 	res "../../../core/response"
-	errorHandler "../../lib/errorhandler"
+	errorHandler "../../lib/error"
 )
 
 type Profile struct {

src/lib/auth/auth.go

@@ -0,0 +1,75 @@
+package lib
+
+import (
+	"encoding/json"
+	"log"
+	"net/http"
+	"errors"
+	"../curl"
+	"../../config"
+)
+
+type UserData struct {
+	UserId   int    `json:"id_user"`
+	Email    string `json:"email"`
+	Name     string `json:"name"`
+	Username string `json:"username"`
+	Token    string `json:"token"`
+	UrlToken string `json:"url_token"`
+	Avatar   string `json:"avatar"`
+	Language string `json:"language"`
+}
+
+// func (user UserData) getId() int {
+// 	id, _ := strconv.Atoi(user.UserId)
+// 	return id
+// }
+
+func GetUser(httpReq *http.Request) (*UserData, bool) {
+
+	curlReq, err := curlRequest(httpReq)
+
+	if err != nil {
+		return nil, false
+	}
+
+	response := curl.Curl(curlReq)
+
+	var userData UserData
+
+	err = json.Unmarshal(response, &userData)
+
+	//fmt.Printf("%+v\n", userData)
+
+	if err != nil {
+		log.Print(err)
+		return nil, false
+	}
+
+	if len(userData.Errors) > 0 {
+		return nil, false
+	}
+
+	return &userData, true
+}
+
+func curlRequest(request *http.Request) curl.Request, error {
+
+	authToken := request.Header.Get("Auth")
+
+	if authToken != nil {
+
+		headers map[string]string
+		headers["Auth"] = authToken
+	
+		curlReq := curl.Request{
+			Url: config.AUTHENTICATION_SERVICE
+			Method: "POST"
+			Headers: headers
+		}
+
+		return curlReq, nil
+	}
+
+	return nil, errors.New("No auth token found in http request")
+}

src/lib/authentication.go

@@ -1,34 +0,0 @@
-package lib
-
-import (
-	"net/http"
-	"strconv"
-)
-
-type UserData struct {
-	Id_user   string
-	Email     string
-	Name      string
-	Username  string
-	Token     string
-	Url_token string
-	Avatar    string
-	Language  string
-	Errors    []apiError
-}
-
-func (user UserData) getId() int {
-	id, _ := strconv.Atoi(user.Id_user)
-	return id
-}
-
-func GetUser(r *http.Request) *UserData {
-
-	auth := r.Header.Get("Auth")
-	userData := curl(auth)
-
-	// debug only
-	//fmt.Printf("%+v\n", userData)
-
-	return userData
-}

src/lib/curl.go

@@ -1,51 +0,0 @@
-package lib
-
-import (
-	"encoding/json"
-	"io/ioutil"
-	"log"
-	"net/http"
-)
-
-func curl(auth string) *UserData {
-
-	req, err := http.NewRequest("POST", "http://208.97.141.22/api/sign/user_data", nil)
-
-	if err != nil {
-		return nil
-	}
-
-	req.Header.Set("Auth", auth)
-
-	resp, err := http.DefaultClient.Do(req)
-
-	if err != nil {
-		log.Print(err)
-		return nil
-	}
-
-	defer resp.Body.Close()
-
-	body, _ := ioutil.ReadAll(resp.Body)
-
-	// debug only
-	//s := string(body[:])
-	//fmt.Println(s)
-
-	var userData UserData
-
-	err = json.Unmarshal(body, &userData)
-
-	//fmt.Printf("%+v\n", userData)
-
-	if err != nil {
-		log.Print(err)
-		return nil
-	}
-
-	if len(userData.Errors) > 0 {
-		return nil
-	}
-
-	return &userData
-}

src/lib/curl/curl.go

@@ -0,0 +1,63 @@
+package curl
+
+import (
+	"bytes"
+	"io"
+	"io/ioutil"
+	"log"
+	"net/http"
+	"strings"
+)
+
+type Request struct {
+	Url        string
+	Method     string
+	Headers    map[string]string
+	Parameters map[string]string
+}
+
+func Curl(input Request) ([]byte, error) {
+
+	req, err := http.NewRequest(input.Method, input.Url, getParams(input.Parameters))
+
+	if err != nil {
+		return nil, err
+	}
+
+	for key, value := range input.Headers {
+		req.Header.Set(key, value)
+	}
+
+	resp, err := http.DefaultClient.Do(req)
+
+	if err != nil {
+		log.Print(err)
+		return nil, err
+	}
+
+	defer resp.Body.Close()
+
+	body, err := ioutil.ReadAll(resp.Body)
+
+	// debug only
+	//s := string(body[:])
+	//fmt.Println(s)
+
+	return body, err
+}
+
+func getParams(params map[string]string) io.Reader {
+
+	if params != nil {
+
+		var buffer bytes.Buffer
+
+		for key, value := range params {
+			buffer.WriteString(key + "=" + value + "&")
+		}
+
+		return strings.NewReader(strings.TrimRight(buffer.String(), "&"))
+	}
+
+	return nil
+}