twitter-stream-1.r

library(streamR)
library(ROAuth)



access_token <- ""
access_secret <-""
consumer_key <- ""
consumer_secret <- ""



oathfunction <- function(consumerKey, consumerSecret, accessToken, accessTokenSecret){
  my_oauth <- ROAuth::OAuthFactory$new(consumerKey=consumerKey,
                                       consumerSecret=consumerSecret,
                                       oauthKey=accessToken,
                                       oauthSecret=accessTokenSecret,
                                       needsVerifier=FALSE, handshakeComplete=TRUE,
                                       verifier="1",
                                       requestURL="https://api.twitter.com/oauth/request_token",
                                       authURL="https://api.twitter.com/oauth/authorize",
                                       accessURL="https://api.twitter.com/oauth/access_token",
                                       signMethod="HMAC")
  return(my_oauth)
}

my_oauth <- oathfunction(consumer_key, consumer_secret, access_token, access_secret)

file = "d:/twittertest6.json"       #The data will be saved to this file as long as the stream is running
track = c("#maga")                 #"Search" by keyword(s)
follow = NULL                           #"Search" by Twitter user(s)
loc = NULL #c(-179, -70, 179, 70)             #Geographical bounding box -- (min longitute,min latitude,max longitute,max latitude)
lang = NULL                             #Filter by language
timeout = NULL #1000                          #Maximum time (in miliseconds)
tweets = 10000 #1000                      #Maximum tweets (not exact)

filterStream(file.name = file, 
             track = track,
             follow = follow, 
             locations = loc, 
             language = lang,
             #timeout = timeout, 
             tweets = tweets, 
             oauth = my_oauth,
             verbose = TRUE)




tweetsdf <- parseTweets(file, verbose = FALSE)
tweetsdf$text <- iconv(tweetsdf$text, from = "UTF-8", to = "ASCII", sub="")


tweetsdf <- transform(tweetsdf, newLon = ifelse(is.na(lon), place_lon, lon))
tweetsdf <- transform(tweetsdf, newLat = ifelse(is.na(lat), place_lat, lat))

tweetsdf <- transform(tweetsdf, trump = ifelse(  grepl("trump", tolower(text)) , "trump" , "x"))
tweetsdf <- transform(tweetsdf, maga = ifelse(  grepl("#maga", tolower(text)) , "maga" , "x"))
tweetsdf <- transform(tweetsdf, refugee = ifelse(  grepl("refugee", tolower(text)) , "refugee" , "x"))

View(tweetsdf)
nrow(tweetsdf)