server.py

import os
import time
import argparse
import tempfile
import subprocess
try:
    from BaseHTTPServer import HTTPServer, BaseHTTPRequestHandler
except:
    from http.server import HTTPServer, BaseHTTPRequestHandler


class HTTPRequestHandler(BaseHTTPRequestHandler):

    def _writeheaders(self):
        self.send_response(200)
        self.send_header('Connection', 'keep-alive')
        self.send_header('Content-Type', 'text/event-stream')
        self.end_headers()

    # GET Method
    def do_GET(self):
        if self.path == '/':
            # prepend the filename with current filepath
            path = os.getcwd() + '/index.html'
            with open(path) as indexHtml:
                self.send_response(200)
                self.send_header('Content-Type', 'text/html')
                self.end_headers()
                self.wfile.write(indexHtml.read().encode())
        else:
            self._writeheaders()
            while True:
                f = tempfile.TemporaryFile()
                p = subprocess.Popen(['top', '-n', '1'], stdout=f)
                time.sleep(2)
                p.terminate()
                p.wait()
                f.seek(0)
                chunk = f.read()
                # test started
                try:
                    from urllib import quote
                except:
                    from urllib.parse import quote
                f.close()
                string = 'id: 1\ndata: {}\ndata:\n\n'.format(quote(chunk))
                self.wfile.write(bytes(string.encode()))

if __name__ == "__main__":
    parser = argparse.ArgumentParser()
    parser.add_argument(
        '-b',
        '--bind',
        help="The host/address to bind to",
        default="127.0.0.1"
    )
    parser.add_argument(
        '-p',
        '--port',
        type=int,
        help="Port number to listen on",
        default=8000
    )
    args = parser.parse_args()
    port = args.port

    httpd = HTTPServer(('', port), HTTPRequestHandler)
    print("Listening at port", port)
    try:
        httpd.serve_forever()
    except KeyboardInterrupt:
        httpd.server_close()
        print("Server stopped")