Add a test which matches on an arg in a variable

Author: wravery

tests.cpp

@@ -922,6 +922,57 @@ TEST_F(TodayServiceCase, SubscribeNodeChangeMismatchedId)
 	}
 }
 
+TEST_F(TodayServiceCase, SubscribeNodeChangeMatchingVariable)
+{
+	auto ast = peg::parseString(R"(subscription TestSubscription($taskId: ID!) {
+			changedNode: nodeChange(id: $taskId) {
+				changedId: id
+				...on Task {
+					title
+					isComplete
+				}
+			}
+		})");
+	response::Value variables(response::Type::Map);
+	variables.emplace_back("taskId", response::Value(std::string("ZmFrZVRhc2tJZA==")));
+	auto state = std::make_shared<today::RequestState>(14);
+	auto subscriptionObject = std::make_shared<today::NodeChange>(
+		[this](const std::shared_ptr<service::RequestState>& state, std::vector<uint8_t>&& idArg) -> std::shared_ptr<service::Object>
+	{
+		EXPECT_EQ(14, std::static_pointer_cast<today::RequestState>(state)->requestId) << "should pass the RequestState to the subscription resolvers";
+		EXPECT_EQ(_fakeTaskId, idArg);
+		return std::static_pointer_cast<service::Object>(std::make_shared<today::Task>(std::vector<uint8_t>(_fakeTaskId), "Don't forget", true));
+	});
+	response::Value result;
+	auto key = _service->subscribe(service::SubscriptionParams { state, std::move(ast), "TestSubscription", std::move(std::move(variables)) },
+		[&result](std::future<response::Value> response)
+	{
+		result = response.get();
+	});
+	_service->deliver("nodeChange", { {"id", response::Value(std::string("ZmFrZVRhc2tJZA==")) } }, std::static_pointer_cast<service::Object>(subscriptionObject));
+	_service->unsubscribe(key);
+
+	try
+	{
+		ASSERT_TRUE(result.type() == response::Type::Map);
+		auto errorsItr = result.find("errors");
+		if (errorsItr != result.get<const response::MapType&>().cend())
+		{
+			FAIL() << response::toJSON(response::Value(errorsItr->second));
+		}
+		const auto data = service::ScalarArgument::require("data", result);
+
+		const auto taskNode = service::ScalarArgument::require("changedNode", data);
+		EXPECT_EQ(_fakeTaskId, service::IdArgument::require("changedId", taskNode)) << "id should match in base64 encoding";
+		EXPECT_EQ("Don't forget", service::StringArgument::require("title", taskNode)) << "title should match";
+		EXPECT_TRUE(service::BooleanArgument::require("isComplete", taskNode)) << "isComplete should match";
+	}
+	catch (const service::schema_exception& ex)
+	{
+		FAIL() << response::toJSON(response::Value(ex.getErrors()));
+	}
+}
+
 TEST(ArgumentsCase, ListArgumentStrings)
 {
 	auto parsed = response::parseJSON(R"js({"value":[