.desktop files should not be executable (#815)

[waydroid.git] / tools / interfaces / IPlatform.py

diff --git a/tools/interfaces/IPlatform.py b/tools/interfaces/IPlatform.py
index a8a5410758b365bcbd6d7e65f4f9641e56372f60..67f8a3ed67b2bddbd1170741c082af1f920ca66d 100644 (file)
--- a/tools/interfaces/IPlatform.py
+++ b/tools/interfaces/IPlatform.py
@@ -2,6 +2,8 @@ import gbinder
 import logging
 import time
 from tools import helpers
 import logging
 import time
 from tools import helpers

+from gi.repository import GLib
+import signal

 
 
 INTERFACE = "lineageos.waydroid.IPlatform"
 
 
 INTERFACE = "lineageos.waydroid.IPlatform"


@@ -18,7 +20,8 @@ TRANSACTION_getAppName = 8
 TRANSACTION_settingsPutString = 9
 TRANSACTION_settingsGetString = 10
 TRANSACTION_settingsPutInt = 11
 TRANSACTION_settingsPutString = 9
 TRANSACTION_settingsGetString = 10
 TRANSACTION_settingsPutInt = 11

-TRANSACTION_getAppName = 12
+TRANSACTION_settingsGetInt = 12
+TRANSACTION_launchIntent = 13

 
 class IPlatform:
     def __init__(self, remote):
 
 class IPlatform:
     def __init__(self, remote):


@@ -182,6 +185,25 @@ class IPlatform:
             if exception != 0:
                 logging.error("Failed with code: {}".format(exception))
 
             if exception != 0:
                 logging.error("Failed with code: {}".format(exception))
 

+    def launchIntent(self, arg1, arg2):
+        request = self.client.new_request()
+        request.append_string16(arg1)
+        request.append_string16(arg2)
+        reply, status = self.client.transact_sync_reply(
+            TRANSACTION_launchIntent, request)
+
+        if status:
+            logging.error("Sending reply failed")
+        else:
+            reader = reply.init_reader()
+            status, exception = reader.read_int32()
+            if exception == 0:
+                rep1 = reader.read_string16()
+                return rep1
+            else:
+                logging.error("Failed with code: {}".format(exception))
+        return None
+

     def getAppName(self, arg1):
         request = self.client.new_request()
         request.append_string16(arg1)
     def getAppName(self, arg1):
         request = self.client.new_request()
         request.append_string16(arg1)


@@ -279,6 +301,13 @@ def get_service(args):
         serviceManager = gbinder.ServiceManager("/dev/" + args.BINDER_DRIVER, args.SERVICE_MANAGER_PROTOCOL, args.BINDER_PROTOCOL)
     except TypeError:
         serviceManager = gbinder.ServiceManager("/dev/" + args.BINDER_DRIVER)
         serviceManager = gbinder.ServiceManager("/dev/" + args.BINDER_DRIVER, args.SERVICE_MANAGER_PROTOCOL, args.BINDER_PROTOCOL)
     except TypeError:
         serviceManager = gbinder.ServiceManager("/dev/" + args.BINDER_DRIVER)

+
+    if not serviceManager.is_present():
+        logging.info("Waiting for binder Service Manager...")
+        if not wait_for_manager(serviceManager):
+            logging.error("Service Manager never appeared")
+            return None
+

     tries = 1000
 
     remote, status = serviceManager.get_service_sync(SERVICE_NAME)
     tries = 1000
 
     remote, status = serviceManager.get_service_sync(SERVICE_NAME)


@@ -293,3 +322,15 @@ def get_service(args):
             return None
 
     return IPlatform(remote)
             return None
 
     return IPlatform(remote)

+
+# Like ServiceManager.wait() but can be interrupted
+def wait_for_manager(sm):
+    mainloop = GLib.MainLoop()
+    hndl = sm.add_presence_handler(lambda: mainloop.quit() if sm.is_present() else None)
+    GLib.timeout_add_seconds(60, lambda: mainloop.quit())
+    GLib.unix_signal_add(GLib.PRIORITY_HIGH, signal.SIGINT, lambda _: mainloop.quit(), None)
+    mainloop.run()
+    sm.remove_handler(hndl)
+    if not sm.is_present():
+        return False
+    return True