changeset 171:da7e915202c7 Orthanc-0.2.3-Paulus

quick and dirty access to raw tags
author Sebastien Jodogne <s.jodogne@gmail.com>
date Fri, 09 Nov 2012 13:45:36 +0100
parents cb8ce04d5708
children 68dae290d5fa
files OrthancServer/OrthancRestApi.cpp
diffstat 1 files changed, 142 insertions(+), 0 deletions(-) [+]
line wrap: on
line diff
--- a/OrthancServer/OrthancRestApi.cpp	Fri Nov 09 12:15:47 2012 +0100
+++ b/OrthancServer/OrthancRestApi.cpp	Fri Nov 09 13:45:36 2012 +0100
@@ -35,10 +35,12 @@
 #include "OrthancInitialization.h"
 #include "FromDcmtkBridge.h"
 #include "../Core/Uuid.h"
+#include "../Core/DicomFormat/DicomArray.h"
 
 #include <dcmtk/dcmdata/dcistrmb.h>
 #include <dcmtk/dcmdata/dcfilefo.h>
 #include <boost/lexical_cast.hpp>
+#include <glog/logging.h>
 
 namespace Orthanc
 {
@@ -115,6 +117,124 @@
   }
 
 
+  static bool GetTagContent(HttpOutput& output,
+                            const FileStorage& storage,
+                            const std::string& fileUuid,
+                            const UriComponents& uri)
+  {
+    // TODO: Implement a true caching mechanism!
+    static boost::mutex mutex_;
+    static std::string lastFileUuid_;
+    static DcmFileFormat dicomFile_;
+
+    boost::mutex::scoped_lock lock(mutex_);
+
+    if (fileUuid != lastFileUuid_)
+    {
+      LOG(INFO) << "Parsing file " << fileUuid;
+      std::string content;
+      storage.ReadFile(content, fileUuid);
+
+      DcmInputBufferStream is;
+      if (content.size() > 0)
+      {
+        is.setBuffer(&content[0], content.size());
+      }
+      is.setEos();
+
+      if (!dicomFile_.read(is).good())
+      {
+        return false;
+      }
+ 
+      lastFileUuid_ = fileUuid;
+    }
+    else
+    {
+      LOG(INFO) << "Already parsed file " << fileUuid;
+    }
+
+    if (uri.size() == 3)
+    {
+      DicomMap dicomSummary;
+      FromDcmtkBridge::Convert(dicomSummary, *dicomFile_.getDataset());
+
+      DicomArray a(dicomSummary);
+    
+      Json::Value target = Json::arrayValue;
+      for (size_t i = 0; i < a.GetSize(); i++)
+      {
+        char b[16];
+        sprintf(b, "%04x-%04x", a.GetElement(i).GetTagGroup(),
+                a.GetElement(i).GetTagElement());
+        target.append(b);
+      }
+
+      SendJson(output, target);
+      return true;
+    }
+
+    if (uri.size() == 4)
+    {
+      if (uri[3].size() != 9 ||
+          uri[3][4] != '-')
+      {
+        return false;
+      }
+      
+      unsigned int group, element;
+      if (sscanf(uri[3].c_str(), "%04x-%04x", &group, &element) != 2)
+      {
+        return false;
+      }
+
+      DcmTagKey tag(group, element);
+      DcmElement* item = NULL;
+
+      if (dicomFile_.getDataset()->findAndGetElement(tag, item).good() && 
+          item != NULL)
+      {
+        std::string buffer;
+        buffer.resize(65536);
+        Uint32 length = item->getLength();
+        Uint32 offset = 0;
+
+        while (offset < length)
+        {
+          Uint32 nbytes;
+          if (length - offset < buffer.size())
+          {
+            nbytes = length - offset;
+          }
+          else
+          {
+            nbytes = buffer.size();
+          }
+
+          output.SendOkHeader("application/octet-stream");
+          if (item->getPartialValue(&buffer[0], offset, nbytes).good())
+          {
+            output.Send(&buffer[0], nbytes);
+            offset += nbytes;
+          }
+          else
+          {
+            return true;
+          }
+        }
+
+        return true;
+      }
+      else
+      {
+        return false;
+      }
+    }
+
+    return false;
+  }
+
+
   bool OrthancRestApi::Store(Json::Value& result,
                                const std::string& postData)
   {
@@ -628,6 +748,28 @@
     }
 
 
+    else if (uri.size() >= 3 &&
+             uri[0] == "instances" &&
+             uri[2] == "content")
+    {
+      Json::Value instance(Json::objectValue);
+      std::string fileUuid;
+      existingResource = index_.GetDicomFile(fileUuid, uri[1]);
+
+      if (existingResource)
+      {
+        if (GetTagContent(output, storage_, fileUuid, uri))
+        {
+          return;
+        }
+        else
+        {
+          existingResource = false;
+        }
+      }
+    }
+
+
     else if (uri[0] == "instances" &&
              ((uri.size() == 3 &&
                (uri[2] == "preview" ||