-void DeletePOP3Aggregator(void *vptr)
-{
- pop3aggr *ptr = vptr;
- DeleteHashPos(&ptr->Pos);
- DeleteHash(&ptr->MsgNumbers);
-// FreeStrBuf(&ptr->rooms);
- FreeStrBuf(&ptr->pop3user);
- FreeStrBuf(&ptr->pop3pass);
- FreeStrBuf(&ptr->Host);
- FreeStrBuf(&ptr->RoomName);
- FreeURL(&ptr->IO.ConnectMe);
- FreeStrBuf(&ptr->Url);
- FreeStrBuf(&ptr->IO.IOBuf);
- FreeStrBuf(&ptr->IO.SendBuf.Buf);
- FreeStrBuf(&ptr->IO.RecvBuf.Buf);
- DeleteAsyncMsg(&ptr->IO.ReadMsg);
- if (((struct CitContext*)ptr->IO.CitContext)) {
- ((struct CitContext*)ptr->IO.CitContext)->state = CON_IDLE;
- ((struct CitContext*)ptr->IO.CitContext)->kill_me = 1;
- }
- FreeAsyncIOContents(&ptr->IO);
- free(ptr);
-}
-
-eNextState FinalizePOP3AggrRun(AsyncIO *IO)
-{
- HashPos *It;
- pop3aggr *cpptr = (pop3aggr *)IO->Data;
-
- EVP3C_syslog(LOG_INFO,
- "%s@%s: fetched %ld new of %d messages in %fs. bye.",
- ChrPtr(cpptr->pop3user),
- ChrPtr(cpptr->Host),
- cpptr->count,
- GetCount(cpptr->MsgNumbers),
- IO->Now - cpptr->IOStart
- );
-
- It = GetNewHashPos(POP3FetchUrls, 0);
- pthread_mutex_lock(&POP3QueueMutex);
- {
- if (GetHashPosFromKey(POP3FetchUrls, SKEY(cpptr->Url), It))
- DeleteEntryFromHash(POP3FetchUrls, It);
- }
- pthread_mutex_unlock(&POP3QueueMutex);
- DeleteHashPos(&It);
- return eAbort;
-}
-
-eNextState FailAggregationRun(AsyncIO *IO)
-{
- return eAbort;
-}
-
-eNextState POP3C_ReadGreeting(pop3aggr *RecvMsg)
-{
- AsyncIO *IO = &RecvMsg->IO;
- SetPOP3State(IO, eGreeting);
- POP3C_DBG_READ();
- /* Read the server greeting */
- if (!POP3C_OK) return eTerminateConnection;
- else return eSendReply;
-}
-
-eNextState POP3C_SendUser(pop3aggr *RecvMsg)
-{
- AsyncIO *IO = &RecvMsg->IO;
- SetPOP3State(IO, eUser);
- /* Identify ourselves. NOTE: we have to append a CR to each command.
- * The LF will automatically be appended by sock_puts(). Believe it
- * or not, leaving out the CR will cause problems if the server happens
- * to be Exchange, which is so b0rken it actually barfs on
- * LF-terminated newlines.
- */
- StrBufPrintf(RecvMsg->IO.SendBuf.Buf,
- "USER %s\r\n", ChrPtr(RecvMsg->pop3user));
- POP3C_DBG_SEND();
- return eReadMessage;
-}
-
-eNextState POP3C_GetUserState(pop3aggr *RecvMsg)
-{
- AsyncIO *IO = &RecvMsg->IO;
- POP3C_DBG_READ();
- if (!POP3C_OK) return eTerminateConnection;
- else return eSendReply;
-}
-
-eNextState POP3C_SendPassword(pop3aggr *RecvMsg)
-{
- AsyncIO *IO = &RecvMsg->IO;
- SetPOP3State(IO, ePassword);
- /* Password */
- StrBufPrintf(RecvMsg->IO.SendBuf.Buf,
- "PASS %s\r\n", ChrPtr(RecvMsg->pop3pass));
- EVP3CM_syslog(LOG_DEBUG, "<PASS <password>\n");
-// POP3C_DBG_SEND(); No, we won't write the passvoid to syslog...
- return eReadMessage;
-}
-
-eNextState POP3C_GetPassState(pop3aggr *RecvMsg)
-{
- AsyncIO *IO = &RecvMsg->IO;
- POP3C_DBG_READ();
- if (!POP3C_OK) return eTerminateConnection;
- else return eSendReply;
-}
-
-eNextState POP3C_SendListCommand(pop3aggr *RecvMsg)
-{
- AsyncIO *IO = &RecvMsg->IO;
- SetPOP3State(IO, eListing);
-
- /* Get the list of messages */
- StrBufPlain(RecvMsg->IO.SendBuf.Buf, HKEY("LIST\r\n"));
- POP3C_DBG_SEND();
- return eReadMessage;
-}
-
-eNextState POP3C_GetListCommandState(pop3aggr *RecvMsg)
-{
- AsyncIO *IO = &RecvMsg->IO;
- POP3C_DBG_READ();
- if (!POP3C_OK) return eTerminateConnection;
- RecvMsg->MsgNumbers = NewHash(1, NULL);
- RecvMsg->State++;
- return eReadMore;
-}
-
-
-eNextState POP3C_GetListOneLine(pop3aggr *RecvMsg)
-{
- AsyncIO *IO = &RecvMsg->IO;
-#if 0
- int rc;
-#endif
- const char *pch;
- FetchItem *OneMsg = NULL;
- POP3C_DBG_READ();
-
- if ((StrLength(RecvMsg->IO.IOBuf) == 1) &&
- (ChrPtr(RecvMsg->IO.IOBuf)[0] == '.'))
- {
- if (GetCount(RecvMsg->MsgNumbers) == 0)
- {
- //// RecvMsg->Sate = ReadQuitState;
- }
- else
- {
- RecvMsg->Pos = GetNewHashPos(RecvMsg->MsgNumbers, 0);
- }
- return eSendReply;
-
- }
-
- /*
- * work around buggy pop3 servers which send
- * empty lines in their listings.
- */
- if ((StrLength(RecvMsg->IO.IOBuf) == 0) ||
- !isdigit(ChrPtr(RecvMsg->IO.IOBuf)[0]))
- {
- return eReadMore;
- }
-
- OneMsg = (FetchItem*) malloc(sizeof(FetchItem));
- memset(OneMsg, 0, sizeof(FetchItem));
- OneMsg->MSGID = atol(ChrPtr(RecvMsg->IO.IOBuf));
-
- pch = strchr(ChrPtr(RecvMsg->IO.IOBuf), ' ');
- if (pch != NULL)
- {
- OneMsg->MSGSize = atol(pch + 1);
- }
-#if 0
- rc = TestValidateHash(RecvMsg->MsgNumbers);
- if (rc != 0)
- EVP3CCS_syslog(LOG_DEBUG, "Hash Invalid: %d\n", rc);
-#endif
-
- Put(RecvMsg->MsgNumbers, LKEY(OneMsg->MSGID), OneMsg, HfreeFetchItem);
-#if 0
- rc = TestValidateHash(RecvMsg->MsgNumbers);
- if (rc != 0)
- EVP3CCS_syslog(LOG_DEBUG, "Hash Invalid: %d\n", rc);
-#endif
- //RecvMsg->State --; /* read next Line */
- return eReadMore;
-}
-
-eNextState POP3_FetchNetworkUsetableEntry(AsyncIO *IO)
-{
- long HKLen;
- const char *HKey;
- void *vData;
- pop3aggr *RecvMsg = (pop3aggr *) IO->Data;
-
- SetPOP3State(IO, eUseTable);
-
- if((RecvMsg->Pos != NULL) &&
- GetNextHashPos(RecvMsg->MsgNumbers,
- RecvMsg->Pos,
- &HKLen,
- &HKey,
- &vData))
- {
- if (server_shutting_down)
- return eAbort;
-
- if (CheckIfAlreadySeen("POP3 Item Seen",
- RecvMsg->CurrMsg->MsgUID,
- IO->Now,
- IO->Now, //// todo
- eCheckUpdate,
- IO->ID, CCID)
- != 0)
- {
- /* Item has already been seen */
- RecvMsg->CurrMsg->NeedFetch = 0;
- }
- else
- {
- EVP3CCSM_syslog(LOG_DEBUG, "NO\n");
- RecvMsg->CurrMsg->NeedFetch = 1;
- }
- return NextDBOperation(&RecvMsg->IO,
- POP3_FetchNetworkUsetableEntry);
- }
- else
- {
- /* ok, now we know them all,
- * continue with reading the actual messages. */
- DeleteHashPos(&RecvMsg->Pos);
- return DBQueueEventContext(IO, POP3_C_ReAttachToFetchMessages);
- }
-}
-
-eNextState POP3C_GetOneMessagID(pop3aggr *RecvMsg)
-{
- AsyncIO *IO = &RecvMsg->IO;
- long HKLen;
- const char *HKey;
- void *vData;
-
- SetPOP3State(IO, eGetMsgID);
-#if 0
- int rc;
- rc = TestValidateHash(RecvMsg->MsgNumbers);
- if (rc != 0)
- EVP3CCS_syslog(LOG_DEBUG, "Hash Invalid: %d\n", rc);
-#endif
- if((RecvMsg->Pos != NULL) &&
- GetNextHashPos(RecvMsg->MsgNumbers,
- RecvMsg->Pos,
- &HKLen, &HKey,
- &vData))
- {
- RecvMsg->CurrMsg = (FetchItem*) vData;
- /* Find out the UIDL of the message,
- * to determine whether we've already downloaded it */
- StrBufPrintf(RecvMsg->IO.SendBuf.Buf,
- "UIDL %ld\r\n", RecvMsg->CurrMsg->MSGID);
- POP3C_DBG_SEND();
- }
- else
- {
- RecvMsg->State++;
- DeleteHashPos(&RecvMsg->Pos);
- /// done receiving uidls.. start looking them up now.
- RecvMsg->Pos = GetNewHashPos(RecvMsg->MsgNumbers, 0);
- return EventQueueDBOperation(&RecvMsg->IO,
- POP3_FetchNetworkUsetableEntry,
- 0);
- }
- return eReadMore; /* TODO */
-}
-
-eNextState POP3C_GetOneMessageIDState(pop3aggr *RecvMsg)
-{
- AsyncIO *IO = &RecvMsg->IO;
-#if 0
- int rc;
- rc = TestValidateHash(RecvMsg->MsgNumbers);
- if (rc != 0)
- EVP3CCS_syslog(LOG_DEBUG, "Hash Invalid: %d\n", rc);
-#endif
-
- POP3C_DBG_READ();
- if (!POP3C_OK) return eTerminateConnection;
- RecvMsg->CurrMsg->MsgUIDL =
- NewStrBufPlain(NULL, StrLength(RecvMsg->IO.IOBuf));
- RecvMsg->CurrMsg->MsgUID =
- NewStrBufPlain(NULL, StrLength(RecvMsg->IO.IOBuf) * 2);
-
- StrBufExtract_token(RecvMsg->CurrMsg->MsgUIDL,
- RecvMsg->IO.IOBuf, 2, ' ');
-
- StrBufPrintf(RecvMsg->CurrMsg->MsgUID,
- "pop3/%s/%s:%s@%s",
- ChrPtr(RecvMsg->RoomName),
- ChrPtr(RecvMsg->CurrMsg->MsgUIDL),
- RecvMsg->IO.ConnectMe->User,
- RecvMsg->IO.ConnectMe->Host);
- RecvMsg->State --;
- return eSendReply;
-}
-
-
-eNextState POP3C_SendGetOneMsg(pop3aggr *RecvMsg)
-{
- AsyncIO *IO = &RecvMsg->IO;
- long HKLen;
- const char *HKey;
- void *vData;
-
- SetPOP3State(IO, eGetMsg);
-
- RecvMsg->CurrMsg = NULL;
- while ((RecvMsg->Pos != NULL) &&
- GetNextHashPos(RecvMsg->MsgNumbers,
- RecvMsg->Pos,
- &HKLen, &HKey,
- &vData) &&
- (RecvMsg->CurrMsg = (FetchItem*) vData,
- RecvMsg->CurrMsg->NeedFetch == 0))
- {}
-
- if ((RecvMsg->CurrMsg != NULL ) && (RecvMsg->CurrMsg->NeedFetch == 1))
- {
- /* Message has not been seen.
- * Tell the server to fetch the message... */
- StrBufPrintf(RecvMsg->IO.SendBuf.Buf,
- "RETR %ld\r\n", RecvMsg->CurrMsg->MSGID);
- POP3C_DBG_SEND();
- return eReadMessage;
- }
- else {
- RecvMsg->State = ReadQuitState;
- return POP3_C_DispatchWriteDone(&RecvMsg->IO);
- }
-}
-
-
-eNextState POP3C_ReadMessageBodyFollowing(pop3aggr *RecvMsg)
-{
- AsyncIO *IO = &RecvMsg->IO;
- POP3C_DBG_READ();
- if (!POP3C_OK) return eTerminateConnection;
- RecvMsg->IO.ReadMsg = NewAsyncMsg(HKEY("."),
- RecvMsg->CurrMsg->MSGSize,
- config.c_maxmsglen,
- NULL, -1,
- 1);
-
- return eReadPayload;
-}
-