mirror of
https://github.com/spacebarchat/server.git
synced 2026-05-10 23:37:05 +00:00
eslint: no-promise-executor-return
This commit is contained in:
@@ -50,6 +50,7 @@ export default defineConfig([
|
||||
"array-callback-return": "error",
|
||||
"no-constructor-return": "error",
|
||||
"no-duplicate-imports": "error",
|
||||
"no-promise-executor-return": ["error", { allowVoid: true }],
|
||||
// unsure what the defaults are here, but we want them to error
|
||||
"for-direction": "error",
|
||||
"constructor-super": "error",
|
||||
|
||||
@@ -22,7 +22,7 @@ async function main() {
|
||||
});
|
||||
} catch (e) {
|
||||
console.error("Failed to apply migrations, retrying in 2s...", e);
|
||||
await new Promise((res) => setTimeout(res, 2000));
|
||||
await new Promise((res) => void setTimeout(res, 2000));
|
||||
await main();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -74,7 +74,7 @@ async function main() {
|
||||
);
|
||||
}
|
||||
|
||||
await new Promise((resolve) => server.listen({ port }, () => resolve(undefined)));
|
||||
await new Promise((resolve) => void server.listen({ port }, () => resolve(undefined)));
|
||||
await Promise.all([api.start(), cdn.start(), gateway.start(), webrtc.start()]);
|
||||
|
||||
if (fs.existsSync("/proc/self/comm")) fs.writeFileSync("/proc/self/comm", `spacebar-bundle-${cluster.worker ? cluster.worker.id : port}`);
|
||||
|
||||
@@ -123,7 +123,7 @@ export async function initDatabase(): Promise<DataSource> {
|
||||
console.log("[Database] Skipping migrations as per config.");
|
||||
while (!(await dbExists())) {
|
||||
console.log("[Database] Database does not exist, and we are not running migrations... Waiting 1 seconds...");
|
||||
await new Promise((r) => setTimeout(r, 5000));
|
||||
await new Promise((r) => void setTimeout(r, 5000));
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -76,7 +76,7 @@ export class KittyLogo {
|
||||
});
|
||||
process.stdout.write("\x1b_Gi=31,s=1,v=1,a=q,t=d,f=24;AAAA\x1b\\\x1b[c");
|
||||
|
||||
await new Promise((res) => setTimeout(res, 5000));
|
||||
await new Promise((res) => void setTimeout(res, 5000));
|
||||
resolve(false);
|
||||
})();
|
||||
});
|
||||
|
||||
@@ -117,7 +117,7 @@ export class RabbitMQ {
|
||||
|
||||
console.log(`[RabbitMQ] Scheduling reconnection attempt ${this.reconnectAttempts} in ${this.BASE_RECONNECT_DELAY_MS}ms`);
|
||||
|
||||
await new Promise((resolve) => setTimeout(resolve, this.BASE_RECONNECT_DELAY_MS));
|
||||
await new Promise((resolve) => void setTimeout(resolve, this.BASE_RECONNECT_DELAY_MS));
|
||||
|
||||
try {
|
||||
await this.connect(host);
|
||||
|
||||
@@ -10,7 +10,7 @@ describe("Stopwatch", () => {
|
||||
|
||||
test("should measure elapsed time", async () => {
|
||||
const sw = Stopwatch.startNew();
|
||||
await new Promise((resolve) => setTimeout(resolve, 101));
|
||||
await new Promise((resolve) => void setTimeout(resolve, 101));
|
||||
sw.stop();
|
||||
const elapsed = sw.elapsed();
|
||||
assert(elapsed.totalMilliseconds >= 100, `Elapsed time was ${elapsed.totalMilliseconds} ms`);
|
||||
@@ -18,13 +18,13 @@ describe("Stopwatch", () => {
|
||||
|
||||
test("should reset correctly", async () => {
|
||||
const sw = Stopwatch.startNew();
|
||||
await new Promise((resolve) => setTimeout(resolve, 101));
|
||||
await new Promise((resolve) => void setTimeout(resolve, 101));
|
||||
sw.stop();
|
||||
let elapsed = sw.elapsed();
|
||||
assert(elapsed.totalMilliseconds >= 100, `Elapsed time was ${elapsed.totalMilliseconds} ms`);
|
||||
|
||||
sw.reset();
|
||||
await new Promise((resolve) => setTimeout(resolve, 50));
|
||||
await new Promise((resolve) => void setTimeout(resolve, 50));
|
||||
sw.stop();
|
||||
elapsed = sw.elapsed();
|
||||
assert(elapsed.totalMilliseconds >= 49 && elapsed.totalMilliseconds < 100, `Elapsed time after reset was ${elapsed.totalMilliseconds} ms`);
|
||||
@@ -32,12 +32,12 @@ describe("Stopwatch", () => {
|
||||
|
||||
test("getElapsedAndReset should work correctly", async () => {
|
||||
const sw = Stopwatch.startNew();
|
||||
await new Promise((resolve) => setTimeout(resolve, 101));
|
||||
await new Promise((resolve) => void setTimeout(resolve, 101));
|
||||
sw.stop();
|
||||
let elapsed = sw.getElapsedAndReset();
|
||||
assert(elapsed.totalMilliseconds >= 100, `Elapsed time was ${elapsed.totalMilliseconds} ms`);
|
||||
|
||||
await new Promise((resolve) => setTimeout(resolve, 50));
|
||||
await new Promise((resolve) => void setTimeout(resolve, 50));
|
||||
sw.stop();
|
||||
elapsed = sw.elapsed();
|
||||
assert(elapsed.totalMilliseconds >= 50 && elapsed.totalMilliseconds < 100, `Elapsed time after getElapsedAndReset was ${elapsed.totalMilliseconds} ms`);
|
||||
@@ -45,7 +45,7 @@ describe("Stopwatch", () => {
|
||||
|
||||
test("timePromise should measure promise execution time", async () => {
|
||||
const { result, elapsed } = await timePromise(async () => {
|
||||
await new Promise((resolve) => setTimeout(resolve, 101));
|
||||
await new Promise((resolve) => void setTimeout(resolve, 101));
|
||||
return 42;
|
||||
});
|
||||
assert.equal(result, 42);
|
||||
|
||||
@@ -143,7 +143,7 @@ export const checkToken = (
|
||||
};
|
||||
|
||||
const dec = jwt.decode(token, { complete: true });
|
||||
if (!dec) return rejectAndLog(reject, 500, "Failed to decode token");
|
||||
if (!dec) return void rejectAndLog(reject, 500, "Failed to decode token");
|
||||
logAuth("Decoded token: " + JSON.stringify(dec));
|
||||
|
||||
if (dec.header.alg == "HS256" && Config.get().security.jwtSecret !== null) {
|
||||
@@ -153,7 +153,7 @@ export const checkToken = (
|
||||
loadOrGenerateKeypair().then((keyPair) => {
|
||||
jwt.verify(token, keyPair.publicKey, { algorithms: ["ES512"] }, validateUser);
|
||||
});
|
||||
} else return rejectAndLog(reject, 400, "Unsupported token algorithm: " + dec.header.alg);
|
||||
} else return void rejectAndLog(reject, 400, "Unsupported token algorithm: " + dec.header.alg);
|
||||
});
|
||||
};
|
||||
|
||||
|
||||
@@ -2,5 +2,5 @@ export * from "./Array";
|
||||
|
||||
// TODO: move to a separate file
|
||||
export async function sleep(ms: number) {
|
||||
return new Promise((resolve) => setTimeout(resolve, ms));
|
||||
return new Promise((resolve) => void setTimeout(resolve, ms));
|
||||
}
|
||||
|
||||
@@ -65,6 +65,6 @@ export class Server {
|
||||
}
|
||||
|
||||
stop() {
|
||||
return new Promise<void>((res) => this.http.close(() => res()));
|
||||
return new Promise<void>((res) => void this.http.close(() => res()));
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user