source: ntrip/trunk/BNC/rinex/rnxobsfile.h@ 3716

// Part of BNC, a utility for retrieving decoding and
// converting GNSS data streams from NTRIP broadcasters.
//
// Copyright (C) 2007
// German Federal Agency for Cartography and Geodesy (BKG)
// http://www.bkg.bund.de
// Czech Technical University Prague, Department of Geodesy
// http://www.fsv.cvut.cz
//
// Email: euref-ip@bkg.bund.de
//
// 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, version 2.
//
// 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.

#ifndef RNXOBSFILE_H
#define RNXOBSFILE_H

#include <fstream>
#include <string>
#include <vector>
#include <map>

#include "newmat.h"
#include "bncconst.h"
#include "bnctime.h"

#define MAXPRN_GPS 32

class t_rnxObsFile {
 public:

  class t_rnxSat {
   public:
    char                satSys;
    int                 satNum;
    std::vector<double> obs;
    std::vector<int>    lli;
    std::vector<int>    snr;
  };

  class t_rnxEpo {
   public:
    void clear() {
      rnxSat.clear();
    }
    bncTime               tt;
    std::vector<t_rnxSat> rnxSat;
  };

  t_rnxObsFile(const std::string& fileName);
  ~t_rnxObsFile();
  
  float               version() const {return _header._version;}
  double              interval() const {return _header._interval;}
  int                 nTypes(char sys) const {return _header.nTypes(sys);}
  const std::string&  fileName() const {return _fileName;}
  const std::string&  obsType(char sys, int index) const {return _header.obsType(sys, index);}
  const std::string&  antennaName() const {return _header._antennaName;}
  const std::string&  markerName() const {return _header._markerName;}
  const ColumnVector& xyz() const {return _header._xyz;}
  const ColumnVector& antNEU() const {return _header._antNEU;}
  const ColumnVector& antXYZ() const {return _header._antXYZ;}
  const ColumnVector& antBSG() const {return _header._antBSG;}
  const t_rnxEpo*     nextEpoch(); 
  int wlFactorL1(unsigned iPrn) {
    return iPrn <= MAXPRN_GPS ? _header._wlFactorsL1[iPrn] : 1;
  }
  int wlFactorL2(unsigned iPrn) {
    return iPrn <= MAXPRN_GPS ? _header._wlFactorsL2[iPrn] : 1;
  }

 protected:
  t_rnxObsFile() {};
  void open(const std::string& fileName);
  void close();

 private: 
  class t_rnxObsHeader {
   public:
    t_rnxObsHeader();
    ~t_rnxObsHeader();

    t_irc               read(std::ifstream* stream, int maxLines = 0);
    int                 nTypes(char sys) const;
    const std::string&  obsType(char sys, int index) const;
 
    static const std::string                  _emptyStr;
    float                                     _version;
    double                                    _interval;
    std::string                               _antennaName;
    std::string                               _markerName;
    ColumnVector                              _antNEU;
    ColumnVector                              _antXYZ;
    ColumnVector                              _antBSG;
    ColumnVector                              _xyz;
    std::vector<std::string>                  _obsTypesV2;
    std::map<char, std::vector<std::string> > _obsTypesV3;
    int                                       _wlFactorsL1[MAXPRN_GPS+1];
    int                                       _wlFactorsL2[MAXPRN_GPS+1];
  };

  const t_rnxEpo* nextEpochV2();
  const t_rnxEpo* nextEpochV3();
  void handleEpochFlag(int flag, const std::string& line);

  std::string    _fileName;
  t_rnxObsHeader _header;
  std::ifstream* _stream;
  t_rnxEpo       _currEpo;
  bool           _flgPowerFail;
};

#endif