/*
* Copyright (c) 2005-2009 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of "Eclipse Public License v1.0"
* which accompanies this distribution, and is available
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
*
* Initial Contributors:
* Nokia Corporation - initial contribution.
*
* Contributors:
*
* Description:   
* This file was autogenerated by rpcgen, but should be modified by the developer.
* Make sure you don't use the -component_mod flag in future or this file will be overwritten.
* Fri Sep 12 12:11:08 2003
* System Includes
*
*/




#include <stdio.h>
#include <assert.h>
#ifdef WIN32
#include <winsock2.h>
#else
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#endif


/****************************************************************************************
 * 
 * Local Includes
 * 
 ***************************************************************************************/
#include "CSvcMobster.h"
#include "CSMobster.h"


/****************************************************************************************
 * 
 * Definitions
 * 
 ***************************************************************************************/
#define MAXLOGNAME		64
#ifndef WIN32
#define _snprintf               snprintf
#define ADDRESS_INTEGER         s_addr
#endif

/****************************************************************************************
 * 
 * Implementation
 * 
 ***************************************************************************************/
CSMobster::CSMobster()
{
}

CSMobster::~CSMobster()
{
	stopdevice( 0 );
}

int CSMobster::GetKey()
{
	return iKey;
}

void CSMobster::SetKey( int aKey )
{
	iKey = aKey;
}


/****************************************************************************************
 * 
 * PUBLIC FUNCTION: cstr_startdevice
 * 
 ***************************************************************************************/
int CSMobster::cstr_startdevice( TDeviceDesc aDeviceDesc )
{
	int rv, err, errcode;

	// set the state info for this object
	memset( &iDeviceDesc, 0, sizeof(iDeviceDesc) );
	iDeviceDesc.iDatalinkConfig = aDeviceDesc.iDatalinkConfig;
	iDeviceDesc.iFilterConfig = aDeviceDesc.iFilterConfig;
	iDeviceDesc.iMTID = iKey;
	iDeviceDesc.iTEID = INVALID_DEVICE_ID;
	iDeviceDesc.iDeviceStatus = CS_INACTIVE;
	iDeviceDesc.iDeviceExitReason = DER_INVALID;

	// start a phone in another thread, note that if it fails the call still succeeds, we
	// treat this as the phone starting and then ending asynchronously. The main motivation
	// for this is that it allows us to get all the debug info out.
	err = iPhone.StartPhone( iKey, iDeviceDesc.iDatalinkConfig, iDeviceDesc.iFilterConfig, &errcode );
	if( err != MTL_SUCCESS ) {
		iDeviceDesc.iDeviceExitReason = DER_START_PHONE_FAILED;
		iDeviceDesc.iDeviceExitSubReason = err;
		iDeviceDesc.iDeviceExitDetail = errcode;
		iDeviceDesc.iDeviceStatus = CS_CLOSED;
	} else {
		iDeviceDesc.iDeviceStatus = CS_ACTIVE;
	}

	// we now just wait for the other thread to get the channel connection
	rv = ERR_NONE;
	return rv;
}


/****************************************************************************************
 * 
 * PUBLIC FUNCTION: dstr_removedevice
 * 
 ***************************************************************************************/
int CSMobster::dstr_removedevice( int aArgs, int *aDeleteInstance )
{
	int rv;
	MTStatus mtstatus;

	// if the phone was CS_ACTIVE last time then we have to check that it hasn't 
	// change on its own accord.
	if( iDeviceDesc.iDeviceStatus == CS_ACTIVE ) {
		mtstatus = iPhone.GetStatus();
		if( mtstatus == MTS_SHUTDOWN_ALL ) {
			iDeviceDesc.iDeviceStatus = CS_CLOSED;
		}
	}

	// cannot remove the device unless it is in the closed state
	if( iDeviceDesc.iDeviceStatus != CS_CLOSED ) {
		*aDeleteInstance = 0;
		return ERR_INVALIDSTATE;
	}

	// otherwise let everything be cleaned up
	*aDeleteInstance = 1;
	rv = ERR_NONE;
	return rv;
}


/****************************************************************************************
 * 
 * PUBLIC FUNCTION: getdeviceinfo
 * 
 ***************************************************************************************/
