updated

Author: wpcodevo

.air.toml

@@ -0,0 +1,36 @@
+root = "."
+testdata_dir = "testdata"
+tmp_dir = "tmp"
+
+[build]
+  bin = "tmp\\main.exe"
+  cmd = "go build -o ./tmp/main.exe ./cmd/server/main.go"
+  delay = 1000
+  exclude_dir = ["assets", "tmp", "vendor", "testdata"]
+  exclude_file = []
+  exclude_regex = ["_test.go"]
+  exclude_unchanged = false
+  follow_symlink = false
+  full_bin = ""
+  include_dir = []
+  include_ext = ["go", "tpl", "tmpl", "html"]
+  kill_delay = "0s"
+  log = "build-errors.log"
+  send_interrupt = false
+  stop_on_error = true
+
+[color]
+  app = ""
+  build = "yellow"
+  main = "magenta"
+  runner = "green"
+  watcher = "cyan"
+
+[log]
+  time = false
+
+[misc]
+  clean_on_exit = false
+
+[screen]
+  clear_on_rebuild = false

.gitignore

@@ -0,0 +1,23 @@
+# Binaries for programs and plugins
+*.exe
+*.exe~
+*.dll
+*.so
+*.dylib
+
+# Test binary, built with `go test -c`
+*.test
+
+# Output of the go coverage tool, specifically when used with LiteIDE
+*.out
+
+# Dependency directories (remove the comment below to include it)
+# vendor/
+.DS_Store
+TODO.md
+logs.txt
+.idea/
+secret.md
+app.env
+/temp
+temp/

Makefile

@@ -0,0 +1,15 @@
+.PHONY: dev dev-down go proto
+
+dev:
+	docker-compose up -d
+
+dev-down:
+	docker-compose 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/createPost_client.go

@@ -0,0 +1,35 @@
+package client
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"time"
+
+	"github.com/wpcodevo/golang-mongodb/pb"
+	"google.golang.org/grpc"
+)
+
+type CreatePostClient struct {
+	service pb.PostServiceClient
+}
+
+func NewCreatePostClient(conn *grpc.ClientConn) *CreatePostClient {
+	service := pb.NewPostServiceClient(conn)
+
+	return &CreatePostClient{service}
+}
+
+func (createPostClient *CreatePostClient) CreatePost(args *pb.CreatePostRequest) {
+
+	ctx, cancel := context.WithTimeout(context.Background(), time.Duration(time.Millisecond*5000))
+	defer cancel()
+
+	res, err := createPostClient.service.CreatePost(ctx, args)
+
+	if err != nil {
+		log.Fatalf("CreatePost: %v", err)
+	}
+
+	fmt.Println(res)
+}

client/deletePost_client.go

@@ -0,0 +1,35 @@
+package client
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"time"
+
+	"github.com/wpcodevo/golang-mongodb/pb"
+	"google.golang.org/grpc"
+)
+
+type DeletePostClient struct {
+	service pb.PostServiceClient
+}
+
+func NewDeletePostClient(conn *grpc.ClientConn) *DeletePostClient {
+	service := pb.NewPostServiceClient(conn)
+
+	return &DeletePostClient{service}
+}
+
+func (deletePostClient *DeletePostClient) DeletePost(args *pb.PostRequest) {
+
+	ctx, cancel := context.WithTimeout(context.Background(), time.Duration(time.Millisecond*5000))
+	defer cancel()
+
+	_, err := deletePostClient.service.DeletePost(ctx, args)
+
+	if err != nil {
+		log.Fatalf("DeletePost: %v", err)
+	}
+
+	fmt.Println("Post deleted successfully")
+}

client/geMe_client.go

@@ -0,0 +1,35 @@
+package client
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"time"
+
+	"github.com/wpcodevo/golang-mongodb/pb"
+	"google.golang.org/grpc"
+)
+
+type GetMeClient struct {
+	service pb.UserServiceClient
+}
+
+func NewGetMeClient(conn *grpc.ClientConn) *GetMeClient {
+	service := pb.NewUserServiceClient(conn)
+
+	return &GetMeClient{service}
+}
+
+func (getMeClient *GetMeClient) GetMeUser(credentials *pb.GetMeRequest) {
+
+	ctx, cancel := context.WithTimeout(context.Background(), time.Duration(time.Millisecond*5000))
+	defer cancel()
+
+	res, err := getMeClient.service.GetMe(ctx, credentials)
+
+	if err != nil {
+		log.Fatalf("GeMe: %v", err)
+	}
+
+	fmt.Println(res)
+}

