run some autoformat
This commit is contained in:
@@ -1,4 +1,5 @@
|
||||
<?php
|
||||
|
||||
/**
|
||||
* Copyright 2018 Matthias Kesler
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
@@ -13,154 +14,157 @@
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
class MatrixConnection
|
||||
{
|
||||
private $hs;
|
||||
private $at;
|
||||
class MatrixConnection {
|
||||
|
||||
function __construct($homeserver, $access_token) {
|
||||
$this->hs = $homeserver;
|
||||
$this->at = $access_token;
|
||||
}
|
||||
private $hs;
|
||||
private $at;
|
||||
|
||||
function send($room_id, $message) {
|
||||
if (!$this->at) {
|
||||
error_log("No access token defined");
|
||||
return false;
|
||||
}
|
||||
function __construct($homeserver, $access_token) {
|
||||
$this->hs = $homeserver;
|
||||
$this->at = $access_token;
|
||||
}
|
||||
|
||||
$send_message = NULL;
|
||||
if (!$message) {
|
||||
error_log("no message to send");
|
||||
return false;
|
||||
} elseif(is_array($message)) {
|
||||
$send_message = $message;
|
||||
} elseif ($message instanceof MatrixMessage) {
|
||||
$send_message = $message->get_object();
|
||||
} else {
|
||||
error_log("message is of not valid type\n");
|
||||
return false;
|
||||
}
|
||||
function send($room_id, $message) {
|
||||
if (!$this->at) {
|
||||
error_log("No access token defined");
|
||||
return false;
|
||||
}
|
||||
|
||||
$url="https://".$this->hs."/_matrix/client/r0/rooms/"
|
||||
. urlencode($room_id) ."/send/m.room.message?access_token=".$this->at;
|
||||
$handle = curl_init($url);
|
||||
curl_setopt($handle, CURLOPT_RETURNTRANSFER, true);
|
||||
curl_setopt($handle, CURLOPT_CONNECTTIMEOUT, 5);
|
||||
curl_setopt($handle, CURLOPT_TIMEOUT, 60);
|
||||
curl_setopt($handle, CURLOPT_POSTFIELDS, json_encode($send_message));
|
||||
curl_setopt($handle, CURLOPT_HTTPHEADER, array("Content-Type: application/json"));
|
||||
$send_message = NULL;
|
||||
if (!$message) {
|
||||
error_log("no message to send");
|
||||
return false;
|
||||
} elseif (is_array($message)) {
|
||||
$send_message = $message;
|
||||
} elseif ($message instanceof MatrixMessage) {
|
||||
$send_message = $message->get_object();
|
||||
} else {
|
||||
error_log("message is of not valid type\n");
|
||||
return false;
|
||||
}
|
||||
|
||||
$response = $this->exec_curl_request($handle);
|
||||
return isset($response["event_id"]);
|
||||
}
|
||||
$url = "https://" . $this->hs . "/_matrix/client/r0/rooms/"
|
||||
. urlencode($room_id) . "/send/m.room.message?access_token=" . $this->at;
|
||||
$handle = curl_init($url);
|
||||
curl_setopt($handle, CURLOPT_RETURNTRANSFER, true);
|
||||
curl_setopt($handle, CURLOPT_CONNECTTIMEOUT, 5);
|
||||
curl_setopt($handle, CURLOPT_TIMEOUT, 60);
|
||||
curl_setopt($handle, CURLOPT_POSTFIELDS, json_encode($send_message));
|
||||
curl_setopt($handle, CURLOPT_HTTPHEADER, array("Content-Type: application/json"));
|
||||
|
||||
function send_msg($room_id, $message) {
|
||||
return $this->send($room_id, array(
|
||||
"msgtype" => "m.notice",
|
||||
"body" => $message
|
||||
)
|
||||
);
|
||||
}
|
||||
$response = $this->exec_curl_request($handle);
|
||||
return isset($response["event_id"]);
|
||||
}
|
||||
|
||||
function hasUser($username) {
|
||||
if (!$username) {
|
||||
throw new Exception ("no user given to lookup");
|
||||
}
|
||||
function send_msg($room_id, $message) {
|
||||
return $this->send($room_id, array(
|
||||
"msgtype" => "m.notice",
|
||||
"body" => $message
|
||||
)
|
||||
);
|
||||
}
|
||||
|
||||
$url = "https://".$this->hs."/_matrix/client/r0/profile/@" . $username . ":" . $this->hs;
|
||||
$handle = curl_init($url);
|
||||
curl_setopt($handle, CURLOPT_RETURNTRANSFER, true);
|
||||
curl_setopt($handle, CURLOPT_CONNECTTIMEOUT, 5);
|
||||
curl_setopt($handle, CURLOPT_TIMEOUT, 60);
|
||||
curl_setopt($handle, CURLOPT_HTTPHEADER, array("Content-Type: application/json"));
|
||||
function hasUser($username) {
|
||||
if (!$username) {
|
||||
throw new Exception("no user given to lookup");
|
||||
}
|
||||
|
||||
$res = $this->exec_curl_request($handle);
|
||||
return !(isset($res["errcode"]) && $res["errcode"] == "M_UNKNOWN");
|
||||
}
|
||||
$url = "https://" . $this->hs . "/_matrix/client/r0/profile/@" . $username . ":" . $this->hs;
|
||||
$handle = curl_init($url);
|
||||
curl_setopt($handle, CURLOPT_RETURNTRANSFER, true);
|
||||
curl_setopt($handle, CURLOPT_CONNECTTIMEOUT, 5);
|
||||
curl_setopt($handle, CURLOPT_TIMEOUT, 60);
|
||||
curl_setopt($handle, CURLOPT_HTTPHEADER, array("Content-Type: application/json"));
|
||||
|
||||
function register($username, $password, $shared_secret) {
|
||||
if (!$username) {
|
||||
error_log("no username provided");
|
||||
}
|
||||
if (!$password) {
|
||||
error_log("no message to send");
|
||||
}
|
||||
$res = $this->exec_curl_request($handle);
|
||||
return !(isset($res["errcode"]) && $res["errcode"] == "M_UNKNOWN");
|
||||
}
|
||||
|
||||
$mac = hash_hmac('sha1', $username, $shared_secret);
|
||||
function register($username, $password, $shared_secret) {
|
||||
if (!$username) {
|
||||
error_log("no username provided");
|
||||
}
|
||||
if (!$password) {
|
||||
error_log("no message to send");
|
||||
}
|
||||
|
||||
$data = array(
|
||||
"username" => $username,
|
||||
"password" => $password,
|
||||
"mac" => $mac,
|
||||
);
|
||||
$url = "https://".$this->hs."/_matrix/client/v2_alpha/register";
|
||||
$handle = curl_init($url);
|
||||
curl_setopt($handle, CURLOPT_RETURNTRANSFER, true);
|
||||
curl_setopt($handle, CURLOPT_CONNECTTIMEOUT, 5);
|
||||
curl_setopt($handle, CURLOPT_TIMEOUT, 60);
|
||||
curl_setopt($handle, CURLOPT_HTTPHEADER, array("Content-Type: application/json"));
|
||||
curl_setopt($handle, CURLOPT_POSTFIELDS, json_encode($data));
|
||||
$mac = hash_hmac('sha1', $username, $shared_secret);
|
||||
|
||||
return $this->exec_curl_request($handle);
|
||||
}
|
||||
$data = array(
|
||||
"username" => $username,
|
||||
"password" => $password,
|
||||
"mac" => $mac,
|
||||
);
|
||||
$url = "https://" . $this->hs . "/_matrix/client/v2_alpha/register";
|
||||
$handle = curl_init($url);
|
||||
curl_setopt($handle, CURLOPT_RETURNTRANSFER, true);
|
||||
curl_setopt($handle, CURLOPT_CONNECTTIMEOUT, 5);
|
||||
curl_setopt($handle, CURLOPT_TIMEOUT, 60);
|
||||
curl_setopt($handle, CURLOPT_HTTPHEADER, array("Content-Type: application/json"));
|
||||
curl_setopt($handle, CURLOPT_POSTFIELDS, json_encode($data));
|
||||
|
||||
function exec_curl_request($handle) {
|
||||
$response = curl_exec($handle);
|
||||
if ($response === false) {
|
||||
$errno = curl_errno($handle);
|
||||
$error = curl_error($handle);
|
||||
error_log("Curl returned error $errno: $error\n");
|
||||
curl_close($handle);
|
||||
return false;
|
||||
}
|
||||
$http_code = intval(curl_getinfo($handle, CURLINFO_HTTP_CODE));
|
||||
curl_close($handle);
|
||||
return $this->exec_curl_request($handle);
|
||||
}
|
||||
|
||||
function exec_curl_request($handle) {
|
||||
$response = curl_exec($handle);
|
||||
if ($response === false) {
|
||||
$errno = curl_errno($handle);
|
||||
$error = curl_error($handle);
|
||||
error_log("Curl returned error $errno: $error\n");
|
||||
curl_close($handle);
|
||||
return false;
|
||||
}
|
||||
$http_code = intval(curl_getinfo($handle, CURLINFO_HTTP_CODE));
|
||||
curl_close($handle);
|
||||
|
||||
if ($http_code >= 500) {
|
||||
// do not want to DDOS server if something goes wrong
|
||||
sleep(10);
|
||||
return false;
|
||||
} else if ($http_code != 200) {
|
||||
$response = json_decode($response, true);
|
||||
error_log("Request has failed with error {$response['error']}\n");
|
||||
if ($http_code == 401) {
|
||||
throw new Exception('Invalid access token provided');
|
||||
}
|
||||
} else {
|
||||
$response = json_decode($response, true);
|
||||
}
|
||||
return $response;
|
||||
}
|
||||
|
||||
if ($http_code >= 500) {
|
||||
// do not want to DDOS server if something goes wrong
|
||||
sleep(10);
|
||||
return false;
|
||||
} else if ($http_code != 200) {
|
||||
$response = json_decode($response, true);
|
||||
error_log("Request has failed with error {$response['error']}\n");
|
||||
if ($http_code == 401) {
|
||||
throw new Exception('Invalid access token provided');
|
||||
}
|
||||
} else {
|
||||
$response = json_decode($response, true);
|
||||
}
|
||||
return $response;
|
||||
}
|
||||
}
|
||||
|
||||
class MatrixMessage
|
||||
{
|
||||
private $message;
|
||||
class MatrixMessage {
|
||||
|
||||
function __construct() {
|
||||
$this->message = ["msgtype" => "m.notice"];
|
||||
}
|
||||
private $message;
|
||||
|
||||
function set_type($msgtype) {
|
||||
$this->message["msgtype"] = $msgtype;
|
||||
}
|
||||
function __construct() {
|
||||
$this->message = ["msgtype" => "m.notice"];
|
||||
}
|
||||
|
||||
function set_format($format) {
|
||||
$this->message["format"] = $format;
|
||||
}
|
||||
function set_type($msgtype) {
|
||||
$this->message["msgtype"] = $msgtype;
|
||||
}
|
||||
|
||||
function set_body($body) {
|
||||
$this->message["body"] = $body;
|
||||
}
|
||||
function set_format($format) {
|
||||
$this->message["format"] = $format;
|
||||
}
|
||||
|
||||
function set_formatted_body($fbody, $format="org.matrix.custom.html") {
|
||||
$this->message["formatted_body"] = $fbody;
|
||||
$this->message["format"] = $format;
|
||||
}
|
||||
function set_body($body) {
|
||||
$this->message["body"] = $body;
|
||||
}
|
||||
|
||||
function set_formatted_body($fbody, $format = "org.matrix.custom.html") {
|
||||
$this->message["formatted_body"] = $fbody;
|
||||
$this->message["format"] = $format;
|
||||
}
|
||||
|
||||
function get_object() {
|
||||
return $this->message;
|
||||
}
|
||||
|
||||
function get_object() {
|
||||
return $this->message;
|
||||
}
|
||||
}
|
||||
|
||||
?>
|
||||
|
||||
Reference in New Issue
Block a user