/* Spa ALSA udev */
/* SPDX-FileCopyrightText: Copyright © 2018 Wim Taymans */
/* SPDX-License-Identifier: MIT */

#include <stddef.h>
#include <stdio.h>
#include <limits.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/inotify.h>
#include <fcntl.h>
#include <dirent.h>

#include <libudev.h>
#include <alsa/asoundlib.h>

#include <spa/utils/cleanup.h>
#include <spa/utils/type.h>
#include <spa/utils/keys.h>
#include <spa/utils/names.h>
#include <spa/utils/result.h>
#include <spa/utils/string.h>
#include <spa/support/loop.h>
#include <spa/support/plugin.h>
#include <spa/monitor/device.h>
#include <spa/monitor/utils.h>
#include <spa/debug/log.h>
#include <spa/debug/dict.h>

#include "alsa.h"

#define MAX_CARDS	64

enum action {
	ACTION_CHANGE,
	ACTION_REMOVE,
};

/* Used for unavailable devices in the card structure. */
#define ID_DEVICE_NOT_SUPPORTED 0

/* This represents an ALSA card.
 * One card can have up to 1 PCM and 1 Compress-Offload device. */
struct card {
	unsigned int card_nr;
	struct udev_device *udev_device;
	unsigned int unavailable:1;
	unsigned int accessible:1;
	unsigned int ignored:1;
	unsigned int emitted:1;

	/* Local SPA object IDs. (Global IDs are produced by PipeWire
	 * out of this using its registry.) Compress-Offload or PCM
	 * is not available, the corresponding ID is set to
	 * ID_DEVICE_NOT_SUPPORTED (= 0).
	 * PCM device IDs are (card nr + 1) * 2, and Compress-Offload
	 * device IDs are (card nr + 1) * 2 + 1. Assigning IDs like this
	 * makes it easy to deal with removed devices. (card nr + 1)
	 * is used because 0 is a valid ALSA card number. */
	uint32_t pcm_device_id;
	uint32_t compress_offload_device_id;
};

static uint32_t calc_pcm_device_id(struct card *card)
{
	return (card->card_nr + 1) * 2 + 0;
}

static uint32_t calc_compress_offload_device_id(struct card *card)
{
	return (card->card_nr + 1) * 2 + 1;
}

struct impl {
	struct spa_handle handle;
	struct spa_device device;

	struct spa_log *log;
	struct spa_loop *main_loop;
	struct spa_system *main_system;

	struct spa_hook_list hooks;

	uint64_t info_all;
	struct spa_device_info info;

	struct udev *udev;
	struct udev_monitor *umonitor;

	struct card cards[MAX_CARDS];
        unsigned int n_cards;

	struct spa_source source;
	struct spa_source notify;
	unsigned int use_acp:1;
	unsigned int expose_busy:1;
	int use_ucm;
};

static int impl_udev_open(struct impl *this)
{
	if (this->udev == NULL) {
		this->udev = udev_new();
		if (this->udev == NULL)
			return -ENOMEM;
	}
	return 0;
}

static int impl_udev_close(struct impl *this)
{
	if (this->udev != NULL)
		udev_unref(this->udev);
	this->udev = NULL;
	return 0;
}

static struct card *add_card(struct impl *this, unsigned int card_nr, struct udev_device *udev_device)
{
	struct card *card;

	if (this->n_cards >= MAX_CARDS)
		return NULL;

	card = &this->cards[this->n_cards++];
	spa_zero(*card);
	card->card_nr = card_nr;
	udev_device_ref(udev_device);
	card->udev_device = udev_device;

	return card;
}

static struct card *find_card(struct impl *this, unsigned int card_nr)
{
	unsigned int i;
	for (i = 0; i < this->n_cards; i++) {
		if (this->cards[i].card_nr == card_nr)
			return &this->cards[i];
	}
	return NULL;
}

static void remove_card(struct impl *this, struct card *card)
{
	udev_device_unref(card->udev_device);
	*card = this->cards[--this->n_cards];
}

static void clear_cards(struct impl *this)
{
        unsigned int i;
	for (i = 0; i < this->n_cards; i++)
	        udev_device_unref(this->cards[i].udev_device);
	this->n_cards = 0;
}

static unsigned int get_card_nr(struct impl *this, struct udev_device *udev_device)
{
	const char *e, *str;

	if (udev_device_get_property_value(udev_device, "ACP_IGNORE"))
		return SPA_ID_INVALID;

	if ((str = udev_device_get_property_value(udev_device, "SOUND_CLASS")) && spa_streq(str, "modem"))
		return SPA_ID_INVALID;

	if (udev_device_get_property_value(udev_device, "SOUND_INITIALIZED") == NULL)
		return SPA_ID_INVALID;

	if ((str = udev_device_get_property_value(udev_device, "DEVPATH")) == NULL)
		return SPA_ID_INVALID;

	if ((e = strrchr(str, '/')) == NULL)
		return SPA_ID_INVALID;

	if (strlen(e) <= 5 || strncmp(e, "/card", 5) != 0)
		return SPA_ID_INVALID;

	return atoi(e + 5);
}

