emdee/tox_irc_sync
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Add video echoing.

Browse source
This commit is contained in:
AZ Huang 2014-04-10 04:48:24 +08:00
parent 7040b1a49b
commit b369a4d3c9
1 changed files with 53 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

68
tox-irc-sync.py
View file

@ -27,37 +27,75 @@ class AV(ToxAV):
self.core = self.get_tox() self.core = self.get_tox()
self.daemon = True self.daemon = True
self.stop = True self.stop = True
self.call_type = self.TypeAudio
def on_invite(self): def on_invite(self):
print 'Incoming call from %s ...' % self.core.get_name( self.call_type = self.get_peer_transmission_type(0)
self.get_peer_id(0)) print("Incoming %s call from %s ..." % (
self.answer(self.TypeAudio) "video" if self.call_type == self.TypeVideo else "audio",
self.core.get_name(self.get_peer_id(0))))
self.answer(self.call_type)
print("Answered, in call...")
def on_start(self): def on_start(self):
self.prepare_transmission(False) self.call_type = self.get_peer_transmission_type(0)
self.prepare_transmission(True)
self.stop = False self.stop = False
self.thread = Thread(target=self.transmission) self.a_thread = Thread(target=self.audio_transmission)
self.thread.daemon = True self.a_thread.daemon = True
self.thread.start() self.a_thread.start()
if self.call_type == self.TypeVideo:
self.v_thread = Thread(target=self.video_transmission)
self.v_thread.daemon = True
self.v_thread.start()
def on_end(self): def on_end(self):
self.stop = True self.stop = True
self.kill_transmission() self.kill_transmission()
self.thread.join() self.a_thread.join()
if self.call_type == self.TypeVideo:
self.v_thread.join()
print 'Call ended' print 'Call ended'
def on_peer_timeout(self): def on_peer_timeout(self):
self.stop_call() self.stop_call()
def transmission(self): def audio_transmission(self):
print "Starting transmission..." print("Starting audio transmission...")
while not self.stop: while not self.stop:
ret = self.recv_audio() try:
if ret: ret = self.recv_audio()
sys.stdout.write('.') if ret:
sys.stdout.flush() sys.stdout.write('.')
self.send_audio(ret["size"], ret["data"]) sys.stdout.flush()
self.send_audio(ret["size"], ret["data"])
except Exception as e:
print(e)
sleep(0.001)
def video_transmission(self):
print("Starting video transmission...")
r = g = b = 0
ar = ag = ab = 0
ar = 1
while not self.stop:
try:
vret = self.recv_video()
if vret:
sys.stdout.write('*')
sys.stdout.flush()
self.send_video(vret['data'])
except Exception as e:
print(e)
sleep(0.001) sleep(0.001)