Skip to content

GitLab

Merged
Created by Maurício de Carvalho Lima@mauricio.limaGuest

Feature/login

Compare
and
7 files
+ 200
- 19
layers/‎service‎
AuthSer‎vice.go‎ +119 -0
ServiceStatu‎sCodeUtil.go‎ +11 -6
Volunteer‎Service.go‎ +29 -13
.e‎nv‎ +5 -0
go.‎mod‎ +2 -0
go.‎sum‎ +5 -0
serv‎er.go‎ +29 -0
layers/service/AuthService.go 0 → 100644
+ 119
- 0
package service
import (
"boilerplate/layers/entity"
"bytes"
"crypto/tls"
"encoding/json"
"errors"
"fmt"
"io/ioutil"
"net/http"
"os"
)
type signIn struct {
Connection string `json:"connection"`
Email string `json:"email"`
Password string `json:"password"`
}
type logIn struct {
Username string `json:"username"`
Password string `json:"password"`
Connection string `json:"connection"`
ClientId string `json:"client_id"`
ClientSecret string `json:"client_secret"`
GrantType string `json:"grant_type"`
}
var (
authSigninUrl = "https://%s/api/v2/users"
authLoginUrl = "https://%s/oauth/token"
authToken = "Bearer %s"
)
func createTlsClient() (client *http.Client) {
client = &http.Client{
Transport: &http.Transport{
TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
},
}
return
}
func sendAuthRequest(body interface{}, url string) (res *http.Response, err error) {
client := createTlsClient()
b, err := json.Marshal(body)
if err != nil {
return &http.Response{}, err
}
req, err := http.NewRequest(
"POST",
fmt.Sprintf(url, os.Getenv("AUTH_DOMAIN")),
bytes.NewBuffer(b),
)
if err != nil {
return &http.Response{}, err
}
req.Header.Set("Content-Type", "application/json")
req.Header.Set("Authorization", fmt.Sprintf(authToken, os.Getenv("AUTH_MGMT_TOKEN")))
res, err = client.Do(req)
return
}
func SignIn(volunteer entity.Volunteer) (code int, err error) {
body := signIn{
Connection: os.Getenv("AUTH_CONNECTION"),
Email: volunteer.Email,
Password: volunteer.Password,
}
res, err := sendAuthRequest(body, authSigninUrl)
defer res.Body.Close()
if err != nil {
return http.StatusInternalServerError, err
}
if res.StatusCode != http.StatusCreated {
var data map[string]interface{}
b, err := ioutil.ReadAll(res.Body)
if err != nil {
return res.StatusCode, err
}
err = json.Unmarshal(b, &data)
if err != nil {
return res.StatusCode, err
}
return res.StatusCode, errors.New(data["message"].(string))
}
return http.StatusOK, nil
}
func LogIn(volunteer entity.Volunteer) (code int, token string, err error) {
body := logIn{
Username: volunteer.Email,
Password: volunteer.Password,
Connection: os.Getenv("AUTH_CONNECTION"),
ClientId: os.Getenv("AUTH_CLIENT_ID"),
ClientSecret: os.Getenv("AUTH_CLIENT_SECRET"),
GrantType: "password",
}
res, err := sendAuthRequest(body, authLoginUrl)
defer res.Body.Close()
if err != nil {
return http.StatusInternalServerError, "", err
}
var data map[string]interface{}
b, err := ioutil.ReadAll(res.Body)
if err != nil {
return res.StatusCode, "", err
}
err = json.Unmarshal(b, &data)
if err != nil {
return res.StatusCode, "", err
}
if res.StatusCode != http.StatusOK {
return res.StatusCode, "", errors.New(data["message"].(string))
}
token = data["id_token"].(string)
return http.StatusOK, token, nil
}
\ No newline at end of file
layers/service/ServiceStatusCodeUtil.go
+ 11
- 6
@@ -20,11 +20,6 @@ func setStatusBadRequest(msg interface{}, ctx *gin.Context) {
ctx.JSON(http.StatusBadRequest, msg)
}
// setStatusFound sets FOUND status to a gin context
func setStatusFound(msg interface{}, ctx *gin.Context) {
ctx.JSON(http.StatusFound, msg)
}
// setStatusNotFound sets NOT FOUND status to a gin context
func setStatusNotFound(msg interface{}, ctx *gin.Context) {
ctx.JSON(http.StatusNotFound, msg)
@@ -33,4 +28,14 @@ func setStatusNotFound(msg interface{}, ctx *gin.Context) {
// setStatusInternalServerError sets INTERNAL SERVER ERROR status to a gin context
func setStatusInternalServerError(msg interface{}, ctx *gin.Context) {
ctx.JSON(http.StatusInternalServerError, msg)
}
\ No newline at end of file
}
// setUnauthorizedStatus sets UNAUTHORIZED status code to a gin context
func setUnauthorizedStatus(msg interface{}, ctx *gin.Context) {
ctx.JSON(http.StatusUnauthorized, msg)
}
// setAuthStatus sets auth0 status code to a gin context
func setAuthStatus(msg interface{}, status int, ctx *gin.Context) {
ctx.JSON(status, msg)
}
layers/service/VolunteerService.go
+ 29
- 13
@@ -5,6 +5,7 @@ import (
"boilerplate/layers/repository"
"github.com/gin-gonic/gin"
"go.mongodb.org/mongo-driver/bson/primitive"
"net/http"
)
// VolunteerService is a struct that defines a Volunteer Service behaviour at service layer
@@ -19,29 +20,44 @@ func (service VolunteerService) Create(ctx *gin.Context) {
if err != nil {
setStatusBadRequest(gin.H{"error": error.Error(err)}, ctx)
} else {
id, err := service.Repository.Create(*volunteer)
if err != nil {
setStatusInternalServerError(gin.H{"error": error.Error(err)}, ctx)
signInStatusCode, err := SignIn(*volunteer)
if signInStatusCode != http.StatusOK {
setAuthStatus(gin.H{"error": error.Error(err)}, signInStatusCode, ctx)
} else {
setStatusCreated(gin.H{"id": id}, ctx)
id, err := service.Repository.Create(*volunteer)
if err != nil {
setStatusInternalServerError(gin.H{"error": error.Error(err)}, ctx)
} else {
logInStatusCode, token, err := LogIn(*volunteer)
if logInStatusCode != http.StatusOK {
setAuthStatus(gin.H{"error": error.Error(err)}, logInStatusCode, ctx)
} else {
setStatusCreated(gin.H{"id": id, "token": token}, ctx)
}
}
}
}
}
// Read is a business logic function that handles Volunteer GET HTTP method
func (service VolunteerService) Read(ctx *gin.Context) {
id, _ := ctx.Params.Get("id")
objId, err := primitive.ObjectIDFromHex(id)
if err != nil {
setStatusBadRequest(gin.H{"error": error.Error(err)}, ctx)
authorized := ctx.MustGet("authorized").(bool)
if !authorized {
setUnauthorizedStatus("Invalid token", ctx)
} else {
volunteer, err := service.Repository.Read(objId)
id, _ := ctx.Params.Get("id")
objId, err := primitive.ObjectIDFromHex(id)
if err != nil {
setStatusInternalServerError(gin.H{"error": error.Error(err)}, ctx)
} else if volunteer == nil {
setStatusNotFound(gin.H{"id": id}, ctx)
setStatusBadRequest(gin.H{"error": error.Error(err)}, ctx)
} else {
setStatusOk(volunteer, ctx)
volunteer, err := service.Repository.Read(objId)
if err != nil {
setStatusInternalServerError(gin.H{"error": error.Error(err)}, ctx)
} else if volunteer == nil {
setStatusNotFound(gin.H{"id": id}, ctx)
} else {
setStatusOk(volunteer, ctx)
}
}
}
}
.env
+ 5
- 0
@@ -4,3 +4,8 @@ MONGO_USER=root
MONGO_PASSWORD=root
MONGO_DATABASE=volunteerDB
MONGO_COLLECTION_NAME=volunteer
AUTH_DOMAIN=dev-u0ektkvv.us.auth0.com
AUTH_CLIENT_ID=C7FfMBENbo3DAugvKDcvndSEs67yOKt6
AUTH_CLIENT_SECRET=REh0V2txVERFYkNSM0ZUY3F5ZFFqZ0dQd0o2bkxiSFgwNi05VjBaRGYxbmctNXZzZnpGNFlKUVd1VTMtRHNyTQ==
AUTH_CONNECTION=Username-Password-Authentication
AUTH_MGMT_TOKEN=eyJhbGciOiJSUzI1NiIsInR5cCI6IkpXVCIsImtpZCI6IkFlaXNITU9MMC04OUFoNW1HMUlSaSJ9.eyJpc3MiOiJodHRwczovL2Rldi11MGVrdGt2di51cy5hdXRoMC5jb20vIiwic3ViIjoiYmpXQVdKdFpYYVl6UlI5bzlVTzFsQUtIUDVlSHZYdjlAY2xpZW50cyIsImF1ZCI6Imh0dHBzOi8vZGV2LXUwZWt0a3Z2LnVzLmF1dGgwLmNvbS9hcGkvdjIvIiwiaWF0IjoxNjIyNDE4NDAzLCJleHAiOjE2MjMwMjMyMDMsImF6cCI6ImJqV0FXSnRaWGFZelJSOW85VU8xbEFLSFA1ZUh2WHY5Iiwic2NvcGUiOiJyZWFkOmNsaWVudF9ncmFudHMgY3JlYXRlOmNsaWVudF9ncmFudHMgZGVsZXRlOmNsaWVudF9ncmFudHMgdXBkYXRlOmNsaWVudF9ncmFudHMgcmVhZDp1c2VycyB1cGRhdGU6dXNlcnMgZGVsZXRlOnVzZXJzIGNyZWF0ZTp1c2VycyByZWFkOnVzZXJzX2FwcF9tZXRhZGF0YSB1cGRhdGU6dXNlcnNfYXBwX21ldGFkYXRhIGRlbGV0ZTp1c2Vyc19hcHBfbWV0YWRhdGEgY3JlYXRlOnVzZXJzX2FwcF9tZXRhZGF0YSByZWFkOnVzZXJfY3VzdG9tX2Jsb2NrcyBjcmVhdGU6dXNlcl9jdXN0b21fYmxvY2tzIGRlbGV0ZTp1c2VyX2N1c3RvbV9ibG9ja3MgY3JlYXRlOnVzZXJfdGlja2V0cyByZWFkOmNsaWVudHMgdXBkYXRlOmNsaWVudHMgZGVsZXRlOmNsaWVudHMgY3JlYXRlOmNsaWVudHMgcmVhZDpjbGllbnRfa2V5cyB1cGRhdGU6Y2xpZW50X2tleXMgZGVsZXRlOmNsaWVudF9rZXlzIGNyZWF0ZTpjbGllbnRfa2V5cyByZWFkOmNvbm5lY3Rpb25zIHVwZGF0ZTpjb25uZWN0aW9ucyBkZWxldGU6Y29ubmVjdGlvbnMgY3JlYXRlOmNvbm5lY3Rpb25zIHJlYWQ6cmVzb3VyY2Vfc2VydmVycyB1cGRhdGU6cmVzb3VyY2Vfc2VydmVycyBkZWxldGU6cmVzb3VyY2Vfc2VydmVycyBjcmVhdGU6cmVzb3VyY2Vfc2VydmVycyByZWFkOmRldmljZV9jcmVkZW50aWFscyB1cGRhdGU6ZGV2aWNlX2NyZWRlbnRpYWxzIGRlbGV0ZTpkZXZpY2VfY3JlZGVudGlhbHMgY3JlYXRlOmRldmljZV9jcmVkZW50aWFscyByZWFkOnJ1bGVzIHVwZGF0ZTpydWxlcyBkZWxldGU6cnVsZXMgY3JlYXRlOnJ1bGVzIHJlYWQ6cnVsZXNfY29uZmlncyB1cGRhdGU6cnVsZXNfY29uZmlncyBkZWxldGU6cnVsZXNfY29uZmlncyByZWFkOmhvb2tzIHVwZGF0ZTpob29rcyBkZWxldGU6aG9va3MgY3JlYXRlOmhvb2tzIHJlYWQ6YWN0aW9ucyB1cGRhdGU6YWN0aW9ucyBkZWxldGU6YWN0aW9ucyBjcmVhdGU6YWN0aW9ucyByZWFkOmVtYWlsX3Byb3ZpZGVyIHVwZGF0ZTplbWFpbF9wcm92aWRlciBkZWxldGU6ZW1haWxfcHJvdmlkZXIgY3JlYXRlOmVtYWlsX3Byb3ZpZGVyIGJsYWNrbGlzdDp0b2tlbnMgcmVhZDpzdGF0cyByZWFkOmluc2lnaHRzIHJlYWQ6dGVuYW50X3NldHRpbmdzIHVwZGF0ZTp0ZW5hbnRfc2V0dGluZ3MgcmVhZDpsb2dzIHJlYWQ6bG9nc191c2VycyByZWFkOnNoaWVsZHMgY3JlYXRlOnNoaWVsZHMgdXBkYXRlOnNoaWVsZHMgZGVsZXRlOnNoaWVsZHMgcmVhZDphbm9tYWx5X2Jsb2NrcyBkZWxldGU6YW5vbWFseV9ibG9ja3MgdXBkYXRlOnRyaWdnZXJzIHJlYWQ6dHJpZ2dlcnMgcmVhZDpncmFudHMgZGVsZXRlOmdyYW50cyByZWFkOmd1YXJkaWFuX2ZhY3RvcnMgdXBkYXRlOmd1YXJkaWFuX2ZhY3RvcnMgcmVhZDpndWFyZGlhbl9lbnJvbGxtZW50cyBkZWxldGU6Z3VhcmRpYW5fZW5yb2xsbWVudHMgY3JlYXRlOmd1YXJkaWFuX2Vucm9sbG1lbnRfdGlja2V0cyByZWFkOnVzZXJfaWRwX3Rva2VucyBjcmVhdGU6cGFzc3dvcmRzX2NoZWNraW5nX2pvYiBkZWxldGU6cGFzc3dvcmRzX2NoZWNraW5nX2pvYiByZWFkOmN1c3RvbV9kb21haW5zIGRlbGV0ZTpjdXN0b21fZG9tYWlucyBjcmVhdGU6Y3VzdG9tX2RvbWFpbnMgdXBkYXRlOmN1c3RvbV9kb21haW5zIHJlYWQ6ZW1haWxfdGVtcGxhdGVzIGNyZWF0ZTplbWFpbF90ZW1wbGF0ZXMgdXBkYXRlOmVtYWlsX3RlbXBsYXRlcyByZWFkOm1mYV9wb2xpY2llcyB1cGRhdGU6bWZhX3BvbGljaWVzIHJlYWQ6cm9sZXMgY3JlYXRlOnJvbGVzIGRlbGV0ZTpyb2xlcyB1cGRhdGU6cm9sZXMgcmVhZDpwcm9tcHRzIHVwZGF0ZTpwcm9tcHRzIHJlYWQ6YnJhbmRpbmcgdXBkYXRlOmJyYW5kaW5nIGRlbGV0ZTpicmFuZGluZyByZWFkOmxvZ19zdHJlYW1zIGNyZWF0ZTpsb2dfc3RyZWFtcyBkZWxldGU6bG9nX3N0cmVhbXMgdXBkYXRlOmxvZ19zdHJlYW1zIGNyZWF0ZTpzaWduaW5nX2tleXMgcmVhZDpzaWduaW5nX2tleXMgdXBkYXRlOnNpZ25pbmdfa2V5cyByZWFkOmxpbWl0cyB1cGRhdGU6bGltaXRzIGNyZWF0ZTpyb2xlX21lbWJlcnMgcmVhZDpyb2xlX21lbWJlcnMgZGVsZXRlOnJvbGVfbWVtYmVycyByZWFkOmVudGl0bGVtZW50cyByZWFkOmF0dGFja19wcm90ZWN0aW9uIHVwZGF0ZTphdHRhY2tfcHJvdGVjdGlvbiByZWFkOm9yZ2FuaXphdGlvbnMgdXBkYXRlOm9yZ2FuaXphdGlvbnMgY3JlYXRlOm9yZ2FuaXphdGlvbnMgZGVsZXRlOm9yZ2FuaXphdGlvbnMgY3JlYXRlOm9yZ2FuaXphdGlvbl9tZW1iZXJzIHJlYWQ6b3JnYW5pemF0aW9uX21lbWJlcnMgZGVsZXRlOm9yZ2FuaXphdGlvbl9tZW1iZXJzIGNyZWF0ZTpvcmdhbml6YXRpb25fY29ubmVjdGlvbnMgcmVhZDpvcmdhbml6YXRpb25fY29ubmVjdGlvbnMgdXBkYXRlOm9yZ2FuaXphdGlvbl9jb25uZWN0aW9ucyBkZWxldGU6b3JnYW5pemF0aW9uX2Nvbm5lY3Rpb25zIGNyZWF0ZTpvcmdhbml6YXRpb25fbWVtYmVyX3JvbGVzIHJlYWQ6b3JnYW5pemF0aW9uX21lbWJlcl9yb2xlcyBkZWxldGU6b3JnYW5pemF0aW9uX21lbWJlcl9yb2xlcyBjcmVhdGU6b3JnYW5pemF0aW9uX2ludml0YXRpb25zIHJlYWQ6b3JnYW5pemF0aW9uX2ludml0YXRpb25zIGRlbGV0ZTpvcmdhbml6YXRpb25faW52aXRhdGlvbnMiLCJndHkiOiJjbGllbnQtY3JlZGVudGlhbHMifQ.S-Xvtcl6ek9LlmFhFVoPu5vacNzBLFBis1w-vqCac5i58opFTnXxZFMRCJHEbE59fMLjG9HGJFqCNL7eaT2TmAFgP4KEHdjGCsWju3EEUP_Z5I4qgT9eA8bmO7pOqfPss0K9xcZhiBAq7FUVSPE-YV20ubecgnwgiIMiamUzE40soIlu2AcbNnKFx2vQbDNVwcq0MW2U4jctnoLea4MI4m2j6lkEL1A_ZRzMa9WpWqRwiUbw-MlEX-65X8F716FXa5qGoFZGqc1CzzFdTGgxnQY-1ve0fPd-hdkfiiObZguzPhyRssBPzJym9FaRUkzYh3gId7xBA1e6FNa8I781QQ
\ No newline at end of file
go.mod
+ 2
- 0
@@ -3,8 +3,10 @@ module boilerplate
go 1.16
require (
github.com/gin-gonic/gin v1.6.3 // indirect
github.com/joho/godotenv v1.3.0 // indirect
github.com/stretchr/testify v1.7.0 // indirect
go.mongodb.org/mongo-driver v1.5.0 // indirect
gopkg.in/square/go-jose.v2 v2.1.7 // indirect
)