// Copyright (c) 2007-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:
// Te_LbsSuplSmsTriggerSender.h
// A class sending SUPL INIT messages via UDP
// 
//

/**
 @file
 @internalComponent
 @prototype
*/

#include <e32base.h>
#include <in_sock.h>

#include "Te_LbsSuplSmsTriggerSender.h"

/**
Static factory method for creating an instance of the CTe_LbsSuplSmsTriggerSender class.

@param aPort	 [In] The port the message must be sent to.
@param aObserver [In] The observer to receive message delivery notifications.

@return An instance of the class. The calling application becomes the
owner of the returned instance and is responsible its disposal.

@leave If a error happens, it leaves with one of the system error codes.
*/
CTe_LbsSuplSmsTriggerSender* CTe_LbsSuplSmsTriggerSender::NewL(TInt aPort, MTe_LbsSuplSmsTriggerSenderObserver& aObserver)
	{
	CTe_LbsSuplSmsTriggerSender* self = new(ELeave) CTe_LbsSuplSmsTriggerSender(aObserver);
	CleanupStack::PushL(self);
	self->ConstructL(aPort);
	CleanupStack::Pop(self);
	return self;
	}

/**
Static factory method for creating an instance of the CTe_LbsSuplSmsTriggerSender class and
leaving it on the cleanup stack.

@param aPort	 [In] The port messages must be sent to.
@param aObserver [In] The observer to receive message delivery notifications.

@return An instance of the class. The calling application becomes the
owner of the returned instance and is responsible its disposal.

@leave If a error happens, it leaves with one of the system error codes.
*/
CTe_LbsSuplSmsTriggerSender* CTe_LbsSuplSmsTriggerSender::NewLC(TInt aPort, MTe_LbsSuplSmsTriggerSenderObserver& aObserver)
	{
	CTe_LbsSuplSmsTriggerSender* self = new(ELeave) CTe_LbsSuplSmsTriggerSender(aObserver);
	CleanupStack::PushL(self);
	self->ConstructL(aPort);
	return self;
	}

/**
Destructor. Cancels the async request and closes the sockets.
*/
CTe_LbsSuplSmsTriggerSender::~CTe_LbsSuplSmsTriggerSender()
	{
	Cancel();
	iSocket.Close();
	iSocketServ.Close();
	}

/**
Sends the given message via UDP on the port specified on the construction.

@param aMessage [In] A message to be sent.

@see MTe_LbsSuplSmsTriggerSenderObserver::OnMessageSent
*/
void CTe_LbsSuplSmsTriggerSender::SendMessage(const TDesC8& aMessage)
	{
	__ASSERT_ALWAYS(!IsActive(), User::Invariant());
	
	iSocket.SendTo(aMessage, iAddr, 0, iStatus);
	SetActive();
	}

/**
Constructor. Adds this active object to the active scheduler's list.
*/
CTe_LbsSuplSmsTriggerSender::CTe_LbsSuplSmsTriggerSender(MTe_LbsSuplSmsTriggerSenderObserver& aObserver) : CActive(EPriorityStandard), 
iObserver(aObserver)
	{
	CActiveScheduler::Add(this);
	}

/**
2nd phase constructor. Opens the socket and preinitializes the address.

@param aPort	 [In] The port messages must be sent to.

@leave If a error happens, it leaves with one of the system error codes.
*/
void CTe_LbsSuplSmsTriggerSender::ConstructL(TInt aPort)
	{
	// Open channel to Socket Server
	User::LeaveIfError(iSocketServ.Connect());
	
	//Open the socket to listen for messages
	User::LeaveIfError(iSocket.Open(iSocketServ, KAfInet, KSockDatagram, KProtocolInetUdp));
	
	iAddr.SetPort(aPort);
	iAddr.SetAddress(INET_ADDR(127,0,0,1));
	}

/**
Called when the message delivery report is received.

@see CActive::RunL
@see SendTo::SendTo
*/
void CTe_LbsSuplSmsTriggerSender::RunL()
	{
	iObserver.OnMessageSent(iStatus.Int());
	}

/**
Cancels the outstanding send async request.

@see CActive::DoCancel
@see SendTo::SendTo
*/
void CTe_LbsSuplSmsTriggerSender::DoCancel()
	{
	iSocket.CancelRecv();
	}