Add TalkBlockSession. This implement #85

Add blockUser to OpenChannelSession.

package.json

@@ -1,6 +1,6 @@
 {
   "name": "node-kakao",
-  "version": "4.0.0-alpha.4",
+  "version": "4.0.0-alpha.5",
   "description": "Loco protocol compatible library",
   "main": "./dist/index.js",
   "exports": {

src/openlink/open-channel-session.ts

@@ -87,6 +87,13 @@ export interface OpenChannelSession {
      */
     kickUser(user: ChannelUser): AsyncCommandResult;
 
+    /**
+     * Block open user from the this channel permanently in client. This cannot be undone.
+     *
+     * @param user
+     */
+    blockUser(user: ChannelUser): AsyncCommandResult;
+
     /**
      * Get latest channel openlink
      */

src/talk/block/index.ts

@@ -0,0 +1,96 @@
+/*
+ * Created on Mon Feb 01 2021
+ *
+ * Copyright (c) storycraft. Licensed under the MIT Licence.
+ */
+
+import { AsyncCommandResult, KnownDataStatusCode } from "../../request";
+import { ChannelUser } from "../../user";
+import { TalkSession } from "../client";
+
+/**
+ * Provide user block / unblock api.
+ * Note: To get block list use web api.
+ */
+export class TalkBlockSession {
+
+    constructor(private _session: TalkSession) {
+
+    }
+
+    /**
+     * Block normal user
+     *
+     * @param user
+     * @param type
+     */
+    async blockUser(user: ChannelUser, type: TalkBlockType = TalkBlockType.BLOCK): AsyncCommandResult {
+        const res = await this._session.request(
+            'BLADDITEM',
+            {
+                'l': [user.userId],
+                'ts': [type]
+            }
+        );
+
+        return { success: res.status === KnownDataStatusCode.SUCCESS, status: res.status };
+    }
+
+    /**
+     * Block plus user
+     *
+     * @param plusUser
+     * @param type 
+     */
+    async blockPlusUser(plusUser: ChannelUser, type: TalkBlockType = TalkBlockType.BLOCK): AsyncCommandResult {
+        const res = await this._session.request(
+            'BLADDITEM',
+            {
+                'pl': [plusUser.userId],
+                'pts': [type]
+            }
+        );
+
+        return { success: res.status === KnownDataStatusCode.SUCCESS, status: res.status };
+    }
+
+    /**
+     * Unblock normal user.
+     *
+     * @param user
+     */
+    async unblockUser(user: ChannelUser) {
+        const res = await this._session.request(
+            'BLDELITEM',
+            {
+                'l': [user.userId],
+            }
+        );
+
+        return { success: res.status === KnownDataStatusCode.SUCCESS, status: res.status };
+    }
+
+    /**
+     * Unblock plus user.
+     *
+     * @param plusUser
+     */
+    async unblockPlusUser(plusUser: ChannelUser) {
+        const res = await this._session.request(
+            'BLDELITEM',
+            {
+                'pl': [plusUser.userId],
+            }
+        );
+
+        return { success: res.status === KnownDataStatusCode.SUCCESS, status: res.status };
+    }
+
+}
+
+export enum TalkBlockType {
+
+    BLOCK = 0,
+    BLOCK_HIDE_PROFILE = 1
+
+}

src/talk/client/index.ts

@@ -22,6 +22,7 @@ import { TalkChannelList } from "../talk-channel-list";
 import { ClientEvents } from "../event";
 import { Long } from "bson";
 import { TypedEmitter } from "../../event";
+import { TalkBlockSession } from "../block";
 
 export * from "./talk-client-session";
 
@@ -53,6 +54,7 @@ export class TalkClient extends TypedEmitter<ClientEvents> implements CommandSes
     private _clientSession: TalkClientSession;
 
     private _cilentUser: ChannelUser;
+    private _blockList: TalkBlockSession;
 
     private _channelList: TalkChannelList;
 
@@ -70,6 +72,7 @@ export class TalkClient extends TypedEmitter<ClientEvents> implements CommandSes
         this._channelList = new TalkChannelList(this.createSessionProxy());
 
         this._cilentUser = { userId: Long.ZERO };
+        this._blockList = new TalkBlockSession(this.createSessionProxy());
 
         this._openLink = new OpenLinkService(this.createSessionProxy());
     }
@@ -94,6 +97,12 @@ export class TalkClient extends TypedEmitter<ClientEvents> implements CommandSes
         return this._cilentUser;
     }
 
+    get blockList() {
+        if (!this.logon) throw new Error('Cannot access without logging in');
+
+        return this._blockList;
+    }
+
     get openLink() {
         if (!this.logon) throw new Error('Cannot access without logging in');
 

src/talk/index.ts

@@ -4,6 +4,7 @@
  * Copyright (c) storycraft. Licensed under the MIT Licence.
  */
 
+export * from "./block";
 export * from "./chat";
 export * from "./channel";
 export * from "./talk-channel-list";

src/talk/openlink/talk-open-channel-session.ts

@@ -201,6 +201,21 @@ export class TalkOpenChannelSession implements OpenChannelSession {
         return { status: res.status, success: res.status === KnownDataStatusCode.SUCCESS };
     }
 
+    async blockUser(user: ChannelUser): AsyncCommandResult {
+        const res = await this._session.request(
+            'BLIND',
+            {
+                'c': this._channel.channelId,
+                'li': this._channel.linkId,
+                'mid': user.userId,
+                // Reporting user is not supported.
+                'r': false
+            }
+        );
+
+        return { status: res.status, success: res.status === KnownDataStatusCode.SUCCESS };
+    }
+
     async changeProfile(profile: OpenLinkProfiles): AsyncCommandResult<Readonly<OpenLinkChannelUserInfo> | null> {
         const res = await this._session.request(
             'UPLINKPROF',

src/talk/openlink/talk-open-channel.ts

@@ -393,6 +393,10 @@ export class TalkOpenChannel extends TypedEmitter<OpenChannelEvents> implements
         return res;
     }
 
+    async blockUser(user: ChannelUser) {
+        return this._openChannelSession.blockUser(user);
+    }
+
     react(flag: boolean) {
         return this._openChannelSession.react(flag);
     }

src/talk/talk-channel-list.ts

@@ -90,8 +90,10 @@ export class TalkChannelList extends TypedEmitter<TalkChannelListEvents> impleme
             }
         });
 
-        await TalkNormalChannelList.initialize(talkChannelList._normalList, normalList);
-        await TalkOpenChannelList.initialize(talkChannelList._openList, openList);
+        await Promise.all([
+            TalkNormalChannelList.initialize(talkChannelList._normalList, normalList),
+            TalkOpenChannelList.initialize(talkChannelList._openList, openList)
+        ]);
 
         return talkChannelList;
     }

src/user/channel-user.ts

@@ -6,10 +6,9 @@
 
 import { Long } from "bson";
 import { OpenLinkComponent } from "../openlink";
-import { OpenChannelUserPerm } from "../openlink/open-link-type";
 
 /**
- * Channel user
+ * Any user that can talk via channel.
  */
 export interface ChannelUser {