socket call - refresh added

app/Controllers/BaseController.php

@@ -56,4 +56,50 @@ abstract class BaseController extends Controller
         $this->db = \Config\Database::connect();
         // E.g.: $this->session = service('session');
     }
+    public function APIcall($method, $url, $data) {
+        //  $curl = curl_init();
+        $curl = curl_init($url);
+        switch ($method) {
+            case "GET":
+                $params2 = '';
+                foreach($data as $key2=>$value2)
+                    $params2 .= $key2.'='.$value2.'&';
+
+                $params2 = trim($params2, '&');
+                $url = $url.'?'.$params2;// add param to URL
+                log_message('critical', "API URL FINAL =>".$url );
+                //curl_setopt($curl, CURLOPT_FRESH_CONNECT, true);
+                //curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
+                //curl_setopt($curl, CURLOPT_POSTFIELDS, http_build_query($data));
+                break;
+            case "POST":
+                curl_setopt($curl, CURLOPT_POST, 1);
+                if ($data)
+                    //  curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
+                    curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($data));
+                //  curl_setopt($curl, CURLOPT_POSTFIELDS, http_build_query($data));
+                break;
+            case "PUT":
+                curl_setopt($curl, CURLOPT_CUSTOMREQUEST, "PUT");
+                if ($data)
+                    curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
+                break;
+        }
+
+        curl_setopt($curl, CURLOPT_URL, $url);
+        curl_setopt($curl, CURLOPT_HTTPHEADER, array(
+            'APIKEY: RegisteredAPIkey',
+            'Content-Type: application/json',
+        ));
+
+        curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
+        curl_setopt($curl, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
+        $result = curl_exec($curl);
+
+        if(!$result) {
+            echo("Connection failure!");
+        }
+        curl_close($curl);
+        return json_decode($result, true);
+    }
 }

app/Controllers/Provision.php

@@ -194,6 +194,11 @@ class Provision extends BaseController
             $mysql = "INSERT INTO provision_actions (member_id,product_uid,action) VALUES ($memberID,'$provisionUID', '$actionText')";
             log_message('critical', "***** ***** Provision :: provisionActions(QUERY) :: ".$mysql);
             $query = $this->db->query($mysql);
+
+            // TELL THE SOCKET TO REFRESH PAGE
+            $data["product_uid"] = $provisionUID;
+            $this->APIcall("GET", 'http://10.0.0.32:5006/broadcast/provisionings', $data);
+
         } catch (Exception $e) {
            // echo 'Caught exception: ',  $e->getMessage(), "\n";
             log_message('critical', "***** ***** Provision Error:: provisionActions() ".$e->getMessage());