1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
<?php
class FreshRSS_UserDAO extends Minz_ModelPdo {
public function createUser($new_user_language = null, $insertDefaultFeeds = false) {
require_once(APP_PATH . '/SQL/install.sql.' . $this->bd->dbType() . '.php');
$currentLanguage = Minz_Translate::language();
try {
if ($new_user_language != null) {
Minz_Translate::reset($new_user_language);
}
$ok = false;
if (defined('SQL_CREATE_TABLES')) { //E.g. MySQL
$sql = sprintf(SQL_CREATE_TABLES . SQL_CREATE_TABLE_ENTRYTMP . SQL_CREATE_TABLE_TAGS, $this->prefix, _t('gen.short.default_category'));
$stm = $this->bd->prepare($sql);
$ok = $stm && $stm->execute();
} else { //E.g. SQLite
global $SQL_CREATE_TABLES, $SQL_CREATE_TABLE_ENTRYTMP, $SQL_CREATE_TABLE_TAGS;
if (is_array($SQL_CREATE_TABLES)) {
$instructions = array_merge($SQL_CREATE_TABLES, $SQL_CREATE_TABLE_ENTRYTMP, $SQL_CREATE_TABLE_TAGS);
$ok = !empty($instructions);
foreach ($instructions as $instruction) {
$sql = sprintf($instruction, $this->prefix, _t('gen.short.default_category'));
$stm = $this->bd->prepare($sql);
$ok &= ($stm && $stm->execute());
}
}
}
if ($ok && $insertDefaultFeeds) {
$default_feeds = FreshRSS_Context::$system_conf->default_feeds;
foreach ($default_feeds as $feed) {
$sql = sprintf(SQL_INSERT_FEED, $this->prefix);
$stm = $this->bd->prepare($sql);
$parameters = array(
':url' => $feed['url'],
':name' => $feed['name'],
':website' => $feed['website'],
':description' => $feed['description'],
);
$ok &= ($stm && $stm->execute($parameters));
}
}
} catch (Exception $e) {
Minz_Log::error('Error while creating database for user: ' . $e->getMessage());
}
Minz_Translate::reset($currentLanguage);
if ($ok) {
return true;
} else {
$info = empty($stm) ? array(2 => 'syntax error') : $stm->errorInfo();
Minz_Log::error(__METHOD__ . ' error: ' . $info[2]);
return false;
}
}
public function deleteUser() {
if (defined('STDERR')) {
fwrite(STDERR, 'Deleting SQL data for user “' . $this->current_user . "”…\n");
}
require_once(APP_PATH . '/SQL/install.sql.' . $this->bd->dbType() . '.php');
$ok = false;
if (defined('SQL_DROP_TABLES')) { //E.g. MySQL
$sql = sprintf(SQL_DROP_TABLES, $this->prefix);
$stm = $this->bd->prepare($sql);
$ok = $stm && $stm->execute();
} else { //E.g. SQLite
global $SQL_DROP_TABLES;
if (is_array($SQL_DROP_TABLES)) {
$instructions = $SQL_DROP_TABLES;
$ok = !empty($instructions);
foreach ($instructions as $instruction) {
$sql = sprintf($instruction, $this->prefix);
$stm = $this->bd->prepare($sql);
$ok &= ($stm && $stm->execute());
}
}
}
if ($ok) {
return true;
} else {
$info = $stm == null ? array(2 => 'syntax error') : $stm->errorInfo();
Minz_Log::error(__METHOD__ . ' error: ' . $info[2]);
return false;
}
}
public static function exists($username) {
return is_dir(USERS_PATH . '/' . $username);
}
public static function touch($username = '') {
if (!FreshRSS_user_Controller::checkUsername($username)) {
$username = Minz_Session::param('currentUser', '_');
}
return touch(USERS_PATH . '/' . $username . '/config.php');
}
public static function mtime($username) {
return @filemtime(USERS_PATH . '/' . $username . '/config.php');
}
}
|
