List Roles

src/datastore/roles.cpp

@@ -76,6 +76,25 @@
 	}
 }
 
+Roles ListRoles() {
+	std::string_view qry = R"(
+		select
+			_id,
+			_rev,
+			name
+		from roles
+	)";
+
+	auto res = pg::exec(qry);
+
+	Roles roles;
+	for (const auto &r : res) {
+		roles.push_back(Role(r));
+	}
+
+	return roles;
+}
+
 Role RetrieveRole(const std::string &id) {
 	std::string_view qry = R"(
 		select

src/datastore/roles.h

@@ -40,5 +40,6 @@ class Role {
 
 using Roles = std::vector<Role>;
 
-Role RetrieveRole(const std::string &id);
+Roles ListRoles();
+Role  RetrieveRole(const std::string &id);
 } // namespace datastore

src/svc/roles.cpp

@@ -55,6 +55,19 @@ grpc::ServerUnaryReactor *Roles::Create(
 	return reactor;
 }
 
+grpc::ServerUnaryReactor *Roles::List(
+	grpc::CallbackServerContext *context, const gk::v1::RolesListRequest *request,
+	gk::v1::RolesListResponse *response) {
+	auto *reactor = context->DefaultReactor();
+
+	// TODO: error handling
+	auto roles = datastore::ListRoles();
+	map(roles, response);
+
+	reactor->Finish(grpc::Status::OK);
+	return reactor;
+}
+
 grpc::ServerUnaryReactor *Roles::Retrieve(
 	grpc::CallbackServerContext *context, const gk::v1::RolesRetrieveRequest *request,
 	gk::v1::Role *response) {
@@ -86,4 +99,11 @@ void Roles::map(const datastore::Role &from, gk::v1::Role *to) {
 		Permissions::map(perm, p);
 	}
 }
+
+void Roles::map(const datastore::Roles &from, gk::v1::RolesListResponse *to) {
+	for (const auto &role : from) {
+		auto r = to->add_data();
+		Roles::map(role, r);
+	}
+}
 } // namespace svc

src/svc/roles.h

@@ -18,12 +18,17 @@ class Roles final : public gk::v1::Roles::CallbackService {
 		grpc::CallbackServerContext *context, const gk::v1::RolesCreateRequest *request,
 		gk::v1::Role *response) override;
 
+	grpc::ServerUnaryReactor *List(
+		grpc::CallbackServerContext *context, const gk::v1::RolesListRequest *request,
+		gk::v1::RolesListResponse *response) override;
+
 	grpc::ServerUnaryReactor *Retrieve(
 		grpc::CallbackServerContext *context, const gk::v1::RolesRetrieveRequest *request,
 		gk::v1::Role *response) override;
 
 	static datastore::Role map(const gk::v1::RolesCreateRequest *from);
 
 	static void map(const datastore::Role &from, gk::v1::Role *to);
+	static void map(const datastore::Roles &from, gk::v1::RolesListResponse *to);
 };
 } // namespace svc

src/svc/roles_test.cpp

@@ -121,6 +121,32 @@ TEST_F(svc_RolesTest, Create) {
 	}
 }
 
+TEST_F(svc_RolesTest, List) {
+	svc::Roles svc;
+
+	// Success: list roles
+	{
+		grpc::CallbackServerContext           ctx;
+		grpc::testing::DefaultReactorTestPeer peer(&ctx);
+		gk::v1::RolesListResponse             response;
+
+		gk::v1::RolesListRequest request;
+
+		datastore::Role role({
+			.id = "id:svc_RolesTest.List",
+		});
+		ASSERT_NO_THROW(role.store());
+
+		auto reactor = svc.List(&ctx, &request, &response);
+		EXPECT_TRUE(peer.test_status_set());
+		EXPECT_TRUE(peer.test_status().ok());
+		EXPECT_EQ(peer.reactor(), reactor);
+
+		EXPECT_EQ(response.data().size(), 1);
+		EXPECT_EQ(response.data()[0].id(), role.id());
+	}
+}
+
 TEST_F(svc_RolesTest, Retrieve) {
 	svc::Roles svc;