libervia-backend: sat/plugins/plugin_misc

annotate sat/plugins/plugin_misc_android.py @ 3152:7ce31f347ca3

core (memory/disco): fixed failure creation in infosEb

author	Goffi <goffi@goffi.org>
date	Mon, 03 Feb 2020 13:42:43 +0100
parents	559a625a236b
children	f2d3ab4390a3

rev	line source
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	1 #!/usr/bin/env python3
3137 559a625a236b fixed shebangs Goffi <goffi@goffi.org> parents: 3136 diff changeset	2
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	3
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	4 # SAT plugin for file tansfer
3136 9d0df638c8b4 dates update Goffi <goffi@goffi.org> parents: 3125 diff changeset	5 # Copyright (C) 2009-2020 Jérôme Poisson (goffi@goffi.org)
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	6
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	7 # This program is free software: you can redistribute it and/or modify
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	8 # it under the terms of the GNU Affero General Public License as published by
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	9 # the Free Software Foundation, either version 3 of the License, or
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	10 # (at your option) any later version.
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	11
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	12 # This program is distributed in the hope that it will be useful,
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	13 # but WITHOUT ANY WARRANTY; without even the implied warranty of
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	15 # GNU Affero General Public License for more details.
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	16
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	17 # You should have received a copy of the GNU Affero General Public License
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	18 # along with this program. If not, see <http://www.gnu.org/licenses/>.
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	19
2841 90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	20 import sys
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	21 import os
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	22 import os.path
3106 7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	23 from pathlib import Path
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	24 from sat.core.i18n import _, D_
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	25 from sat.core.constants import Const as C
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	26 from sat.core.log import getLogger
2841 90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	27 from sat.core import exceptions
3106 7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	28 from sat.memory import params
3124 b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	29 from twisted.internet import defer
2841 90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	30 from twisted.internet import reactor
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	31 from twisted.internet import protocol
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	32 from twisted.internet import error as int_error
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	33
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	34 log = getLogger(__name__)
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	35
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	36 PLUGIN_INFO = {
3124 b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	37 C.PI_NAME: "Android",
2145 33c8c4973743 core (plugins): added missing contants + use of new constants in PLUGIN_INFO Goffi <goffi@goffi.org> parents: 2100 diff changeset	38 C.PI_IMPORT_NAME: "android",
33c8c4973743 core (plugins): added missing contants + use of new constants in PLUGIN_INFO Goffi <goffi@goffi.org> parents: 2100 diff changeset	39 C.PI_TYPE: C.PLUG_TYPE_MISC,
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	40 C.PI_RECOMMENDATIONS: ["XEP-0352"],
2145 33c8c4973743 core (plugins): added missing contants + use of new constants in PLUGIN_INFO Goffi <goffi@goffi.org> parents: 2100 diff changeset	41 C.PI_MAIN: "AndroidPlugin",
33c8c4973743 core (plugins): added missing contants + use of new constants in PLUGIN_INFO Goffi <goffi@goffi.org> parents: 2100 diff changeset	42 C.PI_HANDLER: "no",
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	43 C.PI_DESCRIPTION: D_(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	44 """Manage Android platform specificities, like pause or notifications"""
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	45 ),
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	46 }
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	47
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	48 if sys.platform != "android":
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	49 raise exceptions.CancelError("this module is not needed on this platform")
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	50
2872 6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	51
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	52 from plyer import notification, vibrator
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	53 from plyer.platforms.android import activity
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	54 from jnius import autoclass
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	55 from android.broadcast import BroadcastReceiver
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	56
2872 6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	57 #: delay between a pause event and sending the inactive indication to server, in seconds
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	58 #: we don't send the indication immediately because user can be just checking something
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	59 #: quickly on an other app.
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	60 CSI_DELAY = 30
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	61
3106 7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	62 PARAM_RING_CATEGORY = "Notifications"
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	63 PARAM_RING_NAME = "sound"
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	64 PARAM_RING_LABEL = D_("sound on notifications")
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	65 RING_OPTS = {
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	66 "normal": D_("Normal"),
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	67 "never": D_("Never"),
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	68 }
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	69 PARAM_VIBRATE_CATEGORY = "Notifications"
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	70 PARAM_VIBRATE_NAME = "vibrate"
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	71 PARAM_VIBRATE_LABEL = D_("Vibrate on notifications")
3106 7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	72 VIBRATION_OPTS = {
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	73 "always": D_("Always"),
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	74 "vibrate": D_("In vibrate mode"),
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	75 "never": D_("Never"),
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	76 }
2841 90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	77 SOCKET_DIR = "/data/data/org.salutatoi.cagou/"
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	78 SOCKET_FILE = ".socket"
3057 f91d0e6d9b13 plugin android: fixed encoding in states after Python 3 port Goffi <goffi@goffi.org> parents: 3028 diff changeset	79 STATE_RUNNING = b"running"
f91d0e6d9b13 plugin android: fixed encoding in states after Python 3 port Goffi <goffi@goffi.org> parents: 3028 diff changeset	80 STATE_PAUSED = b"paused"
f91d0e6d9b13 plugin android: fixed encoding in states after Python 3 port Goffi <goffi@goffi.org> parents: 3028 diff changeset	81 STATE_STOPPED = b"stopped"
2841 90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	82 STATES = (STATE_RUNNING, STATE_PAUSED, STATE_STOPPED)
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	83 NET_TYPE_NONE = "no network"
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	84 NET_TYPE_WIFI = "wifi"
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	85 NET_TYPE_MOBILE = "mobile"
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	86 NET_TYPE_OTHER = "other"
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	87
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	88
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	89 Context = autoclass('android.content.Context')
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	90 ConnectivityManager = autoclass('android.net.ConnectivityManager')
3106 7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	91 MediaPlayer = autoclass('android.media.MediaPlayer')
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	92 AudioManager = autoclass('android.media.AudioManager')
2868 5546613f5007 plugin android: workaround to seek() bug, fixing file upload: Goffi <goffi@goffi.org> parents: 2856 diff changeset	93
5546613f5007 plugin android: workaround to seek() bug, fixing file upload: Goffi <goffi@goffi.org> parents: 2856 diff changeset	94
2841 90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	95 class FrontendStateProtocol(protocol.Protocol):
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	96
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	97 def __init__(self, android_plugin):
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	98 self.android_plugin = android_plugin
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	99
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	100 def dataReceived(self, data):
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	101 if data in STATES:
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	102 self.android_plugin.state = data
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	103 else:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	104 log.warning("Unexpected data: {data}".format(data=data))
2841 90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	105
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	106
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	107 class FrontendStateFactory(protocol.Factory):
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	108
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	109 def __init__(self, android_plugin):
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	110 self.android_plugin = android_plugin
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	111
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	112 def buildProtocol(self, addr):
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	113 return FrontendStateProtocol(self.android_plugin)
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	114
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	115
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	116
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	117 class AndroidPlugin(object):
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	118
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	119 params = """
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	120 <params>
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	121 <individual>
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	122 <category name="{category_name}" label="{category_label}">
3106 7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	123 <param name="{ring_param_name}" label="{ring_param_label}" type="list" security="0">
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	124 {ring_options}
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	125 </param>
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	126 <param name="{vibrate_param_name}" label="{vibrate_param_label}" type="list" security="0">
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	127 {vibrate_options}
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	128 </param>
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	129 </category>
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	130 </individual>
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	131 </params>
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	132 """.format(
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	133 category_name=PARAM_VIBRATE_CATEGORY,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	134 category_label=D_(PARAM_VIBRATE_CATEGORY),
3106 7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	135 vibrate_param_name=PARAM_VIBRATE_NAME,
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	136 vibrate_param_label=PARAM_VIBRATE_LABEL,
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	137 vibrate_options=params.makeOptions(VIBRATION_OPTS, "always"),
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	138 ring_param_name=PARAM_RING_NAME,
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	139 ring_param_label=PARAM_RING_LABEL,
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	140 ring_options=params.makeOptions(RING_OPTS, "normal"),
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	141 )
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	142
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	143 def __init__(self, host):
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	144 log.info(_("plugin Android initialization"))
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	145 self.host = host
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	146 self._csi = host.plugins.get('XEP-0352')
2872 6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	147 self._csi_timer = None
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	148 host.memory.updateParams(self.params)
2841 90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	149 try:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	150 os.mkdir(SOCKET_DIR, 0o700)
2841 90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	151 except OSError as e:
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	152 if e.errno == 17:
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	153 # dir already exists
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	154 pass
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	155 else:
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	156 raise e
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	157 self._state = None
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	158 factory = FrontendStateFactory(self)
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	159 socket_path = os.path.join(SOCKET_DIR, SOCKET_FILE)
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	160 try:
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	161 reactor.listenUNIX(socket_path, factory)
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	162 except int_error.CannotListenError as e:
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	163 if e.socketError.errno == 98:
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	164 # the address is already in use, we need to remove it
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	165 os.unlink(socket_path)
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	166 reactor.listenUNIX(socket_path, factory)
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	167 else:
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	168 raise e
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	169 # we set a low priority because we want the notification to be sent after all
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	170 # plugins have done their job
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	171 host.trigger.add("MessageReceived", self.messageReceivedTrigger, priority=-1000)
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	172
3124 b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	173 # profiles autoconnection
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	174 host.bridge.addMethod(
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	175 "profileAutoconnectGet",
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	176 ".plugin",
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	177 in_sign="",
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	178 out_sign="s",
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	179 method=self._profileAutoconnectGet,
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	180 async_=True,
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	181 )
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	182
3106 7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	183 # audio manager, to get ring status
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	184 self.am = activity.getSystemService(Context.AUDIO_SERVICE)
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	185
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	186 # sound notification
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	187 media_dir = Path(host.memory.getConfig("", "media_dir"))
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	188 assert media_dir is not None
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	189 notif_path = media_dir / "sounds" / "notifications" / "music-box.mp3"
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	190 self.notif_player = MediaPlayer()
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	191 self.notif_player.setDataSource(str(notif_path))
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	192 self.notif_player.setAudioStreamType(AudioManager.STREAM_NOTIFICATION)
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	193 self.notif_player.prepare()
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	194
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	195 # Connectivity handling
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	196 self.cm = activity.getSystemService(Context.CONNECTIVITY_SERVICE)
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	197 self._net_type = None
3125 c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	198 d = defer.ensureDeferred(self._checkConnectivity())
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	199 d.addErrback(host.logErrback)
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	200
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	201 # XXX: we need to keep a reference to BroadcastReceiver to avoid
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	202 # "XXX has no attribute 'invoke'" error (looks like the same issue as
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	203 # https://github.com/kivy/pyjnius/issues/59)
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	204 self.br = BroadcastReceiver(
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	205 callback=lambda args, *kwargs: reactor.callLater(0,
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	206 self.onConnectivityChange),
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	207 actions=["android.net.conn.CONNECTIVITY_CHANGE"])
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	208 self.br.start()
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	209
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	210 @property
2841 90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	211 def state(self):
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	212 return self._state
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	213
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	214 @state.setter
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	215 def state(self, new_state):
3057 f91d0e6d9b13 plugin android: fixed encoding in states after Python 3 port Goffi <goffi@goffi.org> parents: 3028 diff changeset	216 log.debug(f"frontend state has changed: {new_state.decode()}")
2841 90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	217 previous_state = self._state
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	218 self._state = new_state
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	219 if new_state == STATE_RUNNING:
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	220 self._onRunning(previous_state)
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	221 elif new_state == STATE_PAUSED:
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	222 self._onPaused(previous_state)
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	223 elif new_state == STATE_STOPPED:
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	224 self._onStopped(previous_state)
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	225
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	226 @property
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	227 def cagou_active(self):
2841 90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	228 return self._state == STATE_RUNNING
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	229
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	230 def _onRunning(self, previous_state):
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	231 if previous_state is not None:
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	232 self.host.bridge.bridgeReactivateSignals()
2872 6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	233 self.setActive()
2841 90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	234
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	235 def _onPaused(self, previous_state):
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	236 self.host.bridge.bridgeDeactivateSignals()
2872 6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	237 self.setInactive()
2841 90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	238
90115cf4e731 plugin android: improved state handling: Goffi <goffi@goffi.org> parents: 2771 diff changeset	239 def _onStopped(self, previous_state):
2872 6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	240 self.setInactive()
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	241
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	242 def _notifyMessage(self, mess_data, client):
2856 26d6ac4e4a66 plugin android: don't send notification if message comes from ourself (from an other device) Goffi <goffi@goffi.org> parents: 2841 diff changeset	243 """Send notification when suitable
26d6ac4e4a66 plugin android: don't send notification if message comes from ourself (from an other device) Goffi <goffi@goffi.org> parents: 2841 diff changeset	244
26d6ac4e4a66 plugin android: don't send notification if message comes from ourself (from an other device) Goffi <goffi@goffi.org> parents: 2841 diff changeset	245 notification is sent if:
26d6ac4e4a66 plugin android: don't send notification if message comes from ourself (from an other device) Goffi <goffi@goffi.org> parents: 2841 diff changeset	246 - there is a message and it is not a groupchat
26d6ac4e4a66 plugin android: don't send notification if message comes from ourself (from an other device) Goffi <goffi@goffi.org> parents: 2841 diff changeset	247 - message is not coming from ourself
26d6ac4e4a66 plugin android: don't send notification if message comes from ourself (from an other device) Goffi <goffi@goffi.org> parents: 2841 diff changeset	248 """
26d6ac4e4a66 plugin android: don't send notification if message comes from ourself (from an other device) Goffi <goffi@goffi.org> parents: 2841 diff changeset	249 if (mess_data["message"] and mess_data["type"] != C.MESS_TYPE_GROUPCHAT
26d6ac4e4a66 plugin android: don't send notification if message comes from ourself (from an other device) Goffi <goffi@goffi.org> parents: 2841 diff changeset	250 and not mess_data["from"].userhostJID() == client.jid.userhostJID()):
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	251 message = next(iter(mess_data["message"].values()))
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	252 try:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	253 subject = next(iter(mess_data["subject"].values()))
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	254 except StopIteration:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	255 subject = "Cagou new message"
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	256
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	257 notification.notify(title=subject, message=message)
3106 7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	258
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	259 ringer_mode = self.am.getRingerMode()
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	260 vibrate_mode = ringer_mode == AudioManager.RINGER_MODE_VIBRATE
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	261
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	262 ring_setting = self.host.memory.getParamA(
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	263 PARAM_RING_NAME,
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	264 PARAM_RING_CATEGORY,
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	265 profile_key=client.profile
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	266 )
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	267
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	268 if ring_setting != 'never' and ringer_mode == AudioManager.RINGER_MODE_NORMAL:
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	269 self.notif_player.start()
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	270
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	271 vibration_setting = self.host.memory.getParamA(
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	272 PARAM_VIBRATE_NAME,
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	273 PARAM_VIBRATE_CATEGORY,
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	274 profile_key=client.profile
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	275 )
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	276 if (vibration_setting == 'always'
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	277 or vibration_setting == 'vibrate' and vibrate_mode):
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	278 try:
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	279 vibrator.vibrate()
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	280 except Exception as e:
7f7cdc6ecfd8 plugin android: sound notification + change settings: Goffi <goffi@goffi.org> parents: 3095 diff changeset	281 log.warning("Can't use vibrator: {e}".format(e=e))
2100 fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	282 return mess_data
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	283
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	284 def messageReceivedTrigger(self, client, message_elt, post_treat):
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	285 if not self.cagou_active:
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	286 # we only send notification is the frontend is not displayed
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	287 post_treat.addCallback(self._notifyMessage, client)
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	288
fbeeba721954 plugin android: first draft: Goffi <goffi@goffi.org> parents: diff changeset	289 return True
2872 6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	290
3124 b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	291 # Profile autoconnection
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	292
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	293 def _profileAutoconnectGet(self):
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	294 return defer.ensureDeferred(self.profileAutoconnectGet())
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	295
3125 c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	296 async def _getProfilesAutoconnect(self):
3124 b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	297 autoconnect_dict = await self.host.memory.storage.getIndParamValues(
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	298 category='Connection', name='autoconnect_backend',
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	299 )
3125 c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	300 return [p for p, v in autoconnect_dict.items() if C.bool(v)]
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	301
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	302 async def profileAutoconnectGet(self):
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	303 """Return profile to connect automatically by frontend, if any"""
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	304 profiles_autoconnect = await self._getProfilesAutoconnect()
3124 b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	305 if not profiles_autoconnect:
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	306 return None
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	307 if len(profiles_autoconnect) > 1:
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	308 log.warning(
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	309 f"More that one profiles with backend autoconnection set found, picking "
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	310 f"up first one (full list: {profiles_autoconnect!r})")
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	311 return profiles_autoconnect[0]
b86060901278 plugin android: added a `profileAutoconnectGet` method: Goffi <goffi@goffi.org> parents: 3106 diff changeset	312
2872 6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	313 # CSI
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	314
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	315 def _setInactive(self):
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	316 self._csi_timer = None
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	317 for client in self.host.getClients(C.PROF_KEY_ALL):
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	318 self._csi.setInactive(client)
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	319
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	320 def setInactive(self):
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	321 if self._csi is None or self._csi_timer is not None:
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	322 return
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	323 self._csi_timer = reactor.callLater(CSI_DELAY, self._setInactive)
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	324
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	325 def setActive(self):
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	326 if self._csi is None:
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	327 return
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	328 if self._csi_timer is not None:
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	329 self._csi_timer.cancel()
2882 0c54970d8e6e plugin android: fixed csi_timer reset in setActive + crash on call of isActive before session initialisation Goffi <goffi@goffi.org> parents: 2872 diff changeset	330 self._csi_timer = None
2872 6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	331 for client in self.host.getClients(C.PROF_KEY_ALL):
6b00f88316bf plugin android: use XEP-0352 to indicate (in)active state: Goffi <goffi@goffi.org> parents: 2868 diff changeset	332 self._csi.setActive(client)
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	333
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	334 # Connectivity
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	335
3125 c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	336 async def _handleNetworkChange(self, net_type):
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	337 """Notify the clients about network changes.
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	338
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	339 This way the client can disconnect/reconnect transport, or change delays
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	340 """
3125 c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	341 log.debug(f"handling network change ({net_type})")
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	342 if net_type == NET_TYPE_NONE:
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	343 for client in self.host.getClients(C.PROF_KEY_ALL):
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	344 client.networkDisabled()
3125 c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	345 else:
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	346 # client may be there but disabled (e.g. with stream management)
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	347 for client in self.host.getClients(C.PROF_KEY_ALL):
3125 c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	348 log.debug(f"enabling network for {client.profile}")
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	349 client.networkEnabled()
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	350
3125 c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	351 # profiles may have been disconnected and then purged, we try
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	352 # to reconnect them in case
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	353 profiles_autoconnect = await self._getProfilesAutoconnect()
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	354 for profile in profiles_autoconnect:
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	355 if not self.host.isConnected(profile):
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	356 log.info(f"{profile} is not connected, reconnecting it")
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	357 try:
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	358 await self.host.connect(profile)
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	359 except Exception as e:
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	360 log.error(f"Can't connect profile {profile}: {e}")
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	361
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	362 async def _checkConnectivity(self):
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	363 active_network = self.cm.getActiveNetworkInfo()
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	364 if active_network is None:
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	365 net_type = NET_TYPE_NONE
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	366 else:
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	367 net_type_android = active_network.getType()
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	368 if net_type_android == ConnectivityManager.TYPE_WIFI:
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	369 net_type = NET_TYPE_WIFI
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	370 elif net_type_android == ConnectivityManager.TYPE_MOBILE:
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	371 net_type = NET_TYPE_MOBILE
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	372 else:
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	373 net_type = NET_TYPE_OTHER
3125 c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	374
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	375 if net_type != self._net_type:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	376 log.info("connectivity has changed")
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	377 self._net_type = net_type
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	378 if net_type == NET_TYPE_NONE:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	379 log.info("no network active")
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	380 elif net_type == NET_TYPE_WIFI:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	381 log.info("WIFI activated")
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	382 elif net_type == NET_TYPE_MOBILE:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	383 log.info("mobile data activated")
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	384 else:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	385 log.info("network activated (type={net_type_android})"
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	386 .format(net_type_android=net_type_android))
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	387 else:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	388 log.debug("_checkConnectivity called without network change ({net_type})"
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	389 .format(net_type = net_type))
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	390
3125 c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	391 # we always call _handleNetworkChange even if there is not connectivity change
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	392 # to be sure to reconnect when necessary
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	393 await self._handleNetworkChange(net_type)
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	394
2887 9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	395
9aadf11b315b plugin android: check connectivity Goffi <goffi@goffi.org> parents: 2882 diff changeset	396 def onConnectivityChange(self):
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 3018 diff changeset	397 log.debug("onConnectivityChange called")
3125 c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	398 d = defer.ensureDeferred(self._checkConnectivity())
c3ce8c997fdf plugin android: reconnect profiles with autoconnect if network is activated: Goffi <goffi@goffi.org> parents: 3124 diff changeset	399 d.addErrback(self.host.logErrback)

Mercurial > libervia-backend

annotate sat/plugins/plugin_misc_android.py @ 3152:7ce31f347ca3