/* (C) 2015-2017 by Harald Welte <laforge@gnumonks.org>
 * (C) 2023-2024 by sysmocom s.f.m.c. GmbH <info@sysmocom.de>
 * All Rights Reserved
 *
 * SPDX-License-Identifier: GPL-2.0+
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 *
 */

#include <errno.h>

#include <osmocom/core/linuxlist.h>
#include <osmocom/core/logging.h>
#include <osmocom/core/talloc.h>
#include <osmocom/core/prim.h>
#include <osmocom/sigtran/osmo_ss7.h>
#include <osmocom/sigtran/mtp_sap.h>

#include "ss7_user.h"
#include "ss7_internal.h"
#include "xua_internal.h"

/***********************************************************************
 * MTP Users (Users of MTP, such as SCCP or ISUP)
 ***********************************************************************/

struct osmo_ss7_user *osmo_ss7_user_create(struct osmo_ss7_instance *inst, const char *name)
{
	struct osmo_ss7_user *user;
	user = talloc_zero(inst, struct osmo_ss7_user);
	if (!user)
		return NULL;

	user->inst = inst;
	user->name = talloc_strdup(user, name ? : "");
	return user;
}

void osmo_ss7_user_destroy(struct osmo_ss7_user *user)
{
	ss7_user_unregister_all(user);
	talloc_free(user);
}

struct osmo_ss7_user *ss7_user_find(struct osmo_ss7_instance *inst, uint8_t service_indicator)
{
	if (service_indicator >= ARRAY_SIZE(inst->user))
		return NULL;
	return inst->user[service_indicator];
}

struct osmo_ss7_instance *osmo_ss7_user_get_instance(const struct osmo_ss7_user *user)
{
	return user->inst;
}

void osmo_ss7_user_set_prim_cb(struct osmo_ss7_user *user, osmo_prim_cb prim_cb)
{
	user->prim_cb = prim_cb;
}

void osmo_ss7_user_set_priv(struct osmo_ss7_user *user, void *priv)
{
	user->priv = priv;
}

void *osmo_ss7_user_get_priv(const struct osmo_ss7_user *user)
{
	return user->priv;
}

/*! \brief Register a MTP user for a given service indicator
 *  \param[in] user SS7 user to register (including primitive call-back)
 *  \param[in] service_ind Service (ISUP, SCCP, ...)
 *  \returns 0 on success; negative on error */
int osmo_ss7_user_register(struct osmo_ss7_user *user, uint8_t service_ind)
{
	struct osmo_ss7_instance *inst = user->inst;

	if (service_ind >= ARRAY_SIZE(inst->user))
		return -EINVAL;

	if (inst->user[service_ind])
		return -EBUSY;

	LOGPSS7U(user, LOGL_DEBUG, "registering for SI %u with priv %p\n",
		 service_ind, user->priv);

	inst->user[service_ind] = user;

	return 0;
}

/*! \brief Unregister a MTP user for a given service indicator
 *  \param[in] user SS7 user to unregister.
 *  \param[in] service_ind Service (ISUP, SCCP, ...)
 *  \returns 0 on success; negative on error */
int osmo_ss7_user_unregister(struct osmo_ss7_user *user, uint8_t service_ind)
{
	struct osmo_ss7_instance *inst = user->inst;

	if (service_ind >= ARRAY_SIZE(inst->user))
		return -EINVAL;

	if (!inst->user[service_ind])
		return -ENODEV;

	if (inst->user[service_ind] != user)
		return -EINVAL;

	LOGPSS7U(user, LOGL_DEBUG, "unregistering from SI %u with priv %p\n",
		 service_ind, user->priv);

	inst->user[service_ind] = NULL;

	return 0;
}

void ss7_user_unregister_all(struct osmo_ss7_user *user)
{
	struct osmo_ss7_instance *inst = user->inst;
	for (unsigned int i = 0; i < ARRAY_SIZE(inst->user); i++) {
		if (inst->user[i] == user)
			inst->user[i] = NULL;
	}
}