Adding Project API Class, and anothers classes to handle bpmn layer model

workflow/engine/src/ProcessMaker/Adapter/Bpmn/Model.php

@@ -0,0 +1,332 @@
+<?php
+namespace ProcessMaker\Adapter\Bpmn;
+
+use \BpmnProject as Project;
+use \BpmnProcess as Process;
+use \BpmnDiagram as Diagram;
+use \BpmnLaneset as Laneset;
+use \BpmnLane as Lane;
+use \BpmnActivity as Activity;
+use \BpmnBound as Bound;
+use \BpmnEvent as Event;
+use \BpmnGateway as Gateway;
+use \BpmnFlow as Flow;
+use \BpmnArtifact as Artifact;
+
+use \BpmnProjectPeer as ProjectPeer;
+use \BpmnProcessPeer as ProcessPeer;
+use \BpmnDiagramPeer as DiagramPeer;
+use \BpmnLanesetPeer as LanesetPeer;
+use \BpmnLanePeer as LanePeer;
+use \BpmnActivityPeer as ActivityPeer;
+use \BpmnBoundPeer as BoundPeer;
+use \BpmnEventPeer as EventPeer;
+use \BpmnGatewayPeer as GatewayPeer;
+use \BpmnFlowPeer as FlowPeer;
+use \BpmnArtifactPeer as ArtifactPeer;
+
+use \ProcessMaker\Util\Hash;
+use \BasePeer;
+
+/**
+ * Class Model
+ *
+ * @package ProcessMaker\Adapter\Bpmn
+ * @author Erik Amaru Ortiz <aortiz.erik@gmail.com, erik@colosa.com>
+ */
+class Model
+{
+    public function createProject($data)
+    {
+        $data = array_change_key_case($data, CASE_UPPER);
+        $uids = array();
+        $oldPrjUid = $data['PRJ_UID'];
+        $diagrams = $data['DIAGRAMS'];
+
+        unset($data['PRJ_UID']);
+
+
+        /*
+         * 1. Create a project record
+         * 2. Create a default diagram record
+         * 3. Create a default process record
+         */
+
+        $project = new Project();
+        $project->fromArray($data, BasePeer::TYPE_FIELDNAME);
+        $project->setPrjUid(Hash::generateUID());
+        $project->setPrjCreateDate(date("Y-m-d H:i:s"));
+        $project->save();
+        $prjUid  = $project->getPrjUid();
+        $prjName = $project->getPrjName();
+        $uids[] = array('old_uid' => $oldPrjUid, 'new_uid' => $prjUid, 'object' => 'project');
+
+        // By now, is thought create a only one diagram for a project/process (1:1)
+        $diagramData = (array) $diagrams[0];
+        $oldDiaUid = $diagramData['dia_uid'];
+
+        $diagram = new Diagram();
+        $diagram->setDiaUid(Hash::generateUID());
+        $diagram->setPrjUid($prjUid);
+        $diagram->setDiaName($prjName);
+        $diagram->save();
+        $diaUid = $diagram->getDiaUid();
+        $uids[] = array('old_uid' => $oldDiaUid, 'new_uid' => $diaUid, 'object' => 'diagram');
+
+
+        $process = new Process();
+        $process->setProUid(Hash::generateUID());
+        $process->setPrjUid($prjUid);
+        $process->setDiaUid($diaUid);
+        $process->setProName($prjName);
+        $process->save();
+        $proUid = $process->getProUid();
+
+        $uids = array_merge($uids, $this->createDiagram($prjUid, $proUid, $diaUid, $diagramData));
+
+        return $uids;
+    }
+
+    private function createDiagram($prjUid, $proUid, $diaUid, $diagramData)
+    {
+        $uids = array();
+
+        /*
+         * 1. ensure that all related object data is defined, if not define it as empty
+         * 2. create all related object
+         */
+
+        $lanesets = array_key_exists('laneset', $diagramData) ? $diagramData['laneset'] : array();
+        $lanes = array_key_exists('lane', $diagramData) ? $diagramData['lanes'] : array();
+        $activities = array_key_exists('activities', $diagramData) ? $diagramData['activities'] : array();
+        $events = array_key_exists('events', $diagramData) ? $diagramData['events'] : array();
+        $gateways = array_key_exists('gateways', $diagramData) ? $diagramData['gateways'] : array();
+        $flows = array_key_exists('flows', $diagramData) ? $diagramData['flows'] : array();
+        $artifacts = array_key_exists('artifacts', $diagramData) ? $diagramData['artifacts'] : array();
+
+
+        foreach($lanesets as $lanesetData) {
+            $lanesetData = array_change_key_case((array) $lanesetData, CASE_UPPER);
+
+            $laneset = new Laneset();
+            $laneset->fromArray($lanesetData, BasePeer::TYPE_FIELDNAME);
+            $laneset->setLnsUid(Hash::generateUID());
+            $laneset->setPrjUid($prjUid);
+            $laneset->setProUid($proUid);
+            $laneset->save();
+            $lnsUid = $laneset->getLnsUid();
+            $oldLnsUid = $lanesetData['LNS_UID'];
+
+            $uids[] = array('old_uid' => $oldLnsUid, 'new_uid' => $lnsUid, 'object' => 'laneset');
+        }
+
+        foreach($lanes as $laneData) {
+            $laneData = array_change_key_case((array) $laneData, CASE_UPPER);
+
+            $lane = new Lane();
+            $lane->fromArray($laneData, BasePeer::TYPE_FIELDNAME);
+            $lane->setLanUid(Hash::generateUID());
+            $lane->setPrjUid($prjUid);
+            $lane->save();
+            $lanUid = $lane->getLanUid();
+            $oldLanUid = $laneData['LNS_UID'];
+
+            $uids[] = array('old_uid' => $oldLanUid, 'new_uid' => $lanUid, 'object' => 'lane');
+        }
+
+        foreach($activities as $activityData) {
+            $activityData = array_change_key_case((array) $activityData, CASE_UPPER);
+
+            /*
+             * 1. crate activity record
+             * 2. crate bound record for activity created in previous step
+             */
+            $activity = new Activity();
+            $activity->fromArray($activityData, BasePeer::TYPE_FIELDNAME);
+            $activity->setActUid(Hash::generateUID());
+            $activity->setPrjUid($prjUid);
+            $activity->setProUid($proUid);
+            $activity->save();
+
+            $actUid = $activity->getActUid();
+            $oldActUid = $activityData['ACT_UID'];
+            $uids[] = array('old_uid' => $oldActUid, 'new_uid' => $actUid, 'object' => 'activity');
+
+
+            $bound = new Bound();
+            $bound->fromArray($activityData, BasePeer::TYPE_FIELDNAME);
+            $bound->setBouUid(Hash::generateUID());
+            $bound->setPrjUid($prjUid);
+            $bound->setDiaUid($diaUid);
+            $bound->setElementUid($activity->getActUid());
+            $bound->setBouElementType(get_class($activity));
+            $bound->setBouElement('pm_canvas');
+            $bound->setBouContainer('bpmnDiagram');
+            $bound->save();
+        }
+
+        foreach($events as $eventData) {
+            $eventData = array_change_key_case((array) $eventData, CASE_UPPER);
+
+            /*
+             * 1. crate activity record
+             * 2. crate bound record for activity created in previous step
+             */
+            $event = new Event();
+
+            $event->fromArray($eventData, BasePeer::TYPE_FIELDNAME);
+            $event->setEvnUid(Hash::generateUID());
+            $event->setPrjUid($prjUid);
+            $event->setProUid($proUid);
+            $event->save();
+
+            $evnUid = $event->getEvnUid();
+            $oldEvnUid = $eventData['EVN_UID'];
+            $uids[] = array('old_uid' => $oldEvnUid, 'new_uid' => $evnUid, 'object' => 'event');
+
+            $bound = new Bound();
+            $bound->fromArray($eventData, BasePeer::TYPE_FIELDNAME);
+            $bound->setBouUid(Hash::generateUID());
+            $bound->setPrjUid($prjUid);
+            $bound->setDiaUid($diaUid);
+            $bound->setElementUid($event->getEvnUid());
+            $bound->setBouElementType(get_class($event));
+            $bound->setBouElement('pm_canvas');
+            $bound->setBouContainer('bpmnDiagram');
+            $bound->save();
+        }
+
+        foreach($gateways as $gatewayData) {
+            $gatewayData = array_change_key_case((array) $gatewayData, CASE_UPPER);
+
+            /*
+             * 1. crate activity record
+             * 2. crate bound record for activity created in previous step
+             */
+            $gateway = new Gateway();
+            $gateway->fromArray($gatewayData, BasePeer::TYPE_FIELDNAME);
+            $gateway->setGatUid(Hash::generateUID());
+            $gateway->setPrjUid($prjUid);
+            $gateway->setProUid($proUid);
+            $gateway->save();
+
+            $gatUid = $gateway->getGatUid();
+            $oldGatUid = $gatewayData['GAT_UID'];
+            $uids[] = array('old_uid' => $oldGatUid, 'new_uid' => $gatUid, 'object' => 'gateway');
+
+            $bound = new Bound();
+            $bound->fromArray($gatewayData, BasePeer::TYPE_FIELDNAME);
+            $bound->setBouUid(Hash::generateUID());
+            $bound->setPrjUid($prjUid);
+            $bound->setDiaUid($diaUid);
+            $bound->setElementUid($gateway->getGatUid());
+            $bound->setBouElementType(get_class($gateway));
+            $bound->setBouElement('pm_canvas');
+            $bound->setBouContainer('bpmnDiagram');
+            $bound->save();
+        }
+
+        foreach($flows as $flowData) {
+            $flowData = array_change_key_case((array) $flowData, CASE_UPPER);
+
+            $floState = json_encode($flowData['FLO_STATE']);
+            unset($flowData['FLO_STATE']);
+
+            $flow = new Flow();
+            $flow->fromArray($flowData, BasePeer::TYPE_FIELDNAME);
+            $flow->setFloUid(Hash::generateUID());
+            $flow->setPrjUid($prjUid);
+            $flow->setDiaUid($diaUid);
+            $flow->setFloState($floState);
+            $flow->save();
+
+            $floUid = $flow->getFloUid();
+            $oldFloUid = $flowData['FLO_UID'];
+            $uids[] = array('old_uid' => $oldFloUid, 'new_uid' => $floUid, 'object' => 'flow');
+        }
+
+        foreach($artifacts as $artifactData) {
+            $artifactData = array_change_key_case((array) $artifactData, CASE_UPPER);
+
+            $artifact = new Artifact();
+            $artifact->fromArray($artifactData, BasePeer::TYPE_FIELDNAME);
+            $artifact->setArtUid(Hash::generateUID());
+            $artifact->setPrjUid($prjUid);
+            $artifact->setProUid($proUid);
+            $artifact->save();
+
+            $artUid = $artifact->getFloUid();
+            $oldArtUid = $artifactData['ART_UID'];
+            $uids[] = array('old_uid' => $oldArtUid, 'new_uid' => $artUid, 'object' => 'artifact');
+        }
+
+        return $uids;
+    }
+
+    public function loadProject($prjUid)
+    {
+        /*
+         * 1. load object of project
+         * 2. load object of process
+         * 3. load object of diagram
+         * 4. load collection of lanesets
+         * 5. load collection of lanes
+         * 6. load collection of activities
+         * 7. load collection of events
+         * 8. load collection of gateways
+         * 9. load collection of flows
+         * 10. load collection of artifacts
+         * 11. compose project data structure
+         */
+
+        $project = self::getBpmnObjectBy('Project', ProjectPeer::PRJ_UID, $prjUid, true);
+        $process = self::getBpmnObjectBy('Process', ProcessPeer::PRJ_UID, $prjUid, true);
+        $diagram = self::getBpmnObjectBy('Diagram', DiagramPeer::DIA_UID, $process['dia_uid'], true);
+        $lanesets = self::getBpmnCollectionBy('Laneset', LanesetPeer::PRJ_UID, $prjUid, true);
+        $lanes = self::getBpmnCollectionBy('Lane', LanePeer::PRJ_UID, $prjUid, true);
+        $activities = self::getBpmnCollectionBy('Activity', ActivityPeer::PRJ_UID, $prjUid, true);
+        $events = self::getBpmnCollectionBy('Event', EventPeer::PRJ_UID, $prjUid, true);
+        $gateways = self::getBpmnCollectionBy('Gateway', GatewayPeer::PRJ_UID, $prjUid, true);
+        $flows = self::getBpmnCollectionBy('Flow', FlowPeer::PRJ_UID, $prjUid, true);
+        $artifacts = self::getBpmnCollectionBy('Artifact', ArtifactPeer::PRJ_UID, $prjUid, true);
+
+        $project = array_change_key_case($project);
+        $project['diagrams'] = array($diagram);
+        $project['diagrams'][0]['lanesets'] = $lanesets;
+        $project['diagrams'][0]['lanes'] = $lanes;
+        $project['diagrams'][0]['activities'] = $activities;
+        $project['diagrams'][0]['events'] = $events;
+        $project['diagrams'][0]['gateways'] = $gateways;
+        $project['diagrams'][0]['flows'] = $flows;
+        $project['diagrams'][0]['artifacts'] = $artifacts;
+
+        return $project;
+    }
+
+    private static function getBpmnCollectionBy($class, $field, $value, $changeCase = false)
+    {
+        $data = array();
+
+        $c = new \Criteria('workflow');
+        $c->add($field, $value);
+
+        $classPeer = 'Bpmn' . $class . 'Peer';
+        $rs = $classPeer::doSelectRS($c);
+
+        $rs->setFetchmode(\ResultSet::FETCHMODE_ASSOC);
+
+        while ($rs->next()) {
+            $data[] = $changeCase ? array_change_key_case($rs->getRow(), CASE_LOWER) : $rs->getRow();
+        }
+
+        return $data;
+    }
+
+    private static function getBpmnObjectBy($class, $field, $value, $changeCase = false)
+    {
+        $record = self::getBpmnCollectionBy($class, $field, $value, $changeCase);
+
+        return empty($record) ? null : $record[0];
+    }
+}
+

