add support for ephemeral events

src/index.ts

@@ -137,6 +137,8 @@ async function run() {
 	puppet.on("removeReaction", slack.handleMatrixRemoveReaction.bind(slack));
 	puppet.on("image", slack.handleMatrixImage.bind(slack));
 	puppet.on("file", slack.handleMatrixFile.bind(slack));
+	puppet.on("presence", slack.handleMatrixPresence.bind(slack));
+	puppet.on("typing", slack.handleMatrixTyping.bind(slack));
 	puppet.setCreateUserHook(slack.createUser.bind(slack));
 	puppet.setCreateRoomHook(slack.createRoom.bind(slack));
 	puppet.setCreateGroupHook(slack.createGroup.bind(slack));

src/slack.ts

@@ -12,6 +12,7 @@ import {
 	IStringFormatterVars,
 	MessageDeduplicator,
 	ISendingUser,
+	IPresenceEvent,
 } from "mx-puppet-bridge";
 import {
 	SlackMessageParser, ISlackMessageParserOpts, MatrixMessageParser, IMatrixMessageParserOpts,
@@ -790,6 +791,46 @@ export class App {
 		}
 	}
 
+	public async handleMatrixPresence(
+		puppetId: number,
+		presence: IPresenceEvent,
+		asUser: ISendingUser | null,
+		event: any,
+	) {
+		const p = this.puppets[puppetId];
+		if (!p || asUser) {
+			return;
+		}
+		if (presence.statusMsg) {
+			await p.client.setStatus(presence.statusMsg);
+		}
+		await p.client.setPresence({
+			online: "auto",
+			offline: "away",
+			unavailable: "away",
+		}[presence.presence] as "auto" | "away");
+	}
+
+	public async handleMatrixTyping(
+		room: IRemoteRoom,
+		typing: boolean,
+		asUser: ISendingUser | null,
+		event: any,
+	) {
+		const p = this.puppets[room.puppetId];
+		if (!p || asUser) {
+			return;
+		}
+		const chan = p.client.getChannel(room.roomId);
+		if (!chan) {
+			log.warn(`Room ${room.roomId} not found!`);
+			return;
+		}
+		if (typing) {
+			await chan.sendTyping();
+		}
+	}
+
 	public async createRoom(room: IRemoteRoom): Promise<IRemoteRoom | null> {
 		const p = this.puppets[room.puppetId];
 		if (!p) {