1 from plugins
.video
.video
import Video
, VideoDetails
15 import xml
.etree
.ElementTree
as ElementTree
18 CLASS_NAME
= 'WebVideo'
21 class WebVideo(Video
):
23 CONTENT_TYPE
= 'x-not-for/tivo'
26 self
.work_queue
= Queue
.Queue()
27 self
.download_thread_num
= 1
29 self
.in_progress_lock
= threading
.Lock()
33 self
.startWorkerThreads()
37 xmpp_info
= m
.getXMPPLoginInfo()
39 jid
=xmpp
.protocol
.JID(xmpp_info
['username'] + '/pyTivo')
41 server
=xmpp_info
['server'],
42 port
=xmpp_info
['port'],
46 cl
.RegisterHandler('message', self
.processMessage
)
47 cl
.auth(user
=jid
.getNode(), password
=config
.getTivoPassword(), resource
='pyTivo')
49 cl
.sendInitPresence(requestRoster
=0)
51 for user_name
in xmpp_info
['presence_list']:
52 jid
=xmpp
.protocol
.JID(user_name
)
55 t
= threading
.Thread(target
=self
.processXMPP
, args
=(cl
,))
59 def startWorkerThreads(self
):
60 for i
in range(self
.download_thread_num
):
61 t
= threading
.Thread(target
=self
.processDlRequest
)
65 def processXMPP(self
, client
):
66 while client
.Process():
69 def processMessage(self
, sess
,mess
):
70 xmpp_action
= ElementTree
.fromstring(mess
.getBody())
72 method_name
= 'xmpp_' + xmpp_action
.findtext('action').lower()
73 if not hasattr(self
, method_name
):
76 method
= getattr(self
, method_name
)
79 def xmpp_cdsupdate(self
, xml
=None):
82 self
.in_progress_lock
.acquire()
84 for request
in m
.getDownloadRequests():
85 if not request
['bodyOfferId'] in self
.in_progress
:
86 self
.in_progress
[request
['bodyOfferId']] = True
87 self
.work_queue
.put(request
)
89 self
.in_progress_lock
.release()
91 def processDlRequest(self
):
94 data
= self
.work_queue
.get()
96 for share_name
, settings
in config
.getShares():
97 if settings
['type'] == 'webvideo':
101 path
= settings
['path']
102 file_name
= os
.path
.join(path
, '%s-%s' % (data
['bodyOfferId'] ,data
['url'].split('/')[-1]))
104 self
.downloadFile(data
['url'], file_name
)
107 file_info
= VideoDetails()
108 file_info
.update(self
.metadata_full(file_name
, tsn
))
111 s
= socket
.socket(socket
.AF_INET
, socket
.SOCK_DGRAM
)
112 s
.connect(('tivo.com',123))
113 ip
= s
.getsockname()[0]
114 port
= config
.getPort()
116 data
['url'] = 'http://%s:%s' % (ip
, port
) + urllib
.quote('/%s/%s' % (share_name
, os
.path
.split(file_name
)[-1]))
117 data
['duration'] = file_info
['duration'] / 1000
118 data
['size'] = file_info
['size']
123 m
.completeDownloadRequest(data
)
125 self
.in_progress_lock
.acquire()
127 del self
.in_progress
[data
['bodyOfferId']]
129 self
.in_progress_lock
.release()
132 def downloadFile(self
, url
, file_path
):
133 print 'downloading %s to %s' % (url
, file_path
)
135 outfile
= open(file_path
, 'awb')
136 size
= os
.path
.getsize(file_path
)
137 r
= urllib2
.Request(url
)
139 r
.add_header('Range', 'bytes=%s-' % size
)
140 infile
= urllib2
.urlopen(r
)
141 shutil
.copyfileobj(infile
, outfile
, 8192)
143 print 'done downloading %s to %s' % (url
, file_path
)
145 def send_file(self
, handler
, container
, name
):
146 Video
.send_file(self
, handler
, container
, name
)
148 o
= urlparse
.urlparse("http://fake.host" + handler
.path
)
149 path
= urllib
.unquote(o
[2])
150 file_path
= container
['path'] + path
[len(name
) + 1:]
151 if os
.path
.exists(file_path
):