Skip to content

Commit e5029b2

Browse files
wraverywravery
committed
Emit all operations in a unified file to start
1 parent 4a6e11a commit e5029b2

22 files changed

+1819
-646
lines changed

‎include/ClientGenerator.h

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -39,19 +39,22 @@ class [[nodiscard]] Generator
3939
[[nodiscard]] std::string getHeaderPath() const noexcept;
4040
[[nodiscard]] std::string getSourcePath() const noexcept;
4141
[[nodiscard]] const std::string& getClientNamespace() const noexcept;
42-
[[nodiscard]] const std::string& getRequestNamespace() const noexcept;
43-
[[nodiscard]] const std::string& getFullNamespace() const noexcept;
42+
[[nodiscard]] const std::string& getOperationNamespace(
43+
const Operation& operation) const noexcept;
4444
[[nodiscard]] std::string getResponseFieldCppType(
4545
const ResponseField& responseField, std::string_view currentScope = {}) const noexcept;
4646

4747
[[nodiscard]] bool outputHeader() const noexcept;
4848
void outputRequestComment(std::ostream& headerFile) const noexcept;
4949
void outputGetRequestDeclaration(std::ostream& headerFile) const noexcept;
50+
void outputGetOperationNameDeclaration(std::ostream& headerFile) const noexcept;
5051
[[nodiscard]] bool outputResponseFieldType(std::ostream& headerFile,
5152
const ResponseField& responseField, size_t indent = 0) const noexcept;
5253

5354
[[nodiscard]] bool outputSource() const noexcept;
5455
void outputGetRequestImplementation(std::ostream& sourceFile) const noexcept;
56+
void outputGetOperationNameImplementation(
57+
std::ostream& sourceFile, const Operation& operation) const noexcept;
5558
bool outputModifiedResponseImplementation(std::ostream& sourceFile,
5659
const std::string& outerScope, const ResponseField& responseField) const noexcept;
5760
[[nodiscard]] static std::string getTypeModifierList(

‎include/GeneratorUtil.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ class [[nodiscard]] NamespaceScope
3939
private:
4040
bool _inside = false;
4141
std::ostream& _outputFile;
42-
std::string_view _cppNamespace;
42+
std::string _cppNamespace;
4343
};
4444

4545
// Keep track of whether we want to add a blank separator line once some additional content is about

‎include/RequestLoader.h

Lines changed: 34 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -64,10 +64,25 @@ struct [[nodiscard]] RequestVariable
6464

6565
using RequestVariableList = std::vector<RequestVariable>;
6666

67+
struct [[nodiscard]] Operation
68+
{
69+
const peg::ast_node* operation;
70+
std::string_view name;
71+
std::string_view type;
72+
ResponseType responseType;
73+
RequestVariableList variables;
74+
internal::string_view_set inputTypeNames;
75+
RequestInputTypeList referencedInputTypes;
76+
internal::string_view_set enumNames;
77+
RequestSchemaTypeList referencedEnums;
78+
};
79+
80+
using OperationList = std::vector<Operation>;
81+
6782
struct [[nodiscard]] RequestOptions
6883
{
6984
const std::string requestFilename;
70-
const std::string operationName;
85+
const std::optional<std::string> operationName;
7186
const bool noIntrospection = false;
7287
};
7388

@@ -79,16 +94,21 @@ class [[nodiscard]] RequestLoader
7994
explicit RequestLoader(RequestOptions&& requestOptions, const SchemaLoader& schemaLoader);
8095

8196
[[nodiscard]] std::string_view getRequestFilename() const noexcept;
82-
[[nodiscard]] std::string_view getOperationDisplayName() const noexcept;
83-
[[nodiscard]] std::string getOperationNamespace() const noexcept;
84-
[[nodiscard]] std::string_view getOperationType() const noexcept;
97+
[[nodiscard]] const OperationList& getOperations() const noexcept;
98+
[[nodiscard]] std::string_view getOperationDisplayName(
99+
const Operation& operation) const noexcept;
100+
[[nodiscard]] std::string getOperationNamespace(const Operation& operation) const noexcept;
101+
[[nodiscard]] std::string_view getOperationType(const Operation& operation) const noexcept;
85102
[[nodiscard]] std::string_view getRequestText() const noexcept;
86103

87-
[[nodiscard]] const ResponseType& getResponseType() const noexcept;
88-
[[nodiscard]] const RequestVariableList& getVariables() const noexcept;
104+
[[nodiscard]] const ResponseType& getResponseType(const Operation& operation) const noexcept;
105+
[[nodiscard]] const RequestVariableList& getVariables(
106+
const Operation& operation) const noexcept;
89107

