partey_workadventure/pusher/src/Services/ApiClientRepository.ts

/**
 * A class to get connections to the correct "api" server given a room name.
 */
import {RoomManagerClient} from "../Messages/generated/messages_grpc_pb";
import grpc from 'grpc';
import crypto from 'crypto';
import {API_URL} from "../Enum/EnvironmentVariable";

import Debug from "debug";

const debug = Debug('apiClientRespository');

class ApiClientRepository {
    private roomManagerClients: RoomManagerClient[] = [];

    public constructor(private apiUrls: string[]) {}

    public async getClient(roomId: string): Promise<RoomManagerClient> {
        const array = new Uint32Array(crypto.createHash('md5').update(roomId).digest());
        const index = array[0] % this.apiUrls.length;

        let client = this.roomManagerClients[index];
        if (client === undefined) {
            this.roomManagerClients[index] = client = new RoomManagerClient(this.apiUrls[index], grpc.credentials.createInsecure());
            debug('Mapping room %s to API server %s', roomId, this.apiUrls[index])
        }

        return Promise.resolve(client);
    }

    public async getAllClients(): Promise<RoomManagerClient[]> {
        return [await this.getClient('')];
    }
}

const apiClientRepository = new ApiClientRepository(API_URL.split(','));

export { apiClientRepository };