/*

* Copyright (c) 2010 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: 

*

*/

#include "zeroconfclient.h"

#include "e32math.h"

#include <in_sock.h>

#include <ecom/ecom.h>

const TUint KPublishTierId = 0x2001DC8A;

CZeroconfClient* CZeroconfClient::NewL(MPnPObserver* aObserver)

	{

	CZeroconfClient* self = CZeroconfClient::NewLC(aObserver);

	CleanupStack::Pop(self);

	return self;

	}

CZeroconfClient* CZeroconfClient::NewLC(MPnPObserver* aObserver)

	{

	CZeroconfClient* self = new (ELeave) CZeroconfClient(aObserver);

	CleanupStack::PushL(self);

	self->ConstructL();

	return self;

	}

void CZeroconfClient::ConnectL()

	{

    GetBTName();    

    TInt openStatus1 = iServicePublish.Open(KPublishTierId);

    const TUint KTestTierId = 536924288;

    TInt openStatus = iControlPoint.Open(KTestTierId);

	//

	}

CZeroconfClient::~CZeroconfClient()

	{

	iServicePublish.Close();

	iControlPoint.Close();

	iBTName.Close();

	REComSession::FinalClose();

	}

CZeroconfClient::CZeroconfClient(MPnPObserver* aObserver)

	{

	iMdnsObserver = aObserver;

	}

void CZeroconfClient::ConstructL()

	{

	}

void CZeroconfClient::GetBTName()

    {

    iBTName.CreateL(KMaxFileName);

    TInt rand = Math::Random()%100;

    iBTName.Num(rand);

    }

void CZeroconfClient::PublishMyService(const TDesC8& aBaseUrl,const TDesC8& aFileList,const TDesC8& aIconName)

    {

    RPnPParameterBundle pnpBundle;

    pnpBundle.Open ();

        //CleanupClosePushL( pnpBundle );

    RParameterFamily srvFamily = pnpBundle.CreateFamilyL (EMdnsSrvParamset);

    RParameterFamily txtFamily = pnpBundle.CreateFamilyL (EMdnsTxtParamset);

    RParameterFamily ptrFamily = pnpBundle.CreateFamilyL (EMdnsPtrParamset);

        //Srv Record

    pnpBundle.SetPnPObserver((MPnPObserver*)iMdnsObserver);

    CMDnsSrvParamSet* srvParam = CMDnsSrvParamSet::NewL(srvFamily);

        //CleanupStack::PushL(srvParam);

    RBuf8 serviceName;

    serviceName.CreateL(KMaxFileName);

    serviceName.Append(_L8("DeviceService"));

    serviceName.Append(iBTName.Collapse());

    serviceName.Append(_L8("._daap._tcp.local"));

    srvParam->SetDomainNameL(serviceName);

    srvParam->SetTargetL(_L8("2IND50001.Local"));

    srvParam->SetPriority(2);

    srvParam->SetWeight(100);

    srvParam->SetPort(80);

    CMDnsPtrParamSet* ptrParam = CMDnsPtrParamSet::NewL(ptrFamily);

    ptrParam->SetInstanceNameL(_L8("_daap._tcp.local"));

    ptrParam->SetDomainNameL(serviceName);

        //Txt record

    CMDnsTxtParamSet* txtParam = CMDnsTxtParamSet::NewL(txtFamily);

    //CleanupStack::PushL(txtParam);

    txtParam->SetDomainNameL(serviceName);

    RBuf8 baseUrl,fileUrl,iconUrl;

    //data3 contains the base ip addr

    baseUrl.Create(KMaxPath);

    fileUrl.Create(KMaxFileName);

    iconUrl.Create(KMaxFileName);

    //data4 contains the filelist name

    baseUrl.Append(_L8("BaseUrl = "));

    baseUrl.Append(aBaseUrl);

    fileUrl.Append(_L8("FileUrl = "));

    fileUrl.Append(aFileList);

    iconUrl.Append(_L8("IconUrl = "));

    iconUrl.Append(aIconName);

    txtParam->AppendTxtData(baseUrl);

    txtParam->AppendTxtData(fileUrl);

    txtParam->AppendTxtData(iconUrl);

    iServicePublish.Publish(pnpBundle);

    pnpBundle.Close();

    baseUrl.Close();

    fileUrl.Close();

    iconUrl.Close();

    serviceName.Close();

    }

