You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
272 lines
8.2 KiB
272 lines
8.2 KiB
<?php
|
|
use Symfony\Component\HttpFoundation\Request;
|
|
use Symfony\Component\HttpFoundation\Response;
|
|
|
|
use Monolog\Logger;
|
|
|
|
class API {
|
|
|
|
public $http;
|
|
|
|
public function __construct() {
|
|
$this->http = new Telegraph\HTTP();
|
|
}
|
|
|
|
private function respond(Response $response, $code, $params, $headers=[]) {
|
|
$response->setStatusCode($code);
|
|
foreach($headers as $k=>$v) {
|
|
$response->headers->set($k, $v);
|
|
}
|
|
$response->headers->set('Content-Type', 'application/json');
|
|
$response->setContent(json_encode($params));
|
|
return $response;
|
|
}
|
|
|
|
private static function toHtmlEntities($input) {
|
|
return mb_convert_encoding($input, 'HTML-ENTITIES', mb_detect_encoding($input));
|
|
}
|
|
|
|
private static function generateStatusToken() {
|
|
$str = dechex(date('y'));
|
|
$chs = '0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ';
|
|
$len = strlen($chs);
|
|
for($i = 0; $i < 16; $i++) {
|
|
$str .= $chs[mt_rand(0, $len - 1)];
|
|
}
|
|
return $str;
|
|
}
|
|
|
|
public function webmention(Request $request, Response $response) {
|
|
# Require the token parameter
|
|
if(!$token=$request->get('token')) {
|
|
return $this->respond($response, 401, [
|
|
'error' => 'authentication_required',
|
|
'error_description' => 'A token is required to use the API'
|
|
]);
|
|
}
|
|
|
|
# Require source and target or target_domain parameters
|
|
$target = $target_domain = null;
|
|
if((!$source=$request->get('source')) || ((!$target=$request->get('target')) && (!$target_domain=$request->get('target_domain')))) {
|
|
return $this->respond($response, 400, [
|
|
'error' => 'missing_parameters',
|
|
'error_description' => 'The source or target or target_domain parameters were missing'
|
|
]);
|
|
}
|
|
if($target && $target_domain) {
|
|
return $this->respond($response, 400, [
|
|
'error' => 'invalid_parameter',
|
|
'error_description' => 'Can\'t provide both target and target_domain together'
|
|
]);
|
|
}
|
|
|
|
$urlregex = '/^https?:\/\/[^ ]+\.[^ ]+$/';
|
|
$domainregex = '/^[^ ]+$/';
|
|
|
|
# Verify source, target, and callback are URLs
|
|
$callback = $request->get('callback');
|
|
if(!preg_match($urlregex, $source) ||
|
|
(!preg_match($urlregex, $target) && !preg_match($domainregex, $target_domain)) ||
|
|
($callback && !preg_match($urlregex, $callback))) {
|
|
return $this->respond($response, 400, [
|
|
'error' => 'invalid_parameter',
|
|
'error_description' => 'The source, target, or callback parameters were invalid'
|
|
]);
|
|
}
|
|
|
|
# Verify the token is valid
|
|
$role = ORM::for_table('roles')->where('token', $token)->find_one();
|
|
|
|
if(!$role) {
|
|
return $this->respond($response, 401, [
|
|
'error' => 'invalid_token',
|
|
'error_description' => 'The token provided is not valid'
|
|
]);
|
|
}
|
|
|
|
# Synchronously check the source URL and verify that it actually contains
|
|
# a link to the target. This way we prevent this API from sending known invalid mentions.
|
|
$sourceData = $this->http->get($source);
|
|
|
|
$doc = new DOMDocument();
|
|
@$doc->loadHTML(self::toHtmlEntities($sourceData['body']));
|
|
|
|
if(!$doc) {
|
|
return $this->respond($response, 400, [
|
|
'error' => 'source_not_html',
|
|
'error_description' => 'The source document could not be parsed as HTML'
|
|
]);
|
|
}
|
|
|
|
$xpath = new DOMXPath($doc);
|
|
|
|
$found = [];
|
|
foreach($xpath->query('//a[@href]') as $href) {
|
|
$url = $href->getAttribute('href');
|
|
if($target) {
|
|
# target parameter was provided
|
|
if($url == $target) {
|
|
$found[$url] = null;
|
|
}
|
|
} elseif($target_domain) {
|
|
# target_domain parameter was provided
|
|
$domain = parse_url($url, PHP_URL_HOST);
|
|
if($domain && ($domain == $target_domain || str_ends_with($domain, '.' . $target_domain))) {
|
|
$found[$url] = null;
|
|
}
|
|
}
|
|
}
|
|
|
|
if(!$found) {
|
|
return $this->respond($response, 400, [
|
|
'error' => 'no_link_found',
|
|
'error_description' => 'The source document does not have a link to the target URL or domain'
|
|
]);
|
|
}
|
|
|
|
# Everything checked out, so write the webmention to the log and queue a job to start sending
|
|
# TODO: database transaction?
|
|
|
|
$statusURLs = [];
|
|
foreach($found as $url=>$_) {
|
|
$w = ORM::for_table('webmentions')->create();
|
|
$w->site_id = $role->site_id;
|
|
$w->created_by = $role->user_id;
|
|
$w->created_at = date('Y-m-d H:i:s');
|
|
$w->token = self::generateStatusToken();
|
|
$w->source = $source;
|
|
$w->target = $url;
|
|
$w->vouch = $request->get('vouch');
|
|
$w->callback = $callback;
|
|
$w->save();
|
|
|
|
q()->queue('Telegraph\Webmention', 'send', [$w->id]);
|
|
|
|
$statusURLs[] = Config::$base . 'webmention/' . $w->token;
|
|
}
|
|
|
|
if ($target) {
|
|
$body = [
|
|
'status' => 'queued',
|
|
'location' => $statusURLs[0]
|
|
];
|
|
$headers = ['Location' => $statusURLs[0]];
|
|
} else {
|
|
$body = [
|
|
'status' => 'queued',
|
|
'location' => $statusURLs
|
|
];
|
|
$headers = [];
|
|
}
|
|
return $this->respond($response, 201, $body, $headers);
|
|
}
|
|
|
|
public function superfeedr_tracker(Request $request, Response $response, $args) {
|
|
logger()->addInfo("Got payload from superfeedr: " . $request->getContent());
|
|
|
|
$input = json_decode($request->getContent(), true);
|
|
|
|
# Require the code parameter
|
|
if(!$token=$args['token']) {
|
|
return $this->respond($response, 401, [
|
|
'error' => 'authentication_required',
|
|
'error_description' => 'A token is required to use the API'
|
|
]);
|
|
}
|
|
|
|
# Verify the token is valid
|
|
$role = ORM::for_table('roles')->where('token', $token)->find_one();
|
|
|
|
if(!$role) {
|
|
return $this->respond($response, 401, [
|
|
'error' => 'invalid_token',
|
|
'error_description' => 'The token provided is not valid'
|
|
]);
|
|
}
|
|
|
|
$site = ORM::for_table('sites')->where('id', $role->site_id)->find_one();
|
|
|
|
if(($items = $input['items'])
|
|
&& is_array($items)
|
|
&& array_key_exists(0, $items)
|
|
&& ($item = $items[0])
|
|
&& array_key_exists('permalinkUrl', $item)) {
|
|
$url = $item['permalinkUrl'];
|
|
|
|
$domain = parse_url($site->url, PHP_URL_HOST);
|
|
|
|
# Create a new request that looks like a request to the API with a target_domain parameter
|
|
$new_request = new Request(['token' => $token, 'source' => $url, 'target_domain' => $domain]);
|
|
|
|
return $this->webmention($new_request, $response);
|
|
|
|
} else {
|
|
return $this->respond($response, 200, [
|
|
'error' => 'invalid_request',
|
|
'error_description' => 'Could not find source URL from the superfeedr payload'
|
|
]);
|
|
}
|
|
}
|
|
|
|
public function webmention_status(Request $request, Response $response, $args) {
|
|
|
|
$webmention = ORM::for_table('webmentions')->where('token', $args['code'])->find_one();
|
|
|
|
if(!$webmention) {
|
|
return $this->respond($response, 404, [
|
|
'status' => 'not_found',
|
|
]);
|
|
}
|
|
|
|
$status = ORM::for_table('webmention_status')->where('webmention_id', $webmention->id)->order_by_desc('created_at')->find_one();
|
|
|
|
$statusURL = Config::$base . 'webmention/' . $webmention->token;
|
|
|
|
if(!$status) {
|
|
$code = 'queued';
|
|
} else {
|
|
$code = $status->status;
|
|
}
|
|
|
|
$data = [
|
|
'source' => $webmention->source,
|
|
'target' => $webmention->target,
|
|
'status' => $code,
|
|
];
|
|
|
|
if($webmention->webmention_endpoint) {
|
|
$data['type'] = 'webmention';
|
|
$data['endpoint'] = $webmention->webmention_endpoint;
|
|
}
|
|
if($webmention->pingback_endpoint) {
|
|
$data['type'] = 'pingback';
|
|
$data['endpoint'] = $webmention->pingback_endpoint;
|
|
}
|
|
|
|
switch($code) {
|
|
case 'queued':
|
|
$summary = 'The webmention is still in the processing queue';
|
|
break;
|
|
case 'not_supported':
|
|
$summary = 'No webmention or pingback endpoint were found at the target';
|
|
break;
|
|
case 'accepted':
|
|
$summary = 'The '.$data['type'].' request was accepted';
|
|
break;
|
|
default:
|
|
$summary = false;
|
|
}
|
|
|
|
if($status && $status->http_code)
|
|
$data['http_code'] = (int)$status->http_code;
|
|
|
|
if($summary)
|
|
$data['summary'] = $summary;
|
|
|
|
if($webmention->complete == 0)
|
|
$data['location'] = $statusURL;
|
|
|
|
return $this->respond($response, 200, $data);
|
|
}
|
|
|
|
}
|