"""
Copyright (c) 2012 Fredrik Ehnbom
This software is provided 'as-is', without any express or implied
warranty. In no event will the authors be held liable for any damages
arising from the use of this software.
Permission is granted to anyone to use this software for any purpose,
including commercial applications, and to alter it and redistribute it
freely, subject to the following restrictions:
1. The origin of this software must not be misrepresented; you must not
claim that you wrote the original software. If you use this software
in a product, an acknowledgment in the product documentation would be
appreciated but is not required.
2. Altered source versions must be plainly marked as such, and must not be
misrepresented as being the original software.
3. This notice may not be removed or altered from any source
distribution.
"""
import sublime
import sublime_plugin
import subprocess
import Queue
import re
import threading
import traceback
def get_settings():
return sublime.load_settings("ADBView.sublime-settings")
def get_setting(key, default=None):
try:
s = sublime.active_window().active_view().settings()
if s.has(key):
return s.get(key)
except:
pass
return get_settings().get(key, default)
class ADBView(object):
LINE = 0
FOLD_ALL = 1
CLEAR = 2
SCROLL = 3
VIEWPORT_POSITION = 4
def __init__(self):
self.queue = Queue.Queue()
self.name = "ADB"
self.closed = True
self.view = None
self.last_fold = None
def is_open(self):
return not self.closed
def open(self):
if self.view == None or self.view.window() == None:
self.create_view()
self.maxlines = get_setting("adb_maxlines", 20000)
self.filter = re.compile(get_setting("adb_filter", "."))
self.doScroll = get_setting("adb_auto_scroll", True)
def add_line(self, line):
if self.is_open():
self.queue.put((ADBView.LINE, line))
sublime.set_timeout(self.update, 0)
def scroll(self, line):
if self.is_open():
self.queue.put((ADBView.SCROLL, line))
sublime.set_timeout(self.update, 0)
def set_viewport_position(self, pos):
if self.is_open():
self.queue.put((ADBView.VIEWPORT_POSITION, pos))
sublime.set_timeout(self.update, 0)
def clear(self):
if self.is_open():
self.queue.put((ADBView.CLEAR, None))
sublime.set_timeout(self.update, 0)
def set_filter(self, filter):
try:
self.filter = re.compile(filter)
self.apply_filter(sublime.active_window().active_view())
except:
sublime.error_message("invalid regex")
def apply_filter(self, view):
if is_adb_syntax(view):
view.run_command("unfold_all")
endline, endcol = view.rowcol(view.size())
line = 0
currRegion = None
regions = []
while line < endline:
region = view.full_line(view.text_point(line, 0))
data = view.substr(region)
if self.filter.search(data) == None:
if currRegion == None:
currRegion = region
else:
currRegion = currRegion.cover(region)
else:
if currRegion:
regions.append(currRegion)
currRegion = None
line += 1
if currRegion:
regions.append(currRegion)
view.fold(regions)
def create_view(self):
self.view = sublime.active_window().new_file()
self.view.set_name(self.name)
self.view.set_scratch(True)
self.view.set_read_only(True)
self.view.set_syntax_file("Packages/ADBView/adb.tmLanguage")
self.closed = False
def is_closed(self):
return self.closed
def was_closed(self):
self.closed = True
def fold_all(self):
if self.is_open():
self.queue.put((ADBView.FOLD_ALL, None))
def get_view(self):
return self.view
def update(self):
if not self.is_open():
return
try:
while True:
cmd, data = self.queue.get_nowait()
if cmd == ADBView.LINE:
self.view.set_read_only(False)
e = self.view.begin_edit()
row, col = self.view.rowcol(self.view.size())
if row+1 > self.maxlines:
self.view.erase(e, self.view.full_line(0))
self.view.insert(e, self.view.size(), data)
self.view.end_edit(e)
self.view.set_read_only(True)
if self.filter.search(data) == None:
region = self.view.line(self.view.size()-1)
if self.last_fold != None:
self.view.unfold(self.last_fold)
self.last_fold = self.last_fold.cover(region)
else:
self.last_fold = region
self.view.fold(self.last_fold)
else:
self.last_fold = None
elif cmd == ADBView.FOLD_ALL:
self.view.run_command("fold_all")
elif cmd == ADBView.CLEAR:
self.view.set_read_only(False)
e = self.view.begin_edit()
self.view.erase(e, sublime.Region(0, self.view.size()))
self.view.end_edit(e)
self.view.set_read_only(True)
elif cmd == ADBView.SCROLL:
self.view.run_command("goto_line", {"line": data + 1})
elif cmd == ADBView.VIEWPORT_POSITION:
self.view.set_viewport_position(data, True)
self.queue.task_done()
except Queue.Empty:
# get_nowait throws an exception when there's nothing..
pass
except:
traceback.print_exc()
finally:
if self.doScroll:
self.view.show(self.view.size())
adb_view = ADBView()
adb_process = None
def output(pipe):
while True:
try:
if adb_process.poll() != None:
break
line = pipe.readline().strip()
if len(line) > 0:
adb_view.add_line("%s\n" % line)
except:
traceback.print_exc()
def is_adb_syntax(view):
sn = view.scope_name(view.sel()[0].a)
return sn.startswith("source.adb")
class AdbFilterByProcessId(sublime_plugin.TextCommand):
def run(self, edit):
data = self.view.substr(self.view.full_line(self.view.sel()[0].a))
match = re.match(r"[\-\d\s:.]*./.+\( *(\d+)\)", data)
if match != None:
adb_view.set_filter("\( *%s\)" % match.group(1))
else:
sublime.error_message("Couldn't extract process id")
def is_enabled(self):
return is_adb_syntax(self.view) or (adb_view.is_open() and adb_view.get_view().id() == self.view.id())
def is_visible(self):
return self.is_enabled()
class AdbFilterByProcessName(sublime_plugin.TextCommand):
def run(self, edit):
data = self.view.substr(self.view.full_line(self.view.sel()[0].a))
match = re.match(r"[\-\d\s:.]*./(.+)\( *\d+\)", data)
if match != None:
adb_view.set_filter("%s\( *\d+\)" % match.group(1))
else:
sublime.error_message("Couldn't extract process name")
def is_enabled(self):
return is_adb_syntax(self.view) or (adb_view.is_open() and adb_view.get_view().id() == self.view.id())
def is_visible(self):
return self.is_enabled()
class AdbFilterByMessageLevel(sublime_plugin.Text