7 files changed, 1052 insertions, 0 deletions

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..c0fa452
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,112 @@
+# Created by .ignore support plugin (hsz.mobi)
+
+### Python template
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+env/
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+*.egg-info/
+.installed.cfg
+*.egg
+
+# PyInstaller
+#  Usually these files are written by a python script from a template
+#  before PyInstaller builds the exe, so as to inject date/other infos into it.
+*.manifest
+*.spec
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*,cover
+
+# Translations
+*.mo
+*.pot
+
+# Django stuff:
+*.log
+
+# Sphinx documentation
+docs/_build/
+
+# PyBuilder
+target/
+
+
+### JetBrains template
+# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion
+
+*.iml
+
+## Directory-based project format:
+.idea/
+# if you remove the above rule, at least ignore the following:
+
+# User-specific stuff:
+# .idea/workspace.xml
+# .idea/tasks.xml
+# .idea/dictionaries
+
+# Sensitive or high-churn files:
+# .idea/dataSources.ids
+# .idea/dataSources.xml
+# .idea/sqlDataSources.xml
+# .idea/dynamic.xml
+# .idea/uiDesigner.xml
+
+# Gradle:
+# .idea/gradle.xml
+# .idea/libraries
+
+# Mongo Explorer plugin:
+# .idea/mongoSettings.xml
+
+## File-based project format:
+*.ipr
+*.iws
+
+## Plugin-specific files:
+
+# IntelliJ
+/out/
+
+# mpeltonen/sbt-idea plugin
+.idea_modules/
+
+# JIRA plugin
+atlassian-ide-plugin.xml
+
+# Crashlytics plugin (for Android Studio and IntelliJ)
+com_crashlytics_export_strings.xml
+crashlytics.properties
+crashlytics-build.properties
+
+
diff --git a/afeedprocessor/afeedparser.py b/afeedprocessor/afeedparser.py
new file mode 100644
index 0000000..0c23187
--- /dev/null
+++ b/afeedprocessor/afeedparser.py
@@ -0,0 +1,59 @@
+import feedparser
+import PyRSS2Gen
+import datetime
+
+
+class FeedParser:
+    @staticmethod
+    def date_tuple_to_datetime(date_tuple):
+        return datetime.datetime(*(date_tuple[:5])) if date_tuple else None
+
+    @staticmethod
+    def get_first(lst):
+        return lst[0] if lst and len(lst) > 0 else None
+
+    def get_rss_item_for_entry(self, entry):
+        return PyRSS2Gen.RSSItem(
+            title=entry.get('title'),
+            link=entry.get('link'),
+            description=entry.get('description'),
+            author=entry.get('author'),
+            categories=entry.get('tags'),
+            comments=entry.get('comments'),
+            enclosure=self.get_first(entry.get('enclosures')),
+            guid=entry.get('id'),
+            pubDate=self.date_tuple_to_datetime(entry.get('published_parsed')),
+            source=entry.get('source'),
+        )
+
+    def get_rss2_from_feed(self, feed, entries):
+        return PyRSS2Gen.RSS2(
+            title=feed.get('title'),
+            link=feed.get('link'),
+            description=feed.get('subtitle'),
+
+            language=feed.get('language'),
+            copyright=feed.get('rights'),
+            managingEditor=feed.get('contributors'),
+            webMaster=feed.get('publisher'),
+            pubDate=self.date_tuple_to_datetime(feed.get('published_parsed')),
+            lastBuildDate=self.date_tuple_to_datetime(feed.get('updated_parsed')),
+
+            categories=feed.get('tags'),
+            generator=feed.get('generator'),
+            docs=feed.get('docs'),
+            cloud=feed.get('cloud'),
+            ttl=feed.get('ttl'),
+
+            image=feed.get('image'),
+            rating=None,
+            textInput=feed.get('textinput'),
+            skipHours=None,
+            skipDays=None,
+
+            items=[self.get_rss_item_for_entry(entry) for entry in entries],
+        )
+
+    def parse(self, feed):
+        parsed_feed = feedparser.parse(feed)
+        return self.get_rss2_from_feed(parsed_feed.feed, parsed_feed.entries)
diff --git a/afeedprocessor/afeedprocessor.py b/afeedprocessor/afeedprocessor.py
new file mode 100644
index 0000000..e3663ee
--- /dev/null
+++ b/afeedprocessor/afeedprocessor.py
@@ -0,0 +1,96 @@
+import PyRSS2Gen
+
+from afeedprocessor.anitemprocessor import ItemProcessor
+
+
+class FeedProcessor:
+    def __init__(self, item_processor: ItemProcessor=None):
+        if item_processor is None:
+            self.item_processor = ItemProcessor()
+        else:
+            self.item_processor = item_processor
+
+    def get_title(self, title, feed):
+        return title
+
+    def get_link(self, link, feed):
+        return link
+
+    def get_description(self, description, feed):
+        return description
+
+    def get_language(self, language, feed):
+        return language
+
+    def get_copyright(self, copyright, feed):
+        return copyright
+
+    def get_managing_editor(self, managing_editor, feed):
+        return managing_editor
+
+    def get_web_master(self, web_master, feed):
+        return web_master
+
+    def get_pub_date(self, pub_date, feed):
+        return pub_date
+
+    def get_last_build_date(self, last_build_date, feed):
+        return last_build_date
+
+    def get_categories(self, categories, feed):
+        return categories
+
+    def get_generator(self, generator, feed):
+        return generator
+
+    def get_docs(self, docs, feed):
+        return docs
+
+    def get_cloud(self, cloud, feed):
+        return cloud
+
+    def get_ttl(self, ttl, feed):
+        return ttl
+
+    def get_image(self, image, feed):
+        return image
+
+    def get_rating(self, rating, feed):
+        return rating
+
+    def get_text_input(self, text_input, feed):
+        return text_input
+
+    def get_skip_hours(self, skip_hours, feed):
+        return skip_hours
+
+    def get_skip_days(self, skip_days, feed):
+        return skip_days
+
+    def get_items(self, items, feed):
+        return [self.item_processor.process(item) for item in items]
+
+    def process(self, feed: PyRSS2Gen.RSS2):