robot0nfire/fl0w-old
robot0nfire/fl0w-old
Archived
1
0
Fork 0
Code Issues 5 Pull requests Projects Releases Packages Wiki Activity Actions

Added processes route

Browse source 
"processes" is a simple process list for debugging purposes and an ideal pipe demonstration
This commit is contained in:
Philip Trauner 2016-12-05 22:54:28 +01:00
parent cf57d760de
commit 4b1e70d2e5
1 changed files with 21 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

25
Sublime/fl0w/fl0w.py
View file

@ -17,7 +17,7 @@ from watchdog.events import FileSystemEventHandler
import sublime import sublime
import sublime_plugin import sublime_plugin
from Highway import Client, Route, DummyPipe from Highway import Client, Route, Pipe, DummyPipe
from SublimeMenu import * from SublimeMenu import *
import Logging import Logging
@ -65,10 +65,16 @@ class Fl0wClient(Client):
def run(self, data, handler): def run(self, data, handler):
controller_menu = Menu() controller_menu = Menu()
for id_ in data: for id_ in data:
action_menu = Menu(subtitles=False) action_menu = Menu()
action_menu += Entry("Set Name", action=lambda: Input("New Hostname:", action_menu += Entry("Set Name",
"Sets the hostname of the selected controller",
action=lambda: Input("New Hostname:",
initial_text=data[id_]["name"], on_done=self.set_hostname, initial_text=data[id_]["name"], on_done=self.set_hostname,
kwargs={"id_" : id_, "handler" : handler}).invoke(handler.fl0w.window)) kwargs={"id_" : id_, "handler" : handler}).invoke(handler.fl0w.window))
action_menu += Entry("Processes",
"Lists processes currently running on controller.",
action=lambda handler: handler.pipe(None, "processes", id_),
kwargs={"handler" : handler})
controller_menu += Entry(data[id_]["name"], id_, sub_menu=action_menu) controller_menu += Entry(data[id_]["name"], id_, sub_menu=action_menu)
controller_menu.invoke(handler.fl0w.window, back=handler.fl0w.main_menu) controller_menu.invoke(handler.fl0w.window, back=handler.fl0w.main_menu)
@ -77,6 +83,16 @@ class Fl0wClient(Client):
handler.pipe({"set" : hostname}, "hostname", id_) handler.pipe({"set" : hostname}, "hostname", id_)
class Processes(Pipe):
def run(self, data, peer, handler):
view = handler.fl0w.window.new_file()
view.set_name("Processes")
view.settings().set("draw_indent_guides", False)
for line in data:
view.run_command("append", {"characters": line + "\n"})
view.set_read_only(True)
class Fl0w: class Fl0w:
def __init__(self, window, debug=False): def __init__(self, window, debug=False):
self.connected = False self.connected = False
@ -158,7 +174,8 @@ class Fl0w:
def connect(self, connect_details): def connect(self, connect_details):
try: try:
self.ws = Fl0wClient('ws://%s' % connect_details) self.ws = Fl0wClient('ws://%s' % connect_details)
self.ws.setup({"info" : Fl0wClient.Info(), "peers" : Fl0wClient.Peers()}, self.ws.setup({"info" : Fl0wClient.Info(), "peers" : Fl0wClient.Peers(),
"processes" : Fl0wClient.Processes()},
self, debug=True) self, debug=True)
self.ws.connect() self.ws.connect()
sublime.set_timeout_async(self.ws.run_forever, 0) sublime.set_timeout_async(self.ws.run_forever, 0)