repo.py

from conversation import Conversation

class ConversationRepository:
    def __init__(self):
        self.conversations = {}

    def get_or_create(self, recipient_id):
        conversation = self.conversations.get(recipient_id)
        if conversation:
            return conversation

        conversation = Conversation(recipient_id)
        self.conversations[recipient_id] = conversation
        return conversation

    def get_all(self):
        return self.conversations.values()

    def get_by_team(self, team_slug):
        return [c for c in self.get_all() if c.user.team_slug == team_slug]

    def get_by_realtime(self, match):
        cond = lambda c: c.realtime_subs.has(match)
        return self.get_cond(cond)

    def get_by_interest(self, match):
        cond = lambda c: (
            c.user.team_slug in [match.mandante, match.visitante] or
            c.interest_subs.has(match)
        )
        return self.get_cond(cond)

    def get_cond(self, cond):
        return [c for c in self.get_all() if cond(c)]

class PollRepository:
    def __init__(self):
        self.polls = []

    def insert(self, poll):
        self.polls.append(poll)
        poll.uid = len(self.polls)
        return poll

    def get_all(self):
        return self.polls

    def get(self, uid):
        if len(self.polls) < uid:
            return None

        return self.polls[uid-1]