Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: Adjust server-side timers when resuming an execution #2438

Merged
merged 18 commits into from
Jan 25, 2024
Merged

feat: Adjust server-side timers when resuming an execution #2438

Show file tree
Hide file tree
Changes from 14 commits
Commits
Show all changes
18 commits
Select commit Hold shift + click to select a range
851360e
feat: Adjust server timers when resuming an execution
hectoras Jan 15, 2024
e9bc636
chore: Cleanup
hectoras Jan 15, 2024
83dd3f8
chore: Cleanup
hectoras Jan 15, 2024
a5b8f75
chore: Update year in license header
hectoras Jan 16, 2024
8b5b6f2
chore: Get the former order for duration cache updates
hectoras Jan 16, 2024
229d5a3
fix: Explicitly provide the component to apply the adjustment in
hectoras Jan 16, 2024
fb85c06
chore: Revert to the simpler approach applying the adjustment tot he …
hectoras Jan 16, 2024
c5d9648
chore: Change log msg
hectoras Jan 16, 2024
8da35ae
fix: Store the pause timestamp associated to all execution IDs
hectoras Jan 16, 2024
4393a42
chore: Cleanup
hectoras Jan 16, 2024
0519afb
chore: Cleanup
hectoras Jan 16, 2024
b4e1bd2
chore: Cleanup
hectoras Jan 16, 2024
4c1ca83
chore: Coding style improvements
hectoras Jan 17, 2024
46d1793
chore: Use a lower log level for debug messages in ConcurringSessionS…
hectoras Jan 17, 2024
46991ef
fix: Don't try to update the duration cache for non-available sources
hectoras Jan 18, 2024
75fb5c8
fix: Pass the execution user ID when fetching the service context
hectoras Jan 22, 2024
f841314
fix: Store the item duration instead of the current timestamp on test…
hectoras Jan 25, 2024
c6b4f7b
test: Update unit tests
hectoras Jan 25, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
125 changes: 119 additions & 6 deletions model/Service/ConcurringSessionService.php
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,14 +15,15 @@
* along with this program; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
*
* Copyright (c) 2023 (original work) Open Assessment Technologies SA;
* Copyright (c) 2023-2024 (original work) Open Assessment Technologies SA;
*/

declare(strict_types=1);

namespace oat\taoQtiTest\model\Service;

use common_Exception;
use oat\oatbox\service\ServiceManager;
use oat\tao\model\featureFlag\FeatureFlagCheckerInterface;
use oat\taoDelivery\model\execution\DeliveryExecution;
use oat\taoDelivery\model\execution\DeliveryExecutionInterface;
Expand All @@ -31,8 +32,15 @@
use oat\taoQtiTest\models\container\QtiTestDeliveryContainer;
use oat\taoQtiTest\models\runner\QtiRunnerService;
use oat\taoQtiTest\models\runner\QtiRunnerServiceContext;
use oat\taoQtiTest\models\runner\session\TestSession;
use oat\taoQtiTest\models\runner\time\QtiTimer;
use oat\taoQtiTest\models\runner\time\QtiTimerFactory;
use oat\taoQtiTest\models\runner\time\TimerAdjustmentService;
use oat\taoQtiTest\models\TestSessionService;
use PHPSession;
use Psr\Log\LoggerInterface;
use qtism\runtime\tests\RouteItem;
use DateTime;
use Throwable;

class ConcurringSessionService
Expand Down Expand Up @@ -68,6 +76,7 @@ public function pauseConcurrentSessions(DeliveryExecution $activeExecution): voi
return;
}

$now = $_SERVER['REQUEST_TIME_FLOAT'] ?? microtime(true);
$userIdentifier = $activeExecution->getUserIdentifier();

if (empty($userIdentifier) || $userIdentifier === 'anonymous') {
Expand All @@ -81,20 +90,23 @@ public function pauseConcurrentSessions(DeliveryExecution $activeExecution): voi
);

