aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--Makefile5
-rw-r--r--mpd_trigger.c228
2 files changed, 233 insertions, 0 deletions
diff --git a/Makefile b/Makefile
new file mode 100644
index 0000000..7ba32d2
--- /dev/null
+++ b/Makefile
@@ -0,0 +1,5 @@
+all: mpd_trigger
+mpd_trigger: mpd_trigger.o
+ gcc -o $@ $< -lmpdclient
+mpd_trigger.o: mpd_trigger.c
+ gcc -c $< -g
diff --git a/mpd_trigger.c b/mpd_trigger.c
new file mode 100644
index 0000000..4560b51
--- /dev/null
+++ b/mpd_trigger.c
@@ -0,0 +1,228 @@
+#include <mpd/idle.h>
+#include <mpd/tag.h>
+#include <mpd/status.h>
+#include <mpd/client.h>
+#include <stdio.h>
+#include <assert.h>
+#include <unistd.h>
+#include <string.h>
+#include <stdlib.h>
+#include <sys/wait.h>
+#include <sys/types.h>
+
+struct mpd_connection *conn;
+typedef struct mpd_song mpd_song_t;
+typedef struct mpd_status mpd_status_t;
+
+#define MAINLOOP_ERROR do { handle_error(conn); return; } while (0)
+#define MAX_HASH 1021
+#define MAX_INFO_BUFF 256
+#define MAX_OUTPUT_BUFF 2048
+
+const char *host = "192.168.248.130";
+unsigned int port = 6600;
+const char *state_name[4] = {"unknown", "stopped", "now playing", "paused"};
+const char *shell = "bash";
+const char *trigger_command = "terminal-notifier -title '{title}: {state} ({elapsed_pct}%)' "
+ "-subtitle '{artist}' -message $'{album}\\\\n{track}' -sender com.apple.iTunes";
+
+typedef const char *(*Hook_t)(mpd_status_t status, mpd_song_t song);
+typedef struct Entry {
+ const char *name;
+ const char **content_ref;
+ struct Entry *next;
+} Entry;
+
+typedef struct {
+ Entry *head[MAX_HASH];
+} HashTable;
+
+HashTable *hash_table_create() {
+ HashTable *ht = (HashTable *)malloc(sizeof(HashTable));
+ memset(ht->head, sizeof(ht->head), 0);
+ return ht;
+}
+
+unsigned hash_table_hash_func(const char *name) {
+ unsigned int seed = 131, res = 0;
+ while (*name)
+ res = res * seed + (*name++ - 'a');
+ return res % MAX_HASH;
+}
+
+void hash_table_destroy(HashTable *ht) {
+ unsigned int i;
+ for (i = 0; i < MAX_HASH; i++)
+ {
+ Entry *e, *ne;
+ for (e = ht->head[i]; e; e = ne)
+ {
+ ne = e->next;
+ free(e);
+ }
+ }
+}
+
+void hash_table_register(HashTable *ht, const char *name, const char **content_ref) {
+ unsigned int hv = hash_table_hash_func(name);
+ Entry *e = (Entry *)malloc(sizeof(Entry));
+ e->name = name;
+ e->content_ref = content_ref;
+ e->next = ht->head[hv];
+ ht->head[hv] = e;
+}
+
+const char *hash_table_lookup(HashTable *ht, const char *name) {
+ unsigned int hv = hash_table_hash_func(name);
+ Entry *e;
+ for (e = ht->head[hv]; e; e = e->next)
+ if (!strcmp(e->name, name))
+ return *(e->content_ref);
+ return NULL;
+}
+
+char etime_buff[MAX_INFO_BUFF], ttime_buff[MAX_INFO_BUFF], epct_buff[MAX_INFO_BUFF];
+const char *title, *artist, *album, *track, *state,
+ *elapsed_time = etime_buff, *total_time = ttime_buff, *elapsed_pct = epct_buff;
+
+HashTable *dict;
+
+void handle_error(struct mpd_connection *conn) {
+ fprintf(stderr, "%s\n", mpd_connection_get_error_message(conn));
+ mpd_connection_free(conn);
+}
+
+const char *filter(const char *input) {
+ static char output_buff[MAX_OUTPUT_BUFF];
+ static char token_buff[MAX_INFO_BUFF];
+ char *optr = output_buff, *tptr = token_buff;
+ enum {
+ ESCAPE,
+ IN_TOKEN,
+ NORMAL
+ } state = NORMAL;
+ while (*input)
+ {
+ if (state == NORMAL)
+ {
+ if (*input == '\\')
+ state = ESCAPE;
+ else if (*input == '{')
+ state = IN_TOKEN;
+ else
+ *optr++ = *input;
+ }
+ else if (state == IN_TOKEN)
+ {
+ if (*input == '}')
+ {
+ size_t csize;
+ const char *content;
+ *tptr = '\0'; /* mark the end of the token */
+ if ((content = hash_table_lookup(dict, token_buff)))
+ {
+ csize = strlen(content);
+ memmove(optr, content, csize);
+ optr += csize;
+ }
+ tptr = token_buff;
+ state = NORMAL;
+ }
+ else *tptr++ = *input;
+ }
+ else
+ {
+ *optr++ = *input;
+ state = NORMAL;
+ }
+ input++;
+ }
+ *optr = '\0';
+ return output_buff;
+}
+
+void trigger(const char *filtered_cmd) {
+ pid_t pid;
+ int fd[2];
+ pipe(fd);
+ fprintf(stderr, "executing: %s\n", filtered_cmd);
+ if ((pid = fork()) == -1)
+ {
+ fprintf(stderr, "failed to fork\n");
+ return;
+ }
+ else if (!pid)
+ {
+ dup2(fd[0], 0); /* override stdin */
+ close(fd[0]);
+ close(fd[1]);
+ execlp(shell, shell, (char *)NULL);
+ }
+ close(fd[0]);
+ write(fd[1], filtered_cmd, strlen(filtered_cmd));
+ close(fd[1]);
+ waitpid(pid, NULL, 0);
+}
+
+void main_loop() {
+ for (;;)
+ {
+ int idle_info;
+ mpd_song_t *song;
+ mpd_status_t *status;
+
+ if (mpd_connection_get_error(conn) != MPD_ERROR_SUCCESS)
+ MAINLOOP_ERROR;
+
+ mpd_send_idle_mask(conn, MPD_IDLE_PLAYER);
+ idle_info = mpd_recv_idle(conn, 1);
+ if (!idle_info) MAINLOOP_ERROR;
+ fprintf(stderr, "new event: %s(%d)\n", mpd_idle_name(idle_info), idle_info);
+ if (idle_info == MPD_IDLE_PLAYER)
+ {
+ int et, tt;
+ mpd_send_status(conn);
+ status = mpd_recv_status(conn);
+ if (!status) MAINLOOP_ERROR;
+ state = state_name[mpd_status_get_state(status)];
+ et = mpd_status_get_elapsed_time(status);
+ tt = mpd_status_get_total_time(status);
+ sprintf(etime_buff, "%i", et);
+ sprintf(ttime_buff, "%i", tt);
+ sprintf(epct_buff, "%d", tt ? et * 100 / tt : 0);
+ mpd_status_free(status);
+ mpd_send_current_song(conn);
+ while ((song = mpd_recv_song(conn)) != NULL)
+ {
+ title = mpd_song_get_tag(song, MPD_TAG_TITLE, 0);
+ artist = mpd_song_get_tag(song, MPD_TAG_ARTIST, 0);
+ album = mpd_song_get_tag(song, MPD_TAG_ALBUM, 0);
+ track = mpd_song_get_tag(song, MPD_TAG_TRACK, 0);
+ /* printf("%s\n", filter("\\{title\\}artist:{artist}\nalbum:{album}\ntrack:{track}\nstate:{state}\n{elapsed_time}/{total_time}")); */
+ trigger(filter(trigger_command));
+ mpd_song_free(song);
+ }
+ }
+ }
+}
+
+int main() {
+ int i;
+ dict = hash_table_create();
+ hash_table_register(dict, "title", &title);
+ hash_table_register(dict, "artist", &artist);
+ hash_table_register(dict, "album", &album);
+ hash_table_register(dict, "track", &track);
+ hash_table_register(dict, "state", &state);
+ hash_table_register(dict, "elapsed_time", &elapsed_time);
+ hash_table_register(dict, "total_time", &total_time);
+ hash_table_register(dict, "elapsed_pct", &elapsed_pct);
+ for (;;)
+ {
+ fprintf(stderr, "trying to connect %s:%d\n", host, port);
+ conn = mpd_connection_new(host, port, 0);
+ main_loop();
+ fprintf(stderr, "reconnecting\n");
+ sleep(2);
+ }
+}