from tweepy.streaming import StreamListener
from tweepy import OAuthHandler
from tweepy import Stream
import tweepy

consumer_key="KqiUO3abFVhv0iIMcBYV0BxUf"
consumer_secret="7shjEbPXs4l5mejXxZgGhaqm8XAFiWhsv1EnYplmT60hAll9yc"
access_token="1098485478909771777-2qWb39Gju80n080aDpnQunAm22MliI"
access_token_secret="m83ujY8fqxDW9hKa0MKwjJwLPCTgBxu3goc9U0JRekv5y"



MAX_TWEETS = 5

auth = OAuthHandler(consumer_key, consumer_secret)
api = tweepy.API(auth)

#for tweet in tweepy.Cursor(api.search, q='#python', rpp=100).items(MAX_TWEETS):
 #   a = tweet

    #gh = a['created_at']
    #if gh and isinstance(gh, list):
    # Assuming you want to iterate over the list
        #for ghs in gh:
            #c = ghs.get('created_at')
            #print(c)



# def get_tweets(username):

#         # Authorization to consumer key and consumer secret
#         auth = OAuthHandler(consumer_key, consumer_secret)

#         # Access to user's access key and access secret
#         auth.set_access_token(access_token, access_token_secret)

#         # Calling api
#         api = tweepy.API(auth)

#         # 200 tweets to be extracted
#         number_of_tweets=20
#         tweets = api.user_timeline(screen_name=username)

#         # Empty Array
#         tmp=[]

#         # create array of tweet information: username,
#         # tweet id, date/time, text
#         tweets_for_csv = [tweet.text for tweet in tweets] # CSV file created
#         for j in tweets_for_csv:

#             # Appending tweets to the empty array tmp
#             tmp.append(j)

#         # Printing the tweets
#         print(tmp)


# Driver code
# if __name__ == '__main__':

#     # Here goes the twitter handle for the user
#     # whose tweets are to be extracted.
#     get_tweets("twitter-handle")




class MyStreamListener(StreamListener):

    def on_data(self, data):
        count = 0
        count +=1
        while count >=11:
            print(data)
            break
        #savefile=open('tweetsdata.csv','a')
        #savefile.write(data)
        #savefile.write('/n')
        #savefile.close()
        #return True

    def on_error(self, status):
        print(status)

if __name__ == '__main__':
    l = MyStreamListener()

    auth = OAuthHandler(consumer_key, consumer_secret)
    auth.set_access_token(access_token, access_token_secret)
    a=input("enter hashtag")
    stream = Stream(auth, l)
    stream.filter(track=[a])