diff OrthancServer/main.cpp @ 3636:bce6ee64f2a4 storage-commitment

reorganization
author Sebastien Jodogne <s.jodogne@gmail.com>
date Fri, 31 Jan 2020 14:29:35 +0100
parents 8c0ef729d5a8
children f6a73611ec5c
line wrap: on
line diff
--- a/OrthancServer/main.cpp	Wed Jan 29 17:39:31 2020 +0100
+++ b/OrthancServer/main.cpp	Fri Jan 31 14:29:35 2020 +0100
@@ -50,6 +50,7 @@
 #include "OrthancInitialization.h"
 #include "OrthancMoveRequestHandler.h"
 #include "ServerContext.h"
+#include "ServerJobs/StorageCommitmentScpJob.h"
 #include "ServerToolbox.h"
 
 using namespace Orthanc;
@@ -91,227 +92,6 @@
 
 
 
-namespace Orthanc
-{
-  class StorageCommitmentScpJob : public SetOfCommandsJob
-  {
-  private:
-    class LookupCommand : public SetOfCommandsJob::ICommand
-    {
-    private:
-      StorageCommitmentScpJob&  that_;
-      std::string               sopClassUid_;
-      std::string               sopInstanceUid_;
-
-    public:
-      LookupCommand(StorageCommitmentScpJob& that,
-                    const std::string& sopClassUid,
-                    const std::string& sopInstanceUid) :
-        that_(that),
-        sopClassUid_(sopClassUid),
-        sopInstanceUid_(sopInstanceUid)
-      {
-      }
-
-      virtual bool Execute()
-      {
-        that_.LookupInstance(sopClassUid_, sopInstanceUid_);
-        return true;
-      }
-
-      virtual void Serialize(Json::Value& target) const
-      {
-        target = Json::objectValue;
-        target["Type"] = "Lookup";
-        target["SopClassUid"] = sopClassUid_;
-        target["SopInstanceUid"] = sopInstanceUid_;
-      }
-    };
-    
-    class AnswerCommand : public SetOfCommandsJob::ICommand
-    {
-    private:
-      StorageCommitmentScpJob&  that_;
-
-    public:
-      AnswerCommand(StorageCommitmentScpJob& that) :
-        that_(that)
-      {
-      }
-
-      virtual bool Execute()
-      {
-        that_.Answer();
-        return true;
-      }
-
-      virtual void Serialize(Json::Value& target) const
-      {
-        target = Json::objectValue;
-        target["Type"] = "Answer";
-      }
-    };
-    
-    class Unserializer : public SetOfCommandsJob::ICommandUnserializer
-    {
-    private:
-      StorageCommitmentScpJob&   that_;
-
-    public:
-      Unserializer(StorageCommitmentScpJob&  that) :
-        that_(that)
-      {
-      }
-
-      virtual ICommand* Unserialize(const Json::Value& source) const
-      {
-        std::cout << "===================================\n";
-        std::cout << source.toStyledString();
-        
-        /*DicomMap findAnswer;
-        findAnswer.Unserialize(source);
-        return new Command(that_, findAnswer);*/
-
-        throw OrthancException(ErrorCode_NotImplemented);
-      }
-    };
-
-    ServerContext&            context_;
-    bool                      ready_;
-    std::string               transactionUid_;
-    RemoteModalityParameters  remoteModality_;
-    std::string               calledAet_;
-    std::list<std::string>    successSopClassUids_;
-    std::list<std::string>    successSopInstanceUids_;
-    std::list<std::string>    failedSopClassUids_;
-    std::list<std::string>    failedSopInstanceUids_;
-
-    void LookupInstance(const std::string& sopClassUid,
-                        const std::string& sopInstanceUid)
-    {
-      bool success = false;
-      
-      try
-      {
-        std::vector<std::string> orthancId;
-        context_.GetIndex().LookupIdentifierExact(orthancId, ResourceType_Instance, DICOM_TAG_SOP_INSTANCE_UID, sopInstanceUid);
-
-        if (orthancId.size() == 1)
-        {
-          std::string a, b;
-          
-          ServerContext::DicomCacheLocker locker(context_, orthancId[0]);
-          if (locker.GetDicom().GetTagValue(a, DICOM_TAG_SOP_CLASS_UID) &&
-              locker.GetDicom().GetTagValue(b, DICOM_TAG_SOP_INSTANCE_UID) &&
-              a == sopClassUid &&
-              b == sopInstanceUid)
-          {
-            success = true;
-          }
-        }
-      }
-      catch (OrthancException&)
-      {
-      }
-
-      LOG(INFO) << "  Storage commitment SCP job: " << (success ? "Success" : "Failure")
-                << " while looking for " << sopClassUid << " / " << sopInstanceUid;
-
-      if (success)
-      {
-        successSopClassUids_.push_back(sopClassUid);
-        successSopInstanceUids_.push_back(sopInstanceUid);
-      }
-      else
-      {
-        failedSopClassUids_.push_back(sopClassUid);
-        failedSopInstanceUids_.push_back(sopInstanceUid);
-      }
-    }
-
-    void Answer()
-    {
-      LOG(INFO) << "  Storage commitment SCP job: Sending answer";
-      
-      DicomUserConnection scu(calledAet_, remoteModality_);
-      scu.ReportStorageCommitment(transactionUid_, successSopClassUids_, successSopInstanceUids_,
-                                  failedSopClassUids_, failedSopInstanceUids_);
-
-      /**
-       * "After the N-EVENT-REPORT has been sent, the Transaction UID is
-       * no longer active and shall not be reused for other
-       * transactions."
-       * http://dicom.nema.org/medical/dicom/2019a/output/chtml/part04/sect_J.3.3.html
-       **/
-    }
-    
-  public:
-    StorageCommitmentScpJob(ServerContext& context,
-                            const std::string& transactionUid,
-                            const std::string& remoteAet,
-                            const std::string& calledAet) :
-      context_(context),
-      ready_(false),
-      transactionUid_(transactionUid),
-      calledAet_(calledAet)
-    {
-      {
-        OrthancConfiguration::ReaderLock lock;
-        if (!lock.GetConfiguration().LookupDicomModalityUsingAETitle(remoteModality_, remoteAet))
-        {
-          throw OrthancException(ErrorCode_InexistentItem,
-                                 "Unknown remote modality for storage commitment SCP: " + remoteAet);
-        }
-      }
-    }
-
-    void AddInstance(const std::string& sopClassUid,
-                     const std::string& sopInstanceUid)
-    {
-      if (ready_)
-      {
-        throw OrthancException(ErrorCode_BadSequenceOfCalls);
-      }
-      else
-      {
-        AddCommand(new LookupCommand(*this, sopClassUid, sopInstanceUid));        
-      }
-    }
-
-    void MarkAsReady()
-    {
-      if (ready_)
-      {
-        throw OrthancException(ErrorCode_BadSequenceOfCalls);
-      }
-      else
-      {
-        AddCommand(new AnswerCommand(*this));
-        ready_ = true;
-      }
-    }
-
-    virtual void Stop(JobStopReason reason)
-    {
-    }
-
-    virtual void GetJobType(std::string& target)
-    {
-      target = "StorageCommitmentScp";
-    }
-
-    virtual void GetPublicContent(Json::Value& value)
-    {
-      SetOfCommandsJob::GetPublicContent(value);
-      
-      value["LocalAet"] = calledAet_;
-      value["RemoteAet"] = remoteModality_.GetApplicationEntityTitle();
-      value["TransactionUid"] = transactionUid_;
-    }
-  };
-}
-
-
 class OrthancStorageCommitmentRequestHandler : public IStorageCommitmentRequestHandler
 {
 private:
@@ -358,6 +138,13 @@
                             const std::string& calledAet)
   {
     printf("HANDLE REPORT\n");
+
+    /**
+     * "After the N-EVENT-REPORT has been sent, the Transaction UID is
+     * no longer active and shall not be reused for other
+     * transactions."
+     * http://dicom.nema.org/medical/dicom/2019a/output/chtml/part04/sect_J.3.3.html
+     **/
   }
 };