tox_irc_sync/tox-irc-sync.py

159 lines
5.6 KiB
Python
Raw Normal View History

2013-12-01 15:09:54 +00:00
import sys
import socket
import string
import select
import re
from tox import Tox
from time import sleep
from os.path import exists
2013-12-09 04:49:23 +00:00
SERVER = ["54.215.145.71", 33445, "6EDDEE2188EF579303C0766B4796DCBA89C93058B6032FEA51593DCD42FB746C"]
2013-12-01 15:09:54 +00:00
GROUP_BOT = '56A1ADE4B65B86BCD51CC73E2CD4E542179F47959FE3E0E21B4B0ACDADE5185520B3E6FC5D64'
IRC_HOST = "irc.freenode.net"
IRC_PORT = 6667
NAME = NICK = IDENT = REALNAME = "SyncBot"
CHANNEL = '#tox-ontopic'
2013-12-01 15:09:54 +00:00
class SyncBot(Tox):
def __init__(self):
if exists('data'):
self.load_from_file('data')
self.connect()
self.set_name("SyncBot")
self.set_status_message("Send me a message with the word 'invite'")
2013-12-01 15:09:54 +00:00
print('ID: %s' % self.get_address())
self.readbuffer = ""
self.sent = None
self.tox_group_id = None
self.irc = socket.socket()
self.irc.connect((IRC_HOST, IRC_PORT))
self.irc.send("NICK %s\r\n" % NICK)
self.irc.send("USER %s %s bla :%s\r\n" % (IDENT, IRC_HOST, REALNAME))
self.irc.send("JOIN %s\r\n" % CHANNEL)
def connect(self):
print('connecting...')
2013-12-11 15:55:40 +00:00
self.bootstrap_from_address(SERVER[0], 1, SERVER[1], SERVER[2])
def ensure_exe(self, func, args):
count = 0
2013-12-11 16:02:01 +00:00
THRESHOLD = 50
2013-12-11 15:55:40 +00:00
while True:
try:
return func(*args)
except:
assert count < THRESHOLD
count += 1
for i in range(10):
self.do()
sleep(0.02)
2013-12-01 15:09:54 +00:00
def loop(self):
checked = False
self.joined = False
2013-12-11 16:02:01 +00:00
self.request = False
2013-12-01 15:09:54 +00:00
try:
while True:
status = self.isconnected()
if not checked and status:
print('Connected to DHT.')
checked = True
2013-12-11 16:02:01 +00:00
try:
self.bid = self.get_friend_id(GROUP_BOT)
except:
self.ensure_exe(self.add_friend, (GROUP_BOT, "Hi"))
self.bid = self.get_friend_id(GROUP_BOT)
2013-12-01 15:09:54 +00:00
if checked and not status:
print('Disconnected from DHT.')
self.connect()
checked = False
2013-12-09 04:25:08 +00:00
readable, _, _ = select.select([self.irc], [], [], 0.01)
2013-12-01 15:09:54 +00:00
if readable:
self.readbuffer += self.irc.recv(4096)
lines = self.readbuffer.split('\n')
self.readbuffer = lines.pop()
for line in lines:
rx = re.match(r':(.*?)!.*? PRIVMSG %s :(.*?)\r' %
CHANNEL, line, re.S)
if rx:
print('IRC> %s: %s' % rx.groups())
2013-12-01 15:09:54 +00:00
msg = '%s> %s' % rx.groups()
2013-12-22 16:33:15 +00:00
content = rx.group(2)
2014-01-02 19:41:35 +00:00
if content == '^syncbot' or \
content == '^echobot':
self.irc.send('PRIVMSG %s :%s\r\n' %
(CHANNEL, self.get_address()))
2013-12-22 16:33:15 +00:00
elif content[1:].startswith('ACTION '):
action = '%s> %s' % (rx.group(1),
rx.group(2)[8:-1])
self.sent = action
self.ensure_exe(self.group_action_send,
(self.tox_group_id, action))
2013-12-11 15:55:40 +00:00
elif self.tox_group_id != None:
2013-12-11 16:32:53 +00:00
self.sent = msg
2013-12-11 15:55:40 +00:00
self.ensure_exe(self.group_message_send,
(self.tox_group_id, msg))
2013-12-01 15:09:54 +00:00
2013-12-01 15:24:33 +00:00
l = line.rstrip().split()
if l[0] == "PING":
self.irc.send("PONG %s\r\n" % l[1])
2013-12-01 15:09:54 +00:00
self.do()
except KeyboardInterrupt:
self.save_to_file('data')
2013-12-11 15:55:40 +00:00
def on_connection_status(self, friendId, status):
2013-12-11 16:02:01 +00:00
if not self.request and not self.joined \
and friendId == self.bid and status:
2013-12-11 15:55:40 +00:00
print('Groupbot online, trying to join group chat.')
2013-12-11 16:02:01 +00:00
self.request = True
self.ensure_exe(self.send_message, (self.bid, 'invite'))
2013-12-01 15:09:54 +00:00
def on_group_invite(self, friendid, pk):
if not self.joined:
self.joined = True
self.tox_group_id = self.join_groupchat(friendid, pk)
print('Joined groupchat.')
def on_group_message(self, groupnumber, friendgroupnumber, message):
if message != self.sent:
name = self.group_peername(groupnumber, friendgroupnumber)
print('TOX> %s: %s' % (name, message))
self.irc.send('PRIVMSG %s :%s> %s\r\n' % (CHANNEL, name, message))
2013-12-22 16:33:15 +00:00
def on_group_action(self, groupnumber, friendgroupnumber, action):
if action != self.sent:
name = self.group_peername(groupnumber, friendgroupnumber)
print('TOX> %s: %s' % (name, action))
self.irc.send('PRIVMSG %s :\x01ACTION %s> %s\x01\r\n' %
(CHANNEL, name, action))
def on_friend_request(self, pk, message):
print('Friend request from %s: %s' % (pk, message))
self.add_friend_norequest(pk)
print('Accepted.')
def on_friend_message(self, friendid, message):
if message == 'invite':
2013-12-11 15:54:18 +00:00
print('Inviting %s' % self.get_name(friendid))
self.invite_friend(friendid, self.tox_group_id)
2014-01-02 19:41:35 +00:00
else:
self.ensure_exe(self.send_message, (friendid, message))
2013-12-01 15:09:54 +00:00
t = SyncBot()
t.loop()