smartuniverse/ts/smartuniverse.classes.clientuniversechannel.ts

84 lines
2.3 KiB
TypeScript
Raw Permalink Normal View History

import * as plugins from './smartuniverse.plugins';
2019-04-11 15:52:01 +00:00
import * as interfaces from './interfaces';
2019-04-11 15:52:01 +00:00
import { ClientUniverse } from './';
2019-04-11 15:52:01 +00:00
export class ClientUniverseChannel implements interfaces.IUniverseChannel {
// ======
// STATIC
// ======
2019-04-22 21:11:51 +00:00
/**
* creates a channel and adds it to the cache of clientUniverseArg
* @param clientUniverseArg
2019-04-22 22:28:57 +00:00
* @param channelNameArg
* @param passphraseArg
2019-04-22 21:11:51 +00:00
*/
2019-08-13 16:41:27 +00:00
public static createClientUniverseChannel(
clientUniverseArg: ClientUniverse,
2019-04-22 21:11:51 +00:00
channelNameArg: string,
2019-04-22 07:58:36 +00:00
passphraseArg: string
2019-08-13 16:41:27 +00:00
): ClientUniverseChannel {
2019-04-22 22:28:57 +00:00
const clientChannel = new ClientUniverseChannel(
clientUniverseArg,
channelNameArg,
passphraseArg
);
2019-08-13 13:48:20 +00:00
clientUniverseArg.clientUniverseCache.channelMap.add(clientChannel);
return clientChannel;
}
// ========
// INSTANCE
// ========
2019-04-22 20:04:52 +00:00
// properties
public name: string;
2019-04-22 07:58:36 +00:00
public passphrase: string;
2019-04-22 22:28:57 +00:00
2019-04-22 20:04:52 +00:00
// refs
2019-08-12 15:23:10 +00:00
public clientUniverseRef: ClientUniverse;
2019-04-22 22:28:57 +00:00
constructor(clientUniverseArg: ClientUniverse, nameArg: string, passphraseArg: string) {
2019-08-12 15:23:10 +00:00
this.clientUniverseRef = clientUniverseArg;
2019-04-22 20:04:52 +00:00
this.name = nameArg;
2019-04-22 11:06:01 +00:00
this.passphrase = passphraseArg;
}
/**
2019-04-22 11:06:01 +00:00
* subscribes to a channel
* tells the universe about this instances interest into a channel
*/
2019-04-22 11:06:01 +00:00
public async subscribe() {
2019-08-12 12:59:37 +00:00
const serverCallActionName: interfaces.IServerCallActions = 'channelSubscription';
2019-04-24 21:27:57 +00:00
const serverCallActionPayload: interfaces.IServerCallSubscribeActionPayload = {
name: this.name,
passphrase: this.passphrase
};
2019-09-01 15:04:25 +00:00
await this.clientUniverseRef.smartsocketClient.serverCall(
serverCallActionName,
serverCallActionPayload
);
2019-08-12 15:23:10 +00:00
}
/**
* sends a message towards the server
* @param messageArg
*/
public async sendMessage(messageArg: interfaces.IMessageCreator) {
await this.clientUniverseRef.checkConnection();
const universeMessageToSend: interfaces.IUniverseMessage = {
id: plugins.smartunique.shortId(),
timestamp: Date.now(),
passphrase: this.passphrase,
targetChannelName: this.name,
messageText: messageArg.messageText,
payload: messageArg.payload,
payloadStringType: messageArg.payloadStringType
};
2019-09-01 15:04:25 +00:00
await this.clientUniverseRef.smartsocketClient.serverCall(
'processMessage',
universeMessageToSend
);
}
}