TGo4HttpProxy.h

Go to the documentation of this file.

// $Id: TGo4HttpProxy.h 1692 2015-07-09 15:56:55Z linev $
//-----------------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//         Experiment Data Processing at EE department, GSI
//-----------------------------------------------------------------------
// Copyright (C) 2000- GSI Helmholtzzentrum für Schwerionenforschung GmbH
//                     Planckstr. 1, 64291 Darmstadt, Germany
// Contact:            http://go4.gsi.de
//-----------------------------------------------------------------------
// This software can be used under the license agreements as stated
// in Go4License.txt file which is part of the distribution.
//-----------------------------------------------------------------------

#ifndef TGO4HTTPPROXY_H
#define TGO4HTTPPROXY_H

#include "TGo4ServerProxy.h"

#include "TXMLEngine.h"

#include <QNetworkAccessManager>
#include <QNetworkReply>

class TGo4HttpProxy;
class TGo4HttpAccess;
class TGo4ObjectManager;

class QHttpProxy : public QObject {
   Q_OBJECT

   friend class TGo4HttpProxy;
   friend class TGo4HttpAccess;

   protected:
      QNetworkAccessManager qnam;  
      QNetworkReply *fHReply;      
      TGo4HttpProxy *fProxy;

   public slots:
      void httpFinished();
      void httpHReqError(QNetworkReply::NetworkError);
      void authenticationRequiredSlot(QNetworkReply*, QAuthenticator*);

      void updateRatemeter();
      void updateHierarchy();

      void regularRequestFinished();

   public:

      QHttpProxy(TGo4HttpProxy* p);
      virtual ~QHttpProxy();

      void StartRequest(const char* url);
};

// -----------------------------------------------------------------------------------

class TGo4HttpAccess : public QObject, public TGo4Access {

   Q_OBJECT

   protected:
      TGo4HttpProxy   *fProxy;
      XMLNodePointer_t fNode;
      TString          fUrlPath;
      // Request kind. Can be:
      //   0 - h.xml request,
      //   1 - root.bin request,
      //   2 - dabc get.xml request,
      //   3 - dabc get.xml history requests
      //   4 - parameter status request
      //   5 - sample tree
      //   6 - analysis status request
      Int_t            fKind;
      TString          fNameAttr;
      TString          fKindAttr;
      TString          fExtraArg;
      TGo4ObjectManager* fReceiver;
      TString          fRecvPath;
      QNetworkReply   *fReply;

   public slots:
      void httpFinished();
      void httpError(QNetworkReply::NetworkError);

   public:

      TGo4HttpAccess(TGo4HttpProxy* proxy, XMLNodePointer_t node, Int_t kind = 1, const char* extra_arg = 0);

      virtual ~TGo4HttpAccess() { }

      virtual Bool_t IsRemote() const { return kTRUE; }

      virtual Bool_t CanGetObject() const { return kFALSE; }

      virtual Bool_t GetObject(TObject* &obj, Bool_t &owner) const { return kFALSE; }

      virtual TClass* GetObjectClass() const;

      virtual const char* GetObjectName() const;

      virtual const char* GetObjectClassName() const;

      virtual Int_t AssignObjectTo(TGo4ObjectManager* rcv, const char* path);

};

// -----------------------------------------------------------------------------------

class TGo4HttpProxy : public TGo4ServerProxy  {

   friend class QHttpProxy;
   friend class TGo4HttpAccess;

   protected:
      TXMLEngine     *fXML;
      XMLDocPointer_t fxHierarchy;    
      QHttpProxy      fComm;          
      Int_t           fRateCnt;       
      Int_t           fStatusCnt;     
      Int_t           fDebugCnt;      
      Bool_t          fbAnalysisRunning; 
      TString         fUserName;      
      TString         fPassword;      
      Bool_t          fConnected;     
      QNetworkReply  *fRegularReq;    
      Int_t           fShutdownCnt;    

      void GetHReply(QByteArray& res);

      XMLNodePointer_t FindItem(const char* name, XMLNodePointer_t curr = 0) const;

      TString MakeUrlPath(XMLNodePointer_t item);

      void ProcessUpdateTimer();

      void ProcessRegularMultiRequest(Bool_t finished = kFALSE);

      Bool_t ServerHasRestrict();

      Bool_t ServerHasMulti();

