x3c/include/projectManagement/Projects.h

/******************************************************************************
 * Projects.h
 *
 *  Author      : Danni Song
 *  Version     :
 *  Copyright   : (C) Copyright 2011 XCube Research and Development
 *                      All rights reserved.
 *  Description : This class provides user functions to projects, refers to the
 *                access and manipulation of Logger Data Projects related data
 *                on any X3C logger ot DSSC platform.
 *  HISTORY     :
 *          Oct 14, 2011 - initial version
 *
 *****************************************************************************/
#ifndef PROJECTS_H_
#define PROJECTS_H_

#include "xcTypes.h"
#include "CX3cFile.h"
//#include "CMsgHub.h"
#include "xcTaskTools.h"
#include "x3cTaskDefs.h"

#include <string>
#include <vector>
#include <sstream>
using namespace std;

#define MNT_POINT_BASE_NUMBER 0;
#define PROJECTNAME_PREFIX "proj_"  //UTC is appended to this string
#define PROJECT_BASE_PATH "/xcube"
// this is defined in lgrTaskDefs.h
//Identifies the TYPE of task,
//#define TASK_ADDR_LGRMGR              ((TASK_TYPE_LGRMGR << 16)   | 0x00000000)



typedef struct  _STREAM_BLOCK_ {

    string strmParent;


    string strmPath;            // Path from project base path


    string  strmName;


    unsigned long long strmSize;


    unsigned int strmType;


    unsigned int strmEnum;


    unsigned int strmRun;
}STREAM;


typedef struct  _PROJECT_BLOCK_
{

    string  prjName;


    UINT64 prjSize;


    bool activeFlag;

    /* a vector containing all stream of this project*/
    vector<STREAM> streamList;
} PROJECT;


class Projects
{
 protected:


    string mRootPath;


    string mMntBasePnt;


    UINT32 mDiskCount;


    vector<PROJECT> mProjects;


    PROJECT* mActiveProject;

    PROJECT* mCurrentProject;


    static const int MntBasePntNo = MNT_POINT_BASE_NUMBER;


 public:

    bool mProjectCreated;


    Projects(string mntBasePnt = "", string projBasePath = "",
             unsigned diskCount = 0);


    virtual ~ Projects();


    vector<PROJECT> pmGetProjects();


    int pmDeleteProject(string const& prjName);

    // ! Close project
    int pmCloseProject();


    int pmActivateProject(string prjName);


    int pmInactivateProject();


    PROJECT* pmGetActiveProject();


    int pmGetStreams(vector<STREAM> &streamList);


    bool pmIsProjectAlive() const;


    bool pmIsProjectActive();


    PROJECT* pmGetCurrentProject();


    void pmSetCurrentProject(string projectName);


    string pmGetRootPath() const;


    string pmGetMntBasePnt() const;


    unsigned pmGetDiskCount() const;


    void pmSetDiskCount(int numOfDisks);


    PROJECT* pmGetLatestProject();

    int pmGetStreamFiles(STREAM const& stream, vector<string>& streamFiles);

protected:

    int pmScanProjects();

    // ! Remove a directory
    int pmRemoveDirectory(string path);


    bool pmIsDirectory(string path);


    INT64 pmGetProjectDataSize(string const& projName, vector<int> &missingDisks);


    int pmScanStreams(PROJECT &proj);


    void pmParseStreamName(STREAM &stream);


    PROJECT* pmFindProject(string prjName);


    unsigned long long pmGetStreamSize(STREAM const& stream);

    unsigned long long pmGetStreamSizeDeepSearch(STREAM const& stream);

    unsigned long long pmGetProjectDataSizeDeepSearch(std::string const& prjName);

    int pmDeleteProjectDeepSearch(std::string const& prjName);
};

#endif /* PROJECTS_H_ */