1 files changed, 105 insertions, 0 deletions
diff --git a/package/tapi_sip/src/tapi_agent.c b/package/tapi_sip/src/tapi_agent.c
new file mode 100644
index 0000000000..93c73c24d8
--- /dev/null
+++ b/package/tapi_sip/src/tapi_agent.c
@@ -0,0 +1,105 @@
+
+#include <stdbool.h>
+#include <stdio.h>
+#include <tapi-port.h>
+
+#include "session.h"
+#include "agent.h"
+#include "tapi_agent.h"
+
+static int tapi_agent_invite(struct agent *agent, struct session *session)
+{
+	struct tapi_agent *tagent = agent_to_tapi_agent(agent);
+
+	if (tagent->session)
+		return -1;
+
+	tagent->state = TAPI_AGENT_STATE_RINGING;
+	tapi_port_set_ring(&tagent->port, true);
+
+	tagent->session = session;
+
+	return 0;
+}
+
+static int tapi_agent_accept(struct agent *agent, struct session *session)
+{
+	return 0;
+}
+
+static int tapi_agent_hangup(struct agent *agent, struct session *session)
+{
+	struct tapi_agent *tagent = agent_to_tapi_agent(agent);
+
+	switch (tagent->state) {
+	case TAPI_AGENT_STATE_RINGING:
+		tapi_port_set_ring(&tagent->port, false);
+		break;
+	default:
+		break;
+	}
+
+	tagent->state = TAPI_AGENT_STATE_IDLE;
+	tagent->session = NULL;
+
+	return 0;
+}
+
+static int tapi_agent_get_endpoint(struct agent *agent, struct session *session)
+{
+	struct tapi_agent *tagent = agent_to_tapi_agent(agent);
+	return tapi_port_get_endpoint(&tagent->port);
+}
+
+static const struct agent_ops tapi_agent_ops = {
+	.invite = tapi_agent_invite,
+	.accept = tapi_agent_accept,
+	.hangup = tapi_agent_hangup,
+	.get_endpoint = tapi_agent_get_endpoint,
+};
+
+static void tapi_agent_event(struct tapi_port *port, struct tapi_event *event,
+	void *data)
+{
+	struct tapi_agent *tagent = data;
+
+	if (event->type != TAPI_EVENT_TYPE_HOOK)
+		return;
+
+	if (!tagent->session)
+		return;
+
+	if (event->hook.on) {
+		session_hangup(tagent->session, &tagent->agent);
+		tagent->state = TAPI_AGENT_STATE_IDLE;
+		tagent->session = NULL;
+	} else {
+		session_accept(tagent->session, &tagent->agent);
+		tagent->state = TAPI_AGENT_STATE_ACTIVE;
+	}
+}
+
+void tapi_agent_init(struct tapi_device *tdev, int port, struct tapi_agent *tagent)
+{
+	int ret;
+
+	tagent->agent.ops = &tapi_agent_ops;
+	tagent->state = TAPI_AGENT_STATE_IDLE;
+	tagent->session = NULL;
+
+	ret = tapi_port_open(tdev, port, &tagent->port);
+	if (ret) {
+		printf("Failed to open tapi port %d: %d\n", port, ret);
+		return;
+	}
+
+	tagent->event_listener.callback = tapi_agent_event;
+	tagent->event_listener.data = tagent;
+
+	tapi_port_register_event(&tagent->port, &tagent->event_listener);
+}
+
+void tapi_agent_free(struct tapi_agent *tagent)
+{
+	tapi_port_unregister_event(&tagent->port, &tagent->event_listener);
+}