Blog: add comments

README.md

@@ -65,6 +65,12 @@ A new binary will be created under `./build/regen`.
 
 To run the node, you can refer to the documentation [here](https://docs.cosmos.network/master/run-node/).
 
+## Tests
+if you would like to run test, run:
+```bash
+make test
+```
+
 ## Resources
 
 - Cosmos SDK Documentation: https://docs.cosmos.network/master/.

proto/blog/v1/query.proto

@@ -4,11 +4,12 @@ package blog.v1;
 option go_package = "github.com/regen-network/bec/x/blog";
 
 import "cosmos/base/query/v1beta1/pagination.proto";
-import "blog/v1/common.proto";
+import "blog/v1/types.proto";
 
 // Query defines the gRPC querier service.
 service Query {
   rpc AllPosts(QueryAllPostsRequest) returns (QueryAllPostsResponse);
+  rpc AllComments(QueryAllCommentsRequest) returns (QueryAllCommentsResponse);
 }
 
 message QueryAllPostsRequest {
@@ -20,3 +21,14 @@ message QueryAllPostsResponse {
 
   cosmos.base.query.v1beta1.PageResponse pagination = 2;
 }
+
+message QueryAllCommentsRequest {
+  string postSlug = 1;
+  cosmos.base.query.v1beta1.PageRequest pagination = 2;
+}
+
+message QueryAllCommentsResponse {
+  repeated Comment comments = 1;
+
+  cosmos.base.query.v1beta1.PageResponse pagination = 2;
+}

proto/blog/v1/tx.proto

@@ -6,6 +6,7 @@ option go_package = "github.com/regen-network/bec/x/blog";
 // Msg is the blog.v1 Msg service
 service Msg {
   rpc CreatePost(MsgCreatePost) returns (MsgCreatePostResponse);
+  rpc CreateComment(MsgCreateComment) returns (MsgCreateCommentResponse);
 }
 
 // MsgCreatePost is the Msg/CreatePost request type.
@@ -18,3 +19,13 @@ message MsgCreatePost {
 
 // MsgCreatePostResponse is the Msg/CreatePost response type.
 message MsgCreatePostResponse {}
+
+// MsgCreateComment is the Msg/CreateComment request type.
+message MsgCreateComment {
+  string post_slug = 1;
+  string author = 2;
+  string body = 3;
+}
+
+// MsgCreateCommentResponse is the Msg/CreateComment response type.
+message MsgCreateCommentResponse {}

proto/blog/v1/types.proto

@@ -11,3 +11,11 @@ message Post {
   string title = 3;
   string body = 4;
 }
+
+message Comment {
+  // post_slug is a short human-readable string for the post, used as unique
+  // identifier for the post.
+  string post_slug = 1;
+  string author = 2;
+  string body = 3;
+}

scripts/protocgen.sh

@@ -19,15 +19,15 @@ protoc_gen_gocosmos
 
 proto_dirs=$(find ./proto -path -prune -o -name '*.proto' -print0 | xargs -0 -n1 dirname | sort | uniq)
 for dir in $proto_dirs; do
-  buf protoc \
+  buf alpha protoc \
   -I "proto" \
   -I "third_party/proto" \
   --gocosmos_out=plugins=interfacetype+grpc,\
 Mgoogle/protobuf/any.proto=github.com/cosmos/cosmos-sdk/codec/types:. \
   $(find "${dir}" -maxdepth 1 -name '*.proto')
 
   # command to generate gRPC gateway (*.pb.gw.go in respective modules) files
-  buf protoc \
+  buf alpha protoc \
   -I "proto" \
   -I "third_party/proto" \
   --grpc-gateway_out=logtostderr=true:. \

x/blog/client/cli/cli_test.go

@@ -182,6 +182,57 @@ func (s *IntegrationTestSuite) TestAllPosts() {
 	}
 }
 
+func (s *IntegrationTestSuite) TestCreateComment() {
+	val0 := s.network.Validators[0]
+
+	testCases := []struct {
+		postArgs    []string
+		commentArgs []string
+		name        string
+		expErr      bool
+		expErrMsg   string
+	}{
+		{
+			postArgs:    []string{val0.Address.String(), "/post", "title", "body"},
+			commentArgs: []string{val0.Address.String(), "/post", "content"},
+			name:        "valid comment request",
+			expErr:      false,
+			expErrMsg:   "",
+		},
+	}
+
+	for _, tc := range testCases {
+		s.Run(tc.name, func() {
+			postcmd := cli.CmdCreatePost()
+			args := append([]string{
+				fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
+				fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
+				fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
+			}, tc.postArgs...)
+			_, err := clitestutil.ExecTestCLICmd(val0.ClientCtx, postcmd, args)
+			s.Require().NoError(err)
+
+			commentcmd := cli.CmdCreateComment()
+			args = append([]string{
+				fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
+				fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
+				fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
+			}, tc.commentArgs...)
+			fmt.Printf("args %v+", args)
+			out, err := clitestutil.ExecTestCLICmd(val0.ClientCtx, commentcmd, args)
+			if tc.expErr {
+				s.Require().Error(err)
+				s.Require().Contains(err.Error(), tc.expErrMsg)
+			} else {
+				var txRes sdk.TxResponse
+				err := val0.ClientCtx.Codec.UnmarshalJSON(out.Bytes(), &txRes)
+				s.Require().NoError(err)
+				s.Require().Equal(uint32(0), txRes.Code)
+			}
+		})
+	}
+}
+
 func TestKeeperTestSuite(t *testing.T) {
 	suite.Run(t, new(IntegrationTestSuite))
 }

x/blog/client/cli/tx.go

@@ -61,3 +61,37 @@ func CmdCreatePost() *cobra.Command {
 
 	return cmd
 }
+
+func CmdCreateComment() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "create-comment [author] [post_slug] [body]",
+		Short: "Creates a new comment on a post",
+		Args:  cobra.ExactArgs(3),
+		RunE: func(cmd *cobra.Command, args []string) error {
+			err := cmd.Flags().Set(flags.FlagFrom, args[0])
+			if err != nil {
+				return err
+			}
+
+			argsPostSlug := string(args[1])
+			argsBody := string(args[2])
+
+			clientCtx, err := client.GetClientTxContext(cmd)
+			if err != nil {
+				return err
+			}
+
+			msg := &blog.MsgCreateComment{
+				Author:   clientCtx.GetFromAddress().String(),
+				PostSlug: argsPostSlug,
+				Body:     argsBody,
+			}
+
+			return tx.GenerateOrBroadcastTxCLI(clientCtx, cmd.Flags(), msg)
+		},
+	}
+
+	flags.AddTxFlagsToCmd(cmd)
+
+	return cmd
+}