/* * Copyright (C) 2015 Christian Mollekopf * * 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. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * 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 USA. */ #include "mail.h" #include #include #include #include #include #include "../resultset.h" #include "../index.h" #include "../storage.h" #include "../log.h" #include "../propertymapper.h" #include "../query.h" #include "../definitions.h" #include "../typeindex.h" #include "mail_generated.h" SINK_DEBUG_AREA("mail"); static QMutex sMutex; using namespace Sink::ApplicationDomain; static TypeIndex &getIndex() { QMutexLocker locker(&sMutex); static TypeIndex *index = 0; if (!index) { index = new TypeIndex("mail"); index->addProperty("uid"); index->addProperty("sender"); index->addProperty("senderName"); index->addProperty("subject"); index->addProperty("date"); index->addProperty("folder"); index->addPropertyWithSorting("folder", "date"); } return *index; } ResultSet TypeImplementation::queryIndexes(const Sink::Query &query, const QByteArray &resourceInstanceIdentifier, QSet &appliedFilters, QByteArray &appliedSorting, Sink::Storage::Transaction &transaction) { return getIndex().query(query, appliedFilters, appliedSorting, transaction); } void TypeImplementation::index(const QByteArray &identifier, const BufferAdaptor &bufferAdaptor, Sink::Storage::Transaction &transaction) { SinkTrace() << "Indexing " << identifier; getIndex().add(identifier, bufferAdaptor, transaction); } void TypeImplementation::removeIndex(const QByteArray &identifier, const BufferAdaptor &bufferAdaptor, Sink::Storage::Transaction &transaction) { getIndex().remove(identifier, bufferAdaptor, transaction); } QSharedPointer::Buffer> > TypeImplementation::initializeReadPropertyMapper() { auto propertyMapper = QSharedPointer >::create(); propertyMapper->addMapping(&Buffer::uid); propertyMapper->addMapping(&Buffer::sender); propertyMapper->addMapping(&Buffer::senderName); propertyMapper->addMapping(&Buffer::subject); propertyMapper->addMapping(&Buffer::date); propertyMapper->addMapping(&Buffer::unread); propertyMapper->addMapping(&Buffer::important); propertyMapper->addMapping(&Buffer::folder); propertyMapper->addMapping(&Buffer::mimeMessage); propertyMapper->addMapping(&Buffer::draft); propertyMapper->addMapping(&Buffer::trash); propertyMapper->addMapping(&Buffer::sent); return propertyMapper; } QSharedPointer::BufferBuilder> > TypeImplementation::initializeWritePropertyMapper() { auto propertyMapper = QSharedPointer >::create(); propertyMapper->addMapping(&BufferBuilder::add_uid); propertyMapper->addMapping(&BufferBuilder::add_sender); propertyMapper->addMapping(&BufferBuilder::add_senderName); propertyMapper->addMapping(&BufferBuilder::add_subject); propertyMapper->addMapping(&BufferBuilder::add_date); propertyMapper->addMapping(&BufferBuilder::add_unread); propertyMapper->addMapping(&BufferBuilder::add_important); propertyMapper->addMapping(&BufferBuilder::add_folder); propertyMapper->addMapping(&BufferBuilder::add_mimeMessage); propertyMapper->addMapping(&BufferBuilder::add_draft); propertyMapper->addMapping(&BufferBuilder::add_trash); propertyMapper->addMapping(&BufferBuilder::add_sent); return propertyMapper; }