New script gribble.py: automatically authenticate to gribble for Bitcoin OTC exchange

python/gribble.py

+# gribble - automatically authenticate to gribble for bitcoin otc exchange
+# by Alex Fluter <afluter@gmail.com>
+# irc nick @fluter
+#
+# before load this script, set your gpg passphrase by
+#     /secure set gpg_passphrase xxxxxx
+
+import re
+import subprocess
+import urllib2
+import weechat
+
+NAME = "gribble"
+AUTHOR = "fluter <afluter@gmail.com>"
+VERSION = "0.1"
+LICENSE = "Apache"
+DESCRIPTION = "Script to talk to gribble"
+
+gribble_channel = "#bitcoin-fr"
+gribble_nick = "gribble"
+ident_nick = "fluter"
+options = {
+        # the channel name to watch to trigger this script
+        "channel": "#bitcoin-otc",
+        # the key of the secure data storing gpg passphrase
+        "pass_key": "gpg_passphrase"
+}
+gribble_buffer = None
+
+
+hook_msg = None
+
+def init():
+    global gribble_buffer
+    gribble_buffer = weechat.buffer_new(NAME, "", "", "", "")
+    weechat.prnt(gribble_buffer, "Options:")
+    for opt, val in options.iteritems():
+        if not weechat.config_is_set_plugin(opt):
+            weechat.config_set_plugin(opt, val)
+        else:
+            options[opt] = weechat.config_get_plugin(opt)
+        weechat.prnt(gribble_buffer, "    %s: %s" % (opt, options[opt]))
+
+def privmsg(server, to, msg):
+    buffer = weechat.info_get("irc_buffer", server)
+    weechat.command(buffer, "/msg %s %s" % (to, msg))
+
+def join_cb(data, signal, signal_data):
+    dict_in = {"message": signal_data}
+    dict_out = weechat.info_get_hashtable("irc_message_parse", dict_in)
+    channel = dict_out["channel"]
+    if channel != options["channel"]:
+        return weechat.WEECHAT_RC_OK
+
+    server = signal.split(",")[0]
+    nick = dict_out["nick"]
+    me = weechat.info_get("irc_nick", server)
+    if nick != me:
+        return weechat.WEECHAT_RC_OK
+
+    weechat.prnt(gribble_buffer, "Channel %s joined" % channel)
+    hook_msg = weechat.hook_signal("*,irc_in2_PRIVMSG", "privmsg_cb", "")
+    weechat.prnt(gribble_buffer, "Sent eauth to %s" % gribble_nick)
+    privmsg(server, gribble_nick, "eauth %s" % ident_nick)
+
+    return weechat.WEECHAT_RC_OK
+
+def privmsg_cb(data, signal, signal_data):
+    dict_in = {"message": signal_data}
+    dict_out = weechat.info_get_hashtable("irc_message_parse", dict_in)
+    if not weechat.info_get("irc_is_nick", dict_out["channel"]):
+        return weechat.WEECHAT_RC_OK
+
+    server = signal.split(",")[0]
+    nick = dict_out["channel"]
+    me = weechat.info_get("irc_nick", server)
+    if nick != me:
+        return weechat.WEECHAT_RC_OK
+
+    if dict_out["nick"] != gribble_nick:
+        return weechat.WEECHAT_RC_OK
+
+    msg = dict_out["text"]
+    m = re.match("^.*Get your encrypted OTP from (.*)$", msg)
+    if m is None:
+        return weechat.WEECHAT_RC_OK
+    weechat.prnt(gribble_buffer, "Got OTP")
+    otp_url = m.group(1)
+    otp = urllib2.urlopen(otp_url).read()
+    # the passphrase is stored encrypted in secure data
+    expr = "${sec.data.%s}" % options["pass_key"]
+    gpg_pass = weechat.string_eval_expression(expr, "", "", "")
+    if gpg_pass == "":
+        weechat.prnt(gribble_buffer, "no gpg pass found in secure data")
+        return weechat.WEECHAT_RC_OK
+
+    p = subprocess.Popen(["gpg", "--batch", "--decrypt", "--passphrase", gpg_pass],
+            stdin = subprocess.PIPE,
+            stdout = subprocess.PIPE,
+            stderr = subprocess.PIPE)
+    out, err = p.communicate(otp)
+    if err != "":
+        weechat.prnt(gribble_buffer, "gpg output: " + err)
+    if out != "":
+        privmsg(server, gribble_nick, "everify %s" % out)
+
+    return weechat.WEECHAT_RC_OK
+
+def main():
+    init()
+    hook_join = weechat.hook_signal("*,irc_in2_JOIN", "join_cb", "foo")
+
+weechat.register(NAME, AUTHOR, VERSION, LICENSE, DESCRIPTION, "", "")
+weechat.prnt("", "%s %s loaded" % (NAME, VERSION))
+main()