ContentCollection.cpp

Go to the documentation of this file.

#include "ContentInfo.h"
#include "ContentCollection.h"

#include "PKIFMessageException.h"
#include "ASN1Helper.h"
#include "ContentCollectionModule.h"
#include "ToolkitUtils.h"
#include "PKIFMessageErrors.h"
#include "PKIFCMSUtils.h"

#include "OID.h"
#include "Buffer.h"
#include "PKIFBase64.h"

struct CPKIFContentCollectionImpl
{
    CPKIFContentInfoList m_contentInfoList;
};

CPKIFContentCollection::CPKIFContentCollection()
    :m_impl (new CPKIFContentCollectionImpl)
{
    LOG_STRING_DEBUG("CPKIFContentCollection::CPKIFContentCollection()", TOOLKIT_MESSAGE_CONTENT_INFO, 0, this);
    SetContentType(g_contentCollection);
}
CPKIFContentCollection::~CPKIFContentCollection()
{
    LOG_STRING_DEBUG("CPKIFContentCollection::~CPKIFContentCollection()", TOOLKIT_MESSAGE_CONTENT_INFO, 0, this);

    delete m_impl;
    m_impl = NULL;
}

void CPKIFContentCollection::SetContentList(
    CPKIFContentInfoList& contentList) 
{
    m_impl->m_contentInfoList = contentList;
}
void CPKIFContentCollection::GetContentList(
     CPKIFContentInfoList& contentList) const 
{
    contentList = m_impl->m_contentInfoList;
}

void CPKIFContentCollection::Decode(
    const unsigned char* buf,
    int bufLen)
{
    LOG_STRING_DEBUG("CPKIFContentCollection::Decode(const unsigned char* buf, int bufLen)", TOOLKIT_MESSAGE_CONTENT_INFO, 0, this);

    //if the input is empty - fail now
    if(NULL == buf || 0 == bufLen)
    {
        throw CPKIFMessageException(thisComponent, COMMON_INVALID_INPUT, "NULL parameter passed to CPKIFContentCollection::Decode");
    }

    try
    {
        //otherwise, try to parse (the decode function may throw)
        CPKIFASNWrapper<ContentCollection> cmsMsg(BEREncContentCollection, BERDecContentCollection);
        cmsMsg.Decode(buf, bufLen);

        DListNode * curr = cmsMsg->head;
        while(curr != NULL)
        {
            CACCMSContentInfo *tmp = (CACCMSContentInfo*)curr->data;

            CPKIFOIDPtr tmpOID(new CPKIFOID(tmp->contentType.subid, tmp->contentType.numids));
            CPKIFBufferPtr tmpBuff(new CPKIFBuffer(tmp->content.data, tmp->content.numocts));
            CPKIFContentInfoPtr ci(new CPKIFContentInfo(tmpOID, tmpBuff));


            m_impl->m_contentInfoList.push_back(ci);
            curr = curr->next;
        }
    }
    catch(CPKIFException& e)
    {
        unsigned char * decoded = NULL;
        unsigned long decodedLen;
        bool b = PEMDecode((char *)buf, &decoded, &decodedLen);
        if(b)
        {
            try
            {
                CPKIFASNWrapper<ContentCollection> cmsMsg(BEREncContentCollection, BERDecContentCollection);
                cmsMsg.Decode(decoded, decodedLen);

                DListNode * curr = cmsMsg->head;
                while(curr != NULL)
                {
                    CACCMSContentInfo *tmp = (CACCMSContentInfo*)curr->data;

                    CPKIFOIDPtr tmpOID(new CPKIFOID(tmp->contentType.subid, tmp->contentType.numids));
                    CPKIFBufferPtr tmpBuff(new CPKIFBuffer(tmp->content.data, tmp->content.numocts));
                    CPKIFContentInfoPtr ci(new CPKIFContentInfo(tmpOID, tmpBuff));


                    m_impl->m_contentInfoList.push_back(ci);
                    curr = curr->next;
                }
                if(NULL != decoded)
                    delete decoded;

            }catch(CPKIFException& e)
            {
                if(NULL != decoded)
                    delete decoded;

                CPKIFMessageException me(thisComponent, MSG_DECODE_FAILED);
                me.push_info(e);
                //delete e;
                throw me;
            }
        }
        else
        {
            if(NULL != decoded)
                delete decoded;

            CPKIFMessageException me(thisComponent, MSG_DECODE_FAILED);
            me.push_info(e);
            //delete e;
            throw me;
        }
    }
}
void CPKIFContentCollection::Decode(
    CPKIFBufferPtr& buf)
{
    if(buf == (CPKIFBuffer*)NULL)
    {
        throw CPKIFMessageException(thisComponent, COMMON_INVALID_INPUT, "NULL parameter passed to CPKIFContentCollection::Decode");
    }

    Decode(buf->GetBuffer(), buf->GetLength());
}
//CPKIFBufferPtr CPKIFContentCollection::Encode()
//{
//  LOG_STRING_DEBUG("CPKIFContentCollection::Encode()", TOOLKIT_MESSAGE_CONTENT_INFO, 0, this);

    //if we don't have a content OID and content then fail
    //if(m_impl->m_contentType == (CPKIFOID*)NULL || m_impl->m_content == (CPKIFBuffer*)NULL)
    //{
    //  throw CPKIFMessageException(thisComponent, MSG_INCOMPLETE);
    //}

    //CACCMSContentInfo cmsMsg;

    //CPKIFStringPtr str(new std::string(m_impl->m_contentType->ToString())); 
    //ASN1OBJID* tmpOid = ConvertStringToASN1OBJID(str);
    //CopyOID(&cmsMsg.contentType, tmpOid);

    //if(NULL != tmpOid)
    //  delete tmpOid;
    //cmsMsg.content.data = m_impl->m_content->GetBuffer();
    //cmsMsg.content.numocts = m_impl->m_content->GetLength();

    //ASN1OpenType* data = NULL;

    //try
    //{
    //  //encode the message
    //  CACASNWRAPPER_CREATE(CACCMSContentInfo, objPDU);
    //  data = objPDU.Encode(&cmsMsg);

    //  //return a CPKIFBufferPtr containing the encoded message
    //  CPKIFBufferPtr tmp(new CPKIFBuffer(data->data, data->numocts));
    //  delete data;
    //  return tmp;
    //}
    //catch(CPKIFException& e)
    //{
    //  CPKIFMessageException me(thisComponent, MSG_ENCODE_FAILED);
    //  me.push_info(e);
    //  //delete e;
    //  throw me;
    //}
//}

CPKIFBufferPtr CPKIFContentCollection::Encode()
{
    RAISE_MESSAGE_EXCEPTION("Content collection creation is not supported in this version.", thisComponent, COMMON_NOT_IMPLEMENTED, this);
}