RetrieveItemJob.cpp

#include "RetrieveItemJob.h"

RetrieveItemJob::RetrieveItemJob(Akonadi::Item const& item, Session* session) : item(item), session(session) {

  lpMessage = NULL;
}

RetrieveItemJob::~RetrieveItemJob() {
  if(lpMessage) {
    lpMessage->Release();
  }
}

void RetrieveItemJob::start() {
  HRESULT hr = session->init();
  if(hr != hrSuccess) {
    setError((int) hr);
    emitResult();
    return;    
  }

  LPMDB lpStore = session->getLpStore();
  IMAPISession* lpSession = session->getLpSession();
  IAddrBook* lpAddrBook = session->getLpAddrBook();
  ECLogger* lpLogger = session->getLpLogger();
  sending_options* sopt = &session->sopt;

  qDebug() << "retrieveItem";

  QStringList splitArr = item.remoteId().split(":");
  QString collectionSourceKey = splitArr[0];
  QString itemSourceKey = splitArr[1];

  SBinary sEntryID;
  session->EntryIDFromSourceKey(collectionSourceKey, 
                                itemSourceKey, sEntryID);

  ULONG ulObjType;
  hr = lpStore->OpenEntry(sEntryID.cb, 
                          (LPENTRYID) sEntryID.lpb, 
                          &IID_IMessage, 
                          MAPI_DEFERRED_ERRORS, 
                          &ulObjType, 
                          (LPUNKNOWN *) &lpMessage);
		  
  if (hr != hrSuccess) {
    setError((int) hr);
    emitResult();
  }

  char *szMessage = NULL;
  hr = IMToINet(lpSession, lpAddrBook, lpMessage, &szMessage, 
		*sopt);

  if (hr != hrSuccess) {
    setError((int) hr);
    emitResult();
  }


  LPSPropValue lpPropVal = NULL;
  hr = HrGetOneProp(lpMessage, PR_MESSAGE_FLAGS, &lpPropVal);
  if (hr != hrSuccess) {
    qDebug() << "GetOneProp failed";
    setError((int) hr);
    emitResult(); 
    return;
  }

  if(lpPropVal && lpPropVal->Value.ul & MSGFLAG_READ) {
    item.setFlag(Akonadi::MessageFlags::Seen);
  }
  else {
    item.clearFlag(Akonadi::MessageFlags::Seen);  
  }

  KMime::Message::Ptr msg(new KMime::Message);
  QByteArray bodyText = szMessage;

  msg->setContent(KMime::CRLFtoLF(bodyText));
  msg->parse();

  item.setMimeType(QLatin1String("message/rfc822"));  // mail
  item.setPayload<KMime::Message::Ptr>(msg);

  emitResult();
}