void CZeroconfClient::PublishNowPlayingServiceL(TDes& aTitleBuf)

    {

    TInt openStatus1 = iMusicPublish.Open(KPublishTierId);

    RPnPParameterBundle pnpBundle;

    pnpBundle.Open ();

    CleanupClosePushL( pnpBundle );

    RParameterFamily srvFamily = pnpBundle.CreateFamilyL (EMdnsSrvParamset);

    RParameterFamily txtFamily = pnpBundle.CreateFamilyL (EMdnsTxtParamset);

    //Srv Record

    pnpBundle.SetPnPObserver((MPnPObserver*)iMdnsObserver);

    CMDnsSrvParamSet* srvParam = CMDnsSrvParamSet::NewL(srvFamily);

    //CleanupStack::PushL(srvParam);

    RBuf8 serviceName;

    serviceName.CreateL(KMaxFileName);

    serviceName.Append(_L8("MusicService"));

    serviceName.Append(iBTName.Collapse());

    serviceName.Append(_L8("._daap._tcp.local"));

    srvParam->SetDomainNameL(serviceName);

    srvParam->SetTargetL(_L8("2IND04990.Local"));

    srvParam->SetPriority(2);

    srvParam->SetWeight(100);

    srvParam->SetPort(80);

    //Txt record

    RBuf8 data;

    TUint KMaxLength(255);

    data.CreateL(_L8("Now playing = "),KMaxLength);

    data.Append(aTitleBuf.Collapse());  

    CMDnsTxtParamSet* txtParam = CMDnsTxtParamSet::NewL(txtFamily);

    //CleanupStack::PushL(txtParam);

    txtParam->SetDomainNameL(serviceName); 

    txtParam->AppendTxtData(data);  

    iServicePublish.Publish(pnpBundle); 

    data.Close();

    serviceName.Close();

    CleanupStack::PopAndDestroy(1);//pnpBundle

    }     

void CZeroconfClient::UpdateNowPlayingServiceL(TDes& aTitleBuf)

    {

    RPnPParameterBundle pnpBundle;

    pnpBundle.Open ();

    pnpBundle.SetPnPObserver((MPnPObserver*)iMdnsObserver);

    RParameterFamily srvFamily = pnpBundle.CreateFamilyL (EMdnsSrvParamset);

    RParameterFamily txtFamily = pnpBundle.CreateFamilyL (EMdnsTxtParamset);

    //update Publish 

    //pnpBundle.ClearAllParameters(RParameterFamily::ERequested);

    RParameterFamily publishFamily = pnpBundle.CreateFamilyL (EMdnsPublishParamset);

    CMDnsPublishParamSet* publishParam = CMDnsPublishParamSet::NewL(publishFamily);

    publishParam->SetPublishUpdate(ETrue);

    CMDnsSrvParamSet* srvParam = CMDnsSrvParamSet::NewL(srvFamily);

    //CleanupStack::PushL(srvParam);

    RBuf8 serviceName;

    serviceName.CreateL(KMaxFileName);

    serviceName.Append(_L8("MusicService"));

    serviceName.Append(iBTName.Collapse());

    serviceName.Append(_L8("._daap._tcp.local"));

    srvParam->SetDomainNameL(serviceName);

    srvParam->SetTargetL(_L8("2IND04990.Local"));

    srvParam->SetPriority(2);

    srvParam->SetWeight(100);

    srvParam->SetPort(80);

    //Txt record

    RBuf8 data;

    TUint KMaxLength(255);

    data.CreateL(_L8("Now playing = "),KMaxLength);

    data.Append(aTitleBuf.Collapse());   

    CMDnsTxtParamSet* txtParam = CMDnsTxtParamSet::NewL(txtFamily);

    //CleanupStack::PushL(txtParam);

    txtParam->SetDomainNameL(serviceName); 

    txtParam->AppendTxtData(data);

    iServicePublish.Publish(pnpBundle); 

    data.Close();

    serviceName.Close();

    pnpBundle.Close();        

    }

