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

fix(gateway): remove Collection

Browse Source
This commit is contained in:
Yuzu 2022-07-13 10:14:43 -05:00
parent 5225d46a73
commit 815e0f4bf8
2 changed files with 1 additions and 102 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
packages/discordeno/gateway/manager/shardManager.ts
View File

@ -1,6 +1,5 @@
import { DiscordGatewayPayload } from "../../types/discord.ts"; import { DiscordGatewayPayload } from "../../types/discord.ts";
import { PickPartial } from "../../types/shared.ts"; import { PickPartial } from "../../types/shared.ts";
import { Collection } from "../../util/collection.ts";
import { CreateShard, createShard } from "../shard/createShard.ts"; import { CreateShard, createShard } from "../shard/createShard.ts";
import { Shard, ShardGatewayConfig } from "../shard/types.ts"; import { Shard, ShardGatewayConfig } from "../shard/types.ts";
@ -33,7 +32,7 @@ export function createShardManager(options: CreateShardManager) {
/** Gateway configuration which is used when creating a Shard. */ /** Gateway configuration which is used when creating a Shard. */
gatewayConfig: options.gatewayConfig, gatewayConfig: options.gatewayConfig,
/** Managed Shards. */ /** Managed Shards. */
shards: new Collection( shards: new Map(
options.shardIds.map((shardId) => { options.shardIds.map((shardId) => {
const shard = createShard({ const shard = createShard({
...options.createShardOptions, ...options.createShardOptions,

100
packages/discordeno/util/collection.ts
View File

@ -1,100 +0,0 @@
export class Collection<K, V> extends Map<K, V> {
maxSize: number | undefined;
constructor(entries?: (readonly (readonly [K, V])[] | null) | Map<K, V>, options?: CollectionOptions<K, V>) {
super(entries ?? []);
this.maxSize = options?.maxSize;
}
set(key: K, value: V) {
// When this collection is maxSized make sure we can add first
if ((this.maxSize || this.maxSize === 0) && this.size >= this.maxSize) {
return this;
}
return super.set(key, value);
}
forceSet(key: K, value: V) {
return super.set(key, value);
}
array() {
return [...this.values()];
}
/** Retrieve the value of the first element in this collection */
first(): V | undefined {
return this.values().next().value;
}
last(): V | undefined {
return [...this.values()][this.size - 1];
}
random(): V | undefined {
const array = [...this.values()];
return array[Math.floor(Math.random() * array.length)];
}
find(callback: (value: V, key: K) => boolean) {
for (const key of this.keys()) {
const value = this.get(key)!;
if (callback(value, key)) return value;
}
// If nothing matched
return;
}
filter(callback: (value: V, key: K) => boolean) {
const relevant = new Collection<K, V>();
this.forEach((value, key) => {
if (callback(value, key)) relevant.set(key, value);
});
return relevant;
}
map<T>(callback: (value: V, key: K) => T) {
const results = [];
for (const key of this.keys()) {
const value = this.get(key)!;
results.push(callback(value, key));
}
return results;
}
some(callback: (value: V, key: K) => boolean) {
for (const key of this.keys()) {
const value = this.get(key)!;
if (callback(value, key)) return true;
}
return false;
}
every(callback: (value: V, key: K) => boolean) {
for (const key of this.keys()) {
const value = this.get(key)!;
if (!callback(value, key)) return false;
}
return true;
}
reduce<T>(callback: (accumulator: T, value: V, key: K) => T, initialValue?: T): T {
let accumulator: T = initialValue!;
for (const key of this.keys()) {
const value = this.get(key)!;
accumulator = callback(accumulator, value, key);
}
return accumulator;
}
}
export interface CollectionOptions<K, V> {
maxSize?: number;
}