/*
 * ServerListenerImpl.cc
 *
 *  Created on: Mar 3, 2011
 *      Author: lamikr
 */
#include <string.h>

#include <plp/log.h>
#include <plp/retval.h>
#include "ServerListenerImpl.hh"
#include "../src/plp/devicebus/DeviceBusMessageId.hh"

using namespace plpdevicebus;

ServerListenerImpl::ServerListenerImpl(DeviceManagerServer *dev_man_param) {
	_dev_man	= dev_man_param;
}

int ServerListenerImpl::request_received(const char *msg_req_param, const char **msg_rsp_param) {
	log_debug("request_received(char *%s)\n", msg_req_param);
	*msg_rsp_param = strdup("jee");
	return 0;
}

int ServerListenerImpl::request_received(const BusMessage *msg_req_param, const BusMessage *msg_rsp_param) {
	int	err_flg;
	long	type_id;
	int	ret_val;

	ret_val		= -1;
	type_id		= ((BusMessage *)msg_req_param)->get_type(&err_flg);
	if (err_flg == PLP_OK) {
		log_debug("request_received, type_id: %ld\n", type_id);
		switch(type_id) {
			case MSG_TYPE_ID__GET_DEVICE_LIST:
				log_debug("get device list request handling started\n");
				_dev_man->get_device_list(msg_rsp_param);
				ret_val	= 0;
				break;
			case MSG_TYPE_ID__GET_LATEST_DATA:
				log_debug("get latest data request handling started\n");
				_dev_man->get_latest_data((BusMessage *)msg_req_param, msg_rsp_param);
				ret_val	= 0;
				break;
			case MSG_TYPE_ID__GET_DATA_RANGE:
				log_debug("get data range request handling started\n");
				_dev_man->get_data_range((BusMessage *)msg_req_param, msg_rsp_param);
				ret_val	= 0;
				break;
			case MSG_TYPE_ID__GET_DATA_BETWEEN_DATES:
				log_debug("get data between dates handling started\n");
				_dev_man->get_data_between_dates((BusMessage *)msg_req_param, msg_rsp_param);
				ret_val	= 0;
				break;
			default:
				log_debug("unknown message type-id received: %ld\n", type_id);
				break;
		}
	}
	return ret_val;
}