You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
89 lines
2.9 KiB
89 lines
2.9 KiB
import { Subject } from "../observe/Observable";
|
|
import { Model } from "./AbstractModel";
|
|
import { Observer } from "../observe/Observer";
|
|
import { fetchErrorHandler } from "./FetchErrorHandler";
|
|
import { ActiveUserViewModel } from "../viewmodel/ActiveUserViewModel";
|
|
import { ChatMessageViewModel } from "../viewmodel/ChatMessageViewModel";
|
|
import { JsonAPI } from "../singleton/JsonAPI";
|
|
import log = require('loglevel');
|
|
import { EncryptionService } from "../service/EncryptionService";
|
|
import { SJCLEncryptionService } from "../service/SJCLEncryptionService";
|
|
import { ChatMessageDTO } from "../dto/ChatMessageDTO";
|
|
import { ChatModelHelper } from "./ChatModelHelper";
|
|
|
|
export class ChatModel implements Subject {
|
|
/**
|
|
* @type {Observer[]} List of subscribers. In real life, the list of
|
|
* subscribers can be stored more comprehensively (categorized by event
|
|
* type, etc.).
|
|
*/
|
|
private readonly _observers: Observer[] = [];
|
|
private state: ChatMessageViewModel[] | null;
|
|
private readonly _messagesMap: Map<string, ChatMessageViewModel[]>;
|
|
|
|
constructor() {
|
|
this.state = null;
|
|
this._messagesMap = new Map();
|
|
}
|
|
/**
|
|
* The subscription management methods.
|
|
*/
|
|
public attach(observer: Observer): void {
|
|
console.log('Subject: Attached an observer.');
|
|
this._observers.push(observer);
|
|
}
|
|
|
|
public detach(observer: Observer): void {
|
|
const observerIndex = this._observers.indexOf(observer);
|
|
this._observers.splice(observerIndex, 1);
|
|
console.log('Subject: Detached an observer.');
|
|
}
|
|
|
|
public setUserMessages(username: string, messages: ChatMessageViewModel[]) {
|
|
this._messagesMap.set(username, messages);
|
|
}
|
|
|
|
/**
|
|
* Trigger an update in each subscriber.
|
|
*/
|
|
public notify(userName: string): void {
|
|
console.log('Subject: Notifying observers...');
|
|
for (const observer of this._observers) {
|
|
observer.update(this._messagesMap.get(userName));
|
|
}
|
|
}
|
|
|
|
public someBusinessMethod(chatMessageList: ChatMessageViewModel[]): void {
|
|
this.state = chatMessageList;
|
|
this.helperMethod();
|
|
console.log(`Subject: My state has just changed`);
|
|
console.log(chatMessageList);
|
|
this.notify("some user");
|
|
}
|
|
|
|
public async getmessages(userName: string, passphrase: string, lastMessageTime: string | null): Promise<ChatMessageViewModel[]> {
|
|
const cVMs = await ChatModelHelper.getMessages(userName, passphrase, lastMessageTime, this);
|
|
if (cVMs != null) {
|
|
log.info('Subject: My state has just changed')
|
|
log.debug(cVMs);
|
|
this._messagesMap.set(userName, cVMs);
|
|
this.notify(userName);
|
|
}
|
|
else {
|
|
log.error('Messages were null');
|
|
}
|
|
|
|
return cVMs;
|
|
}
|
|
|
|
|
|
|
|
private helperMethod() { }
|
|
|
|
public populateMessages(): void {
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|