@Override public void onDataChanged(DataEventBuffer dataEvents) { Log.d(LOG_TAG, " in data changed"); for (DataEvent event : dataEvents) { if (event.getType() == DataEvent.TYPE_CHANGED) { // DataItem changed DataItem item = event.getDataItem(); if (item.getUri().getPath().compareTo(WEATHER_PATH) == 0) { DataMap dataMap = DataMapItem.fromDataItem(item).getDataMap(); weather_id = dataMap.getInt(WEATHER_ID); high_temp = dataMap.getDouble(HIGH_TEMP); low_temp = dataMap.getDouble(LOW_TEMP); } } else if (event.getType() == DataEvent.TYPE_DELETED) { // DataItem deleted } } invalidate(); }
@Override public void onDataChanged(DataEventBuffer dataEvents) { LOGD(TAG, "onDataChanged: " + dataEvents + " for " + getPackageName()); for (DataEvent event : dataEvents) { LOGD(TAG, "Uri is: " + event.getDataItem().getUri()); DataMapItem mapItem = DataMapItem.fromDataItem(event.getDataItem()); String path = event.getDataItem().getUri().getPath(); if (event.getType() == DataEvent.TYPE_CHANGED) { if (PATH_RESPONSE.equals(path)) { // we have a response DataMap data = mapItem.getDataMap(); saveFeedback(data); } } else if (event.getType() == DataEvent.TYPE_DELETED) { if (path.startsWith(SessionAlarmService.PATH_FEEDBACK)) { Uri uri = event.getDataItem().getUri(); dismissLocalNotification(uri.getLastPathSegment()); } } } }
/** * This method is activated when a data is receive from the phone * @param dataEvents */ @Override public void onDataChanged(DataEventBuffer dataEvents) { DataMap dataMap; for (DataEvent event : dataEvents) { // Check the data type if (event.getType() == DataEvent.TYPE_CHANGED) { // Check the data path dataMap = DataMapItem.fromDataItem(event.getDataItem()).getDataMap(); //get the new rule send by the phone CustomRules rule= getRuleFromMap(dataMap); //save the rule in the database RulesRepository.getInstance().insertOrUpdate(rule); //send the value to the activty to change the display of bar Intent messageIntent = new Intent(); messageIntent.setAction(Intent.ACTION_SEND); messageIntent.putExtra(Const.KEY_BROADCASTdATA, dataMap.toBundle()); LocalBroadcastManager.getInstance(this).sendBroadcast(messageIntent); } } }
@Override public void onDataChanged(DataEventBuffer dataEvents) { super.onDataChanged(dataEvents); for (DataEvent event : dataEvents) { if (event.getType() == DataEvent.TYPE_CHANGED) { // DataItem changed DataItem item = event.getDataItem(); if (item.getUri().getPath().compareTo("/SHAKEINTENSITY") == 0) { DataMap dataMap = DataMapItem.fromDataItem(item).getDataMap(); Log.e("Data Event", "value->"+dataMap.getString(SHAKE_INTENSITY_KEY)); LocalStoreUtils.setShakeIntensity(dataMap.getString(SHAKE_INTENSITY_KEY), this); } } } }
@Override public void onDataChanged(DataEventBuffer dataEvents) { for (DataEvent dataEvent : dataEvents) { if (dataEvent.getType() == DataEvent.TYPE_CHANGED) { if (ZabbkitConstants.PATH_DATA_REQUEST.equals(dataEvent.getDataItem().getUri().getPath())) { Map<String, Object> params = new ArrayMap<String, Object>(); params.put(Constants.REQ_SELECT_HOSTS, new String[]{ Constants.REQ_VAL_HOST_ID, Constants.REQ_VAL_HOST}); params.put(Constants.REQ_SORT_FIELD, Constants.REQ_VAL_DESCRIPTION); params.put(Constants.REQ_OUTPUT, Constants.REQ_VAL_EXTEND); params.put(Constants.REQ_MONITORED, true); params.put(Constants.REQ_EXPAND_DESCRIPTION, true); Communicator.getInstance().getTriggers(params, this); } } } }
@Override public void onDataChanged(DataEventBuffer dataEvents) { for (int i = 0; i < dataEvents.getCount(); i++) { DataEvent event = dataEvents.get(i); if (event.getType() == DataEvent.TYPE_CHANGED && event.getDataItem().getUri().getPath().equals(APP_DATA_UPDATE_REQUEST)) { DataMap dataMap = DataMapItem.fromDataItem(event.getDataItem()).getDataMap(); Asset asset = dataMap.getAsset("dataIcon"); WatchFaceService.highTemp = dataMap.getInt("dataHigh"); WatchFaceService.lowTemp = dataMap.getInt("dataLow"); doLoadBitmap(asset); } } }
@Override // DataApi.DataListener public void onDataChanged(DataEventBuffer dataEvents) { Log.d(TAG, "Data changed"); for (DataEvent dataEvent : dataEvents) { if (dataEvent.getType() != DataEvent.TYPE_CHANGED) { continue; } DataItem dataItem = dataEvent.getDataItem(); if (!dataItem.getUri().getPath().equals( ConfigurationHelper.PATH_WITH_FEATURE)) { continue; } DataMapItem dataMapItem = DataMapItem.fromDataItem(dataItem); DataMap config = dataMapItem.getDataMap(); Log.d(TAG, "Config DataItem updated:" + config); // This can happen from this method more often when phone changes updateUiForConfigDataMap(config); } }
@Override // DataApi.DataListener public void onDataChanged(DataEventBuffer dataEvents) { for (DataEvent dataEvent : dataEvents) { if (dataEvent.getType() != DataEvent.TYPE_CHANGED) { continue; } DataItem dataItem = dataEvent.getDataItem(); if (!dataItem.getUri().getPath().equals( WatchFaceUtil.PATH_WITH_FEATURE)) { continue; } DataMapItem dataMapItem = DataMapItem.fromDataItem(dataItem); DataMap config = dataMapItem.getDataMap(); Log.d(TAG, "Config DataItem updated:" + config); updateUiForConfigDataMap(config); } }
@Override // DataApi.DataListener public void onDataChanged(DataEventBuffer dataEvents) { Log.d(TAG,"onDataChanged "+dataEvents); for (DataEvent dataEvent : dataEvents) { if (dataEvent.getType() != DataEvent.TYPE_CHANGED) { continue; } DataItem dataItem = dataEvent.getDataItem(); if (!dataItem.getUri().getPath().equals(WatchFaceUtil.PATH_WITH_FEATURE)) { continue; } DataMapItem dataMapItem = DataMapItem.fromDataItem(dataItem); DataMap config = dataMapItem.getDataMap(); Log.d(TAG, "Config DataItem updated:" + config); updateUiForConfigDataMap(config); } }
@Override public void onDataChanged(DataEventBuffer dataEvents) { final List<DataEvent> events = FreezableUtils.freezeIterable(dataEvents); dataEvents.close(); for (DataEvent event : events) { Uri uri = event.getDataItem().getUri(); String path = uri.getPath(); if (WEAR_PATH.equals(path)) { DataMapItem item = DataMapItem.fromDataItem(event.getDataItem()); byte[] realmAsset = item.getDataMap().getByteArray(DATA_ASSET_FILE); if (realmAsset != null) { toFile(realmAsset); getBaseContext().sendBroadcast(new Intent(DATA_STORY_CHANGED)); } } } }
@Override public void onDataChanged(DataEventBuffer dataEvents) { super.onDataChanged(dataEvents); DataMap dataMap = new DataMap(); for(DataEvent dataEvent : dataEvents){ if(dataEvent.getType()==DataEvent.TYPE_CHANGED){ String path = dataEvent.getDataItem().getUri().getPath(); if(path.equalsIgnoreCase(MOBILE_MESSAGE_PATH)){ dataMap = DataMapItem.fromDataItem(dataEvent.getDataItem()).getDataMap(); } } } Intent messageIntent = new Intent(); messageIntent.setAction(Intent.ACTION_SEND); messageIntent.putExtra("datamap", dataMap.toBundle()); LocalBroadcastManager.getInstance(this).sendBroadcast(messageIntent); }
/** * An Observable that emits whenever data changes in the wear datalayer * * @param context * @return Observable that emits DataEventBuffer */ public static Observable<DataEventBuffer> getDataEvents(Context context) { return getGoogleApiClient(context) .flatMap(new Func1<GoogleApiClient, Observable<DataEventBuffer>>() { @Override public Observable<DataEventBuffer> call(final GoogleApiClient googleApiClient) { return Observable.create(new Observable.OnSubscribe<DataEventBuffer>() { @Override public void call(final Subscriber<? super DataEventBuffer> subscriber) { Wearable.DataApi.addListener(googleApiClient, new DataApi.DataListener() { @Override public void onDataChanged(DataEventBuffer dataEventBuffer) { subscriber.onNext(dataEventBuffer); } }); } }); } }); }
@Override public void onDataChanged(DataEventBuffer dataEvents) {//KS does not seem to get triggered; therefore use OnMessageReceived instead DataMap dataMap; for (DataEvent event : dataEvents) { if (event.getType() == DataEvent.TYPE_CHANGED) { String path = event.getDataItem().getUri().getPath(); switch (path) { case WEARABLE_PREF_DATA_PATH: dataMap = DataMapItem.fromDataItem(event.getDataItem()).getDataMap(); if (dataMap != null) { Log.d(TAG, "onDataChanged WEARABLE_PREF_DATA_PATH dataMap=" + dataMap); syncPrefData(dataMap); } break; default: Log.d(TAG, "Unknown wearable path: " + path); break; } } } }
@Override public void onDataChanged(DataEventBuffer dataEventBuffer) { Log.d(LOG_TAG, "Weather data has been changed!"); for (DataEvent event : dataEventBuffer) { DataItem item = event.getDataItem(); if (WEATHER_DATA_PATH.equals(item.getUri().getPath())) { DataMap dataMap = DataMapItem.fromDataItem(item).getDataMap(); double high = dataMap.getDouble(WEATHER_DATA_HIGH); double low = dataMap.getDouble(WEATHER_DATA_LOW); long id = dataMap.getLong(WEATHER_DATA_ID); mWeather = (int) Math.round(high) + "/" + (int) Math.round(low); mWeatherId = (int) id; loadIconForWeatherId(); SharedPreferences preferences = getSharedPreferences(PREFERENCES, MODE_PRIVATE); SharedPreferences.Editor editor = preferences.edit(); editor.putString(KEY_WEATHER, mWeather); editor.putInt(KEY_WEATHER_ID, mWeatherId); editor.apply(); } } }
@Override public void onDataChanged(DataEventBuffer dataEvents) { Log.d(LOG_TAG, "onDataChanged" ); for (DataEvent dataEvent : dataEvents) { if (DataEvent.TYPE_CHANGED == dataEvent.getType()) { DataItem dataItem = dataEvent.getDataItem(); DataMap dataMap = DataMapItem.fromDataItem(dataItem).getDataMap(); String path = dataEvent.getDataItem().getUri().getPath(); if (path.equals(WEATHER_PATH)) { Log.d(LOG_TAG, "/weather id=" + dataMap.getString(KEY_UUID)); SunshineSyncAdapter.syncImmediately(this); } } } }
/** * Called whenever a new message sent by the Wearable. * * @param dataEvents buffer with transmitted data */ @Override public void onDataChanged(DataEventBuffer dataEvents) { Log.i(TAG, "onDataChanged()"); for (DataEvent dataEvent : dataEvents) { if (dataEvent.getType() == DataEvent.TYPE_CHANGED) { DataItem dataItem = dataEvent.getDataItem(); Uri uri = dataItem.getUri(); String path = uri.getPath(); if (path.startsWith("/sensors/")) { if (SmartWatch.getInstance() != null) { SmartWatch.getInstance().unpackSensorData(DataMapItem.fromDataItem(dataItem).getDataMap()); } } } } }
@Override public void onDataChanged(DataEventBuffer dataEvents) { Log.i("DEV", "Wear: MainActivity.onDataChangeListener"); for (DataEvent event : dataEvents) { if (event.getType() == DataEvent.TYPE_CHANGED) { // DataItem changed DataItem item = event.getDataItem(); if (item.getUri().getPath().compareTo("/stayawhile/queue") == 0) { DataMap dataMap = DataMapItem.fromDataItem(item).getDataMap(); queueUpdated(dataMap.getString(QUEUE_KEY)); } } else if (event.getType() == DataEvent.TYPE_DELETED) { // DataItem deleted } } }
@Override public void onDataChanged(DataEventBuffer dataEvents) { DataMap dataMap; for (DataEvent event : dataEvents) { Log.v("myTag", "DataMap received on watch: " + DataMapItem.fromDataItem(event.getDataItem()).getDataMap()); // Check the data type if (event.getType() == DataEvent.TYPE_CHANGED) { // Check the data path String path = event.getDataItem().getUri().getPath(); if (path.equals(WEARABLE_DATA_PATH)) {} dataMap = DataMapItem.fromDataItem(event.getDataItem()).getDataMap(); // Broadcast DataMap contents to wearable activity for display // The content has the golf hole number and distances to the front, // middle and back pin placements. Intent messageIntent = new Intent(); messageIntent.setAction(Intent.ACTION_SEND); messageIntent.putExtra("datamap", dataMap.toBundle()); LocalBroadcastManager.getInstance(this).sendBroadcast(messageIntent); } } }
@Override public void onDataChanged(DataEventBuffer dataEvents) { for (DataEvent event : dataEvents) { if (event.getType() == DataEvent.TYPE_CHANGED) { // Check the data path String path = event.getDataItem().getUri().getPath(); if (WearableApi.SETTINGS.equals(path)) { HashMap<String, String> newSettings = new HashMap<>(); DataMap dataMap = DataMapItem.fromDataItem(event.getDataItem()).getDataMap(); for (String key : dataMap.keySet()) { newSettings.put(key, dataMap.getString(key, null)); PreferencesUtil.putString(this, key, newSettings.get(key)); } WearableApi.sendMessage(mGoogleApiClient, WearableApi.SETTINGS, PreferencesUtil.toString(newSettings), null); sendStatus(mGoogleApiClient); } } } }
@Override public void onDataChanged(DataEventBuffer dataEvents) { if (debugMode) Log.d(TAG, "data event happened"); for (DataEvent event : dataEvents) { if (debugMode) Log.d(TAG, event.getDataItem().getUri().getPath()); if (event.getType() == DataEvent.TYPE_CHANGED && event.getDataItem().getUri().getPath().contains(Statics.DATAIGC)) { getStringFromAsset(event.getDataItem()); } if (event.getType() == DataEvent.TYPE_CHANGED && event.getDataItem().getUri().getPath().contains(Statics.DATATHROWABLE)) { getExceptionFromWear(event.getDataItem()); } if (event.getType() == DataEvent.TYPE_CHANGED && event.getDataItem().getUri().getPath().contains(Statics.DATABTFAILED)) { getBTFailed(event.getDataItem()); } } }
@Override public void onDataChanged(DataEventBuffer dataEventBuffer) { for (DataEvent dataEvent : dataEventBuffer) { if (dataEvent.getType() != DataEvent.TYPE_CHANGED) { continue; } DataItem dataItem = dataEvent.getDataItem(); if (!dataItem.getUri().getPath().equals( DigitalWatchFaceUtil.PATH_WITH_FEATURE)) { continue; } DataMapItem dataMapItem = DataMapItem.fromDataItem(dataItem); DataMap config = dataMapItem.getDataMap(); Log.d("WatchFace", "Config DataItem updated:" + config); updateUiForConfigDataMap(config); } }
@Override public void onDataChanged(DataEventBuffer dataEventBuffer) { if (dataEventBuffer == null) { weatherInformationListener.onWeatherInformationFetchFailure(); return; } for (DataEvent dataEvent : dataEventBuffer) { if (doesHaveWeatherData(dataEvent)) { DataMap weatherDataMap = getWeatherDataMap(dataEvent); Double high = weatherDataMap.getDouble(WeatherRequestKeys.HIGH); Double low = weatherDataMap.getDouble(WeatherRequestKeys.LOW); weatherInformationListener.onTemperatureFetchSuccess(high, low); fetchWeatherIconAsynchronously(weatherDataMap); return; } } }
@Override public void onDataChanged(DataEventBuffer dataEvents) { for (DataEvent event : dataEvents) { if (event.getType() == DataEvent.TYPE_CHANGED) { DataItem dataItem = event.getDataItem(); switch (Message.getMessageType(dataItem)) { case ACTION_TYPE: int productAction = Message.decodeActionTypeMessage(dataItem); onActionTypeChanged(productAction); break; case INTERACTION_TYPE: int interactionType = Message.decodeInteractionTypeMessage(dataItem); onInteractionTypeChanged(interactionType); break; } } } }
@Override public void onDataChanged(DataEventBuffer dataEvents) { for (DataEvent dataEvent : dataEvents) { if (dataEvent.getType() == DataEvent.TYPE_CHANGED) { DataItem dataItem = dataEvent.getDataItem(); Uri uri = dataItem.getUri(); String path = uri.getPath(); if (path.startsWith("/sensors/")) { unpackSensorData( Integer.parseInt(uri.getLastPathSegment()), DataMapItem.fromDataItem(dataItem).getDataMap() ); } } } }
@Override public void onDataChanged(DataEventBuffer dataEventBuffer) { Log.i("WATCH", "onDataChanged"); for (DataEvent event : dataEventBuffer) { if (event.getType() == DataEvent.TYPE_CHANGED) { // DataItem changed DataItem item = event.getDataItem(); if (item.getUri().getPath().compareTo(DATA_PATH) == 0) { DataMap dataMap = DataMapItem.fromDataItem(item).getDataMap(); extractWeatherData(dataMap); } } else if (event.getType() == DataEvent.TYPE_DELETED) { // DataItem deleted } } }
@Override public void onDataChanged(DataEventBuffer dataEventBuffer) { Log.d(TAG, "onDataChanged"); for (DataEvent event : dataEventBuffer) { if (event.getType() == DataEvent.TYPE_CHANGED) { // DataItem changed DataItem item = event.getDataItem(); String path = item.getUri().getPath(); Log.d(TAG, "path: " + path); if (path.equals(REQ_PATH)) { DataMap dataMap = DataMapItem.fromDataItem(item).getDataMap(); mWeatherId = dataMap.getInt(KEY_WEATHER_ID); mMaxTemperature = dataMap.getDouble(KEY_TEMP_MAX); mMinTemperature = dataMap.getDouble(KEY_TEMP_MIN); mLocation = dataMap.getString(KEY_LOCATION); invalidate(); } } } dataEventBuffer.release(); }
@Override public void onDataChanged(DataEventBuffer dataEventBuffer) { final List<DataEvent> events = FreezableUtils.freezeIterable(dataEventBuffer); for(DataEvent event : events) { if (WearMessages.MESSAGE_BOT_LIST.equalsIgnoreCase(event.getDataItem().getUri().getPath())) { final DataMap map = DataMapItem.fromDataItem(event.getDataItem()).getDataMap(); ArrayList<DataMap> botList = map.getDataMapArrayList(WearMessages.MAPENTRY_BOT_LIST); WearBot[] bots = new WearBot[botList.size()]; for (int i = 0; i < botList.size(); i++) { bots[i] = new WearBot(botList.get(i)); } getListener().updateBotList(bots); } } }
@Override public void onDataChanged(DataEventBuffer dataEvents) { Log.d(TAG, "onDataChanged"); final List<DataEvent> events = FreezableUtils.freezeIterable(dataEvents); dataEvents.close(); for (DataEvent event : events) { Uri uri = event.getDataItem().getUri(); String path = uri.getPath(); if (Tools.WEAR_PATH.equals(path)) { DataMapItem item = DataMapItem.fromDataItem(event.getDataItem()); byte[] realmAsset = item.getDataMap().getByteArray(Tools.DATA_ASSET_FILE); if(realmAsset != null){ toFile(realmAsset); getBaseContext().sendBroadcast(new Intent(Tools.DATA_STORY_CHANGED)); } } } }
@Override // DataApi.DataListener public void onDataChanged(DataEventBuffer dataEvents) { for (DataEvent dataEvent : dataEvents) { if (dataEvent.getType() != DataEvent.TYPE_CHANGED) { continue; } DataItem dataItem = dataEvent.getDataItem(); if (!dataItem.getUri().getPath().equals( SunsetsWatchFaceUtil.PATH_WITH_FEATURE)) { continue; } DataMapItem dataMapItem = DataMapItem.fromDataItem(dataItem); DataMap config = dataMapItem.getDataMap(); Log.d(TAG, "Config DataItem updated:" + config); updateUiForConfigDataMap(config); } }
@Override // DataApi.DataListener public void onDataChanged(DataEventBuffer dataEvents) { for (DataEvent dataEvent : dataEvents) { if (dataEvent.getType() != DataEvent.TYPE_CHANGED) { continue; } DataItem dataItem = dataEvent.getDataItem(); if (!dataItem.getUri().getPath().equals(SunsetsWatchFaceUtil.PATH_WITH_FEATURE)) { continue; } DataMapItem dataMapItem = DataMapItem.fromDataItem(dataItem); DataMap config = dataMapItem.getDataMap(); if (Log.isLoggable(TAG, Log.DEBUG)) { Log.d(TAG, "Config DataItem updated:" + config); } updateUiForConfigDataMap(config); } }
@Override public void onDataChanged(DataEventBuffer dataEvents) { Log.d(TAG, "onDataChanged: " + dataEvents); final List<DataEvent> events = FreezableUtils.freezeIterable(dataEvents); dataEvents.close(); for (DataEvent event : events) { Log.d(TAG, "Event: " + event.getDataItem().toString()); Uri uri = event.getDataItem().getUri(); String path = uri.getPath(); if (path.equals(Path.GRADE_SYSTEM)) { DataMapItem dataMapItem = DataMapItem.fromDataItem(event.getDataItem()); String gradeSystem = dataMapItem.getDataMap().getString(Path.GRADE_SYSTEM_KEY); if (gradeSystem != null) { SharedPreferences sharedPref = PreferenceManager.getDefaultSharedPreferences(this); SharedPreferences.Editor editor = sharedPref.edit(); editor.putString(Path.PREF_GRAD_SYSTEM_TYPE, gradeSystem); editor.commit(); } } } }
@Override public void onDataChanged(DataEventBuffer dataEvents) { for (DataEvent dataEvent : dataEvents) { String path = dataEvent.getDataItem().getUri().getPath(); Timber.d("Path == %s", path); switch (path) { case Constants.PATH_MOMENT_NOTIFICATION: handleNewMoment(dataEvent); break; case Constants.PATH_FRIEND_ADDED_BACK: handleFriendAddedNotification(dataEvent); break; case Constants.PATH_FRIENDS_REFRESH: handleRefreshFriends(dataEvent); break; default: break; } } }
@Override public void onDataChanged(DataEventBuffer dataEvents) { for (DataEvent event : dataEvents) { if (event.getType() == DataEvent.TYPE_CHANGED) { String path = event.getDataItem().getUri().getPath(); Timber.d("path == %s", path); if (path.equals(Constants.PATH_NEW_MOMENT)) { sendMoment(event); } else if (path.equals(Constants.PATH_FRIENDS_REFRESH_REQUEST)) { try { friendsSync.syncFriends(); } catch (IOException e) { Timber.e(e, "sync friends failed"); } } } } }