static int dehex(char x)
{
	if (x >= '0' && x <= '9')
		return x - '0';
	if (x >= 'A' && x <= 'F')
		return x - 'A' + 10;
	if (x >= 'a' && x <= 'f')
		return x - 'a' + 10;
	return -1;
}

static void unescape(const char *src, char *dst)
{
	const char *s;
	char *d;
	int h1 = 0, h2 = 0;
	enum { TEXT, BACKSLASH, EX, FIRST } state = TEXT;

	for (s = src, d = dst; *s; s++) {
		switch (state) {
		case TEXT:
			if (*s == '\\')
				state = BACKSLASH;
			else
				*(d++) = *s;
			break;

		case BACKSLASH:
			if (*s == 'x')
				state = EX;
			else {
				*(d++) = '\\';
				*(d++) = *s;
				state = TEXT;
			}
			break;

		case EX:
			h1 = dehex(*s);
			if (h1 < 0) {
				*(d++) = '\\';
				*(d++) = 'x';
				*(d++) = *s;
				state = TEXT;
			} else
				state = FIRST;
			break;

		case FIRST:
			h2 = dehex(*s);
			if (h2 < 0) {
				*(d++) = '\\';
				*(d++) = 'x';
				*(d++) = *(s-1);
				*(d++) = *s;
			} else
				*(d++) = (char) (h1 << 4) | h2;
			state = TEXT;
			break;
		}
	}
	switch (state) {
	case TEXT:
		break;
	case BACKSLASH:
		*(d++) = '\\';
		break;
	case EX:
		*(d++) = '\\';
		*(d++) = 'x';
		break;
	case FIRST:
		*(d++) = '\\';
		*(d++) = 'x';
		*(d++) = *(s-1);
		break;
	}
	*d = 0;
}

static int check_device_pcm_class(const char *devname)
{
	char path[PATH_MAX];
	char buf[16];
	size_t sz;

	/* Check device class */
	spa_scnprintf(path, sizeof(path), "/sys/class/sound/%s/pcm_class", devname);

	spa_autoptr(FILE) f = fopen(path, "re");
	if (f == NULL)
		return -errno;
	sz = fread(buf, 1, sizeof(buf) - 1, f);
	buf[sz] = '\0';
	return spa_strstartswith(buf, "modem") ? -ENXIO : 0;
}

static int get_num_pcm_devices(unsigned int card_nr)
{
	char prefix[32];
	struct dirent *entry;
	int num_dev = 0;
	int res;

	/* Check if card has PCM devices, without opening them */

	spa_scnprintf(prefix, sizeof(prefix), "pcmC%uD", card_nr);

	spa_autoptr(DIR) snd = opendir("/dev/snd");
	if (snd == NULL)
		return -errno;

	while ((errno = 0, entry = readdir(snd)) != NULL) {
		if (!(entry->d_type == DT_CHR &&
				spa_strstartswith(entry->d_name, prefix)))
			continue;

		res = check_device_pcm_class(entry->d_name);
		if (res != -ENXIO) {
			/* count device also if sysfs status file not accessible */
			++num_dev;
		}
	}

	return errno != 0 ? -errno : num_dev;
}

static int get_num_compress_offload_devices(unsigned int card_nr)
{
	char prefix[32];
	struct dirent *entry;
	int num_dev = 0;

	/* Check if card has Compress-Offload devices, without opening them */

	spa_scnprintf(prefix, sizeof(prefix), "comprC%uD", card_nr);

	spa_autoptr(DIR) snd = opendir("/dev/snd");
	if (snd == NULL)
		return -errno;

	while ((errno = 0, entry = readdir(snd)) != NULL) {
		if (!(entry->d_type == DT_CHR &&
				spa_strstartswith(entry->d_name, prefix)))
			continue;

		++num_dev;
	}

	return errno != 0 ? -errno : num_dev;
}

static int check_udev_environment(struct udev *udev, const char *devname)
{
	char path[PATH_MAX];
	struct udev_device *dev;
	int ret = 0;

	/* Check for ACP_IGNORE on a specific PCM device (not the whole card) */
	spa_scnprintf(path, sizeof(path), "/sys/class/sound/%s", devname);

	dev = udev_device_new_from_syspath(udev, path);
	if (dev == NULL)
		return 0;

	if (udev_device_get_property_value(dev, "ACP_IGNORE"))
		ret = -ENXIO;

	udev_device_unref(dev);

	return ret;
}

