/******************************************************************************
 * Project         Persistency
 * (c) copyright   2012
 * Company         XS Embedded GmbH
 *****************************************************************************/
/******************************************************************************
 * This Source Code Form is subject to the terms of the
 * Mozilla Public License, v. 2.0. If a  copy of the MPL was not distributed
 * with this file, You can obtain one at http://mozilla.org/MPL/2.0/.
******************************************************************************/
 /**
 * @file           persistence_client_library_pas_interface.c
 * @ingroup        Persistence client library
 * @author         Ingo Huerner
 * @brief          Implementation of the persistence client library persistence
 *                 administration service interface.
 * @see
 */

#include "persistence_client_library_pas_interface.h"

#include <errno.h>
#include <dlt.h>

DLT_IMPORT_CONTEXT(gPclDLTContext);

/// flag if access is locked
static int gLockAccess = 0;


void pers_lock_access(void)
{
   gLockAccess = 0;
   __sync_fetch_and_add(&gLockAccess,1);
}


void pers_unlock_access(void)
{
   __sync_fetch_and_sub(&gLockAccess,1);
}


int isAccessLocked(void)
{
   return gLockAccess;
}



int check_pas_request(unsigned int request, unsigned int requestID)
{
   int rval = 0;

   switch(request)
   {
      case (PasMsg_Block|PasMsg_WriteBack):
      {
      	MainLoopData_u data;

      	memset(&data, 0, sizeof(MainLoopData_u));
      	data.cmd = (uint32_t)CMD_PAS_BLOCK_AND_WRITE_BACK;
      	data.params[0] = request;
      	data.params[1] = requestID;
      	data.string[0] = '\0'; 	// no string parameter, set to 0

         DLT_LOG(gPclDLTContext, DLT_LOG_INFO, DLT_STRING("chkPasReq - case PasMsg_Block o. PasMsg_WriteBack"));
         if(-1 == deliverToMainloop_NM(&data))
         {
            DLT_LOG(gPclDLTContext, DLT_LOG_ERROR, DLT_STRING("write failed w/ errno "), DLT_INT(errno), DLT_STRING(strerror(errno)));
            rval = PasErrorStatus_FAIL;
         }
         else
         {
            rval = PasErrorStatus_RespPend;
         }
         break;
      }
      case PasMsg_Unblock:
      {
         DLT_LOG(gPclDLTContext, DLT_LOG_INFO, DLT_STRING("chkPasReq - case PasMsg_Unblock"));
         pers_unlock_access();
         rval = PasErrorStatus_OK;
         break;
      }
      default:
      {
         rval = PasErrorStatus_FAIL;
         break;
      }
   }
   return rval;
}



DBusHandlerResult msg_persAdminRequest(DBusConnection *connection, DBusMessage *message)
{
   int request = 0, requestID = 0;
   int errorReturn = 0;

   DBusMessage *reply;
   DBusError error;
   dbus_error_init (&error);

   if (!dbus_message_get_args(message, &error, DBUS_TYPE_INT32 , &request,
                                               DBUS_TYPE_INT32 , &requestID, DBUS_TYPE_INVALID))
   {
      reply = dbus_message_new_error(message, error.name, error.message);

      if(reply == 0)
      {
         DLT_LOG(gPclDLTContext, DLT_LOG_ERROR, DLT_STRING("msgPasReq - DBus No mem"));
      }

      if (!dbus_connection_send(connection, reply, 0))
      {
         DLT_LOG(gPclDLTContext, DLT_LOG_ERROR, DLT_STRING("msgPasReq - DBus No mem"));
      }

      dbus_message_unref(reply);

      return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
   }

   DLT_LOG(gPclDLTContext, DLT_LOG_INFO, DLT_STRING("msg_persAdminRequest"), DLT_INT(request), DLT_INT(requestID) );
   errorReturn = check_pas_request((unsigned int)request, (unsigned int)requestID);

   reply = dbus_message_new_method_return(message);

   if (reply == 0)
   {
      DLT_LOG(gPclDLTContext, DLT_LOG_ERROR, DLT_STRING("msgPasReq - DBus No mem"));
   }

   if (!dbus_message_append_args(reply, DBUS_TYPE_INT32, &errorReturn, DBUS_TYPE_INVALID))
   {
      DLT_LOG(gPclDLTContext, DLT_LOG_ERROR, DLT_STRING("msgPasReq - DBus No mem"));
   }

   if (!dbus_connection_send(connection, reply, 0))
   {
      DLT_LOG(gPclDLTContext, DLT_LOG_ERROR, DLT_STRING("msgPasReq - DBus No mem"));
   }

   dbus_connection_flush(connection);
   dbus_message_unref(reply);

   return DBUS_HANDLER_RESULT_HANDLED;
}