      Bool_t SubmitURL(const char* path, Int_t waitres = -1);

      Bool_t PostObject(const char* prefix, TObject* obj, Int_t waitres = -1, Bool_t destroy_after = kTRUE);

      Bool_t CheckUserName(const char* expects, Bool_t dflt = kFALSE);

      Bool_t CheckShutdown(Bool_t force = kFALSE);

      TGo4HttpAccess* SubmitRequest(const char* itemname, Int_t kind, TGo4Slot* tgtslot, const char* extra_arg = 0);

   public:
      TGo4HttpProxy();
      virtual ~TGo4HttpProxy();

      void SetAccount(const char* username, const char* passwd);

      Bool_t Connect(const char* nodename);
      Bool_t UpdateHierarchy(Bool_t sync = kTRUE);

      virtual void Initialize(TGo4Slot* slot);
      virtual void Finalize(TGo4Slot* slot) {}

      virtual Bool_t HasSublevels() const;
      virtual TGo4Access* ProvideAccess(const char* name);
      virtual TGo4LevelIter* MakeIter();

      virtual Int_t GetObjectKind() {  return TGo4Access::kndFolder; }
      virtual const char* GetContainedClassName() { return ClassName(); }
      virtual TObject* GetAssignedObject() { return this; }
      virtual const char* GetContainedObjectInfo();
      virtual Int_t GetObjectSizeInfo() { return -1; }

      virtual void WriteData(TGo4Slot* slot, TDirectory* dir, Bool_t onlyobjs);
      virtual void ReadData(TGo4Slot* slot, TDirectory* dir);

      virtual void Update(TGo4Slot* slot, Bool_t strong);

      virtual TString FindCommand(const char* name);
      virtual Int_t  NumCommandArgs(const char* name);
      virtual Bool_t SubmitCommand(const char* name, Int_t waitres = -1, const char* arg1 = 0, const char* arg2 = 0, const char* arg3 = 0);

      virtual const char* GetUserName() const { return fUserName.Data(); }

      virtual Bool_t IsAnalysisServer() const { return kTRUE; }
      virtual Bool_t IsGo4Analysis() const;
      virtual Bool_t IsConnected() { return fConnected; }
      virtual Bool_t IsViewer()  { return CheckUserName("observer", kFALSE); }
      virtual Bool_t IsController()  { return CheckUserName("controller", kFALSE); }
      virtual Bool_t IsAdministrator()  { return CheckUserName("admin", kTRUE); }

      virtual Bool_t CanSubmitObjects();
      virtual void RequestAnalysisSettings();
      virtual void SubmitAnalysisSettings();
      virtual void CloseAnalysisSettings();

      virtual Bool_t NamesListReceived();
      virtual Bool_t RefreshNamesList();
      virtual Bool_t DelayedRefreshNamesList(Int_t delay_sec);

      virtual Bool_t IsAnalysisRunning() const { return fbAnalysisRunning; }
      virtual void StartAnalysis();
      virtual void StopAnalysis();

      virtual Bool_t RequestObjectStatus(const char* objectname, TGo4Slot* tgtslot);

      virtual Bool_t UpdateAnalysisObject(const char* objectname, TObject* obj);

      virtual void ClearAllAnalysisObjects();
      virtual void ClearAnalysisObject(const char* fullpath);

      virtual void RemoteTreeDraw(const char* treename,
                                  const char* varexp,
                                  const char* cutcond,
                                  const char* hname);

      virtual void RequestEventStatus(const char* evname, Bool_t astree, TGo4Slot* tgtslot);

      virtual void RemotePrintEvent(const char* evname,
                                    Int_t evnumber,
                                    Int_t subid,
                                    Bool_t ishex,
                                    Bool_t islong);

      virtual void ChageObjectProtection(const char* fullpath, const char* flags);

      virtual void RemoveObjectFromAnalysis(const char* fullpath);

      virtual void ExecuteLine(const char* line);

      virtual void PrintDynListEntry(const char* fullpath);

      virtual void LoadConfigFile(const char* fname);
      virtual void SaveConfigFile(const char* fname);

      virtual void WriteAutoSave(const char* fname,
                                 Int_t complevel,
                                 Bool_t overwrite);

      virtual void ResetDebugOutputRequests();

      virtual void DisconnectAnalysis(Int_t waittime = 30, Bool_t servershutdown = kFALSE);


};

#endif