1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
#!/usr/bin/env gjs
import GLib from 'gi://GLib';
import Gio from 'gi://Gio';
const GJS_SUPPORTS_FILE_IFACE_PROMISES = imports.system.version >= 17101;
if (GJS_SUPPORTS_FILE_IFACE_PROMISES)
Gio._promisify(Gio.File.prototype, 'query_default_handler_async');
function getHandlerAppAsync(location, cancellable) {
if (!location)
return null;
if (!GJS_SUPPORTS_FILE_IFACE_PROMISES) {
Gio._promisify(location.constructor.prototype,
'query_default_handler_async',
'query_default_handler_finish');
}
return location.query_default_handler_async(
GLib.PRIORITY_DEFAULT, cancellable);
}
async function mainAsync(argv) {
if (argv.length < 1) {
const currentBinary = GLib.path_get_basename(new Error().fileName);
printerr(`Usage: ${currentBinary} <action> uri [ --timeout <value> ]`);
return 1;
}
const [action, uri] = argv;
let timeout = 200;
if (action !== 'handler')
throw new TypeError(`Unexpected action ${action}`);
for (let i = 1; i < argv.length; ++i) {
if (argv[i] === '--timeout' && i < argv.length - 1)
timeout = argv[++i];
}
const location = Gio.File.new_for_uri(uri);
const cancellable = new Gio.Cancellable();
// GVfs providers could hang when querying the file information, so we
// workaround this by using the async API in a sync way, but we need to
// use a timeout to avoid this to hang forever, better than hang the
// shell.
let launchMaxWaitId;
try {
const handler = await Promise.race([
getHandlerAppAsync(location, cancellable),
new Promise((_resolve, reject) => {
launchMaxWaitId = GLib.timeout_add(
GLib.PRIORITY_DEFAULT, timeout, () => {
launchMaxWaitId = 0;
cancellable.cancel();
reject(new GLib.Error(Gio.IOErrorEnum,
Gio.IOErrorEnum.TIMED_OUT,
`Searching for ${location.get_uri()} ` +
'handler took too long'));
return GLib.SOURCE_REMOVE;
});
}),
]);
print(handler.get_id());
} catch (e) {
printerr(e.message);
logError(e);
return e.code ? e.code : GLib.MAXUINT8;
} finally {
if (launchMaxWaitId)
GLib.source_remove(launchMaxWaitId);
}
return 0;
}
function main(args) {
let ret;
const loop = new GLib.MainLoop(null, false);
mainAsync(args).then(r => (ret = r)).catch(logError).finally(() => loop.quit());
loop.run();
return ret;
}
imports.system.exit(main(ARGV));
|