client/getPost_client.go

@@ -0,0 +1,35 @@
+package client
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"time"
+
+	"github.com/wpcodevo/golang-mongodb/pb"
+	"google.golang.org/grpc"
+)
+
+type GetPostClient struct {
+	service pb.PostServiceClient
+}
+
+func NewGetPostClient(conn *grpc.ClientConn) *GetPostClient {
+	service := pb.NewPostServiceClient(conn)
+
+	return &GetPostClient{service}
+}
+
+func (getPostClient *GetPostClient) GetPost(args *pb.PostRequest) {
+
+	ctx, cancel := context.WithTimeout(context.Background(), time.Duration(time.Millisecond*5000))
+	defer cancel()
+
+	res, err := getPostClient.service.GetPost(ctx, args)
+
+	if err != nil {
+		log.Fatalf("GetPost: %v", err)
+	}
+
+	fmt.Println(res)
+}

client/listPosts_client.go

@@ -0,0 +1,47 @@
+package client
+
+import (
+	"context"
+	"fmt"
+	"io"
+	"log"
+	"time"
+
+	"github.com/wpcodevo/golang-mongodb/pb"
+	"google.golang.org/grpc"
+)
+
+type ListPostsClient struct {
+	service pb.PostServiceClient
+}
+
+func NewListPostsClient(conn *grpc.ClientConn) *ListPostsClient {
+	service := pb.NewPostServiceClient(conn)
+
+	return &ListPostsClient{service}
+}
+
+func (listPostsClient *ListPostsClient) ListPosts(args *pb.GetPostsRequest) {
+	ctx, cancel := context.WithTimeout(context.Background(), time.Duration(time.Millisecond*5000))
+	defer cancel()
+
+	stream, err := listPostsClient.service.GetPosts(ctx, args)
+	if err != nil {
+		log.Fatalf("ListPosts: %v", err)
+	}
+
+	for {
+		res, err := stream.Recv()
+
+		if err == io.EOF {
+			break
+		}
+
+		if err != nil {
+			log.Fatalf("ListPosts: %v", err)
+		}
+
+		fmt.Println(res)
+	}
+
+}

client/signin_client.go

@@ -0,0 +1,35 @@
+package client
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"time"
+
+	"github.com/wpcodevo/golang-mongodb/pb"
+	"google.golang.org/grpc"
+)
+
+type SignInUserClient struct {
+	service pb.AuthServiceClient
+}
+
+func NewSignInUserClient(conn *grpc.ClientConn) *SignInUserClient {
+	service := pb.NewAuthServiceClient(conn)
+
+	return &SignInUserClient{service}
+}
+
+func (signInUserClient *SignInUserClient) SignInUser(credentials *pb.SignInUserInput) {
+
+	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
+	defer cancel()
+
+	res, err := signInUserClient.service.SignInUser(ctx, credentials)
+
+	if err != nil {
+		log.Fatalf("SignInUser: %v", err)
+	}
+
+	fmt.Println(res)
+}

client/signup_client.go

@@ -0,0 +1,35 @@
+package client
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"time"
+
+	"github.com/wpcodevo/golang-mongodb/pb"
+	"google.golang.org/grpc"
+)
+
+type SignUpUserClient struct {
+	service pb.AuthServiceClient
+}
+
+func NewSignUpUserClient(conn *grpc.ClientConn) *SignUpUserClient {
+	service := pb.NewAuthServiceClient(conn)
+
+	return &SignUpUserClient{service}
+}
+
+func (signUpUserClient *SignUpUserClient) SignUpUser(credentials *pb.SignUpUserInput) {
+
+	ctx, cancel := context.WithTimeout(context.Background(), time.Duration(time.Millisecond*5000))
+	defer cancel()
+
+	res, err := signUpUserClient.service.SignUpUser(ctx, credentials)
+
+	if err != nil {
+		log.Fatalf("SignUpUser: %v", err)
+	}
+
+	fmt.Println(res)
+}