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 #include <QXmlStreamReader>
  26
  27 #include <yamf/model/command/processor.h>
  28
  29 #include "dashserver/connection.h"
  30 #include "dashserver/logger.h"
  31 #include "dashserver/xdbms/manager.h"
  32
  33 #include "dash/projectsaver.h"
  34 #include "dash/network/package/transfer.h"
  35
  36 #include "member.h"
  37 #include "commandprocessor.h"
  38
  39 #include <dcore/debug.h>
  40
  41 namespace DashServer {
  42 namespace Project {
  43
  44 struct Project::Private
  45 {
  46         Private(Project *q) : q(q), initialized(false) {}
  47
  48         Project *q;
  49         bool initialized;
  50         CommandProcessor *processor;
  51
  52         QSet<DashServer::Connection *> connections;
  53
  54         QHash<QString, Member *> members;
  55
  56
  57         void loadMembers();
  58 };
  59
  60 void Project::Private::loadMembers()
  61 {
  62         members.clear();
  63
  64         QList<XDBMS::Object *> objects = q->objects();
  65
  66         foreach(XDBMS::Object *obj, objects)
  67         {
  68                 if( obj->klass() == "member" )
  69                 {
  70                         Member *member = static_cast<Member *>(obj);
  71                         members[member->id()] = member;
  72                 }
  73         }
  74
  75         initialized = true;
  76 }
  77
  78 Project::Project(QObject *parent) : Dash::Project(parent), XDBMS::Object(), d(new Private(this))
  79 {
  80         d->processor = new CommandProcessor(this);
  81
  82         setClass("project");
  83 }
  84
  85
  86 Project::~Project()
  87 {
  88         delete d->processor;
  89         delete d;
  90 }
  91
  92 void Project::execute(const QString &xml, DashServer::Connection *source)
  93 {
  94         if( d->connections.contains(source) )
  95         {
  96                 QString cmdname;
  97
  98                 {
  99                         QXmlStreamReader reader(xml);
 100                         while(!reader.atEnd())
 101                         {
 102                                 if( reader.readNext() == QXmlStreamReader::StartElement )
 103                                 {
 104                                         if( reader.name() == "command" )
 105                                         {
 106                                                 cmdname = reader.attributes().value("name").toString();
 107                                                 break;
 108                                         }
 109                                 }
 110                         }
 111                 }
 112
 113                 Member *member = d->members.value(source->user()->login());
 114                 int part = Project::partFromCommand(cmdname);
 115
 116                 if( ! member->canWriteOn(part) )
 117                 {
 118                         DashServer::Logger::self()->info(QString("Permission denied: User %1 trying to write on %2").arg(member->id(), Project::partName(part)));
 119
 120                         source->sendToClient( "<command />\n", true );
 121                         source->sendError(tr("Permission denied"), Dash::Network::Package::Error::Err);
 122                         return;
 123                 }
 124
 125                 if( d->processor->execute(xml) )
 126                 {
 127                         QString tosend = source->signXml(xml);
 128
 129                         foreach(DashServer::Connection *cnx, d->connections)
 130                         {
 131                                 if( d->members[cnx->user()->login()]->canReadOn(part) )
 132                                 {
 133                                         cnx->sendToClient( tosend, false );
 134                                 }
 135                         }
 136                 }
 137                 else
 138                 {
 139                         source->sendToClient( "<command />", true ); // FIXME: create a package
 140                 }
 141         }
 142         else
 143         {
 144                 qWarning("INVALID SOURCE");
 145         }
 146 }
 147
 148 void Project::addClient(DashServer::Connection *cnx)
 149 {
 150         d->connections << cnx;
 151 }
 152
 153 void Project::removeClient(DashServer::Connection *client)
 154 {
 155         d->connections.remove(client);
 156
 157         if( d->connections.isEmpty() )
 158         {
 159                 save();
 160         }
 161 }
 162
 163 void Project::sendToClient(DashServer::Connection *client)
 164 {
 165         // FIXME: Poner en un thread
 166         {
 167                 QFile f(this->fileName());
 168                 Dash::Network::Package::Transfer transfer(f.size());
 169                 client->sendToClient(transfer.toString(), true);
 170
 171                 if( f.open(QIODevice::ReadOnly) )
 172                 {
 173                         while(!f.atEnd())
 174                         {
 175                                 client->sendBinaryData(f.read(1024));
 176                         }
 177                 }
 178         }
 179 }
 180
 181 void Project::sendToAll()
 182 {
 183         save();
 184
 185         {
 186                 QFile f(this->fileName());
 187
 188                 foreach(DashServer::Connection *client, d->connections)
 189                 {
 190                         Dash::Network::Package::Transfer transfer(f.size());
 191                         client->sendToClient(transfer.toString(), true);
 192                 }
 193
 194                 if( f.open(QIODevice::ReadOnly) )
 195                 {
 196                         while(!f.atEnd())
 197                         {
 198                                 foreach(DashServer::Connection *client, d->connections)
 199                                 {
 200                                         client->sendBinaryData(f.read(1024));
 201                                 }
 202                         }
 203                 }
 204         }
 205 }
 206
 207 QHash<QString, Member *> Project::members() const
 208 {
 209         return d->members;
 210 }
 211
 212 QSet<DashServer::Connection *> Project::connections() const
 213 {
 214         return d->connections;
 215 }
 216
 217 int Project::clientCount() const
 218 {
 219         return d->connections.size();
 220 }
 221
 222 void Project::aboutToSave()
 223 {
 224         if( projectName().isEmpty() ) return;
 225
 226         setId(projectName());
 227
 228         add("description", description());
 229         add("author", author());
 230
 231         if(!d->initialized) d->loadMembers();
 232 }
 233
 234 void Project::afterLoad()
 235 {
 236         setProjectName(id());
 237         setDescription(value("description"));
 238         setAuthor(value("author"));
 239
 240         if(!d->initialized) d->loadMembers();
 241 }
 242
 243 bool Project::save()
 244 {
 245         if(!d->initialized) d->loadMembers();
 246
 247         QString pname = projectName();
 248
 249         if( pname.isEmpty() ) return false;
 250
 251         return Dash::ProjectSaver::save(this, fileName());
 252 }
 253
 254 bool Project::load()
 255 {
 256         if(!d->initialized) d->loadMembers();
 257
 258         QString pname = projectName();
 259
 260         if( pname.isEmpty() )
 261         {
 262                 qWarning("Warning: Project name is empty");
 263                 return false;
 264         }
 265
 266         clear();
 267
 268         return Dash::ProjectSaver::load(this, fileName());
 269 }
 270
 271 QString Project::fileName() const
 272 {
 273         QString pname = projectName();
 274
 275         if( pname.isEmpty() )
 276                 return QString();
 277
 278         return XDBMS::Manager::self()->databaseDir().absoluteFilePath(pname+".dsh");
 279 }
 280
 281 void Project::addMember(Member *member)
 282 {
 283         if( d->members.contains(member->id()) )
 284         {
 285                 d->members.remove(member->id());
 286                 remove(member);
 287         }
 288
 289         d->members[member->id()] = member;
 290         add(member);
 291 }
 292
 293 QString Project::partName(int part)
 294 {
 295         switch(part)
 296         {
 297                 case All:
 298                 {
 299                         return "all";
 300                 }
 301                 break;
 302                 case Scene:
 303                 {
 304                         return "scene";
 305                 }
 306                 break;
 307                 case Layer:
 308                 {
 309                         return "layer";
 310                 }
 311                 break;
 312                 case Frame:
 313                 {
 314                         return "frame";
 315                 }
 316                 break;
 317                 case Object:
 318                 {
 319                         return "object";
 320                 }
 321                 break;
 322         }
 323
 324         return QString();
 325 }
 326
 327
 328 int Project::partFromCommand(const QString &pkgname)
 329 {
 330         Project::Part part = Project::None;
 331
 332         // LIBRARY
 333         if( pkgname == "addlibraryfolder" )
 334         {
 335                 part = Project::Library;
 336         }
 337         else if( pkgname == "addlibraryobject" )
 338         {
 339                 part = Project::Library;
 340         }
 341         else if( pkgname == "modifysymbol" )
 342         {
 343                 part = Project::Library;
 344         }
 345         else if( pkgname == "renamelibraryobject" )
 346         {
 347                 part = Project::Library;
 348         }
 349
 350
 351         // OBJECT AND ITEM
 352         if( pkgname == "additemfilter" )
 353         {
 354                 part = Project::Object;
 355         }
 356         else if( pkgname == "addobject" )
 357         {
 358                 part = Project::Object;
 359         }
 360         else if( pkgname == "addtweening" )
 361         {
 362                 part = Project::Object;
 363         }
 364         else if( pkgname == "bringforwardsitem" )
 365         {
 366                 part = Project::Object;
 367         }
 368         else if( pkgname == "bringtofrontitem" )
 369         {
 370                 part = Project::Object;
 371         }
 372         else if( pkgname == "changelayervisibility" )
 373         {
 374                 part = Project::Object;
 375         }
 376         else if( pkgname == "changetextfont" )
 377         {
 378                 part = Project::Object;
 379         }
 380         else if( pkgname == "changetext" )
 381         {
 382                 part = Project::Object;
 383         }
 384         else if( pkgname == "changetextwidth" )
 385         {
 386                 part = Project::Object;
 387         }
 388         else if( pkgname == "convertitem" )
 389         {
 390                 part = Project::Object;
 391         }
 392         else if( pkgname == "editnodesitem" )
 393         {
 394                 part = Project::Object;
 395         }
 396         else if( pkgname == "changeitembrush" )
 397         {
 398                 part = Project::Object;
 399         }
 400         else if( pkgname == "changeitempen" )
 401         {
 402                 part = Project::Object;
 403         }
 404         else if( pkgname == "groupitem" )
 405         {
 406                 part = Project::Object;
 407         }
 408         else if( pkgname == "modifyfilter" )
 409         {
 410                 part = Project::Object;
 411         }
 412         else if( pkgname == "modifyitem" )
 413         {
 414                 part = Project::Object;
 415         }
 416         else if( pkgname == "removelibraryobject" )
 417         {
 418                 part = Project::Object;
 419         }
 420         else if( pkgname == "removeobject" )
 421         {
 422                 part = Project::Object;
 423         }
 424         else if( pkgname == "sendbackwardsitem" )
 425         {
 426                 part = Project::Object;
 427         }
 428         else if( pkgname == "sendtobackitem" )
 429         {
 430                 part = Project::Object;
 431         }
 432         else if( pkgname == "ungroupitem" )
 433         {
 434                 part = Project::Object;
 435         }
 436
 437
 438         // FRAME
 439         if( pkgname == "changeframevisibility" )
 440         {
 441                 part = Project::Frame;
 442         }
 443         else if( pkgname == "expandframe" )
 444         {
 445                 part = Project::Frame;
 446         }
 447         else if( pkgname == "insertframe" )
 448         {
 449                 part = Project::Frame;
 450         }
 451         else if( pkgname == "lockframe" )
 452         {
 453                 part = Project::Frame;
 454         }
 455         else if( pkgname == "moveframe" )
 456         {
 457                 part = Project::Frame;
 458         }
 459         else if( pkgname == "removeframe" )
 460         {
 461                 part = Project::Frame;
 462         }
 463         else if( pkgname == "renameframe" )
 464         {
 465                 part = Project::Frame;
 466         }
 467
 468         // LAYER
 469         if( pkgname == "insertlayer" )
 470         {
 471                 part = Project::Layer;
 472         }
 473         else if( pkgname == "locklayer" )
 474         {
 475                 part = Project::Layer;
 476         }
 477         else if( pkgname == "movelayer" )
 478         {
 479                 part = Project::Layer;
 480         }
 481         else if( pkgname == "removelayer" )
 482         {
 483                 part = Project::Layer;
 484         }
 485         else if( pkgname == "renamelayer" )
 486         {
 487                 part = Project::Layer;
 488         }
 489
 490
 491         // SCENE
 492         if( pkgname == "insertscene" )
 493         {
 494                 part = Project::Scene;
 495         }
 496         else if( pkgname == "movescene" )
 497         {
 498                 part = Project::Scene;
 499         }
 500         else if( pkgname == "removescene" )
 501         {
 502                 part = Project::Scene;
 503         }
 504         else if( pkgname == "renamescene" )
 505         {
 506                 part = Project::Scene;
 507         }
 508
 509         return part;
 510 }
 511
 512
 513 }
 514 }
 515
 516