mirror of
https://github.com/appwrite/appwrite.git
synced 2026-05-26 13:51:13 +00:00
Use values from req headers for tests
This commit is contained in:
@@ -62,7 +62,7 @@ class ScheduleExecutions extends ScheduleBase
|
||||
$executionDelay = $executedAt->getTimestamp() - $scheduledAt->getTimestamp();
|
||||
|
||||
$headers = $data['headers'] ?? [];
|
||||
$headers['x-appwrite-schedule-delay'] = (string)$executionDelay;
|
||||
$headers['x-appwrite-execution-delay'] = (string)$executionDelay;
|
||||
$headers['x-appwrite-scheduled-at'] = $scheduledAt->format('Y-m-d\TH:i:s.v\Z');
|
||||
$headers['x-appwrite-executed-at'] = $executedAt->format('Y-m-d\TH:i:s.v\Z');
|
||||
|
||||
|
||||
@@ -136,30 +136,17 @@ class FunctionsScheduleTest extends Scope
|
||||
$this->assertStringContainsString('path-is-/custom-path', $execution['body']['logs']);
|
||||
$this->assertStringContainsString('user-is-' . $this->getUser()['$id'], $execution['body']['logs']);
|
||||
$this->assertStringContainsString('jwt-is-valid', $execution['body']['logs']);
|
||||
$this->assertStringContainsString('execution-delay-is-valid', $execution['body']['logs']);
|
||||
$this->assertStringContainsString('scheduled-at-is-valid', $execution['body']['logs']);
|
||||
$this->assertStringContainsString('executed-at-is-valid', $execution['body']['logs']);
|
||||
$this->assertGreaterThan(0, $execution['body']['duration']);
|
||||
|
||||
$logs = explode("\n", $execution['body']['logs']);
|
||||
$scheduleDelay = null;
|
||||
$scheduledAt = null;
|
||||
$executedAt = null;
|
||||
|
||||
foreach ($logs as $line) {
|
||||
$line = trim($line);
|
||||
|
||||
if (str_starts_with($line, 'schedule-delay-is-')) {
|
||||
$scheduleDelay = (int) substr($line, strlen('schedule-delay-is-'));
|
||||
} elseif (str_starts_with($line, 'scheduled-at-is-')) {
|
||||
$scheduledAt = substr($line, strlen('scheduled-at-is-'));
|
||||
} elseif (str_starts_with($line, 'executed-at-is-')) {
|
||||
$executedAt = substr($line, strlen('executed-at-is-'));
|
||||
}
|
||||
}
|
||||
|
||||
$this->assertNotNull($scheduleDelay);
|
||||
$this->assertLessThanOrEqual(5, $scheduleDelay);
|
||||
$this->assertNotNull($scheduledAt);
|
||||
$this->assertNotNull($executedAt);
|
||||
$this->assertNotEquals($scheduledAt, $executedAt, );
|
||||
$requestHeaders = array_column($execution['body']['requestHeaders'], 'value', 'name');
|
||||
$this->assertArrayHasKey('x-appwrite-scheduled-at', $requestHeaders);
|
||||
$this->assertArrayHasKey('x-appwrite-executed-at', $requestHeaders);
|
||||
$this->assertArrayHasKey('x-appwrite-execution-delay', $requestHeaders);
|
||||
$this->assertIsNumeric($requestHeaders['x-appwrite-execution-delay']);
|
||||
$this->assertGreaterThan($requestHeaders['x-appwrite-scheduled-at'], $requestHeaders['x-appwrite-executed-at']);
|
||||
}, 10000, 500);
|
||||
|
||||
/* Test for FAILURE */
|
||||
|
||||
@@ -37,9 +37,6 @@ module.exports = async(context) => {
|
||||
context.log('method-is-' + (context.req.method ?? '').toLowerCase());
|
||||
context.log('path-is-' + (context.req.path ?? ''));
|
||||
context.log('user-is-' + (context.req.headers['x-appwrite-user-id'] ?? ''));
|
||||
context.log('schedule-delay-is-' + (context.req.headers['x-appwrite-schedule-delay'] ?? ''));
|
||||
context.log('scheduled-at-is-' + (context.req.headers['x-appwrite-scheduled-at'] ?? ''));
|
||||
context.log('executed-at-is-' + (context.req.headers['x-appwrite-executed-at'] ?? ''));
|
||||
|
||||
const statusCode = context.req.query['code'] || '200';
|
||||
|
||||
|
||||
Reference in New Issue
Block a user