Skip to content

Commit

Permalink
デモ用にダンス開始のトリガーのボタンを追加した
Browse files Browse the repository at this point in the history
  • Loading branch information
@cattaka
cattaka committed Aug 25, 2012
1 parent fea59fa commit 15f571f
Show file tree
Hide file tree
Showing 2 changed files with 67 additions and 36 deletions.
6 changes: 6 additions & 0 deletions DroidRobo01/res/layout/monitor_twitter.xml
View file
Expand Up @@ -3,6 +3,12 @@
android:layout_width="match_parent"
android:layout_height="match_parent"
android:orientation="vertical" >
<Button
android:id="@+id/DanceButton"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:text="Dance"
/>
<ListView
android:id="@+id/TweetListView"
android:layout_width="match_parent"
Expand Down
97 changes: 61 additions & 36 deletions DroidRobo01/src/net/cattaka/droidrobo01/MonitorTwitterActivity.java
View file
@@ -1,3 +1,4 @@

package net.cattaka.droidrobo01;

import java.text.DateFormat;
Expand All @@ -10,7 +11,6 @@
import net.cattaka.droidrobo01.robo.RoboPauseInfo;
import net.cattaka.droidrobo01.service.AdkService;
import net.cattaka.droidrobo01.service.IAdkService;

import twitter4j.FilterQuery;
import twitter4j.Status;
import twitter4j.StatusDeletionNotice;
Expand All @@ -31,23 +31,31 @@
import android.os.RemoteException;
import android.preference.PreferenceManager;
import android.util.Log;
import android.view.View;
import android.view.WindowManager;
import android.widget.ArrayAdapter;
import android.widget.ListView;

public class MonitorTwitterActivity extends Activity {
public class MonitorTwitterActivity extends Activity implements View.OnClickListener {
private static final int EVENT_ADD_MESSAGE = 1;

private static final int EVENT_DRIVE = 2;

private MonitorTwitterActivity me = this;

private IAdkService mAdkService;

private ListView mTweetListView;

private TwitterStream mTwitterStream;

private ArmSetting mSetting;

private Queue<RoboPauseInfo> mPauseQueue = new LinkedList<RoboPauseInfo>();

private RoboPauseInfo ROBO_PAUSE_STOP = new RoboPauseInfo(false, MotorState.NONE, 500, 0.25f, 0.25f);


private RoboPauseInfo ROBO_PAUSE_STOP = new RoboPauseInfo(false, MotorState.NONE, 500, 0.25f,
0.25f);

private ServiceConnection mServiceConnection = new ServiceConnection() {

@Override
Expand All @@ -71,24 +79,26 @@ public void handleMessage(android.os.Message msg) {
if (msg.what == EVENT_ADD_MESSAGE) {
if (mTweetListView.getAdapter() instanceof ArrayAdapter<?>) {
if (msg.obj instanceof String) {
addMessage((String) msg.obj);
addMessage((String)msg.obj);
}
}
} else if (msg.what == EVENT_DRIVE) {
startDriveRobo();
}
};
};

@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.monitor_twitter);
getWindow().addFlags(WindowManager.LayoutParams.FLAG_KEEP_SCREEN_ON);;

mTweetListView = (ListView) findViewById(R.id.TweetListView);
getWindow().addFlags(WindowManager.LayoutParams.FLAG_KEEP_SCREEN_ON);

findViewById(R.id.DanceButton).setOnClickListener(this);

mTweetListView = (ListView)findViewById(R.id.TweetListView);
}

@Override
protected void onResume() {
super.onResume();
Expand All @@ -102,29 +112,37 @@ protected void onResume() {
mSetting = new ArmSetting();
mSetting.loadPreference(pref);
}

startMonitor();
startDriveRobo();
}

@Override
protected void onPause() {
super.onPause();
stopMonitor();
stopDriveRobo();
}


@Override
public void onClick(View v) {
if (v.getId() == R.id.DanceButton) {
addMessageAsync(null);
}
}

