/* * Copyright (c) 2023 Hunan OpenValley Digital Industry Development Co., Ltd. * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ import { ChatBox } from './ChatBox'; import Logger from '../../utils/Logger'; class BasicDataSource implements IDataSource { private listeners: DataChangeListener[] = []; public totalCount(): number { return 0; } public getData(index: number): ESObject { return undefined; } registerDataChangeListener(listener: DataChangeListener): void { if (this.listeners.indexOf(listener) < 0) { Logger.info('add listener'); this.listeners.push(listener); } } unregisterDataChangeListener(listener: DataChangeListener): void { const pos = this.listeners.indexOf(listener); if (pos >= 0) { Logger.info('remove listener'); this.listeners.splice(pos, 1); } } notifyDataReload(): void { this.listeners.forEach((listener) => { listener.onDataReloaded(); }); } notifyDataAdd(index: number): void { this.listeners.forEach((listener) => { listener.onDataAdd(index); }); } notifyDataChange(index: number): void { this.listeners.forEach((listener) => { listener.onDataChange(index); }); } notifyDataDelete(index: number): void { this.listeners.forEach((listener) => { listener.onDataDelete(index); }); } notifyDataMove(from: number, to: number): void { this.listeners.forEach((listener) => { listener.onDataMove(from, to); }); } } export class ChatSource extends BasicDataSource { private chatsArray: Array = []; public totalCount(): number { return this.chatsArray.length; } public getData(index: number): ChatBox { return this.chatsArray[index]; } public addData(index: number, data: ChatBox): void { this.chatsArray.splice(index, 0, data); this.notifyDataAdd(index); } public pushData(data: ChatBox): void { this.chatsArray.push(data); this.notifyDataAdd(this.chatsArray.length - 1); } }