First running version (#2)
This currently depends of interacting with matrix_synapse_rest_auth[1] and mxisd[2]. How to integrate that is explained in the README [1] https://github.com/kamax-io/matrix-synapse-rest-auth [2] https://github.com/kamax-io/mxisd
This commit is contained in:
Matthias
36
internal/directory_search.php
Normal file
36
internal/directory_search.php
Normal file
@@ -0,0 +1,36 @@
|
||||
<?php
|
||||
require_once("../database.php");
|
||||
$response=[
|
||||
"limited" => false,
|
||||
"result" => [],
|
||||
];
|
||||
|
||||
try {
|
||||
$inputJSON = file_get_contents('php://input');
|
||||
$input = json_decode($inputJSON, TRUE);
|
||||
if (empty($input)) {
|
||||
throw new Exception('no valid json as input present');
|
||||
}
|
||||
if (!isset($input["by"])) {
|
||||
throw new Exception('"by" is not defined');
|
||||
}
|
||||
if (!isset($input["search_term"])) {
|
||||
throw new Exception('"search_term" is not defined');
|
||||
}
|
||||
switch ($input["by"]) {
|
||||
case "name":
|
||||
$response["result"] = $mx_db->searchUserByName($input["search_term"]);
|
||||
break;
|
||||
case "threepid":
|
||||
$response["result"] = $mx_db->searchUserByEmail($input["search_term"]);
|
||||
break;
|
||||
default:
|
||||
throw new Exception("unknown type for \"by\" param");
|
||||
}
|
||||
|
||||
} catch (Exception $e) {
|
||||
error_log("failed with error: " . $e->getMessage());
|
||||
$response["error"] = $e->getMessage();
|
||||
}
|
||||
print (json_encode($response, JSON_PRETTY_PRINT) . "\n");
|
||||
?>
|
||||
53
internal/identity_bulk.php
Normal file
53
internal/identity_bulk.php
Normal file
@@ -0,0 +1,53 @@
|
||||
<?php
|
||||
require_once("../database.php");
|
||||
$response = [
|
||||
"lookup" => []
|
||||
];
|
||||
try {
|
||||
$inputJSON = file_get_contents('php://input');
|
||||
$input = json_decode($inputJSON, TRUE);
|
||||
if (!isset($input)) {
|
||||
throw new Exception('request body is no valid json');
|
||||
}
|
||||
|
||||
if (!isset($input["lookup"])) {
|
||||
throw new Exception('"lookup" is not defined');
|
||||
}
|
||||
if (!is_array($input["lookup"])) {
|
||||
throw new Exception('"lookup" is not an array');
|
||||
}
|
||||
foreach ($input["lookup"] as $lookup) {
|
||||
if (!isset($lookup["medium"])) {
|
||||
throw new Exception('"lookup.medium" is not defined');
|
||||
}
|
||||
if (!isset($lookup["address"])) {
|
||||
throw new Exception('"lookup.address" is not defined');
|
||||
}
|
||||
$res2 = array();
|
||||
switch ($lookup["medium"]) {
|
||||
case "email":
|
||||
$res2 = $mx_db->searchUserByEmail($lookup["address"]);
|
||||
if (!empty($res2)) {
|
||||
array_push($response["lookup"], [
|
||||
"medium" => $lookup["medium"],
|
||||
"address" => $lookup["address"],
|
||||
"id" => [
|
||||
"type" => "localpart",
|
||||
"value" => $res2[0]["user_id"],
|
||||
]
|
||||
]
|
||||
);
|
||||
}
|
||||
break;
|
||||
case "msisdn":
|
||||
break;
|
||||
default:
|
||||
throw new Exception("unknown type for \"by\" param");
|
||||
}
|
||||
}
|
||||
} catch (Exception $e) {
|
||||
error_log("ídentity_bulk failed with error: " . $e->getMessage());
|
||||
$response["error"] = $e->getMessage();
|
||||
}
|
||||
print (json_encode($response, JSON_PRETTY_PRINT) . "\n");
|
||||
?>
|
||||
46
internal/identity_single.php
Normal file
46
internal/identity_single.php
Normal file
@@ -0,0 +1,46 @@
|
||||
<?php
|
||||
require_once("../database.php");
|
||||
$response = new stdClass;
|
||||
try {
|
||||
$inputJSON = file_get_contents('php://input');
|
||||
$input = json_decode($inputJSON, TRUE);
|
||||
if (empty($input)) {
|
||||
throw new Exception('no valid json as input present');
|
||||
}
|
||||
if (!isset($input["lookup"])) {
|
||||
throw new Exception('"lookup" is not defined');
|
||||
}
|
||||
if (!isset($input["lookup"]["medium"])) {
|
||||
throw new Exception('"lookup.medium" is not defined');
|
||||
}
|
||||
if (!isset($input["lookup"]["address"])) {
|
||||
throw new Exception('"lookup.address" is not defined');
|
||||
}
|
||||
$res2 = array();
|
||||
switch ($input["lookup"]["medium"]) {
|
||||
case "email":
|
||||
$res2 = $mx_db->searchUserByEmail($input["lookup"]["address"]);
|
||||
if (!empty($res2)) {
|
||||
$response = [
|
||||
"lookup" => [
|
||||
"medium" => $input["lookup"]["medium"],
|
||||
"address" => $input["lookup"]["address"],
|
||||
"id" => [
|
||||
"type" => "localpart",
|
||||
"value" => $res2[0]["user_id"],
|
||||
]
|
||||
]
|
||||
];
|
||||
}
|
||||
|
||||
|
||||
break;
|
||||
default:
|
||||
throw new Exception("unknown type for \"by\" param");
|
||||
}
|
||||
} catch (Exception $e) {
|
||||
error_log("ídentity_bulk failed with error: " . $e->getMessage());
|
||||
$response["error"] = $e->getMessage();
|
||||
}
|
||||
print (json_encode($response, JSON_PRETTY_PRINT) . "\n");
|
||||
?>
|
||||
98
internal/login.php
Normal file
98
internal/login.php
Normal file
@@ -0,0 +1,98 @@
|
||||
<?php
|
||||
$response = [
|
||||
"auth" => [
|
||||
"success" => false,
|
||||
]
|
||||
];
|
||||
|
||||
require_once("../database.php");
|
||||
abstract class LoginRequester {
|
||||
const UNDEFINED = 0;
|
||||
const MXISD = 1;
|
||||
const RestAuth = 2;
|
||||
}
|
||||
$loginRequester = LoginRequester::UNDEFINED;
|
||||
|
||||
try {
|
||||
$inputJSON = file_get_contents('php://input');
|
||||
$input = json_decode($inputJSON, TRUE);
|
||||
$mxid = NULL;
|
||||
$localpart = NULL;
|
||||
if (isset($input["user"])) {
|
||||
if (isset($input["user"]["localpart"])) {
|
||||
$localpart = $input["user"]["localpart"];
|
||||
$loginRequester = LoginRequester::MXISD;
|
||||
} elseif (isset($input["user"]["id"])) {
|
||||
// compatibility for matrix-synapse-rest-auth
|
||||
$mxid = $input["user"]["id"];
|
||||
$loginRequester = LoginRequester::RestAuth;
|
||||
} elseif (isset($input["user"]["mxid"])) {
|
||||
// compatibility for mxisd
|
||||
$mxid = $input["user"]["mxid"];
|
||||
$loginRequester = LoginRequester::MXISD;
|
||||
}
|
||||
}
|
||||
|
||||
// prefer the localpart attribute of mxisd. But in case of matrix-synapse-rest-auth
|
||||
// we have to parse it on our own
|
||||
if (empty($localpart) && !empty($mxid)) {
|
||||
// A mxid would start with an @ so we start at the 2. position
|
||||
$sepPos = strpos($mxid,':', 1);
|
||||
if ($sepPos === false) {
|
||||
// : not found. Assume mxid is localpart
|
||||
// TODO: further checks
|
||||
$localpart = $mxid;
|
||||
} else {
|
||||
$localpart = substr($mxid, 1, strpos($mxid,':') - 1 );
|
||||
}
|
||||
}
|
||||
|
||||
if (empty($localpart)) {
|
||||
throw new Exception ("localpart cannot be identified");
|
||||
}
|
||||
|
||||
$password = NULL;
|
||||
if (isset($input["user"]) && isset($input["user"]["password"])) {
|
||||
$password = $input["user"]["password"];
|
||||
}
|
||||
if (empty($password)) {
|
||||
throw new Exception ("password is not present");
|
||||
}
|
||||
|
||||
$user = $mx_db->getUserForLogin($localpart, $password);
|
||||
if (!$user) {
|
||||
throw new Exception("user not found or password did not match");
|
||||
}
|
||||
$response["auth"]["success"] = true;
|
||||
$response["auth"]["profile"] = [
|
||||
"display_name" => $user["first_name"] . " " . $user["last_name"],
|
||||
"three_pids" => [
|
||||
[
|
||||
"medium" => "email",
|
||||
"address" => $user["email"],
|
||||
],
|
||||
],
|
||||
];
|
||||
|
||||
switch ($loginRequester) {
|
||||
case LoginRequester::RestAuth:
|
||||
$response["auth"]["mxid"] = $mxid;
|
||||
break;
|
||||
case LoginRequester::MXISD;
|
||||
$response["auth"]["id"] = [
|
||||
"type" => "localpart",
|
||||
"value" => $localpart,
|
||||
];
|
||||
break;
|
||||
default:
|
||||
// only return that it was successful.
|
||||
// we do not know how the data shall be transmitted so we do nothing with it
|
||||
$response["auth"]["success"] = false;
|
||||
break;
|
||||
}
|
||||
} catch (Exception $e) {
|
||||
error_log("Auth failed with error: " . $e->getMessage());
|
||||
$response["auth"]["error"] = $e->getMessage();
|
||||
}
|
||||
print (json_encode($response, JSON_PRETTY_PRINT) . "\n");
|
||||
?>
|
||||
Reference in New Issue
Block a user