Wnlab

User Tools

Site Tools

You are here: start » giraffplus » android-middleware
Trace:
giraffplus:android-middleware

Differences

This shows you the differences between two versions of the page.

Link to this comparison view

Both sides previous revisionPrevious revision
Next revision		Previous revision
giraffplus:android-middleware [2013-10-30 13:38] – [GiraffPlus middleware packages] davidegiraffplus:android-middleware [2014-05-30 16:10] (current) – [GiraffPlus packages] davide
Line 6: Line 6:
  
 Middleware: Middleware:
-  * https://www.dropbox.com/s/gmnlbcx3gb2gn6v/communicationconnector.mqtt.apk +  * https://www.dropbox.com/s/zfcqrvcqtlz934v/gp-communicationconnector-1.0.2.apk (last update on 15-May-2014) 
-  * https://www.dropbox.com/s/8wh3o1km1g61j0i/middleware.apk +  * https://www.dropbox.com/s/pwet4ise2ta3k46/gp-middleware-1.0.2.apk (last update on 15-May-2014) 
- +   
-Tablet application: +  Previous versions: 
-  * https://www.dropbox.com/s/iby1v19tivlwmn3/giraffplus-tablet-1.1.139.apk+  * https://www.dropbox.com/s/gmnlbcx3gb2gn6v/communicationconnector.mqtt.apk (last update on 06-Feb-2014 15.30) 
 +  * https://www.dropbox.com/s/8wh3o1km1g61j0i/middleware.apk (last update on 06-Feb-2014 15.30)
 ===== One-time setup ===== ===== One-time setup =====
 Applications that use this infrastructure require that the middleware application (Android/giraff.android/middleware folder from the svn checkout) and at least one communication connector application (there is only one by now in the communicationconnector.mqtt Android/giraff.android/ folder from the svn checkout) are previously installed to the device. Applications that use this infrastructure require that the middleware application (Android/giraff.android/middleware folder from the svn checkout) and at least one communication connector application (there is only one by now in the communicationconnector.mqtt Android/giraff.android/ folder from the svn checkout) are previously installed to the device.
Line 202: Line 203:
 </code> </code>
  
-The SensorsDescriptors constructor creates a descriptor for the accelerometer sensor present on the device using the **id** taken directly from the database (for sake of consistency with the GiraffPlus ecosystem we choose to publish data on the subtree **sensor/** of the context bus, please respect this constraint):+We called the method sensorsDescriptors.initialize(middleware) in the SensorsService class when we implemented the service connection. This method calls the method to create the sensor descriptors, announces them and then register a listener to be notified about the sensor changes:
  
 <code java> <code java>
-private final static int SENSORS_DELAY = SensorManager.SENSOR_DELAY_NORMAL; +public void initialize(IMiddleware middleware) { 
-private final static SparseArray<String> SENSORS = new SparseArray<String>() +    this.middleware = middleware; 
-private SparseArray<Pair<Sensor, Bundle>> SERVICE_DESCRIPTORS = new SparseArray<Pair<Sensor, Bundle>>(); +    try { 
-private SensorManager sensorManager; +        createSensorDescriptors (); 
-static { +        announce(); 
-    // desirable sensors +        register(); 
-    SENSORS.append(Sensor.TYPE_ACCELEROMETER, "TYPE_ACCELEROMETER"); +    } catch (RemoteException e) { 
-    /*SENSORS.append(Sensor.TYPE_AMBIENT_TEMPERATURE, "TYPE_AMBIENT_TEMPERATURE"); +        Log.e(TAG, "cannot announce"); 
-    SENSORS.append(Sensor.TYPE_GRAVITY, "TYPE_GRAVITY"); +    }
-    SENSORS.append(Sensor.TYPE_GYROSCOPE, "TYPE_GYROSCOPE"); +
-    SENSORS.append(Sensor.TYPE_LIGHT, "TYPE_LIGHT"); +
-    SENSORS.append(Sensor.TYPE_LINEAR_ACCELERATION, "TYPE_LINEAR_ACCELERATION"); +
-    SENSORS.append(Sensor.TYPE_MAGNETIC_FIELD, "TYPE_MAGNETIC_FIELD"); +
-    SENSORS.append(Sensor.TYPE_PRESSURE, "TYPE_PRESSURE"); +
-    SENSORS.append(Sensor.TYPE_PROXIMITY, "TYPE_PROXIMITY"); +
-    SENSORS.append(Sensor.TYPE_RELATIVE_HUMIDITY, "TYPE_RELATIVE_HUMIDITY"); +
-    SENSORS.append(Sensor.TYPE_ROTATION_VECTOR, "TYPE_ROTATION_VECTOR");*/ +
-} +
- +
-public SensorsDescriptors(Context context) { +
-    Sensor sensor; +
-    Bundle serviceDescriptor; +
- +
-    sensorManager = (SensorManager) context.getSystemService(Context.SENSOR_SERVICE); +
- +
-    String id = "5255554d7d1e4f5713ecaa3e"; // Sensor ID obtained from the database +
- +
-    // for each desirable sensor +
-    //for (int i = 0; i < SENSORS.size(); i++) { +
-        int sensorType = SENSORS.keyAt(0);  // In this example, only the accelerometer is used +
- String sensorName = SENSORS.get(sensorType); +
- +
- // probe sensor and add to the list +
- sensor = sensorManager.getDefaultSensor(sensorType); +
- if (sensor != null) { +
-            serviceDescriptor = new Bundle(); +
-            serviceDescriptor.putString("serviceBusTopic", "sensor/" + id); +
-            serviceDescriptor.putString("id", id); +
-            serviceDescriptor.putString("type", sensorName); +
-            serviceDescriptor.putString("category", "sensor"); +
-            serviceDescriptor.putString("contextBusTopic", "sensor/" + id); +
-            serviceDescriptor.putString("description", sensor.toString()); +
-            Bundle[] ba = new Bundle[] {new Bundle (), new Bundle (), new Bundle ()}; +
-            ba[0].putString ("name", "Acc_X"); +
-            ba[0].putString ("unit", "g"); +
-  +
-            ba[1].putString ("name", "Acc_Y"); +
-            ba[1].putString ("unit", "g"); +
- +
-            ba[2].putString ("name", "Acc_z"); +
-            ba[2].putString ("unit", "g"); +
-  +
-            serviceDescriptor.putParcelableArray ("messageFormat", ba); +
-  +
-            serviceDescriptor.putParcelableArray ("recipient", new Bundle[] {}); +
-  +
-            serviceDescriptors.put(sensorType, new Pair<Sensor, Bundle>(sensor, serviceDescriptor)); +
- } +
-    //}+
 } }
 </code> </code>
  
