@@ -26,7 +26,6 @@ class MockWorkerScope {
2626 removeEventListener = jest . fn ( ) ;
2727}
2828
29-
3029describe ( 'MessageTransports' , ( ) => {
3130 describe ( 'WorkerMessageTransport' , ( ) => {
3231 let mockWorker : MockWorker ;
@@ -41,7 +40,7 @@ describe('MessageTransports', () => {
4140 it ( 'should send messages to worker' , async ( ) => {
4241 const testMessage = { jsonrpc : '2.0' , method : 'test' } ;
4342 await transport . send ( testMessage ) ;
44-
43+
4544 expect ( mockWorker . postMessage ) . toHaveBeenCalledWith ( testMessage ) ;
4645 } ) ;
4746
@@ -51,30 +50,33 @@ describe('MessageTransports', () => {
5150 } ) ;
5251
5352 const testMessage = { jsonrpc : '2.0' , method : 'test' } ;
54- await expect ( transport . send ( testMessage ) ) . rejects . toThrow ( 'PostMessage failed' ) ;
53+ await expect ( transport . send ( testMessage ) ) . rejects . toThrow (
54+ 'PostMessage failed' ,
55+ ) ;
5556 } ) ;
5657 } ) ;
5758
5859 describe ( 'Message Listening' , ( ) => {
5960 it ( 'should set up message listeners' , ( ) => {
6061 const mockCallback = jest . fn ( ) ;
6162 const disposable = transport . listen ( mockCallback ) ;
62-
63+
6364 expect ( mockWorker . addEventListener ) . toHaveBeenCalledWith (
6465 'message' ,
65- expect . any ( Function )
66+ expect . any ( Function ) ,
6667 ) ;
6768 expect ( disposable . dispose ) . toBeDefined ( ) ;
6869 } ) ;
6970
7071 it ( 'should handle incoming messages' , ( ) => {
7172 const mockCallback = jest . fn ( ) ;
7273 transport . listen ( mockCallback ) ;
73-
74+
7475 // Get the message handler
75- const messageHandler = mockWorker . addEventListener . mock . calls
76- . find ( ( [ event ] ) => event === 'message' ) ?. [ 1 ] ;
77-
76+ const messageHandler = mockWorker . addEventListener . mock . calls . find (
77+ ( [ event ] ) => event === 'message' ,
78+ ) ?. [ 1 ] ;
79+
7880 if ( messageHandler ) {
7981 const testMessage = { data : { jsonrpc : '2.0' , method : 'test' } } ;
8082 messageHandler ( testMessage ) ;
@@ -85,12 +87,12 @@ describe('MessageTransports', () => {
8587 it ( 'should clean up listeners when disposed' , ( ) => {
8688 const mockCallback = jest . fn ( ) ;
8789 const disposable = transport . listen ( mockCallback ) ;
88-
90+
8991 disposable . dispose ( ) ;
90-
92+
9193 expect ( mockWorker . removeEventListener ) . toHaveBeenCalledWith (
9294 'message' ,
93- expect . any ( Function )
95+ expect . any ( Function ) ,
9496 ) ;
9597 } ) ;
9698 } ) ;
@@ -99,21 +101,22 @@ describe('MessageTransports', () => {
99101 it ( 'should set up error listeners' , ( ) => {
100102 const mockCallback = jest . fn ( ) ;
101103 const disposable = transport . onError ( mockCallback ) ;
102-
104+
103105 expect ( mockWorker . addEventListener ) . toHaveBeenCalledWith (
104106 'error' ,
105- expect . any ( Function )
107+ expect . any ( Function ) ,
106108 ) ;
107109 expect ( disposable . dispose ) . toBeDefined ( ) ;
108110 } ) ;
109111
110112 it ( 'should handle worker errors' , ( ) => {
111113 const mockCallback = jest . fn ( ) ;
112114 transport . onError ( mockCallback ) ;
113-
114- const errorHandler = mockWorker . addEventListener . mock . calls
115- . find ( ( [ event ] ) => event === 'error' ) ?. [ 1 ] ;
116-
115+
116+ const errorHandler = mockWorker . addEventListener . mock . calls . find (
117+ ( [ event ] ) => event === 'error' ,
118+ ) ?. [ 1 ] ;
119+
117120 if ( errorHandler ) {
118121 const errorEvent = { message : 'Worker error' } ;
119122 errorHandler ( errorEvent ) ;
@@ -136,21 +139,21 @@ describe('MessageTransports', () => {
136139 it ( 'should send messages to self' , async ( ) => {
137140 const testMessage = { jsonrpc : '2.0' , method : 'test' } ;
138141 await transport . send ( testMessage ) ;
139-
142+
140143 expect ( mockSelf . postMessage ) . toHaveBeenCalledWith ( testMessage ) ;
141144 } ) ;
142145
143146 it ( 'should work with global self when no scope provided' , async ( ) => {
144147 // Mock global self
145148 const globalSelf = new MockWorkerScope ( ) ;
146149 ( global as any ) . self = globalSelf ;
147-
150+
148151 const globalTransport = new SelfMessageTransport ( ) ;
149152 const testMessage = { jsonrpc : '2.0' , method : 'test' } ;
150153 await globalTransport . send ( testMessage ) ;
151-
154+
152155 expect ( globalSelf . postMessage ) . toHaveBeenCalledWith ( testMessage ) ;
153-
156+
154157 // Cleanup
155158 delete ( global as any ) . self ;
156159 } ) ;
@@ -160,21 +163,22 @@ describe('MessageTransports', () => {
160163 it ( 'should set up message listeners on self' , ( ) => {
161164 const mockCallback = jest . fn ( ) ;
162165 const disposable = transport . listen ( mockCallback ) ;
163-
166+
164167 expect ( mockSelf . addEventListener ) . toHaveBeenCalledWith (
165168 'message' ,
166- expect . any ( Function )
169+ expect . any ( Function ) ,
167170 ) ;
168171 expect ( disposable . dispose ) . toBeDefined ( ) ;
169172 } ) ;
170173
171174 it ( 'should handle messages from main thread' , ( ) => {
172175 const mockCallback = jest . fn ( ) ;
173176 transport . listen ( mockCallback ) ;
174-
175- const messageHandler = mockSelf . addEventListener . mock . calls
176- . find ( ( [ event ] ) => event === 'message' ) ?. [ 1 ] ;
177-
177+
178+ const messageHandler = mockSelf . addEventListener . mock . calls . find (
179+ ( [ event ] ) => event === 'message' ,
180+ ) ?. [ 1 ] ;
181+
178182 if ( messageHandler ) {
179183 const testMessage = { data : { jsonrpc : '2.0' , method : 'test' } } ;
180184 messageHandler ( testMessage ) ;
@@ -183,5 +187,4 @@ describe('MessageTransports', () => {
183187 } ) ;
184188 } ) ;
185189 } ) ;
186-
187- } ) ;
190+ } ) ;
0 commit comments