support initiating 1-1 chats from matrix

src/index.ts

@@ -92,6 +92,8 @@ async function run() {
 	puppet.setCreateUserHook(steam.createUser.bind(steam));
 	// puppet.setGetUserIdsInRoomHook(steam.getUserIdsInRoom.bind(steam));
 	puppet.setListUsersHook(steam.listUsers.bind(steam));
+	puppet.setGetDmRoomIdHook(steam.getDmRoomId.bind(steam));
+	puppet.setCreateRoomHook(steam.createRoom.bind(steam));
 	puppet.setGetDescHook(async (puppetId: number, data: any): Promise<string> => {
 		let s = "Steam";
 		if (data.screenName) {

src/steam.ts

@@ -290,7 +290,7 @@ export class Steam {
 	}
 
 	public async listUsers(puppetId: number): Promise<IRetList[]> {
-		let friends = this.puppets[puppetId].client.users as {[steamId: string]: IPersona};
+		let friends = this.puppets[puppetId].client.users as { [steamId: string]: IPersona };
 
 		return Object.keys(friends).map((steamId) => ({
 			id: steamId,
@@ -298,6 +298,43 @@ export class Steam {
 		}));
 	}
 
+	public async getDmRoomId(user: IRemoteUser): Promise<string | null> {
+		log.info(`Got request for dm room id for ${user.userId}`);
+
+		if (!this.puppets[user.puppetId]) {
+			return null;
+		}
+
+		return user.userId;
+	}
+
+	public async createRoom(room: IRemoteRoom): Promise<IRemoteRoom | null> {
+		const p = this.puppets[room.puppetId];
+		if (!p) {
+			return null;
+		}
+
+		try {
+			let steamId = new SteamID(room.roomId);
+			if (!steamId.isValid()) {
+				throw new Error();
+			}
+
+			let persona = await this.getPersona(p, steamId);
+
+			log.info(`Got request to room user ${room.roomId}`);
+			return {
+				puppetId: room.puppetId,
+				roomId: room.roomId,
+				isDirect: true,
+				topic: persona.player_name
+			};
+		} catch (e) {
+			await this.bridge.sendStatusMessage(room.puppetId, `Creating group room chats is currently not supported`);
+			return null;
+		}
+	}
+
 	// public async getUserIdsInRoom(room: IRemoteRoom): Promise<Set<string> | null> {
 	// 	const p = this.puppets[room.puppetId];
 	// 	const client: TalkClient = p.client;