void CZeroconfClient::PublishCurrentStatusServiceL(const TDesC8& aStatus)

    {

    TInt openStatus1 = iStatusPublish.Open(KPublishTierId);

    RPnPParameterBundle pnpBundle;

    pnpBundle.Open ();

    CleanupClosePushL( pnpBundle );

    RParameterFamily srvFamily = pnpBundle.CreateFamilyL (EMdnsSrvParamset);

    RParameterFamily txtFamily = pnpBundle.CreateFamilyL (EMdnsTxtParamset);

    //Srv Record

    pnpBundle.SetPnPObserver((MPnPObserver*)iMdnsObserver);

    CMDnsSrvParamSet* srvParam = CMDnsSrvParamSet::NewL(srvFamily);

    //CleanupStack::PushL(srvParam);

    RBuf8 serviceName;

    serviceName.CreateL(KMaxFileName);

    serviceName.Append(_L8("StatusService"));

    serviceName.Append(iBTName.Collapse());

    serviceName.Append(_L8("._daap._tcp.local"));

    srvParam->SetDomainNameL(serviceName);

    srvParam->SetTargetL(_L8("2IND04990.Local"));

    srvParam->SetPriority(2);

    srvParam->SetWeight(100);

    srvParam->SetPort(80);

    //Txt record

    RBuf8 data;

    TUint KMaxLength(255);

    data.CreateL(_L8("Status = "),KMaxLength);

    data.Append(aStatus);  

    CMDnsTxtParamSet* txtParam = CMDnsTxtParamSet::NewL(txtFamily);

    //CleanupStack::PushL(txtParam);

    txtParam->SetDomainNameL(serviceName); 

    txtParam->AppendTxtData(data);  

    iServicePublish.Publish(pnpBundle); 

    data.Close();

    serviceName.Close();

    CleanupStack::PopAndDestroy(1);//pnpBundle

    }     

void CZeroconfClient::UpdateCurrentStatusServiceL(const TDesC8& aStatus)

    {

    RPnPParameterBundle pnpBundle;

    pnpBundle.Open ();

    pnpBundle.SetPnPObserver((MPnPObserver*)iMdnsObserver);

    RParameterFamily srvFamily = pnpBundle.CreateFamilyL (EMdnsSrvParamset);

    RParameterFamily txtFamily = pnpBundle.CreateFamilyL (EMdnsTxtParamset);

    //update Publish 

    //pnpBundle.ClearAllParameters(RParameterFamily::ERequested);

    RParameterFamily publishFamily = pnpBundle.CreateFamilyL (EMdnsPublishParamset);

    CMDnsPublishParamSet* publishParam = CMDnsPublishParamSet::NewL(publishFamily);

    publishParam->SetPublishUpdate(ETrue);

    CMDnsSrvParamSet* srvParam = CMDnsSrvParamSet::NewL(srvFamily);

    //CleanupStack::PushL(srvParam);

    RBuf8 serviceName;

    serviceName.CreateL(KMaxFileName);

    serviceName.Append(_L8("StatusService"));

    serviceName.Append(iBTName.Collapse());

    serviceName.Append(_L8("._daap._tcp.local"));

    srvParam->SetDomainNameL(serviceName);

    srvParam->SetTargetL(_L8("2IND04990.Local"));

    srvParam->SetPriority(2);

    srvParam->SetWeight(100);

    srvParam->SetPort(80);

    //Txt record

    RBuf8 data;

    TUint KMaxLength(255);

    data.CreateL(_L8("Status = "),KMaxLength);

    data.Append(aStatus);   

    CMDnsTxtParamSet* txtParam = CMDnsTxtParamSet::NewL(txtFamily);

    //CleanupStack::PushL(txtParam);

    txtParam->SetDomainNameL(serviceName); 

    txtParam->AppendTxtData(data);

    iServicePublish.Publish(pnpBundle); 

    data.Close();

    serviceName.Close();

    pnpBundle.Close();        

    }

