Method ExecuteRedisTransaction

lib/icingadb/icingadb-objects.cpp:3229–3264

* Execute the provided HMSET values and runtime updates in a single Redis transaction on the provided Redis connection. * * The HMSETs should just contain the necessary key value pairs to be set in Redis, i.e, without the HMSET command * itself. This function will then go through each of the map keys and prepend the HMSET command when transforming the * map into valid Redis queries. Likewise,

 * @param runtimeUpdates A list of dictionaries to be sent to the icinga:runtime stream.
 */
void IcingaDB::ExecuteRedisTransaction(const RedisConnection::Ptr& rcon,
	std::map<RedisConnection::QueryArg, RedisConnection::Query>& hMSets, const std::vector<Dictionary::Ptr>& runtimeUpdates)
{
	RedisConnection::Queries transaction{{"MULTI"}};
	for (auto& [redisKey, query] : hMSets) {
		if (!query.empty()) {
			query.insert(query.begin(), {"HSET", redisKey});
			transaction.emplace_back(std::move(query));
		}
	}

	for (auto& attrs : runtimeUpdates) {
		RedisConnection::Query xAdd{"XADD", "icinga:runtime", "MAXLEN", "~", "1000000", "*"};

		ObjectLock olock(attrs);
		for (auto& [key, value] : attrs) {
			if (auto streamVal(IcingaToStreamValue(value)); !streamVal.IsEmpty()) {
				xAdd.emplace_back(key);
				xAdd.emplace_back(std::move(streamVal));
			}
		}

		transaction.emplace_back(std::move(xAdd));
	}

	if (transaction.size() > 1) {
		transaction.emplace_back(RedisConnection::Query{"EXEC"});
		if (!runtimeUpdates.empty()) {
			rcon->FireAndForgetQueries(std::move(transaction), {1});
		} else {
			// This is likely triggered by the initial Redis config dump, so a) we don't need to record the number of
			// affected objects and b) we don't really know how many objects are going to be affected by this tx.
			rcon->FireAndForgetQueries(std::move(transaction));
		}
	}
}