-We called the method sensorsDescriptors.initialize(middleware) in the SensorsService class when we implemented the service connection. This method announce the descriptors created before and register to sensors changes:+The createSensorDescriptors() creates a descriptor for the accelerometer sensor present on the device using the **id** taken directly from the database (for sake of consistency with the GiraffPlus ecosystem we choose to publish data on the subtree **sensor/** of the context bus, please respect this constraint):
  
 <code java> <code java>
-public void initialize(IMiddleware middleware) {+private void createSensorDescriptors () throws RemoteException { 
 +    Sensor sensor; 
     try {     try {
- announce(middleware); +        // Gets all the local sensors in a JSON array 
- register(); +        JSONArray localSensors = new JSONArray (middleware.getSensorsByManufacturer ("ISTI-CNR")); 
-    } catch (RemoteException e) { +  
- Log.e(TAG, "cannot announce");+        // for each desirable sensor 
 +        for (int i = 0; i < sensors.size(); i++) 
 +        { 
 +            int sensorCode = sensors.keyAt (i); 
 +            String sensorType = sensors.get (sensorCode); 
 +  
 +            // probe sensor and add to the list 
 +            sensor = sensorManager.getDefaultSensor (sensorCode); 
 +            if (sensor != null) { 
 +                JSONObject sensDesc = null; 
 +  
 +                Log.d(TAG, "found: " + sensorType); 
 +  
 +                for (int j = 0; j < localSensors.length (); j++) 
 +                    if (((String)((JSONObject) localSensors.get (j)).get ("type")).toString ().equals (sensorType)) { 
 +                        sensDesc = (JSONObject) localSensors.get (j); 
 +                        break; 
 +                    } 
 +  
 +                if (sensDesc != null) { // The sensor descriptor exists in the database 
 +                    Bundle serviceDescriptor = new Bundle (); 
 +                    serviceDescriptor.putString ("serviceBusTopic", "sensor/" + sensDesc.getString ("id")); 
 +                    serviceDescriptor.putString ("id", sensDesc.getString ("id")); 
 +                    serviceDescriptor.putString ("type", sensDesc.getString ("type")); 
 +                    serviceDescriptor.putString ("category", "sensor"); 
 +                    serviceDescriptor.putString ("contextBusTopic", "sensor/" + sensDesc.getString ("id")); 
 +                    serviceDescriptor.putString ("description", sensor.toString()); 
 +                     
 +                    JSONArray params = sensDesc.getJSONArray ("messageFormat"); 
 +                    Bundle[] messageFormat = new Bundle[params.length ()]; 
 +                    for (int j = 0; j < params.length (); j++) { 
 +                        messageFormat[j] = new Bundle (); 
 +                        messageFormat[j].putString ("name", ((JSONObject) params.get (j)).getString ("name")); 
 +                        messageFormat[j].putString ("unit", ((JSONObject) params.get (j)).getString ("unit")); 
 +                    } 
 + 
 +                    serviceDescriptor.putParcelableArray ("messageFormat", messageFormat); 
 +                    serviceDescriptor.putParcelableArray ("recipient", new Bundle[] {}); 
 +                    serviceDescriptors.put(sensorCode, new Pair<Sensor, Bundle>(sensor, serviceDescriptor)); 
 +                } 
 +            } 
 +        } 
 +    } 
 +    catch (JSONException ex) { 
 +        Log.e (TAG,  ex.getMessage ());
     }     }
 } }
Line 324: Line 321:
  payload.put("sensor_id", serviceDescriptor.getString("id"));  payload.put("sensor_id", serviceDescriptor.getString("id"));
  payload.put("timestamp", event.timestamp);  payload.put("timestamp", event.timestamp);
- JSONArray values = new JSONArray(); + JSONObject values = new JSONObject(); 
- JSONObject array_value = new JSONObject(); + values.put("Acc_X", event.values[0]); 
- array_value.put("Acc_X", event.values[0]); + values.put("Acc_Y", event.values[1]); 
- array_value.put("Acc_Y", event.values[1]); + values.put("Acc_z", event.values[2]);
- array_value.put("Acc_z", event.values[2]); +
- values.put(array_value);+
  payload.put("values", values);  payload.put("values", values);
     } catch (JSONException e) {     } catch (JSONException e) {
giraffplus/android-middleware.1383140295.txt.gz · Last modified: 2013-10-30 13:38 by davide
Donate Powered by PHP Valid HTML5 Valid CSS Run on Debian Driven by DokuWiki