# -*- coding: utf-8 -*-
# Proxy RTSP vers HTTP v0.0.4
# (c) Puyb, AlexSoloex 2006
# http://www.puyb.net
#
# Ce programme est distribué sous les termes la licence GPL v2 de la Free Software Fondation
# This software is distributed under the terms of the Free Software Fondation's GPL v2 licence
# Vous pouvez obtenir une copie de la licence a l'adresse :
# You can find a copy of the licence at :
# http://www.puyb.net/download/LICENCE-GPL2.txt
#
# changelog :
# v0.0.4 - Meilleur gestion du protocoles RTSP... Envois du paquet de réponse pour eviter les deconnexions
# Par AlexSolex
# v0.0.3 - reconnexion automatique du flux rtsp
# v0.0.2 - correction de la taille des paquets UDP lus
# - suppression de l'entÂte RTP de 12 octets avant envoi du paquet en HTTP
# v0.0.1 - version initiale
import socket
import sys
import thread
import time
_version="0.0.4"
_server_string="rtsp2http proxy %s" % _version
# une petire class de serveur qui me simplifie un petit peu le travail
class server_socket(socket.socket):
def __init__(self, arg):
if not type(arg)==tuple:
self.socket=arg
else:
self.socket=socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
self.socket.bind(arg)
self.socket.listen(1)
def accept(self):
s, addr=self.socket.accept()
return server_socket(s), addr
def readline(self):
"""receive and return a complete line"""
line=""
while 1:
char = self.recv(1)
if not char:
if line=="":
return False
return line
if char=="\n":
return line
if char!="\r":
line += char
def __getattr__(self, name):
return getattr(self.socket, name)
# une petite class de client.. la même que pour un serveur, sauf l'initialisation
class client_socket(server_socket):
def __init__(self, ip, port):
self.socket=socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.socket.connect((ip,port))
# une class qui essaye de comprendre les réponses au requettes RTSP
class basic_rtsp_socket(client_socket):
def __init__(self, ip, port):
client_socket.__init__(self, ip, port)
self.cseq=1
self.RTCP_port=None
def request(self, request):
#print "\n".join([">>> %s" % x for x in (request % self.cseq).split("\n")])
self.send(request % self.cseq)
self.cseq+=1
l=self.readline()
print "<<< %s" % l
(proto, code)=l.split(" ")[0:2]
if proto[0:4]!="RTSP": raise "Error: not a rtsp response", l
if code!="200": raise "Error: rtsp error", l
l=self.readline()
print "<<< %s" % l
header={}
while l!="" and l!=None:
l2=l.split(": ")
if len(l2)!=2: raise "Incorrect response", l
print " %s : %s"%(l2[0],l2[1])
header[l2[0]]=l2[1]
if l2[0]=="Transport":
prm_transport=l2[1].split(";")
for prms in prm_transport:
try:
print prms
key,val=prms.split("=")
if key=="server_port":
self.RTCP_port=int(val.split("-")[1])
break
except:
pass
l=self.readline()
print "<<< %s" % l
if l==None: raise "rtsp connection closed by foreign host", None
data=None
if "Content-length" in header.keys():
data=read(int(header["Content-length"]))
return (header, data)
def char2bits(txt):
bits = []
for char in txt:
if type(char) == str:char = ord(char)
#print char,
for i in range(8):
j = 2**(7-i)
bits.append(int(char - j >= 0))
char = char % j
print len(bits)
print bits
def bits2char(bits):
char = 0
for b in range(8):
if bits[7-b] == 1:
char += 2**b
return char
def httpthread(http_conn, addr):
data = http_conn.readline()
if not data: raise "no data on http line", None
# on prend la première ligne
(request, url, proto)=data.split(" ")[0:3]
if request!="GET":
print "ATTENTION : le player n'a pas envoyé de GET"
#raise "Error : not a get request", data
if proto[0:4]!="HTTP":
raise "Error : not a http request", data
# on attend la fin de la requette
# soit une ligne vide
# un peu barbare... mais je suis qur qu'il ren a dire d'interressant
l=http_conn.readline()
#print "<<< %s" %l
while l!="" and l!=None:
l=http_conn.readline()
#print "<<< %s" % l
# parle a ma main !!!
if l==None: raise "http connection closed", None
# on repond le header
reponse="""HTTP/1.0 200 OK
Content-type: application/octet-stream
Cache-Control: no-cache
"""
#print reponse
http_conn.send(reponse)
reconnect=True
####
####
while reconnect:
print "starting RTSP connection at %f" % time.clock()
# on établie la connexion rtsp
rtsp_session=basic_rtsp_socket("mafreebox.freebox.fr", 554)
#print "connected to the rtsp session"
# dump du dialogue RTSP entre VLC et la freebox...
## (header, data)=rtsp_session.request("""OPTIONS rtsp://mafreebox.freebox.fr/freeboxtv%s RTSP/1.0
##CSeq: %s
##User-Agent: %s
##
##""" % (url, "%d", _version))
#print "HEADER OPTIONS: \n%s"%header
#print "DATA OPTIONS: \n%s"%data
(header, data)=rtsp_session.request("""SETUP rtsp://212.27.38.253/freeboxtv%s RTSP/1.0
CSeq: %s
Transport: RTP/AVP;unicast;client_port=31330-31331
User-Agent: %s
""" % (url, "%d", _version))
#print "HEADER SETUP: \n%s"%header
#print "DATA SETUP: \n%s"%data
session=header["Session"]
# on se prépare a recevoir les connexion UDP
rtsp_data = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
rtsp_data.bind(("", 31330))
rtsp_data.settimeout(0.1)
#préparation du control de flux
rtsp_control = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
rtsp_control.bind(("",31331))
rtsp_control.connect(("mafreebox.freebox.fr",rtsp_session.RTCP_port))
# Go, go, go
(header, data)=rtsp_session.request("""PLAY rtsp://mafreebox.freebox.fr/freeboxtv%s RTSP/1.0
CSeq: %s
Session: %s
Range: npt="now"
User-Agent: %s
""" % (url, "%d", session, _version))
#print "HEADER PLAY: \n%s"%header
#print "DATA PLAY: \n%s"%header
# on repete tout au client http
# on met des datas en mémoire
ok=True
t=time.clock()
while ok:
if time.clock()-t>5:
sheader=""
for key in header.keys():
sheader+="%s: %s\n"%(key,header[key])
sheader+="\n"
rtsp_control.send(sheader)
t=time.clock()
# on lit 2k... Si le datagram est plus petit, on aura moins de données (FIXME : lire la MTU d'un paquet UDP)
try:
data, addr=rtsp_data.recvfrom(2048)
except:
ok=False
print "RTSP TimeOut : retrying"
if addr[0]==socket.gethostbyname("mafreebox.freebox.fr"):
try:
#m=data[:12]
#char2bits(m)
http_conn.sendall(data[12:])
# on envoi la paylaod... C'est a dire, le datgram moins les 12 octets d'entête
except:
ok=False # une execption... on arrete tout !
print "exception lors de l'envoi des données en http"
reconnect=False
# une des connexion a été coupée, on ferme toutes les connexions...
try:
print rtsp_session.request("""TEARDOWN rtsp://mafreebox.freebox.fr/freeboxtv%s RTSP/1.0
CSeq: %s
Session: %s
User-Agent: rtsp2http v0.0.1
""" % (url, "%d", session))
print "HEADER TEARDOWN: \n%s"%header
except:
print "Exception on TEARDOWN, skiping"
print "%s"%url
rtsp_session.close()
rtsp_control.close()
rtsp_data.close()
http_listen.close()
http_conn.close()
print "%s disconnected" % (addr, )
# Début du code
# on met en place un serveur http
http_listen=server_socket(("", 8083))
while True:
http_conn, addr = http_listen.accept()
print 'Connected by', addr
thread.start_new_thread(httpthread, (http_conn, addr))