TimelineYukkuriTalker for Pi » TimelineTalker

<component name="ArtifactManager">

  <artifact type="jar" name="TwitterTimelineTalker:jar">

    <output-path>$PROJECT_DIR$/out/artifacts/TwitterTimelineTalker_jar</output-path>

    <root id="archive" name="TwitterTimelineTalker.jar">

      <element id="module-output" name="TwitterTimelineTalker" />

      <element id="extracted-dir" path="$MAVEN_REPOSITORY$/org/twitter4j/twitter4j-core/4.0.6/twitter4j-core-4.0.6.jar" path-in-jar="/" />

      <element id="extracted-dir" path="$MAVEN_REPOSITORY$/org/twitter4j/twitter4j-stream/4.0.6/twitter4j-stream-4.0.6.jar" path-in-jar="/" />

    </root>

  </artifact>

</component>

        <module name="TwitterTimelineTalker" />

      <module name="TwitterTimelineTalker" target="1.7" />

      <module fileurl="file://$PROJECT_DIR$/TwitterTimelineTalker.iml" filepath="$PROJECT_DIR$/TwitterTimelineTalker.iml" />

<?xml version="1.0" encoding="UTF-8"?>

<module org.jetbrains.idea.maven.project.MavenProjectsManager.isMavenModule="true" type="JAVA_MODULE" version="4">

  <component name="NewModuleRootManager" LANGUAGE_LEVEL="JDK_1_7">

    <output url="file://$MODULE_DIR$/target/classes" />

    <output-test url="file://$MODULE_DIR$/target/test-classes" />

    <content url="file://$MODULE_DIR$">

      <sourceFolder url="file://$MODULE_DIR$/src" isTestSource="false" />

      <excludeFolder url="file://$MODULE_DIR$/target" />

    </content>

    <orderEntry type="inheritedJdk" />

    <orderEntry type="sourceFolder" forTests="false" />

    <orderEntry type="library" name="Maven: org.twitter4j:twitter4j-core:4.0.6" level="project" />

    <orderEntry type="library" name="Maven: org.twitter4j:twitter4j-stream:4.0.6" level="project" />

  </component>

</module>

	<artifactId>TwitterTimelineTalker</artifactId>

Main-Class: com.mizo0203.twitter.timeline.talker.Application

package com.mizo0203.twitter.timeline.talker;

import twitter4j.conf.Configuration;

import twitter4j.conf.ConfigurationBuilder;

/**

 * Java アプリケーション起動時に実行されるクラス

 * 

 * @author みぞ@CrazyBeatCoder

 */

public class Application {

  public static void main(String[] args) {

    TwitterTimelineTalker twitterTimelineTalker;

    Talker talker;

    try {

      talker = new Talker();

      twitterTimelineTalker =

          new TwitterTimelineTalker(new Arguments(args).twitterConfiguration, talker);

    } catch (IllegalArgumentException | IllegalStateException e) {

      System.err.println(e.getMessage());

      return;

    }

    twitterTimelineTalker.start();

    talker.talkAsync("アプリケーションを起動しました", Talker.YukkuriVoice.REIMU);

  }

  /**

   * Java アプリケーション起動時に指定する引数のデータクラス

   * 

   * @author みぞ@CrazyBeatCoder

   */

  private static class Arguments {

    private final Configuration twitterConfiguration;

    private Arguments(String[] args) throws IllegalArgumentException {

      if (args.length < Argument.values().length) {

        StringBuilder exceptionMessage = new StringBuilder();

        exceptionMessage.append(Argument.values().length + " つの引数を指定してください。\n");

        for (Argument arg : Argument.values()) {

          exceptionMessage.append((arg.ordinal() + 1) + " つ目: " + arg.detail + "\n");

        }

        throw new IllegalArgumentException(exceptionMessage.toString());

      }

      String consumer_key = args[Argument.CONSUMER_KEY.ordinal()];

      String consumer_secret = args[Argument.CONSUMER_SECRET.ordinal()];

      String access_token = args[Argument.ACCESS_TOKEN.ordinal()];

      String access_token_secret = args[Argument.ACCESS_TOKEN_SECRET.ordinal()];

      twitterConfiguration = new ConfigurationBuilder().setOAuthConsumerKey(consumer_key)

          .setOAuthConsumerSecret(consumer_secret).setOAuthAccessToken(access_token)

          .setOAuthAccessTokenSecret(access_token_secret).build();

    }

  }

  /**

   * Java アプリケーション起動時に指定する引数の定義

   * 

   * @author みぞ@CrazyBeatCoder

   */

  private enum Argument {

    CONSUMER_KEY("Twitter Application's Consumer Key (API Key)"), //

    CONSUMER_SECRET("Twitter Application's Consumer Secret (API Secret)"), //

    ACCESS_TOKEN("Twitter Account's Access Token"), //

    ACCESS_TOKEN_SECRET("Twitter Account's Access Token Secret"), //

    ;

    private final String detail;

    private Argument(String detail) {

      this.detail = detail;

    }

  }

}

package com.mizo0203.twitter.timeline.talker;

import java.io.IOException;

public class RuntimeUtil {

  public static void execute(String[] cmdarray) {

    try {

      Process process = Runtime.getRuntime().exec(cmdarray);

      process.waitFor();

      process.destroy();

    } catch (IOException | InterruptedException e) {

      e.printStackTrace();

    }

  }

}

package com.mizo0203.twitter.timeline.talker;

