Spaces:

nxdev-org
/

fastapi-sse

Sleeping

nxdev-org commited on Feb 12

Commit

ef83458

1 Parent(s): 8bb14a4

update

Files changed (3) hide show

index.html CHANGED Viewed

@@ -2,6 +2,7 @@
 <html>
 <head>
   <title>Minimalistic SSE Frontend</title>
   <style>
     body {
       font-family: Arial, sans-serif;
@@ -45,6 +46,7 @@
         <th>Event ID</th>
         <th>Message</th>
         <th>Date & Time</th>
       </tr>
     </thead>
     <tbody id="data-list"></tbody>
@@ -56,7 +58,10 @@
     eventSource.addEventListener('new_message', event => {
       const { message, datetime } = JSON.parse(event.data);
       const row = document.createElement('tr');
-      row.innerHTML = `<td>${event.lastEventId}</td><td>${message}</td><td>${datetime}</td>`;
       dataList.appendChild(row);
     });
   </script>

 <html>
 <head>
   <title>Minimalistic SSE Frontend</title>
+  <meta> </meta>
   <style>
     body {
       font-family: Arial, sans-serif;
         <th>Event ID</th>
         <th>Message</th>
         <th>Date & Time</th>
+        <th>Delay(ms)</th>
       </tr>
     </thead>
     <tbody id="data-list"></tbody>
     eventSource.addEventListener('new_message', event => {
       const { message, datetime } = JSON.parse(event.data);
       const row = document.createElement('tr');
+      const tr = new Date(datetime);
+      const tn = new Date(Date.now());
+      const delay = (tn - tr);
+      row.innerHTML = `<td>${event.lastEventId}</td><td>${message}</td><td>${datetime}</td><td>${delay}</td>`;
       dataList.appendChild(row);
     });
   </script>

main.py CHANGED Viewed

@@ -28,12 +28,10 @@ def get_new_messages() -> Iterable:
             "data": json.dumps(
                 {
                     "message": "test message",
-                    "datetime": datetime.datetime.now().isoformat(
-                        sep="T", timespec="auto"
-                    ),
                 }
             ),
-            "id": uuid.uuid4(),
         }
     ]

             "data": json.dumps(
                 {
                     "message": "test message",
+                    "datetime": datetime.datetime.now(datetime.timezone.utc).isoformat(),
                 }
             ),
+            "id": str(uuid.uuid4()),
         }
     ]

requirements.txt ADDED Viewed

+fastapi
+uvicorn
+uvloop
+websockets
+sse-starlette