1/*
2 Copyright (c) 2006 Volker Krause <vkrause@kde.org>
3
4 This library is free software; you can redistribute it and/or modify it
5 under the terms of the GNU Library General Public License as published by
6 the Free Software Foundation; either version 2 of the License, or (at your
7 option) any later version.
8
9 This library is distributed in the hope that it will be useful, but WITHOUT
10 ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 FITNESS FOR A PARTICULAR PURPOSE. See the GNU Library General Public
12 License for more details.
13
14 You should have received a copy of the GNU Library General Public License
15 along with this library; see the file COPYING.LIB. If not, write to the
16 Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
17 02110-1301, USA.
18*/
19
20#include "transaction.h"
21#include "storage/datastore.h"
22#include "connection.h"
23#include "response.h"
24#include "imapstreamparser.h"
25
26#include <QMetaEnum>
27
28using namespace Akonadi::Server;
29
30TransactionHandler::TransactionHandler(Mode mode)
31 : mMode(mode)
32{
33}
34
35bool TransactionHandler::parseStream()
36{
37 DataStore *store = connection()->storageBackend();
38
39 if (mMode == Begin) {
40 if (!store->beginTransaction()) {
41 return failureResponse("Unable to begin transaction.");
42 }
43 }
44
45 if (mMode == Rollback) {
46 if (!store->inTransaction()) {
47 return failureResponse("There is no transaction in progress.");
48 }
49 if (!store->rollbackTransaction()) {
50 return failureResponse("Unable to roll back transaction.");
51 }
52 }
53
54 if (mMode == Commit) {
55 if (!store->inTransaction()) {
56 return failureResponse("There is no transaction in progress.");
57 }
58 if (!store->commitTransaction()) {
59 return failureResponse("Unable to commit transaction.");
60 }
61 }
62
63 const QMetaEnum me = metaObject()->enumerator(metaObject()->indexOfEnumerator("Mode"));
64 return successResponse(me.valueToKey(mMode) + QByteArray(" completed"));
65}
66