alexis2/parser.py

#!/usr/bin/python3 
import sys
import re
import newspaper
import pymongo
import htmlmin
import feedparser
import datetime
import threading

from queue import Queue 
from frontpage import FrontPage
from newspaper import Article
from db import db
from source import Source

class LinkList():
    def __init__(self,url,selector=None,rss=False):
        self.links=[]
        if rss:
            feed = feedparser.parse(url)
            #print(feed["bozo"]) FIXME: If bozo==1 => error
            self.links=[i["link"] for i in feed["items"]]
            print(self.links)
        else:
            if selector is None:
                #s=newspaper.build(url,language="en",memoize_articles=False) #memoize puede salvarme la vida
                s = newspaper.Source(url,memoize_articles=False)
                s.download()
                s.parse()
                s.set_categories()
                s.download_categories()
                s.parse_categories()
                s.generate_articles()
    
                self.links=list(set([a.url for a in s.articles])) #avoid dupes
            else:
                f=FrontPage(url,selector)
                self.links=f.links

        self.links=self.purgeLinks(self.links)

    def purgeLinks(self,l):
        return [ sanitizeUrl(link) for link in l if not "presslist" in link.lower() and not "videolist" in link.lower() ]

class News():
    r=re.compile(r"hours? ago|yesterday|today|last week|month",flags=re.IGNORECASE)
    r_noise=re.compile(r"posted|Product|Google",flags=re.IGNORECASE)
    
    URL=""
    AUTHORS=[]
    SCRAP_DATE=None 
    PUBLISH_DATE=None
    SUMMARY=""
    TEXT=""
    HTML=""
    ERROR=False
    SOURCE=""

    def __init__(self,url,source,lang="en"):
        url=sanitizeUrl(url)
        self.URL=url
        self.SOURCE=source

        a = Article(url, language=lang,keep_article_html=True)
        a.download()
        a.parse()
        a.nlp()
        
        a.authors=self.dedup([self.fix_author(value) for value in a.authors if not self.isComment(value) and not self.isNoise(value)])
        
        self.SCRAP_DATE=datetime.datetime.now()
        self.AUTHORS=a.authors
        self.PUBLISH_DATE=a.publish_date
        self.SUMMARY=a.summary
        self.TEXT=a.text
        self.HTML=htmlmin.minify(a.article_html,remove_empty_space=True)

    def get(self):
        return {
                "url": self.URL,
                "source": self.SOURCE,
                "authors": self.AUTHORS,
                "scrap_date": self.SCRAP_DATE,
                "publish_date": self.PUBLISH_DATE,
                "summary": self.SUMMARY,
                "text": self.TEXT,
                "html": self.HTML 
                }

    def dedup(self,val):
        return list(set(val))

    def isNoise(self,v):
        if self.r_noise.match(v):
            return True
        return False
    def isComment(self,v):
        if self.r.match(v):
            return True
        return False
    
    def fix_author(self,a):
        return a.replace("_", " ").lower()


unsharer=re.compile(r"(\?share=|#).+$",flags=re.IGNORECASE)
def sanitizeUrl(url):
    global unsharer
    ret = re.sub(unsharer, "",url)
    return ret

def sanitizeSelector(s):
    s=s.replace(">a","> a")
    if re.match(r'=\w+\]',s) is None:
        return s

    ret=re.sub(r"=(\w+)]", r'="\1"]', s)
    return ret


def parseSource(s):
    sel=None
    rss=False
    if "selector" in s:
        sel=s["selector"]
    if "rss" in s:
        rss=bool(["rss"])
    l=LinkList(s["link"],sel,rss=rss)

    if l is not None:
        for a in l.links:
            if not d.article_exists(a):
                print(a)
                q.put(a)
        print(len(l.links))

    num_worker_threads=8
    threads=[]
    for i in range(num_worker_threads):
        t = threading.Thread(target=news_worker,args=[s["_id"]])
        t.daemon=True
        t.start()
        threads.append(t)

    q.join()
    for i in range(num_worker_threads):
        q.put(None)
    for t in threads:
        t.join()
    print("Finished parsing %s" %s)



def news_worker(source_id):
    while True:
        item = q.get()
        if item is None:
            break
        n=News(item,source_id)
        print("[Thread %s] %s" % (threading.current_thread(),n.URL))
        d.insert_article(n.get())
        q.task_done()

q=Queue()
d=db()
for s in d.sources():
    print(s["name"])
    parseSource(s)
    break