@@ -72,10 +72,10 @@ struct InspectorProtocol {
72
72
}
73
73
74
74
static folly::dynamic constructGetPagesResponsePayloadForPackager (
75
- const std::vector<facebook::react::InspectorPage> &pages,
75
+ const std::vector<facebook::react::jsinspector_modern:: InspectorPage> &pages,
76
76
InspectorPackagerConnection::BundleStatus bundleStatus) {
77
77
folly::dynamic payload = folly::dynamic::array;
78
- for (const facebook::react::InspectorPage &page : pages) {
78
+ for (const facebook::react::jsinspector_modern:: InspectorPage &page : pages) {
79
79
folly::dynamic pageDyn = folly::dynamic::object;
80
80
pageDyn[" id" ] = page.id ;
81
81
pageDyn[" title" ] = page.title ;
@@ -167,62 +167,63 @@ winrt::fire_and_forget InspectorPackagerConnection::connectAsync() {
167
167
m_packagerWebSocketConnection->SetOnConnect (
168
168
[]() { facebook::react::tracing::log (" Inspector: Websocket connection succeeded." ); });
169
169
170
- m_packagerWebSocketConnection->SetOnMessage ([self = shared_from_this ()](
171
- size_t /* length*/ , const std::string &message, bool isBinary) {
172
- assert (!isBinary && " We don't expect any binary messages !" );
173
- folly::dynamic messageDyn = folly::parseJson (message);
174
-
175
- InspectorProtocol::EventType eventType = InspectorProtocol::getEventType (messageDyn);
176
- switch (eventType) {
177
- case InspectorProtocol::EventType::GetPages: {
178
- std::vector<facebook::react::InspectorPage> inspectorPages = facebook::react::getInspectorInstance ().getPages ();
179
- folly::dynamic response = InspectorProtocol::constructResponseForPackager (
180
- InspectorProtocol::EventType::GetPages,
181
- InspectorProtocol::constructGetPagesResponsePayloadForPackager (
182
- inspectorPages, self->m_bundleStatusProvider ->getBundleStatus ()));
183
-
184
- std::string responsestr = folly::toJson (response);
185
- self->sendMessageToPackager (std::move (responsestr));
186
- break ;
187
- }
188
-
189
- case InspectorProtocol::EventType::WrappedEvent: {
190
- folly::dynamic payload = messageDyn[InspectorProtocol::Message_PAYLOAD];
191
- int32_t pageId = static_cast <int32_t >(payload[InspectorProtocol::Message_PAGEID].asInt ());
192
-
193
- if (self->m_localConnections .find (pageId) == self->m_localConnections .end ()) {
194
- break ;
195
- }
196
-
197
- std::string wrappedEvent = payload[InspectorProtocol::Message_eventName_wrappedEvent].getString ();
198
- self->sendMessageToVM (pageId, std::move (wrappedEvent));
199
- break ;
200
- }
201
-
202
- case InspectorProtocol::EventType::Connect: {
203
- folly::dynamic payload = messageDyn[InspectorProtocol::Message_PAYLOAD];
204
- int32_t pageId = static_cast <int32_t >(payload[InspectorProtocol::Message_PAGEID].asInt ());
205
-
206
- if (self->m_localConnections .find (pageId) != self->m_localConnections .end ()) {
207
- break ;
208
- }
209
-
210
- self->m_localConnections [pageId] =
211
- facebook::react::getInspectorInstance ().connect (pageId, std::make_unique<RemoteConnection>(pageId, *self));
212
- break ;
213
- }
214
-
215
- case InspectorProtocol::EventType::Disconnect: {
216
- folly::dynamic payload = messageDyn[InspectorProtocol::Message_PAYLOAD];
217
- int32_t pageId = static_cast <int32_t >(payload[InspectorProtocol::Message_PAGEID].asInt ());
218
- if (self->m_localConnections .find (pageId) != self->m_localConnections .end ()) {
219
- self->m_localConnections [pageId]->disconnect ();
220
- self->m_localConnections .erase (pageId);
170
+ m_packagerWebSocketConnection->SetOnMessage (
171
+ [self = shared_from_this ()](size_t /* length*/ , const std::string &message, bool isBinary) {
172
+ assert (!isBinary && " We don't expect any binary messages !" );
173
+ folly::dynamic messageDyn = folly::parseJson (message);
174
+
175
+ InspectorProtocol::EventType eventType = InspectorProtocol::getEventType (messageDyn);
176
+ switch (eventType) {
177
+ case InspectorProtocol::EventType::GetPages: {
178
+ std::vector<facebook::react::jsinspector_modern::InspectorPage> inspectorPages =
179
+ facebook::react::jsinspector_modern::getInspectorInstance ().getPages ();
180
+ folly::dynamic response = InspectorProtocol::constructResponseForPackager (
181
+ InspectorProtocol::EventType::GetPages,
182
+ InspectorProtocol::constructGetPagesResponsePayloadForPackager (
183
+ inspectorPages, self->m_bundleStatusProvider ->getBundleStatus ()));
184
+
185
+ std::string responsestr = folly::toJson (response);
186
+ self->sendMessageToPackager (std::move (responsestr));
187
+ break ;
188
+ }
189
+
190
+ case InspectorProtocol::EventType::WrappedEvent: {
191
+ folly::dynamic payload = messageDyn[InspectorProtocol::Message_PAYLOAD];
192
+ int32_t pageId = static_cast <int32_t >(payload[InspectorProtocol::Message_PAGEID].asInt ());
193
+
194
+ if (self->m_localConnections .find (pageId) == self->m_localConnections .end ()) {
195
+ break ;
196
+ }
197
+
198
+ std::string wrappedEvent = payload[InspectorProtocol::Message_eventName_wrappedEvent].getString ();
199
+ self->sendMessageToVM (pageId, std::move (wrappedEvent));
200
+ break ;
201
+ }
202
+
203
+ case InspectorProtocol::EventType::Connect: {
204
+ folly::dynamic payload = messageDyn[InspectorProtocol::Message_PAYLOAD];
205
+ int32_t pageId = static_cast <int32_t >(payload[InspectorProtocol::Message_PAGEID].asInt ());
206
+
207
+ if (self->m_localConnections .find (pageId) != self->m_localConnections .end ()) {
208
+ break ;
209
+ }
210
+
211
+ self->m_localConnections [pageId] = facebook::react::jsinspector_modern::getInspectorInstance ().connect (
212
+ pageId, std::make_unique<RemoteConnection>(pageId, *self));
213
+ break ;
214
+ }
215
+
216
+ case InspectorProtocol::EventType::Disconnect: {
217
+ folly::dynamic payload = messageDyn[InspectorProtocol::Message_PAYLOAD];
218
+ int32_t pageId = static_cast <int32_t >(payload[InspectorProtocol::Message_PAGEID].asInt ());
219
+ if (self->m_localConnections .find (pageId) != self->m_localConnections .end ()) {
220
+ self->m_localConnections [pageId]->disconnect ();
221
+ self->m_localConnections .erase (pageId);
222
+ }
223
+ break ;
224
+ }
221
225
}
222
- break ;
223
- }
224
- }
225
- });
226
+ });
226
227
227
228
Microsoft::React::Networking::IWebSocketResource::Protocols protocols;
228
229
Microsoft::React::Networking::IWebSocketResource::Options options;
0 commit comments