ramen.scala

import twitter4j._
import scala.concurrent.Future
import scala.concurrent.ExecutionContext.Implicits.global

object Main{
  def open(url: String): Unit = {
    import scala.sys.process.Process
    Future { Process("open", Seq(url)).! }
  }

  def main(args: Array[String]): Unit = {
    val t = new TwitterStreamFactory().getInstance
    t.addListener(new UserStreamAdapter {
      override def onStatus(status: Status): Unit = {
        val urls = status.getMediaEntities().collect { case e:MediaEntity if e.getType == "photo" => e.getMediaURL }
        val eurls = status.getExtendedMediaEntities().collect { case e:ExtendedMediaEntity if e.getType == "photo" => e.getMediaURL }
        (urls ++ eurls).distinct.foreach(open)
      }
    })
    val q = new FilterQuery().track(Array[String]("寿司", "ラーメン"))
    t.filter(q)
  }
}