/*
* Copyright (c) 2008 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 is the implementation of application class
 *
*/

#include <bt_sock.h>
#include "socketlistener.h"
#include "listenerobserver.h"
#include "sockets.pan"
#include "bthidclientsrv.h" //for BT Stack v2 security
#include "bthidtypes.h"
#include <e32std.h>
#include <e32svr.h>
#include "debug.h"
// The transport protocol of the sockets used by this object.
_LIT(KTransportProtocol, "L2CAP");

const TInt KListenQueueSize = 2;

CSocketListener* CSocketListener::NewL(RSocketServ& aSocketServ, TUint aPort,
        MListenerObserver& aObserver, TBool aAuthorisation)
    {
    CSocketListener* self = NewLC(aSocketServ, aPort, aObserver,
            aAuthorisation);
    CleanupStack::Pop(self);
    return self;
    }

CSocketListener* CSocketListener::NewLC(RSocketServ& aSocketServ,
        TUint aPort, MListenerObserver& aObserver, TBool aAuthorisation)
    {
    CSocketListener* self = new (ELeave) CSocketListener(aSocketServ, aPort,
            aObserver, aAuthorisation);
    CleanupStack::PushL(self);
    self->ConstructL();
    return self;
    }

CSocketListener::CSocketListener(RSocketServ& aSocketServ, TUint aPort,
        MListenerObserver& aObserver, TBool aAuthorisation) :
    CActive(CActive::EPriorityStandard), iSocketServer(aSocketServ), iPort(
            aPort), iObserver(aObserver), iAuthorisationAskedFlag(
            aAuthorisation)
    {
    CActiveScheduler::Add(this);
    }

CSocketListener::~CSocketListener()
    {
        TRACE_INFO((_L("[BTHID]\tCSocketListener::~CSocketListener()")));
    Cancel(); // Causes DoCancel

    // Close the listening socket
    iListeningSocket.Close();
    }

void CSocketListener::ConstructL()
    {
        TRACE_INFO((_L("[BTHID]\tCSocketListener::ConstructL()")));
    // Open the listening socket
    User::LeaveIfError(iListeningSocket.Open(iSocketServer,
            KTransportProtocol));
    TL2CAPSockAddr addr;
    addr.SetPort(iPort);
    TBTServiceSecurity serverSecurity;
    serverSecurity.SetUid(KUidBTHidServer);
    serverSecurity.SetAuthentication(ETrue); //Microsoft KB reconnect needs this!?? --> This line has caused IOP problems before.
    serverSecurity.SetAuthorisation(iAuthorisationAskedFlag); //This should be according to Authorisation setting
    serverSecurity.SetDenied(EFalse);

    //No need for Interrupt channel to use encryption
    if (KL2CAPHidInterrupt == iPort)
        serverSecurity.SetEncryption(EFalse); //Logitech Mx5000 needs this false.
    else
        serverSecurity.SetEncryption(ETrue);

    addr.SetSecurity(serverSecurity);
    //Bind
    User::LeaveIfError(iListeningSocket.Bind(addr));
    User::LeaveIfError(iListeningSocket.Listen(KListenQueueSize));

    }

void CSocketListener::DoCancel()
    {
    // Cancel any outstanding request
    iListeningSocket.CancelAccept();
    }

void CSocketListener::RunL()
    {
    TInt err = iStatus.Int();

        TRACE_INFO((_L("[BTHID]\tCSocketListener::RunL(), iStatus.Int()=%d"),err));

    if (err == KErrCancel)
        return; //Active task was cancelled.

    // In case of KErrHardwareNotAvailable,  cancel and reset the listening
    // socket and reissue the Accept is needed.
    if (err == KErrHardwareNotAvailable)
        {
        iListeningSocket.CancelAll();

        err = iListeningSocket.Listen(KListenQueueSize);

        if (err == KErrNone)
            {
            iListeningSocket.Accept(*iAcceptSocket, iStatus);
            SetActive();
            }
        else
            {
            // Report the result to the observer.
            iObserver.SocketAccepted(iPort, err);
            }
        }
    else
        {
        // Report the result to the observer.
        iObserver.SocketAccepted(iPort, err);
        }
    }

TInt CSocketListener::AcceptConnection(RSocket& aSocket)
    {

        TRACE_INFO((_L("[BTHID]\tCSocketListener::AcceptConnection()")));

    // If we aren't in the correct state to accept, panic.
    __ASSERT_DEBUG(!IsActive(),
            User::Panic(KPanicBTConnection, ESocketsBadState));

    // close old connection - if any
    aSocket.Close();

    // Open abstract socket
    TInt err = aSocket.Open(iSocketServer);

    if (err == KErrNone)
        {

            TRACE_INFO((_L("[BTHID]\tCSocketListener::AcceptConnection(), opening new socket succeed")));
        // Accept onto the new socket
        iListeningSocket.Accept(aSocket, iStatus);

        // Keep a handle on the accept socket.
        iAcceptSocket = &aSocket;

        SetActive();
        }
    else
        TRACE_INFO((_L("[BTHID]\tCSocketListener::AcceptConnection(), opening new socket failed")));

    return err;
    }

//End of file