@@ -29,7 +29,7 @@ test('MeshV2Service Subscription Integration', t => {
2929 return {
3030 subscribe : observer => {
3131 subscriptionObserver = observer ;
32- return { unsubscribe : ( ) => { } } ;
32+ return { unsubscribe : ( ) => { } } ;
3333 }
3434 } ;
3535 }
@@ -52,7 +52,7 @@ test('MeshV2Service Subscription Integration', t => {
5252 subscribe : ( ) => ( {
5353 subscribe : observer => {
5454 subscriptionObserver = observer ;
55- return { unsubscribe : ( ) => { } } ;
55+ return { unsubscribe : ( ) => { } } ;
5656 }
5757 } )
5858 } ;
@@ -61,7 +61,7 @@ test('MeshV2Service Subscription Integration', t => {
6161
6262 // Spy on handleDataUpdate
6363 let handleDataUpdateCalled = false ;
64- service . handleDataUpdate = ( payload ) => {
64+ service . handleDataUpdate = payload => {
6565 handleDataUpdateCalled = true ;
6666 st . equal ( payload . __typename , 'NodeStatus' ) ;
6767 st . equal ( payload . nodeId , 'node2' ) ;
@@ -71,9 +71,11 @@ test('MeshV2Service Subscription Integration', t => {
7171 subscriptionObserver . next ( {
7272 data : {
7373 onMessageInGroup : {
74- __typename : 'NodeStatus' ,
75- nodeId : 'node2' ,
76- data : [ ]
74+ nodeStatus : {
75+ __typename : 'NodeStatus' ,
76+ nodeId : 'node2' ,
77+ data : [ ]
78+ }
7779 }
7880 }
7981 } ) ;
@@ -92,7 +94,7 @@ test('MeshV2Service Subscription Integration', t => {
9294 subscribe : ( ) => ( {
9395 subscribe : observer => {
9496 subscriptionObserver = observer ;
95- return { unsubscribe : ( ) => { } } ;
97+ return { unsubscribe : ( ) => { } } ;
9698 }
9799 } )
98100 } ;
@@ -101,7 +103,7 @@ test('MeshV2Service Subscription Integration', t => {
101103
102104 // Spy on handleBatchEvent
103105 let handleBatchEventCalled = false ;
104- service . handleBatchEvent = ( payload ) => {
106+ service . handleBatchEvent = payload => {
105107 handleBatchEventCalled = true ;
106108 st . equal ( payload . __typename , 'BatchEvent' ) ;
107109 st . equal ( payload . firedByNodeId , 'node2' ) ;
@@ -111,9 +113,11 @@ test('MeshV2Service Subscription Integration', t => {
111113 subscriptionObserver . next ( {
112114 data : {
113115 onMessageInGroup : {
114- __typename : 'BatchEvent' ,
115- firedByNodeId : 'node2' ,
116- events : [ ]
116+ batchEvent : {
117+ __typename : 'BatchEvent' ,
118+ firedByNodeId : 'node2' ,
119+ events : [ ]
120+ }
117121 }
118122 }
119123 } ) ;
@@ -132,7 +136,7 @@ test('MeshV2Service Subscription Integration', t => {
132136 subscribe : ( ) => ( {
133137 subscribe : observer => {
134138 subscriptionObserver = observer ;
135- return { unsubscribe : ( ) => { } } ;
139+ return { unsubscribe : ( ) => { } } ;
136140 }
137141 } )
138142 } ;
@@ -149,8 +153,10 @@ test('MeshV2Service Subscription Integration', t => {
149153 subscriptionObserver . next ( {
150154 data : {
151155 onMessageInGroup : {
152- __typename : 'GroupDissolvePayload' ,
153- message : 'Bye'
156+ groupDissolve : {
157+ __typename : 'GroupDissolvePayload' ,
158+ message : 'Bye'
159+ }
154160 }
155161 }
156162 } ) ;
@@ -170,7 +176,7 @@ test('MeshV2Service Subscription Integration', t => {
170176 subscribe : ( ) => ( {
171177 subscribe : observer => {
172178 subscriptionObserver = observer ;
173- return { unsubscribe : ( ) => { } } ;
179+ return { unsubscribe : ( ) => { } } ;
174180 }
175181 } )
176182 } ;
@@ -179,9 +185,15 @@ test('MeshV2Service Subscription Integration', t => {
179185
180186 // Spies
181187 let anyCalled = false ;
182- service . handleDataUpdate = ( ) => { anyCalled = true ; } ;
183- service . handleBatchEvent = ( ) => { anyCalled = true ; } ;
184- service . cleanupAndDisconnect = ( ) => { anyCalled = true ; } ;
188+ service . handleDataUpdate = ( ) => {
189+ anyCalled = true ;
190+ } ;
191+ service . handleBatchEvent = ( ) => {
192+ anyCalled = true ;
193+ } ;
194+ service . cleanupAndDisconnect = ( ) => {
195+ anyCalled = true ;
196+ } ;
185197
186198 // Simulate unknown message
187199 subscriptionObserver . next ( {
0 commit comments