static int check_pcm_device_availability(struct impl *this, struct card *card,
                                         int *num_pcm_devices)
{
	char path[PATH_MAX];
	char buf[16];
	size_t sz;
	struct dirent *entry, *entry_pcm;
	int res;

	res = get_num_pcm_devices(card->card_nr);
	if (res < 0) {
		spa_log_error(this->log, "Error finding PCM devices for ALSA card %u: %s",
			card->card_nr, spa_strerror(res));
		return res;
	}
	*num_pcm_devices = res;

	spa_log_debug(this->log, "card %u has %d PCM device(s)",
	              card->card_nr, *num_pcm_devices);

	/*
	 * Check if some pcm devices of the card are busy.  Check it via /proc, as we
	 * don't want to actually open any devices using alsa-lib (generates uncontrolled
	 * number of inotify events), or replicate its subdevice logic.
	 *
	 * The /proc/asound directory might not exist if kernel is compiled with
	 * CONFIG_SND_PROCFS=n, and the pcmXX directories may be missing if compiled
	 * with CONFIG_SND_VERBOSE_PROCFS=n. In those cases, the busy check always succeeds.
	 */

	res = 0;
	if (this->expose_busy)
		return res;

	spa_scnprintf(path, sizeof(path), "/proc/asound/card%u", card->card_nr);

	spa_autoptr(DIR) card_dir = opendir(path);
	if (card_dir == NULL)
		goto done;

	while ((errno = 0, entry = readdir(card_dir)) != NULL) {
		if (!(entry->d_type == DT_DIR &&
				spa_strstartswith(entry->d_name, "pcm")))
			continue;

		spa_scnprintf(path, sizeof(path), "pcmC%uD%s",
				card->card_nr, entry->d_name+3);
		if (check_device_pcm_class(path) < 0)
			continue;
		/* Check udev environment */
		if (check_udev_environment(this->udev, path) < 0)
			continue;

		/* Check busy status */
		spa_scnprintf(path, sizeof(path), "/proc/asound/card%u/%s",
				card->card_nr, entry->d_name);

		spa_autoptr(DIR) pcm = opendir(path);
		if (pcm == NULL)
			goto done;

		while ((errno = 0, entry_pcm = readdir(pcm)) != NULL) {
			if (!(entry_pcm->d_type == DT_DIR &&
					spa_strstartswith(entry_pcm->d_name, "sub")))
				continue;

			spa_scnprintf(path, sizeof(path), "/proc/asound/card%u/%s/%s/status",
					card->card_nr, entry->d_name, entry_pcm->d_name);

			spa_autoptr(FILE) f = fopen(path, "re");
			if (f == NULL)
				goto done;
			sz = fread(buf, 1, 6, f);
			buf[sz] = '\0';

			if (!spa_strstartswith(buf, "closed")) {
				spa_log_debug(this->log, "card %u pcm device %s busy",
						card->card_nr, entry->d_name);
				res = -EBUSY;
				goto done;
			}
			spa_log_debug(this->log, "card %u pcm device %s free",
					card->card_nr, entry->d_name);
		}
		if (errno != 0)
			goto done;
	}
	if (errno != 0)
		goto done;

done:
	if (errno != 0) {
		spa_log_info(this->log, "card %u: failed to find busy status (%s)",
				card->card_nr, spa_strerror(-errno));
	}

	return res;
}

static int check_compress_offload_device_availability(struct impl *this, struct card *card,
                                                      int *num_compress_offload_devices)
{
	int res;

	res = get_num_compress_offload_devices(card->card_nr);
	if (res < 0) {
		spa_log_error(this->log, "Error finding Compress-Offload devices for ALSA card %u: %s",
			card->card_nr, spa_strerror(res));
		return res;
	}
	*num_compress_offload_devices = res;

	spa_log_debug(this->log, "card %u has %d Compress-Offload device(s)",
	              card->card_nr, *num_compress_offload_devices);

	return 0;
}