90-
[[nodiscard]] const RequestInputTypeList& getReferencedInputTypes() const noexcept;
91-
[[nodiscard]] const RequestSchemaTypeList& getReferencedEnums() const noexcept;
108+
[[nodiscard]] const RequestInputTypeList& getReferencedInputTypes(
109+
const Operation& operation) const noexcept;
110+
[[nodiscard]] const RequestSchemaTypeList& getReferencedEnums(
111+
const Operation& operation) const noexcept;
92112

93113
[[nodiscard]] std::string getInputCppType(
94114
const RequestSchemaType& wrappedInputType) const noexcept;
@@ -111,11 +131,11 @@ class [[nodiscard]] RequestLoader
111131

112132
void findOperation();
113133
void collectFragments() noexcept;
114-
void collectVariables() noexcept;
115-
void collectInputTypes(const RequestSchemaType& variableType) noexcept;
116-
void reorderInputTypeDependencies();
117-
void collectEnums(const RequestSchemaType& variableType) noexcept;
118-
void collectEnums(const ResponseField& responseField) noexcept;
134+
void collectVariables(Operation& operation) noexcept;
135+
void collectInputTypes(Operation& operation, const RequestSchemaType& variableType) noexcept;
136+
void reorderInputTypeDependencies(Operation& operation);
137+
void collectEnums(Operation& operation, const RequestSchemaType& variableType) noexcept;
138+
void collectEnums(Operation& operation, const ResponseField& responseField) noexcept;
119139

120140
using FragmentDefinitionMap = std::map<std::string_view, const peg::ast_node*>;
121141

@@ -153,16 +173,8 @@ class [[nodiscard]] RequestLoader
153173
peg::ast _ast;
154174

155175
std::string _requestText;
156-
const peg::ast_node* _operation = nullptr;
157-
std::string_view _operationName;
158-
std::string_view _operationType;
176+
OperationList _operations;
159177
FragmentDefinitionMap _fragments;
160-
ResponseType _responseType;
161-
RequestVariableList _variables;
162-
internal::string_view_set _inputTypeNames;
163-
RequestInputTypeList _referencedInputTypes;
164-
internal::string_view_set _enumNames;
165-
RequestSchemaTypeList _referencedEnums;
166178
};
167179

168180
} // namespace graphql::generator

‎samples/client/CMakeLists.txt

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ add_subdirectory(query)
77
add_subdirectory(mutate)
88
add_subdirectory(subscribe)
99
add_subdirectory(nestedinput)
10+
add_subdirectory(multiple)
1011

1112
add_subdirectory(benchmark)
1213

‎samples/client/benchmark.cpp

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -86,14 +86,15 @@ int main(int argc, char** argv)
8686

