|
1
|
|
|
<?php |
|
2
|
|
|
|
|
3
|
|
|
/** |
|
4
|
|
|
* This is a slightly strange file. It is not designed to ever be run directly from within SMF's |
|
5
|
|
|
* conventional running, but called externally to facilitate background tasks. It can be called |
|
6
|
|
|
* either directly or via cron, and in either case will completely ignore anything supplied |
|
7
|
|
|
* via command line, or $_GET, $_POST, $_COOKIE etc. because those things should never affect the |
|
8
|
|
|
* running of this script. |
|
9
|
|
|
* |
|
10
|
|
|
* Because of the way this runs, etc. we do need some of SMF but not everything to try to keep this |
|
11
|
|
|
* running a little bit faster. |
|
12
|
|
|
* |
|
13
|
|
|
* Simple Machines Forum (SMF) |
|
14
|
|
|
* |
|
15
|
|
|
* @package SMF |
|
16
|
|
|
* @author Simple Machines https://www.simplemachines.org |
|
17
|
|
|
* @copyright 2021 Simple Machines and individual contributors |
|
18
|
|
|
* @license https://www.simplemachines.org/about/smf/license.php BSD |
|
19
|
|
|
* |
|
20
|
|
|
* @version 2.1 RC3 |
|
21
|
|
|
*/ |
|
22
|
|
|
|
|
23
|
|
|
define('SMF', 'BACKGROUND'); |
|
24
|
|
|
define('SMF_VERSION', '2.1 RC3'); |
|
25
|
|
|
define('SMF_FULL_VERSION', 'SMF ' . SMF_VERSION); |
|
26
|
|
|
define('SMF_SOFTWARE_YEAR', '2021'); |
|
27
|
|
|
define('FROM_CLI', empty($_SERVER['REQUEST_METHOD'])); |
|
28
|
|
|
|
|
29
|
|
|
define('JQUERY_VERSION', '3.5.1'); |
|
30
|
|
|
define('POSTGRE_TITLE', 'PostgreSQL'); |
|
31
|
|
|
define('MYSQL_TITLE', 'MySQL'); |
|
32
|
|
|
define('SMF_USER_AGENT', 'Mozilla/5.0 (' . php_uname('s') . ' ' . php_uname('m') . ') AppleWebKit/605.1.15 (KHTML, like Gecko) SMF/' . strtr(SMF_VERSION, ' ', '.')); |
|
33
|
|
|
|
|
34
|
|
|
// This one setting is worth bearing in mind. If you are running this from proper cron, make sure you |
|
35
|
|
|
// don't run this file any more frequently than indicated here. It might turn ugly if you do. |
|
36
|
|
|
// But on proper cron you can always increase this value provided you don't go beyond max_limit. |
|
37
|
|
|
define('MAX_CRON_TIME', 10); |
|
38
|
|
|
// If a task fails for whatever reason it will still be marked as claimed. This is the threshold |
|
39
|
|
|
// by which if a task has not completed in this time, the task should become available again. |
|
40
|
|
|
define('MAX_CLAIM_THRESHOLD', 300); |
|
41
|
|
|
|
|
42
|
|
|
// We're going to want a few globals... these are all set later. |
|
43
|
|
|
global $maintenance, $msubject, $mmessage, $mbname, $language; |
|
44
|
|
|
global $boardurl, $boarddir, $sourcedir, $webmaster_email; |
|
45
|
|
|
global $db_server, $db_name, $db_user, $db_prefix, $db_persist, $db_error_send, $db_last_error; |
|
46
|
|
|
global $db_connection, $modSettings, $context, $sc, $user_info, $txt; |
|
47
|
|
|
global $smcFunc, $ssi_db_user, $scripturl, $db_passwd, $cachedir; |
|
48
|
|
|
|
|
49
|
|
|
if (!defined('TIME_START')) |
|
50
|
|
|
define('TIME_START', microtime(true)); |
|
51
|
|
|
|
|
52
|
|
|
// Just being safe... |
|
53
|
|
|
foreach (array('db_character_set', 'cachedir') as $variable) |
|
54
|
|
|
if (isset($GLOBALS[$variable])) |
|
55
|
|
|
unset($GLOBALS[$variable]); |
|
56
|
|
|
|
|
57
|
|
|
// Get the forum's settings for database and file paths. |
|
58
|
|
|
require_once(dirname(__FILE__) . '/Settings.php'); |
|
59
|
|
|
|
|
60
|
|
|
// Make absolutely sure the cache directory is defined and writable. |
|
61
|
|
|
if (empty($cachedir) || !is_dir($cachedir) || !is_writable($cachedir)) |
|
62
|
|
|
{ |
|
63
|
|
|
if (is_dir($boarddir . '/cache') && is_writable($boarddir . '/cache')) |
|
64
|
|
|
$cachedir = $boarddir . '/cache'; |
|
65
|
|
|
else |
|
66
|
|
|
{ |
|
67
|
|
|
$cachedir = sys_get_temp_dir() . '/smf_cache_' . md5($boarddir); |
|
68
|
|
|
@mkdir($cachedir, 0750); |
|
69
|
|
|
} |
|
70
|
|
|
} |
|
71
|
|
|
|
|
72
|
|
|
// Don't do john didley if the forum's been shut down completely. |
|
73
|
|
|
if ($maintenance == 2) |
|
74
|
|
|
die($mmessage); |
|
75
|
|
|
|
|
76
|
|
|
// Fix for using the current directory as a path. |
|
77
|
|
|
if (substr($sourcedir, 0, 1) == '.' && substr($sourcedir, 1, 1) != '.') |
|
78
|
|
|
$sourcedir = dirname(__FILE__) . substr($sourcedir, 1); |
|
79
|
|
|
|
|
80
|
|
|
// Have we already turned this off? If so, exist gracefully. |
|
81
|
|
|
if (file_exists($cachedir . '/cron.lock')) |
|
82
|
|
|
obExit_cron(); |
|
83
|
|
|
|
|
84
|
|
|
// Before we go any further, if this is not a CLI request, we need to do some checking. |
|
85
|
|
|
if (!FROM_CLI) |
|
86
|
|
|
{ |
|
87
|
|
|
// When using sub-domains with SSI and ssi_themes set, browsers will receive a "Access-Control-Allow-Origin" error. |
|
88
|
|
|
// * is not ideal but the best method to preventing this from occurring. |
|
89
|
|
|
header('Access-Control-Allow-Origin: *'); |
|
90
|
|
|
|
|
91
|
|
|
// We will clean up $_GET shortly. But we want to this ASAP. |
|
92
|
|
|
$ts = isset($_GET['ts']) ? (int) $_GET['ts'] : 0; |
|
93
|
|
|
if ($ts <= 0 || $ts % 15 != 0 || time() - $ts < 0 || time() - $ts > 20) |
|
94
|
|
|
obExit_cron(); |
|
95
|
|
|
} |
|
96
|
|
|
|
|
97
|
|
|
else |
|
98
|
|
|
$_SERVER['SERVER_PROTOCOL'] = 'HTTP/1.0'; |
|
99
|
|
|
|
|
100
|
|
|
// Load the most important includes. In general, a background should be loading its own dependencies. |
|
101
|
|
|
require_once($sourcedir . '/Errors.php'); |
|
102
|
|
|
require_once($sourcedir . '/Load.php'); |
|
103
|
|
|
require_once($sourcedir . '/Security.php'); |
|
104
|
|
|
require_once($sourcedir . '/Subs.php'); |
|
105
|
|
|
|
|
106
|
|
|
// Create a variable to store some SMF specific functions in. |
|
107
|
|
|
$smcFunc = array(); |
|
108
|
|
|
|
|
109
|
|
|
// This is our general bootstrap, a la SSI.php but with a few differences. |
|
110
|
|
|
unset ($db_show_debug); |
|
111
|
|
|
loadDatabase(); |
|
112
|
|
|
reloadSettings(); |
|
113
|
|
|
|
|
114
|
|
|
// Just in case there's a problem... |
|
115
|
|
|
set_error_handler('smf_error_handler_cron'); |
|
116
|
|
|
$sc = ''; |
|
117
|
|
|
$_SERVER['QUERY_STRING'] = ''; |
|
118
|
|
|
$_SERVER['REQUEST_URL'] = FROM_CLI ? 'CLI cron.php' : $boardurl . '/cron.php'; |
|
119
|
|
|
|
|
120
|
|
|
// Now 'clean the request' (or more accurately, ignore everything we're not going to use) |
|
121
|
|
|
cleanRequest_cron(); |
|
122
|
|
|
|
|
123
|
|
|
// At this point we could reseed the RNG but I don't think we need to risk it being seeded *even more*. |
|
124
|
|
|
// Meanwhile, time we got on with the real business here. |
|
125
|
|
|
while ($task_details = fetch_task()) |
|
126
|
|
|
{ |
|
127
|
|
|
$result = perform_task($task_details); |
|
128
|
|
|
if ($result) |
|
129
|
|
|
{ |
|
130
|
|
|
$smcFunc['db_query']('', ' |
|
131
|
|
|
DELETE FROM {db_prefix}background_tasks |
|
132
|
|
|
WHERE id_task = {int:task}', |
|
133
|
|
|
array( |
|
134
|
|
|
'task' => $task_details['id_task'], |
|
135
|
|
|
) |
|
136
|
|
|
); |
|
137
|
|
|
} |
|
138
|
|
|
} |
|
139
|
|
|
obExit_cron(); |
|
140
|
|
|
exit; |
|
141
|
|
|
|
|
142
|
|
|
/** |
|
143
|
|
|
* The heart of this cron handler... |
|
144
|
|
|
* |
|
145
|
|
|
* @return bool|array False if there's nothing to do or an array of info about the task |
|
146
|
|
|
*/ |
|
147
|
|
|
function fetch_task() |
|
148
|
|
|
{ |
|
149
|
|
|
global $smcFunc; |
|
150
|
|
|
|
|
151
|
|
|
// Check we haven't run over our time limit. |
|
152
|
|
|
if (microtime(true) - TIME_START > MAX_CRON_TIME) |
|
153
|
|
|
return false; |
|
154
|
|
|
|
|
155
|
|
|
// Try to find a task. Specifically, try to find one that hasn't been claimed previously, or failing that, |
|
156
|
|
|
// a task that was claimed but failed for whatever reason and failed long enough ago. We should not care |
|
157
|
|
|
// what task it is, merely that it is one in the queue, the order is irrelevant. |
|
158
|
|
|
$request = $smcFunc['db_query']('', ' |
|
159
|
|
|
SELECT id_task, task_file, task_class, task_data, claimed_time |
|
160
|
|
|
FROM {db_prefix}background_tasks |
|
161
|
|
|
WHERE claimed_time < {int:claim_limit} |
|
162
|
|
|
LIMIT 1', |
|
163
|
|
|
array( |
|
164
|
|
|
'claim_limit' => time() - MAX_CLAIM_THRESHOLD, |
|
165
|
|
|
) |
|
166
|
|
|
); |
|
167
|
|
|
if ($row = $smcFunc['db_fetch_assoc']($request)) |
|
168
|
|
|
{ |
|
169
|
|
|
// We found one. Let's try and claim it immediately. |
|
170
|
|
|
$smcFunc['db_free_result']($request); |
|
171
|
|
|
$smcFunc['db_query']('', ' |
|
172
|
|
|
UPDATE {db_prefix}background_tasks |
|
173
|
|
|
SET claimed_time = {int:new_claimed} |
|
174
|
|
|
WHERE id_task = {int:task} |
|
175
|
|
|
AND claimed_time = {int:old_claimed}', |
|
176
|
|
|
array( |
|
177
|
|
|
'new_claimed' => time(), |
|
178
|
|
|
'task' => $row['id_task'], |
|
179
|
|
|
'old_claimed' => $row['claimed_time'], |
|
180
|
|
|
) |
|
181
|
|
|
); |
|
182
|
|
|
// Could we claim it? If so, return it back. |
|
183
|
|
|
if ($smcFunc['db_affected_rows']() != 0) |
|
184
|
|
|
{ |
|
185
|
|
|
// Update the time and go back. |
|
186
|
|
|
$row['claimed_time'] = time(); |
|
187
|
|
|
return $row; |
|
188
|
|
|
} |
|
189
|
|
|
else |
|
190
|
|
|
{ |
|
191
|
|
|
// Uh oh, we just missed it. Try to claim another one, and let it fall through if there aren't any. |
|
192
|
|
|
return fetch_task(); |
|
193
|
|
|
} |
|
194
|
|
|
} |
|
195
|
|
|
else |
|
196
|
|
|
{ |
|
197
|
|
|
// No dice. Clean up and go home. |
|
198
|
|
|
$smcFunc['db_free_result']($request); |
|
199
|
|
|
return false; |
|
200
|
|
|
} |
|
201
|
|
|
} |
|
202
|
|
|
|
|
203
|
|
|
/** |
|
204
|
|
|
* This actually handles the task |
|
205
|
|
|
* |
|
206
|
|
|
* @param array $task_details An array of info about the task |
|
207
|
|
|
* @return bool|void True if the task is invalid; otherwise calls the function to execute the task |
|
208
|
|
|
*/ |
|
209
|
|
|
function perform_task($task_details) |
|
210
|
|
|
{ |
|
211
|
|
|
global $smcFunc, $sourcedir, $boarddir; |
|
212
|
|
|
|
|
213
|
|
|
// This indicates the file to load. |
|
214
|
|
|
if (!empty($task_details['task_file'])) |
|
215
|
|
|
{ |
|
216
|
|
|
$include = strtr(trim($task_details['task_file']), array('$boarddir' => $boarddir, '$sourcedir' => $sourcedir)); |
|
217
|
|
|
if (file_exists($include)) |
|
218
|
|
|
require_once($include); |
|
219
|
|
|
} |
|
220
|
|
|
|
|
221
|
|
|
if (empty($task_details['task_class'])) |
|
222
|
|
|
{ |
|
223
|
|
|
// This would be nice to translate but the language files aren't loaded for any specific language. |
|
224
|
|
|
log_error('Invalid background task specified (no class, ' . (empty($task_details['task_file']) ? ' no file' : ' to load ' . $task_details['task_file']) . ')'); |
|
225
|
|
|
return true; // So we clear it from the queue. |
|
226
|
|
|
} |
|
227
|
|
|
|
|
228
|
|
|
// All background tasks need to be classes. |
|
229
|
|
|
elseif (class_exists($task_details['task_class']) && is_subclass_of($task_details['task_class'], 'SMF_BackgroundTask')) |
|
230
|
|
|
{ |
|
231
|
|
|
$details = empty($task_details['task_data']) ? array() : $smcFunc['json_decode']($task_details['task_data'], true); |
|
232
|
|
|
$bgtask = new $task_details['task_class']($details); |
|
233
|
|
|
return $bgtask->execute(); |
|
234
|
|
|
} |
|
235
|
|
|
else |
|
236
|
|
|
{ |
|
237
|
|
|
log_error('Invalid background task specified: (class: ' . $task_details['task_class'] . ', ' . (empty($task_details['task_file']) ? ' no file' : ' to load ' . $task_details['task_file']) . ')'); |
|
238
|
|
|
return true; // So we clear it from the queue. |
|
239
|
|
|
} |
|
240
|
|
|
} |
|
241
|
|
|
|
|
242
|
|
|
// These are all our helper functions that resemble their big brother counterparts. These are not so important. |
|
243
|
|
|
/** |
|
244
|
|
|
* Cleans up the request variables |
|
245
|
|
|
* |
|
246
|
|
|
* @return void |
|
247
|
|
|
*/ |
|
248
|
|
|
function cleanRequest_cron() |
|
249
|
|
|
{ |
|
250
|
|
|
global $scripturl, $boardurl; |
|
251
|
|
|
|
|
252
|
|
|
$scripturl = $boardurl . '/index.php'; |
|
253
|
|
|
|
|
254
|
|
|
// These keys shouldn't be set...ever. |
|
255
|
|
|
if (isset($_REQUEST['GLOBALS']) || isset($_COOKIE['GLOBALS'])) |
|
256
|
|
|
die('Invalid request variable.'); |
|
|
|
|
|
|
257
|
|
|
|
|
258
|
|
|
// Save some memory.. (since we don't use these anyway.) |
|
259
|
|
|
unset($GLOBALS['HTTP_POST_VARS'], $GLOBALS['HTTP_POST_VARS']); |
|
260
|
|
|
unset($GLOBALS['HTTP_POST_FILES'], $GLOBALS['HTTP_POST_FILES']); |
|
261
|
|
|
unset($GLOBALS['_GET'], $GLOBALS['_POST'], $GLOBALS['_REQUEST'], $GLOBALS['_COOKIE'], $GLOBALS['_FILES']); |
|
262
|
|
|
} |
|
263
|
|
|
|
|
264
|
|
|
/** |
|
265
|
|
|
* The error handling function |
|
266
|
|
|
* |
|
267
|
|
|
* @param int $error_level One of the PHP error level constants (see ) |
|
268
|
|
|
* @param string $error_string The error message |
|
269
|
|
|
* @param string $file The file where the error occurred |
|
270
|
|
|
* @param int $line What line of the specified file the error occurred on |
|
271
|
|
|
* @return void |
|
272
|
|
|
*/ |
|
273
|
|
|
function smf_error_handler_cron($error_level, $error_string, $file, $line) |
|
274
|
|
|
{ |
|
275
|
|
|
global $modSettings; |
|
276
|
|
|
|
|
277
|
|
|
// Ignore errors that should not be logged. |
|
278
|
|
|
if (error_reporting() == 0) |
|
279
|
|
|
return; |
|
280
|
|
|
|
|
281
|
|
|
$error_type = 'cron'; |
|
282
|
|
|
|
|
283
|
|
|
log_error($error_level . ': ' . $error_string, $error_type, $file, $line); |
|
284
|
|
|
|
|
285
|
|
|
// If this is an E_ERROR or E_USER_ERROR.... die. Violently so. |
|
286
|
|
|
if ($error_level % 255 == E_ERROR) |
|
287
|
|
|
die('No direct access...'); |
|
|
|
|
|
|
288
|
|
|
} |
|
289
|
|
|
|
|
290
|
|
|
/** |
|
291
|
|
|
* The exit function |
|
292
|
|
|
*/ |
|
293
|
|
|
function obExit_cron() |
|
294
|
|
|
{ |
|
295
|
|
|
if (FROM_CLI) |
|
296
|
|
|
die(0); |
|
|
|
|
|
|
297
|
|
|
else |
|
298
|
|
|
{ |
|
299
|
|
|
header('content-type: image/gif'); |
|
300
|
|
|
die("\x47\x49\x46\x38\x39\x61\x01\x00\x01\x00\x80\x00\x00\x00\x00\x00\x00\x00\x00\x21\xF9\x04\x01\x00\x00\x00\x00\x2C\x00\x00\x00\x00\x01\x00\x01\x00\x00\x02\x02\x44\x01\x00\x3B"); |
|
301
|
|
|
} |
|
302
|
|
|
} |
|
303
|
|
|
|
|
304
|
|
|
// We would like this to be defined, but we don't want to have to load more stuff than necessary. |
|
305
|
|
|
// Thus we declare it here, and any legitimate background task must implement this. |
|
306
|
|
|
/** |
|
307
|
|
|
* Class SMF_BackgroundTask |
|
308
|
|
|
*/ |
|
309
|
|
|
abstract class SMF_BackgroundTask |
|
310
|
|
|
{ |
|
311
|
|
|
/** |
|
312
|
|
|
* Constants for notification types. |
|
313
|
|
|
*/ |
|
314
|
|
|
const RECEIVE_NOTIFY_EMAIL = 0x02; |
|
315
|
|
|
const RECEIVE_NOTIFY_ALERT = 0x01; |
|
316
|
|
|
|
|
317
|
|
|
/** |
|
318
|
|
|
* @var array Holds the details for the task |
|
319
|
|
|
*/ |
|
320
|
|
|
protected $_details; |
|
321
|
|
|
|
|
322
|
|
|
/** |
|
323
|
|
|
* @var array Temp property to hold the current user info while tasks make use of $user_info |
|
324
|
|
|
*/ |
|
325
|
|
|
private $current_user_info = array(); |
|
326
|
|
|
|
|
327
|
|
|
/** |
|
328
|
|
|
* The constructor. |
|
329
|
|
|
* |
|
330
|
|
|
* @param array $details The details for the task |
|
331
|
|
|
*/ |
|
332
|
|
|
public function __construct($details) |
|
333
|
|
|
{ |
|
334
|
|
|
global $user_info; |
|
335
|
|
|
|
|
336
|
|
|
$this->_details = $details; |
|
337
|
|
|
|
|
338
|
|
|
$this->current_user_info = $user_info; |
|
339
|
|
|
} |
|
340
|
|
|
|
|
341
|
|
|
/** |
|
342
|
|
|
* The function to actually execute a task |
|
343
|
|
|
* |
|
344
|
|
|
* @return mixed |
|
345
|
|
|
*/ |
|
346
|
|
|
abstract public function execute(); |
|
347
|
|
|
|
|
348
|
|
|
/** |
|
349
|
|
|
* Loads minimal info for the previously loaded user ids |
|
350
|
|
|
* |
|
351
|
|
|
* @param array $user_ids |
|
352
|
|
|
* @return array |
|
353
|
|
|
* @throws Exception |
|
354
|
|
|
*/ |
|
355
|
|
|
public function getMinUserInfo($user_ids = array()) |
|
356
|
|
|
{ |
|
357
|
|
|
return loadMinUserInfo($user_ids); |
|
358
|
|
|
} |
|
359
|
|
|
|
|
360
|
|
|
public function __destruct() |
|
361
|
|
|
{ |
|
362
|
|
|
global $user_info; |
|
363
|
|
|
|
|
364
|
|
|
$user_info = $this->current_user_info; |
|
365
|
|
|
} |
|
366
|
|
|
} |
|
367
|
|
|
|
|
368
|
|
|
?> |
In general, usage of exit should be done with care and only when running in a scripting context like a CLI script.