datalib.h

Go to the documentation of this file.

/********************************************************************
* Copyright (C) 2015 by Interstel Technologies, Inc.
*   and Hawaii Space Flight Laboratory.
*
* This file is part of the COSMOS/core that is the central
* module for COSMOS. For more information on COSMOS go to
* <http://cosmos-project.com>
*
* The COSMOS/core software is licenced under the
* GNU Lesser General Public License (LGPL) version 3 licence.
*
* You should have received a copy of the
* GNU Lesser General Public License
* If not, go to <http://www.gnu.org/licenses/>
*
* COSMOS/core is free software: you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public License
* as published by the Free Software Foundation, either version 3 of
* the License, or (at your option) any later version.
*
* COSMOS/core 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
* Lesser General Public License for more details.
*
* Refer to the "licences" folder for further information on the
* condititons and terms to use this software.
********************************************************************/

#ifndef _DATALIB_H
#define _DATALIB_H

// COSMOS libs
#include "support/configCosmos.h"
#include "support/cosmos-errno.h"
#include "support/jsondef.h"
#include "support/jsonlib.h"
#include "thirdparty/zlib/zlib.h"
#include "support/timelib.h"

// C libs
#include <sys/stat.h>
#include <fstream>

#ifdef _MSC_BUILD
#include "dirent/dirent.h"
#else
#include <dirent.h>
#endif



#define DATA_LOG_TYPE_SOH 0
#define DATA_LOG_TYPE_EVENT 1
#define DATA_LOG_TYPE_BEACON 2
#define DATA_LOG_TYPE_PROGRAM 3 // to log program status information while running

typedef struct
{
    string node;
    string agent;
    string name;
    string type;
    string path;
    off_t size;
    uint16_t year;
    uint16_t jday;
    uint32_t seconds;
    double utc;
} filestruc;

void log_reopen();
void log_write(string node, int type, double utc, const char* data, string directory="temp");
void log_write(string node, string agent, double utc, string type, const char *data);
//void log_write(string node, string agent, double utc, string extra, string type, string record);
void log_write(string node, string agent, double utc, string extra, string type, string record, string location="temp");
void log_move(string node, string agent, string srclocation, string dstlocation, bool compress);
void log_move(string node, string agent);
void log_move(string oldpath, string newpath, bool compress);
string log_read(gzFile &file, int num);
int check_events(eventstruc* events, int max, cosmosstruc* data);
int32_t data_get_nodes(vector<cosmosstruc> &data);
vector<string> data_list_nodes();
int32_t data_list_nodes(vector<string>& nodes);
vector<filestruc> data_list_files(string directory);
size_t data_list_files(string directory, vector<filestruc>& files);
vector<filestruc> data_list_files(string node, string location, string agent);
size_t data_list_files(string node, string location, string agent, vector<filestruc>& files);
vector<filestruc> data_list_archive(string node, string agent, double utc, string type);
vector<filestruc> data_list_archive(string node, string agent, double utc);
vector <double> data_list_archive_days(string node, string agent);
FILE* data_open(string path, const char *mode);
int32_t data_name_date(string node, string filename, uint16_t &year, uint16_t &jday, uint32_t &seconds);
int32_t data_name_date(string node, string filename, double &utc);
string data_name(string node, double mjd, string extra, string type);
string data_name(string node, double mjd, string type);
string data_base_path(string node);
string data_base_path(string node, string location);
string data_base_path(string node, string location, string agent);
string data_base_path(string node, string location, string agent, string filename);
string data_archive_path(string node, string agent, double mjd);
string data_type_path(string node, string location, string agent, double mjd, string type);
string data_type_path(string node, string location, string agent, double mjd, string extra, string type);
string data_name_path(string node, string location="", string agent="", double mjd=0., string name="");
string data_resource_path(string name);
bool data_exists(string& path);
bool data_isdir(string path);
bool data_ischardev(string path);
bool data_isfile(string path, off_t size=0);
double data_ctime(string path);
int32_t data_execute(string cmd, string& result, string shell="");
off_t data_size(string path);
int32_t set_cosmosroot(string name, bool create_flag=false);
int32_t set_cosmosroot(bool create_flag=false);
int32_t get_cosmosroot(string &result, bool create_flag=false);
string get_cosmosroot(bool create_flag=false);
int32_t set_cosmosresources(string name, bool create_flag);
int32_t set_cosmosresources(bool create_flag=false);
int32_t get_cosmosresources(string &result, bool create_flag=false);
string get_cosmosresources(bool create_flag=false);
int32_t setEnvCosmosResources(string path);
int32_t setEnvCosmosNodes(string path);
int32_t setEnv(string var, string path);
int32_t setEnvCosmos(string path);
int32_t set_cosmosnodes(string name, bool create_flag=false);
int32_t set_cosmosnodes(bool create_flag=false);
int32_t get_cosmosnodes(string &result, bool create_flag=false);
string get_cosmosnodes(bool create_flag=false);
string get_nodedir(string node, bool create_flag=false);
int32_t data_load_archive(string node, string agent, double utcbegin, double utcend, string type, vector<string> &result);
int32_t data_load_archive(string node, string agent, double mjd, string type, vector<string> &result);
int32_t data_load_archive(double mjd, vector<string> &telem, vector<string> &event, cosmosstruc* root);
double findlastday(string node);
double findfirstday(string node);
int32_t kml_write(cosmosstruc* cinfo);


#endif // DATALIB_H