Merge branch 'develop'

2 files changed, 9 insertions, 4 deletions

diff --git a/src/server/api/stream/channels/messaging.ts b/src/server/api/stream/channels/messaging.ts
index 4c41dc820b..58427e2771 100644
--- a/src/server/api/stream/channels/messaging.ts
+++ b/src/server/api/stream/channels/messaging.ts
@@ -10,7 +10,7 @@ export default class extends Channel {
 	public static requireCredential = true;
 
 	private otherpartyId: string | null;
-	private otherparty?: User;
+	private otherparty: User | null;
 	private groupId: string | null;
 	private subCh: string;
 	private typers: Record<User['id'], Date> = {};
@@ -18,9 +18,9 @@ export default class extends Channel {
 
 	@autobind
 	public async init(params: any) {
-		this.otherpartyId = params.otherparty as string;
-		this.otherparty = await Users.findOne({ id: this.otherpartyId });
-		this.groupId = params.group as string;
+		this.otherpartyId = params.otherparty;
+		this.otherparty = this.otherpartyId ? await Users.findOneOrFail({ id: this.otherpartyId }) : null;
+		this.groupId = params.group;
 
 		// Check joining
 		if (this.groupId) {
diff --git a/src/server/api/stream/index.ts b/src/server/api/stream/index.ts
index 647b890ff8..75d82cfe66 100644
--- a/src/server/api/stream/index.ts
+++ b/src/server/api/stream/index.ts
@@ -92,6 +92,11 @@ export default class Connection {
 				this.userProfile = body;
 				break;
 
+			case 'terminate':
+				this.wsConnection.close();
+				this.dispose();
+				break;
+
 			default:
 				break;
 		}