Initial commit.
This commit is contained in:
commit
378cafc8fe
2 changed files with 113 additions and 0 deletions
3
README.md
Normal file
3
README.md
Normal file
|
@ -0,0 +1,3 @@
|
|||
#Tox-Sync
|
||||
|
||||
A bot that sync messages between Freenode IRC #tox-dev and Tox group chat.
|
110
tox-sync.py
Normal file
110
tox-sync.py
Normal file
|
@ -0,0 +1,110 @@
|
|||
import sys
|
||||
import socket
|
||||
import string
|
||||
import select
|
||||
import re
|
||||
|
||||
from tox import Tox
|
||||
|
||||
from time import sleep
|
||||
from os.path import exists
|
||||
|
||||
SERVER = ["192.81.133.111", 33445, "8CD5A9BF0A6CE358BA36F7A653F99FA6B258FF756E490F52C1F98CC420F78858"]
|
||||
GROUP_BOT = '56A1ADE4B65B86BCD51CC73E2CD4E542179F47959FE3E0E21B4B0ACDADE5185520B3E6FC5D64'
|
||||
|
||||
IRC_HOST = "irc.freenode.net"
|
||||
IRC_PORT = 6667
|
||||
NAME = NICK = IDENT = REALNAME = "SyncBot"
|
||||
|
||||
CHANNEL = '#tox-dev'
|
||||
|
||||
class SyncBot(Tox):
|
||||
def __init__(self):
|
||||
if exists('data'):
|
||||
self.load_from_file('data')
|
||||
|
||||
self.connect()
|
||||
self.set_name("SyncBot")
|
||||
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...')
|
||||
self.bootstrap_from_address(SERVER[0], 0, SERVER[1], SERVER[2])
|
||||
|
||||
def loop(self):
|
||||
checked = False
|
||||
self.joined = False
|
||||
|
||||
count = 0
|
||||
try:
|
||||
while True:
|
||||
status = self.isconnected()
|
||||
if not checked and status:
|
||||
print('Connected to DHT.')
|
||||
checked = True
|
||||
try:
|
||||
self.add_friend(GROUP_BOT, "")
|
||||
except: pass
|
||||
|
||||
if checked and not status:
|
||||
print('Disconnected from DHT.')
|
||||
self.connect()
|
||||
checked = False
|
||||
|
||||
if not self.joined:
|
||||
tid = self.get_friend_id(GROUP_BOT)
|
||||
try:
|
||||
self.send_message(tid, 'invite')
|
||||
except: pass
|
||||
|
||||
readable, _, _ = select.select([self.irc], [], [], 0.02)
|
||||
|
||||
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:
|
||||
msg = '%s> %s' % rx.groups()
|
||||
print 'IRC> %s' % msg
|
||||
self.sent = msg
|
||||
|
||||
if self.tox_group_id != None:
|
||||
self.group_message_send(self.tox_group_id, msg)
|
||||
|
||||
self.do()
|
||||
except KeyboardInterrupt:
|
||||
self.save_to_file('data')
|
||||
|
||||
def on_friend_request(self, pk, message):
|
||||
print('Friend request from %s: %s' % (pk, message))
|
||||
self.add_friend_norequest(pk)
|
||||
print('Accepted.')
|
||||
|
||||
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))
|
||||
|
||||
t = SyncBot()
|
||||
t.loop()
|
Loading…
Reference in a new issue