def _not_implemented(self):

raise NotImplementedError, "your OS is not supported"

def get_environment(self, pid):

return self._not_implemented()

def get_exe_fname(self, pid):

return self._not_implemented()

def getppid(self, pid = None):

return self._not_implemented()

def listpids(self):

return self._not_implemented()

def get_parents(self, pid = None):

if pid is None:

pid = os.getpid()

l = [pid]

while pid != 1:

pid = self.getppid(pid)

if pid == 0: # `[kthreadd]` and `init` have ppid == 0 at linux

break

l.append(pid)

def get_environment(self, pid):

return dict((line.split('=', 1) for line in open('/proc/%i/environ' % pid).read().split('\x00') if line))

def get_exe_fname(self, pid):

try:

argv0 = os.readlink('/proc/%i/exe' % pid)

except OSError, e:

if e.errno == errno.EACCES:

argv0 = open('/proc/%i/cmdline' % pid).read().split('\x00', 1)[0]

else:

raise

return os.path.split(argv0)[1]

def getppid(self, pid):

for line in open('/proc/%i/status' % pid):

match = re.match(r'PPid:\s+(\d+)', line)

if match:

return int(match.group(1))

raise Exception, "No parent pid"

def listpids(self):

def is_int(s):

try:

int(s)

return True

except:

return False

for pid in (int(s) for s in ifilter(is_int, os.listdir('/proc'))):

X = []

for pid in weeos.listpids():

if weeos.get_exe_fname(pid) == 'X':

X.append(pid)

# I rely on the fact, that "X" is seldom child of "X"

# So X produces one and only one session, session starter

# is usually child or sister of "X", so I'm looking for

# dbus variables there

init_children = set()

for pid in X:

init_children.add(weeos.get_parents(pid)[-2])

for pid in weeos.listpids():

try:

if weeos.get_parents(pid)[-2] in init_children:

renv = weeos.get_environment(pid)

# notification-daemon has DBUS_STARTER_ADDRESS

# variable that may be passed as DBUS_SESSION_BUS_ADDRESS

# But sometimes notification-daemon is not running,

# that's why the ugly hack is used

return {

'DBUS_SESSION_BUS_ADDRESS': renv['DBUS_SESSION_BUS_ADDRESS'],

'DISPLAY': renv['DISPLAY'],

}

except:

continue

try:

new_env = get_env_ext()

weechat.prnt("Dbus daemon found, environment: %s" % str(new_env), '', '')

except NoNotificationDaemonError:

new_env = {}

weechat.prnt("No dbus daemon found...", '', '')

except NotImplementedError, e:

new_env = {}

weechat.prnt('Dynamic DBUS_SESSION_BUS_ADDRESS detection is not supported on your OS: %s' % str(e), '', '')

global env_ext

updated = (env_ext != new_env)

env_ext = new_env

# FIXME: possible bug if notify-send loops

args = ['notify-send']

delay = int(weechat.get_plugin_config('time')) * 1000

if delay:

args.extend(['-t', str(delay)])

icon = weechat.get_plugin_config('icon')

if icon and os.path.exists(icon):

args.extend(['-i', icon])

args.extend([saxutils.escape(s) for s in ('--', u'%s wrote to %s' % (nick, chan), message)])

args = [s.encode(local_charset) for s in args]

null = open(os.devnull)

newenv = dict(chain(os.environ.iteritems(), env_ext.iteritems()))

p = Popen(args, env = newenv, stdout = null, stderr = null)

if p.wait() != 0 and update_env_ext():

# failed to use old environment, but environment changed

newenv = dict(chain(os.environ.iteritems(), env_ext.iteritems()))

p = Popen(args, env = newenv, stdout = null, stderr = null)

if p.wait() != 0:

# :nick!ident@host PRIVMSG dest :foobarbaz

l = command.split(' ', 3)

mask = l[0][1:]

nick = mask.split("!")[0]

dest = l[2]

message = l[3][1:]

###########################################

#nothing, info, message = command.split(":", 2)

#info = info.split(' ')

if dest == weechat.get_info('nick', server):

buffer = nick

else:

buffer = dest

# look at src/plugins/irc/irc-color.c to get proper color parser

# modifiers = ( # one-byte modifiers

# ur'\x02', # IRC_COLOR_BOLD_CHAR

# ur'\x03', # IRC_COLOR_COLOR_CHAR, color defenition follows

# ur'\x0F', # IRC_COLOR_RESET_CHAR

# ur'\x11', # IRC_COLOR_FIXED_CHAR

# ur'\x12', # IRC_COLOR_REVERSE_CHAR

# ur'\x16', # IRC_COLOR_REVERSE2_CHAR

# ur'\x1d', # IRC_COLOR_ITALIC_CHAR

# ur'\x1f') # IRC_COLOR_UNDERLINE_CHAR

# hope, python regexps are character-aware, not byte-aware

nick, buffer, message = [unicode(s, local_charset) for s in parse_privmsg(server, args)]

global last_message

if message != last_message:

last_message = message

match = re.match(ur'\x01ACTION (.*)\x01', message)

if match:

message = u'/me ' + match.group(1)

message = strip_irc_colors(message)

if nick == buffer:

buffer = u'me'

run_notify(nick, buffer, message)

global weeos, local_charset

default = {

"time": "3",

"icon": "/usr/share/pixmaps/gnome-irc.png"

}

if weechat.register("weenotify", "0.6", "", "notify-send on highlight/private msg"):

for k, v in default.items():

if not weechat.get_plugin_config(k):

weechat.set_plugin_config(k, v)

local_charset = getlocale()[1]

if os.uname()[0] == 'Linux':

weeos = LinuxSupport()

else:

weeos = OsSupport()

update_env_ext()

weechat.add_message_handler("weechat_highlight", "on_msg")