summaryrefslogtreecommitdiffstats
path: root/module/plugins/hooks/HotFolder.py
diff options
context:
space:
mode:
Diffstat (limited to 'module/plugins/hooks/HotFolder.py')
-rw-r--r--module/plugins/hooks/HotFolder.py71
1 files changed, 0 insertions, 71 deletions
diff --git a/module/plugins/hooks/HotFolder.py b/module/plugins/hooks/HotFolder.py
deleted file mode 100644
index f771cf232..000000000
--- a/module/plugins/hooks/HotFolder.py
+++ /dev/null
@@ -1,71 +0,0 @@
-# -*- coding: utf-8 -*-
-
-from __future__ import with_statement
-
-import os
-import time
-
-from shutil import move
-
-from module.plugins.Hook import Hook
-from module.utils import fs_encode, save_join
-
-
-class HotFolder(Hook):
- __name__ = "HotFolder"
- __type__ = "hook"
- __version__ = "0.14"
-
- __config__ = [("folder" , "str" , "Folder to observe" , "container"),
- ("watch_file", "bool", "Observe link file" , False ),
- ("keep" , "bool", "Keep added containers", True ),
- ("file" , "str" , "Link file" , "links.txt")]
-
- __description__ = """Observe folder and file for changes and add container and links"""
- __license__ = "GPLv3"
- __authors__ = [("RaNaN", "RaNaN@pyload.de")]
-
-
- def setup(self):
- self.info = {} #@TODO: Remove in 0.4.10
- self.interval = 30
-
-
- def periodical(self):
- folder = fs_encode(self.getConfig('folder'))
- file = fs_encode(self.getConfig('file'))
-
- try:
- if not os.path.isdir(os.path.join(folder, "finished")):
- os.makedirs(os.path.join(folder, "finished"))
-
- if self.getConfig('watch_file'):
- with open(file, "a+") as f:
- f.seek(0)
- content = f.read().strip()
-
- if content:
- f = open(file, "wb")
- f.close()
-
- name = "%s_%s.txt" % (file, time.strftime("%H-%M-%S_%d%b%Y"))
-
- with open(save_join(folder, "finished", name), "wb") as f:
- f.write(content)
-
- self.core.api.addPackage(f.name, [f.name], 1)
-
- for f in os.listdir(folder):
- path = os.path.join(folder, f)
-
- if not os.path.isfile(path) or f.endswith("~") or f.startswith("#") or f.startswith("."):
- continue
-
- newpath = os.path.join(folder, "finished", f if self.getConfig('keep') else "tmp_" + f)
- move(path, newpath)
-
- self.logInfo(_("Added %s from HotFolder") % f)
- self.core.api.addPackage(f, [newpath], 1)
-
- except (IOError, OSError), e:
- self.logError(e)