swoolepush/test.php at master · EGroupware/swoolepush · GitHub

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
<?php
/**
 * Testing Push Server for EGroupware using PHP Swoole extension
 *
 * To use on commandline:
 * docker exec -it egroupware bash
 * HTTP_HOST=example.org php /usr/share/egroupware/swoolepush/test.php
 *
 * Please note:
 * - backoff-time and failed-attempts are stored in APCu / shared memory and
 *   therefore are NOT the same for web-usage and command-line!
 * - for command-line the host need to be specified as shown above for the test to succeed!
 *
 * @link https://www.egroupware.org
 * @author Ralf Becker <rb-At-egroupware.org>
 * @package swoolepush
 * @copyright (c) 2020 by Ralf Becker <rb-At-egroupware.org>
 * @license http://opensource.org/licenses/gpl-license.php GPL - GNU General Public License
 */
use EGroupware\Api;
use EGroupware\Api\Json\Push;
use EGroupware\SwoolePush\Backend;

$GLOBALS['egw_info'] = [
	'flags' => [
		'currentapp' => PHP_SAPI !== 'cli' ? 'admin' : 'login',
		'noheader' => true,
	]
];

require_once __DIR__.'/../header.inc.php';

if (PHP_SAPI !== 'cli')
{
	Api\Framework::message($message=lang('Checking PUSH (green for success or red for failure)'), 'error');
	echo $egw->framework->header();
	echo "<pre>\n";
	$success_start = "<span style='color: green; font-weight: bold'>";
	$failure_start = "<span style='color: red; font-weight: bold'>";
	$end = '</span>';
}
else
{
	echo "\n";
	$success_start = $failure_start = $end = '';
}

function check_push($ignore_cache=false)
{
	global $success_start, $failure_start, $end;
	$only_fallback = Push::onlyFallback($ignore_cache);
	$result = ($only_fallback ?
			$failure_start.lang('Using fallback via regular JSON requests') :
			$success_start.lang('Using native Swoole Push')).$end;
	echo "Push::onlyFallback()=".json_encode($only_fallback).' --> '.$result."\n\n";
	echo "SwoolPush\Backend::failedAttempts()=".Backend::failedAttempts().", SwoolePush\Backend::backoffTime=".Backend::backoffTime();
}

check_push();

if (Backend::failedAttempts() > Backend::MAX_FAILED_ATTEMPTS)
{
	if (empty($_POST['reset']) && PHP_SAPI !== 'cli')
	{
		echo " <form style='display:inline-block; margin:0' method='post'><input type='submit' name='reset' value='Reset' class='padding: 5px'/></form>\n";
	}
	else
	{
		echo "\nresetting to SwoolePush\Backend::failedAttempts()=".Backend::failedAttempts(-2*Backend::MAX_FAILED_ATTEMPTS).
			" and SwoolePush\Backend::backoffTime()=".Backend::backoffTime()."seconds\n";
	}
}
else echo "\n";
echo "\n";

echo "SwoolePush\Backend->online()=";
try {
	echo json_encode(array_map(function($account_id) {
			return Api\Accounts::id2name($account_id);
		},(new Backend())->online()))."\n\n";

	if (PHP_SAPI !== 'cli')
	{
		// success message needs to be delayed (3rd param) as push might be quicker than the error-message in the regular response
		(new Backend())->addGeneric(Push::SESSION, 'apply', [
			'func' => 'app.admin.pushTestMessage',
			'parms' => [$message, 'info', 200],
		]);
	}
}
catch (Exception $e) {
	echo $failure_start.$e->getMessage().$end."\n";
}

check_push(true);

echo "\n\nPush->online()=".json_encode(array_map(function($account_id) {
	return Api\Accounts::id2name($account_id);
},(new Push())->online()))."\n\n";

if (PHP_SAPI !== 'cli')
{
	echo "\n<form style='display:inline-block; margin:0'><input type='submit' value='Retry' style='padding: 5px'/></form>\n";
}