Fix SYNCJOIN to work properly.

This fix is hacky so need to be fixed in future

Author: storycraft

src/talk/channel/talk-channel-handler.ts

@@ -24,7 +24,7 @@ import {
 } from '../../chat';
 import { EventContext, TypedEmitter } from '../../event';
 import { ChannelEvents, ChannelListEvent } from '../event';
-import { ChgMetaRes, DecunreadRes, LeftRes, MsgRes, SyncJoinRes } from '../../packet/chat';
+import { ChgMetaRes, DecunreadRes, LeftRes, MsgRes } from '../../packet/chat';
 import { ChatlogStruct, structToChatlog } from '../../packet/struct';
 import { AsyncCommandResult, DefaultRes } from '../../request';
 import { ChannelUserInfo } from '../../user';
@@ -296,22 +296,6 @@ export class TalkChannelListHandler<T extends Channel> implements Managed<Channe
         break;
       }
 
-      // TODO: Move SYNCJOIN handling to TalkChannelList
-      case 'SYNCJOIN': {
-        const joinData = data as DefaultRes & SyncJoinRes;
-
-        const res = await this._updater.addChannel({ channelId: joinData.c });
-        if (res.success) {
-          this._callEvent(
-            parentCtx,
-            'channel_join',
-            res.result as T,
-          );
-        }
-
-        break;
-      }
-
       default: break;
     }
   }

src/talk/channel/talk-normal-channel-list.ts

@@ -25,7 +25,7 @@ import { TalkChannelManageSession } from './talk-channel-session';
 import { ClientDataLoader } from '../../loader';
 import { updateChatList } from './common';
 
-type TalkNormalChannelListEvents = NormalChannelListEvents<TalkNormalChannel, NormalChannelUserInfo>;
+export type TalkNormalChannelListEvents = NormalChannelListEvents<TalkNormalChannel, NormalChannelUserInfo>;
 
 /**
  * Manage session channels

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

@@ -37,7 +37,7 @@ import { OpenChannelUserInfo } from '../../user';
 import { ClientDataLoader } from '../../loader';
 import { TalkClientLinkStore } from './client-link-store';
 
-type TalkOpenChannelListEvents = OpenChannelListEvents<TalkOpenChannel, OpenChannelUserInfo>;
+export type TalkOpenChannelListEvents = OpenChannelListEvents<TalkOpenChannel, OpenChannelUserInfo>;
 
 /**
  * Manage open profile, channel.

src/talk/talk-channel-list.ts

@@ -5,19 +5,27 @@
  */
 
 import { Long } from 'bson';
-import { ChannelStore, LoginData, NormalChannelData } from '../channel';
+import { Channel, ChannelStore, LoginData, NormalChannelData } from '../channel';
 import { TalkSession } from './client';
 import { EventContext, TypedEmitter } from '../event';
 import { InformedOpenLink, OpenChannelData } from '../openlink';
 import { DefaultRes } from '../request';
-import { ChainedIterator } from '../util';
+import { ChainedIterator, JsonUtil } from '../util';
 import { ChannelListEvents } from './event';
 import { Managed } from './managed';
-import { TalkOpenChannel, TalkOpenChannelList } from './openlink';
-import { ChannelListUpdater, TalkChannel, TalkNormalChannel, TalkNormalChannelList } from './channel';
+import { TalkOpenChannel, TalkOpenChannelList, TalkOpenChannelListEvents } from './openlink';
+import {
+  ChannelListUpdater,
+  TalkChannel,
+  TalkNormalChannel,
+  TalkNormalChannelList,
+  TalkNormalChannelListEvents
+} from './channel';
 import { ChannelUserInfo } from '../user';
 import { ClientDataLoader } from '../loader';
-import { MsgRes } from '../packet/chat';
+import { MsgRes, SyncJoinRes } from '../packet/chat';
+import { structToChatlog } from '../packet/struct';
+import { KnownChatType, KnownFeedType } from '../chat';
 
 type TalkChannelListEvents = ChannelListEvents<TalkChannel, ChannelUserInfo>;
 
@@ -98,6 +106,40 @@ export class TalkChannelList
           ctx.emit('channel_added', res.result);
         }
       }
+    } else if (method === 'SYNCJOIN') {
+      const joinData = data as DefaultRes & SyncJoinRes;
+      
+      if (joinData.chatLog) {
+        const chat = structToChatlog(joinData.chatLog);
+        
+        if (chat.type === KnownChatType.FEED && chat.text) {
+          const content = JsonUtil.parseLoseless(chat.text);
+
+          const channel: Channel = { channelId: joinData.c };
+
+          if (content['feedType'] === KnownFeedType.OPENLINK_JOIN) {
+            const openRes = await this._open.addChannel(channel);
+
+            if (openRes.success) {
+              const childCtx = new EventContext<TalkOpenChannelListEvents>(this._open, ctx);
+              childCtx.emit(
+                'channel_join',
+                openRes.result,
+              );
+            }
+          } else {
+            const normalRes = await this._normal.addChannel(channel);
+
+            if (normalRes.success) {
+              const childCtx = new EventContext<TalkNormalChannelListEvents>(this._normal, ctx);
+              childCtx.emit(
+                'channel_join',
+                normalRes.result,
+              );
+            }
+          }
+        }
+      }
     }
 
     await this._normal.pushReceived(method, data, ctx);