/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 2 -*-
 *
 * The contents of this file are subject to the Netscape Public
 * License Version 1.1 (the "License"); you may not use this file
 * except in compliance with the License. You may obtain a copy of
 * the License at http://www.mozilla.org/NPL/
 *
 * Software distributed under the License is distributed on an "AS
 * IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or
 * implied. See the License for the specific language governing
 * rights and limitations under the License.
 *
 * The Original Code is mozilla.org code.
 *
 * The Initial Developer of the Original Code is Netscape
 * Communications Corporation.  Portions created by Netscape are
 * Copyright (C) 1998 Netscape Communications Corporation. All
 * Rights Reserved.
 *
 * Contributor(s): 
 */
#ifndef imapoff_H
#define imapoff_H

class MailDB;
class MailMessageHdr;
class MSG_IMAPFolderInfoMail;
class DBOfflineImapOperation;
class MSG_UrlQueue;
class MsgDocument;
class DownloadOfflineImapState;

#include "net.h"
#include "msgcom.h"
#include "msgimap.h"
#include "msgzap.h"
#include "msgdbtyp.h"

class XPStringObj;

class OfflineImapGoOnlineState : public MSG_ZapIt {
public:												// set to one folder to playback one folder only
	OfflineImapGoOnlineState(MSG_Pane *workerPane, MSG_IMAPFolderInfoMail *singleFolderOnly = NULL);
	virtual ~OfflineImapGoOnlineState();

	void		ProcessNextOperation();
	
	uint32		GetCurrentUIDValidity() { return mCurrentUIDValidity; }
	void		SetCurrentUIDValidity(uint32 uidvalidity) { mCurrentUIDValidity = uidvalidity; }
	
	void		SetPseudoOffline(XP_Bool pseudoOffline) {m_pseudoOffline = pseudoOffline;}
	XP_Bool		ProcessingStaleFolderUpdate() { return m_singleFolderToUpdate != NULL; }

	MSG_UrlQueue *GetUrlQueue(XP_Bool *alreadyRunning);
	DownloadOfflineImapState *GetDownloadOfflineImapState() {return m_downloadOfflineImapState;}
	void		SetDownloadOfflineImapState(DownloadOfflineImapState *state) {m_downloadOfflineImapState = state;}
	XP_Bool		CreateOfflineFolder(MSG_FolderInfo *folder);
private:
	XP_Bool		CreateOfflineFolders();
	void 		AdvanceToNextFolder();
	void 		DeleteAllOfflineOpsForCurrentDB();
	
	void		ProcessFlagOperation(DBOfflineImapOperation *currentOp);
	void		ProcessMoveOperation(DBOfflineImapOperation *currentOp);
	void		ProcessCopyOperation(DBOfflineImapOperation *currentOp);
	void		ProcessEmptyTrash(DBOfflineImapOperation *currentOp);
	void		ProcessAppendMsgOperation(DBOfflineImapOperation *currentOp,
										  int32 opType);
	static void PostAppendMsgExitFunction(URL_Struct *URL_s, int status,
										  MWContext *window_id);
	
	MSG_Pane			*m_workerPane;
	MSG_FolderInfoMail	*m_currentFolder;
	MSG_IMAPFolderInfoMail *m_singleFolderToUpdate;
	MSG_FolderIterator	*m_folderIterator;
	IDArray				m_CurrentKeys;
	int					m_KeyIndex;
	MailDB				*m_currentDB;
	uint32				mCurrentUIDValidity;
	int32				mCurrentPlaybackOpType;	// kFlagsChanged -> kMsgCopy -> kMsgMoved
	XP_Bool				m_mailboxupdatesStarted;
	XP_Bool				m_pseudoOffline;		// for queueing online events in offline db
	XP_Bool				m_createdOfflineFolders;
	MSG_UrlQueue		*m_urlQueue;	
	DownloadOfflineImapState *m_downloadOfflineImapState;

};


class OfflineImapState : public MSG_ZapIt 
{
public:
	OfflineImapState(MSG_IMAPFolderInfoMail *folder);  
	virtual ~OfflineImapState();
protected:
	void		SetFolderInfo(MSG_IMAPFolderInfoMail *folder);
	MailDB			*m_maildb;
	MailMessageHdr	*m_msgHdr;
	MSG_IMAPFolderInfoMail *m_folderInfo;
};


// used for streaming msg bodies into the db
class DownloadOfflineImapState : public OfflineImapState
{
public:
	DownloadOfflineImapState(MSG_IMAPFolderInfoMail *folder, NET_StreamClass *displayStream);  // only called by CreateOfflineImapStream
	virtual ~DownloadOfflineImapState();
	
