Hack together a Library tab

This needs serious clean up.  Even though it's not the first iteration.

1 files changed, 246 insertions, 0 deletions

diff --git a/nncmpp.c b/nncmpp.c
index 4abdcb3..0755bb2 100644
--- a/nncmpp.c
+++ b/nncmpp.c
@@ -2008,6 +2008,242 @@ current_tab_init (void)
 	return super;
 }
 
+// --- Library tab -------------------------------------------------------------
+
+enum
+{
+	// This list is also ordered by ASCII and important for sorting
+
+	LIBRARY_ROOT = '/',                 ///< Root entry
+	LIBRARY_UP   = '^',                 ///< Upper directory
+	LIBRARY_DIR  = 'd',                 ///< Directory
+	LIBRARY_FILE = 'f'                  ///< File
+};
+
+static struct
+{
+	struct tab super;                   ///< Parent class
+	struct str path;                    ///< Current path
+	struct str_vector items;            ///< Current items (type, name, path)
+}
+g_library_tab;
+
+static void
+library_tab_on_item_draw (size_t item_index, struct row_buffer *buffer,
+	int width)
+{
+	(void) width;
+	hard_assert (item_index < g_library_tab.items.len);
+
+	const char *item = g_library_tab.items.vector[item_index];
+	char type = *item++;
+
+	switch (type)
+	{
+	case LIBRARY_ROOT: row_buffer_append (buffer, "/",   0); break;
+	case LIBRARY_UP:   row_buffer_append (buffer, "/..", 0); break;
+	case LIBRARY_DIR:  row_buffer_addv (buffer, "/", 0, item, 0, NULL); break;
+	case LIBRARY_FILE: row_buffer_addv (buffer, " ", 0, item, 0, NULL); break;
+	default:           hard_assert (!"invalid item type");
+	}
+}
+
+static void
+library_tab_add (int type, const char *name, const char *path)
+{
+	str_vector_add_owned (&g_library_tab.items,
+		xstrdup_printf ("%c%s%c%s", type, name, 0, path));
+}
+
+static void
+library_tab_chunk (struct str_map *map)
+{
+	if (!map->len)
+		return;
+
+	const char *artist = str_map_find (map, "artist");
+	const char *title  = str_map_find (map, "title");
+	char *name = (artist && title)
+		? xstrdup_printf ("%s - %s", artist, title)
+		: NULL;
+
+	char *id, type;
+	if ((id = str_map_find (map, "directory")))
+		type = LIBRARY_DIR;
+	else if ((id = str_map_find (map, "file")))
+		type = LIBRARY_FILE;
+
+	const char *last_slash = strrchr (id, '/');
+	const char *base = last_slash ? last_slash + 1 : id;
+	library_tab_add (type, name ? name : base, id);
+	free (name);
+}
+
+static int
+library_tab_compare (char **a, char **b)
+{
+	char *item_a = *a; char type_a = *item_a++;
+	char *item_b = *b; char type_b = *item_b++;
+	char *path_a = strchr (item_a, '\0') + 1;
+	char *path_b = strchr (item_b, '\0') + 1;
+
+	if (type_a != type_b)
+		return type_a - type_b;
+
+	// TODO: this should be case insensitive
+	return u8_strcmp ((uint8_t *) path_a, (uint8_t *) path_b);
+}
+
+static void
+library_tab_on_data (const struct mpd_response *response,
+	const struct str_vector *data, void *user_data)
+{
+	(void) user_data;
+	if (!response->success)
+		return;
+
+	str_vector_reset (&g_library_tab.items);
+	if (g_library_tab.path.len)
+	{
+		library_tab_add (LIBRARY_ROOT, "", "");
+		library_tab_add (LIBRARY_UP,   "", "");
+	}
+
+	struct str_map map;
+	str_map_init (&map);
+	map.key_xfrm = tolower_ascii_strxfrm;
+
+	char *key, *value;
+	for (size_t i = 0; i < data->len; i++)
+	{
+		if (!(key = mpd_client_parse_kv (data->vector[i], &value)))
+		{
+			print_debug ("%s: %s", "erroneous MPD output", data->vector[i]);
+			continue;
+		}
+		if (!strcasecmp_ascii (key, "file")
+		 || !strcasecmp_ascii (key, "directory"))
+		{
+			library_tab_chunk (&map);
+			str_map_clear (&map);
+		}
+		str_map_set (&map, key, value);
+	}
+	library_tab_chunk (&map);
+	str_map_free (&map);
+
+	struct str_vector *items = &g_library_tab.items;
+	qsort (items->vector, items->len, sizeof *items->vector,
+		(int (*) (const void *, const void *)) library_tab_compare);
+
+	// TODO: we ought to remember the previous level's selection and item_top
+	g_library_tab.super.item_count = g_library_tab.items.len;
+
+	app_fix_view_range ();
+	app_move_selection (0);
+	app_invalidate ();
+}
+
+static const char *
+library_tab_path (void)
+{
+	struct str *path = &g_library_tab.path;
+	return path->len ? path->str : "/";
+}
+
+static void
+library_tab_reload (const char *new_path)
+{
+	// TODO: actually we should update the path _after_ we receive data
+	if (new_path)
+	{
+		struct str *path = &g_library_tab.path;
+		str_reset (path);
+		str_append (path, new_path);
+	}
+
+	struct mpd_client *c = &g_ctx.client;
+	mpd_client_send_command (c, "lsinfo", library_tab_path (), NULL);
+
+	mpd_client_add_task (c, library_tab_on_data, NULL);
+	mpd_client_idle (c, 0);
+}
+
+static bool
+library_tab_on_action (enum user_action action)
+{
+	struct tab *self = g_ctx.active_tab;
+	if (self->item_selected < 0)
+		return false;
+
+	struct mpd_client *c = &g_ctx.client;
+	if (c->state != MPD_CONNECTED)
+		return false;
+
+	char *item = g_library_tab.items.vector[self->item_selected];
+	char type = *item++;
+	const char *item_path = strchr (item, '\0') + 1;
+
+	switch (action)
+	{
+	case USER_ACTION_CHOOSE:
+		switch (type)
+		{
+		case LIBRARY_ROOT: library_tab_reload ("");        break;
+		case LIBRARY_UP:
+		{
+			struct str *path = &g_library_tab.path;
+			char *last_slash = strrchr (path->str, '/');
+			if (last_slash)
+			{
+				char *new_path = xstrndup (path->str, last_slash - path->str);
+				library_tab_reload (new_path);
+				free (new_path);
+			}
+			else
+				library_tab_reload ("");
+			break;
+		}
+		case LIBRARY_DIR:  library_tab_reload (item_path); break;
+		case LIBRARY_FILE: MPD_SIMPLE ("add", item_path)   break;
+		default:           hard_assert (!"invalid item type");
+		}
+		return true;
+	case USER_ACTION_MPD_REPLACE:
+		// FIXME: we also need to play it if we've been playing things already
+		if (type == LIBRARY_DIR || type == LIBRARY_FILE)
+		{
+			MPD_SIMPLE ("clear");
+			MPD_SIMPLE ("add", item_path)
+			return true;
+		}
+		return false;
+	case USER_ACTION_MPD_ADD:
+		if (type == LIBRARY_DIR || type == LIBRARY_FILE)
+		{
+			MPD_SIMPLE ("add", item_path)
+			return true;
+		}
+		break;
+	default:
+		break;
+	}
+	return false;
+}
+
+static struct tab *
+library_tab_init (void)
+{
+	str_init (&g_library_tab.path);
+	str_vector_init (&g_library_tab.items);
+
+	struct tab *super = &g_library_tab.super;
+	tab_init (super, "Library");
+	super->on_action = library_tab_on_action;
+	super->on_item_draw = library_tab_on_item_draw;
+	return super;
+}
+
 // --- Streams -----------------------------------------------------------------
 
 // MPD can only parse m3u8 playlists, and only when it feels like doing so
