1<?php 2/** 3 * DokuWiki Plugin bez (Action Component) 4 * 5 */ 6 7// must be run within Dokuwiki 8 9if (!defined('DOKU_INC')) die(); 10 11/** 12 * Class action_plugin_bez_migration 13 * 14 * Handle migrations that need more than just SQL 15 */ 16class action_plugin_ireadit_migration extends DokuWiki_Action_Plugin 17{ 18 /** 19 * @inheritDoc 20 */ 21 public function register(Doku_Event_Handler $controller) 22 { 23 $controller->register_hook('PLUGIN_SQLITE_DATABASE_UPGRADE', 'AFTER', $this, 'handle_migrations'); 24 } 25 26 /** 27 * Call our custom migrations when defined 28 * 29 * @param Doku_Event $event 30 * @param $param 31 */ 32 public function handle_migrations(Doku_Event $event, $param) 33 { 34 if ($event->data['sqlite']->getAdapter()->getDbname() !== 'ireadit') { 35 return; 36 } 37 $to = $event->data['to']; 38 39 if (is_callable(array($this, "migration$to"))) { 40 $event->result = call_user_func(array($this, "migration$to"), $event->data); 41 } 42 } 43 44 /** 45 * Convenience function to run an INSERT ... ON CONFLICT IGNORE operation 46 * 47 * The function takes a key-value array with the column names in the key and the actual value in the value, 48 * build the appropriate query and executes it. 49 * 50 * @param string $table the table the entry should be saved to (will not be escaped) 51 * @param array $entry A simple key-value pair array (only values will be escaped) 52 * @return bool|SQLiteResult 53 */ 54 protected function insertOrIgnore(helper_plugin_sqlite $sqlite, $table, $entry) { 55 $keys = join(',', array_keys($entry)); 56 $vals = join(',', array_fill(0,count($entry),'?')); 57 58 $sql = "INSERT OR IGNORE INTO $table ($keys) VALUES ($vals)"; 59 return $sqlite->query($sql, array_values($entry)); 60 } 61 62 protected function migration1($data) 63 { 64 global $conf; 65 66 /** @var helper_plugin_sqlite $sqlite */ 67 $sqlite = $data['sqlite']; 68 $db = $sqlite->getAdapter()->getDb(); 69 70 /* @var \helper_plugin_ireadit $helper */ 71 $helper = plugin_load('helper', 'ireadit'); 72 73 74 $datadir = $conf['datadir']; 75 if (substr($datadir, -1) != '/') { 76 $datadir .= '/'; 77 } 78 79 $rii = new RecursiveIteratorIterator(new RecursiveDirectoryIterator($datadir)); 80 $pages = array(); 81 foreach ($rii as $file) { 82 if ($file->isDir()){ 83 continue; 84 } 85 86 //remove start path and extension 87 $page = substr($file->getPathname(), strlen($datadir), -4); 88 $pages[] = str_replace('/', ':', $page); 89 } 90 $db->beginTransaction(); 91 92 foreach ($pages as $page) { 93 //import historic data 94 $meta = p_get_metadata($page, 'plugin_ireadit'); 95 if (!$meta) continue; 96 97 foreach ($meta as $rev => $data) { 98 if ($rev === '' || count($data) == 0) continue; 99 foreach ($data as $user_read) { 100 $sqlite->storeEntry('ireadit', array( 101 'page' => $page, 102 'rev' => $rev, 103 'user' => $user_read['client'], 104 'timestamp' => date('c', $user_read['time']) 105 )); 106 } 107 } 108 109 //import current data 110 $content = file_get_contents($datadir . str_replace(':', '/', $page) . '.txt'); 111 $status = preg_match('/~~IREADIT.*~~/', $content, $matches); 112 //no ireadit on page 113 if ($status !== 1) continue; 114 115 $match = trim(substr($matches[0], strlen('~~IREADIT'), -2)); 116 $splits = preg_split('/\s+/', $match, -1, PREG_SPLIT_NO_EMPTY); 117 118 $users = array(); 119 $groups = array(); 120 foreach ($splits as $split) { 121 if ($split[0] == '@') { 122 $group = substr($split, 1); 123 $groups[] = $group; 124 } else { 125 $users[] = $split; 126 } 127 } 128 129 $usersToInsert = $helper->users_set($users, $groups); 130 131 if ($usersToInsert) { 132 $last_change_date = p_get_metadata($page, 'last_change date'); 133 foreach ($usersToInsert as $user => $info) { 134 $this->insertOrIgnore($sqlite,'ireadit', array( 135 'page' => $page, 136 'rev' => $last_change_date, 137 'user' => $user 138 )); 139 } 140 } 141 142 } 143 $db->commit(); 144 145 return true; 146 } 147} 148