void CZeroconfClient::PublishService()

	{

    RPnPParameterBundle pnpBundle;

    pnpBundle.Open ();

    //CleanupClosePushL( pnpBundle );

    RParameterFamily srvFamily = pnpBundle.CreateFamilyL (EMdnsSrvParamset);

    RParameterFamily txtFamily = pnpBundle.CreateFamilyL (EMdnsTxtParamset);

    //Srv Record

    pnpBundle.SetPnPObserver((MPnPObserver*)iMdnsObserver);

    CMDnsSrvParamSet* srvParam = CMDnsSrvParamSet::NewL(srvFamily);

    //CleanupStack::PushL(srvParam);

    srvParam->SetDomainNameL(_L8("xyz._daap._tcp.local"));

    srvParam->SetTargetL(_L8("2IND04990.Local"));

    srvParam->SetPriority(2);

    srvParam->SetWeight(100);

    srvParam->SetPort(80);

    //Txt record

    CMDnsTxtParamSet* txtParam = CMDnsTxtParamSet::NewL(txtFamily);

    //CleanupStack::PushL(txtParam);

    txtParam->SetDomainNameL(_L8("xyz._daap._tcp.local")); 

    RBuf8 data1,data2;

    data1.Create(_L8("vadan = ct "));

    data2.Create(_L8("prakash  = sharma "));

    txtParam->AppendTxtData(data1);

    txtParam->AppendTxtData(data2);

    iServicePublish.Publish(pnpBundle);	

    pnpBundle.Close();

    data1.Close();

    data2.Close();

	}

void CZeroconfClient::WriteServices()

	{

    RPnPParameterBundle pnpBundle;

    pnpBundle.Open ();

    pnpBundle.SetPnPObserver((MPnPObserver*)iMdnsObserver);

    RParameterFamily pnpFamily = pnpBundle.CreateFamilyL (EMdnsRegisterNotifyParamset);

    CMDnsRegisterNotifyParamSet* registerParam = CMDnsRegisterNotifyParamSet::NewL(pnpFamily);

    _LIT8(KInstance,"_daap._tcp.local");

    registerParam->SetInstanceNameL(KInstance);

    iControlPoint.RegisterNotify(pnpBundle);	

    pnpBundle.Close();

	}

void CZeroconfClient::WriteServiceTypes()

	{

	_LIT8(KInstance,"");

    _LIT8(KServiceType,"_daap.");

    RPnPParameterBundle pnpBundle;

    pnpBundle.Open ();

    pnpBundle.SetPnPObserver((MPnPObserver*)iMdnsObserver);

    RParameterFamily pnpFamily = pnpBundle.CreateFamilyL (EMDnsDiscoverRequestParamSet);

    CMDnsQueryRequestParamSet* queryParam = CMDnsQueryRequestParamSet::NewL(pnpFamily);

    queryParam->SetInstanceNameL(KInstance);

    queryParam->SetQueryTypeL(EDnsQType_Any);

    queryParam->SetProtocol(1);

    queryParam->SetServiceTypeL(KServiceType);

    User::After(5000000);

    iControlPoint.Discover(pnpBundle);

    pnpBundle.Close();

	}

void CZeroconfClient::GetService(const TDesC8& aInstanceName,TDnsType aType)

    {

    _LIT8(KServiceType,"_daap.");

    RPnPParameterBundle pnpBundle;

    pnpBundle.Open ();

    pnpBundle.SetPnPObserver((MPnPObserver*)iMdnsObserver);

    RParameterFamily pnpFamily = pnpBundle.CreateFamilyL (EMDnsDiscoverRequestParamSet);

    CMDnsQueryRequestParamSet* queryParam = CMDnsQueryRequestParamSet::NewL(pnpFamily);

    queryParam->SetInstanceNameL(aInstanceName);

    queryParam->SetQueryTypeL(aType);

    queryParam->SetProtocol(1);

    queryParam->SetServiceTypeL(KServiceType);

    iControlPoint.Discover(pnpBundle);

    pnpBundle.Close();

    }

void CZeroconfClient::SearchService()

	{}

void CZeroconfClient::UnPublishServices()

    {

        iServicePublish.Close();

        iMusicPublish.Close();

        iStatusPublish.Close();

    }