static int emit_added_object_info(struct impl *this, struct card *card)
{
	char path[32];
	int res, num_pcm_devices, num_compress_offload_devices;
	const char *str;
	struct udev_device *udev_device = card->udev_device;

	/*
	 * inotify close events under /dev/snd must not be emitted, except after setting
	 * card->emitted to true. alsalib functions can be used after that.
	 */

	snprintf(path, sizeof(path), "hw:%u", card->card_nr);

	if ((res = check_pcm_device_availability(this, card, &num_pcm_devices)) < 0)
		return res;
	if ((res = check_compress_offload_device_availability(this, card, &num_compress_offload_devices)) < 0)
		return res;

	if ((num_pcm_devices == 0) && (num_compress_offload_devices == 0)) {
		spa_log_debug(this->log, "no PCM and no Compress-Offload devices for %s", path);
		card->ignored = true;
		return -ENODEV;
	}

	card->emitted = true;

	if (num_pcm_devices > 0) {
		struct spa_device_object_info info;
		char *cn = NULL, *cln = NULL;
		struct spa_dict_item items[26];
		unsigned int n_items = 0;

		card->pcm_device_id = calc_pcm_device_id(card);

		spa_log_debug(this->log, "emitting ACP/PCM device interface for card %s; "
		              "using local alsa-udev object ID %" PRIu32, path, card->pcm_device_id);

		info = SPA_DEVICE_OBJECT_INFO_INIT();

		info.type = SPA_TYPE_INTERFACE_Device;
		info.factory_name = this->use_acp ?
			SPA_NAME_API_ALSA_ACP_DEVICE :
			SPA_NAME_API_ALSA_PCM_DEVICE;
		info.change_mask = SPA_DEVICE_OBJECT_CHANGE_MASK_FLAGS |
			SPA_DEVICE_OBJECT_CHANGE_MASK_PROPS;
		info.flags = 0;

		items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_ENUM_API, "udev");
		items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_API,  "alsa");
		items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_MEDIA_CLASS, "Audio/Device");
		if (this->use_ucm != -1)
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_API_ALSA_USE_UCM,
					this->use_ucm ? "true" : "false");
		items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_API_ALSA_PATH, path);
		items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_API_ALSA_CARD, path+3);
		if (snd_card_get_name(card->card_nr, &cn) >= 0)
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_API_ALSA_CARD_NAME, cn);
		if (snd_card_get_longname(card->card_nr, &cln) >= 0)
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_API_ALSA_CARD_LONGNAME, cln);

		if ((str = udev_device_get_property_value(udev_device, "ACP_NAME")) && *str)
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_NAME, str);

		if ((str = udev_device_get_property_value(udev_device, "ACP_PROFILE_SET")) && *str)
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_PROFILE_SET, str);

		if ((str = udev_device_get_property_value(udev_device, "SOUND_CLASS")) && *str)
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_CLASS, str);

		if ((str = udev_device_get_property_value(udev_device, "USEC_INITIALIZED")) && *str)
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_PLUGGED_USEC, str);

		str = udev_device_get_property_value(udev_device, "ID_PATH");
		if (!(str && *str))
			str = udev_device_get_syspath(udev_device);
		if (str && *str) {
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_BUS_PATH, str);
		}
		if ((str = udev_device_get_devpath(udev_device)) && *str) {
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_SYSFS_PATH, str);
		}
		if ((str = udev_device_get_property_value(udev_device, "ID_ID")) && *str) {
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_BUS_ID, str);
		}
		if ((str = udev_device_get_property_value(udev_device, "ID_BUS")) && *str) {
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_BUS, str);
		}
		if ((str = udev_device_get_property_value(udev_device, "SUBSYSTEM")) && *str) {
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_SUBSYSTEM, str);
		}
		if ((str = udev_device_get_property_value(udev_device, "ID_VENDOR_ID")) && *str) {
			int32_t val;
			if (spa_atoi32(str, &val, 16)) {
				char *dec = alloca(12); /* 0xffffffff is max */
				snprintf(dec, 12, "0x%04x", val);
				items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_VENDOR_ID, dec);
			}
		}
		str = udev_device_get_property_value(udev_device, "ID_VENDOR_FROM_DATABASE");
		if (!(str && *str)) {
			str = udev_device_get_property_value(udev_device, "ID_VENDOR_ENC");
			if (!(str && *str)) {
				str = udev_device_get_property_value(udev_device, "ID_VENDOR");
			} else {
				char *t = alloca(strlen(str) + 1);
				unescape(str, t);
				str = t;
			}
		}
		if (str && *str) {
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_VENDOR_NAME, str);
		}
		if ((str = udev_device_get_property_value(udev_device, "ID_MODEL_ID")) && *str) {
			int32_t val;
			if (spa_atoi32(str, &val, 16)) {
				char *dec = alloca(12); /* 0xffffffff is max */
				snprintf(dec, 12, "0x%04x", val);
				items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_PRODUCT_ID, dec);
			}
		}
		str = udev_device_get_property_value(udev_device, "ID_MODEL_FROM_DATABASE");
		if (!(str && *str)) {
			str = udev_device_get_property_value(udev_device, "ID_MODEL_ENC");
			if (!(str && *str)) {
				str = udev_device_get_property_value(udev_device, "ID_MODEL");
			} else {
				char *t = alloca(strlen(str) + 1);
				unescape(str, t);
				str = t;
			}
		}
		if (str && *str)
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_PRODUCT_NAME, str);

		if ((str = udev_device_get_property_value(udev_device, "ID_SERIAL")) && *str) {
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_SERIAL, str);
		}
		if ((str = udev_device_get_property_value(udev_device, "SOUND_FORM_FACTOR")) && *str) {
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_FORM_FACTOR, str);
		}
		info.props = &SPA_DICT_INIT(items, n_items);

		spa_log_debug(this->log, "interface information:");
		spa_debug_log_dict(this->log, SPA_LOG_LEVEL_DEBUG, 2, info.props);

		spa_device_emit_object_info(&this->hooks, card->pcm_device_id, &info);
		free(cn);
		free(cln);
	} else {
		card->pcm_device_id = ID_DEVICE_NOT_SUPPORTED;
	}

	if (num_compress_offload_devices > 0) {
		struct spa_device_object_info info;
		struct spa_dict_item items[11];
		unsigned int n_items = 0;
		char device_name[200];
		char device_desc[200];

		card->compress_offload_device_id = calc_compress_offload_device_id(card);

		spa_log_debug(this->log, "emitting Compress-Offload device interface for card %s; "
		              "using local alsa-udev object ID %" PRIu32, path, card->compress_offload_device_id);

		info = SPA_DEVICE_OBJECT_INFO_INIT();

		info.type = SPA_TYPE_INTERFACE_Device;
		info.factory_name = SPA_NAME_API_ALSA_COMPRESS_OFFLOAD_DEVICE;
		info.change_mask = SPA_DEVICE_OBJECT_CHANGE_MASK_FLAGS |
			SPA_DEVICE_OBJECT_CHANGE_MASK_PROPS;
		info.flags = 0;

		snprintf(device_name, sizeof(device_name), "comprC%u", card->card_nr);
		snprintf(device_desc, sizeof(device_desc), "Compress-Offload device (ALSA card %u)", card->card_nr);

		items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_ENUM_API, "udev");
		items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_API,  "alsa:compressed");
		items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_NAME, device_name);
		items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_DESCRIPTION, device_desc);
		items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_MEDIA_CLASS, "Audio/Device");
		items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_API_ALSA_PATH, path);
		items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_API_ALSA_CARD, path+3);

		if ((str = udev_device_get_property_value(udev_device, "USEC_INITIALIZED")) && *str)
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_PLUGGED_USEC, str);

		str = udev_device_get_property_value(udev_device, "ID_PATH");
		if (!(str && *str))
			str = udev_device_get_syspath(udev_device);
		if (str && *str) {
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_BUS_PATH, str);
		}
		if ((str = udev_device_get_devpath(udev_device)) && *str) {
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_SYSFS_PATH, str);
		}
		if ((str = udev_device_get_property_value(udev_device, "SUBSYSTEM")) && *str) {
			items[n_items++] = SPA_DICT_ITEM_INIT(SPA_KEY_DEVICE_SUBSYSTEM, str);
		}

		info.props = &SPA_DICT_INIT(items, n_items);

		spa_log_debug(this->log, "interface information:");
		spa_debug_log_dict(this->log, SPA_LOG_LEVEL_DEBUG, 2, info.props);

		spa_device_emit_object_info(&this->hooks, card->compress_offload_device_id, &info);
	} else {
		card->compress_offload_device_id = ID_DEVICE_NOT_SUPPORTED;
	}

	return 1;
}

