/*
* Copyright (C) 2014 The Android Open Source Project
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.example.android.wearable.quiz;
import static com.example.android.wearable.quiz.Constants.ANSWERS;
import static com.example.android.wearable.quiz.Constants.CHOSEN_ANSWER_CORRECT;
import static com.example.android.wearable.quiz.Constants.CORRECT_ANSWER_INDEX;
import static com.example.android.wearable.quiz.Constants.NUM_CORRECT;
import static com.example.android.wearable.quiz.Constants.NUM_INCORRECT;
import static com.example.android.wearable.quiz.Constants.NUM_SKIPPED;
import static com.example.android.wearable.quiz.Constants.QUESTION;
import static com.example.android.wearable.quiz.Constants.QUESTION_INDEX;
import static com.example.android.wearable.quiz.Constants.QUESTION_WAS_ANSWERED;
import static com.example.android.wearable.quiz.Constants.QUESTION_WAS_DELETED;
import static com.example.android.wearable.quiz.Constants.QUIZ_ENDED_PATH;
import static com.example.android.wearable.quiz.Constants.QUIZ_EXITED_PATH;
import static com.example.android.wearable.quiz.Constants.RESET_QUIZ_PATH;
import android.app.Activity;
import android.graphics.Color;
import android.net.Uri;
import android.os.Bundle;
import android.util.Log;
import android.view.LayoutInflater;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.LinearLayout;
import android.widget.RadioGroup;
import android.widget.TextView;
import com.google.android.gms.common.ConnectionResult;
import com.google.android.gms.common.api.GoogleApiClient;
import com.google.android.gms.common.api.GoogleApiClient.ConnectionCallbacks;
import com.google.android.gms.common.api.ResultCallback;
import com.google.android.gms.common.data.FreezableUtils;
import com.google.android.gms.wearable.DataApi;
import com.google.android.gms.wearable.DataEvent;
import com.google.android.gms.wearable.DataEventBuffer;
import com.google.android.gms.wearable.DataItem;
import com.google.android.gms.wearable.DataItemBuffer;
import com.google.android.gms.wearable.DataMap;
import com.google.android.gms.wearable.DataMapItem;
import com.google.android.gms.wearable.MessageApi;
import com.google.android.gms.wearable.MessageEvent;
import com.google.android.gms.wearable.Node;
import com.google.android.gms.wearable.NodeApi;
import com.google.android.gms.wearable.PutDataMapRequest;
import com.google.android.gms.wearable.PutDataRequest;
import com.google.android.gms.wearable.Wearable;
import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.PriorityQueue;
/**
* Allows the user to create questions, which will be put as notifications on the watch's stream.
* The status of questions will be updated on the phone when the user answers them.
*/
public class MainActivity extends Activity implements DataApi.DataListener,
MessageApi.MessageListener, ConnectionCallbacks,
GoogleApiClient.OnConnectionFailedListener {
private static final String TAG = "ExampleQuizApp";
private static final String QUIZ_JSON_FILE = "Quiz.json";
// Various UI components.
private EditText questionEditText;
private EditText choiceAEditText;
private EditText choiceBEditText;
private EditText choiceCEditText;
private EditText choiceDEditText;
private RadioGroup choicesRadioGroup;
private TextView quizStatus;
private LinearLayout quizButtons;
private LinearLayout questionsContainer;
private Button readQuizFromFileButton;
private Button resetQuizButton;
private GoogleApiClient mGoogleApiClient;
private PriorityQueue<Question> mFutureQuestions;
private int mQuestionIndex = 0;
private boolean mHasQuestionBeenAsked = false;
// Data to display in end report.
private int mNumCorrect = 0;
private int mNumIncorrect = 0;
private int mNumSkipped = 0;
private static final Map<Integer, Integer> radioIdToIndex;
static {
Map<Integer, Integer> temp = new HashMap<Integer, Integer>(4);
temp.put(R.id.choice_a_radio, 0);
temp.put(R.id.choice_b_radio, 1);
temp.put(R.id.choice_c_radio, 2);
temp.put(R.id.choice_d_radio, 3);
radioIdToIndex = Collections.unmodifiableMap(temp);
}
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
mGoogleApiClient = new GoogleApiClient.Builder(this)
.addApi(Wearable.API)
.addConnectionCallbacks(this)
.addOnConnectionFailedListener(this)
.build();
mFutureQuestions = new PriorityQueue<Question>(10);
// Find UI components to be used later.
questionEditText = (EditText) findViewById(R.id.question_text);
choiceAEditText = (EditText) findViewById(R.id.choice_a_text);
choiceBEditText = (EditText) findViewById(R.id.choice_b_text);
choiceCEditText = (EditText) findViewById(R.id.choice_c_text);
choiceDEditText = (EditText) findViewById(R.id.choice_d_text);
choicesRadioGroup = (RadioGroup) findViewById(R.id.choices_radio_group);
quizStatus = (TextView) findViewById(R.id.quiz_status);
quizButtons = (LinearLayout) findViewById(R.id.quiz_buttons);
questionsContainer = (LinearLayout) findViewById(R.id.questions_container);
readQuizFromFileButton = (Button) findViewById(R.id.read_quiz_from_file_button);
resetQuizButton = (Button) findViewById(R.id.reset_quiz_button);
}
@Override
protected void onStart() {
super.onStart();
if (!mGoogleApiClient.isConnected()) {
mGoogleApiClient.connect();
}
}
@Override
protected void onStop() {
Wearable.DataApi.removeListener(mGoogleApiClient, this);
Wearable.MessageApi.removeListener(mGoogleApiClient, this);
// Tell the wearable to end the quiz (counting unanswered questions as skipped), and then
// disconnect mGoogleApiClient.
DataMap dataMap = new DataMap();
dataMap.putInt(NUM_CORRECT, mNumCorrect);
dataMap.putInt(NUM_INCORRECT, mNumIncorrect);
if (mHasQuestionBeenAsked) {
mNumSkipped += 1;
}
mNumSkipped += mFutureQuestions.size();
dataMap.putInt(NUM_SKIPPED, mNumSkipped);
if (mNumCorrect + mNumIncorrect + mNumSkipped > 0) {
sendMessageToWearable(QUIZ_EXITED_PATH, dataMap.toByteArray());
}
clearQuizStatus();
super.onStop();
}
@Override
public void onConnected(Bundle connectionHint) {
Wearable.DataApi.addListener(mGoogleApiClient, this);
Wearable.MessageApi.addListener(mGoogleApiClient, this);
}
@Override
public void onConnectionSuspended(int cause) {
// Ignore
}
@Override
public void onConnectionFailed(ConnectionResult result) {
Log.e(TAG, "Failed to connect to Google Play Services");
}
@Override
public void onMessageReceived(MessageEvent messageEvent) {
if (messageEvent.getPath().equals(RESET_QUIZ_PATH)) {
runOnUiThread(new Runnable() {
@Override
public void run() {
resetQuiz(null);
}
});
}
}
/**
* Used to ensure questions with smaller indexes come before questions with larger
* indexes. For example, question0 should come before question1.
*/
private static class Question implements Comparable<Question> {
private String question;
private int questionIndex;
private String[] answers;
private int correctAnswerIndex;
public Question(String question, int questionIndex, String[] answers,
int correctAnswerIndex) {
this.question = question;
this.questionIndex = questionIndex;
this.answers = answers;
this.correctAnswerIndex = correctAnswerIndex;
}
public static Question fromJson(JSONObject questionObject, int questionIndex)
throws JSONException {
String question = questionObject.getString(JsonUtils.JSON_FIELD_QUESTION);
JSONArray answersJsonArray = questionObject.getJSONArray(JsonUtils.JSON_FIELD_ANSWERS);
String[] answers = new String[JsonUtils.NUM_ANSWER_CHOICES];
for (int j = 0; j < answersJsonArray.length(); j++) {
answers[j] = answersJsonArray.getString(j);
}
int correctIndex = questionObject.getInt(JsonUtils.JSON_FIELD_CORRECT_INDEX);
return new Question(question, questionIndex, answers, correctIndex);
}
@Override
public int compareTo(Question that) {
return this.questionIndex - that.questionIndex;
}
public PutDataRequest toPutDataRequest() {
PutDataMapRequest request = PutDataMapRequest.create("/question/" + questionIndex);
DataMap dataMap = request.getDataMap();
dataMap.putString(QUESTION, question);
dataMap.putInt(QUESTION_INDEX, questionIndex);
dataMap.putStringArray(ANSWERS, answers);
dataMap.putInt(CORRECT_ANSWER_INDEX, correctAnswerIndex);
return request.asPutDataRequest();
}
}
/**
* Create a quiz, as defined in Quiz.json, when the user clicks on "Read quiz from file."
* @throws IOException
*/
public void readQuizFromFile(View view) throws IOException, JSONException {
clearQuizStatus();
JSONObject jsonObject = JsonUtils.loadJsonFile(this, QUIZ_JSON_FILE);
JSONArray jsonArray = jsonObject.getJSONArray(JsonUtils.JSON_FIELD_QUESTIONS);
for (int i = 0; i < jsonArray.length(); i++) {
JSONObject questionObject = jsonArray.getJSONObject(i);
Question question = Question.fromJson(questionObject, mQuestionIndex++);
addQuestionDataItem(question);
setNewQuestionStatus(question.question);
}
}
/**
* Adds a question (with answer choices) when user clicks on "Add Question."
*/
public void addQuestion(View view) {
// Retrieve the question and answers supplied by the user.
String question = questionEditText.getText().toString();
String[] answers = new String[4];
answers[0] = choiceAEditText.getText().toString();
answers[1] = choiceBEditText.getText().toString();
answers[2] = choiceCEditText.getText().toString();
answers[3] = choiceDEditText.getText().toString();
int correctAnswerIndex = radioIdToIndex.get(choicesRadioGroup.getCheckedRadioButtonId());
addQuestionDataItem(new Question(question, mQuestionIndex++, answers, correctAnswerIndex));
setNewQuestionStatus(question);
// Clear the edit boxes to let the user input a new question.
questionEditText.setText("");
choiceAEditText.setText("");
choiceBEditText.setText("");
choiceCEditText.setText("");
choiceDEditText.setText("");
}
/**
* Adds the questions (and answers) to the wearable's stream by creating a Data Item
* that will be received on the wearable, which will create corresponding notifications.
*/
private void addQuestionDataItem(Question question) {
if (!mHasQuestionBeenAsked) {
// Ask the question now.
Wearable.DataApi.putDataItem(mGoogleApiClient, question.toPutDataRequest());
setHasQuestionBeenAsked(true);
} else {
// Enqueue the question to be asked in the future.
mFutureQuestions.add(question);
}
}
/**
* Sets the question's status to be the default "unanswered." This will be updated when the
* user chooses an answer for the question on the wearable.
*/
private void setNewQuestionStatus(String question) {
quizStatus.setVisibility(View.VISIBLE);
quizButtons.setVisibility(View.VISIBLE);
LayoutInflater inflater = LayoutInflater.from(this);
View questionStatusElem = inflater.inflate(R.layout.question_status_element, null, false);
((TextView) questionStatusElem.findViewById(R.id.question)).setText(question);
((TextView) questionStatusElem.findViewById(R.id.status))
.setText(R.string.question_unanswered);
questionsContainer.addView(questionStatusElem);
}
@Override
public void onDataChanged(DataEventBuffer dataEvents) {
final List<DataEvent> events = FreezableUtils.freezeIterable(dataEvents);
dataEvents.close();
runOnUiThread(new Runnable() {
@Override
public void run() {
for (DataEvent event : events) {
if (event.getType() == DataEvent.TYPE_CHANGED) {
DataMap dataMap = DataMapItem.fromDataItem(event.getDataItem())
.getDataMap();
boolean questionWasAnswered = dataMap.getBoolean(QUESTION_WAS_ANSWERED);
boolean questionWasDeleted = dataMap.getBoolean(QUESTION_WAS_DELETED);
if (questionWasAnswered) {
// Update the answered question's status.
int questionIndex = dataMap.getInt(QUESTION_INDEX);
boolean questionCorrect = dataMap.getBoolean(CHOSEN_ANSWER_CORRECT);
updateQuestionStatus(questionIndex, questionCorrect);
askNextQuestionIfExists();
} else if (questionWasDeleted) {
// Update the deleted question's status by marking it as left blank.
int questionIndex = dataMap.getInt(QUESTION_INDEX);
markQuestionLeftBlank(questionIndex);
askNextQuestionIfExists();
}
}
}
}
});
}
/**
* Updates the given question based on whether it was answered correctly or not.
* This involves changing the question's text color and changing the status text for it.
*/
public void updateQuestionStatus(int questionIndex, boolean questionCorrect) {
LinearLayout questionStatusElement = (LinearLayout)
questionsContainer.getChildAt(questionIndex);
TextView questionText = (TextView) questionStatusElement.findViewById(R.id.question);
TextView questionStatus = (TextView) questionStatusElement.findViewById(R.id.status);
if (questionCorrect) {
questionText.setTextColor(Color.GREEN);
questionStatus.setText(R.string.question_correct);
mNumCorrect++;
} else {
questionText.setTextColor(Color.RED);
questionStatus.setText(R.string.question_incorrect);
mNumIncorrect++;
}
}
/**
* Marks a question as "left blank" when its corresponding question notification is deleted.
*/
private void markQuestionLeftBlank(int index) {
LinearLayout questionStatusElement = (LinearLayout) questionsContainer.getChildAt(index);
if (questionStatusElement != null) {
TextView questionText = (TextView) questionStatusElement.findViewById(R.id.question);
TextView questionStatus = (TextView) questionStatusElement.findViewById(R.id.status);
if (questionStatus.getText().equals(getString(R.string.question_unanswered))) {
questionText.setTextColor(Color.YELLOW);
questionStatus.setText(R.string.question_left_blank);
mNumSkipped++;
}
}
}
/**
* Asks the next enqueued question if it exists, otherwise ends the quiz.
*/
private void askNextQuestionIfExists() {
if (mFutureQuestions.isEmpty()) {
// Quiz has been completed - send message to wearable to display end report.
DataMap dataMap = new DataMap();
dataMap.putInt(NUM_CORRECT, mNumCorrect);
dataMap.putInt(NUM_INCORRECT, mNumIncorrect);
dataMap.putInt(NUM_SKIPPED, mNumSkipped);
sendMessageToWearable(QUIZ_ENDED_PATH, dataMap.toByteArray());
setHasQuestionBeenAsked(false);
} else {
// Ask next question by putting a DataItem that will be received on the wearable.
Wearable.DataApi.putDataItem(mGoogleApiClient,
mFutureQuestions.remove().toPutDataRequest());
setHasQuestionBeenAsked(true);
}
}
private void sendMessageToWearable(final String path, final byte[] data) {
Wearable.NodeApi.getConnectedNodes(mGoogleApiClient).setResultCallback(
new ResultCallback<NodeApi.GetConnectedNodesResult>() {
@Override
public void onResult(NodeApi.GetConnectedNodesResult nodes) {
for (Node node : nodes.getNodes()) {
Wearable.MessageApi.sendMessage(mGoogleApiClient, node.getId(), path, data);
}
if (path.equals(QUIZ_EXITED_PATH) && mGoogleApiClient.isConnected()) {
mGoogleApiClient.disconnect();
}
}
});
}
/**
* Resets the current quiz when Reset Quiz is pressed.
*/
public void resetQuiz(View view) {
// Reset quiz status in phone layout.
for(int i = 0; i < questionsContainer.getChildCount(); i++) {
LinearLayout questionStatusElement = (LinearLayout) questionsContainer.getChildAt(i);
TextView questionText = (TextView) questionStatusElement.findViewById(R.id.question);
TextView questionStatus = (TextView) questionStatusElement.findViewById(R.id.status);
questionText.setTextColor(Color.WHITE);
questionStatus.setText(R.string.question_unanswered);
}
// Reset data items and notifications on wearable.
if (mGoogleApiClient.isConnected()) {
Wearable.DataApi.getDataItems(mGoogleApiClient)
.setResultCallback(new ResultCallback<DataItemBuffer>() {
@Override
public void onResult(DataItemBuffer result) {
if (result.getStatus().isSuccess()) {
List<DataItem> dataItemList = FreezableUtils.freezeIterable(result);
result.close();
resetDataItems(dataItemList);
} else {
if (Log.isLoggable(TAG, Log.DEBUG)) {
Log.d(TAG, "Reset quiz: failed to get Data Items to reset");
}
}
result.close();
}
});
} else {
Log.e(TAG, "Failed to reset data items because client is disconnected from "
+ "Google Play Services");
}
setHasQuestionBeenAsked(false);
mNumCorrect = 0;
mNumIncorrect = 0;
mNumSkipped = 0;
}
private void resetDataItems(List<DataItem> dataItemList) {
if (mGoogleApiClient.isConnected()) {
for (final DataItem dataItem : dataItemList) {
final Uri dataItemUri = dataItem.getUri();
Wearable.DataApi.getDataItem(mGoogleApiClient, dataItemUri)
.setResultCallback(new ResetDataItemCallback());
}
} else {
Log.e(TAG, "Failed to reset data items because client is disconnected from "
+ "Google Play Services");
}
}
/**
* Callback that marks a DataItem, which represents a question, as unanswered and not deleted.
*/
private class ResetDataItemCallback implements ResultCallback<DataApi.DataItemResult> {
@Override
public void onResult(DataApi.DataItemResult dataItemResult) {
if (dataItemResult.getStatus().isSuccess()) {
PutDataMapRequest request = PutDataMapRequest.createFromDataMapItem(
DataMapItem.fromDataItem(dataItemResult.getDataItem()));
DataMap dataMap = request.getDataMap();
dataMap.putBoolean(QUESTION_WAS_ANSWERED, false);
dataMap.putBoolean(QUESTION_WAS_DELETED, false);
if (!mHasQuestionBeenAsked && dataMap.getInt(QUESTION_INDEX) == 0) {
// Ask the first question now.
Wearable.DataApi.putDataItem(mGoogleApiClient, request.asPutDataRequest());
setHasQuestionBeenAsked(true);
} else {
// Enqueue future questions.
mFutureQuestions.add(new Question(dataMap.getString(QUESTION),
dataMap.getInt(QUESTION_INDEX), dataMap.getStringArray(ANSWERS),
dataMap.getInt(CORRECT_ANSWER_INDEX)));
}
} else {
Log.e(TAG, "Failed to reset data item " + dataItemResult.getDataItem().getUri());
}
}
}
/**
* Clears the current quiz when user clicks on "New Quiz."
* On this end, this involves clearing the quiz status layout and deleting all DataItems. The
* wearable will then remove any outstanding question notifications upon receiving this change.
*/
public void newQuiz(View view) {
clearQuizStatus();
if (mGoogleApiClient.isConnected()) {
Wearable.DataApi.getDataItems(mGoogleApiClient)
.setResultCallback(new ResultCallback<DataItemBuffer>() {
@Override
public void onResult(DataItemBuffer result) {
if (result.getStatus().isSuccess()) {
List<Uri> dataItemUriList = new ArrayList<Uri>();
for (final DataItem dataItem : result) {
dataItemUriList.add(dataItem.getUri());
}
result.close();
deleteDataItems(dataItemUriList);
} else {
if (Log.isLoggable(TAG, Log.DEBUG)) {
Log.d(TAG, "Clear quiz: failed to get Data Items for deletion");
}
}
result.close();
}
});
} else {
Log.e(TAG, "Failed to delete data items because client is disconnected from "
+ "Google Play Services");
}
}
/**
* Removes quiz status views (i.e. the views describing the status of each question).
*/
private void clearQuizStatus() {
questionsContainer.removeAllViews();
quizStatus.setVisibility(View.INVISIBLE);
quizButtons.setVisibility(View.INVISIBLE);
setHasQuestionBeenAsked(false);
mFutureQuestions.clear();
mQuestionIndex = 0;
mNumCorrect = 0;
mNumIncorrect = 0;
mNumSkipped = 0;
}
private void deleteDataItems(List<Uri> dataItemUriList) {
if (mGoogleApiClient.isConnected()) {
for (final Uri dataItemUri : dataItemUriList) {
Wearable.DataApi.deleteDataItems(mGoogleApiClient, dataItemUri)
.setResultCallback(new ResultCallback<DataApi.DeleteDataItemsResult>() {
@Override
public void onResult(DataApi.DeleteDataItemsResult deleteResult) {
if (Log.isLoggable(TAG, Log.DEBUG)) {
if (deleteResult.getStatus().isSuccess()) {
Log.d(TAG, "Successfully deleted data item " + dataItemUri);
} else {
Log.d(TAG, "Failed to delete data item " + dataItemUri);
}
}
}
});
}
} else {
Log.e(TAG, "Failed to delete data items because client is disconnected from "
+ "Google Play Services");
}
}
private void setHasQuestionBeenAsked(boolean b) {
mHasQuestionBeenAsked = b;
// Only let user click on Reset or Read from file if they have answered all the questions.
readQuizFromFileButton.setEnabled(!mHasQuestionBeenAsked);
resetQuizButton.setEnabled(!mHasQuestionBeenAsked);
}
}