tiramisu/seyfert
5
0
Fork 0
mirror of https://github.com/tiramisulabs/seyfert.git synced 2025-07-02 21:16:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: deno environment variable support (#316)

Browse Source 
* fix: deno environment variable support

* fix: avoid unnecessary string construction
This commit is contained in:
veryCrunchy 2024-12-28 06:00:05 +01:00 committed by GitHub
parent 72ae9e65ca
commit ce86aa78ff
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/client/workerclient.ts
View File

@ -38,19 +38,19 @@ let workerData: WorkerData;
let manager: import('node:worker_threads').MessagePort; let manager: import('node:worker_threads').MessagePort;
try { try {
workerData = { workerData = {
debug: process.env.SEYFERT_WORKER_DEBUG === 'true', debug: String(process.env.SEYFERT_WORKER_DEBUG) === 'true',
intents: Number(process.env.SEYFERT_WORKER_INTENTS), intents: Number(process.env.SEYFERT_WORKER_INTENTS),
path: process.env.SEYFERT_WORKER_PATH!, path: process.env.SEYFERT_WORKER_PATH!,
shards: JSON.parse(process.env.SEYFERT_WORKER_SHARDS!), shards: JSON.parse(process.env.SEYFERT_WORKER_SHARDS!),
token: process.env.SEYFERT_WORKER_TOKEN!, token: process.env.SEYFERT_WORKER_TOKEN!,
workerId: Number(process.env.SEYFERT_WORKER_WORKERID), workerId: Number(process.env.SEYFERT_WORKER_WORKERID),
workerProxy: process.env.SEYFERT_WORKER_WORKERPROXY === 'true', workerProxy: String(process.env.SEYFERT_WORKER_WORKERPROXY) === 'true',
totalShards: Number(process.env.SEYFERT_WORKER_TOTALSHARDS), totalShards: Number(process.env.SEYFERT_WORKER_TOTALSHARDS),
mode: process.env.SEYFERT_WORKER_MODE as 'custom' | 'threads' | 'clusters', mode: process.env.SEYFERT_WORKER_MODE as 'custom' | 'threads' | 'clusters',
resharding: process.env.SEYFERT_WORKER_RESHARDING === 'true', resharding: String(process.env.SEYFERT_WORKER_RESHARDING) === 'true',
totalWorkers: Number(process.env.SEYFERT_WORKER_TOTALWORKERS), totalWorkers: Number(process.env.SEYFERT_WORKER_TOTALWORKERS),
info: JSON.parse(process.env.SEYFERT_WORKER_INFO!), info: JSON.parse(process.env.SEYFERT_WORKER_INFO!),
compress: process.env.SEYFERT_WORKER_COMPRESS === 'true', compress: String(process.env.SEYFERT_WORKER_COMPRESS) === 'true',
} satisfies WorkerData; } satisfies WorkerData;
} catch { } catch {
// //
@ -443,7 +443,11 @@ export class WorkerClient<Ready extends boolean = boolean> extends BaseClient {
} }
async resumeShard(shardId: number, shardData: MakeRequired<ShardData>) { async resumeShard(shardId: number, shardData: MakeRequired<ShardData>) {
const exists = (await this.tellWorkers((r, vars) => r.shards.has(vars.shardId), { shardId })).some(x => x); const exists = (
await this.tellWorkers((r, vars) => r.shards.has(vars.shardId), {
shardId,
})
).some(x => x);
if (exists) throw new Error('Cannot override existing shard'); if (exists) throw new Error('Cannot override existing shard');
const shard = this.createShard(shardId, { const shard = this.createShard(shardId, {
info: this.workerData.info, info: this.workerData.info,