main.py

import asyncio
import traceback
import os

from TwitterCLI.app import TwitterClient
from TwitterCLI.reducers import RootReducer
from TwitterCLI.reducers import TerminalReducer
from TwitterCLI.utils import Store
from TweetSource.app import TweetSource as TweetSource
from TweetSource.app import main as ts_func
from TweetSource.app import getAllTweets
from TwitterCLI.middleware import TweetSourceMiddleware
from TwitterCLI.middleware import ActionLogger

from time import sleep
from threading import Thread
from queue import Queue

import json
from TweetSource import TweetFetcher
from TweetSource import MongoTweetSource
from TweetSource.utils import getTwitter
from TweetSource import TwitterWrapper

import pymongo

from blessed import Terminal

def main():
    mongo = pymongo.MongoClient('localhost', 27017)
    db = mongo['twitter-cli']

    with open('config/twitter.json') as twitter_config:
        config = json.load(twitter_config)
    twitter = getTwitter(config)
    tweetSource = TwitterWrapper(config, twitter)
    mongoSource = MongoTweetSource(db)
    tweetFetcher = TweetFetcher(tweetSource, mongoSource)

    TweetSourceInbox = asyncio.Queue()
    TwitterCLIInbox = asyncio.Queue()
    middlewares = [
        TweetSourceMiddleware(TweetSourceInbox),
        ActionLogger('logs/actions.log'),
    ]
    reducers = [
        RootReducer(middlewares=middlewares),
        TerminalReducer(Terminal()),
    ]

    ts = TweetSource(TweetSourceInbox, TwitterCLIInbox, tweetFetcher)

    initialState = {
        'cursor': 0,
        'cursor_max': 200,
        'username': 'grobolom',
        'selected_list': 'home_timeline',
        'lists': {},
        'view': 'splash',
    }
    store = Store(reducers, initialState)
    app = TwitterClient(TwitterCLIInbox, store=store)

    loop = asyncio.get_event_loop()
    try:
        asyncio.async(ts.run())
        loop.run_until_complete(app.run())

        pending = asyncio.Task.all_tasks()
        for task in pending:
            task.cancel()
        try:
            loop.run_until_complete(asyncio.sleep(0.01))
        except:
            pass
    except Exception as e:
        pass

    mongo.close()
if __name__ == "__main__":
    main()