private void startMonitor() {
stopMonitor();

ConfigurationBuilder builder = new ConfigurationBuilder();
builder.setOAuthAccessToken(mSetting.getAccessToken());
builder.setOAuthAccessTokenSecret(mSetting.getAccessTokenSecret());
builder.setOAuthConsumerKey(Constants.getTwConsumerKey(this));
builder.setOAuthConsumerSecret(Constants.getTwConsumerSecret(this));
mTwitterStream = new TwitterStreamFactory(builder.build()).getInstance();

final ArrayAdapter<String> adapter = new ArrayAdapter<String>(this, android.R.layout.simple_list_item_1);

final ArrayAdapter<String> adapter = new ArrayAdapter<String>(this,
android.R.layout.simple_list_item_1);
mTweetListView.setAdapter(adapter);
StatusListener listener = new StatusListener() {
public void onStatus(Status status) {
Expand All @@ -140,23 +158,25 @@ public void onStatus(Status status) {
}

public void onDeletionNotice(StatusDeletionNotice statusDeletionNotice) {
addMessageAsync("Got a status deletion notice id:" + statusDeletionNotice.getStatusId());
addMessageAsync("Got a status deletion notice id:"
+ statusDeletionNotice.getStatusId());
}

public void onTrackLimitationNotice(int numberOfLimitedStatuses) {
addMessageAsync("Got track limitation notice:" + numberOfLimitedStatuses);
}

public void onScrubGeo(long userId, long upToStatusId) {
addMessageAsync("Got scrub_geo event userId:" + userId + " upToStatusId:" + upToStatusId);
addMessageAsync("Got scrub_geo event userId:" + userId + " upToStatusId:"
+ upToStatusId);
}

public void onException(Exception ex) {
Log.e("Debug", ex.getMessage(), ex);
}
};
mTwitterStream.addListener(listener);

List<Long> follow = new ArrayList<Long>();
List<String> track = new ArrayList<String>();
{
Expand All @@ -169,40 +189,44 @@ public void onException(Exception ex) {
track.add(str);
}
}

long[] followArray = new long[follow.size()];
for (int i = 0; i < follow.size(); i++) {
followArray[i] = follow.get(i);
}
String[] trackArray = track.toArray(new String[track.size()]);

mTwitterStream.filter(new FilterQuery(0, followArray, trackArray));
//mTwitterStream.sample();

// mTwitterStream.sample();
}

private void addMessage(String str) {
@SuppressWarnings("unchecked")
ArrayAdapter<String> adapter = (ArrayAdapter<String> )mTweetListView.getAdapter();
ArrayAdapter<String> adapter = (ArrayAdapter<String>)mTweetListView.getAdapter();
adapter.insert(str, 0);
if (adapter.getCount() >= 20) {
while (adapter.getCount() > 10) {
adapter.remove(adapter.getItem(10));
}
}

adapter.notifyDataSetChanged();
}

private void addMessageAsync(String str) {
Message msg = new Message();
msg.what = EVENT_ADD_MESSAGE;
msg.obj = str;
mHandler.sendMessage(msg);
if (str != null) {
Message msg = new Message();
msg.what = EVENT_ADD_MESSAGE;
msg.obj = str;
mHandler.sendMessage(msg);
}
if (mPauseQueue.size() == 0) {
mPauseQueue.add(new RoboPauseInfo(true, MotorState.NONE, 500, 0.25f, 0.25f));
mPauseQueue.add(new RoboPauseInfo(false, MotorState.NONE, 500, 0.25f, 0.25f));
mPauseQueue.add(new RoboPauseInfo(true, MotorState.NONE, 500, 0.25f, 0.25f));
mPauseQueue.add(new RoboPauseInfo(false, MotorState.NONE, 500, 0.25f, 0.25f));

mPauseQueue.add(new RoboPauseInfo(true, MotorState.NONE, 1000, 0.75f, 0.75f));
mPauseQueue.add(new RoboPauseInfo(true, MotorState.NONE, 500, 1.00f, 0.50f));
mPauseQueue.add(new RoboPauseInfo(true, MotorState.NONE, 500, 0.50f, 1.00f));
Expand All @@ -214,19 +238,19 @@ private void addMessageAsync(String str) {

mPauseQueue.add(new RoboPauseInfo(true, MotorState.TURN_LEFT, 200, 0.75f, 0.75f));
mPauseQueue.add(new RoboPauseInfo(true, MotorState.TURN_RIGHT, 200, 0.75f, 0.75f));

mPauseQueue.add(new RoboPauseInfo(true, MotorState.NONE, 1000, 1.0f, 1.0f));

}
}

private void stopMonitor() {
if (mTwitterStream != null) {
mTwitterStream.shutdown();
mTwitterStream = null;
}
}

private void startDriveRobo() {
RoboPauseInfo rpInfo = mPauseQueue.poll();
if (rpInfo == null) {
Expand All @@ -238,12 +262,13 @@ private void startDriveRobo() {
mAdkService.sendCommand((byte)0x03, (byte)(0x0), rpInfo.toUpperBytes());
mAdkService.sendCommand((byte)0x03, (byte)(0x5), rpInfo.toLowerBytes());
} catch (RemoteException e) {
Log.e("Debug", e.getMessage(),e);
Log.e("Debug", e.getMessage(), e);
}
}
}
mHandler.sendEmptyMessageDelayed(EVENT_DRIVE, rpInfo.getDucation());
}

private void stopDriveRobo() {
mHandler.removeMessages(EVENT_DRIVE);
}
Expand Down

0 comments on commit 15f571f

Please sign in to comment.