static bool check_access(struct impl *this, struct card *card)
{
	char path[128], pcm_prefix[32], compr_prefix[32];;
	spa_autoptr(DIR) snd = NULL;
	struct dirent *entry;
	bool accessible = false;

	snprintf(path, sizeof(path), "/dev/snd/controlC%u", card->card_nr);
	if (access(path, R_OK|W_OK) >= 0 && (snd = opendir("/dev/snd"))) {
		/*
		 * It's possible that controlCX is accessible before pcmCX* or
		 * the other way around. Return true only if all devices are
                 * accessible.
		 */

		accessible = true;
		spa_scnprintf(pcm_prefix, sizeof(pcm_prefix), "pcmC%uD", card->card_nr);
		spa_scnprintf(compr_prefix, sizeof(compr_prefix), "comprC%uD", card->card_nr);
		while ((entry = readdir(snd)) != NULL) {
			if (!(entry->d_type == DT_CHR &&
			      (spa_strstartswith(entry->d_name, pcm_prefix) ||
			       spa_strstartswith(entry->d_name, compr_prefix))))
				continue;

			snprintf(path, sizeof(path), "/dev/snd/%.32s", entry->d_name);
			if (access(path, R_OK|W_OK) < 0) {
				accessible = false;
				break;
			}
		}
	}

	if (accessible != card->accessible)
		spa_log_debug(this->log, "%s accessible:%u", path, accessible);
	card->accessible = accessible;

	return card->accessible;
}

