ohif-viewer/Packages/ohif-dicom-services/server/DICOMWeb/getJSON.js

111 lines
3.0 KiB
JavaScript

import { Meteor } from 'meteor/meteor';
import { OHIF } from 'meteor/ohif:core';
const http = Npm.require('http');
const https = Npm.require('https');
const url = Npm.require('url');
function makeRequest(geturl, options, callback) {
const parsed = url.parse(geturl);
const jsonHeaders = ['application/json', 'application/dicom+json'];
let requestOpt = {
hostname: parsed.hostname,
headers: {
Accept: 'application/json'
},
path: parsed.path,
method: 'GET'
};
let requester;
if (parsed.protocol === 'https:') {
requester = https.request;
const allowUnauthorizedAgent = new https.Agent({ rejectUnauthorized: false });
requestOpt.agent = allowUnauthorizedAgent;
} else {
requester = http.request;
}
if (parsed.port) {
requestOpt.port = parsed.port;
}
if (options.auth) {
requestOpt.auth = options.auth;
}
if (options.headers) {
Object.keys(options.headers).forEach(key => {
const value = options.headers[key];
requestOpt.headers[key] = value;
});
}
const req = requester(requestOpt, function(resp) {
// TODO: handle errors with 400+ code
const contentType = (resp.headers['content-type'] || '').split(';')[0];
if (jsonHeaders.indexOf(contentType) === -1) {
const errorMessage = `We only support json but "${contentType}" was sent by the server`;
callback(new Error(errorMessage), null);
return;
}
let output = '';
resp.setEncoding('utf8');
resp.on('data', function(chunk){
output += chunk;
});
resp.on('error', function (responseError) {
OHIF.log.error('There was an error in the DICOMWeb Server')
OHIF.log.error(error.stack);
OHIF.log.trace();
callback(new Meteor.Error('server-internal-error', responseError.message), null);
});
resp.on('end', function(){
callback(null, { data: JSON.parse(output) });
});
});
req.on('error', function (requestError) {
OHIF.log.error('Couldn\'t connect to DICOMWeb server.');
OHIF.log.error('Make sure you are trying to connect to the right server and that it is up and running.');
OHIF.log.error(requestError.stack);
OHIF.log.trace();
callback(new Meteor.Error('server-connection-error', requestError.message), null);
});
req.end();
}
const makeRequestSync = Meteor.wrapAsync(makeRequest);
DICOMWeb.getJSON = function(geturl, options) {
if (options && options.logRequests) {
OHIF.log.info(geturl);
}
if (options && options.logTiming) {
console.time(geturl);
}
const result = makeRequestSync(geturl, options);
if (options && options.logTiming) {
console.timeEnd(geturl);
}
if (options && options.logResponses) {
OHIF.log.info(result);
}
return result;
};