check other comands

2017-08-14 15:58:34 -04:00
parent 97a04ed16a
commit b556051254
4 changed files with 170 additions and 80 deletions
--- a/workflow/engine/src/ProcessMaker/Util/Cnn.php
+++ b/workflow/engine/src/ProcessMaker/Util/Cnn.php
@@ -0,0 +1,122 @@
+<?php
+
+namespace ProcessMaker\Util;
+
+use Propel;
+
+/**
+ * Class Cnn
+ * @package ProcessMaker\Util
+ */
+class Cnn
+{
+    private $DBFile;
+    private $Workspace;
+
+    /**
+     * Establishes connection for the workspace
+     * @param string $Workspace Name workspace
+     */
+    public static function connect($Workspace)
+    {
+        $cnn = new static();
+        $cnn->Workspace = $Workspace;
+        Propel::initConfiguration($cnn->buildParams());
+    }
+
+    /**
+     * Loads the parameters required to connect to each workspace database
+     * @return array
+     */
+    public function buildParams()
+    {
+        if ($this->readFileDBWorkspace()) {
+            return $this->prepareDataSources();
+        }
+        return [];
+    }
+
+    /**
+     * Reads the workspace db.php file
+     * @return bool
+     */
+    private function readFileDBWorkspace()
+    {
+        if (file_exists(PATH_DB . $this->Workspace . PATH_SEP . 'db.php')) {
+            $this->DBFile = file_get_contents(PATH_DB . $this->Workspace . PATH_SEP . 'db.php');
+            return true;
+        }
+        return false;
+    }
+
+    /**
+     * Prepares data resources
+     * @return array
+     */
+    private function prepareDataSources()
+    {
+        $phpCode = preg_replace(
+            '/define\s*\(\s*[\x22\x27](.*)[\x22\x27]\s*,\s*(\x22.*\x22|\x27.*\x27)\s*\)\s*;/i',
+            '$$1 = $2;',
+            $this->DBFile
+        );
+        $phpCode = str_replace(['<?php', '<?', '?>'], '', $phpCode);
+
+        eval($phpCode);
+
+        $dataSources = [];
+        $dataSources['datasources'] = array(
+            'workflow' => array(
+                'connection' => $this->buildDsnString(
+                    $DB_ADAPTER,
+                    $DB_HOST,
+                    $DB_NAME,
+                    $DB_USER,
+                    urlencode($DB_PASS)
+                ),
+                'adapter' => "mysql"
+            ),
+            'rbac' => array(
+                'connection' => $this->buildDsnString(
+                    $DB_ADAPTER,
+                    $DB_RBAC_HOST,
+                    $DB_RBAC_NAME,
+                    $DB_RBAC_USER,
+                    urlencode($DB_RBAC_PASS)
+                ),
+                'adapter' => "mysql"
+            ),
+            'report' => array(
+                'connection' => $this->buildDsnString(
+                    $DB_ADAPTER,
+                    $DB_REPORT_HOST,
+                    $DB_REPORT_NAME,
+                    $DB_REPORT_USER,
+                    urlencode($DB_REPORT_PASS)
+                ),
+                'adapter' => "mysql"
+            )
+        );
+        return $dataSources;
+    }
+
+    /**
+     * Builds the DSN string to be used by PROPEL
+     * @param string $Adapter
+     * @param string $Host
+     * @param string $Name
+     * @param string $User
+     * @param string $Pass
+     * @return string
+     */
+    private function buildDsnString($Adapter, $Host, $Name, $User, $Pass)
+    {
+        $Dsn = $Adapter . "://" . $User . ":" . $Pass . "@" . $Host . "/" . $Name;
+        switch ($Adapter) {
+            case 'mysql':
+                $Dsn .= '?encoding=utf8';
+                break;
+        }
+        return $Dsn;
+    }
+}