Provide minor fixes

Author: numq

data/repository/post_repository.go

@@ -49,6 +49,14 @@ func (r *postRepository) GetPosts(ctx context.Context, threadId string, skip int
 	return data, nil
 }
 
+func (r *postRepository) GetPostById(ctx context.Context, id string) (*domain.Post, error) {
+	data := new(domain.Post)
+	if err := r.db.Posts.FindOne(ctx, bson.M{"_id": id}).Decode(&data); err != nil {
+		return nil, err
+	}
+	return data, nil
+}
+
 func (r *postRepository) CreatePost(ctx context.Context, post *domain.Post) (string, error) {
 	session, err := r.db.Boards.Database().Client().StartSession()
 	if err != nil {

domain/repository.go

@@ -24,6 +24,7 @@ type ThreadRepository interface {
 
 type PostRepository interface {
 	GetPosts(ctx context.Context, threadId string, skip int64, limit int64) ([]*Post, error)
+	GetPostById(ctx context.Context, id string) (*Post, error)
 	CreatePost(ctx context.Context, post *Post) (string, error)
 	DeletePost(ctx context.Context, id string) (int64, error)
 }

infrastructure/handler/post_handler.go

@@ -10,6 +10,7 @@ import (
 
 type PostHandler interface {
 	GetPosts(req *proto.GetPostsReq, stream proto.PostService_GetPostsServer) error
+	GetPostById(ctx context.Context, req *proto.GetPostByIdReq) (*proto.GetPostByIdRes, error)
 	CreatePost(ctx context.Context, req *proto.CreatePostReq) (*proto.CreatePostRes, error)
 	DeletePost(ctx context.Context, req *proto.DeletePostReq) (*proto.DeletePostRes, error)
 }
@@ -38,6 +39,15 @@ func (h *postHandler) GetPosts(req *proto.GetPostsReq, stream proto.PostService_
 	return nil
 }
 
+func (h *postHandler) GetPostById(ctx context.Context, req *proto.GetPostByIdReq) (*proto.GetPostByIdRes, error) {
+	post, err := h.useCase.GetPostById(ctx, req.GetId())
+	if err != nil {
+		log.Println(err)
+		return &proto.GetPostByIdRes{}, nil
+	}
+	return &proto.GetPostByIdRes{Post: mapping.PostToProto(post)}, nil
+}
+
 func (h *postHandler) CreatePost(ctx context.Context, req *proto.CreatePostReq) (*proto.CreatePostRes, error) {
 	id, err := h.useCase.CreatePost(ctx, mapping.PostToModel(req.GetPost()))
 	if err != nil {

proto/post.proto

@@ -6,6 +6,7 @@ option go_package = "./proto";
 
 service PostService{
   rpc GetPosts(GetPostsReq) returns (stream GetPostsRes);
+  rpc GetPostById(GetPostByIdReq) returns (GetPostByIdRes);
   rpc CreatePost(CreatePostReq) returns (CreatePostRes);
   rpc DeletePost(DeletePostReq) returns (DeletePostRes);
 }
@@ -20,6 +21,14 @@ message GetPostsRes{
   Post post = 1;
 }
 
+message GetPostByIdReq{
+  string id = 1;
+}
+
+message GetPostByIdRes{
+  Post post = 1;
+}
+
 message CreatePostReq{
   Post post = 1;
 }

usecase/post_usecase.go

@@ -7,6 +7,7 @@ import (
 
 type PostUseCase interface {
 	GetPosts(ctx context.Context, threadId string, skip int64, limit int64) ([]*domain.Post, error)
+	GetPostById(ctx context.Context, id string) (*domain.Post, error)
 	CreatePost(ctx context.Context, post *domain.Post) (string, error)
 	DeletePost(ctx context.Context, id string) (int64, error)
 }
@@ -23,6 +24,10 @@ func (u *postUseCase) GetPosts(ctx context.Context, threadId string, skip int64,
 	return u.Repository.GetPosts(ctx, threadId, skip, limit)
 }
 
+func (u *postUseCase) GetPostById(ctx context.Context, id string) (*domain.Post, error) {
+	return u.Repository.GetPostById(ctx, id)
+}
+
 func (u *postUseCase) CreatePost(ctx context.Context, post *domain.Post) (string, error) {
 	return u.Repository.CreatePost(ctx, post)
 }