Update tell_cluster_to_identify.ts

This commit is contained in:
ITOH
2021-04-29 11:16:31 +02:00
parent 10b824901c
commit c0a549a634

View File

@@ -1,4 +1,3 @@
import { closeWS } from "./close_ws.ts";
import { ws } from "./ws.ts";
/** Allows users to hook in and change to communicate to different clusters across different servers or anything they like. For example using redis pubsub to talk to other servers. */
@@ -7,11 +6,5 @@ export async function tellClusterToIdentify(
shardId: number,
_bucketId: number,
) {
// When resharding this may exist already
const oldShard = ws.shards.get(shardId);
await ws.identify(shardId, ws.maxShards);
if (oldShard) {
closeWS(oldShard.ws, 3063, "Resharded!");
}
}