Initial commit

Author: mudox

.gitignore

@@ -0,0 +1,107 @@
+
+# Created by https://www.gitignore.io/api/python
+
+### Python ###
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+
+# PyInstaller
+#  Usually these files are written by a python script from a template
+#  before PyInstaller builds the exe, so as to inject date/other infos into it.
+*.manifest
+*.spec
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*.cover
+.hypothesis/
+
+# Translations
+*.mo
+*.pot
+
+# Django stuff:
+*.log
+local_settings.py
+
+# Flask stuff:
+instance/
+.webassets-cache
+
+# Scrapy stuff:
+.scrapy
+
+# Sphinx documentation
+docs/_build/
+
+# PyBuilder
+target/
+
+# Jupyter Notebook
+.ipynb_checkpoints
+
+# pyenv
+.python-version
+
+# celery beat schedule file
+celerybeat-schedule
+
+# SageMath parsed files
+*.sage.py
+
+# Environments
+.env
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+
+# Spyder project settings
+.spyderproject
+.spyproject
+
+# Rope project settings
+.ropeproject
+
+# mkdocs documentation
+/site
+
+# mypy
+.mypy_cache/
+
+# End of https://www.gitignore.io/api/python

JacServer.tmux-session.sh

@@ -0,0 +1,45 @@
+#!/usr/bin/env bash
+# vim: fdm=marker
+
+CLIENT_WIDTH=213
+CLIENT_HEIGHT=57
+
+session_name='JacKit'
+if tmux has-session -t ${session_name} &>/dev/null; then
+  echo "session [${session_name}] already exisits, kill it!"
+  tmux kill-session -t "${session_name}"
+fi
+
+
+#
+# Editor
+#
+
+root="${HOME}/Develop/Python/jack-server/"
+window_name='Editor'
+window="${session_name}:${window_name}"
+tmux new-session       \
+  -s "${session_name}" \
+  -n "${window_name}"  \
+  -x "$CLIENT_WIDTH"   \
+  -y "$CLIENT_HEIGHT"  \
+  -c "${root}"         \
+  -d
+
+#
+# Log
+#
+
+root="${HOME}/Git/vim-config"
+window_name='Log'
+window="${session_name}:${window_name}"
+tmux new-window -a -d        \
+  -t "${session_name}:{end}" \
+  -n "${window_name}"        \
+  -c "${root}"
+sleep 1
+tmux send-keys -t "${window}" "
+vv vimrc
+"
+
+tmux select-window -t "${session_name}:Editor"

demo.py

@@ -0,0 +1,70 @@
+from BaseHTTPServer import BaseHTTPRequestHandler, HTTPServer
+from SocketServer import ThreadingMixIn
+import threading
+import argparse
+import re
+import cgi
+
+
+class LocalData(object):
+  records = {}
+
+
+class HTTPRequestHandler(BaseHTTPRequestHandler):
+
+  # POST /log/
+  #
+  # Log event in JSON format
+  def do_POST(self) >
+    if re.search('/log/', self.path) is not None:
+      length = int(self.headers.getheader('content-length'))
+      data = cgi.parse_qs(self.rfile.read(length), keep_blank_values=1)
+      recordID = self.path.split('/')[-1]
+      LocalData.records[recordID] = data
+
+    else:
+      self.send_response(403)
+      self.end_headers()
+
+
+class ThreadedHTTPServer(ThreadingMixIn, HTTPServer):
+  allow_reuse_address = True
+
+  def shutdown(self):
+    self.socket.close()
+    HTTPServer.shutdown(self)
+
+
+class SimpleHttpServer():
+
+  def __init__(self, ip, port):
+    self.server = ThreadedHTTPServer((ip, port), HTTPRequestHandler)
+
+  def start(self):
+    self.server_thread = threading.Thread(target=self.server.serve_forever)
+    self.server_thread.daemon = True
+    self.server_thread.start()
+
+  def waitForThread(self):
+    self.server_thread.join()
+
+  def addRecord(self, recordID, jsonEncodedRecord):
+    LocalData.records[recordID] = jsonEncodedRecord
+
+  def stop(self):
+    self.server.shutdown()
+    self.waitForThread()
+
+
+if __name__ == '__main__':
+  parser = argparse.ArgumentParser(description='HTTP Server')
+  parser.add_argument(
+      'port',
+      type=int,
+      help='Listening port for HTTP Server')
+  parser.add_argument('ip', help='HTTP Server IP')
+  args = parser.parse_args()
+
+  server = SimpleHttpServer(args.ip, args.port)
+  server.start()
+  server.waitForThread()

