ArServerFileUtils.h

Go to the documentation of this file.

/*
MobileRobots Advanced Robotics Interface for Applications (ARIA)
Copyright (C) 2004, 2005 ActivMedia Robotics LLC
Copyright (C) 2006, 2007 MobileRobots Inc.

     This program is free software; you can redistribute it and/or modify
     it under the terms of the GNU General Public License as published by
     the Free Software Foundation; either version 2 of the License, or
     (at your option) any later version.

     This program 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 General Public License for more details.

     You should have received a copy of the GNU General Public License
     along with this program; if not, write to the Free Software
     Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

If you wish to redistribute ARIA under different terms, contact 
MobileRobots for information about a commercial version of ARIA at 
robots@mobilerobots.com or 
MobileRobots Inc, 19 Columbia Drive, Amherst, NH 03031; 800-639-9481
*/

#ifndef ARSERVERFILEUTILS_H
#define ARSERVERFILEUTILS_H

#include "Aria.h"
#include "ArServerBase.h"


class ArServerFileUtil
{
public:
  AREXPORT static bool squashCase(const char *baseDir, const char *fileName, 
                           char * result, size_t resultLen);
  AREXPORT static bool getDirectory(const char *fileName, 
                                     char * result, size_t resultLen);
  AREXPORT static bool getFileName(const char *fileName, 
                                     char * result, size_t resultLen);

protected:
  static std::list<std::string> splitFileName(const char *fileName);

};


class ArServerFileLister
{
public:
  AREXPORT ArServerFileLister(ArServerBase *server, const char *topDir);
  AREXPORT virtual ~ArServerFileLister();
  AREXPORT void getDirListing(ArServerClient *client,
                              ArNetPacket *packet);
protected:
  char myBaseDir[2048];
  ArServerBase *myServer;
  ArFunctor2C<ArServerFileLister, ArServerClient *, 
      ArNetPacket *> myGetDirListingCB;
};



class ArServerFileToClient
{
public:
  AREXPORT ArServerFileToClient(ArServerBase *server, const char *topDir);
  AREXPORT virtual ~ArServerFileToClient();
  AREXPORT void getFile(ArServerClient *client,
                        ArNetPacket *packet);
protected:
  
  char myBaseDir[2048];
  ArServerBase *myServer;
  ArFunctor2C<ArServerFileToClient, ArServerClient *, 
      ArNetPacket *> myGetFileCB;
};


class ArServerFileFromClient
{
public:
  AREXPORT ArServerFileFromClient(ArServerBase *server, const char *topDir, 
                                  const char *tempDir);
  AREXPORT virtual ~ArServerFileFromClient();
  AREXPORT void putFile(ArServerClient *client, ArNetPacket *packet);
  AREXPORT void putFileInterleaved(ArServerClient *client, 
                                   ArNetPacket *packet);

  AREXPORT void addPreMoveCallback(
          ArFunctor *functor, ArListPos::Pos position = ArListPos::LAST);
  AREXPORT void remPreMoveCallback(ArFunctor *functor);
  AREXPORT void addPostMoveCallback(
          ArFunctor *functor, ArListPos::Pos position = ArListPos::LAST);
  AREXPORT void remPostMoveCallback(ArFunctor *functor);  
  const char *getMovingFileName(void) { return myMovingFileName.c_str(); }
protected:
  AREXPORT void internalPutFile(ArServerClient *client, ArNetPacket *packet,
                                bool interleaved);
  char myBaseDir[2048];
  char myTempDir[2048];
  ArServerBase *myServer;
  std::list<ArFunctor *> myPreMoveCallbacks;
  std::list<ArFunctor *> myPostMoveCallbacks;
  ArFunctor2C<ArServerFileFromClient, ArServerClient *, 
      ArNetPacket *> myPutFileCB;
  ArFunctor2C<ArServerFileFromClient, ArServerClient *, 
      ArNetPacket *> myPutFileInterleavedCB;

  std::string myMovingFileName;

  int myFileNumber;
  class FileInfo
  {
  public:
    FileInfo() { myFile = NULL; }
    virtual ~FileInfo() {}
    std::string myRealFileName;
    std::string myTempFileName;
    FILE *myFile;
    ArTime myStartedTransfer;
    ArTime myLastActivity;
  };
  // map of raw filenames to FileInfo (so we don't have to walk it all the time)
  std::map<std::string, FileInfo *> myMap;
};



class ArServerDeleteFileOnServer
{
public:
  AREXPORT ArServerDeleteFileOnServer(ArServerBase *server, 
                                      const char *topDir);
  AREXPORT virtual ~ArServerDeleteFileOnServer();
  AREXPORT void deleteFile(ArServerClient *client,
                           ArNetPacket *packet);
  AREXPORT void addPreDeleteCallback(
          ArFunctor *functor, ArListPos::Pos position = ArListPos::LAST);
  AREXPORT void remPreDeleteCallback(ArFunctor *functor);
  AREXPORT void addPostDeleteCallback(
          ArFunctor *functor, ArListPos::Pos position = ArListPos::LAST);
  AREXPORT void remPostDeleteCallback(ArFunctor *functor);  
  const char *getDeletingFileName(void) { return myDeletingFileName.c_str(); }
protected:
  char myBaseDir[2048];
  ArServerBase *myServer;
  ArFunctor2C<ArServerDeleteFileOnServer, ArServerClient *, 
      ArNetPacket *> myDeleteFileCB;
  std::string myDeletingFileName;
  std::list<ArFunctor *> myPreDeleteCallbacks;
  std::list<ArFunctor *> myPostDeleteCallbacks;

};

#endif // ARSERVERFILEUTILS_H

---