DBusHandlerResult checkPersAdminMsg(DBusConnection * connection, DBusMessage * message, void * user_data)
{
   DBusHandlerResult result = DBUS_HANDLER_RESULT_NOT_YET_HANDLED;

   (void)user_data;

   if((0==strcmp(gDbusPersAdminConsInterface, dbus_message_get_interface(message))))
   {
   	DLT_LOG(gPclDLTContext, DLT_LOG_INFO, DLT_STRING("checkPasMsg - Received dbus msg: "), DLT_STRING(dbus_message_get_member(message)));

      if((0==strcmp(gDbusPersAdminConsMsg, dbus_message_get_member(message))))
      {
         result = msg_persAdminRequest(connection, message);
      }
      else
      {
         DLT_LOG(gPclDLTContext, DLT_LOG_ERROR, DLT_STRING("checkPasMsg - unknown msg"), DLT_STRING(dbus_message_get_member(message)));
      }
   }
   else
   {
      DLT_LOG(gPclDLTContext, DLT_LOG_ERROR, DLT_STRING("checkPasMsg - unknown msg"), DLT_STRING(dbus_message_get_interface(message)));
   }
   return result;
}



int register_pers_admin_service(void)
{
   int rval =  0;

	MainLoopData_u data;

	memset(&data, 0, sizeof(MainLoopData_u));
	data.cmd = (uint32_t)CMD_SEND_PAS_REGISTER;
	data.params[0] = 1;
	data.params[1] = (PasMsg_Block | PasMsg_WriteBack | PasMsg_Unblock);
	data.string[0] = '\0'; 	// no string parameter, set to 0

   if(-1 == deliverToMainloop(&data))
   {
      DLT_LOG(gPclDLTContext, DLT_LOG_ERROR, DLT_STRING("regPas - failed write pipe"), DLT_INT(errno));
      rval = -1;
   }
   else
   {
      pthread_mutex_lock(&gDbusPendingRegMtx);
      while(0 == gDbusPendingCondValue)
      {
         pthread_cond_wait(&gDbusPendingCond, &gDbusPendingRegMtx);
      }
      pthread_mutex_unlock(&gDbusPendingRegMtx);

      gDbusPendingCondValue = 0;
      rval = gDbusPendingRvalue;

   }
   return rval;
}



int unregister_pers_admin_service(void)
{
   int rval =  0;

	MainLoopData_u data;

	memset(&data, 0, sizeof(MainLoopData_u));
	data.cmd = (uint32_t)CMD_SEND_PAS_REGISTER;
	data.params[0] = 0;
	data.params[1] = (PasMsg_Block | PasMsg_WriteBack | PasMsg_Unblock);
	data.string[0] = '\0'; 	// no string parameter, set to 0

   if(-1 == deliverToMainloop(&data))
   {
      DLT_LOG(gPclDLTContext, DLT_LOG_ERROR, DLT_STRING("unregPas - failed write pipe"), DLT_INT(errno));
      rval = -1;
   }
   else
   {
      pthread_mutex_lock(&gDbusPendingRegMtx);
      while(0 == gDbusPendingCondValue)
         pthread_cond_wait(&gDbusPendingCond, &gDbusPendingRegMtx);
      pthread_mutex_unlock(&gDbusPendingRegMtx);

      gDbusPendingCondValue = 0;
      rval = gDbusPendingRvalue;

   }
   return rval;
}