event.py

@@ -0,0 +1,49 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+from pathlib import Path
+from textwrap import indent
+
+from shared import Settings
+from shared import colorize
+
+LOG_ROOT = Path('~/Library/Logs/JacKit/').expanduser()
+LOG_ROOT.mkdir(exist_ok=True)
+
+
+class Event:
+
+  # Hold all opened file object for each senssionID
+  # Created on each `POST /session/`
+  # Where
+  #   - key: session ID
+  #   - value: opened file object
+  jsonFiles = {}
+  logFiles = {}
+
+  def __init__(self, jsonDict):
+    self.jsonDict = jsonDict
+
+  def sessionID(self):
+    return self.jsonDict['sessionID']
+
+  def timestamp(self):
+    return self.jsonDict['timestamp']
+
+  def subsystem(self):
+    return self.jsonDict['subsystem']
+
+  def level(self):
+    return self.jsonDict['level']
+
+  def message(self):
+    return self.jsonDict['message']
+
+  def logLine(self):
+    symbol = Settings.symbols[self.level()]
+    color1, color2 = Settings.colors[self.level()]
+
+    tagLine = colorize(f' {symbol}{self.subsystem()}', color1)
+    messageLines = indent(self.message(), '   ')
+    messageLines = colorize(messageLines, color2)
+    return '\n'.join([tagLine, messageLines])

jacserver.py

@@ -0,0 +1,106 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+
+import datetime
+import json
+import socket
+import time
+from http.server import BaseHTTPRequestHandler, HTTPServer
+from os import system
+
+from event import Event
+from shared import Settings, colorize
+
+PORT = 7086
+
+
+def start():
+  """Start the server
+  """
+  s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+  s.connect(("8.8.8.8", 80))
+  ip = s.getsockname()[0]
+
+  httpd = HTTPServer((ip, 7086), HTTPRequestHandler)
+  print('Start server listening at {}:7086 ...\n\n'.format(ip))
+  httpd.serve_forever()
+
+
+class HTTPRequestHandler(BaseHTTPRequestHandler):
+  """Handle the request sent to server"""
+
+  server_version = 'JackServer/0.1'
+  protocol_version = 'HTTP/1.1'  # enable persistent connection
+
+  time_interval = 3
+  last_timestamp = time.time()
+
+  def do_POST(self):
+    if self.path == '/session/':
+      self.newSession()
+    elif self.path == '/event/':
+      self.newEvent()
+    else:
+      self.send_error(
+          403,
+          'Invalid API path',
+          '''
+          Currently JackServeronly support:
+
+            - POST /session/ HTTP/1.1
+              Notify of a new Xcode project running session
+
+            - POST /event/   HTTP/1.1
+              Send a new event
+          '''
+      )
+      return
+
+  def newSession(self):
+    self.send_response(200)
+    self.send_header('Content-Length', 0)
+    self.end_headers()
+
+    system('clear')
+
+  def newEvent(self):
+    self.send_response(200)
+    self.send_header('Content-Length', 0)
+    self.end_headers()
+
+    size = int(self.headers['Content-Length'])
+    jsonDict = json.loads(self.rfile.read(size))
+    self.event = Event(jsonDict)
+
+    self.printTimeSeparatorIfNeeded()
+    print(self.event.logLine())
+
+  def printTimeSeparatorIfNeeded(self):
+    seconds = self.event.timestamp() - HTTPRequestHandler.last_timestamp
+
+    if seconds > HTTPRequestHandler.time_interval:
+      color1, color2 = Settings.colors['time_sep']
+
+      delta = datetime.timedelta(seconds=seconds)
+      prefix = colorize('\n -- ', color2)
+      deltaColored = colorize(delta, color1)
+      suffix = colorize(' elapsed ---\n', color2)
+      timeLine = f'{prefix}{deltaColored}{suffix}'
+
+      print(timeLine)
+
+    HTTPRequestHandler.last_timestamp = self.event.timestamp()
+
+
+try:
+  system('stty -echo; clear; tput civis')
+  start()
+except KeyboardInterrupt:
+  exit(0)
+except Exception as e:
+  exit(1)
+else:
+  exit(0)
+finally:
+  system('tput cnorm; stty echo')