/* radare2 - BSD 3 Clause License - crowell, pancake, ret2libc 2016-2025 */

#define LOAD_FACTOR 1
#define S_ARRAY_SIZE(x) (sizeof (x) / sizeof (x[0]))

// Sizes of the ht.
static const ut32 ht_primes_sizes[] = {
	3, 7, 11, 17, 23, 29, 37, 47, 59, 71, 89, 107, 131,
	163, 197, 239, 293, 353, 431, 521, 631, 761, 919,
	1103, 1327, 1597, 1931, 2333, 2801, 3371, 4049, 4861,
	5839, 7013, 8419, 10103, 12143, 14591, 17519, 21023,
	25229, 30293, 36353, 43627, 52361, 62851, 75431, 90523,
	108631, 130363, 156437, 187751, 225307, 270371, 324449,
	389357, 467237, 560689, 672827, 807403, 968897, 1162687,
	1395263, 1674319, 2009191, 2411033, 2893249, 3471899,
	4166287, 4999559, 5999471, 7199369
};

static inline ut32 hashfn(HtName_(Ht) *ht, const KEY_TYPE k) {
	return ht->opt.hashfn ? ht->opt.hashfn (k) : KEY_TO_HASH (k);
}

static inline ut32 bucketfn(HtName_(Ht) *ht, const KEY_TYPE k) {
	return hashfn (ht, k) % ht->size;
}

static inline KEY_TYPE dupkey(HtName_(Ht) *ht, const KEY_TYPE k) {
	return ht->opt.dupkey ? ht->opt.dupkey (k) : (KEY_TYPE)k;
}

static inline VALUE_TYPE dupval(HtName_(Ht) *ht, const VALUE_TYPE v) {
	return ht->opt.dupvalue ? ht->opt.dupvalue (v) : (VALUE_TYPE)v;
}

static inline ut32 calcsize_key(HtName_(Ht) *ht, const KEY_TYPE k) {
	return ht->opt.calcsizeK ? ht->opt.calcsizeK (k) : 0;
}

static inline ut32 calcsize_val(HtName_(Ht) *ht, const VALUE_TYPE v) {
	return ht->opt.calcsizeV ? ht->opt.calcsizeV (v) : 0;
}

static inline void freefn(HtName_(Ht) *ht, HT_(Kv) *kv) {
	if (ht->opt.freefn) {
		ht->opt.freefn (kv);
	}
}

static inline ut32 next_idx(ut32 idx) {
	if (idx != UT32_MAX && idx < S_ARRAY_SIZE (ht_primes_sizes) - 1) {
		return idx + 1;
	}
	return UT32_MAX;
}

static inline ut32 compute_size(ut32 idx, ut32 sz) {
	// when possible, use the precomputed prime numbers which help with
	// collisions, otherwise, at least make the number odd with |1
	return idx != UT32_MAX && idx < S_ARRAY_SIZE(ht_primes_sizes) ? ht_primes_sizes[idx] : (sz | 1);
}

static inline bool is_kv_equal(HtName_(Ht) *ht, const KEY_TYPE key, const ut32 key_len, const HT_(Kv) *kv) {
	if (key_len != kv->key_len) {
		return false;
	}

	bool res = key == kv->key;
	if (!res && ht->opt.cmp) {
		res = !ht->opt.cmp (key, kv->key);
	}
	return res;
}

static inline HT_(Kv) *kv_at(HtName_(Ht) *ht, HT_(Bucket) *bt, ut32 i) {
	return (HT_(Kv) *)((char *)bt->arr + i * ht->opt.elem_size);
}

static inline HT_(Kv) *next_kv(HtName_(Ht) *ht, HT_(Kv) *kv) {
	return (HT_(Kv) *)((char *)kv + ht->opt.elem_size);
}

#define BUCKET_FOREACH(ht, bt, j, kv)					\
	if ((bt)->arr)							\
		for ((j) = 0, (kv) = (bt)->arr; (j) < (bt)->count; (j)++, (kv) = next_kv (ht, kv))

#define BUCKET_FOREACH_SAFE(ht, bt, j, count, kv)			\
	if ((bt)->arr)							\
		for ((j) = 0, (kv) = (bt)->arr, (count) = (ht)->count;	\
		     (j) < (bt)->count;					\
		     (j) = (count) == (ht)->count? j + 1: j, (kv) = (count) == (ht)->count? next_kv (ht, kv): kv, (count) = (ht)->count)

