aboutsummaryrefslogtreecommitdiff
path: root/pyaggr3g470r/models.py
blob: ba2730b92a0c945797605a711c5071e0c88e9cba (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
#! /usr/bin/env python
# -*- coding: utf-8 -*-

from mongoengine import *
from datetime import datetime

from werkzeug import generate_password_hash, check_password_hash
from flask.ext.login import UserMixin

import bson.objectid

class User(Document, UserMixin):
    firstname  = StringField(required=True)
    lastname = StringField(required = True)
    email = EmailField(required=True, unique=True)
    pwdhash = StringField(required=True)
    feeds = SortedListField(EmbeddedDocumentField('Feed'), ordering='title', reverse=True)
    created_at = DateTimeField(required=True, default=datetime.now)

    def get_id(self):
        return self.email

    def set_password(self, password):
        self.pwdhash = generate_password_hash(password)

    def check_password(self, password):
        return check_password_hash(self.pwdhash, password)

    #required for administrative interface
    def __unicode__(self):
        return self.email

class Feed(EmbeddedDocument):
    oid = ObjectIdField(default=bson.objectid.ObjectId , primary_key=True)
    title = StringField(required=True)
    link = StringField(required=True)
    site_link = StringField(required=True)
    mail = BooleanField(default=False)
    articles = ListField(ReferenceField('Article', dbref = False))
    created_date = DateTimeField(required=True, default=datetime.now)

    meta = {
        'ordering': ['+title']
    }

    def __str__(self):
        return 'Feed: %s' % self.title

class Article(Document):
    date = DateTimeField(required=True)
    link = StringField(required=True)
    title = StringField(required=True)
    content = StringField(required=True)
    readed = BooleanField()
    like = BooleanField()
    retrieved_date = DateTimeField(required=True, default=datetime.now)

    meta = {
        'ordering': ['-date'],
        'indexes': [
            {'fields': ['-date'],
              'sparse': True, 'types': False },
        ]
    }

    def __str__(self):
        return 'Article: %s' % self.title

if __name__ == "__main__":
    # Point of entry in execution mode
    db = connect('pyaggr3g470r1')
    db.drop_database('pyaggr3g470r1')


    from werkzeug import generate_password_hash
    password = generate_password_hash("admin")
    user1 = User(firstname="Cédric", lastname="Bonhomme", \
                email="kimble.mandel@gmail.com", pwdhash=generate_password_hash("admin"))
    user1.save()
    user2 = User(firstname="Carole", lastname="Niesel", \
                email="carole.niesel@gmail.com", pwdhash=generate_password_hash("secret"))
    user2.save()

    user2 = User.objects(email="carole.niesel@gmail.com").first()
    feed1user2 =  Feed(title='Zaubette - une maitresse qui ouvre son cartable', \
                       link='http://zaubette.eklablog.com/rss/', \
                       site_link='http://zaubette.eklablog.com/', \
                       mail = False)
    user2.feeds.append(feed1user2)
    user2.save()


    import mongodb
    mongo = mongodb.Articles("127.0.0.1", 27017, \
                        "pyaggr3g470r", "***", "")
    feeds = mongo.get_all_feeds()
    for feed in feeds:
        articles = []
        feed_articles = mongo.get_articles(feed["feed_id"])
        feed_articles = sorted(feed_articles, key=lambda t: t['article_date'], reverse=True)
        for article in feed_articles:
            article1 = Article(date=article["article_date"], link=article["article_link"], \
                       title=article["article_title"], content=article["article_content"], \
                        readed=article["article_readed"], like=article["article_like"], \
                        retrieved_date=article["article_date"])

            articles.append(article1)
            article1.save()

        sorted(articles, key=lambda t: t.date, reverse=True)

        feed1 = Feed(title=feed["feed_title"], link=feed["feed_link"],
                 site_link=feed["site_link"], mail=feed["mail"],
                 articles=articles)
        #feed1.save()
        user1.feeds.append(feed1)
        user1.save()
bgstack15