static void process_card(struct impl *this, enum action action, struct card *card)
{
	if (card->ignored)
		return;

	switch (action) {
	case ACTION_CHANGE: {
		check_access(this, card);
		if (card->accessible && !card->emitted) {
			int res = emit_added_object_info(this, card);
			if (res < 0) {
				if (card->ignored)
					spa_log_info(this->log, "ALSA card %u unavailable (%s): it is ignored",
							card->card_nr, spa_strerror(res));
				else if (!card->unavailable)
					spa_log_info(this->log, "ALSA card %u unavailable (%s): wait for it",
							card->card_nr, spa_strerror(res));
				else
					spa_log_debug(this->log, "ALSA card %u still unavailable (%s)",
							card->card_nr, spa_strerror(res));
				card->unavailable = true;
			} else {
				if (card->unavailable)
					spa_log_info(this->log, "ALSA card %u now available",
							card->card_nr);
				card->unavailable = false;
			}
		} else if (!card->accessible && card->emitted) {
			card->emitted = false;

			if (card->pcm_device_id != ID_DEVICE_NOT_SUPPORTED)
				spa_device_emit_object_info(&this->hooks, card->pcm_device_id, NULL);
			if (card->compress_offload_device_id != ID_DEVICE_NOT_SUPPORTED)
				spa_device_emit_object_info(&this->hooks, card->compress_offload_device_id, NULL);
		}
		break;
	}
	case ACTION_REMOVE: {
		uint32_t pcm_device_id = card->pcm_device_id;
		uint32_t compress_offload_device_id = card->compress_offload_device_id;
		bool emitted = card->emitted;

		remove_card(this, card);

		if (emitted) {
			if (pcm_device_id != ID_DEVICE_NOT_SUPPORTED)
				spa_device_emit_object_info(&this->hooks, pcm_device_id, NULL);
			if (compress_offload_device_id != ID_DEVICE_NOT_SUPPORTED)
				spa_device_emit_object_info(&this->hooks, compress_offload_device_id, NULL);
		}
		break;
	}
	}
}

static void process_udev_device(struct impl *this, enum action action, struct udev_device *udev_device)
{
	unsigned int card_nr;
	struct card *card;

	if ((card_nr = get_card_nr(this, udev_device)) == SPA_ID_INVALID)
		return;

	card = find_card(this, card_nr);
	if (action == ACTION_CHANGE && !card)
		card = add_card(this, card_nr, udev_device);

	if (!card)
		return;

	process_card(this, action, card);
}

static int stop_inotify(struct impl *this)
{
	if (this->notify.fd == -1)
		return 0;
	spa_log_info(this->log, "stop inotify");
	spa_loop_remove_source(this->main_loop, &this->notify);
	close(this->notify.fd);
	this->notify.fd = -1;
	return 0;
}

static void impl_on_notify_events(struct spa_source *source)
{
	bool deleted = false;
	struct impl *this = source->data;
	union {
		struct inotify_event e;
		char name[NAME_MAX+1+sizeof(struct inotify_event)];
	} buf;

	while (true) {
		ssize_t len;
		const struct inotify_event *event;
		void *p, *e;

		len = read(source->fd, &buf, sizeof(buf));
		if (len <= 0)
			break;

		e = SPA_PTROFF(&buf, len, void);

		for (p = &buf; p < e;
		     p = SPA_PTROFF(p, sizeof(struct inotify_event) + event->len, void)) {
			unsigned int card_nr;
			struct card *card;

			event = (const struct inotify_event *) p;
			spa_assert_se(SPA_PTRDIFF(e, p) >= (ptrdiff_t)sizeof(struct inotify_event) &&
			              SPA_PTRDIFF(e, p) - sizeof(struct inotify_event) >= event->len &&
			              "bad event from kernel");

			/* card becomes accessible or not busy */
			if ((event->mask & (IN_ATTRIB | IN_CLOSE_WRITE))) {
				if (sscanf(event->name, "controlC%u", &card_nr) != 1 &&
				    sscanf(event->name, "pcmC%uD", &card_nr) != 1)
					continue;
				if ((card = find_card(this, card_nr)) == NULL)
					continue;

				process_card(this, ACTION_CHANGE, card);
			}
			/* /dev/snd/ might have been removed */
			if ((event->mask & (IN_IGNORED | IN_MOVE_SELF)))
				deleted = true;
		}
	}
	if (deleted)
		stop_inotify(this);
}

