WIP Unable to start MQTT service with android 8 and higher

app/build.gradle

@@ -67,7 +67,6 @@ dependencies {
     testImplementation 'junit:junit:4.12'
     testImplementation 'org.mockito:mockito-core:2.21.0'
     androidTestImplementation 'org.mockito:mockito-android:2.21.0'
-
     // MQTT libraries
     implementation('org.eclipse.paho:org.eclipse.paho.android.service:1.0.2') {
         exclude module: 'support-v4'
@@ -79,24 +78,20 @@ dependencies {
     implementation 'com.madgag.spongycastle:pkix:1.54.0.0'
     implementation 'com.google.code.gson:gson:2.8.1'
     implementation 'com.google.zxing:core:3.3.0'
-
     // Google libraries
     implementation 'com.android.support:multidex:1.0.3'
     implementation 'com.android.support:appcompat-v7:27.1.1'
     implementation 'com.android.support:design:27.1.1'
     implementation 'com.android.support:support-v4:27.1.1'
-    implementation "android.arch.persistence.room:runtime:1.1.1"
-    annotationProcessor "android.arch.persistence.room:compiler:1.1.1"
-
+    implementation 'android.arch.persistence.room:runtime:1.1.1'
+    annotationProcessor 'android.arch.persistence.room:compiler:1.1.1'
     // Logger
     implementation 'com.orhanobut:logger:2.1.1'
-
     // Android Inventory Library
     implementation 'org.flyve:inventory:0.10.0@aar'
-
     // Bug snag
     implementation 'com.bugsnag:bugsnag-android:4.1.3'
-
+    implementation project(':policies')
 }
 
 

app/src/main/AndroidManifest.xml

@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="utf-8"?>
 <manifest xmlns:android="http://schemas.android.com/apk/res/android"
     package="org.flyve.mdm.agent"
-    android:versionCode="2618"
+    android:versionCode="3067"
     android:versionName="2.0.0-rc.5">
 
     <!-- For writing logfiles -->

app/src/main/assets/about.properties

@@ -1,6 +1,6 @@
-about.version=2.0.0-rc.4
-about.build=2556
-about.date=Wed Sep 26 19:33:47 2018
+about.version=2.0.0-rc.5
+about.build=2986
+about.date=Thu Nov 29 10:54:09 2018
 about.commit=
 about.commitFull=
 about.github=https://github.com/flyve-mdm/flyve-mdm-android-agent

app/src/main/java/org/flyve/mdm/agent/adapter/ApplicationsAdapter.java

@@ -96,7 +96,7 @@ public View getView(int position, View convertView, ViewGroup parent) {
 		try {
 			app = data[position];
 		} catch (Exception ex) {
-			FlyveLog.e(ex.getMessage());
+			FlyveLog.e(this.getClass().getName() + ", getView",ex.getMessage());
 			return vi;
 		}
 
@@ -114,7 +114,7 @@ public View getView(int position, View convertView, ViewGroup parent) {
 					status = parent.getResources().getString(R.string.app_installed);
 				}
 			} catch (Exception ex) {
-				FlyveLog.e(ex.getMessage());
+				FlyveLog.e(this.getClass().getName() + ", getView", ex.getMessage());
 			}
 		} else {
 			status = parent.getResources().getString(R.string.app_not_installed);

app/src/main/java/org/flyve/mdm/agent/adapter/ConnectivityAdapter.java

@@ -93,7 +93,7 @@ public View getView(int position, View convertView, ViewGroup parent) {
 		try {
 			hashdata = data.get(position);
 		} catch (Exception ex) {
-			FlyveLog.e(ex.getMessage());
+			FlyveLog.e(this.getClass().getName() + ", getView", ex.getMessage());
 			return vi;
 		}
 

app/src/main/java/org/flyve/mdm/agent/adapter/DrawerAdapter.java

@@ -93,7 +93,7 @@ public View getView(int position, View convertView, ViewGroup parent) {
 		try {
 			hashdata = data.get(position);
 		} catch (Exception ex) {
-			FlyveLog.e(ex.getMessage());
+			FlyveLog.e(this.getClass().getName() + ", getView", ex.getMessage());
 			return vi;
 		}
 

app/src/main/java/org/flyve/mdm/agent/adapter/FilesAdapter.java

@@ -92,7 +92,7 @@ public View getView(int position, View convertView, ViewGroup parent) {
 		try {
 			file = data[position];
 		} catch (Exception ex) {
-			FlyveLog.e(ex.getMessage());
+			FlyveLog.e(this.getClass().getName() + ", getView", ex.getMessage());
 			return vi;
 		}
 

app/src/main/java/org/flyve/mdm/agent/adapter/LogAdapter.java

@@ -45,7 +45,7 @@ public LogAdapter(Activity activity, List<HashMap<String, String>> data) {
 		try {
 			inflater = (LayoutInflater) activity.getSystemService(Context.LAYOUT_INFLATER_SERVICE);
 		} catch (Exception ex) {
-			FlyveLog.e(ex.getMessage());
+			FlyveLog.e(this.getClass().getName() + ", LogAdapter", ex.getMessage());
 		}
 	}
 
@@ -94,7 +94,7 @@ public View getView(int position, View convertView, ViewGroup parent) {
 		try {
 			hashdata = data.get(position);
 		} catch (Exception ex) {
-			FlyveLog.e(ex.getMessage());
+			FlyveLog.e(this.getClass().getName() + ", getView", ex.getMessage());
 			return vi;
 		}
 

app/src/main/java/org/flyve/mdm/agent/adapter/PoliciesAdapter.java

@@ -92,7 +92,7 @@ public View getView(int position, View convertView, ViewGroup parent) {
 		try {
 			hashdata = data.get(position);
 		} catch (Exception ex) {
-			FlyveLog.e(ex.getMessage());
+			FlyveLog.e(this.getClass().getName() + ", getView", ex.getMessage());
 			return vi;
 		}
 

app/src/main/java/org/flyve/mdm/agent/core/Routes.java

@@ -92,16 +92,16 @@ public String pluginFlyvemdmAgent(String agentId) {
      * @param fileId String file id
      * @return String url
      */
-    public String pluginFlyvemdmFile(String fileId, String sessionToken) {
-        return url + "/PluginFlyvemdmFile/" + fileId + "?session_token=" + sessionToken;
+    public String pluginFlyvemdmFile(String fileId) {
+        return url + "/PluginFlyvemdmFile/" + fileId;
     }
 
     /**
      * Download apk
      * @param fileId String file id
      * @return String url
      */
-    public String pluginFlyvemdmPackage(String fileId, String sessionToken) {
-        return url + "/PluginFlyvemdmPackage/" + fileId + "?session_token=" + sessionToken;
+    public String pluginFlyvemdmPackage(String fileId) {
+        return url + "/PluginFlyvemdmPackage/" + fileId;
     }
 }

app/src/main/java/org/flyve/mdm/agent/core/deeplink/DeeplinkModel.java

@@ -53,7 +53,7 @@ public void lint(Context context, String deeplink) {
             deepLinkData = Helpers.base64decode(deeplink);
         } catch(Exception ex) {
             presenter.showSnackError( CommonErrorType.DEEPLINK_BASE64DECODE, deepLinkErrorMessage);
-            FlyveLog.e(deepLinkErrorMessage + " - " + ex.getMessage());
+            FlyveLog.e(this.getClass().getName() + ", lint", deepLinkErrorMessage + " - " + ex.getMessage());
             return;
         }
 
@@ -127,7 +127,7 @@ public void lint(Context context, String deeplink) {
             presenter.lintSuccess(deeplinkSchema);
 
         } catch (Exception ex) {
-            FlyveLog.e(ex.getMessage());
+            FlyveLog.e(this.getClass().getName() + ", lint", ex.getMessage());
             presenter.showSnackError( CommonErrorType.DEEPLINK_GENERAL_EXCEPTION, deepLinkErrorMessage );
         }
     }
@@ -152,11 +152,9 @@ public void saveSupervisor(Context context, String name, String phone, String we
     @Override
     public void saveMQTTConfig(Context context, String url, String userToken, String invitationToken) {
         MqttData cache = new MqttData(context);
-        if(cache.getUrl().isEmpty()) {
-            cache.setUrl(url);
-            cache.setUserToken(userToken);
-            cache.setInvitationToken(invitationToken);
-        }
+        cache.setUrl(url);
+        cache.setUserToken(userToken);
+        cache.setInvitationToken(invitationToken);
     }
 
     @Override

app/src/main/java/org/flyve/mdm/agent/core/enrollment/EnrollmentHelper.java

@@ -88,7 +88,7 @@ private String manageError(String error) {
         String errorMessage = "";
 
         if(error.contains("EXCEPTION_HTTP") || error.contains("ERROR")) {
-            FlyveLog.e(error);
+            FlyveLog.e(this.getClass().getName() + ", manageError", error);
 
             errorMessage = error;
 
@@ -107,7 +107,7 @@ private String manageError(String error) {
                     errorMessage = errorArray[0];
                 }
             } catch (Exception ex) {
-                FlyveLog.e(ex.getMessage());
+                FlyveLog.e(this.getClass().getName() + ", manageError", ex.getMessage());
             }
 
             return errorMessage;
@@ -128,10 +128,11 @@ public void run()
                 String profileId = "";
                 JSONObject jsonSession;
                 HashMap<String, String> header = new HashMap();
+                header.put("user_token", cache.getUserToken());
 
                 try {
                     // STEP 1 get session token
-                    data = getSyncWebData(routes.initSession(cache.getUserToken()), "GET", null);
+                    data = getSyncWebData(routes.initSession(cache.getUserToken()), "GET", header);
 
                     final String errorMessage = manageError(data);
                     if(!errorMessage.equals("")) {
@@ -148,7 +149,7 @@ public void run() {
                     cache.setSessionToken(sessionToken);
 
                 } catch (final Exception ex) {
-                    FlyveLog.e(ex.getMessage());
+                    FlyveLog.e(this.getClass().getName() + ", getActiveSessionToken", ex.getMessage());
                     EnrollmentHelper.runOnUI(new Runnable() {
                         public void run() {
                             callback.onError(CommonErrorType.ENROLLMENT_HELPER_INITSESSION, context.getString(R.string.wrong_json_format, data, ex.getMessage()));
@@ -182,7 +183,7 @@ public void run() {
                     cache.setProfileId(profileId);
 
                 } catch (final Exception ex) {
-                    FlyveLog.e(ex.getMessage());
+                    FlyveLog.e(this.getClass().getName() + ", getActiveSessionToken", ex.getMessage());
                     EnrollmentHelper.runOnUI(new Runnable() {
                         public void run() {
                             callback.onError(CommonErrorType.ENROLLMENT_HELPER_FULLSESSION, context.getString(R.string.wrong_json_format, data, ex.getMessage()));
@@ -209,7 +210,7 @@ public void run() {
                         });
                     }
                 } catch (final Exception ex) {
-                    FlyveLog.e(ex.getMessage());
+                    FlyveLog.e(this.getClass().getName() + ", getActiveSessionToken", ex.getMessage());
                     EnrollmentHelper.runOnUI(new Runnable() {
                         public void run() {
                             callback.onError(CommonErrorType.ENROLLMENT_HELPER_CHANGEACTIVEPROFILE, context.getString(R.string.wrong_json_format, data, ex.getMessage()));
@@ -257,7 +258,7 @@ public void run() {
 
                 if(data.contains("ERROR")){
                     final String msgError = manageError(data);
-                    FlyveLog.e(msgError + " - Device serial: " + Helpers.getDeviceSerial());
+                    FlyveLog.e(this.getClass().getName() + ", enrollment", msgError + " - Device serial: " + Helpers.getDeviceSerial());
 
                     EnrollmentHelper.runOnUI(new Runnable() {
                         public void run() {
@@ -357,7 +358,7 @@ public void run() {
                         }
                     });
                 } catch (Exception ex) {
-                    FlyveLog.e(ex.getMessage());
+                    FlyveLog.e(this.getClass().getName() + ", createX509cert", ex.getMessage());
                     EnrollmentHelper.runOnUI(new Runnable() {
                         public void run() {
                             callback.onError(CommonErrorType.ENROLLMENT_HELPER_X509CERTIFICATION, "false");

app/src/main/java/org/flyve/mdm/agent/core/enrollment/EnrollmentModel.java

@@ -168,6 +168,10 @@ public void enroll(final Activity activity, final List<UserData.EmailsData> arrE
             payload.put("type", "android");
             payload.put("has_system_permission", Helpers.isSystemApp(activity));
             payload.put("inventory", mInventory);
+            // could be mqtt or fcm
+            payload.put("notification_type", "mqtt");
+            // this is the token get from fcm register
+            payload.put("notification_token", "");
 
             FlyveLog.d(mInventory);
 
@@ -192,7 +196,6 @@ public void onSuccess(String data) {
                     // -------------------------------
                     MqttData cache = new MqttData(activity);
                     cache.setInvitationToken("");
-                    cache.setUserToken("");
 
                     presenter.enrollSuccess();
                 }