TDeviceDesc CSMobster::getdeviceinfo( int aArgs )
{
	struct sockaddr_in sockaddr;
	TDeviceDesc rv;
	char *addr;
	MTStatus mtstatus;

	// if the phone was CS_ACTIVE last time then we have to check that it hasn't 
	// change on its own accord.
	if( iDeviceDesc.iDeviceStatus == CS_ACTIVE ) {
		mtstatus = iPhone.GetStatus();
		if( mtstatus == MTS_SHUTDOWN_ALL ) {
			iDeviceDesc.iDeviceStatus = CS_CLOSED;
		}
	}

	// copy the static values from the local version
	rv = iDeviceDesc;

	// update the addresses from the MT
	iPhone.GetLocalUUAddress( &sockaddr );
	sprintf( rv.iLocalAirInterfacePort, "%d", ntohs(sockaddr.sin_port) );
	iPhone.GetRemoteUUAddress( &sockaddr );
	sprintf( rv.iRemoteAirInterfacePort, "%d", ntohs(sockaddr.sin_port) );
	addr = inet_ntoa( sockaddr.sin_addr );
	_snprintf( rv.iRemoteAirInterfaceAddress, MAXADDRLEN, "%s", addr ); 

	// done
	return rv;
}


/****************************************************************************************
 * 
 * PUBLIC FUNCTION: getdevicelog
 * 
 ***************************************************************************************/
TVarData CSMobster::getdevicelog( int aArgs )
{
	TVarData rv;
	CLog *log;
	int logsize;

	// init the rv
	rv.TVarData_len = 0;
	rv.TVarData_val = NULL;

	// get the log from the device
	log = iPhone.GetLog();

	// get the size of the log and allocate the space
	logsize = log->CalculateLogSize();
	if( logsize == 0 ) {
		return rv;
	}
	rv.TVarData_val = (char*)malloc( logsize );
	rv.TVarData_len = logsize;

	// copy the log into the buffer
	log->PrintLogToBuffer( logsize, rv.TVarData_val );

	// close up the file and return data
	return rv;
}


/****************************************************************************************
 * 
 * PUBLIC FUNCTION: stopdevice
 * 
 ***************************************************************************************/
int CSMobster::stopdevice( int aArgs )
{
	int rv, err;

	// no phone should be in the ps_inactive state (non-atomically)
	assert( iDeviceDesc.iDeviceStatus != CS_INACTIVE );

	// if we are in the closed state already then return invalid state
	if( iDeviceDesc.iDeviceStatus == CS_CLOSED ) {
		rv = ERR_INVALIDSTATE;
		return rv;
	}

	// if we are in the active state then stop the phone -- if stop fails then we 
	// return without changing the state -- this means that the phone should only
	// return an error from StopPhone() if it is a transient error.
	assert( iDeviceDesc.iDeviceStatus == CS_ACTIVE );
	err = iPhone.StopPhone();
	if( err != 0 ) {
		rv = ERR_STOPFAILED;
		return rv;
	}
	iDeviceDesc.iDeviceExitReason = DER_USER_REQUEST;
	iDeviceDesc.iDeviceExitSubReason = 0;
	iDeviceDesc.iDeviceExitDetail = 0;
	iDeviceDesc.iDeviceStatus = CS_CLOSED;

	// return success
	rv = ERR_NONE;
	return rv;
}


/****************************************************************************************
 * 
 * PUBLIC FUNCTION: setremoteuuaddress
 * 
 ***************************************************************************************/
int CSMobster::setremoteuuaddress( TUUAddress aArgs )
{
	int rv, err;
	struct sockaddr_in sockaddr;

	// call the phone
	sockaddr.sin_family = AF_INET;
	sockaddr.sin_addr.ADDRESS_INTEGER = aArgs.iRemoteAddress;
	sockaddr.sin_port = aArgs.iRemotePort;
	err = iPhone.SetRemoteUUAddress( sockaddr );

	// translate cphone error to mobster
	assert( err == MTL_SUCCESS );
	rv = ERR_NONE;
	return rv;
}


/****************************************************************************************
 * 
 * PUBLIC FUNCTION: settesocket
 * 
 ***************************************************************************************/
int CSMobster::settesocket( int aSock )
{
	MTError merr;

	// pass the socket to the phone
	merr = iPhone.SetTeSocket( aSock );

	// 	translate the errors
	return ((merr == MTL_SUCCESS) ? ERR_NONE : ERR_CHANNEL_SOCKET_ALREADY_SET);
}