workflow/engine/src/ProcessMaker/Adapter/Bpmn/Transform.php

@@ -0,0 +1,28 @@
+<?php
+namespace ProcessMaker\Adapter\Bpmn;
+
+use \BpmnProject as Project;
+use \BpmnProcess as Process;
+use \BpmnDiagram as Diagram;
+use \BpmnLaneset as Laneset;
+use \BpmnLane as Lane;
+use \BpmnActivity as Activity;
+use \BpmnBound as Bound;
+use \BpmnEvent as Event;
+use \BpmnGateway as Gateway;
+use \BpmnFlow as Flow;
+use \BpmnArtifact as Artifact;
+
+use \ProcessMaker\Util\Hash;
+use \BasePeer;
+
+/**
+ * Class Transform
+ *
+ * @package ProcessMaker\Adapter\Bpmn
+ * @author Erik Amaru Ortiz <aortiz.erik@gmail.com, erik@colosa.com>
+ */
+class Transform
+{
+    
+}

workflow/engine/src/ProcessMaker/Services/Api.php

@@ -1,7 +1,15 @@
 <?php
 namespace ProcessMaker\Services;
 
-class Api
+/**
+ * Abstract Class Api
+ *
+ * Api class be be extended by Restler Classes
+ *
+ * @package ProcessMaker\Services
+ * @author Erik Amaru Ortiz <aortiz.erik@gmail.com, erik@colosa.com>
+ */
+abstract class Api
 {
     private static $workspace;
     private static $userId;

workflow/engine/src/ProcessMaker/Util/Hash.php

@@ -0,0 +1,68 @@
+<?php
+namespace ProcessMaker\Util;
+
+class Hash
+{
+    /**
+     * Generate random number
+     *
+     * @author Fernando Ontiveros Lira <fernando@colosa.com>
+     * @access public
+     * @return string
+     */
+    public static function generateUID()
+    {
+        do {
+            $sUID = str_replace('.', '0', uniqid(rand(0, 999999999), true));
+        } while (strlen( $sUID ) != 32);
+
+        return $sUID;
+    }
+
+    /**
+     * Generate a numeric or alphanumeric code
+     *
+     * @author Julio Cesar Laura Avendaño <juliocesar@colosa.com>
+     * @access public
+     * @param int $iDigits
+     * @param string $sType
+     * @return string
+     */
+    public function generateCode($iDigits = 4, $sType = 'NUMERIC')
+    {
+        if (($iDigits < 4) || ($iDigits > 50)) {
+            $iDigits = 4;
+        }
+        if (($sType != 'NUMERIC') && ($sType != 'ALPHA') && ($sType != 'ALPHANUMERIC')) {
+            $sType = 'NUMERIC';
+        }
+
+        $aValidCharacters = array(
+            '0','1','2','3','4','5','6','7','8','9','A','B','C','D','E','F','G','H',
+            'I','J','K','L','M','N','O','P','Q','R','S','T','U','V','W','X','Y','Z'
+        );
+
+        switch ($sType) {
+            case 'NUMERIC':
+                $iMin = 0;
+                $iMax = 9;
+                break;
+            case 'ALPHA':
+                $iMin = 10;
+                $iMax = 35;
+                break;
+            case 'ALPHANUMERIC':
+                $iMin = 0;
+                $iMax = 35;
+                break;
+        }
+
+        $sCode = '';
+        for ($i = 0; $i < $iDigits; $i ++) {
+            $sCode .= $aValidCharacters[rand($iMin, $iMax)];
+        }
+
+        return $sCode;
+    }
+}
+

workflow/engine/src/ProcessMaker/Util/Logger.php

@@ -1,7 +1,13 @@
 <?php
-
 namespace ProcessMaker\Util;
 
+/**
+ * Singleton Class Logger
+ *
+ * This Utility is usefull to log local messages
+ * @package ProcessMaker\Util
+ * @author Erik Amaru Ortiz <aortiz.erik@gmail.com, erik@colosa.com>
+ */
 class Logger
 {
     private static $instance;

workflow/engine/src/Services/Api/ProcessMaker/Project.php

@@ -0,0 +1,36 @@
+<?php
+namespace Services\Api\ProcessMaker;
+
+use Luracast\Restler\RestException;
+use ProcessMaker\Services\Api;
+use ProcessMaker\Adapter\Bpmn\Model as BpmnModel;
+
+/**
+ * Class Project
+ *
+ * @package Services\Api\ProcessMaker
+ * @author Erik Amaru Ortiz <aortiz.erik@gmail.com, erik@colosa.com>
+ *
+ * @protected
+ */
+class Project extends Api
+{
+
+    function post($request_data)
+    {
+        try {
+            $bpmnModel = new BpmnModel();
+
+            return $bpmnModel->createProject($request_data);
+        } catch (\Exception $e) {
+            throw new RestException(Api::STAT_APP_EXCEPTION, $e->getMessage());
+        }
+    }
+
+    function get($prjUid)
+    {
+        $project = BpmnModel::loadProject($prjUid);
+
+        return $project;
+    }
+}