Function ParseActionsArray

pg_documentdb/src/commands/roles.c:606–659

* ParseActionsArray parses the "actions" field from a privilege entry. * Returns a hash set of action strings for automatic deduplication. */

 * Returns a hash set of action strings for automatic deduplication.
 */
static HTAB *
ParseActionsArray(bson_iter_t *privilegeDocIter)
{
	if (bson_iter_type(privilegeDocIter) != BSON_TYPE_ARRAY)
	{
		ereport(ERROR, (errcode(ERRCODE_DOCUMENTDB_BADVALUE),
						errmsg("'actions' must be an array.")));
	}

	/* Create a hash set for deduplication */
	HASHCTL hashCtl;
	MemSet(&hashCtl, 0, sizeof(hashCtl));
	hashCtl.keysize = NAMEDATALEN;
	hashCtl.entrysize = NAMEDATALEN;
	HTAB *actions = hash_create("ActionsSet", 8, &hashCtl, HASH_ELEM | HASH_STRINGS);

	bson_iter_t actionsIter;
	bson_iter_recurse(privilegeDocIter, &actionsIter);

	while (bson_iter_next(&actionsIter))
	{
		if (bson_iter_type(&actionsIter) != BSON_TYPE_UTF8)
		{
			hash_destroy(actions);
			ereport(ERROR, (errcode(ERRCODE_DOCUMENTDB_BADVALUE),
							errmsg("Each action must be a string.")));
		}

		uint32_t actionLength = 0;
		const char *action = bson_iter_utf8(&actionsIter, &actionLength);

		if (actionLength > 0 && actionLength < NAMEDATALEN)
		{
			if (!IsActionSupported(action))
			{
				hash_destroy(actions);
				ereport(ERROR, (errcode(ERRCODE_DOCUMENTDB_BADVALUE),
								errmsg("Unsupported action '%s'.",
									   action)));
			}

			hash_search(actions, action, HASH_ENTER, NULL);
		}
	}

	if (hash_get_num_entries(actions) == 0)
	{
		hash_destroy(actions);
		ereport(ERROR, (errcode(ERRCODE_DOCUMENTDB_BADVALUE),
						errmsg("At least one valid action must be specified.")));
	}

	return actions;
}


/*