123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172 |
- <?php
- set_time_limit(0); //scanning can take ages
- \OC::$session->close();
- $force = (isset($_GET['force']) and ($_GET['force'] === 'true'));
- $dir = isset($_GET['dir']) ? $_GET['dir'] : '';
- if (isset($_GET['users'])) {
- OC_JSON::checkAdminUser();
- if ($_GET['users'] === 'all') {
- $users = OC_User::getUsers();
- } else {
- $users = json_decode($_GET['users']);
- }
- } else {
- $users = array(OC_User::getUser());
- }
- $eventSource = new OC_EventSource();
- $listener = new ScanListener($eventSource);
- foreach ($users as $user) {
- $eventSource->send('user', $user);
- $scanner = new \OC\Files\Utils\Scanner($user);
- $scanner->listen('\OC\Files\Utils\Scanner', 'scanFile', array($listener, 'file'));
- $scanner->listen('\OC\Files\Utils\Scanner', 'scanFolder', array($listener, 'folder'));
- if ($force) {
- $scanner->scan($dir);
- } else {
- $scanner->backgroundScan($dir);
- }
- }
- $eventSource->send('done', $listener->getCount());
- $eventSource->close();
- class ScanListener {
- private $fileCount = 0;
- private $lastCount = 0;
- /**
- * @var \OC_EventSource event source to pass events to
- */
- private $eventSource;
- /**
- * @param \OC_EventSource $eventSource
- */
- public function __construct($eventSource) {
- $this->eventSource = $eventSource;
- }
- /**
- * @param string $path
- */
- public function folder($path) {
- $this->eventSource->send('folder', $path);
- }
- public function file() {
- $this->fileCount++;
- if ($this->fileCount > $this->lastCount + 20) { //send a count update every 20 files
- $this->lastCount = $this->fileCount;
- $this->eventSource->send('count', $this->fileCount);
- }
- }
- public function getCount() {
- return $this->fileCount;
- }
- }
|