Some more warnings and erors are fixed
This commit is contained in:
parent
61cbcf85a1
commit
3a840aa22d
4 changed files with 43 additions and 19 deletions
|
@ -304,7 +304,7 @@ class GServer
|
||||||
Logger::info('Set failed status for existing server', ['url' => $url]);
|
Logger::info('Set failed status for existing server', ['url' => $url]);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
DBA::insert('gserver', ['url' => $url, 'nurl' => Strings::normaliseLink($url),
|
self::insert(['url' => $url, 'nurl' => Strings::normaliseLink($url),
|
||||||
'network' => Protocol::PHANTOM, 'created' => DateTimeFormat::utcNow(),
|
'network' => Protocol::PHANTOM, 'created' => DateTimeFormat::utcNow(),
|
||||||
'failed' => true, 'last_failure' => DateTimeFormat::utcNow()]);
|
'failed' => true, 'last_failure' => DateTimeFormat::utcNow()]);
|
||||||
Logger::info('Set failed status for new server', ['url' => $url]);
|
Logger::info('Set failed status for new server', ['url' => $url]);
|
||||||
|
@ -583,7 +583,7 @@ class GServer
|
||||||
$gserver = DBA::selectFirst('gserver', ['network'], ['nurl' => Strings::normaliseLink($url)]);
|
$gserver = DBA::selectFirst('gserver', ['network'], ['nurl' => Strings::normaliseLink($url)]);
|
||||||
if (!DBA::isResult($gserver)) {
|
if (!DBA::isResult($gserver)) {
|
||||||
$serverdata['created'] = DateTimeFormat::utcNow();
|
$serverdata['created'] = DateTimeFormat::utcNow();
|
||||||
$ret = DBA::insert('gserver', $serverdata);
|
$ret = self::insert($serverdata);
|
||||||
$id = DBA::lastInsertId();
|
$id = DBA::lastInsertId();
|
||||||
} else {
|
} else {
|
||||||
$ret = self::update($serverdata, ['nurl' => $serverdata['nurl']]);
|
$ret = self::update($serverdata, ['nurl' => $serverdata['nurl']]);
|
||||||
|
@ -2259,6 +2259,7 @@ class GServer
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
* Update rows in the gserver table.
|
||||||
* Enforces gserver table field maximum sizes to avoid "Data too long" database errors
|
* Enforces gserver table field maximum sizes to avoid "Data too long" database errors
|
||||||
*
|
*
|
||||||
* @param array $fields
|
* @param array $fields
|
||||||
|
@ -2274,4 +2275,22 @@ class GServer
|
||||||
|
|
||||||
return DBA::update('gserver', $fields, $condition);
|
return DBA::update('gserver', $fields, $condition);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Insert a row into the gserver table.
|
||||||
|
* Enforces gserver table field maximum sizes to avoid "Data too long" database errors
|
||||||
|
*
|
||||||
|
* @param array $fields
|
||||||
|
* @param int $duplicate_mode What to do on a duplicated entry
|
||||||
|
*
|
||||||
|
* @return bool
|
||||||
|
*
|
||||||
|
* @throws Exception
|
||||||
|
*/
|
||||||
|
public static function insert(array $fields, int $duplicate_mode = Database::INSERT_DEFAULT): bool
|
||||||
|
{
|
||||||
|
$fields = DI::dbaDefinition()->truncateFieldsForTable('gserver', $fields);
|
||||||
|
|
||||||
|
return DBA::insert('gserver', $fields, $duplicate_mode);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -2674,10 +2674,12 @@ class Item
|
||||||
'unseen' => 1,
|
'unseen' => 1,
|
||||||
];
|
];
|
||||||
|
|
||||||
|
if (in_array($activity, [Activity::LIKE, Activity::DISLIKE])) {
|
||||||
$signed = Diaspora::createLikeSignature($uid, $new_item);
|
$signed = Diaspora::createLikeSignature($uid, $new_item);
|
||||||
if (!empty($signed)) {
|
if (!empty($signed)) {
|
||||||
$new_item['diaspora_signed_text'] = json_encode($signed);
|
$new_item['diaspora_signed_text'] = json_encode($signed);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
self::insert($new_item, true);
|
self::insert($new_item, true);
|
||||||
|
|
||||||
|
|
|
@ -156,6 +156,8 @@ class HttpClient implements ICanSendHttpRequests
|
||||||
$conf[HttpClientOptions::HEADERS]['Accept'] = HttpClientAccept::DEFAULT;
|
$conf[HttpClientOptions::HEADERS]['Accept'] = HttpClientAccept::DEFAULT;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
$conf['sink'] = tempnam(System::getTempPath(), 'http-');
|
||||||
|
|
||||||
try {
|
try {
|
||||||
$this->logger->debug('http request config.', ['url' => $url, 'method' => $method, 'options' => $conf]);
|
$this->logger->debug('http request config.', ['url' => $url, 'method' => $method, 'options' => $conf]);
|
||||||
|
|
||||||
|
@ -172,6 +174,7 @@ class HttpClient implements ICanSendHttpRequests
|
||||||
$this->logger->info('Invalid Argument for HTTP call.', ['url' => $url, 'method' => $method, 'exception' => $argumentException]);
|
$this->logger->info('Invalid Argument for HTTP call.', ['url' => $url, 'method' => $method, 'exception' => $argumentException]);
|
||||||
return new CurlResult($url, '', ['http_code' => 500], $argumentException->getCode(), $argumentException->getMessage());
|
return new CurlResult($url, '', ['http_code' => 500], $argumentException->getCode(), $argumentException->getMessage());
|
||||||
} finally {
|
} finally {
|
||||||
|
unlink($conf['sink']);
|
||||||
$this->logger->debug('Request stop.', ['url' => $url, 'method' => $method]);
|
$this->logger->debug('Request stop.', ['url' => $url, 'method' => $method]);
|
||||||
$this->profiler->stopRecording();
|
$this->profiler->stopRecording();
|
||||||
}
|
}
|
||||||
|
|
|
@ -287,8 +287,7 @@ class ParseUrl
|
||||||
// Expected form: Content-Type: text/html; charset=ISO-8859-4
|
// Expected form: Content-Type: text/html; charset=ISO-8859-4
|
||||||
if (preg_match('/charset=([a-z0-9-_.\/]+)/i', $curlResult->getContentType(), $matches)) {
|
if (preg_match('/charset=([a-z0-9-_.\/]+)/i', $curlResult->getContentType(), $matches)) {
|
||||||
$charset = trim(trim(trim(array_pop($matches)), ';,'));
|
$charset = trim(trim(trim(array_pop($matches)), ';,'));
|
||||||
}
|
} else {
|
||||||
|
|
||||||
// Then in body that gets precedence
|
// Then in body that gets precedence
|
||||||
// Expected forms:
|
// Expected forms:
|
||||||
// - <meta http-equiv="Content-Type" content="text/html; charset=utf-8">
|
// - <meta http-equiv="Content-Type" content="text/html; charset=utf-8">
|
||||||
|
@ -302,6 +301,7 @@ class ParseUrl
|
||||||
$charset = trim(trim(trim(array_pop($matches)), ';,'));
|
$charset = trim(trim(trim(array_pop($matches)), ';,'));
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
}
|
||||||
|
|
||||||
$siteinfo['charset'] = $charset;
|
$siteinfo['charset'] = $charset;
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue