summaryrefslogtreecommitdiffstats
path: root/common/resource.cpp
blob: db08c4f6e9a0b7e9bea9a8d00dd9228b6293e8be (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
/*
 * Copyright (C) 2014 Aaron Seigo <aseigo@kde.org>
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) version 3, or any
 * later version accepted by the membership of KDE e.V. (or its
 * successor approved by the membership of KDE e.V.), which shall
 * act as a proxy defined in Section 6 of version 3 of the license.
 *
 * This library 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
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library.  If not, see <http://www.gnu.org/licenses/>.
 */

#include "resource.h"

#include <QCoreApplication>
#include <QDir>
#include <QPluginLoader>
#include <QPointer>

namespace Akonadi2
{

Resource::Resource()
    : d(0)
{

}

Resource::~Resource()
{
    //delete d;
}

void Resource::configurePipeline(Pipeline *pipeline)
{

}

void Resource::processCommand(int commandId, const QByteArray &data, uint size, Pipeline *pipeline)
{
    Q_UNUSED(commandId)
    Q_UNUSED(data)
    Q_UNUSED(size)
    Q_UNUSED(pipeline)
    pipeline->null();
}

Async::Job<void> Resource::synchronizeWithSource(Pipeline *pipeline)
{
    return Async::start<void>([pipeline](Async::Future<void> &f) {
        pipeline->null();
    });
}

class ResourceFactory::Private
{
public:
    static QHash<QString, QPointer<ResourceFactory> > s_loadedFactories;
};

QHash<QString, QPointer<ResourceFactory> > ResourceFactory::Private::s_loadedFactories;

ResourceFactory::ResourceFactory(QObject *parent)
    : QObject(parent),
      d(0)
{

}

ResourceFactory::~ResourceFactory()
{
    //delete d;
}

ResourceFactory *ResourceFactory::load(const QString &resourceName)
{
    ResourceFactory *factory = Private::s_loadedFactories.value(resourceName);
    if (factory) {
        return factory;
    }

    for (auto const &path: QCoreApplication::instance()->libraryPaths()) {
        if (path.endsWith(QLatin1String("plugins"))) {
            QDir pluginDir(path);
            //TODO: centralize this so that it is easy to change centrally
            //      also ref'd in cmake as ${AKONADI_RESOURCE_PLUGINS_PATH}
            pluginDir.cd(QStringLiteral("akonadi2"));
            pluginDir.cd(QStringLiteral("resources"));

            for (const QString &fileName: pluginDir.entryList(QDir::Files)) {
                const QString path = pluginDir.absoluteFilePath(fileName);
                QPluginLoader loader(path);

                const QString id = loader.metaData()[QStringLiteral("IID")].toString();
                if (id == resourceName) {
                    QObject *object = loader.instance();
                    if (object) {
                        factory = qobject_cast<ResourceFactory *>(object);
                        if (factory) {
                            Private::s_loadedFactories.insert(resourceName, factory);
                            factory->registerFacades(FacadeFactory::instance());
                            //TODO: if we need more data on it const QJsonObject json = loader.metaData()[QStringLiteral("MetaData")].toObject();
                            return factory;
                        } else {
                            qWarning() << "Plugin for" << resourceName << "from plugin" << loader.fileName() << "produced the wrong object type:" << object;
                            delete object;
                        }
                    } else {
                        qWarning() << "Could not load factory for" << resourceName << "from plugin" << loader.fileName() << "due to the following error:" << loader.errorString();
                    }
                }
            }
        }
    }

    qWarning() << "Failed to find factory for resource:" << resourceName;
    return nullptr;
}

} // namespace Akonadi2