@@ -2615,6 +2851,9 @@ mpd_on_events (unsigned subsystems, void *user_data)
 	(void) user_data;
 	struct mpd_client *c = &g_ctx.client;
 
+	if (subsystems & MPD_SUBSYSTEM_DATABASE)
+		library_tab_reload (NULL);
+
 	if (subsystems & (MPD_SUBSYSTEM_PLAYER
 		| MPD_SUBSYSTEM_PLAYLIST | MPD_SUBSYSTEM_MIXER))
 		mpd_request_info ();
@@ -2639,7 +2878,10 @@ mpd_on_password_response (const struct mpd_response *response,
 	struct mpd_client *c = &g_ctx.client;
 
 	if (response->success)
+	{
 		mpd_request_info ();
+		library_tab_reload (NULL);
+	}
 	else
 	{
 		print_error ("%s: %s",
@@ -2662,7 +2904,10 @@ mpd_on_connected (void *user_data)
 		mpd_client_add_task (c, mpd_on_password_response, NULL);
 	}
 	else
+	{
 		mpd_request_info ();
+		library_tab_reload (NULL);
+	}
 }
 
 static void
@@ -2985,6 +3230,7 @@ main (int argc, char *argv[])
 	app_prepend_tab (info_tab_init ());
 	if (g_ctx.streams.len)
 		app_prepend_tab (streams_tab_init ());
+	app_prepend_tab (library_tab_init ());
 	app_prepend_tab (current_tab_init ());
 	app_switch_tab ((g_ctx.help_tab = help_tab_init ()));