// Create a new hashtable and return a pointer to it.
// size - number of buckets in the hashtable
// hashfunction - the function that does the hashing, must not be null.
// comparator - the function to check if values are equal, if NULL, just checks
// == (for storing ints).
// keydup - function to duplicate to key (eg sdb_strdup), if NULL just does strup.
// valdup - same as keydup, but for values but if NULL just assign
// pair_free - function for freeing resources owned by a keyvaluepair.
//             Callbacks may free owned payloads, but must not free kv itself.
// calcsize - function to calculate the size of a value. if NULL, just stores 0.
static HtName_(Ht)* internal_ht_new(ut32 size, ut32 prime_idx, HT_(Options) *opt) {
	HtName_(Ht)* ht = (HtName_(Ht)*)sdb_gh_calloc (1, sizeof (*ht));
	if (SDB_LIKELY (ht)) {
		ht->size = size;
		ht->count = 0;
		ht->prime_idx = prime_idx;
		ht->table = (HT_(Bucket)*)sdb_gh_calloc (ht->size, sizeof (*ht->table));
		if (!ht->table) {
			sdb_gh_free (ht);
			return NULL;
		}
		ht->opt = *opt;
		// if not provided, assume we are dealing with a regular HtName_(Ht), with
		// HT_(Kv) as elements
		if (ht->opt.elem_size == 0) {
			ht->opt.elem_size = sizeof (HT_(Kv));
		}
		return ht;
	}
	return NULL;
}

SDB_API HtName_(Ht) *Ht_(new_opt)(HT_(Options) *opt) {
	return internal_ht_new (ht_primes_sizes[0], 0, opt);
}

SDB_API void Ht_(free)(HtName_(Ht)* ht) {
	if (SDB_LIKELY (ht)) {
		ut32 i, htsize = ht->size;
		HT_(Bucket) *table = ht->table;
		for (i = 0; i < htsize; i++) {
			HT_(Bucket) *bt = &table[i];
			HT_(Kv) *kv;
			ut32 j;
			BUCKET_FOREACH (ht, bt, j, kv) {
				freefn (ht, kv);
			}
			sdb_gh_free (bt->arr);
		}
		sdb_gh_free (ht->table);
		sdb_gh_free (ht);
	}
}

// Increases the size of the hashtable by 2.
static void internal_ht_grow(HtName_(Ht)* ht) {
	HtName_(Ht) swap;
	ut32 idx = next_idx (ht->prime_idx);
	ut32 sz = compute_size (idx, ht->size * 2);
	ut32 i;

	HtName_(Ht)* ht2 = internal_ht_new (sz, idx, &ht->opt);
	if (!ht2) {
		// we can't grow the ht anymore. Never mind, we'll be slower,
		// but everything can continue to work
		return;
	}

	HT_(Bucket) *table = ht->table;
	for (i = 0; i < ht->size; i++) {
		HT_(Bucket) *bt = &table[i];
		HT_(Kv) *kv;
		ut32 j;

		BUCKET_FOREACH (ht, bt, j, kv) {
			Ht_(insert_kv) (ht2, kv, false);
		}
	}
	// And now swap the internals.
	swap = *ht;
	*ht = *ht2;
	*ht2 = swap;

	ht2->opt.freefn = NULL;
	Ht_(free) (ht2);
}

static void check_growing(HtName_(Ht) *ht) {
	if (ht->count >= LOAD_FACTOR * ht->size) {
		internal_ht_grow (ht);
	}
}

static HT_(Kv) *reserve_kv(HtName_(Ht) *ht, const KEY_TYPE key, const int key_len, bool update) {
	HT_(Bucket) *bt = &ht->table[bucketfn (ht, key)];
	HT_(Kv) *kvtmp;
	ut32 j;

	BUCKET_FOREACH (ht, bt, j, kvtmp) {
		if (is_kv_equal (ht, key, key_len, kvtmp)) {
			if (update) {
				freefn (ht, kvtmp);
				return kvtmp;
			}
			return NULL;
		}
	}

	if (bt->count + 1 >= bt->size) {
		bt->size = (bt->count + 1) * 2;
		HT_(Kv) *newkvarr = (HT_(Kv)*)sdb_gh_realloc (bt->arr, (bt->size) * ht->opt.elem_size);
		if (!SDB_UNLIKELY (newkvarr)) {
			return NULL;
		}
		bt->arr = newkvarr;
	}
	bt->count++;
	ht->count++;
	return kv_at (ht, bt, bt->count - 1);
}

SDB_API bool Ht_(insert_kv)(HtName_(Ht) *ht, HT_(Kv) *kv, bool update) {
	HT_(Kv) *kv_dst = reserve_kv (ht, kv->key, kv->key_len, update);
	if (SDB_LIKELY (kv_dst)) {
		memcpy (kv_dst, kv, ht->opt.elem_size);
		check_growing (ht);
		return true;
	}
	return false;
}

