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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
|
import { isRealPlayer } from "@/utils/mpris";
import { GLib, GObject, property, readFileAsync, register, writeFileAsync } from "astal";
import AstalMpris from "gi://AstalMpris";
@register({ GTypeName: "Players" })
export default class Players extends GObject.Object {
static instance: Players;
static get_default() {
if (!this.instance) this.instance = new Players();
return this.instance;
}
readonly #path = `${STATE}/players.txt`;
readonly #players: AstalMpris.Player[] = [];
readonly #subs = new Map<
JSX.Element,
{ signals: string[]; callback: () => void; ids: number[]; player: AstalMpris.Player | null }
>();
@property(AstalMpris.Player)
get lastPlayer(): AstalMpris.Player | null {
return this.#players.length > 0 && this.#players[0].identity !== null ? this.#players[0] : null;
}
/**
* List of real players.
*/
@property(Object)
get list() {
return this.#players;
}
hookLastPlayer(widget: JSX.Element, signal: string, callback: () => void): this;
hookLastPlayer(widget: JSX.Element, signals: string[], callback: () => void): this;
hookLastPlayer(widget: JSX.Element, signals: string | string[], callback: () => void) {
if (!Array.isArray(signals)) signals = [signals];
// Add subscription
if (this.lastPlayer)
this.#subs.set(widget, {
signals,
callback,
ids: signals.map(s => this.lastPlayer!.connect(s, callback)),
player: this.lastPlayer,
});
else this.#subs.set(widget, { signals, callback, ids: [], player: null });
// Remove subscription on widget destroyed
widget.connect("destroy", () => {
const sub = this.#subs.get(widget);
if (sub?.player) sub.ids.forEach(id => sub.player!.disconnect(id));
this.#subs.delete(widget);
});
// Initial run of callback
callback();
// For chaining
return this;
}
makeCurrent(player: AstalMpris.Player) {
const index = this.#players.findIndex(p => p.busName === player.busName);
// Ignore if already current
if (index === 0 || !isRealPlayer(player)) return;
// Remove if present
else if (index > 0) this.#players.splice(index, 1);
// Connect signals if not already in list (i.e. new player)
else this.#connectPlayerSignals(player);
// Add to front
this.#players.unshift(player);
this.#updatePlayer();
this.notify("list");
// Save to file
this.#save();
}
#updatePlayer() {
this.notify("last-player");
for (const sub of this.#subs.values()) {
sub.callback();
if (sub.player) sub.ids.forEach(id => sub.player!.disconnect(id));
sub.ids = this.lastPlayer ? sub.signals.map(s => this.lastPlayer!.connect(s, sub.callback)) : [];
sub.player = this.lastPlayer;
}
}
#save() {
writeFileAsync(this.#path, this.#players.map(p => p.busName).join("\n")).catch(console.error);
}
#connectPlayerSignals(player: AstalMpris.Player) {
// Change order on attribute change
for (const signal of [
"notify::playback-status",
"notify::shuffle-status",
"notify::loop-status",
"notify::volume",
"notify::rate",
])
player.connect(signal, () => this.makeCurrent(player));
}
constructor() {
super();
const mpris = AstalMpris.get_default();
// Load players
if (GLib.file_test(this.#path, GLib.FileTest.EXISTS)) {
readFileAsync(this.#path).then(out => {
for (const busName of out.split("\n").reverse()) {
const player = mpris.get_players().find(p => p.busName === busName);
if (player) this.makeCurrent(player);
}
// Add new players from in between sessions
for (const player of mpris.get_players()) this.makeCurrent(player);
});
} else {
const sortOrder = [
AstalMpris.PlaybackStatus.PLAYING,
AstalMpris.PlaybackStatus.PAUSED,
AstalMpris.PlaybackStatus.STOPPED,
];
const players = mpris
.get_players()
.sort((a, b) => sortOrder.indexOf(b.playbackStatus) - sortOrder.indexOf(a.playbackStatus));
for (const player of players) this.makeCurrent(player);
}
// Add and connect signals when added
mpris.connect("player-added", (_, player) => this.makeCurrent(player));
// Remove when closed
mpris.connect("player-closed", (_, player) => {
const index = this.#players.indexOf(player);
if (index >= 0) {
this.#players.splice(index, 1);
this.notify("list");
if (index === 0) this.#updatePlayer();
this.#save();
}
});
}
}
|
