updated

Author: wpcodevo

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/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/updatePost_client.go

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

cmd/client/main.go

@@ -35,7 +35,7 @@ func main() {
 	}
 
 	// Sign In
-	if true {
+	if false {
 		signInUserClient := client.NewSignInUserClient(conn)
 
 		credentials := &pb.SignInUserInput{
@@ -56,4 +56,68 @@ func main() {
 
 	}
 
+	// List Posts
+	if false {
+		listPostsClient := client.NewListPostsClient(conn)
+
+		var page int64 = 1
+		var limit int64 = 10
+		args := &pb.GetPostsRequest{
+			Page:  &page,
+			Limit: &limit,
+		}
+
+		listPostsClient.ListPosts(args)
+	}
+
+	// Create Post
+	if false {
+		createPostClient := client.NewCreatePostClient(conn)
+
+		args := &pb.CreatePostRequest{
+			Title:   "My second gRPC post with joy",
+			Content: "It's always good to learn new technologies",
+			User:    "62908e0a42a608d5aeae2f64",
+			Image:   "default.png",
+		}
+
+		createPostClient.CreatePost(args)
+	}
+
+	// Update Post
+	if false {
+		updatePostClient := client.NewUpdatePostClient(conn)
+
+		title := "My new updated title"
+		args := &pb.UpdatePostRequest{
+			Id: "629147ff3c92aed11d49394b",
+			Post: &pb.UpdatePostBody{
+				Title: &title,
+			},
+		}
+
+		updatePostClient.UpdatePost(args)
+	}
+
+	// Get Post
+	if true {
+		getPostClient := client.NewGetPostClient(conn)
+
+		args := &pb.PostRequest{
+			Id: "629169e00a6c7cfd24e2129d",
+		}
+
+		getPostClient.GetPost(args)
+	}
+
+	// Delete Post
+	if false {
+		deletePostClient := client.NewDeletePostClient(conn)
+
+		args := &pb.PostRequest{
+			Id: "629147ff3c92aed11d49394b",
+		}
+
+		deletePostClient.DeletePost(args)
+	}
 }

cmd/server/main.go

@@ -109,8 +109,8 @@ func main() {
 
 	defer mongoclient.Disconnect(ctx)
 
-	startGinServer(config)
-	// startGrpcServer(config)
+	// startGinServer(config)
+	startGrpcServer(config)
 }
 
 func startGrpcServer(config config.Config) {
@@ -124,10 +124,16 @@ func startGrpcServer(config config.Config) {
 		log.Fatal("cannot create grpc userServer: ", err)
 	}
 
+	postServer, err := gapi.NewGrpcPostServer(postCollection, postService)
+	if err != nil {
+		log.Fatal("cannot create grpc postServer: ", err)
+	}
+
 	grpcServer := grpc.NewServer()
 
 	pb.RegisterAuthServiceServer(grpcServer, authServer)
 	pb.RegisterUserServiceServer(grpcServer, userServer)
+	pb.RegisterPostServiceServer(grpcServer, postServer)
 	reflection.Register(grpcServer)
 
 	listener, err := net.Listen("tcp", config.GrpcServerAddress)

gapi/post-server.go

@@ -0,0 +1,22 @@
+package gapi
+
+import (
+	"github.com/wpcodevo/golang-mongodb/pb"
+	"github.com/wpcodevo/golang-mongodb/services"
+	"go.mongodb.org/mongo-driver/mongo"
+)
+
+type PostServer struct {
+	pb.UnimplementedPostServiceServer
+	postCollection *mongo.Collection
+	postService    services.PostService
+}
+
+func NewGrpcPostServer(postCollection *mongo.Collection, postService services.PostService) (*PostServer, error) {
+	postServer := &PostServer{
+		postCollection: postCollection,
+		postService:    postService,
+	}
+
+	return postServer, nil
+}

gapi/rpc_create_post.go

@@ -0,0 +1,44 @@
+package gapi
+
+import (
+	"context"
+	"strings"
+
+	"github.com/wpcodevo/golang-mongodb/models"
+	"github.com/wpcodevo/golang-mongodb/pb"
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/status"
+	"google.golang.org/protobuf/types/known/timestamppb"
+)
+
+func (postServer *PostServer) CreatePost(ctx context.Context, req *pb.CreatePostRequest) (*pb.PostResponse, error) {
+
+	post := &models.CreatePostRequest{
+		Title:   req.GetTitle(),
+		Content: req.GetContent(),
+		Image:   req.GetImage(),
+		User:    req.GetUser(),
+	}
+
+	newPost, err := postServer.postService.CreatePost(post)
+
+	if err != nil {
+		if strings.Contains(err.Error(), "title already exists") {
+			return nil, status.Errorf(codes.AlreadyExists, err.Error())
+		}
+
+		return nil, status.Errorf(codes.Internal, err.Error())
+	}
+
+	res := &pb.PostResponse{
+		Post: &pb.Post{
+			Id:        newPost.Id.Hex(),
+			Title:     newPost.Title,
+			Content:   newPost.Content,
+			User:      newPost.User,
+			CreatedAt: timestamppb.New(newPost.CreateAt),
+			UpdatedAt: timestamppb.New(newPost.UpdatedAt),
+		},
+	}
+	return res, nil
+}

gapi/rpc_delete_post.go

@@ -0,0 +1,27 @@
+package gapi
+
+import (
+	"context"
+	"strings"
+
+	"github.com/wpcodevo/golang-mongodb/pb"
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/status"
+)
+
+func (postServer *PostServer) DeletePost(ctx context.Context, req *pb.PostRequest) (*pb.DeletePostResponse, error) {
+	postId := req.GetId()
+
+	if err := postServer.postService.DeletePost(postId); err != nil {
+		if strings.Contains(err.Error(), "Id exists") {
+			return nil, status.Errorf(codes.NotFound, err.Error())
+		}
+		return nil, status.Errorf(codes.Internal, err.Error())
+	}
+
+	res := &pb.DeletePostResponse{
+		Success: true,
+	}
+
+	return res, nil
+}