	static void CreateOfflineImapStream(NET_StreamClass *theStream, MSG_IMAPFolderInfoMail *folder, NET_StreamClass *displayStream, DownloadOfflineImapState *closureData = NULL);

	static unsigned int OfflineImapStreamWriteReady (NET_StreamClass *stream) { return MAX_WRITE_READY; }
	static void OfflineImapStreamComplete(NET_StreamClass *stream);
	static void OfflineImapStreamAbort (NET_StreamClass *stream, int status);
	static int OfflineImapStreamWrite (NET_StreamClass *stream, const char *block, int32 messageKey);
	
	int		WriteStream(const char *block, uint32 messageKey);
	void	CompleteStream();
	void	AbortStream(int status);
	MSG_OfflineMsgDocumentHandle	m_dbWriteDocument;
	void	SetDeleteOnComplete(XP_Bool deleteOnComplete) {m_deleteOnComplete = deleteOnComplete;}
private:
	NET_StreamClass *m_displayStream;
	XP_Bool m_offlineWriteFailure;
	XP_Bool	m_deleteOnComplete;
};


// used for streaming bodies from the db into the display
class DisplayOfflineImapState : public OfflineImapState
{
public:
	DisplayOfflineImapState(MSG_IMAPFolderInfoMail *folder, MessageKey key);  
	virtual ~DisplayOfflineImapState();
	
	uint32 GetMsgSize();
	
	int ProcessDisplay(char *socketBuffer, uint32 read_size);
protected:
	uint32 	m_bytesDisplayedSoFar;
	XP_Bool	m_wasUnread;
};


// used for append msg operation
class AppendMsgOfflineImapState : public OfflineImapState
{
public:
	AppendMsgOfflineImapState(MSG_IMAPFolderInfoMail *folder, MessageKey key,
							  const char *msg_file_name);
	virtual ~AppendMsgOfflineImapState();
	void RemoveHdrFromDB();
	void RemoveMsgFile();
protected:
	char *m_msg_file_name;
};


// new access type of stored imap operations

const int32 kFlagsChanged		= 0x1;
const int32 kMsgMoved			= 0x2;
const int32 kMsgCopy			= 0x4;
const int32 kMoveResult			= 0x8;
const int32 kAppendDraft        = 0x10;
const int32 kAddedHeader		= 0x20;
const int32 kDeletedMsg			= 0x40;
const int32 kMsgMarkedDeleted	= 0x80;
const int32 kAppendTemplate     = 0x100;
const int32 kDeleteAllMsgs		= 0x200;

class DBOfflineImapOperation 
{
public:
						/** Instance Methods **/
						DBOfflineImapOperation();
	virtual				~DBOfflineImapOperation();

	void				SetMessageKey(MessageId key);
	void				SetInitialImapFlags(imapMessageFlagsType flags); // the flags we start with
	
	void				SetImapFlagOperation(imapMessageFlagsType flags);
	void				ClearImapFlagOperation();
	
		// you can only move (copy,delete) a msg once
	void				SetMessageMoveOperation(const char *destinationBox);
	void				ClearMoveOperation(MSG_DBHandle dbHandle);
	
		// you can copy a message more than once
	void				AddMessageCopyOperation(const char *destinationBox);
	void				ClearCopyOperations();
	
	void				SetSourceMailbox(const char *sourceMailBox, MessageKey sourceKey);
	
	void				SetDeleteAllMsgs();
	void				ClearDeleteAllMsgs();

	MessageKey							GetMessageKey();
	uint32								GetOperationFlags() ;
	imapMessageFlagsType				GetNewMessageFlags() ;
	
	XP_Bool				GetMoveDestination(MSG_DBHandle dbHandle, XPStringObj &boxName);

	uint32				GetNumberOfCopyOps();
	XP_Bool				GetIndexedCopyDestination(MSG_DBHandle dbHandle, uint32 index, XPStringObj &boxName);
	void				ClearFirstCopyOperation(MSG_DBHandle dbHandle);
	
	XP_Bool				GetSourceInfo(XPStringObj &sourceBoxName, MessageKey &sourceKey);

	void                SetAppendMsgOperation(const char *destinationBox,
											  int32 opType);
	void                ClearAppendMsgOperation(MSG_DBHandle dbHandle, int32 opType);
	MSG_OfflineIMAPOperationHandle GetHandle() {return m_offlineIMAPOperationHandle;}
	void				SetHandle(MSG_OfflineIMAPOperationHandle handle) {m_offlineIMAPOperationHandle = handle;}
	void				SetDBHandle(MSG_DBHandle dbHandle) {m_dbHandle = dbHandle;}

protected:
	MSG_OfflineIMAPOperationHandle m_offlineIMAPOperationHandle;
	MSG_DBHandle			m_dbHandle;	// which db is this in?
	
};
	



#endif