Skip to content

Commit

Permalink
refactor(waitFor): use GetGameTimer to timeout callbacks
Browse files Browse the repository at this point in the history
Corrected error message output to ms.
Resolves #518.
  • Loading branch information
thelindat committed Mar 18, 2024
1 parent 591fb02 commit 2190cd3
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 25 deletions.
22 changes: 6 additions & 16 deletions imports/waitFor/shared.lua
Original file line number Diff line number Diff line change
Expand Up @@ -10,31 +10,21 @@ function lib.waitFor(cb, errMessage, timeout)

if value ~= nil then return value end


if timeout or timeout == nil then
if type(timeout) ~= 'number' then timeout = 1000 end

if IsDuplicityVersion() then
timeout /= 50;
else
timeout -= GetFrameTime() * 1000;
end
end


local start = GetGameTimer()
local i = 0
local start = timeout and GetGameTimer()

while value == nil do
if timeout then
i += 1
Wait(0)

local elapsed = timeout and GetGameTimer() - start

if i > timeout then
return error(('%s (waited %.1fms)'):format(errMessage or 'failed to resolve callback', (GetGameTimer() - start) / 1000), 2)
end
if elapsed and elapsed > timeout then
return error(('%s (waited %.1fms)'):format(errMessage or 'failed to resolve callback', elapsed), 2)
end

Wait(0)
value = cb()
end

Expand Down
13 changes: 4 additions & 9 deletions package/shared/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ export interface VehicleProperties {
modLightbar: number;
windows: number[];
doors: number[];
tyres: Record<number | string, 1 | 2>
tyres: Record<number | string, 1 | 2>;
leftHeadlight: boolean;
rightHeadlight: boolean;
frontBumper: boolean;
Expand All @@ -113,22 +113,17 @@ export async function waitFor<T>(cb: () => T, errMessage?: string, timeout?: num

if (timeout || timeout == null) {
if (typeof timeout !== 'number') timeout = 1000;

if (IsDuplicityVersion()) timeout /= 50;
else timeout -= GetFrameTime() * 1000;
}

const start = GetGameTimer();
let id: number;
let i = 0;

const p = new Promise<T>((resolve, reject) => {
id = setTick(async () => {
if (timeout) {
i++;
const elapsed = timeout && GetGameTimer() - start;

if (i > timeout)
return reject(`${errMessage || 'failed to resolve callback'} (waited ${(GetGameTimer() - start) / 1000}ms)`);
if (elapsed && elapsed > (timeout as number)) {
return reject(`${errMessage || 'failed to resolve callback'} (waited ${elapsed}ms)`);
}

value = await cb();
Expand Down

0 comments on commit 2190cd3

Please sign in to comment.