feat(x/ecocredit): query all projects with pagination

proto/regen/ecocredit/v1/query.proto

@@ -49,6 +49,12 @@ service Query {
     };
   }
 
+  // Projects queries for all projects within a class with pagination.
+  rpc Projects(QueryProjectsRequest) returns (QueryProjectsResponse) {
+    option (google.api.http).get =
+        "/regen/ecocredit/v1/projects";
+  }
+
   // ProjectsByClass queries for all projects within a class with pagination.
   rpc ProjectsByClass(QueryProjectsByClassRequest)
       returns (QueryProjectsByClassResponse) {
@@ -253,6 +259,23 @@ message QueryClassIssuersResponse {
   cosmos.base.query.v1beta1.PageResponse pagination = 2;
 }
 
+// QueryProjectsRequest is the Query/Projects request type.
+message QueryProjectsRequest {
+
+  // pagination defines an optional pagination for the request.
+  cosmos.base.query.v1beta1.PageRequest pagination = 1;
+}
+
+// QueryProjectsResponse is the Query/Projects response type.
+message QueryProjectsResponse {
+
+  // projects are the fetched projects.
+  repeated ProjectInfo projects = 1;
+
+  // pagination defines the pagination in the response.
+  cosmos.base.query.v1beta1.PageResponse pagination = 2;
+}
+
 // QueryProjectsByClassRequest is the Query/ProjectsByClass request type.
 message QueryProjectsByClassRequest {
 

x/ecocredit/client/query.go

@@ -34,6 +34,7 @@ func QueryCmd(name string) *cobra.Command {
 		QueryBalanceCmd(),
 		QuerySupplyCmd(),
 		QueryCreditTypesCmd(),
+		QueryProjectsCmd(),
 		QueryProjectsByClassCmd(),
 		QueryProjectsByReferenceIdCmd(),
 		QueryProjectsByAdminCmd(),
@@ -154,14 +155,50 @@ regen q ecocredit class-issuers C01 --limit 10
 	return qflags(cmd)
 }
 
-// QueryProjectsByClassCmd returns a query command that retrieves projects.
+// QueryProjectsCmd returns a query command that retrieves projects.
+func QueryProjectsCmd() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "projects",
+		Short: "Query all projects",
+		Long:  "Query all projects with optional pagination flags.",
+		Example: `
+regen q ecocredit projects
+regen q ecocredit projects --limit 10 --count-total
+		`,
+		Args: cobra.ExactArgs(0),
+		RunE: func(cmd *cobra.Command, args []string) error {
+			c, ctx, err := mkQueryClient(cmd)
+			if err != nil {
+				return err
+			}
+
+			pagination, err := client.ReadPageRequest(cmd.Flags())
+			if err != nil {
+				return err
+			}
+
+			res, err := c.Projects(cmd.Context(), &core.QueryProjectsRequest{
+				Pagination: pagination,
+			})
+
+			return printQueryResponse(ctx, res, err)
+		},
+	}
+
+	flags.AddPaginationFlagsToCmd(cmd, "projects")
+
+	return qflags(cmd)
+}
+
+// QueryProjectsByClassCmd returns a query command that retrieves projects by credit class.
 func QueryProjectsByClassCmd() *cobra.Command {
 	cmd := &cobra.Command{
 		Use:   "projects-by-class [class_id]",
-		Short: "List all projects in the given class with pagination flags",
+		Short: "Query projects by credit class",
+		Long:  "Query projects by credit class with optional pagination flags.",
 		Example: `
-regen q ecocredit projects C01
-regen q ecocredit projects C01 --limit 10
+regen q ecocredit projects-by-class C01
+regen q ecocredit projects-by-class C01 --limit 10 --count-total
 		`,
 		Args: cobra.ExactArgs(1),
 		RunE: func(cmd *cobra.Command, args []string) error {

x/ecocredit/client/testsuite/grpc.go

@@ -2,6 +2,7 @@ package testsuite
 
 import (
 	"fmt"
+	"strings"
 
 	"github.com/cosmos/cosmos-sdk/types"
 	"github.com/cosmos/cosmos-sdk/types/rest"
@@ -80,7 +81,177 @@ func (s *IntegrationTestSuite) TestQueryClass() {
 			err = s.val.ClientCtx.Codec.UnmarshalJSON(resp, &res)
 			require.NoError(err)
 			require.NotNil(res.Class)
-			require.Contains(res.Class.Id, s.classId)
+			require.Equal(res.Class.Id, s.classId)
+		})
+	}
+}
+
+func (s *IntegrationTestSuite) TestQueryProject() {
+	testCases := []struct {
+		name string
+		url  string
+	}{
+		{
+			"valid",
+			fmt.Sprintf("%s/%s/project/%s", s.val.APIAddress, coreRoute, s.projectId),
+		},
+		{
+			"valid alternative",
+			fmt.Sprintf("%s/%s/projects/%s", s.val.APIAddress, coreRoute, s.projectId),
+		},
+	}
+
+	require := s.Require()
+	for _, tc := range testCases {
+		tc := tc
+		s.Run(tc.name, func() {
+			bz, err := rest.GetRequest(tc.url)
+			require.NoError(err)
+
+			var res core.QueryProjectResponse
+			require.NoError(s.val.ClientCtx.Codec.UnmarshalJSON(bz, &res))
+			require.NotEmpty(res.Project)
+			require.Equal(res.Project.Id, s.projectId)
+		})
+	}
+}
+
+func (s *IntegrationTestSuite) TestQueryProjects() {
+	testCases := []struct {
+		name string
+		url  string
+	}{
+		{
+			name: "valid",
+			url:  fmt.Sprintf("%s/%s/projects", s.val.APIAddress, coreRoute),
+		},
+		{
+			name: "valid with pagination",
+			url: fmt.Sprintf(
+				"%s/%s/projects?pagination.limit=1&pagination.countTotal=true",
+				s.val.APIAddress,
+				coreRoute,
+			),
+		},
+	}
+
+	require := s.Require()
+	for _, tc := range testCases {
+		tc := tc
+		s.Run(tc.name, func() {
+			bz, err := rest.GetRequest(tc.url)
+			require.NoError(err)
+
+			var res core.QueryProjectsResponse
+			require.NoError(s.val.ClientCtx.Codec.UnmarshalJSON(bz, &res))
+			require.NotEmpty(res.Projects)
+			if strings.Contains(tc.name, "pagination") {
+				require.Len(res.Projects, 1)
+				require.NotEmpty(res.Pagination)
+				require.NotEmpty(res.Pagination.Total)
+			} else {
+				require.Empty(res.Pagination)
+			}
+		})
+	}
+}
+
+func (s *IntegrationTestSuite) TestQueryProjectsByClass() {
+	testCases := []struct {
+		name string
+		url  string
+	}{
+		{
+			name: "valid",
+			url:  fmt.Sprintf("%s/%s/projects-by-class/%s", s.val.APIAddress, coreRoute, s.classId),
+		},
+		{
+			name: "valid with pagination",
+			url: fmt.Sprintf(
+				"%s/%s/projects-by-class/%s?pagination.countTotal=true",
+				//"%s/%s/projects-by-class/%s?pagination.limit=1&pagination.countTotal=true", TODO: #1113
+				s.val.APIAddress,
+				coreRoute,
+				s.classId,
+			),
+		},
+		{
+			name: "valid alternative",
+			url:  fmt.Sprintf("%s/%s/classes/%s/projects", s.val.APIAddress, coreRoute, s.classId),
+		},
+	}
+
+	require := s.Require()
+	for _, tc := range testCases {
+		tc := tc
+		s.Run(tc.name, func() {
+			bz, err := rest.GetRequest(tc.url)
+			require.NoError(err)
+
+			var res core.QueryProjectsByClassResponse
+			require.NoError(s.val.ClientCtx.Codec.UnmarshalJSON(bz, &res))
+			require.NotEmpty(res.Projects)
+			if strings.Contains(tc.name, "pagination") {
+				// require.Len(res.Projects, 1) TODO: #1113
+				require.NotEmpty(res.Pagination)
+				require.NotEmpty(res.Pagination.Total)
+			} else {
+				require.Empty(res.Pagination)
+			}
+		})
+	}
+}
+
+func (s *IntegrationTestSuite) TestQueryProjectsByReferenceId() {
+	testCases := []struct {
+		name string
+		url  string
+	}{
+		{
+			name: "valid",
+			url: fmt.Sprintf(
+				"%s/%s/projects-by-reference-id/%s",
+				s.val.APIAddress,
+				coreRoute,
+				s.projectReferenceId,
+			),
+		},
+		{
+			name: "valid with pagination",
+			url: fmt.Sprintf(
+				"%s/%s/projects-by-reference-id/%s?pagination.limit=1&pagination.countTotal=true",
+				s.val.APIAddress,
+				coreRoute,
+				s.projectReferenceId,
+			),
+		},
+		{
+			name: "valid alternative",
+			url: fmt.Sprintf("%s/%s/projects/reference-id/%s",
+				s.val.APIAddress,
+				coreRoute,
+				s.projectReferenceId,
+			),
+		},
+	}
+
+	require := s.Require()
+	for _, tc := range testCases {
+		tc := tc
+		s.Run(tc.name, func() {
+			bz, err := rest.GetRequest(tc.url)
+			require.NoError(err)
+
+			var res core.QueryProjectsByReferenceIdResponse
+			require.NoError(s.val.ClientCtx.Codec.UnmarshalJSON(bz, &res))
+			require.NotEmpty(res.Projects)
+			if strings.Contains(tc.name, "pagination") {
+				require.Len(res.Projects, 1)
+				require.NotEmpty(res.Pagination)
+				require.NotEmpty(res.Pagination.Total)
+			} else {
+				require.Empty(res.Pagination)
+			}
 		})
 	}
 }