add to sending room messages
This commit is contained in:
12
sdk/main.ts
12
sdk/main.ts
@@ -88,6 +88,7 @@ interface MatrixRTCSdk {
|
|||||||
/** Use the LocalMemberConnectionState returned from `join` for a more detailed connection state */
|
/** Use the LocalMemberConnectionState returned from `join` for a more detailed connection state */
|
||||||
connected$: Behavior<boolean>;
|
connected$: Behavior<boolean>;
|
||||||
sendData?: (data: unknown) => Promise<void>;
|
sendData?: (data: unknown) => Promise<void>;
|
||||||
|
sendRoomMessage?: (message: string) => Promise<void>;
|
||||||
}
|
}
|
||||||
|
|
||||||
export async function createMatrixRTCSdk(
|
export async function createMatrixRTCSdk(
|
||||||
@@ -250,6 +251,16 @@ export async function createMatrixRTCSdk(
|
|||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
const sendRoomMessage = async (message: string): Promise<void> => {
|
||||||
|
const messageString = JSON.stringify(message);
|
||||||
|
logger.info("try sending to room: ", messageString);
|
||||||
|
try {
|
||||||
|
await client.sendTextMessage(room.roomId, message);
|
||||||
|
} catch (e) {
|
||||||
|
logger.error("failed sending to room: ", messageString, e);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
// after hangup gets called
|
// after hangup gets called
|
||||||
const leaveSubs = callViewModel.leave$.subscribe(() => {
|
const leaveSubs = callViewModel.leave$.subscribe(() => {
|
||||||
const scheduleWidgetCloseOnLeave = async (): Promise<void> => {
|
const scheduleWidgetCloseOnLeave = async (): Promise<void> => {
|
||||||
@@ -344,5 +355,6 @@ export async function createMatrixRTCSdk(
|
|||||||
[],
|
[],
|
||||||
),
|
),
|
||||||
sendData,
|
sendData,
|
||||||
|
sendRoomMessage,
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user