Add methods to send internal messages.

This commit is contained in:
Joachim Bauch 2022-07-12 11:55:26 +02:00
parent e101e74672
commit 7d9970713d
No known key found for this signature in database
GPG key ID: 77C1D22D53E15F02

View file

@ -474,6 +474,42 @@ func (c *TestClient) SendControl(recipient MessageClientMessageRecipient, data i
return c.WriteJSON(message)
}
func (c *TestClient) SendInternalAddSession(msg *AddSessionInternalClientMessage) error {
message := &ClientMessage{
Id: "abcd",
Type: "internal",
Internal: &InternalClientMessage{
Type: "addsession",
AddSession: msg,
},
}
return c.WriteJSON(message)
}
func (c *TestClient) SendInternalUpdateSession(msg *UpdateSessionInternalClientMessage) error {
message := &ClientMessage{
Id: "abcd",
Type: "internal",
Internal: &InternalClientMessage{
Type: "updatesession",
UpdateSession: msg,
},
}
return c.WriteJSON(message)
}
func (c *TestClient) SendInternalRemoveSession(msg *RemoveSessionInternalClientMessage) error {
message := &ClientMessage{
Id: "abcd",
Type: "internal",
Internal: &InternalClientMessage{
Type: "removesession",
RemoveSession: msg,
},
}
return c.WriteJSON(message)
}
func (c *TestClient) SetTransientData(key string, value interface{}) error {
payload, err := json.Marshal(value)
if err != nil {