Portions created by the Initial Developer are Copyright (C) 2016-2018 the Initial Developer. All Rights Reserved. Contributor(s): Mark J Crane */ //includes require_once "root.php"; require_once "resources/require.php"; //get the user settings $sql = "select user_uuid, domain_uuid from v_user_settings "; $sql .= "where user_setting_category = 'message' "; $sql .= "and user_setting_subcategory = 'key' "; $sql .= "and user_setting_value = :key "; $sql .= "and user_setting_enabled = 'true' "; $prep_statement = $db->prepare($sql); $prep_statement->bindParam(':key', $_GET['key']); if ($prep_statement) { $prep_statement->execute(); $row = $prep_statement->fetch(PDO::FETCH_NAMED); } //default authorized to false $authorized = 'false'; //get the user if (isset($row['user_uuid']) && strlen($row['user_uuid']) > 0) { $domain_uuid = $row['domain_uuid']; $user_uuid = $row['user_uuid']; $authorized = 'true'; } //authorization failed if ($authorized == 'false') { //log the failed auth attempt to the system, to be available for fail2ban. openlog('FusionPBX', LOG_NDELAY, LOG_AUTH); syslog(LOG_WARNING, '['.$_SERVER['REMOTE_ADDR']."] authentication failed for ".$_GET['key']); closelog(); //send http 404 header("HTTP/1.0 404 Not Found"); echo "\n"; echo "404 Not Found\n"; echo "\n"; echo "

404 Not Found

\n"; echo "

nginx/1.12.1\n"; echo "\n"; echo "\n"; exit(); } //get the data $json = file_get_contents('php://input'); //decode the json $message = json_decode($json, true); //get a unique id $message_uuid = uuid(); //get the source phone number $phone_number = $message["from"]; $phone_number = preg_replace('{[\D]}', '', $phone_number); //get the contact uuid //$sql = "SELECT trim(c.contact_name_given || ' ' || c.contact_name_family || ' (' || c.contact_organization || ')') AS name, p.phone_number AS number "; $sql = "SELECT c.contact_uuid "; $sql .= "FROM v_contacts as c, v_contact_phones as p "; $sql .= "WHERE p.contact_uuid = c.contact_uuid "; //$sql .= "and p.phone_number = :phone_number "; $sql .= "and p.phone_number = '".$phone_number."' "; $sql .= "and c.domain_uuid = '".$domain_uuid."' "; $prep_statement = $db->prepare($sql); //$prep_statement->bindParam(':phone_number', $phone_number); $prep_statement->execute(); $row = $prep_statement->fetch(PDO::FETCH_NAMED); $contact_uuid = $row['contact_uuid']; //build the array $array['messages'][0]["domain_uuid"] = $domain_uuid; $array['messages'][0]["user_uuid"] = $user_uuid; $array['messages'][0]["contact_uuid"] = $contact_uuid; $array['messages'][0]['message_uuid'] = $message_uuid; $array['messages'][0]['message_json'] = $json; $array['messages'][0]['message_direction'] = 'inbound'; $array['messages'][0]['message_date'] = 'now()'; $array['messages'][0]['message_type'] = 'sms'; $array['messages'][0]['message_from'] = $message["from"]; $array['messages'][0]['message_to'] = $message["to"]; $array['messages'][0]['message_text'] = $message["text"]; //get the media if (is_array($message["media"])) { foreach($message["media"] as $media) { $media_extension = pathinfo($media, PATHINFO_EXTENSION); if ($media_extension !== "xml") { $array['messages'][0]['message_media_type'] = $media_extension; $array['messages'][0]['message_media_url'] = $media; $array['messages'][0]['message_media_content'] = base64_encode(file_get_contents($media)); } } } //convert the array to json $array_json = json_encode($array); //add the dialplan permission $p = new permissions; $p->add("message_add", "temp"); //save to the data $database = new database; $database->app_name = 'messages'; $database->app_uuid = '4a20815d-042c-47c8-85df-085333e79b87'; $database->uuid($message_uuid); $database->save($array); $result = $database->message; //remove the temporary permission $p->delete("message_add", "temp"); //get the list of extensions using the user_uuid //$user_uuid //forward the messages over SIP // //create the event socket connection //$fp = event_socket_create($_SESSION['event_socket_ip_address'], $_SESSION['event_socket_port'], $_SESSION['event_socket_password']); //if ($fp) { //prepare the command // $command = ""; //send the command // $response = event_socket_request($fp, "api ".$command); // $response = event_socket_request($fp, "api log notice ".$command); //close the connection // fclose($fp); //} //set the file //$file = '/tmp/sms.txt'; //save the file //file_put_contents($file, $json); //save the data to the file system //file_put_contents($file, $json."\n"); //file_put_contents($file, $array_json."\nfrom: ".$message["from"]." to: ".$message["to"]." text: ".$message["text"]."\n$sql_test\njson: ".$json."\n".$saved_result."\n"); ?>