src/dashserver/project/project.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 "project.h"
  23
  24 #include <QSet>
  25
  26 #include <yamf/model/command/processor.h>
  27
  28 #include "dashserver/connection.h"
  29 #include "dashserver/xdbms/manager.h"
  30
  31 #include "dash/projectsaver.h"
  32 #include "dash/network/package/transfer.h"
  33
  34 #include <dcore/debug.h>
  35
  36 namespace DashServer {
  37 namespace Project {
  38
  39 struct Project::Private
  40 {
  41         YAMF::Command::Processor *processor;
  42
  43         QSet<DashServer::Connection *> connections;
  44
  45         QSet<QString> designers;
  46         QSet<QString> owners;
  47 };
  48
  49 Project::Project() : YAMF::Model::Project(), d(new Private)
  50 {
  51         d->processor = new YAMF::Command::Processor(this);
  52 }
  53
  54
  55 Project::~Project()
  56 {
  57         delete d->processor;
  58         delete d;
  59 }
  60
  61 void Project::execute(const QString &xml, DashServer::Connection *source)
  62 {
  63         if( d->connections.contains(source) )
  64         {
  65                 if( d->processor->execute(xml) )
  66                 {
  67                         QString tosend = source->signXml(xml);
  68
  69                         foreach(DashServer::Connection *cnx, d->connections)
  70                         {
  71                                 cnx->sendToClient( tosend, false );
  72                         }
  73                 }
  74                 else
  75                 {
  76                         source->sendToClient( "<command />", true );
  77                 }
  78         }
  79         else
  80         {
  81                 qWarning("INVALID SOURCE");
  82         }
  83 }
  84
  85 void Project::addClient(DashServer::Connection *cnx)
  86 {
  87         d->connections << cnx;
  88 }
  89
  90 void Project::removeClient(DashServer::Connection *client)
  91 {
  92         d->connections.remove(client);
  93
  94         if( d->connections.isEmpty() )
  95         {
  96                 save();
  97         }
  98 }
  99
 100 void Project::sendToClient(DashServer::Connection *client)
 101 {
 102         // FIXME: Poner en un thread
 103         {
 104                 QFile f(this->fileName());
 105                 Dash::Network::Package::Transfer transfer(f.size());
 106                 client->sendToClient(transfer.toString(), true);
 107
 108                 if( f.open(QIODevice::ReadOnly) )
 109                 {
 110                         while(!f.atEnd())
 111                         {
 112                                 client->sendBinaryData(f.read(1024));
 113                         }
 114                 }
 115         }
 116 }
 117
 118 void Project::sendToAll()
 119 {
 120         save();
 121
 122         {
 123                 QFile f(this->fileName());
 124
 125                 foreach(DashServer::Connection *client, d->connections)
 126                 {
 127                         Dash::Network::Package::Transfer transfer(f.size());
 128                         client->sendToClient(transfer.toString(), true);
 129                 }
 130
 131                 if( f.open(QIODevice::ReadOnly) )
 132                 {
 133                         while(!f.atEnd())
 134                         {
 135                                 foreach(DashServer::Connection *client, d->connections)
 136                                 {
 137                                         client->sendBinaryData(f.read(1024));
 138                                 }
 139                         }
 140                 }
 141         }
 142 }
 143
 144 QSet<DashServer::Connection *> Project::members() const
 145 {
 146         return d->connections;
 147 }
 148
 149 int Project::clientCount() const
 150 {
 151         return d->connections.size();
 152 }
 153
 154 void Project::keep()
 155 {
 156         if( projectName().isEmpty() ) return;
 157
 158 //      QString id = projectName().toLower().replace(' ', '_');;
 159
 160         setId(projectName());
 161
 162         add("description", description());
 163         add("author", author());
 164         addList("owners", d->owners.toList());
 165         addList("designers", d->designers.toList());
 166
 167 }
 168
 169 void Project::sync()
 170 {
 171         setProjectName(id());
 172         setDescription(value("description"));
 173         setAuthor(value("author"));
 174
 175         dfDebug << value("author");
 176
 177         foreach(QString owner, list("owners"))
 178         {
 179                 addOwner(owner);
 180         }
 181
 182         foreach(QString designer, list("designers"))
 183         {
 184                 addDesigner(designer);
 185         }
 186 }
 187
 188 bool Project::save()
 189 {
 190         QString pname = projectName();
 191
 192         if( pname.isEmpty() ) return false;
 193
 194         return Dash::ProjectSaver::save(this, fileName());
 195 }
 196
 197 bool Project::load()
 198 {
 199         QString pname = projectName();
 200
 201         if( pname.isEmpty() ) return false;
 202
 203         clear();
 204
 205         return Dash::ProjectSaver::load(this, fileName());
 206 }
 207
 208 QString Project::fileName() const
 209 {
 210         QString pname = projectName();
 211
 212         if( pname.isEmpty() )
 213                 return QString();
 214
 215         return XDBMS::Manager::self()->databaseDir().absoluteFilePath(pname+".dsh");
 216 }
 217
 218 QSet<QString> Project::designers() const
 219 {
 220         return d->designers;
 221 }
 222
 223 void Project::addDesigner(const QString &name)
 224 {
 225         d->designers << name;
 226 }
 227
 228 QSet<QString> Project::owners() const
 229 {
 230         return d->owners;
 231 }
 232
 233 void Project::addOwner(const QString &name)
 234 {
 235         d->owners << name;
 236 }
 237
 238
 239 }
 240 }
 241
 242