api/api.php at master · hide2/api · 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
<?php
require_once __DIR__ . '/vendor/autoload.php';
require_once __DIR__ . '/lib/app_http.php';
require_once __DIR__ . '/config.php';
ini_set("precision", "-1");
ini_set("serialize_precision", "-1");

$app = new App("http://0.0.0.0:8888");
$app->count = 8;
$app->name = 'api';

$app->onWorkerStart = function ($worker) {
	require_once __DIR__ . '/lib/auth.php';
	require_once __DIR__ . '/lib/db.php';
	require_once __DIR__ . '/lib/clickhouse.php';
	require_once __DIR__ . '/lib/cache.php';
	require_once __DIR__ . '/lib/kafka.php';
	require_once __DIR__ . '/config.php';
	ini_set("precision", "-1");
	ini_set("serialize_precision", "-1");

	echo "[" . date('Y-m-d H:i:s') . "] Worker start[" . $worker->id . "]\n";
};

///////////////////////////////// API接口定义开始

$app->get('/', function ($req) {
	return 'OK';
});

$app->post('/', function ($req) {
	return 'OK';
});

$app->get('/health/check', function ($req) {
	return 'OK';
});

$app->before('/api', function ($req) {
	return Auth::verify_api($req);
});

$app->get('/tables', function ($req) {
	if (CACHE::exists('tables')) {
		return json_decode(CACHE::get('tables'));
	} else {
		$tables = DB::query('show tables');
		CACHE::set('tables', json_encode($tables), 5);
		return json_decode(CACHE::get('tables'));
	}
});

///////////////////////////////// API接口定义结束


App::$logFile = './logs/workerman_api.log';
App::$stdoutFile = './logs/api.log';

App::runAll();