1
- from datetime import datetime
1
+ from datetime import datetime , timezone
2
2
import functools
3
3
import os
4
4
import socket
@@ -204,7 +204,7 @@ def _trigger_event(self, event, namespace, *args):
204
204
serialized_socket = self .serialize_socket (sid , namespace , eio_sid )
205
205
self .sio .emit ('socket_connected' , (
206
206
serialized_socket ,
207
- datetime .utcfromtimestamp ( t ).isoformat () + 'Z' ,
207
+ datetime .fromtimestamp ( t , timezone . utc ).isoformat (),
208
208
), namespace = self .admin_namespace )
209
209
elif event == 'disconnect' :
210
210
del self .sio .manager ._timestamps [sid ]
@@ -213,14 +213,14 @@ def _trigger_event(self, event, namespace, *args):
213
213
namespace ,
214
214
sid ,
215
215
reason ,
216
- datetime .utcfromtimestamp ( t ).isoformat () + 'Z' ,
216
+ datetime .fromtimestamp ( t , timezone . utc ).isoformat (),
217
217
), namespace = self .admin_namespace )
218
218
else :
219
219
self .sio .emit ('event_received' , (
220
220
namespace ,
221
221
sid ,
222
222
(event , * args [1 :]),
223
- datetime .utcfromtimestamp ( t ).isoformat () + 'Z' ,
223
+ datetime .fromtimestamp ( t , timezone . utc ).isoformat (),
224
224
), namespace = self .admin_namespace )
225
225
return self .sio .__trigger_event (event , namespace , * args )
226
226
@@ -246,7 +246,7 @@ def _basic_enter_room(self, sid, namespace, room, eio_sid=None):
246
246
namespace ,
247
247
room ,
248
248
sid ,
249
- datetime .utcnow ( ).isoformat () + 'Z' ,
249
+ datetime .now ( timezone . utc ).isoformat (),
250
250
), namespace = self .admin_namespace )
251
251
return ret
252
252
@@ -256,7 +256,7 @@ def _basic_leave_room(self, sid, namespace, room):
256
256
namespace ,
257
257
room ,
258
258
sid ,
259
- datetime .utcnow ( ).isoformat () + 'Z' ,
259
+ datetime .now ( timezone . utc ).isoformat (),
260
260
), namespace = self .admin_namespace )
261
261
return self .sio .manager .__basic_leave_room (sid , namespace , room )
262
262
@@ -276,7 +276,7 @@ def _emit(self, event, data, namespace, room=None, skip_sid=None,
276
276
namespace ,
277
277
sid ,
278
278
event_data ,
279
- datetime .utcnow ( ).isoformat () + 'Z' ,
279
+ datetime .now ( timezone . utc ).isoformat (),
280
280
), namespace = self .admin_namespace )
281
281
return ret
282
282
@@ -335,7 +335,7 @@ def _eio_send_ping(socket, self): # pragma: no cover
335
335
eio_sid )
336
336
self .sio .emit ('socket_connected' , (
337
337
serialized_socket ,
338
- datetime .utcfromtimestamp ( t ).isoformat () + 'Z' ,
338
+ datetime .fromtimestamp ( t , timezone . utc ).isoformat (),
339
339
), namespace = self .admin_namespace )
340
340
return socket .__send_ping ()
341
341
@@ -384,7 +384,7 @@ def serialize_socket(self, sid, namespace, eio_sid=None):
384
384
'secure' : environ .get ('wsgi.url_scheme' , '' ) == 'https' ,
385
385
'url' : environ .get ('PATH_INFO' , '' ),
386
386
'issued' : tm * 1000 ,
387
- 'time' : datetime .utcfromtimestamp (tm ).isoformat () + 'Z'
387
+ 'time' : datetime .fromtimestamp (tm , timezone . utc ).isoformat ()
388
388
if tm else '' ,
389
389
},
390
390
'rooms' : self .sio .manager .get_rooms (sid , namespace ),
0 commit comments