foreach ($userExecutions as $execution) {
if ($execution->getOriginalIdentifier() !== $activeExecution->getOriginalIdentifier()) {
$executionId = $execution->getOriginalIdentifier();

if ($executionId !== $activeExecution->getOriginalIdentifier()) {
try {
$this->setConcurringSession($execution->getOriginalIdentifier());
$this->setConcurringSession($executionId);

$context = $this->getContextByDeliveryExecution($execution);

$this->qtiRunnerService->endTimer($context);
$this->qtiRunnerService->pause($context);

$this->currentSession->setAttribute("pausedAt-{$executionId}", $now);
} catch (Throwable $e) {
$this->logger->warning(
sprintf(
'%s: Unable to pause delivery execution %s: %s',
self::class,
$execution->getOriginalIdentifier(),
$executionId,
$e->getMessage()
)
);
Expand Down Expand Up @@ -124,9 +136,87 @@ public function setConcurringSession(string $executionId): void
);
}

public function adjustTimers(DeliveryExecution $execution): void
{
$this->logger->debug(
sprintf('Adjusting timers on test restart, current ts is %f', microtime(true))
);

$testSession = $this->getTestSessionService()->getTestSession($execution);

if ($testSession instanceof TestSession) {
$timer = $testSession->getTimer();
} else {
$timer = $this->getQtiTimerFactory()->getTimer(
$execution->getIdentifier(),
$execution->getUserIdentifier()
);
}

$ids = [
$execution->getIdentifier(),
$execution->getOriginalIdentifier()
];

foreach ($ids as $executionId) {
if ($this->currentSession->hasAttribute("pausedAt-{$executionId}")) {
$last = $this->currentSession->getAttribute("pausedAt-{$executionId}");
$this->currentSession->removeAttribute("pausedAt-{$executionId}");

$this->logger->debug(
sprintf('Adjusting timers based on timestamp stored in session: %f', $last)
);
}
}

if (!isset($last) && $testSession instanceof TestSession) {
$last = $this->getHighestItemTimestamp($testSession, $timer);

$this->logger->debug(
sprintf('Adjusting timers based on highest item timestamp: %f', $last)
);
}

if (isset($last) && $last > 0) {
$delta = (new DateTime('now'))->format('U') - $last;
$this->logger->debug(sprintf('Adjusting timers by %.2f s', $delta));

$this->getTimerAdjustmentService()->increase(
$testSession,
(int) $delta
);

$testSession->suspend();
$this->getTestSessionService()->persist($testSession);
}
}

private function getHighestItemTimestamp(TestSession $testSession, QtiTimer $timer): ?float
{
$timestamps = [];

foreach ($testSession->getRoute()->getAllRouteItems() as $item) {
/* @var $item RouteItem */
$timestamp = $timer->getLastTimestamp(
$testSession->getItemTags($item)
);
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

[Optional]

Suggested change
$timestamp = $timer->getLastTimestamp(
$testSession->getItemTags($item)
);
$timestamp = $timer->getLastTimestamp($testSession->getItemTags($item));


if ($timestamp > 0) {
$timestamps[] = $timestamp;
}
}

if (empty($timestamps)) {
return null;
}

return max($timestamps);
}

private function getContextByDeliveryExecution(DeliveryExecutionInterface $execution): QtiRunnerServiceContext
{
$container = $this->runtimeService->getDeliveryContainer($execution->getDelivery()->getUri());
$delivery = $execution->getDelivery();
$container = $this->runtimeService->getDeliveryContainer($delivery->getUri());

if (!$container instanceof QtiTestDeliveryContainer) {
throw new common_Exception(
Expand All @@ -150,4 +240,27 @@ private function getContextByDeliveryExecution(DeliveryExecutionInterface $execu
$execution->getOriginalIdentifier()
);
}

private function getQtiTimerFactory(): QtiTimerFactory
{
/** @noinspection PhpIncompatibleReturnTypeInspection */
return $this->getServiceManager()->get(QtiTimerFactory::SERVICE_ID);
}

private function getTimerAdjustmentService(): TimerAdjustmentService
{
/** @noinspection PhpIncompatibleReturnTypeInspection */
return $this->getServiceManager()->get(TimerAdjustmentService::SERVICE_ID);
}

private function getTestSessionService(): TestSessionService
{
/** @noinspection PhpIncompatibleReturnTypeInspection */
return $this->getServiceManager()->get(TestSessionService::SERVICE_ID);
}

private function getServiceManager()
{
return ServiceManager::getServiceManager();
}
}
10 changes: 7 additions & 3 deletions models/classes/runner/session/TestSession.php
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* along with this program; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
*
* Copyright (c) 2016-2017 (original work) Open Assessment Technologies SA
* Copyright (c) 2016-2024 (original work) Open Assessment Technologies SA
*
*/

Expand Down Expand Up @@ -336,13 +336,17 @@ protected function updateCurrentDurationCache()
{
$target = $this->getTimerTarget();
$routeItem = $this->getCurrentRouteItem();

$sources = [
$routeItem->getAssessmentTest(),
$this->getAssessmentTest(),
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Are we sure, that we can use $this (TestSession) instead of RoutItem ?

Copy link
Contributor Author

@hectoras hectoras Jan 17, 2024 •
edited
Loading

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This solves a bug: If this ends up being called on a test (lets call it test B) other than the one we are current running (lets call it test A), $routeItem is null. That is, getCurrentRouteItem() returns null when called from a request associated with the test runner session for test A to get the current item for test B.

    protected function getCurrentRouteItem()
    {
        if ($this->isRunning() === true) {
            return $this->getRoute()->current();
        }

        return false;
    }

The test we are pausing (B) is / was running, but not in the current request (which is "bound" to A), and we need this to work also in that case (so the elapsed time for the item of test B is stored when suspending the test).

Both $routeItem->getAssessmentItemRef() and $this->getAssessmentTest() return an instance of AssessmentTest that refers to the same test.

$this->getCurrentTestPart(),
$this->getCurrentAssessmentSection(),
$routeItem->getAssessmentItemRef(),
];

if ($routeItem instanceof RouteItem) {
$sources[] = $routeItem->getAssessmentItemRef();
}

foreach ($sources as $source) {
$this->updateDurationCache($source->getIdentifier(), $target);
}
Expand Down
Loading