static bool insert_update(HtName_(Ht) *ht, const KEY_TYPE key, VALUE_TYPE value, bool update) {
	ut32 key_len = calcsize_key (ht, key);
	HT_(Kv)* kv_dst = reserve_kv (ht, key, key_len, update);
	if (SDB_LIKELY (kv_dst)) {
		kv_dst->key = dupkey (ht, key);
		kv_dst->key_len = key_len;
		kv_dst->value = dupval (ht, value);
		kv_dst->value_len = calcsize_val (ht, value);
		check_growing (ht);
		return true;
	}
	return false;
}

// Inserts the key value pair key, value into the hashtable.
// Doesn't allow for "update" of the value.
SDB_API bool Ht_(insert)(HtName_(Ht)* ht, const KEY_TYPE key, VALUE_TYPE value) {
	return insert_update (ht, key, value, false);
}

// Inserts the key value pair key, value into the hashtable.
// Does allow for "update" of the value.
SDB_API bool Ht_(update)(HtName_(Ht)* ht, const KEY_TYPE key, VALUE_TYPE value) {
	return insert_update (ht, key, value, true);
}

// Update the key of an element that has old_key as key and replace it with new_key
SDB_API bool Ht_(update_key)(HtName_(Ht)* ht, const KEY_TYPE old_key, const KEY_TYPE new_key) {
	// First look for the value associated with old_key
	bool found;
	VALUE_TYPE value = Ht_(find) (ht, old_key, &found);
	if (!found) {
		return false;
	}

	// Associate the existing value with new_key
	bool inserted = insert_update (ht, new_key, value, false);
	if (!inserted) {
		return false;
	}

	// Remove the old_key kv, paying attention to not double free the value
	HT_(Bucket) *bt = &ht->table[bucketfn (ht, old_key)];
	const int old_key_len = calcsize_key (ht, old_key);
	HT_(Kv) *kv;
	ut32 j;

	const bool dupvalue = ht->opt.dupvalue;
	const size_t elem_size = ht->opt.elem_size;
	BUCKET_FOREACH (ht, bt, j, kv) {
		if (is_kv_equal (ht, old_key, old_key_len, kv)) {
			if (!dupvalue) {
				// do not free the value part if dupvalue is not
				// set, because the old value has been
				// associated with the new key and it should not
				// be freed
				kv->value = HT_NULL_VALUE;
				kv->value_len = 0;
			}
			freefn (ht, kv);
			void *src = next_kv (ht, kv);
			memmove (kv, src, (bt->count - j - 1) * elem_size);
			bt->count--;
			ht->count--;
			return true;
		}
	}
	return false;
}

// Returns the corresponding SdbKv entry from the key.
// If `found` is not NULL, it will be set to true if the entry was found, false
// otherwise.
SDB_API HT_(Kv)* Ht_(find_kv)(HtName_(Ht)* ht, const KEY_TYPE key, bool* found) {
	if (found) {
		*found = false;
	}
	if (!ht) {
		if (found) {
			*found = false;
		}
		return NULL;
	}

	HT_(Bucket) *bt = &ht->table[bucketfn (ht, key)];
	ut32 key_len = calcsize_key (ht, key);
	HT_(Kv) *kv;
	ut32 j;

	BUCKET_FOREACH (ht, bt, j, kv) {
		if (is_kv_equal (ht, key, key_len, kv)) {
			if (found) {
				*found = true;
			}
			return kv;
		}
	}
	return NULL;
}

// Looks up the corresponding value from the key.
// If `found` is not NULL, it will be set to true if the entry was found, false
// otherwise.
SDB_API VALUE_TYPE Ht_(find)(HtName_(Ht)* ht, const KEY_TYPE key, bool* found) {
	HT_(Kv) *res = Ht_(find_kv) (ht, key, found);
	return res ? res->value : HT_NULL_VALUE;
}

// Deletes a entry from the hash table from the key, if the pair exists.
SDB_API bool Ht_(delete)(HtName_(Ht)* ht, const KEY_TYPE key) {
	HT_(Bucket) *bt = &ht->table[bucketfn (ht, key)];
	ut32 key_len = calcsize_key (ht, key);
	HT_(Kv) *kv;
	ut32 j;

	BUCKET_FOREACH (ht, bt, j, kv) {
		if (is_kv_equal (ht, key, key_len, kv)) {
			freefn (ht, kv);
			void *src = next_kv (ht, kv);
			memmove (kv, src, (bt->count - j - 1) * ht->opt.elem_size);
			bt->count--;
			ht->count--;
			return true;
		}
	}
	return false;
}

SDB_API void Ht_(foreach)(HtName_(Ht) *ht, HT_(ForeachCallback) cb, void *user) {
	ut32 i, htsize = ht->size;

	for (i = 0; i < htsize; i++) {
		HT_(Bucket) *bt = &ht->table[i];
		HT_(Kv) *kv;
		ut32 j, count;

		BUCKET_FOREACH_SAFE (ht, bt, j, count, kv) {
			if (!cb (user, kv->key, kv->value)) {
				return;
			}
		}
	}
}