static int start_inotify(struct impl *this)
{
	int res, notify_fd;

	if (this->notify.fd != -1)
		return 0;

	if ((notify_fd = inotify_init1(IN_CLOEXEC | IN_NONBLOCK)) < 0)
		return -errno;

	res = inotify_add_watch(notify_fd, "/dev/snd",
			IN_ATTRIB | IN_CLOSE_WRITE | IN_MOVE_SELF);
	if (res < 0) {
		res = -errno;
		close(notify_fd);

		if (res == -ENOENT) {
			spa_log_debug(this->log, "/dev/snd/ does not exist yet");
			return 0;
		}
		spa_log_error(this->log, "inotify_add_watch() failed: %s", spa_strerror(res));
		return res;
	}
	spa_log_info(this->log, "start inotify");
	this->notify.func = impl_on_notify_events;
	this->notify.data = this;
	this->notify.fd = notify_fd;
	this->notify.mask = SPA_IO_IN | SPA_IO_ERR;

	spa_loop_add_source(this->main_loop, &this->notify);

	return 0;
}

static void impl_on_fd_events(struct spa_source *source)
{
	struct impl *this = source->data;
	struct udev_device *udev_device;
	const char *action;

	udev_device = udev_monitor_receive_device(this->umonitor);
	if (udev_device == NULL)
		return;

	if ((action = udev_device_get_action(udev_device)) == NULL)
		action = "change";

	spa_log_debug(this->log, "action %s", action);

	start_inotify(this);

	if (spa_streq(action, "add") || spa_streq(action, "change")) {
		process_udev_device(this, ACTION_CHANGE, udev_device);
	} else if (spa_streq(action, "remove")) {
		process_udev_device(this, ACTION_REMOVE, udev_device);
	}
	udev_device_unref(udev_device);
}

static int start_monitor(struct impl *this)
{
	int res;

	if (this->umonitor != NULL)
		return 0;

	this->umonitor = udev_monitor_new_from_netlink(this->udev, "udev");
	if (this->umonitor == NULL)
		return -ENOMEM;

	udev_monitor_filter_add_match_subsystem_devtype(this->umonitor,
							"sound", NULL);
	udev_monitor_enable_receiving(this->umonitor);

	this->source.func = impl_on_fd_events;
	this->source.data = this;
	this->source.fd = udev_monitor_get_fd(this->umonitor);
	this->source.mask = SPA_IO_IN | SPA_IO_ERR;

	spa_log_debug(this->log, "monitor %p", this->umonitor);
	spa_loop_add_source(this->main_loop, &this->source);

	if ((res = start_inotify(this)) < 0)
		return res;

	return 0;
}

static int stop_monitor(struct impl *this)
{
	if (this->umonitor == NULL)
		return 0;

        clear_cards (this);

	spa_loop_remove_source(this->main_loop, &this->source);
	udev_monitor_unref(this->umonitor);
	this->umonitor = NULL;

	stop_inotify(this);

	return 0;
}

static int enum_cards(struct impl *this)
{
	struct udev_enumerate *enumerate;
	struct udev_list_entry *udev_devices;

	enumerate = udev_enumerate_new(this->udev);
	if (enumerate == NULL)
		return -ENOMEM;

	udev_enumerate_add_match_subsystem(enumerate, "sound");
	udev_enumerate_scan_devices(enumerate);

	for (udev_devices = udev_enumerate_get_list_entry(enumerate); udev_devices;
			udev_devices = udev_list_entry_get_next(udev_devices)) {
		struct udev_device *udev_device;

		udev_device = udev_device_new_from_syspath(this->udev,
		                                           udev_list_entry_get_name(udev_devices));
		if (udev_device == NULL)
			continue;

		process_udev_device(this, ACTION_CHANGE, udev_device);

		udev_device_unref(udev_device);
	}
	udev_enumerate_unref(enumerate);

	return 0;
}

static const struct spa_dict_item device_info_items[] = {
	{ SPA_KEY_DEVICE_API, "udev" },
	{ SPA_KEY_DEVICE_NICK, "alsa-udev" },
	{ SPA_KEY_API_UDEV_MATCH, "sound" },
};

static void emit_device_info(struct impl *this, bool full)
{
	uint64_t old = full ? this->info.change_mask : 0;
	if (full)
		this->info.change_mask = this->info_all;
	if (this->info.change_mask) {
		this->info.props = &SPA_DICT_INIT_ARRAY(device_info_items);
		spa_device_emit_info(&this->hooks, &this->info);
		this->info.change_mask = old;
	}
}

static void impl_hook_removed(struct spa_hook *hook)
{
	struct impl *this = hook->priv;
	if (spa_hook_list_is_empty(&this->hooks)) {
		stop_monitor(this);
		impl_udev_close(this);
	}
}