8787
try
8888
{
89-
for (size_t i = 0; i < iterations; ++i)
90-
{
91-
using namespace client::query::Query;
89+
using namespace client::query::Query;
9290

93-
auto query = GetRequestObject();
91+
auto query = GetRequestObject();
92+
const auto& name = GetOperationName();
9493

94+
for (size_t i = 0; i < iterations; ++i)
95+
{
9596
const auto startResolve = std::chrono::steady_clock::now();
96-
auto response = service->resolve({ query }).get();
97+
auto response = service->resolve({ query, name }).get();
9798
const auto startParseServiceResponse = std::chrono::steady_clock::now();
9899
auto serviceResponse = client::parseServiceResponse(std::move(response));
99100
const auto startParseResponse = std::chrono::steady_clock::now();

‎samples/client/benchmark/BenchmarkClient.cpp

Lines changed: 57 additions & 49 deletions
Original file line numberDiff line numberDiff line change
@@ -14,13 +14,54 @@
1414
using namespace std::literals;
1515

1616
namespace graphql::client {
17+
namespace benchmark {
1718

18-
using namespace query::Query;
19+
const std::string& GetRequestText() noexcept
20+
{
21+
static const auto s_request = R"gql(
22+
# Copyright (c) Microsoft Corporation. All rights reserved.
23+
# Licensed under the MIT License.
24+
25+
query {
26+
appointments {
27+
pageInfo {
28+
hasNextPage
29+
}
30+
edges {
31+
node {
32+
id
33+
when
34+
subject
35+
isNow
36+
}
37+
}
38+
}
39+
}
40+
)gql"s;
41+
42+
return s_request;
43+
}
44+
45+
const peg::ast& GetRequestObject() noexcept
46+
{
47+
static const auto s_request = []() noexcept {
48+
auto ast = peg::parseString(GetRequestText());
49+
50+
// This has already been validated against the schema by clientgen.
51+
ast.validated = true;
52+
53+
return ast;
54+
}();
55+
56+
return s_request;
57+
}
58+
59+
} // namespace benchmark
1960

2061
template <>
21-
Response::appointments_AppointmentConnection::pageInfo_PageInfo ModifiedResponse<Response::appointments_AppointmentConnection::pageInfo_PageInfo>::parse(response::Value&& response)
62+
query::Query::Response::appointments_AppointmentConnection::pageInfo_PageInfo ModifiedResponse<query::Query::Response::appointments_AppointmentConnection::pageInfo_PageInfo>::parse(response::Value&& response)
2263
{
23-
Response::appointments_AppointmentConnection::pageInfo_PageInfo result;
64+
query::Query::Response::appointments_AppointmentConnection::pageInfo_PageInfo result;
2465

2566
if (response.type() == response::Type::Map)
2667
{
@@ -40,9 +81,9 @@ Response::appointments_AppointmentConnection::pageInfo_PageInfo ModifiedResponse
4081
}
4182

4283
template <>
43-
Response::appointments_AppointmentConnection::edges_AppointmentEdge::node_Appointment ModifiedResponse<Response::appointments_AppointmentConnection::edges_AppointmentEdge::node_Appointment>::parse(response::Value&& response)
84+
query::Query::Response::appointments_AppointmentConnection::edges_AppointmentEdge::node_Appointment ModifiedResponse<query::Query::Response::appointments_AppointmentConnection::edges_AppointmentEdge::node_Appointment>::parse(response::Value&& response)
4485
{
45-
Response::appointments_AppointmentConnection::edges_AppointmentEdge::node_Appointment result;
86+
query::Query::Response::appointments_AppointmentConnection::edges_AppointmentEdge::node_Appointment result;
4687

4788
if (response.type() == response::Type::Map)
4889
{
@@ -77,9 +118,9 @@ Response::appointments_AppointmentConnection::edges_AppointmentEdge::node_Appoin
77118
}
78119

79120
template <>
80-
Response::appointments_AppointmentConnection::edges_AppointmentEdge ModifiedResponse<Response::appointments_AppointmentConnection::edges_AppointmentEdge>::parse(response::Value&& response)
121+
query::Query::Response::appointments_AppointmentConnection::edges_AppointmentEdge ModifiedResponse<query::Query::Response::appointments_AppointmentConnection::edges_AppointmentEdge>::parse(response::Value&& response)
81122
{
82-
Response::appointments_AppointmentConnection::edges_AppointmentEdge result;
123+
query::Query::Response::appointments_AppointmentConnection::edges_AppointmentEdge result;
83124

84125
if (response.type() == response::Type::Map)
85126
{
@@ -89,7 +130,7 @@ Response::appointments_AppointmentConnection::edges_AppointmentEdge ModifiedResp
89130
{
90131
if (member.first == R"js(node)js"sv)
91132
{
92-
result.node = ModifiedResponse<Response::appointments_AppointmentConnection::edges_AppointmentEdge::node_Appointment>::parse<TypeModifier::Nullable>(std::move(member.second));
133+
result.node = ModifiedResponse<query::Query::Response::appointments_AppointmentConnection::edges_AppointmentEdge::node_Appointment>::parse<TypeModifier::Nullable>(std::move(member.second));
93134
continue;
94135
}
95136
}
@@ -99,9 +140,9 @@ Response::appointments_AppointmentConnection::edges_AppointmentEdge ModifiedResp
99140
}
100141

101142
template <>
102-
Response::appointments_AppointmentConnection ModifiedResponse<Response::appointments_AppointmentConnection>::parse(response::Value&& response)
143+
query::Query::Response::appointments_AppointmentConnection ModifiedResponse<query::Query::Response::appointments_AppointmentConnection>::parse(response::Value&& response)
103144
{
104-
Response::appointments_AppointmentConnection result;
145+
query::Query::Response::appointments_AppointmentConnection result;
105146

106147
if (response.type() == response::Type::Map)
107148
{
@@ -111,12 +152,12 @@ Response::appointments_AppointmentConnection ModifiedResponse<Response::appointm
111152
{
112153
if (member.first == R"js(pageInfo)js"sv)
113154
{
114-
result.pageInfo = ModifiedResponse<Response::appointments_AppointmentConnection::pageInfo_PageInfo>::parse(std::move(member.second));
155+
result.pageInfo = ModifiedResponse<query::Query::Response::appointments_AppointmentConnection::pageInfo_PageInfo>::parse(std::move(member.second));
115156
continue;
116157
}
117158
if (member.first == R"js(edges)js"sv)
118159
{
119-
result.edges = ModifiedResponse<Response::appointments_AppointmentConnection::edges_AppointmentEdge>::parse<TypeModifier::Nullable, TypeModifier::List, TypeModifier::Nullable>(std::move(member.second));
160+
result.edges = ModifiedResponse<query::Query::Response::appointments_AppointmentConnection::edges_AppointmentEdge>::parse<TypeModifier::Nullable, TypeModifier::List, TypeModifier::Nullable>(std::move(member.second));
120161
continue;
121162
}
122163
}
@@ -127,44 +168,11 @@ Response::appointments_AppointmentConnection ModifiedResponse<Response::appointm
127168

128169
namespace query::Query {
129170

130-
const std::string& GetRequestText() noexcept
131-
{
132-
static const auto s_request = R"gql(
133-
# Copyright (c) Microsoft Corporation. All rights reserved.
134-
# Licensed under the MIT License.
135-
136-
query {
137-
appointments {
138-
pageInfo {
139-
hasNextPage
140-
}
141-
edges {
142-
node {
143-
id
144-
when
145-
subject
146-
isNow
147-
}
148-
}
149-
}
150-
}
151-
)gql"s;
152-
153-
return s_request;
154-
}
155-
156-
const peg::ast& GetRequestObject() noexcept
171+
const std::string& GetOperationName() noexcept
157172
{
158-
static const auto s_request = []() noexcept {
159-
auto ast = peg::parseString(GetRequestText());
160-
161-
// This has already been validated against the schema by clientgen.
162-
ast.validated = true;
173+
static const auto s_name = R"gql()gql"s;
163174

164-
return ast;
165-
}();
166-
167-
return s_request;
175+
return s_name;
168176
}
169177

170178
Response parseResponse(response::Value&& response)
@@ -179,7 +187,7 @@ Response parseResponse(response::Value&& response)
179187
{
180188
if (member.first == R"js(appointments)js"sv)
181189
{
182-
result.appointments = ModifiedResponse<Response::appointments_AppointmentConnection>::parse(std::move(member.second));
190+
result.appointments = ModifiedResponse<query::Query::Response::appointments_AppointmentConnection>::parse(std::move(member.second));
183191
continue;
184192
}
185193
}

‎samples/client/benchmark/BenchmarkClient.h

Lines changed: 15 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,8 @@ static_assert(graphql::internal::MinorVersion == 2, "regenerate with clientgen:
2222
#include <string>
2323
#include <vector>
2424

25+
namespace graphql::client {
26+
2527
/// <summary>
2628
/// Operation: query (unnamed)
2729
/// </summary>
@@ -45,14 +47,24 @@ static_assert(graphql::internal::MinorVersion == 2, "regenerate with clientgen:
4547
/// }
4648
/// }
4749
/// </code>
48-
namespace graphql::client::query::Query {
50+
namespace benchmark {
4951

5052
// Return the original text of the request document.
5153
const std::string& GetRequestText() noexcept;
5254

5355
// Return a pre-parsed, pre-validated request object.
5456
const peg::ast& GetRequestObject() noexcept;
5557

58+
} // namespace benchmark
59+
60+
namespace query::Query {
61+
62+
using benchmark::GetRequestText;
63+
using benchmark::GetRequestObject;
64+
65+
// Return the name of this operation in the shared request document.
66+
const std::string& GetOperationName() noexcept;
67+
5668
struct Response
5769
{
5870
struct appointments_AppointmentConnection
@@ -84,6 +96,7 @@ struct Response
8496

8597
Response parseResponse(response::Value&& response);
8698

87-
} // namespace graphql::client::query::Query
99+
} // namespace query::Query
100+
} // namespace graphql::client
88101

89102
#endif // BENCHMARKCLIENT_H

‎samples/client/multiple/CMakeLists.txt

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
# Copyright (c) Microsoft Corporation. All rights reserved.
2+
# Licensed under the MIT License.
3+
4+
cmake_minimum_required(VERSION 3.15)
5+
6+
# Normally this would be handled by find_package(cppgraphqlgen CONFIG).
7+
include(${CMAKE_CURRENT_SOURCE_DIR}/../../../cmake/cppgraphqlgen-functions.cmake)
8+
9+
if(GRAPHQL_UPDATE_SAMPLES AND GRAPHQL_BUILD_CLIENTGEN)
10+
update_graphql_client_files(multiple ../../today/schema.today.graphql multiple.today.graphql MultipleQueries multiple)
11+
endif()
12+
13+
add_graphql_client_target(multiple)

0 commit comments

Comments
 (0)