added grpc

Author: wpcodevo

Makefile

@@ -1,3 +1,5 @@
+.PHONY: dev dev-down go proto
+
 dev:
 	docker-compose up -d
 
@@ -7,3 +9,7 @@ dev-down:
 go:
 	air
 
+proto:
+	protoc --proto_path=proto --go_out=pb --go_opt=paths=source_relative \
+  --go-grpc_out=pb --go-grpc_opt=paths=source_relative \
+  proto/*.proto

client/main.go

@@ -0,0 +1,46 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"time"
+
+	"github.com/wpcodevo/golang-mongodb/pb"
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/credentials/insecure"
+)
+
+const (
+	address = "0.0.0.0:8080"
+)
+
+func main() {
+	conn, err := grpc.Dial(address, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithBlock())
+
+	if err != nil {
+		log.Fatalf("failed to connect: %v", err)
+	}
+
+	defer conn.Close()
+
+	client := pb.NewAuthServiceClient(conn)
+
+	ctx, cancel := context.WithTimeout(context.Background(), time.Duration(time.Millisecond*5000))
+	defer cancel()
+
+	newUser := &pb.SignUpUserInput{
+		Name:            "James Smith",
+		Email:           "jamesmith@gmail.com",
+		Password:        "password123",
+		PasswordConfirm: "password123",
+	}
+
+	res, err := client.SignUpUser(ctx, newUser)
+	if err != nil {
+		log.Fatalf("SignUpUser: %v", err)
+	}
+
+	fmt.Println(res)
+
+}

config/default.go

@@ -11,6 +11,8 @@ type Config struct {
 	RedisUri string `mapstructure:"REDIS_URL"`
 	Port     string `mapstructure:"PORT"`
 
+	GrpcServerAddress string `mapstructure:"GRPC_SERVER_ADDRESS"`
+
 	AccessTokenPrivateKey  string        `mapstructure:"ACCESS_TOKEN_PRIVATE_KEY"`
 	AccessTokenPublicKey   string        `mapstructure:"ACCESS_TOKEN_PUBLIC_KEY"`
 	RefreshTokenPrivateKey string        `mapstructure:"REFRESH_TOKEN_PRIVATE_KEY"`

gapi/rpc_signin_user.go

@@ -0,0 +1,58 @@
+package gapi
+
+import (
+	"context"
+
+	"github.com/wpcodevo/golang-mongodb/pb"
+	"github.com/wpcodevo/golang-mongodb/utils"
+	"go.mongodb.org/mongo-driver/mongo"
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/status"
+)
+
+func (server *Server) SignInUser(ctx context.Context, req *pb.SignInUserInput) (*pb.SignInUserResponse, error) {
+	user, err := server.userService.FindUserByEmail(req.GetEmail())
+	if err != nil {
+		if err == mongo.ErrNoDocuments {
+
+			return nil, status.Errorf(codes.InvalidArgument, "Invalid email or password")
+
+		}
+
+		return nil, status.Errorf(codes.Internal, err.Error())
+
+	}
+
+	if !user.Verified {
+
+		return nil, status.Errorf(codes.PermissionDenied, "You are not verified, please verify your email to login")
+
+	}
+
+	if err := utils.VerifyPassword(user.Password, req.GetPassword()); err != nil {
+
+		return nil, status.Errorf(codes.InvalidArgument, "Invalid email or Password")
+
+	}
+
+	// Generate Tokens
+	access_token, err := utils.CreateToken(server.config.AccessTokenExpiresIn, user.ID, server.config.AccessTokenPrivateKey)
+	if err != nil {
+
+		return nil, status.Errorf(codes.PermissionDenied, err.Error())
+
+	}
+
+	refresh_token, err := utils.CreateToken(server.config.RefreshTokenExpiresIn, user.ID, server.config.RefreshTokenPrivateKey)
+	if err != nil {
+		return nil, status.Errorf(codes.PermissionDenied, err.Error())
+	}
+
+	res := &pb.SignInUserResponse{
+		Status:       "success",
+		AccessToken:  access_token,
+		RefreshToken: refresh_token,
+	}
+
+	return res, nil
+}

gapi/rpc_signup_user.go

@@ -0,0 +1,71 @@
+package gapi
+
+import (
+	"context"
+	"strings"
+
+	"github.com/thanhpk/randstr"
+	"github.com/wpcodevo/golang-mongodb/models"
+	"github.com/wpcodevo/golang-mongodb/pb"
+	"github.com/wpcodevo/golang-mongodb/utils"
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/status"
+)
+
+func (server *Server) SignUpUser(ctx context.Context, req *pb.SignUpUserInput) (*pb.GenericResponse, error) {
+	if req.GetPassword() != req.GetPasswordConfirm() {
+		return nil, status.Errorf(codes.InvalidArgument, "passwords do not match")
+	}
+
+	user := models.SignUpInput{
+		Name:            req.GetName(),
+		Email:           req.GetEmail(),
+		Password:        req.GetPassword(),
+		PasswordConfirm: req.GetPasswordConfirm(),
+	}
+
+	newUser, err := server.authService.SignUpUser(&user)
+
+	if err != nil {
+		if strings.Contains(err.Error(), "email already exist") {
+			return nil, status.Errorf(codes.AlreadyExists, "%s", err.Error())
+
+		}
+		return nil, status.Errorf(codes.Internal, "%s", err.Error())
+	}
+
+	// Generate Verification Code
+	code := randstr.String(20)
+
+	verificationCode := utils.Encode(code)
+
+	// Update User in Database
+	server.userService.UpdateUserById(newUser.ID.Hex(), "verificationCode", verificationCode)
+
+	var firstName = newUser.Name
+
+	if strings.Contains(firstName, " ") {
+		firstName = strings.Split(firstName, " ")[0]
+	}
+
+	// 👇 Send Email
+	emailData := utils.EmailData{
+		URL:       server.config.Origin + "/verifyemail/" + code,
+		FirstName: firstName,
+		Subject:   "Your account verification code",
+	}
+
+	err = utils.SendEmail(newUser, &emailData, "verificationCode.html")
+	if err != nil {
+		return nil, status.Errorf(codes.Internal, "There was an error sending email: %s", err.Error())
+
+	}
+
+	message := "We sent an email with a verification code to " + newUser.Email
+
+	res := &pb.GenericResponse{
+		Status:  "success",
+		Message: message,
+	}
+	return res, nil
+}

gapi/rpc_verify_user.go

@@ -0,0 +1,35 @@
+package gapi
+
+import (
+	"context"
+	"time"
+
+	"github.com/wpcodevo/golang-mongodb/pb"
+	"github.com/wpcodevo/golang-mongodb/utils"
+	"go.mongodb.org/mongo-driver/bson"
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/status"
+)
+
+func (server *Server) VerifyEmail(ctx context.Context, req *pb.VerifyEmailRequest) (*pb.GenericResponse, error) {
+	code := req.GetVerificationCode()
+
+	verificationCode := utils.Encode(code)
+
+	query := bson.D{{Key: "verificationCode", Value: verificationCode}}
+	update := bson.D{{Key: "$set", Value: bson.D{{Key: "verified", Value: true}, {Key: "updated_at", Value: time.Now()}}}, {Key: "$unset", Value: bson.D{{Key: "verificationCode", Value: ""}}}}
+	result, err := server.userCollection.UpdateOne(ctx, query, update)
+	if err != nil {
+		return nil, status.Errorf(codes.Internal, err.Error())
+	}
+
+	if result.MatchedCount == 0 {
+		return nil, status.Errorf(codes.PermissionDenied, "Could not verify email address")
+	}
+
+	res := &pb.GenericResponse{
+		Status:  "success",
+		Message: "Email verified successfully",
+	}
+	return res, nil
+}

gapi/server.go

@@ -0,0 +1,29 @@
+package gapi
+
+import (
+	"github.com/wpcodevo/golang-mongodb/config"
+	"github.com/wpcodevo/golang-mongodb/pb"
+	"github.com/wpcodevo/golang-mongodb/services"
+	"go.mongodb.org/mongo-driver/mongo"
+)
+
+type Server struct {
+	pb.UnimplementedAuthServiceServer
+	config         config.Config
+	authService    services.AuthService
+	userService    services.UserService
+	userCollection *mongo.Collection
+}
+
+func NewGrpcServer(config config.Config, authService services.AuthService,
+	userService services.UserService, userCollection *mongo.Collection) (*Server, error) {
+
+	server := &Server{
+		config:         config,
+		authService:    authService,
+		userService:    userService,
+		userCollection: userCollection,
+	}
+
+	return server, nil
+}

go.mod

@@ -7,9 +7,14 @@ require (
 	github.com/gin-gonic/gin v1.7.7
 	github.com/go-redis/redis/v8 v8.11.5
 	github.com/golang-jwt/jwt v3.2.2+incompatible
+	github.com/k3a/html2text v1.0.8
 	github.com/spf13/viper v1.11.0
+	github.com/thanhpk/randstr v1.0.4
 	go.mongodb.org/mongo-driver v1.9.1
 	golang.org/x/crypto v0.0.0-20220513210258-46612604a0f9
+	google.golang.org/grpc v1.45.0
+	google.golang.org/protobuf v1.28.0
+	gopkg.in/gomail.v2 v2.0.0-20160411212932-81ebce5c23df
 )
 
 require (
@@ -25,7 +30,6 @@ require (
 	github.com/golang/snappy v0.0.1 // indirect
 	github.com/hashicorp/hcl v1.0.0 // indirect
 	github.com/json-iterator/go v1.1.12 // indirect
-	github.com/k3a/html2text v1.0.8 // indirect
 	github.com/klauspost/compress v1.13.6 // indirect
 	github.com/leodido/go-urn v1.2.1 // indirect
 	github.com/magiconair/properties v1.8.6 // indirect
@@ -41,18 +45,17 @@ require (
 	github.com/spf13/jwalterweatherman v1.1.0 // indirect
 	github.com/spf13/pflag v1.0.5 // indirect
 	github.com/subosito/gotenv v1.2.0 // indirect
-	github.com/thanhpk/randstr v1.0.4 // indirect
 	github.com/ugorji/go/codec v1.2.7 // indirect
 	github.com/xdg-go/pbkdf2 v1.0.0 // indirect
 	github.com/xdg-go/scram v1.0.2 // indirect
 	github.com/xdg-go/stringprep v1.0.2 // indirect
 	github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d // indirect
+	golang.org/x/net v0.0.0-20220412020605-290c469a71a5 // indirect
 	golang.org/x/sync v0.0.0-20201207232520-09787c993a3a // indirect
 	golang.org/x/sys v0.0.0-20220513210249-45d2b4557a2a // indirect
 	golang.org/x/text v0.3.7 // indirect
-	google.golang.org/protobuf v1.28.0 // indirect
+	google.golang.org/genproto v0.0.0-20220407144326-9054f6ed7bac // indirect
 	gopkg.in/alexcesaro/quotedprintable.v3 v3.0.0-20150716171945-2caba252f4dc // indirect
-	gopkg.in/gomail.v2 v2.0.0-20160411212932-81ebce5c23df // indirect
 	gopkg.in/ini.v1 v1.66.4 // indirect
 	gopkg.in/yaml.v2 v2.4.0 // indirect
 	gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b // indirect