<?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);
  		}
  	}
  }