import java.io.BufferedWriter;

import java.io.File;

import java.io.FileWriter;

import java.io.IOException;

import java.io.PrintWriter;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

public class Talker {

  private static final String AQUESTALK_PI_PATH = "./aquestalkpi/AquesTalkPi";

  private final ExecutorService mSingleThreadExecutor = Executors.newSingleThreadExecutor();

  public Talker() throws IllegalStateException, SecurityException {

    File file = new File(AQUESTALK_PI_PATH);

    if (!file.isFile()) {

      throw new IllegalStateException(file.getPath() + " に AquesTalk Pi がありません。\n"

          + "https://www.a-quest.com/products/aquestalkpi.html\n" + "からダウンロードしてください。");

    }

    if (!file.canExecute()) {

      throw new IllegalStateException(file.getPath() + " に実行権限がありません。");

    }

  }

  public void talkAsync(final String text, final YukkuriVoice voice) {

    mSingleThreadExecutor.submit(new Runnable() {

      @Override

      public void run() {

        try {

          File file = new File("text.txt");

          PrintWriter pw = new PrintWriter(new BufferedWriter(new FileWriter(file)));

          pw.println(text);

          pw.flush();

          pw.close();

          RuntimeUtil.execute(new String[] {AQUESTALK_PI_PATH, "-v", voice.value, "-f", "text.txt",

              "-o", "out.wav"});

          RuntimeUtil.execute(new String[] {"sh", "-c", "aplay < out.wav"}); // 起動コマンドを指定する

          Thread.sleep(2000);

        } catch (IOException | InterruptedException e) {

          e.printStackTrace();

        }

      }

    });

  }

  public static enum YukkuriVoice {

    /**

     * ゆっくりボイス - 霊夢

     */

    REIMU("f1"), //

    /**

     * ゆっくりボイス - 魔理沙

     */

    MARISA("f2"), //

    ;

    private final String value;

    private YukkuriVoice(String value) {

      this.value = value;

    }

  }

}

package com.mizo0203.twitter.timeline.talker;

import java.util.Locale;

import java.util.regex.Matcher;

import java.util.regex.Pattern;

import twitter4j.StallWarning;

import twitter4j.Status;

import twitter4j.StatusDeletionNotice;

import twitter4j.StatusListener;

import twitter4j.TwitterStream;

import twitter4j.TwitterStreamFactory;

import twitter4j.conf.Configuration;

public class TwitterTimelineTalker {

  /**

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

   */

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

  private Talker.YukkuriVoice mYukkuriVoice = Talker.YukkuriVoice.REIMU;

  private final TwitterStream mTwitterStream;

  private final Talker mTalker;

  public TwitterTimelineTalker(Configuration configuration, Talker talker) {

    mTwitterStream = new TwitterStreamFactory(configuration).getInstance();

    mTwitterStream.addListener(new OnStatusEvent());

    mTalker = talker;

  }

  public void start() {

    // OnStatusEvent に Twitter タイムラインが通知される

    mTwitterStream.user();

  }

  private static String getUserNameWithoutContext(String name) {

    Pattern p = Pattern.compile("([^@＠]+).+");

    Matcher m = p.matcher(name);

    return m.replaceFirst("$1");

  }

  private class OnStatusEvent implements StatusListener {

    public 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(getUserNameWithoutContext(status.getUser().getName()) + "さんがリツイート。");

        buffer.append(getUserNameWithoutContext(retweetedStatus.getUser().getName()) + "さんから、");

        buffer.append(retweetedStatus.getText());

      } else {

        buffer.append(getUserNameWithoutContext(status.getUser().getName()) + "さんから、");

        buffer.append(status.getText());

      }

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

      // 読み上げは、霊夢と魔理沙が交互に行なう

      if (mYukkuriVoice == Talker.YukkuriVoice.REIMU) {

        mYukkuriVoice = Talker.YukkuriVoice.MARISA;

      } else {

        mYukkuriVoice = Talker.YukkuriVoice.REIMU;

      }

    }

    public void onDeletionNotice(StatusDeletionNotice sdn) {

      System.err.println("onDeletionNotice.");

    }

    public void onTrackLimitationNotice(int i) {

      System.err.println("onTrackLimitationNotice.(" + i + ")");

    }

    public void onScrubGeo(long lat, long lng) {

      System.err.println("onScrubGeo.(" + lat + ", " + lng + ")");

    }

    public void onException(Exception excptn) {

      System.err.println("onException.");

    }

    @Override

    public void onStallWarning(StallWarning arg0) {}

  }

}

package com.mizo0203.twitter.timeline.talker;

import java.util.regex.Matcher;

import java.util.regex.Pattern;

/**

 * http://chat-messenger.net/blog-entry-40.html

 */

public class UrlUtil {

  /** URLを抽出するための正規表現パターン */

  private static final Pattern convURLLinkPtn = Pattern.compile(

      "(http://|https://){1}[\\w\\.\\-/:\\#\\?\\=\\&\\;\\%\\~\\+]+", Pattern.CASE_INSENSITIVE);

  /**

   * 指定された文字列内のURLを、正規表現を使用し、 空文字列に変換する。

   * 

   * @param str 指定の文字列。

   * @return リンクに変換された文字列。

   */

  public static String convURLEmpty(CharSequence str) {

    Matcher matcher = convURLLinkPtn.matcher(str);

    return matcher.replaceAll("");

  }

}