static int
impl_device_add_listener(void *object, struct spa_hook *listener,
		const struct spa_device_events *events, void *data)
{
	int res;
	struct impl *this = object;
        struct spa_hook_list save;

	spa_return_val_if_fail(this != NULL, -EINVAL);
	spa_return_val_if_fail(events != NULL, -EINVAL);

	if ((res = impl_udev_open(this)) < 0)
		return res;

        spa_hook_list_isolate(&this->hooks, &save, listener, events, data);

	emit_device_info(this, true);

	if ((res = start_monitor(this)) < 0)
		return res;

	if ((res = enum_cards(this)) < 0)
		return res;

        spa_hook_list_join(&this->hooks, &save);

	listener->removed = impl_hook_removed;
	listener->priv = this;

	return 0;
}

static const struct spa_device_methods impl_device = {
	SPA_VERSION_DEVICE_METHODS,
	.add_listener = impl_device_add_listener,
};

static int impl_get_interface(struct spa_handle *handle, const char *type, void **interface)
{
	struct impl *this;

	spa_return_val_if_fail(handle != NULL, -EINVAL);
	spa_return_val_if_fail(interface != NULL, -EINVAL);

	this = (struct impl *) handle;

	if (spa_streq(type, SPA_TYPE_INTERFACE_Device))
		*interface = &this->device;
	else
		return -ENOENT;

	return 0;
}

static int impl_clear(struct spa_handle *handle)
{
	struct impl *this = (struct impl *) handle;
	stop_monitor(this);
	impl_udev_close(this);
	return 0;
}

static size_t
impl_get_size(const struct spa_handle_factory *factory,
	      const struct spa_dict *params)
{
	return sizeof(struct impl);
}

static int
impl_init(const struct spa_handle_factory *factory,
	  struct spa_handle *handle,
	  const struct spa_dict *info,
	  const struct spa_support *support,
	  uint32_t n_support)
{
	struct impl *this;
	const char *str;

	spa_return_val_if_fail(factory != NULL, -EINVAL);
	spa_return_val_if_fail(handle != NULL, -EINVAL);

	handle->get_interface = impl_get_interface;
	handle->clear = impl_clear;

	this = (struct impl *) handle;
	this->notify.fd = -1;

	this->log = spa_support_find(support, n_support, SPA_TYPE_INTERFACE_Log);
	alsa_log_topic_init(this->log);
	this->main_loop = spa_support_find(support, n_support, SPA_TYPE_INTERFACE_Loop);
	this->main_system = spa_support_find(support, n_support, SPA_TYPE_INTERFACE_System);
	this->use_ucm = -1;

	if (this->main_loop == NULL) {
		spa_log_error(this->log, "a main-loop is needed");
		return -EINVAL;
	}
	if (this->main_system == NULL) {
		spa_log_error(this->log, "a main-system is needed");
		return -EINVAL;
	}
	spa_hook_list_init(&this->hooks);

	this->device.iface = SPA_INTERFACE_INIT(
			SPA_TYPE_INTERFACE_Device,
			SPA_VERSION_DEVICE,
			&impl_device, this);

	this->info = SPA_DEVICE_INFO_INIT();
	this->info_all = SPA_DEVICE_CHANGE_MASK_FLAGS |
			SPA_DEVICE_CHANGE_MASK_PROPS;
	this->info.flags = 0;

	if (info) {
		if ((str = spa_dict_lookup(info, "alsa.use-acp")) != NULL)
			this->use_acp = spa_atob(str);
		else if ((str = spa_dict_lookup(info, "alsa.udev.expose-busy")) != NULL)
			this->expose_busy = spa_atob(str);
		else if ((str = spa_dict_lookup(info, "alsa.use-ucm")) != NULL)
			this->use_ucm = spa_atob(str) ? 1 : 0;
	}

	return 0;
}

static const struct spa_interface_info impl_interfaces[] = {
	{SPA_TYPE_INTERFACE_Device,},
};

static int
impl_enum_interface_info(const struct spa_handle_factory *factory,
			 const struct spa_interface_info **info,
			 uint32_t *index)
{
	spa_return_val_if_fail(factory != NULL, -EINVAL);
	spa_return_val_if_fail(info != NULL, -EINVAL);
	spa_return_val_if_fail(index != NULL, -EINVAL);

	if (*index >= SPA_N_ELEMENTS(impl_interfaces))
		return 0;

	*info = &impl_interfaces[(*index)++];
	return 1;
}

const struct spa_handle_factory spa_alsa_udev_factory = {
	SPA_VERSION_HANDLE_FACTORY,
	SPA_NAME_API_ALSA_ENUM_UDEV,
	NULL,
	impl_get_size,
	impl_init,
	impl_enum_interface_info,
};