Merge pull request #340 from GetStream/textarea-disable-example

feat: Define user$ Observable #338

Author: szuperaz

.github/workflows/workflow.yml

@@ -13,7 +13,7 @@ jobs:
     runs-on: ubuntu-latest
     strategy:
       matrix:
-        node-version: [16.x]
+        node-version: [14.x]
 
     steps:
       - uses: actions/checkout@v2

projects/stream-chat-angular/src/lib/chat-client.service.spec.ts

@@ -2,7 +2,11 @@ import { TestBed } from '@angular/core/testing';
 import { Event, OwnUserResponse, StreamChat } from 'stream-chat';
 import { version } from '../assets/version';
 import { ChatClientService } from './chat-client.service';
-import { mockStreamChatClient, MockStreamChatClient } from './mocks';
+import {
+  mockCurrentUser,
+  mockStreamChatClient,
+  MockStreamChatClient,
+} from './mocks';
 import { NotificationService } from './notification.service';
 import { DefaultStreamChatGenerics } from './types';
 
@@ -29,8 +33,11 @@ describe('ChatClientService', () => {
     expect(StreamChat.getInstance).toHaveBeenCalledWith(apiKey);
     const spy = jasmine.createSpy();
     service.appSettings$.subscribe(spy);
+    const userSpy = jasmine.createSpy();
+    service.user$.subscribe(userSpy);
 
     expect(spy).toHaveBeenCalledWith(undefined);
+    expect(userSpy).toHaveBeenCalledWith(mockCurrentUser());
   });
 
   it('should disconnect user', async () => {
@@ -40,6 +47,9 @@ describe('ChatClientService', () => {
     service.pendingInvites$.subscribe(pendingInvitesSpy);
     pendingInvitesSpy.calls.reset();
     eventsSpy.calls.reset();
+    const userSpy = jasmine.createSpy();
+    service.user$.subscribe(userSpy);
+    userSpy.calls.reset();
     await service.disconnectUser();
     const event = {
       id: 'mockevent',
@@ -50,6 +60,7 @@ describe('ChatClientService', () => {
     expect(mockChatClient.disconnectUser).toHaveBeenCalledWith();
     expect(pendingInvitesSpy).toHaveBeenCalledWith([]);
     expect(eventsSpy).not.toHaveBeenCalled();
+    expect(userSpy).toHaveBeenCalledWith(undefined);
   });
 
   it('should init with user meta data', async () => {

projects/stream-chat-angular/src/lib/chat-client.service.ts

@@ -53,6 +53,10 @@ export class ChatClientService<
    * Emits the list of pending invites of the user. It emits every pending invitation during initialization and then extends the list when a new invite is received. More information can be found in the [channel invitations](../code-examples/channel-invites.mdx) guide.
    */
   pendingInvites$: Observable<(ChannelResponse<T> | Channel<T>)[]>;
+  /**
+   * Emits the current chat user
+   */
+  user$: Observable<UserResponse<T> | undefined>;
   private notificationSubject = new ReplaySubject<ClientEvent<T>>(1);
   private connectionStateSubject = new ReplaySubject<'offline' | 'online'>(1);
   private appSettingsSubject = new BehaviorSubject<AppSettings | undefined>(
@@ -61,6 +65,7 @@ export class ChatClientService<
   private pendingInvitesSubject = new BehaviorSubject<
     (ChannelResponse<T> | Channel<T>)[]
   >([]);
+  private userSubject = new ReplaySubject<UserResponse<T> | undefined>(1);
   private subscriptions: { unsubscribe: () => void }[] = [];
 
   constructor(
@@ -71,6 +76,7 @@ export class ChatClientService<
     this.connectionState$ = this.connectionStateSubject.asObservable();
     this.appSettings$ = this.appSettingsSubject.asObservable();
     this.pendingInvites$ = this.pendingInvitesSubject.asObservable();
+    this.user$ = this.userSubject.asObservable();
   }
 
   /**
@@ -90,6 +96,7 @@ export class ChatClientService<
     await this.ngZone.runOutsideAngular(async () => {
       const user = typeof userOrId === 'string' ? { id: userOrId } : userOrId;
       result = await this.chatClient.connectUser(user, userTokenOrProvider);
+      this.userSubject.next(this.chatClient.user);
       this.chatClient.setUserAgent(
         `stream-chat-angular-${version}-${this.chatClient.getUserAgent()}`
       );
@@ -138,6 +145,7 @@ export class ChatClientService<
   async disconnectUser() {
     this.pendingInvitesSubject.next([]);
     await this.chatClient.disconnectUser();
+    this.userSubject.next(undefined);
     this.subscriptions.forEach((s) => s.unsubscribe());
   }