108 lines
3.2 KiB
TypeScript
108 lines
3.2 KiB
TypeScript
import * as plugins from './smartuniverse.plugins.js';
|
|
import * as interfaces from './interfaces/index.js';
|
|
|
|
import { ClientUniverse } from './index.js';
|
|
import { ClientUniverseMessage } from './smartuniverse.classes.client.universemessage.js';
|
|
import { ReactionRequest } from './smartuniverse.classes.event.reactionrequest.js';
|
|
import { ReactionResponse } from './smartuniverse.classes.event.reactionresponse.js';
|
|
|
|
export class ClientUniverseChannel implements interfaces.IUniverseChannel {
|
|
// ======
|
|
// STATIC
|
|
// ======
|
|
/**
|
|
* creates a channel and adds it to the cache of clientUniverseArg
|
|
* @param clientUniverseArg
|
|
* @param channelNameArg
|
|
* @param passphraseArg
|
|
*/
|
|
public static createClientUniverseChannel(
|
|
clientUniverseArg: ClientUniverse,
|
|
channelNameArg: string,
|
|
passphraseArg: string
|
|
): ClientUniverseChannel {
|
|
const clientChannel = new ClientUniverseChannel(
|
|
clientUniverseArg,
|
|
channelNameArg,
|
|
passphraseArg
|
|
);
|
|
clientUniverseArg.clientUniverseCache.channelMap.add(clientChannel);
|
|
return clientChannel;
|
|
}
|
|
|
|
// ========
|
|
// INSTANCE
|
|
// ========
|
|
|
|
// properties
|
|
public name: string;
|
|
public passphrase: string;
|
|
public status: 'subscribed' | 'unsubscribed' = 'unsubscribed';
|
|
private subject = new plugins.smartrx.rxjs.Subject<ClientUniverseMessage<any>>();
|
|
|
|
// refs
|
|
public clientUniverseRef: ClientUniverse;
|
|
|
|
constructor(clientUniverseArg: ClientUniverse, nameArg: string, passphraseArg: string) {
|
|
this.clientUniverseRef = clientUniverseArg;
|
|
this.name = nameArg;
|
|
this.passphrase = passphraseArg;
|
|
}
|
|
|
|
/**
|
|
* subscribes to a channel
|
|
* tells the universe about this instances interest into a channel
|
|
*/
|
|
public subscribe(observingFunctionArg: (messageArg: ClientUniverseMessage<any>) => void) {
|
|
return this.subject.subscribe(
|
|
(messageArg) => {
|
|
observingFunctionArg(messageArg);
|
|
},
|
|
(error) => console.log(error)
|
|
);
|
|
}
|
|
|
|
public unsubscribe() {
|
|
// TODO: unsubscribe all users
|
|
}
|
|
|
|
public async populateSubscriptionToServer() {
|
|
// lets make sure the channel is connected
|
|
if (this.status === 'unsubscribed') {
|
|
const response =
|
|
await this.clientUniverseRef.smartsocketClient.serverCall<interfaces.ISocketRequest_SubscribeChannel>(
|
|
'subscribeChannel',
|
|
{
|
|
name: this.name,
|
|
passphrase: this.passphrase,
|
|
}
|
|
);
|
|
this.status = response.subscriptionStatus;
|
|
}
|
|
}
|
|
|
|
public async emitMessageLocally(messageArg: ClientUniverseMessage<any>) {
|
|
this.subject.next(messageArg);
|
|
}
|
|
|
|
/**
|
|
* sends a message towards the server
|
|
* @param messageArg
|
|
*/
|
|
public async postMessage(messageArg: interfaces.IMessageCreator) {
|
|
await this.clientUniverseRef.start(); // its ok to call this multiple times
|
|
const universeMessageToSend: interfaces.IUniverseMessage = {
|
|
id: plugins.isounique.uni(),
|
|
timestamp: Date.now(),
|
|
passphrase: this.passphrase,
|
|
targetChannelName: this.name,
|
|
messageText: messageArg.messageText,
|
|
payload: messageArg.payload,
|
|
};
|
|
await this.clientUniverseRef.smartsocketClient.serverCall(
|
|
'processMessage',
|
|
universeMessageToSend
|
|
);
|
|
}
|
|
}
|