2016-11-17 14:14:13 +03:00
|
|
|
<?php
|
|
|
|
/**
|
|
|
|
* @copyright Copyright (c) 2016 Bjoern Schiessle <bjoern@schiessle.org>
|
2016-11-18 12:10:05 +03:00
|
|
|
* @copyright Copyright (c) 2016 Lukas Reschke <lukas@statuscode.ch>
|
2016-11-17 14:14:13 +03:00
|
|
|
*
|
|
|
|
* @license GNU AGPL version 3 or any later version
|
|
|
|
*
|
|
|
|
* This program is free software: you can redistribute it and/or modify
|
|
|
|
* it under the terms of the GNU Affero General Public License as
|
|
|
|
* published by the Free Software Foundation, either version 3 of the
|
|
|
|
* License, or (at your option) any later version.
|
|
|
|
*
|
|
|
|
* This program is distributed in the hope that it will be useful,
|
|
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
|
|
* GNU Affero General Public License for more details.
|
|
|
|
*
|
|
|
|
* You should have received a copy of the GNU Affero General Public License
|
|
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
*
|
|
|
|
*/
|
|
|
|
|
|
|
|
namespace OCA\LookupServerConnector;
|
|
|
|
|
|
|
|
use OC\Accounts\AccountManager;
|
2016-11-18 12:10:05 +03:00
|
|
|
use OC\Security\IdentityProof\Signer;
|
2016-11-18 17:33:51 +03:00
|
|
|
use OCA\LookupServerConnector\BackgroundJobs\RetryJob;
|
|
|
|
use OCP\BackgroundJob\IJobList;
|
2016-11-17 19:00:25 +03:00
|
|
|
use OCP\Http\Client\IClientService;
|
2017-05-10 10:44:02 +03:00
|
|
|
use OCP\IConfig;
|
2016-11-17 14:14:13 +03:00
|
|
|
use OCP\IUser;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Class UpdateLookupServer
|
|
|
|
*
|
|
|
|
* @package OCA\LookupServerConnector
|
|
|
|
*/
|
|
|
|
class UpdateLookupServer {
|
2016-11-18 12:10:05 +03:00
|
|
|
/** @var AccountManager */
|
2016-11-17 14:14:13 +03:00
|
|
|
private $accountManager;
|
2016-11-17 19:00:25 +03:00
|
|
|
/** @var IClientService */
|
|
|
|
private $clientService;
|
2016-11-18 12:10:05 +03:00
|
|
|
/** @var Signer */
|
|
|
|
private $signer;
|
2016-11-18 17:33:51 +03:00
|
|
|
/** @var IJobList */
|
|
|
|
private $jobList;
|
2016-11-17 19:00:25 +03:00
|
|
|
/** @var string URL point to lookup server */
|
2017-05-10 10:44:02 +03:00
|
|
|
private $lookupServer;
|
2019-01-07 14:15:11 +03:00
|
|
|
/** @var bool */
|
|
|
|
private $lookupServerEnabled;
|
2016-11-17 19:00:25 +03:00
|
|
|
|
2016-11-17 14:14:13 +03:00
|
|
|
/**
|
|
|
|
* @param AccountManager $accountManager
|
2016-11-17 19:00:25 +03:00
|
|
|
* @param IClientService $clientService
|
2016-11-18 12:10:05 +03:00
|
|
|
* @param Signer $signer
|
2016-11-18 17:33:51 +03:00
|
|
|
* @param IJobList $jobList
|
2017-05-10 10:44:02 +03:00
|
|
|
* @param IConfig $config
|
2016-11-17 14:14:13 +03:00
|
|
|
*/
|
2016-11-17 19:00:25 +03:00
|
|
|
public function __construct(AccountManager $accountManager,
|
2016-11-18 12:10:05 +03:00
|
|
|
IClientService $clientService,
|
2016-11-18 17:33:51 +03:00
|
|
|
Signer $signer,
|
2017-02-22 21:24:26 +03:00
|
|
|
IJobList $jobList,
|
2017-05-10 10:44:02 +03:00
|
|
|
IConfig $config) {
|
2016-11-17 19:00:25 +03:00
|
|
|
$this->accountManager = $accountManager;
|
|
|
|
$this->clientService = $clientService;
|
2016-11-18 12:10:05 +03:00
|
|
|
$this->signer = $signer;
|
2016-11-18 17:33:51 +03:00
|
|
|
$this->jobList = $jobList;
|
2017-05-10 10:44:02 +03:00
|
|
|
|
2018-10-17 14:09:11 +03:00
|
|
|
if($config->getSystemValue('has_internet_connection', true) === false) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2019-03-04 21:12:46 +03:00
|
|
|
$this->lookupServerEnabled = $config->getAppValue('files_sharing', 'lookupServerUploadEnabled', 'yes') === 'yes';
|
2019-01-07 14:15:11 +03:00
|
|
|
|
2017-05-10 10:44:02 +03:00
|
|
|
$this->lookupServer = $config->getSystemValue('lookup_server', 'https://lookup.nextcloud.com');
|
2018-10-17 14:09:11 +03:00
|
|
|
if(!empty($this->lookupServer)) {
|
|
|
|
$this->lookupServer = rtrim($this->lookupServer, '/');
|
|
|
|
$this->lookupServer .= '/users';
|
|
|
|
}
|
2016-11-17 14:14:13 +03:00
|
|
|
}
|
|
|
|
|
2016-11-18 12:10:05 +03:00
|
|
|
/**
|
|
|
|
* @param IUser $user
|
|
|
|
*/
|
2016-11-17 14:14:13 +03:00
|
|
|
public function userUpdated(IUser $user) {
|
2019-01-07 14:15:11 +03:00
|
|
|
|
|
|
|
if (!$this->shouldUpdateLookupServer()) {
|
2018-10-17 14:09:11 +03:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2016-11-17 14:14:13 +03:00
|
|
|
$userData = $this->accountManager->getUser($user);
|
|
|
|
$publicData = [];
|
|
|
|
|
2016-11-17 19:00:25 +03:00
|
|
|
foreach ($userData as $key => $data) {
|
2016-11-17 14:14:13 +03:00
|
|
|
if ($data['scope'] === AccountManager::VISIBILITY_PUBLIC) {
|
2016-11-17 19:00:25 +03:00
|
|
|
$publicData[$key] = $data;
|
2016-11-17 14:14:13 +03:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2017-02-23 14:27:18 +03:00
|
|
|
$this->sendToLookupServer($user, $publicData);
|
2016-11-17 14:14:13 +03:00
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* send public user data to the lookup server
|
|
|
|
*
|
2016-11-17 19:00:25 +03:00
|
|
|
* @param IUser $user
|
2016-11-17 14:14:13 +03:00
|
|
|
* @param array $publicData
|
|
|
|
*/
|
2016-11-18 12:10:05 +03:00
|
|
|
protected function sendToLookupServer(IUser $user, array $publicData) {
|
2017-02-23 14:27:18 +03:00
|
|
|
|
|
|
|
$dataArray = ['federationId' => $user->getCloudId()];
|
|
|
|
|
|
|
|
if (!empty($publicData)) {
|
|
|
|
$dataArray['name'] = isset($publicData[AccountManager::PROPERTY_DISPLAYNAME]) ? $publicData[AccountManager::PROPERTY_DISPLAYNAME]['value'] : '';
|
|
|
|
$dataArray['email'] = isset($publicData[AccountManager::PROPERTY_EMAIL]) ? $publicData[AccountManager::PROPERTY_EMAIL]['value'] : '';
|
|
|
|
$dataArray['address'] = isset($publicData[AccountManager::PROPERTY_ADDRESS]) ? $publicData[AccountManager::PROPERTY_ADDRESS]['value'] : '';
|
|
|
|
$dataArray['website'] = isset($publicData[AccountManager::PROPERTY_WEBSITE]) ? $publicData[AccountManager::PROPERTY_WEBSITE]['value'] : '';
|
|
|
|
$dataArray['twitter'] = isset($publicData[AccountManager::PROPERTY_TWITTER]) ? $publicData[AccountManager::PROPERTY_TWITTER]['value'] : '';
|
|
|
|
$dataArray['phone'] = isset($publicData[AccountManager::PROPERTY_PHONE]) ? $publicData[AccountManager::PROPERTY_PHONE]['value'] : '';
|
2017-04-28 19:05:55 +03:00
|
|
|
$dataArray['twitter_signature'] = isset($publicData[AccountManager::PROPERTY_TWITTER]['signature']) ? $publicData[AccountManager::PROPERTY_TWITTER]['signature'] : '';
|
|
|
|
$dataArray['website_signature'] = isset($publicData[AccountManager::PROPERTY_WEBSITE]['signature']) ? $publicData[AccountManager::PROPERTY_WEBSITE]['signature'] : '';
|
2017-04-21 17:36:26 +03:00
|
|
|
$dataArray['verificationStatus'] =
|
|
|
|
[
|
|
|
|
AccountManager::PROPERTY_WEBSITE => isset($publicData[AccountManager::PROPERTY_WEBSITE]) ? $publicData[AccountManager::PROPERTY_WEBSITE]['verified'] : '',
|
|
|
|
AccountManager::PROPERTY_TWITTER => isset($publicData[AccountManager::PROPERTY_TWITTER]) ? $publicData[AccountManager::PROPERTY_TWITTER]['verified'] : '',
|
|
|
|
];
|
2017-02-23 14:27:18 +03:00
|
|
|
}
|
|
|
|
|
2016-11-18 12:10:05 +03:00
|
|
|
$dataArray = $this->signer->sign('lookupserver', $dataArray, $user);
|
2016-11-17 19:00:25 +03:00
|
|
|
$httpClient = $this->clientService->newClient();
|
2016-11-18 17:33:51 +03:00
|
|
|
try {
|
2017-02-23 14:27:18 +03:00
|
|
|
if (empty($publicData)) {
|
|
|
|
$httpClient->delete($this->lookupServer,
|
|
|
|
[
|
|
|
|
'body' => json_encode($dataArray),
|
|
|
|
'timeout' => 10,
|
|
|
|
'connect_timeout' => 3,
|
|
|
|
]
|
|
|
|
);
|
|
|
|
} else {
|
|
|
|
$httpClient->post($this->lookupServer,
|
|
|
|
[
|
|
|
|
'body' => json_encode($dataArray),
|
|
|
|
'timeout' => 10,
|
|
|
|
'connect_timeout' => 3,
|
|
|
|
]
|
|
|
|
);
|
|
|
|
}
|
2016-11-18 17:33:51 +03:00
|
|
|
} catch (\Exception $e) {
|
|
|
|
$this->jobList->add(RetryJob::class,
|
|
|
|
[
|
|
|
|
'dataArray' => $dataArray,
|
|
|
|
'retryNo' => 0,
|
|
|
|
]
|
|
|
|
);
|
|
|
|
}
|
2016-11-17 19:00:25 +03:00
|
|
|
}
|
2019-01-07 14:15:11 +03:00
|
|
|
|
|
|
|
/**
|
|
|
|
* check if we should update the lookup server, we only do it if
|
|
|
|
*
|
|
|
|
* * we have a valid URL
|
|
|
|
* * the lookup server update was enabled by the admin
|
|
|
|
*
|
|
|
|
* @return bool
|
|
|
|
*/
|
|
|
|
private function shouldUpdateLookupServer() {
|
2019-04-09 13:28:06 +03:00
|
|
|
return $this->lookupServerEnabled && !empty($this->lookupServer);
|
2019-01-07 14:15:11 +03:00
|
|
|
}
|
|
|
|
|
2016-11-17 14:14:13 +03:00
|
|
|
}
|