diff options
Diffstat (limited to 'libmail/nntpfolder.C')
| -rw-r--r-- | libmail/nntpfolder.C | 554 |
1 files changed, 554 insertions, 0 deletions
diff --git a/libmail/nntpfolder.C b/libmail/nntpfolder.C new file mode 100644 index 0000000..689b0c2 --- /dev/null +++ b/libmail/nntpfolder.C @@ -0,0 +1,554 @@ +/* +** Copyright 2003, Double Precision Inc. +** +** See COPYING for distribution information. +*/ +#include "nntpfolder.H" +#include "nntpnewsrc.H" +#include "nntplistactive.H" +#include "nntpgroupinfo.H" +#include "nntpgroupopen.H" +#include "nntpadd.H" +#include <fstream> +#include <vector> +#include <list> +#include <map> +#include <errno.h> +#include <cstring> + +using namespace std; + +mail::nntp::folder::folder(nntp *myserverArg, string pathArg, + bool hasMessagesArg, bool hasSubFoldersArg) + : mail::folder(myserverArg), myserver(myserverArg), + path(pathArg), hasMessagesFlag(hasMessagesArg), + hasSubFoldersFlag(hasSubFoldersArg) +{ + size_t p=pathArg.rfind('.'); + + if (p == std::string::npos) + p=0; + else + ++p; + + name=pathArg.substr(p); + + if (strncasecmp(pathArg.c_str(), FOLDER_SUBSCRIBED ".", + sizeof(FOLDER_SUBSCRIBED)) == 0) + name=pathArg.substr(sizeof(FOLDER_SUBSCRIBED)); + + if (path == FOLDER_SUBSCRIBED) + name="Subscribed newsgroups"; + if (path == FOLDER_NEWSRC) + name="All newsgroups"; + if (path == FOLDER_CHECKNEW) + name="Check for new newsgroups"; + if (path == FOLDER_REFRESH) + name="Refresh newsgroup list"; + +} + +mail::nntp::folder::folder(const mail::nntp::folder &o) + : mail::folder(o.myserver), myserver(o.myserver), + path(o.path), name(o.name), hasMessagesFlag(o.hasMessagesFlag), + hasSubFoldersFlag(o.hasSubFoldersFlag) +{ +} + +mail::nntp::folder &mail::nntp::folder::operator=(const mail::nntp::folder &o) +{ + path=o.path; + name=o.name; + hasMessagesFlag=o.hasMessagesFlag; + hasSubFoldersFlag=o.hasSubFoldersFlag; + + return *this; +} + +mail::nntp::folder::~folder() +{ +} + +void mail::nntp::folder::sameServerAsHelperFunc() const +{ +} + +std::string mail::nntp::folder::getName() const +{ + return name; +} + +std::string mail::nntp::folder::getPath() const +{ + return path; +} + +bool mail::nntp::folder::hasMessages() const +{ + return hasMessagesFlag; +} + +bool mail::nntp::folder::hasSubFolders() const +{ + return hasSubFoldersFlag; +} + +bool mail::nntp::folder::isParentOf(std::string p) const +{ + string s=path + "."; + + if (p.size() >= s.size() && p.substr(0, s.size()) == s) + return true; + return false; +} + +void mail::nntp::folder::hasMessages(bool flag) +{ + hasMessagesFlag=flag; +} + +void mail::nntp::folder::hasSubFolders(bool flag) +{ + hasSubFoldersFlag=flag; +} + +string mail::nntp::folder::newsgroupName() const +{ + string s=path; + + if (s.size() > 0 && s[0] == '/') + { + size_t n=s.find('.'); + + if (n == std::string::npos) + s=""; + else + s=s.substr(n+1); + } + + if (s.size() > 0 && s.find('\r') == std::string::npos + && s.find('\n') == std::string::npos) + return s; + return ""; +} + +string mail::nntp::folder::isNewsgroup() const +{ + return newsgroupName(); +} + +void mail::nntp::folder::readFolderInfo( callback::folderInfo + &callback1, + callback &callback2) const +{ + if (isDestroyed(callback2)) + return; + + string s=newsgroupName(); + + if (s.size() == 0) + { + callback2.success("Ok."); + return; + } + + myserver->installTask(new GroupInfoTask(&callback2, *myserver, + s, callback1)); +} + +void mail::nntp::folder::getParentFolder(callback::folderList &callback1, + callback &callback2) const +{ + if (isDestroyed(callback2)) + return; + + string ppath(""); + + size_t n=path.rfind('.'); + + if (n != std::string::npos) + ppath=path.substr(0, n); + + myserver->findFolder(ppath, callback1, callback2); +} + +void mail::nntp::folder::readSubFolders( callback::folderList &callback1, + callback &callback2) const +{ + if (isDestroyed(callback2)) + return; + + if (path.size() == 0) + { + myserver->readTopLevelFolders(callback1, callback2); + return; + } + + if (path == FOLDER_REFRESH) + { + myserver->installTask(new ListActiveTask(&callback2, + *myserver)); + return; + } + + list<mail::nntp::folder> folderList; + + if (path == FOLDER_CHECKNEW) + { + if (!myserver->hasNewgroups) + { + ifstream i(myserver->newsrcFilename.c_str()); + string serverDate; + + if (i.is_open()) + { + string line; + + while (!getline(i, line).fail()) + { + if (line.substr(0, 7) == "#DATE: ") + { + serverDate=line.substr(7); + break; + } + } + } + + if (serverDate.size() == 14) + { + myserver-> + installTask(new + ListActiveTask(&callback2, + *myserver, + serverDate, + &callback1) + ); + return; + } + } + + vector<string>::iterator b=myserver->newgroups.begin(), + e=myserver->newgroups.end(); + + while (b != e) + { + folderList.insert(folderList.end(), + folder(myserver, + FOLDER_SUBSCRIBED "." + + *b, true, false)); + b++; + } + } + else if (path == FOLDER_SUBSCRIBED) + { + // List all subscribed folders, in a flat hierarchy + + ifstream i(myserver->newsrcFilename.c_str()); + + if (i.is_open()) + { + string line; + + while (!getline(i, line).fail()) + { + newsrc parseLine(line); + + if (parseLine.newsgroupname.size() == 0) + continue; + + if (!parseLine.subscribed) + continue; + + folderList + .insert(folderList.end(), + folder(myserver, + FOLDER_SUBSCRIBED "." + + parseLine + .newsgroupname, + true, + false)); + } + } + } + else if (path.substr(0, sizeof(FOLDER_NEWSRC)-1) == FOLDER_NEWSRC) + { + size_t p=path.find('.'); + string s=p == std::string::npos ? "":path.substr(p+1); + string sdot=s + "."; + + // All newsrc folders, hierarchically + + map<string, hierEntry> subfolders; + + ifstream i(myserver->newsrcFilename.c_str()); + + if (i.is_open()) + { + string line; + + while (!getline(i, line).fail()) + { + newsrc parseLine(line); + + if (parseLine.newsgroupname.size() == 0) + continue; + + string n; + + // Take only those newsrc newsgroup that + // are in the hierarchy we're opening + + if (s.size() == 0) // Top hierarchy + { + n=parseLine.newsgroupname; + } + else + { + if (parseLine.newsgroupname.size() + < sdot.size() || + parseLine.newsgroupname + .substr(0, sdot.size()) + != sdot) + continue; // Not in this hier + + n=parseLine.newsgroupname + .substr(sdot.size()); + } + + bool isSubFolder=false; + + p=n.find('.'); + + if (p != std::string::npos) + { + n=n.substr(0, p); + isSubFolder=true; + } + + map<string, hierEntry>::iterator p= + subfolders + .insert( make_pair(n, + hierEntry())) + .first; + + if (isSubFolder) + p->second.foundSubFolders=true; + else + p->second.foundFolder=true; + } + } + i.close(); + + map<string, hierEntry>::iterator b, e; + b=subfolders.begin(); + e=subfolders.end(); + + while (b != e) + { + if (b->second.foundSubFolders) + folderList.insert(folderList.end(), + folder(myserver, + path + "." + b->first, + false, true)); + + if (b->second.foundFolder) + { + string s=path + "." + b->first; + + size_t n=s.find('.'); + + folderList + .insert(folderList.end(), + folder(myserver, + FOLDER_SUBSCRIBED + + s.substr(n), + true, + false)); + } + b++; + } + } + + // Convert the folder list to vector of pointers, then invoke the + // callbacks. + + vector<const mail::folder *> ptrList; + + list<mail::nntp::folder>::iterator b, e; + + b=folderList.begin(); + e=folderList.end(); + + while (b != e) + { + ptrList.push_back( &*b ); + b++; + } + + callback1.success(ptrList); + callback2.success("Ok."); +} + +mail::addMessage *mail::nntp::folder::addMessage(callback &callback) const +{ + if (isDestroyed(callback)) + return NULL; + + return new mail::nntp::add(myserver, &callback); +} + +void mail::nntp::folder::createSubFolder(std::string name, bool isDirectory, + callback::folderList + &callback1, + callback &callback2) const +{ + callback2.fail("Not implemented"); +} + +void mail::nntp::folder::create(bool isDirectory, + callback &callback) const +{ + callback.fail("Not implemented"); +} + +// +// A request to delete a folder translate to an unsubscribe request. +// + +void mail::nntp::folder::destroy(callback &callback, bool destroyDir) const +{ + if (isDestroyed(callback)) + return; + + string s=newsgroupName(); + + if (s.size() == 0) + { + callback.fail("Not implemented"); + return; + } + + myserver->updateCachedNewsrc(); + myserver->discardCachedNewsrc(); + + string newNewsrcFilename=myserver->newsrcFilename + ".tmp"; + + ofstream o(newNewsrcFilename.c_str()); + + if (o.is_open()) + { + ifstream i(myserver->newsrcFilename.c_str()); + + string line; + + while (i.is_open() && !getline(i, line).fail()) + { + newsrc parseLine(line); + + if (parseLine.newsgroupname.size() == 0) + { + o << line << endl; + continue; + } + + if (parseLine.newsgroupname == s) + { + parseLine.subscribed=false; + } + + o << (string)parseLine << endl; + } + + if (!o.fail() && !o.bad() && + rename(newNewsrcFilename.c_str(), + myserver->newsrcFilename.c_str()) == 0) + { + callback.success("Unsubscribed."); + return; + } + } + callback.fail(strerror(errno)); +} + +void mail::nntp::folder::renameFolder(const mail::folder *newParent, + string newName, + callback::folderList &callback1, + callback &callback2) const +{ + callback2.fail("Not implemented"); +} + +mail::folder *mail::nntp::folder::clone() const +{ + if (isDestroyed()) + { + errno=EIO; + return NULL; + } + + return new folder(myserver, path, hasMessagesFlag, + hasSubFoldersFlag); +} + +string mail::nntp::folder::toString() const +{ + string s=""; + + int i; + + for (i=0; i<3; i++) + { + string ss; + + if (i > 0) + s += ":"; + + switch (i) { + case 0: + if (hasMessagesFlag) ss += "F"; + if (hasSubFoldersFlag) ss += "D"; + break; + case 1: + ss=name; + break; + case 2: + ss=path; + break; + } + + string::iterator b, e; + b=ss.begin(); + e=ss.end(); + + while (b != e) + { + if (*b == '\\' || *b == ':') + s.append("\\", 1); + s.append(&*b, 1); + b++; + } + } + return s; +} + +void mail::nntp::folder::open(callback &openCallback, + snapshot *restoreSnapshot, + callback::folder &folderCallback) const +{ + if (isDestroyed(openCallback)) + return; + + string s=newsgroupName(); + + if (s.size() > 0) + { + myserver->installTask(new GroupOpenTask(&openCallback, + *myserver, + s, + restoreSnapshot, + &folderCallback)); + return; + } + + openCallback.fail("Not implemented"); +} |