/* $Id$ */
/* Copyright (c) 2011-2020 Pierre Pronchery <khorben@defora.org> */
/* This file is part of DeforaOS System libApp */
/* 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, version 3 of the License.
 *
 * 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 <sys/types.h>
#include <unistd.h>
#include <stdlib.h>
#ifdef DEBUG
# include <stdio.h>
#endif
#include <string.h>
#include <errno.h>
#include <System.h>
#include "App/appmessage.h"
#include "App/appserver.h"
#include "apptransport.h"
#include "appinterface.h"
#include "../config.h"


/* AppServer */
/* private */
/* types */
struct _AppServer
{
	App * app;
	char * name;
	AppServerOptions options;
	AppInterface * interface;
	Event * event;
	int event_free;
	AppTransport * transport;
	AppTransportHelper helper;
};


/* prototypes */
/* helpers */
static int _appserver_helper_message(void * data, AppTransport * transport,
		AppTransportClient * client, AppMessage * message);


/* public */
/* functions */
/* appserver_new */
AppServer * appserver_new(App * self, AppServerOptions options,
		const char * app, char const * name)
{
	return appserver_new_event(self, options, app, name, NULL);
}


/* appserver_new_event */
AppServer * appserver_new_event(App * self, AppServerOptions options,
		char const * app, char const * name, Event * event)
{
	AppServer * appserver;

	if((appserver = object_new(sizeof(*appserver))) == NULL)
		return NULL;
	appserver->app = self;
	appserver->name = string_new(app);
	appserver->options = options;
	appserver->interface = appinterface_new(ATM_SERVER, app);
	appserver->helper.data = appserver;
	appserver->helper.message = _appserver_helper_message;
	appserver->event = (event != NULL) ? event : event_new();
	appserver->event_free = (event != NULL) ? 0 : 1;
	appserver->transport = apptransport_new_app(ATM_SERVER,
			&appserver->helper, app, name, appserver->event);
	/* check for errors */
	if(appserver->name == NULL || appserver->interface == NULL
			|| appserver->transport == NULL
			|| appserver->event == NULL
			|| (((options & ASO_REGISTER) == ASO_REGISTER)
				&& appserver_register(appserver, NULL) != 0))
	{
		appserver_delete(appserver);
		return NULL;
	}
	return appserver;
}


/* appserver_delete */
void appserver_delete(AppServer * appserver)
{
#ifdef DEBUG
	fprintf(stderr, "DEBUG: %s()\n", __func__);
#endif
	if(appserver->interface != NULL)
		appinterface_delete(appserver->interface);
	if(appserver->event_free != 0)
		event_delete(appserver->event);
	object_delete(appserver);
}


/* accessors */
/* appserver_get_app */
char const * appserver_get_app(AppServer * appserver)
{
	return appinterface_get_app(appserver->interface);
}


/* appserver_get_status */
AppStatus * appserver_get_status(AppServer * appserver)
{
	return appinterface_get_status(appserver->interface);
}


/* useful */
/* appserver_loop */
int appserver_loop(AppServer * appserver)
{
#ifdef DEBUG
	fprintf(stderr, "DEBUG: %s()\n", __func__);
#endif
	return event_loop(appserver->event);
}


/* appserver_register */
int appserver_register(AppServer * appserver, char const * name)
{
	return apptransport_server_register(appserver->transport,
			appserver->name, name);
}


/* private */
/* appserver_helper_message */
static int _helper_message_call(AppServer * appserver, AppTransport * transport,
		AppTransportClient * client, AppMessage * message);

static int _appserver_helper_message(void * data, AppTransport * transport,
		AppTransportClient * client, AppMessage * message)
{
	AppServer * appserver = data;

#ifdef DEBUG
	fprintf(stderr, "DEBUG: %s(%p, %u)\n", __func__, (void *)client,
			appmessage_get_type(message));
#endif
	/* FIXME can it happen? */
	if(message == NULL)
		/* XXX report errors */
		return -1;
	switch(appmessage_get_type(message))
	{
		case AMT_CALL:
			return _helper_message_call(appserver, transport,
					client, message);
	}
	return -1;
}

static int _helper_message_call(AppServer * appserver, AppTransport * transport,
		AppTransportClient * client, AppMessage * message)
{
	int ret;
	String const * name;
	String const * method;
	Variable * result = NULL;

	name = (client != NULL) ? apptransport_client_get_name(client) : NULL;
	method = appmessage_get_method(message);
	if(!appinterface_can_call(appserver->interface, method, name))
		/* XXX report errors */
		return -1;
	/* FIXME provide the actual AppServerClient */
	ret = appinterface_call_variablev(appserver->interface, appserver->app,
			NULL, result, method, 0, NULL);
	if(result != NULL)
		variable_delete(result);
	return ret;
}