many new stuff, some things already working

1 files changed, 182 insertions, 0 deletions

diff --git a/module/PluginThread.py b/module/PluginThread.py
new file mode 100644
index 000000000..75b643408
--- /dev/null
+++ b/module/PluginThread.py
@@ -0,0 +1,182 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+
+"""
+    This program is free software; you can redistribute it and/or modify
+    it under the terms of the GNU General Public License as published by
+    the Free Software Foundation; either version 3 of the License,
+    or (at your option) any later version.
+
+    This program is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+    See the GNU General Public License for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with this program; if not, see <http://www.gnu.org/licenses/>.
+
+    @author: RaNaN
+"""
+
+from threading import Thread
+from Queue import Queue
+
+from time import sleep
+from traceback import print_exc
+
+from pycurl import error
+from module.plugins.Plugin import Abort, Reconnect, Retry, Fail
+
+########################################################################
+class PluginThread(Thread):
+	"""abstract base class for thread types"""
+
+	#----------------------------------------------------------------------
+	def __init__(self, manager):
+		"""Constructor"""
+		Thread.__init__(self)
+		self.setDaemon(True)
+		self.m = manager
+		
+
+########################################################################
+class DownloadThread(PluginThread):
+	"""thread for downloading files from 'real' hoster plugins"""
+
+	#----------------------------------------------------------------------
+	def __init__(self, manager):
+		"""Constructor"""
+		PluginThread.__init__(self, manager)
+		
+		self.queue = Queue() # job queue
+		self.active = False
+		
+		self.start()
+		
+	#----------------------------------------------------------------------
+	def run(self):
+		"""run method"""
+		
+		while True:
+			self.active = self.queue.get()
+			pyfile = self.active
+			
+			if self.active == "quit":
+				return True
+			
+			print pyfile
+			
+			try:
+				pyfile.plugin.preprocessing(self)
+				
+			except NotImplementedError:
+				
+				self.m.log.error(_("Plugin %s is missing a function.") % pyfile.pluginname)
+				continue
+			
+			except Abort:
+				self.m.log.info(_("%s aborted") % pyfile.name)
+				pyfile.setStatus("aborted")
+				self.active = False
+				pyfile.release()
+				continue
+				
+			except Reconnect:
+				self.queue.put(pyfile)
+				pyfile.req.clearCookies()
+				
+				while self.m.reconnecting.isSet():
+					sleep(0.5)
+				
+				continue
+			
+			except Retry:
+				
+				self.m.log.info(_("restarting %s") % pyfile.name)
+				self.queue.put(pyfile)
+				continue
+			
+			except Fail,e :
+				
+				msg = e.args[0]
+				
+				if msg == "offline":
+					pyfile.setStatus("offline")
+					self.m.log.warning(_("%s is offline.") % pyfile.name)
+				else:
+					pyfile.setStatus("failed")
+					self.m.log.warning(_("%s failed with message: %s") % (pyfile.name, msg))
+					pyfile.error = msg
+					
+				continue
+						
+			except error, e:
+				code, msg = e
+				print "pycurl error", code, msg
+				continue
+			
+			except Exception,e :
+				pyfile.setStatus("failed")
+				self.m.log.error(_("%s failed with message: .") % (pyfile.name, str(e)))
+				
+				if self.m.core.debug:
+					print_exc()
+				
+				continue
+			
+			
+			finally:
+				print "saved"
+				self.m.core.files.save()
+			
+			print "finished successfully"
+			
+			#@TODO hooks, packagaefinished etc
+			
+			
+			self.active = False	
+			pyfile.finishIfDone()
+			
+	#----------------------------------------------------------------------
+	def put(self, job):
+		"""assing job to thread"""
+		self.queue.put(job)
+	
+	#----------------------------------------------------------------------
+	def stop(self):
+		"""stops the thread"""
+		self.put("quit")
+		
+		
+		
+########################################################################
+class DecrypterThread(PluginThread):
+	"""thread for decrypting"""
+
+	#----------------------------------------------------------------------
+	def __init__(self, pyfile):
+		"""constructor"""
+		Thread.__init__(self)
+		
+		self.pyfile = pyfile
+		
+		self.start()
+		
+	#----------------------------------------------------------------------
+	def run(self):
+		"""run method"""
+		self.pyfile
+		#@TODO: decrypt it
+		
+    
+########################################################################
+class HookThread(PluginThread):
+	"""thread for hooks"""
+
+	#----------------------------------------------------------------------
+	def __init__(self):
+		"""Constructor"""
+		
+		
+    
+	
\ No newline at end of file