202 def navigate(self, msg_id, params: dict) -> None:
203 with self.lock:
204 if self.shutting_down:
205 self.channel.send(make_error(msg_id, 1, "shutting_down"))
206 return
207 if self.current is not None:
208 self.channel.send(make_error(msg_id, 1, "navigate_already_in_progress"))
209 return
210 state = NavigateState(uuid.uuid4().hex[:12])
211 self.current = state
212
213 title = params.get("title", "")
214 url = params.get("url", "")
215 redirect_uri = params.get("redirect_uri", "")
216 timeout_ms = params.get("timeout_ms") or DEFAULT_TIMEOUT_MS
217
218 if not redirect_uri.lower().startswith(BROKER_SCHEME):
219 with self.lock:
220 self.current = None
221 self.channel.send(make_error(msg_id, 1, "unsupported_redirect_scheme"))
222 return
223
224 effective_url, state.had_original_state = rewrite_state(url, state.freerdp_id)
225
226 runtime_dir = os.environ.get("XDG_RUNTIME_DIR", "/tmp")
227 sock_path = os.path.join(runtime_dir, f"freerdp_aad_{state.freerdp_id}.sock")
228 try:
229 os.unlink(sock_path)
230 except FileNotFoundError:
231 pass
232
233 server = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
234 redirect_url = None
235 error = None
236 try:
237 server.bind(sock_path)
238 os.chmod(sock_path, 0o600)
239 server.listen(1)
240 server.settimeout(0.5)
241
242 print(f"[xdgopen-aad-helper] navigate: opening browser for {effective_url!r} "
243 f"(title={title!r}), waiting on {sock_path}", file=sys.stderr)
244 subprocess.Popen(["xdg-open", effective_url])
245
246 deadline = time.monotonic() + timeout_ms / 1000.0
247 while redirect_url is None and error is None:
248 if state.cancelled.is_set():
249 error = "user_cancelled"
250 break
251 with self.lock:
252 if self.shutting_down:
253 error = "shutting_down"
254 break
255 if time.monotonic() >= deadline:
256 error = "timeout"
257 break
258 try:
259 conn, _ = server.accept()
260 except socket.timeout:
261 continue
262 with conn:
263 conn.settimeout(2.0)
264 data = b""
265 try:
266 while True:
267 chunk = conn.recv(4096)
268 if not chunk:
269 break
270 data += chunk
271 except socket.timeout:
272 pass
273 redirect_url = data.decode(errors="replace").strip()
274 finally:
275 server.close()
276 try:
277 os.unlink(sock_path)
278 except FileNotFoundError:
279 pass
280 with self.lock:
281 self.current = None
282
283 if error:
284 self.channel.send(make_error(msg_id, 1, error))
285 return
286
287 redirect_url = restore_state(redirect_url, state.freerdp_id, state.had_original_state)
288
289 parsed = urllib.parse.urlparse(redirect_url)
290 qs = urllib.parse.parse_qs(parsed.query)
291 if "error" in qs:
292 message = qs["error"][0]
293 if "error_subcode" in qs:
294 message += ": " + qs["error_subcode"][0]
295 self.channel.send(make_error(msg_id, 1, message))
296 return
297
298 self.channel.send(make_result(msg_id, {"status": "ok", "redirect_url": redirect_url}))
299
1.9.8