http = new p3k\HTTP(self::useragent()); if(Config::$cache && class_exists('Memcache')) { $this->mc = new Memcache(); $this->mc->addServer('127.0.0.1'); } } public static function debug($msg, $header='X-Parse-Debug') { syslog(LOG_INFO, $msg); if(array_key_exists('REMOTE_ADDR', $_SERVER)) header($header . ": " . $msg); } 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'); $opts = JSON_UNESCAPED_SLASHES; if($this->_pretty) $opts += JSON_PRETTY_PRINT; $response->setContent(json_encode($params, $opts)."\n"); return $response; } private static function toHtmlEntities($input) { return mb_convert_encoding($input, 'HTML-ENTITIES', mb_detect_encoding($input)); } public function parse(Request $request, Response $response) { $opts = []; if($request->get('timeout')) { // We might make 2 HTTP requests, so each request gets half the desired timeout $opts['timeout'] = $request->get('timeout') / 2; } if($request->get('max_redirects') !== null) { $opts['max_redirects'] = (int)$request->get('max_redirects'); } if($request->get('pretty')) { $this->_pretty = true; } $url = $request->get('url'); $html = $request->get('html'); if(!$url && !$html) { return $this->respond($response, 400, [ 'error' => 'missing_url', 'error_description' => 'Provide a URL or HTML to fetch' ]); } if($html) { // If HTML is provided in the request, parse that, and use the URL provided as the base URL for mf2 resolving $result['body'] = $html; $result['url'] = $url; $result['code'] = null; } else { $fetcher = new p3k\XRay\Fetcher($this->http); $fields = [ 'twitter_api_key','twitter_api_secret','twitter_access_token','twitter_access_token_secret', 'github_access_token', 'token' ]; foreach($fields as $f) { if($v=$request->get($f)) $opts[$f] = $v; } $result = $fetcher->fetch($url, $opts); if(!empty($result['error'])) { $error_code = isset($result['error_code']) ? $result['error_code'] : 200; unset($result['error_code']); return $this->respond($response, $error_code, $result); } } $parser = new p3k\XRay\Parser($this->http); $parsed = $parser->parse($result['body'], $result['url'], $opts); // Allow the parser to override the HTTP response code, e.g. a meta-equiv tag if(isset($parsed['code'])) $result['code'] = $parsed['code']; $data = [ 'data' => $parsed['data'], 'url' => $result['url'], 'code' => $result['code'] ]; if($request->get('include_original') && isset($parsed['original'])) $data['original'] = $parsed['original']; return $this->respond($response, 200, $data); // attempt to parse the page as HTML $doc = new DOMDocument(); @$doc->loadHTML(self::toHtmlEntities($result['body'])); if(!$doc) { return $this->respond($response, 200, [ 'error' => 'invalid_content', 'error_description' => 'The document could not be parsed as HTML' ]); } $xpath = new DOMXPath($doc); // Check for meta http equiv and replace the status code if present foreach($xpath->query('//meta[translate(@http-equiv,\'STATUS\',\'status\')=\'status\']') as $el) { $equivStatus = ''.$el->getAttribute('content'); if($equivStatus && is_string($equivStatus)) { if(preg_match('/^(\d+)/', $equivStatus, $match)) { $result['code'] = (int)$match[1]; } } } // If a target parameter was provided, make sure a link to it exists on the page if($target=$request->get('target')) { $found = []; if($target) { self::xPathFindNodeWithAttribute($xpath, 'a', 'href', function($u) use($target, &$found){ if($u == $target) { $found[$u] = null; } }); self::xPathFindNodeWithAttribute($xpath, 'img', 'src', function($u) use($target, &$found){ if($u == $target) { $found[$u] = null; } }); self::xPathFindNodeWithAttribute($xpath, 'video', 'src', function($u) use($target, &$found){ if($u == $target) { $found[$u] = null; } }); self::xPathFindNodeWithAttribute($xpath, 'audio', 'src', function($u) use($target, &$found){ if($u == $target) { $found[$u] = null; } }); } if(!$found) { return $this->respond($response, 200, [ 'error' => 'no_link_found', 'error_description' => 'The source document does not have a link to the target URL', 'url' => $result['url'], 'code' => $result['code'], ]); } } // If the URL has a fragment ID, find the DOM starting at that node and parse it instead $html = $result['body']; $fragment = parse_url($url, PHP_URL_FRAGMENT); if($fragment) { $fragElement = self::xPathGetElementById($xpath, $fragment); if($fragElement) { $html = $doc->saveHTML($fragElement); $foundFragment = true; } else { $foundFragment = false; } } // Now start pulling in the data from the page. Start by looking for microformats2 $mf2 = mf2\Parse($html, $result['url']); if($mf2 && count($mf2['items']) > 0) { $data = Formats\Mf2::parse($mf2, $result['url'], $this->http); if($data) { if($fragment) { $data['info'] = [ 'found_fragment' => $foundFragment ]; } if($request->get('include_original')) $data['original'] = $html; $data['url'] = $result['url']; // this will be the effective URL after following redirects $data['code'] = $result['code']; return $this->respond($response, 200, $data); } } // TODO: look for other content like OEmbed or other known services later return $this->respond($response, 200, [ 'data' => [ 'type' => 'unknown', ], 'url' => $result['url'], 'code' => $result['code'] ]); } private static function xPathFindNodeWithAttribute($xpath, $node, $attr, $callback) { foreach($xpath->query('//'.$node.'[@'.$attr.']') as $el) { $v = $el->getAttribute($attr); $callback($v); } } private static function xPathGetElementById($xpath, $id) { $element = null; foreach($xpath->query("//*[@id='$id']") as $el) { $element = $el; } return $element; } private function parseTwitterURL(&$request, &$response, $url, $match) { $fields = ['twitter_api_key','twitter_api_secret','twitter_access_token','twitter_access_token_secret']; $creds = []; foreach($fields as $f) { if($v=$request->get($f)) $creds[$f] = $v; } $data = false; if(count($creds) == 4) { list($data, $parsed) = Formats\Twitter::parse($url, $match[1], $creds); } elseif(count($creds) > 0) { // If only some Twitter credentials were present, return an error return $this->respond($response, 400, [ 'error' => 'missing_parameters', 'error_description' => 'All 4 Twitter credentials must be included in the request' ]); } else { // Accept Tweet JSON and parse that if provided $json = $request->get('json'); if($json) { list($data, $parsed) = Formats\Twitter::parse($url, $match[1], null, $json); } // Skip parsing from the Twitter API if they didn't include credentials } if($data) { if($request->get('include_original')) $data['original'] = $parsed; $data['url'] = $url; $data['code'] = 200; return $this->respond($response, 200, $data); } else { return $this->respond($response, 200, [ 'data' => [ 'type' => 'unknown' ], 'url' => $url, 'code' => 0 ]); } } private function parseGitHubURL(&$request, &$response, $url) { $fields = ['github_access_token']; $creds = []; foreach($fields as $f) { if($v=$request->get($f)) $creds[$f] = $v; } $data = false; $json = $request->get('json'); if($json) { // Accept GitHub JSON and parse that if provided list($data, $json, $code) = Formats\GitHub::parse($this->http, $url, null, $json); } else { // Otherwise fetch the post unauthenticated or with the provided access token list($data, $json, $code) = Formats\GitHub::parse($this->http, $url, $creds); } if($data) { if($request->get('include_original')) $data['original'] = $json; $data['url'] = $url; $data['code'] = $code; return $this->respond($response, 200, $data); } else { return $this->respond($response, 200, [ 'data' => [ 'type' => 'unknown' ], 'url' => $url, 'code' => $code ]); } } }