src/dashserver/project/store.cpp

   1 /***************************************************************************
   2  *   Copyright (C) 2007 by David Cuadrado                                  *
   3  *   krawek@gmail.com                                                      *
   4  *                                                                         *
   5  *   This program is free software; you can redistribute it and/or modify  *
   6  *   it under the terms of the GNU General Public License as published by  *
   7  *   the Free Software Foundation; either version 2 of the License, or     *
   8  *   (at your option) any later version.                                   *
   9  *                                                                         *
  10  *   This program is distributed in the hope that it will be useful,       *
  11  *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
  12  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
  13  *   GNU General Public License for more details.                          *
  14  *                                                                         *
  15  *   You should have received a copy of the GNU General Public License     *
  16  *   along with this program; if not, write to the                         *
  17  *   Free Software Foundation, Inc.,                                       *
  18  *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
  19  ***************************************************************************/
  20
  21
  22 #include "store.h"
  23
  24 #include <QVariant>
  25 #include <QDir>
  26
  27 #include <dcore/debug.h>
  28 #include <dcore/algorithm.h>
  29
  30 #include "dash/projectsaver.h"
  31
  32 #include "project.h"
  33 #include "dashserver/connection.h"
  34 #include "dashserver/xdbms/manager.h"
  35 #include "dashserver/xdbms/table.h"
  36
  37 #include "dash/network/package/transfer.h"
  38
  39 namespace DashServer {
  40 namespace Project {
  41
  42 struct Store::Private
  43 {
  44         QHash<QString, Project *> projects;
  45
  46 };
  47
  48 Store::Store() : d(new Private)
  49 {
  50 }
  51
  52
  53 Store::~Store()
  54 {
  55         qDeleteAll(d->projects);
  56         delete d;
  57 }
  58
  59 QStringList Store::projects() const
  60 {
  61         XDBMS::Table *table = XDBMS::Manager::self()->table("projects");
  62
  63         return table->objects();
  64 }
  65
  66 QList<Project *> Store::allProjects() const
  67 {
  68         QList<Project *> projects;
  69
  70         XDBMS::Table *table = XDBMS::Manager::self()->table("projects");
  71         foreach(QString projectName, table->objects())
  72         {
  73                 Project *project = new Project;
  74                 project->setId(projectName);
  75                 table->load(project);
  76
  77                 project->sync();
  78                 project->setProjectName(projectName);
  79
  80                 projects << project;
  81         }
  82
  83
  84         return projects;
  85 }
  86
  87 bool Store::createProject(const QString &name, const QString &author, const QString &description)
  88 {
  89         if( !d->projects.contains(name) )
  90         {
  91                 Project *project = new Project;
  92                 project->setProjectName(name);
  93                 project->setAuthor(author);
  94                 project->setDescription(description);
  95                 project->setOpen(true);
  96
  97                 d->projects[name] = project;
  98
  99                 project->keep();
 100                 XDBMS::Manager::self()->addObject("projects", project);
 101
 102                 return project->save();
 103         }
 104
 105         return false;
 106 }
 107
 108 void Store::addToProject(const QString &projectName, DashServer::Connection *cnx)
 109 {
 110         if( d->projects.contains(projectName) )
 111         {
 112                 Project *project = d->projects.value(projectName);
 113
 114                 cnx->setData(ProjectName, projectName);
 115                 project->addClient(cnx);
 116         }
 117 }
 118
 119 bool Store::contains(const QString &projectName) const
 120 {
 121         return d->projects.contains(projectName);
 122 }
 123
 124 bool Store::execute(const QString &xml, DashServer::Connection *source)
 125 {
 126         QString projectName = source->data(ProjectName).toString();
 127
 128         if( d->projects.contains(projectName) )
 129         {
 130                 Project *project = d->projects.value(projectName);
 131                 project->execute(xml, source);
 132
 133                 return true;
 134         }
 135
 136         return false;
 137 }
 138
 139 bool Store::openProject(const QString &projectName, DashServer::Connection *source)
 140 {
 141         if( !d->projects.contains(projectName) )
 142         {
 143                 Project *project = new Project;
 144                 project->setId(projectName);
 145
 146                 if( ! XDBMS::Manager::self()->load("projects", project) ) return false;
 147
 148                 project->sync();
 149                 if( ! project->load() )
 150                         qFatal("=(");
 151
 152                 d->projects[projectName] = project;
 153         }
 154
 155         {
 156                 Project *project = d->projects.value(projectName);
 157
 158                 if( project->save() )
 159                 {
 160                         project->sendToClient(source);
 161                         addToProject(projectName, source);
 162                 }
 163
 164                 return true;
 165         }
 166
 167         return false;
 168 }
 169
 170 QList<Project *> Store::activeProjects() const
 171 {
 172         return d->projects.values();
 173 }
 174
 175 void Store::removeClient(DashServer::Connection *client)
 176 {
 177         QString projectName = client->data(ProjectName).toString();
 178
 179         if( d->projects.contains(projectName) )
 180         {
 181                 Project *project = d->projects.value(projectName);
 182                 project->removeClient(client);
 183
 184                 if( project->clientCount() == 0 )
 185                 {
 186                         d->projects.remove(projectName);
 187                         delete project;
 188                 }
 189         }
 190 }
 191
 192 void Store::sendToMembers(const QString &projectName, const QString &pkg)
 193 {
 194         if( d->projects.contains(projectName) )
 195         {
 196                 Project *project = d->projects.value(projectName);
 197                 foreach(DashServer::Connection *cnx, project->members())
 198                 {
 199                         cnx->sendToClient(pkg, false);
 200                 }
 201         }
 202 }
 203
 204 void Store::resendProject(const QString &projectName)
 205 {
 206         if( d->projects.contains(projectName) )
 207         {
 208                 Project *project = d->projects.value(projectName);
 209                 project->sendToAll();
 210         }
 211 }
 212
 213 }
 214 }
 215