summaryrefslogtreecommitdiffstats
path: root/knode/knfolder.cpp
diff options
context:
space:
mode:
authortoma <toma@283d02a7-25f6-0310-bc7c-ecb5cbfe19da>2009-11-25 17:56:58 +0000
committertoma <toma@283d02a7-25f6-0310-bc7c-ecb5cbfe19da>2009-11-25 17:56:58 +0000
commit460c52653ab0dcca6f19a4f492ed2c5e4e963ab0 (patch)
tree67208f7c145782a7e90b123b982ca78d88cc2c87 /knode/knfolder.cpp
downloadtdepim-460c52653ab0dcca6f19a4f492ed2c5e4e963ab0.tar.gz
tdepim-460c52653ab0dcca6f19a4f492ed2c5e4e963ab0.zip
Copy the KDE 3.5 branch to branches/trinity for new KDE 3.5 features.
BUG:215923 git-svn-id: svn://anonsvn.kde.org/home/kde/branches/trinity/kdepim@1054174 283d02a7-25f6-0310-bc7c-ecb5cbfe19da
Diffstat (limited to 'knode/knfolder.cpp')
-rw-r--r--knode/knfolder.cpp601
1 files changed, 601 insertions, 0 deletions
diff --git a/knode/knfolder.cpp b/knode/knfolder.cpp
new file mode 100644
index 000000000..9cdb2f054
--- /dev/null
+++ b/knode/knfolder.cpp
@@ -0,0 +1,601 @@
+/*
+ KNode, the KDE newsreader
+ Copyright (c) 1999-2005 the KNode authors.
+ See file AUTHORS for details
+
+ This program is free software; you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published by
+ the Free Software Foundation; either version 2 of the License, or
+ (at your option) any later version.
+ You should have received a copy of the GNU General Public License
+ along with this program; if not, write to the Free Software Foundation,
+ Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, US
+*/
+
+#include <qfileinfo.h>
+
+#include <ksimpleconfig.h>
+#include <kstandarddirs.h>
+#include <kdebug.h>
+#include <klocale.h>
+
+#include <kqcstringsplitter.h>
+
+#include "articlewidget.h"
+#include "knarticlemanager.h"
+#include "kncollectionviewitem.h"
+#include "knhdrviewitem.h"
+#include "utilities.h"
+#include "knglobals.h"
+#include "knarticlefactory.h"
+#include "knfolder.h"
+#include "knarticlewindow.h"
+#include "knmainwidget.h"
+
+using namespace KNode;
+
+
+KNFolder::KNFolder()
+ : KNArticleCollection(0), i_d(-1), p_arentId(-1), i_ndexDirty(false), w_asOpen(true)
+{
+}
+
+
+KNFolder::KNFolder(int id, const QString &name, KNFolder *parent)
+ : KNArticleCollection(parent), i_d(id), i_ndexDirty(false), w_asOpen(true)
+{
+ QString fname=path()+QString("custom_%1").arg(i_d);
+
+ n_ame = name;
+ m_boxFile.setName(fname+".mbox");
+ i_ndexFile.setName(fname+".idx");
+ i_nfoPath=fname+".info";
+
+ p_arentId=parent?parent->id():-1;
+
+ if(i_ndexFile.exists())
+ c_ount=i_ndexFile.size()/sizeof(DynData);
+ else
+ c_ount=0;
+}
+
+
+KNFolder::KNFolder(int id, const QString &name, const QString &prefix, KNFolder *parent)
+ : KNArticleCollection(parent), i_d(id), i_ndexDirty(false), w_asOpen(true)
+{
+ QString fname=path()+QString("%1_%2").arg(prefix).arg(i_d);
+
+ n_ame = name;
+ m_boxFile.setName(fname+".mbox");
+ i_ndexFile.setName(fname+".idx");
+ i_nfoPath=fname+".info";
+
+ p_arentId=parent?parent->id():-1;
+
+ if(i_ndexFile.exists())
+ c_ount=i_ndexFile.size()/sizeof(DynData);
+ else
+ c_ount=0;
+}
+
+
+KNFolder::~KNFolder()
+{
+ closeFiles();
+}
+
+
+void KNFolder::updateListItem()
+{
+ if(l_istItem) {
+ l_istItem->setText(0, n_ame);
+ if (!isRootFolder())
+ l_istItem->setTotalCount( c_ount );
+ }
+}
+
+
+QString KNFolder::path()
+{
+ QString dir(locateLocal("data","knode/")+"folders/");
+ /*if (dir.isNull())
+ KNHelper::displayInternalFileError();*/
+ return dir;
+}
+
+
+bool KNFolder::readInfo(const QString &infoPath)
+{
+ if(infoPath.isEmpty())
+ return false;
+
+ i_nfoPath=infoPath;
+
+ KSimpleConfig info(i_nfoPath);
+ if (!isRootFolder() && !isStandardFolder()) {
+ n_ame=info.readEntry("name");
+ i_d=info.readNumEntry("id", -1);
+ p_arentId=info.readNumEntry("parentId", -1);
+ }
+ w_asOpen=info.readBoolEntry("wasOpen", true);
+
+ if(i_d>-1) {
+ QFileInfo fi(infoPath);
+ QString fname=fi.dirPath(true)+"/"+fi.baseName();
+ closeFiles();
+ clear();
+
+ m_boxFile.setName(fname+".mbox");
+ i_ndexFile.setName(fname+".idx");
+ c_ount=i_ndexFile.exists() ? (i_ndexFile.size()/sizeof(DynData)) : 0;
+ }
+
+ return (i_d!=-1);
+}
+
+
+bool KNFolder::readInfo()
+{
+ return readInfo(i_nfoPath);
+}
+
+
+void KNFolder::saveInfo()
+{
+ if(!i_nfoPath.isEmpty()) {
+ KSimpleConfig info(i_nfoPath);
+ if (!isRootFolder() && !isStandardFolder()) {
+ info.writeEntry("name", n_ame);
+ info.writeEntry("id", i_d);
+ info.writeEntry("parentId", p_arentId);
+ }
+ if(l_istItem)
+ info.writeEntry("wasOpen", l_istItem->isOpen());
+ }
+}
+
+
+void KNFolder::setParent(KNCollection *p)
+{
+ p_arent = p;
+ p_arentId = p ? (static_cast<KNFolder*>(p))->id() : -1;
+}
+
+
+bool KNFolder::loadHdrs()
+{
+ if(isLoaded()) {
+ kdDebug(5003) << "KNFolder::loadHdrs() : already loaded" << endl;
+ return true;
+ }
+
+ if(!i_ndexFile.open(IO_ReadOnly)) {
+ kdError(5003) << "KNFolder::loadHdrs() : cannot open index-file!" << endl;
+ closeFiles();
+ return false;
+ }
+
+ if(!m_boxFile.open(IO_ReadOnly)) {
+ kdError(5003) << "KNFolder::loadHdrs() : cannot open mbox-file!" << endl;
+ closeFiles();
+ return false;
+ }
+
+ if(!resize(c_ount)) {
+ closeFiles();
+ return false;
+ }
+
+ QCString tmp;
+ KQCStringSplitter split;
+ KNLocalArticle *art;
+ DynData dynamic;
+ int pos1=0, pos2=0, cnt=0, byteCount;
+
+ knGlobals.top->setCursorBusy(true);
+ knGlobals.setStatusMsg(i18n(" Loading folder..."));
+ knGlobals.top->secureProcessEvents();
+
+ while(!i_ndexFile.atEnd()) {
+
+ //read index-data
+ byteCount=i_ndexFile.readBlock((char*)(&dynamic), sizeof(DynData));
+ if(byteCount!=sizeof(DynData))
+ if(i_ndexFile.status() == IO_Ok) {
+ kdWarning(5003) << "KNFolder::loadHeaders() : found broken entry in index-file: Ignored!" << endl;
+ continue;
+ }
+ else {
+ kdError(5003) << "KNFolder::loadHeaders() : corrupted index-file, IO-error!" << endl;
+ closeFiles();
+ clear();
+ knGlobals.top->setCursorBusy( false );
+ return false;
+ }
+
+ art=new KNLocalArticle(this);
+
+ //set index-data
+ dynamic.getData(art);
+
+ //read overview
+ if(!m_boxFile.at(art->startOffset())) {
+ kdError(5003) << "KNFolder::loadHdrs() : cannot set mbox file-pointer!" << endl;
+ closeFiles();
+ clear();
+ knGlobals.top->setCursorBusy( false );
+ return false;
+ }
+ tmp=m_boxFile.readLine(); //KNFile::readLine()
+ if(tmp.isEmpty()) {
+ if(m_boxFile.status() == IO_Ok) {
+ kdWarning(5003) << "found broken entry in mbox-file: Ignored!" << endl;
+ delete art;
+ continue;
+ }
+ else {
+ kdError(5003) << "KNFolder::loadHdrs() : corrupted mbox-file, IO-error!"<< endl;
+ closeFiles();
+ clear();
+ knGlobals.top->setCursorBusy( false );
+ return false;
+ }
+ }
+
+ //set overview
+ bool end=false;
+ pos1=tmp.find(' ')+1;
+ pos2=tmp.find('\t', pos1);
+ if (pos2 == -1) {
+ pos2=tmp.length();
+ end=true;
+ }
+ art->subject()->from7BitString(tmp.mid(pos1, pos2-pos1));
+
+ if (!end) {
+ pos1=pos2+1;
+ pos2=tmp.find('\t', pos1);
+ if (pos2 == -1) {
+ pos2=tmp.length();
+ end=true;
+ }
+ art->newsgroups()->from7BitString(tmp.mid(pos1, pos2-pos1));
+ }
+
+ if (!end) {
+ pos1=pos2+1;
+ pos2=tmp.find('\t', pos1);
+ if (pos2 == -1) {
+ pos2=tmp.length();
+ end=true;
+ }
+ art->to()->from7BitString(tmp.mid(pos1,pos2-pos1));
+ }
+
+ if (!end) {
+ pos1=pos2+1;
+ pos2=tmp.length();
+ art->lines()->from7BitString(tmp.mid(pos1,pos2-pos1));
+ }
+
+ if(!append(art)) {
+ kdError(5003) << "KNFolder::loadHdrs() : cannot append article!"<< endl;
+ delete art;
+ clear();
+ closeFiles();
+
+ knGlobals.setStatusMsg(QString::null);
+ knGlobals.top->setCursorBusy(false);
+ return false;
+ }
+
+ cnt++;
+ }
+
+ closeFiles();
+ setLastID();
+ c_ount=cnt;
+ updateListItem();
+
+ knGlobals.setStatusMsg(QString::null);
+ knGlobals.top->setCursorBusy(false);
+
+ return true;
+}
+
+
+bool KNFolder::unloadHdrs(bool force)
+{
+ if(l_ockedArticles>0)
+ return false;
+
+ if (!force && isNotUnloadable())
+ return false;
+
+ KNLocalArticle *a;
+ for(int idx=0; idx<length(); idx++) {
+ a=at(idx);
+ if (a->hasContent() && !knGlobals.articleManager()->unloadArticle(a, force))
+ return false;
+ }
+ syncIndex();
+ clear();
+
+ return true;
+}
+
+bool KNFolder::loadArticle(KNLocalArticle *a)
+{
+ if(a->hasContent())
+ return true;
+
+ closeFiles();
+ if(!m_boxFile.open(IO_ReadOnly)) {
+ kdError(5003) << "KNFolder::loadArticle(KNLocalArticle *a) : cannot open mbox file: "
+ << m_boxFile.name() << endl;
+ return false;
+ }
+
+ //set file-pointer
+ if(!m_boxFile.at(a->startOffset())) {
+ kdError(5003) << "KNFolder::loadArticle(KNLocalArticle *a) : cannot set mbox file-pointer!" << endl;
+ closeFiles();
+ return false;
+ }
+
+ //read content
+ m_boxFile.readLine(); //skip X-KNode-Overview
+
+ unsigned int size=a->endOffset()-m_boxFile.at()-1;
+ QCString buff(size+10);
+ int readBytes=m_boxFile.readBlock(buff.data(), size);
+ closeFiles();
+ if(readBytes < (int)(size) && m_boxFile.status() != IO_Ok) { //cannot read file
+ kdError(5003) << "KNFolder::loadArticle(KNLocalArticle *a) : corrupted mbox file, IO-error!" << endl;
+ return false;
+ }
+
+ //set content
+ buff.at(readBytes)='\0'; //terminate string
+ a->setContent(buff);
+ a->parse();
+
+ return true;
+}
+
+
+bool KNFolder::saveArticles( KNLocalArticle::List &l )
+{
+ if(!isLoaded()) // loading should not be done here - keep the StorageManager in sync !!
+ return false;
+
+ if(!m_boxFile.open(IO_WriteOnly | IO_Append)) {
+ kdError(5003) << "KNFolder::saveArticles() : cannot open mbox-file!" << endl;
+ closeFiles();
+ return false;
+ }
+
+ int addCnt=0;
+ bool ret=true;
+ bool clear=false;
+ QTextStream ts(&m_boxFile);
+ ts.setEncoding(QTextStream::Latin1);
+
+ for ( KNLocalArticle::List::Iterator it = l.begin(); it != l.end(); ++it ) {
+
+ clear=false;
+ if ( (*it)->id() == -1 || (*it)->collection() != this ) {
+ if ( (*it)->id() != -1 ) {
+ KNFolder *oldFolder = static_cast<KNFolder*>( (*it)->collection() );
+ if ( !(*it)->hasContent() )
+ if( !( clear = oldFolder->loadArticle( (*it) ) ) ) {
+ ret = false;
+ continue;
+ }
+
+ KNLocalArticle::List l;
+ l.append( (*it) );
+ oldFolder->removeArticles( l, false );
+ }
+ if ( !append( (*it) ) ) {
+ kdError(5003) << "KNFolder::saveArticle(KNLocalArticle::List *l) : cannot append article!" << endl;
+ ret = false;
+ continue;
+ (*it)->setCollection(0);
+ }
+ else {
+ (*it)->setCollection(this);
+ addCnt++;
+ }
+ }
+
+ if ( byId( (*it)->id() ) == (*it) ) {
+
+ //MBox
+ ts << "From aaa@aaa Mon Jan 01 00:00:00 1997\n";
+ (*it)->setStartOffset(m_boxFile.at()); //save offset
+
+ //write overview information
+ ts << "X-KNode-Overview: ";
+ ts << (*it)->subject()->as7BitString(false) << '\t';
+
+ KMime::Headers::Base* h;
+ if( ( h = (*it)->newsgroups( false ) ) !=0 )
+ ts << h->as7BitString(false);
+ ts << '\t';
+
+ if( (h = (*it)->to( false ) ) != 0 )
+ ts << h->as7BitString(false);
+ ts << '\t';
+
+ ts << (*it)->lines()->as7BitString(false) << '\n';
+
+ //write article
+ (*it)->toStream( ts );
+ ts << "\n";
+
+ (*it)->setEndOffset( m_boxFile.at() ); //save offset
+
+ //update
+ ArticleWidget::articleChanged( (*it) );
+ i_ndexDirty=true;
+
+ }
+ else {
+ kdError(5003) << "KNFolder::saveArticle() : article not in folder!" << endl;
+ ret=false;
+ }
+
+ if ( clear )
+ (*it)->KMime::Content::clear();
+ }
+
+ closeFiles();
+ syncIndex();
+
+ if(addCnt>0) {
+ c_ount=length();
+ updateListItem();
+ knGlobals.articleManager()->updateViewForCollection(this);
+ }
+
+ return ret;
+}
+
+
+void KNFolder::removeArticles( KNLocalArticle::List &l, bool del )
+{
+ if( !isLoaded() || l.isEmpty() )
+ return;
+
+ int idx = 0, delCnt = 0, *positions;
+ positions = new int[l.count()];
+ KNLocalArticle *a = 0;
+
+ for ( KNLocalArticle::List::Iterator it = l.begin(); it != l.end(); ++it, ++idx ) {
+ if ( (*it)->isLocked() )
+ positions[idx] = -1;
+ else
+ positions[idx] = a_rticles.indexForId( (*it)->id() );
+ }
+
+ for ( idx = 0; idx < (int)(l.count()); ++idx ) {
+ if(positions[idx]==-1)
+ continue;
+
+ a=at(positions[idx]);
+
+ //update
+ knGlobals.artFactory->deleteComposerForArticle(a);
+ KNArticleWindow::closeAllWindowsForArticle(a);
+ ArticleWidget::articleRemoved( a );
+ delete a->listItem();
+
+ //delete article
+ a_rticles.remove(positions[idx], del, false);
+ delCnt++;
+ if(!del)
+ a->setId(-1);
+ }
+
+ if(delCnt>0) {
+ compact();
+ c_ount-=delCnt;
+ updateListItem();
+ i_ndexDirty=true;
+ }
+ delete[] positions;
+}
+
+
+void KNFolder::deleteAll()
+{
+ if(l_ockedArticles>0)
+ return;
+
+ if (!unloadHdrs(true))
+ return;
+
+ clear();
+ c_ount=0;
+ syncIndex(true);
+ updateListItem();
+}
+
+
+void KNFolder::deleteFiles()
+{
+ m_boxFile.remove();
+ i_ndexFile.remove();
+ QFile::remove(i_nfoPath);
+}
+
+
+void KNFolder::syncIndex(bool force)
+{
+ if(!i_ndexDirty && !force)
+ return;
+
+ if(!i_ndexFile.open(IO_WriteOnly)) {
+ kdError(5003) << "KNFolder::syncIndex(bool force) : cannot open index-file!" << endl;
+ closeFiles();
+ return;
+ }
+
+ KNLocalArticle *a;
+ DynData d;
+ for(int idx=0; idx<length(); idx++) {
+ a=at(idx);
+ d.setData(a);
+ i_ndexFile.writeBlock((char*)(&d), sizeof(DynData));
+ }
+ closeFiles();
+
+ i_ndexDirty=false;
+}
+
+
+void KNFolder::closeFiles()
+{
+ if(m_boxFile.isOpen())
+ m_boxFile.close();
+ if(i_ndexFile.isOpen())
+ i_ndexFile.close();
+}
+
+
+//==============================================================================
+
+
+void KNFolder::DynData::setData(KNLocalArticle *a)
+{
+ id=a->id();
+ so=a->startOffset();
+ eo=a->endOffset();
+ sId=a->serverId();
+ ti=a->date()->unixTime();
+
+ flags[0]=a->doMail();
+ flags[1]=a->mailed();
+ flags[2]=a->doPost();
+ flags[3]=a->posted();
+ flags[4]=a->canceled();
+ flags[5]=a->editDisabled();
+}
+
+
+void KNFolder::DynData::getData(KNLocalArticle *a)
+{
+ a->setId(id);
+ a->date()->setUnixTime(ti);
+ a->setStartOffset(so);
+ a->setEndOffset(eo);
+ a->setServerId(sId);
+ a->setDoMail(flags[0]);
+ a->setMailed(flags[1]);
+ a->setDoPost(flags[2]);
+ a->setPosted(flags[3]);
+ a->setCanceled(flags[4]);
+ a->setEditDisabled(flags[5]);
+}
+