TimelineYukkuriTalker for Pi » TimelineTalker

package com.mizo0203.timeline.talker;

import com.mizo0203.timeline.talker.util.DisplayNameUtil;

import com.mizo0203.timeline.talker.util.UrlUtil;

import org.jetbrains.annotations.NotNull;

import twitter4j.*;

import twitter4j.conf.Configuration;

import java.util.Collections;

import java.util.Locale;

import java.util.Timer;

import java.util.TimerTask;

import java.util.concurrent.TimeUnit;

public class TwitterTimelineTalker implements TimelineTalker {

  /** ISO 639 言語コード - 日本語 (ja) */

  private static final String LANG_JA = Locale.JAPAN.getLanguage();

  @NotNull private final RequestHomeTimelineTimerTask mRequestHomeTimelineTimerTask;

  public TwitterTimelineTalker(@NotNull Configuration configuration, Talker talker) {

    Twitter twitter = new TwitterFactory(configuration).getInstance();

    mRequestHomeTimelineTimerTask = new RequestHomeTimelineTimerTask(twitter, talker);

  }

  @Override

  public void start() {

    new Timer().schedule(mRequestHomeTimelineTimerTask, 0L, TimeUnit.MINUTES.toMillis(1));

  }

  private static class RequestHomeTimelineTimerTask extends TimerTask {

    private static final int HOME_TIMELINE_COUNT_MAX = 200;

    private static final int HOME_TIMELINE_COUNT_MIN = 1;

    private final Twitter mTwitter;

    private final Talker mTalker;

    /** mStatusSinceId より大きい（つまり、より新しい） ID を持つ HomeTimeline をリクエストする */

    private long mStatusSinceId = 1L;

    private boolean mIsUpdatedStatusSinceId = false;

    private RequestHomeTimelineTimerTask(Twitter twitter, Talker talker) {

      mTwitter = twitter;

      mTalker = talker;

    }

    /** The action to be performed by this timer task. */

    @Override

    public void run() {

      try {

        // mStatusSinceId が未更新ならば、 Status を 1 つだけ取得する

        int count = mIsUpdatedStatusSinceId ? HOME_TIMELINE_COUNT_MAX : HOME_TIMELINE_COUNT_MIN;

        Paging paging = new Paging(1, count, mStatusSinceId);

        ResponseList<Status> statusResponseList = mTwitter.getHomeTimeline(paging);

        if (statusResponseList.isEmpty()) {

          return;

        }

        // mStatusSinceId を、取得した最新の ID に更新する

        mStatusSinceId = statusResponseList.get(0).getId();

        mIsUpdatedStatusSinceId = true;

        // Status が古い順になるよう、 statusResponseList を逆順に並び替える

        Collections.reverse(statusResponseList);

        for (Status status : statusResponseList) {

          onStatus(status);

        }

      } catch (TwitterException e) {

        e.printStackTrace();

      }

    }

    private void onStatus(final Status status) {

      if (!LANG_JA.equalsIgnoreCase(status.getLang())) {

        return;

      }

      final StringBuffer buffer = new StringBuffer();

      if (status.isRetweet()) {

        Status retweetedStatus = status.getRetweetedStatus();

        buffer

            .append(DisplayNameUtil.removeContext(status.getUser().getName()))

            .append("さんがリツイート。");

        buffer

            .append(DisplayNameUtil.removeContext(retweetedStatus.getUser().getName()))

            .append("さんから、");

        buffer.append(retweetedStatus.getText());

      } else {

        buffer.append(DisplayNameUtil.removeContext(status.getUser().getName())).append("さんから、");

        buffer.append(status.getText());

      }

      mTalker.talkAlternatelyAsync(UrlUtil.convURLEmpty(buffer).replaceAll("\n", "。"));

    }

  }

}