diff options
author | Feuerfuchs <git@feuerfuchs.eu> | 2018-11-20 23:11:58 +0100 |
---|---|---|
committer | Feuerfuchs <git@feuerfuchs.eu> | 2018-11-20 23:11:58 +0100 |
commit | f61ef2fa53df9449845f4523f469d3a3a696f45f (patch) | |
tree | 46971e4aaf8b6d155a8ad35d32182c7f2c01e6c8 | |
parent | Remove dependency on dbussy/ravel (diff) | |
download | mpris-to-text-f61ef2fa53df9449845f4523f469d3a3a696f45f.tar.gz mpris-to-text-f61ef2fa53df9449845f4523f469d3a3a696f45f.tar.bz2 mpris-to-text-f61ef2fa53df9449845f4523f469d3a3a696f45f.zip |
Cleanup
-rwxr-xr-x | mpris_to_text.py | 412 |
1 files changed, 205 insertions, 207 deletions
diff --git a/mpris_to_text.py b/mpris_to_text.py index 16ee1e0..24baabf 100755 --- a/mpris_to_text.py +++ b/mpris_to_text.py | |||
@@ -16,230 +16,227 @@ from blessed import Terminal | |||
16 | dbus.mainloop.glib.DBusGMainLoop(set_as_default=True) | 16 | dbus.mainloop.glib.DBusGMainLoop(set_as_default=True) |
17 | 17 | ||
18 | 18 | ||
19 | name_regex = re.compile("^org\.mpris\.MediaPlayer2\.") | 19 | class MetaWriter: |
20 | bus = dbus.SessionBus() | 20 | filename = "" |
21 | term = Terminal() | 21 | output_format = "" |
22 | 22 | output_format_artist = "" | |
23 | refresh_cond = threading.Condition() | 23 | output_format_title = "" |
24 | refresh_flag = True | 24 | output_format_album = "" |
25 | exit_flag = False | 25 | last_output = "" |
26 | 26 | ||
27 | players = [] | 27 | def __init__(self, filename, output_format, output_format_artist, output_format_title, output_format_album): |
28 | player_id_to_index = {} | 28 | self.filename = filename |
29 | active_player = "" | 29 | self.output_format = output_format |
30 | current_output = "" | 30 | self.output_format_album = output_format_album |
31 | playing_song_changed_signal_receiver = None | 31 | self.output_format_artist = output_format_artist |
32 | 32 | self.output_format_title = output_format_title | |
33 | filename = "" | 33 | |
34 | meta_format = "" | 34 | def write_meta(self, metadata): |
35 | meta_format_artist = "" | 35 | artist = metadata["xesam:artist"][0] if "xesam:artist" in metadata else "" |
36 | meta_format_title = "" | 36 | title = metadata["xesam:title"] if "xesam:title" in metadata else "" |
37 | meta_format_album = "" | 37 | album = metadata["xesam:album"] if "xesam:album" in metadata else "" |
38 | 38 | ||
39 | 39 | self.write(self.output_format.format( | |
40 | def track_string(metadata): | 40 | artist = self.output_format_artist.format(artist) if artist != "" else "", |
41 | artist = metadata["xesam:artist"][0] if "xesam:artist" in metadata else "" | 41 | title = self.output_format_title.format(title) if title != "" else "", |
42 | title = metadata["xesam:title"] if "xesam:title" in metadata else "" | 42 | album = self.output_format_album.format(album) if album != "" else "" |
43 | album = metadata["xesam:album"] if "xesam:album" in metadata else "" | 43 | )) |
44 | 44 | ||
45 | return meta_format.format( | 45 | def write(self, text): |
46 | artist = meta_format_artist.format(artist) if artist != "" else "", | 46 | self.last_output = text |
47 | title = meta_format_title.format(title) if title != "" else "", | 47 | f = open(self.filename, "w") |
48 | album = meta_format_album.format(album) if album != "" else "" | 48 | f.write(text) |
49 | ) | 49 | f.close() |
50 | 50 | ||
51 | 51 | ||
52 | def write_track(track): | 52 | class PlayerSelector(threading.Thread): |
53 | global filename | 53 | service_regex = re.compile("^org\.mpris\.MediaPlayer2\.") |
54 | global current_output | 54 | bus = None |
55 | loop = None | ||
56 | signal_receiver = None | ||
57 | players = {} | ||
58 | players_indexes = [] | ||
59 | active_player = "" | ||
60 | menu = None | ||
61 | meta_writer = None | ||
62 | |||
63 | def __init__(self, meta_writer, menu=None): | ||
64 | super().__init__() | ||
65 | |||
66 | self.bus = dbus.SessionBus() | ||
67 | self.meta_writer = meta_writer | ||
68 | self.menu = menu | ||
69 | |||
70 | def set_menu(self, menu): | ||
71 | self.menu = menu | ||
55 | 72 | ||
56 | current_output = track | 73 | def get_players(self): |
57 | f = open(filename, "w") | 74 | self.players = {} |
58 | f.write(track) | 75 | self.players_indexes = [] |
59 | f.close() | 76 | |
60 | 77 | bus_path = self.bus.get_object("org.freedesktop.DBus", "/org/freedesktop/DBus") | |
61 | 78 | bus_proxy = dbus.Interface(bus_path, "org.freedesktop.DBus") | |
62 | def playing_song_changed(player, changed_properties, invalidated_properties): | 79 | |
63 | global refresh_cond | 80 | for service in bus_proxy.ListNames(): |
64 | global refresh_flag | 81 | if self.service_regex.match(service): |
65 | 82 | split_service = service.split(".") | |
66 | if "Metadata" in changed_properties: | 83 | name_start_index = len(split_service[0]) + len(split_service[1]) + len(split_service[2]) + 3 |
67 | write_track(track_string(changed_properties["Metadata"])) | 84 | |
68 | with refresh_cond: | 85 | player_path = self.bus.get_object(service, "/org/mpris/MediaPlayer2") |
69 | refresh_flag = True | 86 | player_props = dbus.Interface(player_path, "org.freedesktop.DBus.Properties") |
70 | refresh_cond.notify() | 87 | player_name = service[name_start_index:] |
71 | 88 | try: | |
72 | 89 | player_name = player_props.Get("org.mpris.MediaPlayer2.Player", "Identity") | |
73 | def dbus_name_owner_changed(name, old_owner, new_owner): | 90 | except dbus.exceptions.DBusException: |
74 | global refresh_cond | 91 | pass |
75 | global refresh_flag | 92 | |
76 | 93 | self.players[service] = player_name | |
77 | if name_regex.match(name): | 94 | self.players_indexes.append(service) |
78 | get_players() | 95 | |
79 | with refresh_cond: | 96 | self.set_active_player(self.active_player) |
80 | refresh_flag = True | 97 | |
81 | refresh_cond.notify() | 98 | def set_active_player_index(self, player_index): |
82 | 99 | if player_index < len(self.players_indexes): | |
83 | 100 | self.set_active_player(self.players_indexes[player_index]) | |
84 | def set_active_player(player_id): | 101 | |
85 | global bus | 102 | def set_active_player(self, player_id): |
86 | global players | 103 | if player_id in self.players: |
87 | global player_id_to_index | 104 | self.active_player = player_id |
88 | global active_player | 105 | elif len(self.players) != 0: |
89 | global playing_song_changed_signal_receiver | 106 | self.active_player = next(iter(self.players.keys())) |
90 | 107 | else: | |
91 | if player_id in player_id_to_index: | 108 | self.active_player = "" |
92 | active_player = player_id | 109 | |
93 | elif len(player_id_to_index) != 0: | 110 | if self.signal_receiver is not None: |
94 | active_player = next(iter(player_id_to_index)) | 111 | self.signal_receiver.remove() |
95 | else: | 112 | |
96 | active_player = "" | 113 | if self.active_player != "": |
97 | 114 | self.signal_receiver = self.bus.add_signal_receiver( | |
98 | if playing_song_changed_signal_receiver is not None: | 115 | handler_function = self.playing_song_changed, |
99 | playing_song_changed_signal_receiver.remove() | 116 | bus_name = self.active_player, |
100 | 117 | dbus_interface = "org.freedesktop.DBus.Properties", | |
101 | if active_player != "": | 118 | signal_name = "PropertiesChanged", |
102 | playing_song_changed_signal_receiver = bus.add_signal_receiver( | 119 | path = "/org/mpris/MediaPlayer2" |
103 | handler_function = playing_song_changed, | 120 | ) |
104 | bus_name = active_player, | 121 | |
105 | dbus_interface = "org.freedesktop.DBus.Properties", | 122 | player_path = self.bus.get_object(self.active_player, "/org/mpris/MediaPlayer2") |
106 | signal_name = "PropertiesChanged", | ||
107 | path = "/org/mpris/MediaPlayer2" | ||
108 | ) | ||
109 | |||
110 | player_path = bus.get_object(active_player, "/org/mpris/MediaPlayer2") | ||
111 | player_props = dbus.Interface(player_path, "org.freedesktop.DBus.Properties") | ||
112 | |||
113 | write_track(track_string(player_props.Get("org.mpris.MediaPlayer2.Player", "Metadata"))) | ||
114 | else: | ||
115 | write_track("") | ||
116 | |||
117 | |||
118 | def get_players(): | ||
119 | global players | ||
120 | global player_id_to_index | ||
121 | global active_player | ||
122 | |||
123 | players = [] | ||
124 | player_id_to_index = {} | ||
125 | bus_path = bus.get_object("org.freedesktop.DBus", "/org/freedesktop/DBus") | ||
126 | bus_proxy = dbus.Interface(bus_path, "org.freedesktop.DBus") | ||
127 | names = bus_proxy.ListNames() | ||
128 | |||
129 | for name in names: | ||
130 | if name_regex.match(name): | ||
131 | split_name = name.split(".") | ||
132 | id_start_index = len(split_name[0]) + len(split_name[1]) + len(split_name[2]) + 3 | ||
133 | |||
134 | player_path = bus.get_object(name, "/org/mpris/MediaPlayer2") | ||
135 | player_props = dbus.Interface(player_path, "org.freedesktop.DBus.Properties") | 123 | player_props = dbus.Interface(player_path, "org.freedesktop.DBus.Properties") |
136 | player_id = name[id_start_index:] | ||
137 | try: | ||
138 | player_id = player_props.Get("org.mpris.MediaPlayer2.Player", "Identity") | ||
139 | except dbus.exceptions.DBusException: | ||
140 | pass | ||
141 | 124 | ||
142 | players.append((name, player_id)) | 125 | self.meta_writer.write_meta(player_props.Get("org.mpris.MediaPlayer2.Player", "Metadata")) |
143 | player_id_to_index[name] = len(players) - 1 | 126 | else: |
127 | self.meta_writer.write("") | ||
144 | 128 | ||
145 | set_active_player(active_player) | ||
146 | 129 | ||
130 | def run(self): | ||
131 | bus_path = self.bus.get_object("org.freedesktop.DBus", "/org/freedesktop/DBus") | ||
132 | bus_proxy = dbus.Interface(bus_path, "org.freedesktop.DBus") | ||
133 | bus_proxy.connect_to_signal("NameOwnerChanged", self.dbus_name_owner_changed) | ||
147 | 134 | ||
148 | def draw_menu(): | 135 | self.get_players() |
149 | global term | 136 | self.menu.refresh() |
150 | global players | ||
151 | global refresh_cond | ||
152 | global refresh_flag | ||
153 | global exit_flag | ||
154 | global current_output | ||
155 | global filename | ||
156 | 137 | ||
157 | while not exit_flag: | 138 | self.loop = GLib.MainLoop() |
158 | with refresh_cond: | 139 | self.loop.run() |
159 | while not refresh_flag and not exit_flag: | 140 | |
160 | refresh_cond.wait() | 141 | def quit(self): |
142 | self.loop.quit() | ||
143 | |||
144 | def dbus_name_owner_changed(self, name, old_owner, new_owner): | ||
145 | if self.service_regex.match(name): | ||
146 | self.get_players() | ||
147 | self.menu.refresh() | ||
161 | 148 | ||
162 | refresh_flag = False | 149 | def playing_song_changed(self, player, changed_properties, invalidated_properties): |
150 | if "Metadata" in changed_properties: | ||
151 | self.meta_writer.write_meta(changed_properties["Metadata"]) | ||
152 | self.menu.refresh() | ||
163 | 153 | ||
164 | with term.fullscreen(): | ||
165 | print(term.move(0, 0) + term.bold_bright_white_on_bright_black(("{0:<{width}}").format("MPRIS To Text", width=term.width)) + "\n") |