#!/usr/bin/python
# -*- coding: utf-8 -*-
from tweepy.streaming import StreamListener
from tweepy import OAuthHandler
from tweepy import Stream
from datetime import datetime

#access_token = '105809219-LoQ2ti1dcO0tZpSECWCyteeIpaerWoqISKKvrbXV'
#access_token_secret = 'bwNY0BcU3VKPygM5ZpiDTmtYnbPqzywdvQHLNNr9CMa1e'
#consumer_key = 'PN9JvV4BpOpvZgHoSqdMi2Oy9'
#consumer_secret = '4zWp5hzFgLMsVYsLCKhrLNRQumj62qmlPCM8le94cbEruyq6VP'
#estas contrasennas son de nachoo, devolverselas cuando el quiera sacar sus propios tweets
access_token = '307706130-yf5CsDgNqW183WE3saE39fz6gXgCRRvIwEMAKyVj'
access_token_secret = 'SyyESQ93PKAFYF2e9OKqxdytHyMdA4wtZ4p3Qlb7Q93c0'
consumer_key = 'irvY2ST0cYvpyFjLkIESGYaWs'
consumer_secret = 'cYHJU0epL8MVR70CfYK9BmWBHnNMjvRelk7CUVy64TTjqCcMO9'

EPOCH_SIZE = 10000

class StdOutListener(StreamListener):
    def __init__(self):
        self.epoch = 1
        self.tweets = 0
        self.out_file =  datetime.now().strftime("%Y_%m_%d_%H_%M")+'_Facebook_Data_Stream_'
        self.output = open(self.out_file+str(self.epoch)+'.txt', 'a')

    def shutdown(self):
        print("{0} Epochs, {1} Tweets guardados".format(self.epoch, (self.epoch+1)*EPOCH_SIZE))
        self.output.close()

    def on_data(self, data):
        self.tweets += 1
        self.output.write(data)
        if self.tweets >= EPOCH_SIZE:
            print("[Epoch {0}]: {1} Tweets guardados".format(self.epoch, (self.epoch+1)*EPOCH_SIZE))
            self.output.close()
            self.tweets = 0
            self.epoch += 1
            self.output = open(self.out_file+str(self.epoch)+'.txt', 'a')
        return True

    def on_error(self, status):
        print('error')
        print(status)
        self.shutdown()


if __name__ == '__main__':
    while True:
	    try:
        	l = StdOutListener()
	        auth = OAuthHandler(consumer_key, consumer_secret)
        	auth.set_access_token(access_token, access_token_secret)
	        stream = Stream(auth, l)
	        stream.filter(languages=["es"], track=['#toquedequeda','#ChileDesperto','#YoApoyoAlPresidente','#EstadoEmergencia','#AquiFaltaPinochet','#RenunciaPineraCuliao','#ChileEnResistencia','#DespiertaChile'])
	    except Exception as err:
            	print(err.message)