import { Component, OnInit, OnDestroy, Output, EventEmitter } from '@angular/core'; import { Subscription, of } from 'rxjs'; import { Store, select } from '@ngrx/store'; import { tap, map, catchError } from 'rxjs/operators'; import * as AppStore from '@app/store'; import * as SyncStore from '@app/store/messenger/sync'; import * as RoomStore from '@app/store/messenger/room'; import { UserInfo } from '@ucap-webmessenger/protocol-room'; import { VersionInfo2Response } from '@ucap-webmessenger/api-public'; import { SessionStorageService } from '@ucap-webmessenger/web-storage'; import { KEY_VER_INFO } from '@app/types/ver-info.type'; import { DialogService } from '@ucap-webmessenger/ui'; import { SelectGroupDialogComponent, SelectGroupDialogResult, SelectGroupDialogData } from '../../dialogs/group/select-group.dialog.component'; import { GroupDetailData } from '@ucap-webmessenger/protocol-sync'; import { CreateChatDialogComponent, CreateChatDialogResult, CreateChatDialogData } from '../../dialogs/chat/create-chat.dialog.component'; import { UserSelectDialogType } from '@app/types'; import { LoginResponse } from '@ucap-webmessenger/protocol-authentication'; import { KEY_LOGIN_RES_INFO } from '@app/types/login-res-info.type'; import { MessageApiService, MessageType, RetrieveRequest } from '@ucap-webmessenger/api-message'; import { DeviceType } from '@ucap-webmessenger/core'; import { StatusCode, MessageStatusCode } from '@ucap-webmessenger/api'; @Component({ selector: 'app-layout-chat-right-drawer-message-box', templateUrl: './message-box.component.html', styleUrls: ['./message-box.component.scss'] }) export class MessageBoxComponent implements OnInit, OnDestroy { userInfoList: UserInfo[]; userInfoListSubscription: Subscription; loginRes: LoginResponse; sessionVerinfo: VersionInfo2Response; messageSendListSubscription: Subscription; pageSize = 100; // default currentPage = 0; // start index is 0. constructor( private store: Store, private sessionStorageService: SessionStorageService, private dialogService: DialogService, private messageApiService: MessageApiService ) { this.loginRes = this.sessionStorageService.get( KEY_LOGIN_RES_INFO ); this.sessionVerinfo = this.sessionStorageService.get( KEY_VER_INFO ); } ngOnInit() { this.userInfoListSubscription = this.store .pipe( select(AppStore.MessengerSelector.RoomSelector.selectUserinfolist), tap(userInfoList => { this.userInfoList = userInfoList; }) ) .subscribe(); this.messageSendListSubscription = this.messageApiService .retrieveSendMessage({ userSeq: this.loginRes.userSeq, deviceType: DeviceType.PC, tokenKey: this.loginRes.tokenString, type: MessageType.Send, pageSize: this.pageSize, pageCount: this.currentPage } as RetrieveRequest) .pipe( map(res => { console.log(res); if (res.responseCode === MessageStatusCode.Success) { } else { } }), catchError(error => of(console.log(error))) ) .subscribe(); } ngOnDestroy(): void { if (!!this.userInfoListSubscription) { this.userInfoListSubscription.unsubscribe(); } if (!!this.messageSendListSubscription) { this.messageSendListSubscription.unsubscribe(); } } }