src/Cqm/CqmClient.php

   1 <?php
   2
   3 namespace OpenEMR\Cqm;
   4
   5 use Exception;
   6 use GuzzleHttp\Client;
   7 use OpenEMR\Common\Http\HttpClient;
   8 use OpenEMR\Common\System\System;
   9 use Psr\Http\Message\ResponseInterface;
  10 use Psr\Http\Message\StreamInterface;
  11 use GuzzleHttp\Psr7\Utils;
  12 use GuzzleHttp\Exception\ConnectException;
  13 use GuzzleHttp\Exception\ServerException;
  14
  15 use function GuzzleHttp\Psr7\str;
  16
  17 /**
  18  * Class CqmClient
  19  *
  20  * @package OpenEMR\Cqm
  21  * @author Ken Chapple
  22  */
  23 class CqmClient extends HttpClient
  24 {
  25     protected function getCommand(): string
  26     {
  27         $port = $this->port;
  28
  29         $node = 'node';
  30         $cmd = $this->servicePath;
  31
  32         if (IS_WINDOWS) {
  33             $cmd = "start /B $node $cmd";
  34             return $cmd;
  35         } else {
  36             $command = $node;
  37             $system = new System();
  38             if (!$system->command_exists($node)) {
  39                 if ($system->command_exists('nodejs')) {
  40                     $command = 'nodejs';
  41                 } else {
  42                     error_log("Connection failed. Node does not appear to be installed on the system.");
  43                     throw new Exception('Connection Failed.');
  44                 }
  45             }
  46             $node = $command;
  47         }
  48
  49         return "$node $cmd";
  50     }
  51
  52     /**
  53      * Returns the CQM service's health.
  54      *
  55      * @return array
  56      * @throws \GuzzleHttp\Exception\GuzzleException
  57      */
  58     public function getHealth(): array
  59     {
  60         try {
  61             return json_decode(
  62                 Utils::copyToString($this->request('GET', '/health')->getBody()),
  63                 true
  64             );
  65         } catch (ConnectException $exception) {
  66             return [
  67                 'uptime' => 0
  68             ];
  69         } catch (ServerException $exception) {
  70             return [
  71                 'uptime' => 0
  72             ];
  73         }
  74     }
  75
  76     /**
  77      * Returns CQM Service version and dependencies lookup.
  78      *
  79      * @return array
  80      * @throws \GuzzleHttp\Exception\GuzzleException
  81      */
  82     public function getVersion(): array
  83     {
  84         return json_decode(
  85             Utils::copyToString($this->request('GET', '/version')->getBody()),
  86             true
  87         );
  88     }
  89
  90     /**
  91      * Calculates a CQM measure given a QDM Patient, Measure and ValueSet
  92      *
  93      * @param StreamInterface $patients
  94      * @param StreamInterface $measure
  95      * @param StreamInterface $valueSets
  96      * @return StreamInterface
  97      * @throws \GuzzleHttp\Exception\GuzzleException
  98      */
  99     public function calculate(
 100         StreamInterface $patients,
 101         StreamInterface $measure,
 102         StreamInterface $valueSets,
 103         StreamInterface $options = null
 104     ) {
 105         $patients = (string)str_replace(["\r\n", "\n", "\r"], '', (string)$patients);
 106         $measure = (string)str_replace(["\r\n", "\n", "\r"], '', (string)$measure);
 107         $valueSets = (string)str_replace(["\r\n", "\n", "\r"], '', (string)$valueSets);
 108         $options = (string)$options;
 109         try {
 110             return json_decode(
 111                 Utils::copyToString(
 112                     $this->request('POST', '/calculate', [
 113                         'form_params' => [
 114                             'patients' => $patients,
 115                             'measure' => $measure,
 116                             'valueSets' => $valueSets,
 117                             'options' => $options
 118                         ]])->getBody()
 119                 ),
 120                 true
 121             );
 122         } catch (ConnectException $exception) {
 123             return [$exception->getMessage()];
 124         } catch (ServerException $exception) {
 125             return [$exception->getMessage()];
 126         }
 127     }
 128
 129     /**
 130      * Perform a graceful shutdown of cqm-service node (express) server
 131      *
 132      * @return array
 133      * @throws \GuzzleHttp\Exception\GuzzleException
 134      */
 135     public function shutdown(): array
 136     {
 137         return json_decode(
 138             Utils::copyToString($this->request('GET', '/shutdown')->getBody()),
 139             true
 140         );
 141     }
 142 }