45 lines
1.1 KiB
PHP
45 lines
1.1 KiB
PHP
<?php
|
|
set_time_limit(0); //scanning can take ages
|
|
session_write_close();
|
|
|
|
$user = OC_User::getUser();
|
|
$eventSource = new OC_EventSource();
|
|
$listener = new UpgradeListener($eventSource);
|
|
$legacy = new \OC\Files\Cache\Legacy($user);
|
|
|
|
if ($legacy->hasItems()) {
|
|
OC_Hook::connect('\OC\Files\Cache\Upgrade', 'migrate_path', $listener, 'upgradePath');
|
|
|
|
OC_DB::beginTransaction();
|
|
$upgrade = new \OC\Files\Cache\Upgrade($legacy);
|
|
$count = $legacy->getCount();
|
|
$eventSource->send('total', $count);
|
|
$upgrade->upgradePath('/' . $user . '/files');
|
|
OC_DB::commit();
|
|
}
|
|
\OC\Files\Cache\Upgrade::upgradeDone($user);
|
|
$eventSource->send('done', true);
|
|
$eventSource->close();
|
|
|
|
class UpgradeListener {
|
|
/**
|
|
* @var OC_EventSource $eventSource
|
|
*/
|
|
private $eventSource;
|
|
|
|
private $count = 0;
|
|
private $lastSend = 0;
|
|
|
|
public function __construct($eventSource) {
|
|
$this->eventSource = $eventSource;
|
|
}
|
|
|
|
public function upgradePath($path) {
|
|
$this->count++;
|
|
if ($this->count > ($this->lastSend + 5)) {
|
|
$this->lastSend = $this->count;
|
|
$this->eventSource->send('count', $this->count);
|
|
}
|
|
}
|
|
}
|