Source: public/javascript/modules/serverApi.js

  2. import { DOMAccessor } from "./domelements.js";
  3. import { FITS_HEADER } from './fitsheader.js';
  4. import { URL_SPECTRO_SERVER } from './init.js';
  7. /**
  8.  * Object querying the spectroscopy service
  9.  */
  10.  class SpectroApi {
  11.     constructor() {
  12.         // service endpoint
  13.         this.server = URL_SPECTRO_SERVER;
  14.         // will contain result of getMetadata for caching
  15.         this.metadata = null;
  16.         this.getTransitions = this.getTransitions.bind(this);
  17.         this.getMetadata = this.getMetadata.bind(this);
  18.     }
  20.     /**
  21.      * Get a list of transitions
  22.      * @param {string} db           selected database
  23.      * @param {array} frequencies   min/max frequencies
  24.      * @param {array} atomcount     min/max number of atoms
  25.      * @param {number} energyup      maximum value of upper energy (float)
  26.      * @param {array} species       list of species
  27.      * @param {number} intensity     maximum intensity value (float)
  28.      * @param {function} callback   callback function called on found transitions
  29.      */
  30.     getTransitions(db, frequencies, atomcount, energyup, species, intensity, callback) {
  31.         let criteria = {
  32.             "frequencies": frequencies,
  33.             "atomcount": atomcount,
  34.             "energyup": energyup,
  35.             "species": species,
  36.             "idealisedintensity": intensity,
  37.             "sourcefiles": undefined
  38.         };
  39.         $.ajax({
  40.             method: "POST",
  41.             url: this.server + "/spectroscopy/" + db + "/lines",
  42.             data: JSON.stringify(criteria),
  43.             contentType: "application/json",
  44.             crossDomain: true
  45.         })
  46.             .done(function (transitions) {
  47.                 callback(transitions);
  48.             }).fail(function (jqXHR, textStatus) {
  49.                 console.log("error");
  50.                 console.log(jqXHR);
  51.             });
  52.     }
  54.     /**
  55.      * Get a complete dataset with all its transitions
  56.      * @param {string} db            name of selected database
  57.      * @param {string} sourcefile    data file name in source database
  58.      * @param {function} callback      callback function called on returned transitions
  59.      */
  60.     getDataset(db, sourcefile, callback) {
  61.         let criteria = {
  62.             "sourcefile": sourcefile
  63.         };
  64.         $.ajax({
  65.             method: "POST",
  66.             url: this.server + "/spectroscopy/" + db + "/dataset",
  67.             data: JSON.stringify(criteria),
  68.             contentType: "application/json",
  69.             /*crossDomain : true*/
  70.         })
  71.             .done(function (transitions) {
  72.                 callback(transitions);
  73.             }).fail(function (jqXHR, textStatus) {
  74.                 console.log("error");
  75.                 console.log(jqXHR);
  76.             });
  77.     }
  79.     /**
  80.      * Get metadata from spectroscopy database ( species by source database )
  81.      * @param {function} callback function applied to returned data
  82.      */
  83.     getMetadata(callback) {
  84.         let self = this;
  85.         // no ajax request if metadata already available
  86.         if (this.metadata === null) {
  87.             $.ajax({
  88.                 method: "GET",
  89.                 url: this.server + "/metadata",
  90.                 contentType: "application/json",
  91.                 /*crossDomain : true*/
  92.             })
  93.                 .done(function (metadata) {
  94.                     self.metadata = metadata;
  95.                     callback(metadata);
  96.                 }).fail(function (jqXHR, textStatus) {
  97.                     console.log("error");
  98.                     console.log(jqXHR);
  99.                 });
  100.         }
  101.         // performs callback on cached data
  102.         else {
  103.             callback(this.metadata);
  104.         }
  105.     }
  107.     /**
  108.      * Get status of dbs from spectroscopy database
  109.      * @param {function} callback function applied to returned data
  110.      */
  111.     getStatuses(callback) {
  112.         // no ajax request if metadata already available
  113.         if (this.metadata === null) {
  114.             $.ajax({
  115.                 method: "GET",
  116.                 url: this.server + "/spectroscopy/databases/status",
  117.                 contentType: "application/json",
  118.                 /*crossDomain : true*/
  119.             })
  120.                 .done(function (results) {
  121.                     callback(results);
  122.                 }).fail(function (jqXHR, textStatus) {
  123.                     console.log("error");
  124.                     console.log(jqXHR);
  125.                 });
  126.         }
  127.         // performs callback on cached data
  128.         else {
  129.             callback(this.metadata);
  130.         }
  131.     }
  133. }
  135. /**
  136.  * Access to Yafitss service
  137.  */
  138.  class ServerApi{
  140.     getRADECRangeInDegrees(relFITSFilePath, processResult){
  141.         //DOMAccessor.showLoaderAction(true);
  142.         return $.post("", {
  143.             "method": "RADECRangeInDegrees",
  144.             "relFITSFilePath": relFITSFilePath,
  145.             "sessionID": 0
  146.         }).done(function(resp) {
  147.             console.log('$.post("", {"method": "RADECRangeInDegrees", "relFITSFilePath": dataPaths.relFITSFilePath}).done(function (resp) { : entering');
  148.             processResult(resp);
  149.             //DOMAccessor.showLoaderAction(false);
  150.             console.log('$.post("", {"method": "RADECRangeInDegrees", "relFITSFilePath": dataPaths.relFITSFilePath}).done(function(resp) {: exiting');
  151.         });
  152.     }
  154.     getPixelValue(relFITSFilePath, iRA, iDEC, processResult){
  155.         DOMAccessor.showLoaderAction(true);
  156.         return $.get("getPixelValueAtiRAiDEC", {relFITSFilePath: relFITSFilePath, iRA: iRA, iDEC : iDEC}).done((resp)=>{
  157.             if (resp["status"] == false) {
  158.                 // user probably clicked in an area outside the image, we log but don't show
  159.                 console.log(resp["message"]);
  160.             } else {
  161.                 processResult(resp);
  162.             }
  163.             DOMAccessor.showLoaderAction(false);
  164.         });
  165.     }
  167.     getPixelFreqValue(relFITSFilePath, iRA, iDEC, iFREQ, processResult){
  168.         DOMAccessor.showLoaderAction(true);
  169.         return $.get("getPixelValueAtiFreqiRAiDEC", {relFITSFilePath: relFITSFilePath, iRA: iRA, iDEC: iDEC, iFREQ: iFREQ}).done((resp)=>{
  170.             if (resp["status"] == false) {
  171.                 // user probably clicked in an area outside the image, we log but don't show
  172.                 console.log(resp["message"]);
  173.             } else {
  174.                 processResult(resp);
  175.             }
  176.             DOMAccessor.showLoaderAction(false);
  177.         });
  178.     }
  180.     getSingleSpectrum(iRA, iDEC, relFITSFilePath, processResult){
  181.         // get spectrum
  182.         return $.post("", {
  183.             "method": "getSpectrum",
  184.             "relFITSFilePath": relFITSFilePath,
  185.             "iRA": iRA,
  186.             "iDEC": iDEC,
  187.             "iFREQ0": 0,
  188.             "iFREQ1": FITS_HEADER.naxis3 - 1
  189.         }, null, "json").done(
  190.             /*
  191.              ** This is the function which actually performs the plot as a callback on
  192.              ** return from a call to the FITS file server in order to get the spectrum to draw.
  193.              */
  194.             (resp) => {
  195.                 if (resp.data["status"] == false) {
  196.                     // an error occurred
  197.                     if (resp.data["message"] !== "IndexError") {
  198.                         console.log("getSpectrum callback error : " + resp.data["message"]);
  199.                         alert(resp.data["message"]);
  200.                         return;
  201.                     }
  202.                     // there was nothing at given corrdinates
  203.                     else {
  204.                         console.log("getSpectrum callback error : nothing at given coordinates");
  205.                         return;
  206.                     }
  207.                 }
  208.                 processResult(resp);
  209.                 DOMAccessor.showLoaderAction(false);
  210.             }
  211.         ).fail(function(jqXHR, textStatus, errorThrown){
  212.             console.log(errorThrown);
  213.             DOMAccessor.markLoadingDone();
  214.     });
  215.     }
  217.     getSummedSpectrum(iRA0, iRA1, iDEC0, iDEC1, relFITSFilePath, processResult){
  218.         DOMAccessor.showLoaderAction(true);
  219.         return $.post("", {
  220.             "method": "getAverageSpectrum",
  221.             "relFITSFilePath": relFITSFilePath,
  222.             "iRA0": iRA0,
  223.             "iRA1": iRA1,
  224.             "iDEC0": iDEC0,
  225.             "iDEC1": iDEC1
  226.         }).done((resp) => {
  227.             if (resp["status"] == false) {
  228.                 alert(`Something went wrong with the calculation of the average spectrum. The message was '${resp["message"]}'`);
  229.             } else {
  230.                 processResult(resp);
  231.             }
  232.             DOMAccessor.showLoaderAction(false);
  233.         });
  234.     }
  236.     getSingleSlice(sliceIndex, relFITSFilePath, ittName, lutName, vmName, processResult){
  237.         DOMAccessor.showLoaderAction(true);
  238.         return $.post('png', {
  239.             'si': sliceIndex,
  240.             'relFITSFilePath': relFITSFilePath,
  241.             'ittName': ittName,
  242.             'lutName': lutName,
  243.             'vmName': vmName
  244.         }).done(
  245.             function (resp) {
  246.                 console.log("$.post('/png', {'si': sliceIndex, 'relFITSFilePath': _relFITSFilePath}).done(: entering");
  247.                 if (resp["status"] == false) {
  248.                     alert("Something went wrong during the generation of the image. The message was '" +
  249.                         resp["message"] + "'");
  250.                 } else if (resp["result"] === undefined) {
  251.                     alert("No data available in this channel");
  252.                 } else {
  253.                     processResult(resp);
  254.                 }
  255.                 DOMAccessor.showLoaderAction(false);
  256.                 console.log("$.post('/png', {'si': sliceIndex, 'path': _path}).done(: exiting");
  257.             }
  258.         )
  259.     }
  261.     getSummedSlice(sliceIndex0, sliceIndex1, relFITSFilePath, ittName, lutName, vmName, processResult){
  262.         DOMAccessor.showLoaderAction(true);
  263.         return $.post('sumpng', {
  264.             'si0': sliceIndex0,
  265.             'si1': sliceIndex1,
  266.             'relFITSFilePath': relFITSFilePath,
  267.             'ittName': ittName,
  268.             'lutName': lutName,
  269.             'vmName': vmName
  270.         }).done(
  271.             function (resp) {
  272.                 console.log(` $.post('/sumpng', {'si0': ${sliceIndex0}, 'si1': ${sliceIndex1}, 'relFITSFilePath': ${self._relFITSFilePath}}).done() : entering`);
  273.                 console.log("in _updateSummedSlicesWithPOST");
  275.                 if (resp["status"] == false) {
  276.                     alert("Something went wrong during the generation of the image. The message was " +
  277.                         resp["message"] + "'");
  278.                 } else if (resp["result"] === undefined) {
  279.                     alert("No data available in this channel");
  280.                 } else {
  281.                     processResult(resp);
  282.                 }
  284.                 DOMAccessor.showLoaderAction(false);
  285.                 console.log("$.post('/sumpng', {'si0': sliceIndex0, 'si1': sliceIndex1, 'relFITSFilePath': relFITSFilePath}).done() : exiting");
  286.             });
  287.     }
  289.     getSummedSliceValueAtPixel(iRA, iDEC, iFREQ0, iFREQ1, relFITSFilePath, processResult){
  290.         return $.post("", {
  291.             "method": "getAverage",
  292.             "relFITSFilePath": relFITSFilePath,
  293.             "iRA0": iRA,
  294.             "iRA1": iRA,
  295.             "iDEC0": iDEC,
  296.             "iDEC1": iDEC,
  297.             "iFREQ0": iFREQ0,
  298.             "iFREQ1": iFREQ1,
  299.             "retFITS": false
  300.         }).done(
  301.             (resp) => {
  302.                 processResult(resp);
  303.             }
  304.         ).fail(
  305.             function (err) {
  306.                 var msg = "POST failed" + JSON.stringify(err, 0, 4);
  307.                 alert(msg);
  308.             });
  309.     }
  311.     getFITSSliceImage(sliceIndex, relFITSFilePath, processResult){
  312.         return $.post("", {
  313.             "method": "createFITSSliceImage",
  314.             "relFITSFilePath": relFITSFilePath,
  315.             "iFREQ": sliceIndex
  316.             }).done(
  317.                 function (resp) {
  318.                     console.log("A FITS file has been created for the upper image.");
  319.                     let x = JSON.parse(resp);
  320.                     if (!x["status"]) {
  321.                         console.log(`Something went wrong during the generation of the image FITS file, the message was
  322.                         ${x["message"]}`);
  323.                         alert(x["message"]);
  324.                         processResult(x);
  325.                     }
  326.                 }
  327.             ).fail(
  328.                 function (err) {
  329.                     let msg = "POST failed" + JSON.stringify(err, 0, 4);
  330.                     console.log(msg);
  331.                     alert(msg);
  332.                 }
  333.             );
  334.     }
  336.     getSummedFITSSliceImage(sliceIndex0, sliceIndex1, relFITSFilePath, processResult){
  337.         return $.post("", {
  338.             "method": "createFITSSumSliceImage",
  339.             "relFITSFilePath": relFITSFilePath,
  340.             "iFREQ0": sliceIndex0,
  341.             "iFREQ1": sliceIndex1
  342.         }).done(
  343.             function (resp) {
  344.                 console.log("A FITS file has been created for the bottom image." + resp);
  345.                 let x = JSON.parse(resp);
  346.                 if (!x["status"]) {
  347.                     console.log(`Something went wrong during the generation of the bottom image FITS file, the message was
  348.                     ${x["message"]}`);
  349.                     alert(x["message"]);
  350.                     processResult(x);
  351.                 }
  352.             }
  353.         ).fail(
  354.             function (err) {
  355.                 let msg = "POST failed" + JSON.stringify(err, 0, 4);
  356.                 console.log(msg);
  357.                 alert(msg);
  358.             }
  359.         );
  360.     }
  362.     createFitsFile(iRA, iDEC, relFITSFilePath, processResult){
  363.         return $.post("", {
  364.             "method": "createFits",
  365.             "relFITSFilePath": relFITSFilePath,
  366.             "iRA": iRA,
  367.             "iDEC": iDEC
  368.         })
  369.         .done(
  370.             function (resp) {
  371.                 if (resp["status"] !== false) {
  372.                     processResult(resp);
  373.                     //dataPaths.spectrum = x["result"];
  374.                 } else {
  375.                     console.log(`Something went wrong during the generation of 
  376.                     the spectrum FITS file, the message was ${resp["message"]}`);
  377.                     alert(resp["message"]);
  378.                 }
  379.             }
  380.         )
  381.         .fail(
  382.             function (err) {
  383.                 var msg = "POST failed" + JSON.stringify(err, 0, 4);
  384.                 console.log(msg);
  385.                 alert(msg);
  386.             }
  387.         );
  388.     }
  390.     measureBox(iRA0, iRA1, iDEC0, iDEC1, iFREQ, relFITSFilePath, processResult){
  391.         return $.post("measureBox", {
  392.             'relFITSFilePath': relFITSFilePath,
  393.             'iFREQ': iFREQ,
  394.             'iRA0': iRA0,
  395.             'iRA1': iRA1,
  396.             'iDEC0': iDEC0,
  397.             'iDEC1': iDEC1
  398.         },
  399.             (resp) => {
  400.                 DOMAccessor.showLoaderAction(true);
  401.                 if (resp["status"] == false) {
  402.                     alert(`Something went wrong with the measurements of the box [[${iRA0}, ${iDEC0}], [${iRA1},${iDEC1}]]. The message was '${resp["message"]}'`);
  403.                 }
  404.                 else {
  405.                     processResult(resp);
  406.                 }
  407.                 DOMAccessor.showLoaderAction(false);
  408.             });
  409.     }
  411.     getContours(postParams, processResult){
  412.         return $.post('getContours', postParams,
  413.         (resp) => {
  414.             DOMAccessor.showLoaderAction(false);
  415.             if (resp["status"] == false) {
  416.                 reject(`Error 2 : Something went wrong during the generation of the contours. The message was '${resp["message"]}'`);
  417.             }
  418.             else {
  419.                 processResult(resp);
  420.             }
  421.         });
  422.     }   
  423.     
  425.     measureContours(iFREQ, contour, level, relFITSFilePath, processResult){
  426.         DOMAccessor.showLoaderAction(true);
  427.         return $.post('measureContour', { 'relFITSFilePath': relFITSFilePath, 'iFREQ': iFREQ, 'contour': contour, 'level': level },
  428.         (resp) => {
  429.             DOMAccessor.showLoaderAction(false);
  430.             processResult(resp);
  431.         });        
  432.     }
  434.     createSmoothCube(nbox, relFITSFilePath, processResult){
  435.         return $.post("", {
  436.             "method": "createSmoothCube",
  437.             "relFITSFilePath": relFITSFilePath,
  438.             "nbox": nbox
  439.         }).done(
  440.             function (resp) {
  441.                 console.log("A FITS file has been created for the smoothCube." + resp);
  442.                 processResult(resp);
  443.             }
  444.         ).fail(
  445.             function (err) {
  446.                 var msg = "POST failed" + JSON.stringify(err, 0, 4);
  447.                 console.log(msg);
  448.                 alert(msg);
  449.             }
  450.         );
  451.     }
  452. }
  454. export{
  455.     ServerApi,
  456.     SpectroApi
  457. }