2023-06-30 11:05:33 +00:00
|
|
|
package libgm
|
2023-06-30 09:54:08 +00:00
|
|
|
|
|
|
|
import (
|
|
|
|
"fmt"
|
|
|
|
|
|
|
|
"go.mau.fi/mautrix-gmessages/libgm/binary"
|
|
|
|
)
|
|
|
|
|
2023-07-15 21:55:55 +00:00
|
|
|
func (c *Client) ListConversations(count int64, folder binary.ListConversationsPayload_Folder) (*binary.Conversations, error) {
|
|
|
|
payload := &binary.ListConversationsPayload{Count: count, Folder: folder}
|
2023-07-15 21:26:22 +00:00
|
|
|
//var actionType binary.ActionType
|
|
|
|
//if !c.synced {
|
|
|
|
// actionType = binary.ActionType_LIST_CONVERSATIONS_SYNC
|
|
|
|
// c.synced = true
|
|
|
|
//} else {
|
|
|
|
actionType := binary.ActionType_LIST_CONVERSATIONS
|
|
|
|
|
2023-07-15 22:45:57 +00:00
|
|
|
response, err := c.sessionHandler.sendMessage(actionType, payload)
|
2023-06-30 09:54:08 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
2023-07-09 11:16:52 +00:00
|
|
|
res, ok := response.Data.Decrypted.(*binary.Conversations)
|
|
|
|
if !ok {
|
2023-07-15 21:16:36 +00:00
|
|
|
return nil, fmt.Errorf("unexpected response type %T, expected *binary.Conversations", response.Data.Decrypted)
|
2023-06-30 09:54:08 +00:00
|
|
|
}
|
|
|
|
|
2023-07-09 11:16:52 +00:00
|
|
|
return res, nil
|
2023-06-30 09:54:08 +00:00
|
|
|
}
|
|
|
|
|
2023-07-16 21:51:17 +00:00
|
|
|
func (c *Client) ListContacts() (*binary.ListContactsResponse, error) {
|
|
|
|
payload := &binary.ListContactsPayload{
|
|
|
|
I1: 1,
|
|
|
|
I2: 350,
|
|
|
|
I3: 50,
|
|
|
|
}
|
|
|
|
actionType := binary.ActionType_LIST_CONTACTS
|
|
|
|
|
|
|
|
response, err := c.sessionHandler.sendMessage(actionType, payload)
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
res, ok := response.Data.Decrypted.(*binary.ListContactsResponse)
|
|
|
|
if !ok {
|
|
|
|
return nil, fmt.Errorf("unexpected response type %T, expected *binary.ListContactsResponse", response.Data.Decrypted)
|
|
|
|
}
|
|
|
|
|
|
|
|
return res, nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c *Client) ListTopContacts() (*binary.ListTopContactsResponse, error) {
|
|
|
|
payload := &binary.ListTopContactsPayload{
|
|
|
|
Count: 8,
|
|
|
|
}
|
|
|
|
actionType := binary.ActionType_LIST_TOP_CONTACTS
|
|
|
|
|
|
|
|
response, err := c.sessionHandler.sendMessage(actionType, payload)
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
res, ok := response.Data.Decrypted.(*binary.ListTopContactsResponse)
|
|
|
|
if !ok {
|
|
|
|
return nil, fmt.Errorf("unexpected response type %T, expected *binary.ListTopContactsResponse", response.Data.Decrypted)
|
|
|
|
}
|
|
|
|
|
|
|
|
return res, nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c *Client) GetOrCreateConversation(numbers []string) (*binary.GetOrCreateConversationResponse, error) {
|
|
|
|
contacts := make([]*binary.ContactNumber, len(numbers))
|
|
|
|
for i, number := range numbers {
|
|
|
|
contacts[i] = &binary.ContactNumber{
|
|
|
|
MysteriousInt: 7,
|
|
|
|
Number: number,
|
|
|
|
Number2: number,
|
|
|
|
}
|
|
|
|
}
|
|
|
|
payload := &binary.GetOrCreateConversationPayload{
|
|
|
|
Numbers: contacts,
|
|
|
|
}
|
|
|
|
actionType := binary.ActionType_GET_OR_CREATE_CONVERSATION
|
|
|
|
|
|
|
|
response, err := c.sessionHandler.sendMessage(actionType, payload)
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
res, ok := response.Data.Decrypted.(*binary.GetOrCreateConversationResponse)
|
|
|
|
if !ok {
|
|
|
|
return nil, fmt.Errorf("unexpected response type %T, expected *binary.GetOrCreateConversationResponse", response.Data.Decrypted)
|
|
|
|
}
|
|
|
|
|
|
|
|
return res, nil
|
|
|
|
}
|
|
|
|
|
2023-07-15 21:26:22 +00:00
|
|
|
func (c *Client) GetConversationType(conversationID string) (*binary.GetConversationTypeResponse, error) {
|
|
|
|
payload := &binary.ConversationTypePayload{ConversationID: conversationID}
|
2023-07-09 11:16:52 +00:00
|
|
|
actionType := binary.ActionType_GET_CONVERSATION_TYPE
|
2023-06-30 09:54:08 +00:00
|
|
|
|
2023-07-15 22:45:57 +00:00
|
|
|
response, err := c.sessionHandler.sendMessage(actionType, payload)
|
2023-07-09 11:16:52 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
2023-06-30 09:54:08 +00:00
|
|
|
}
|
|
|
|
|
2023-07-09 11:16:52 +00:00
|
|
|
res, ok := response.Data.Decrypted.(*binary.GetConversationTypeResponse)
|
|
|
|
if !ok {
|
2023-07-15 21:16:36 +00:00
|
|
|
return nil, fmt.Errorf("unexpected response type %T, expected *binary.GetConversationTypeResponse", response.Data.Decrypted)
|
2023-06-30 09:54:08 +00:00
|
|
|
}
|
|
|
|
|
2023-07-09 11:16:52 +00:00
|
|
|
return res, nil
|
2023-06-30 09:54:08 +00:00
|
|
|
}
|
|
|
|
|
2023-07-15 21:26:22 +00:00
|
|
|
func (c *Client) FetchMessages(conversationID string, count int64, cursor *binary.Cursor) (*binary.FetchMessagesResponse, error) {
|
|
|
|
payload := &binary.FetchConversationMessagesPayload{ConversationID: conversationID, Count: count}
|
2023-07-09 11:16:52 +00:00
|
|
|
if cursor != nil {
|
|
|
|
payload.Cursor = cursor
|
2023-06-30 09:54:08 +00:00
|
|
|
}
|
|
|
|
|
2023-07-09 11:16:52 +00:00
|
|
|
actionType := binary.ActionType_LIST_MESSAGES
|
2023-06-30 09:54:08 +00:00
|
|
|
|
2023-07-15 22:45:57 +00:00
|
|
|
response, err := c.sessionHandler.sendMessage(actionType, payload)
|
2023-06-30 09:54:08 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
2023-07-09 11:16:52 +00:00
|
|
|
res, ok := response.Data.Decrypted.(*binary.FetchMessagesResponse)
|
|
|
|
if !ok {
|
2023-07-15 21:16:36 +00:00
|
|
|
return nil, fmt.Errorf("unexpected response type %T, expected *binary.FetchMessagesResponse", response.Data.Decrypted)
|
2023-07-09 11:16:52 +00:00
|
|
|
}
|
2023-06-30 09:54:08 +00:00
|
|
|
|
2023-07-09 11:16:52 +00:00
|
|
|
return res, nil
|
|
|
|
}
|
2023-06-30 09:54:08 +00:00
|
|
|
|
2023-07-15 21:26:22 +00:00
|
|
|
func (c *Client) SendMessage(payload *binary.SendMessagePayload) (*binary.SendMessageResponse, error) {
|
2023-07-09 11:16:52 +00:00
|
|
|
actionType := binary.ActionType_SEND_MESSAGE
|
|
|
|
|
2023-07-15 22:45:57 +00:00
|
|
|
response, err := c.sessionHandler.sendMessage(actionType, payload)
|
2023-07-09 11:16:52 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
2023-06-30 09:54:08 +00:00
|
|
|
}
|
|
|
|
|
2023-07-09 11:16:52 +00:00
|
|
|
res, ok := response.Data.Decrypted.(*binary.SendMessageResponse)
|
|
|
|
if !ok {
|
2023-07-15 21:16:36 +00:00
|
|
|
return nil, fmt.Errorf("unexpected response type %T, expected *binary.SendMessageResponse", response.Data.Decrypted)
|
2023-06-30 09:54:08 +00:00
|
|
|
}
|
2023-07-09 11:16:52 +00:00
|
|
|
|
|
|
|
return res, nil
|
2023-06-30 09:54:08 +00:00
|
|
|
}
|
2023-07-09 17:35:29 +00:00
|
|
|
|
2023-07-15 21:26:22 +00:00
|
|
|
func (c *Client) GetParticipantThumbnail(convID string) (*binary.ParticipantThumbnail, error) {
|
2023-07-09 17:35:29 +00:00
|
|
|
payload := &binary.GetParticipantThumbnailPayload{ConversationID: convID}
|
|
|
|
actionType := binary.ActionType_GET_PARTICIPANTS_THUMBNAIL
|
|
|
|
|
2023-07-15 22:45:57 +00:00
|
|
|
response, err := c.sessionHandler.sendMessage(actionType, payload)
|
2023-07-09 17:35:29 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
res, ok := response.Data.Decrypted.(*binary.ParticipantThumbnail)
|
|
|
|
if !ok {
|
2023-07-15 21:16:36 +00:00
|
|
|
return nil, fmt.Errorf("unexpected response type %T, expected *binary.ParticipantThumbnail", response.Data.Decrypted)
|
2023-07-09 17:35:29 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return res, nil
|
|
|
|
}
|
|
|
|
|
2023-07-15 21:26:22 +00:00
|
|
|
func (c *Client) UpdateConversation(convBuilder *ConversationBuilder) (*binary.UpdateConversationResponse, error) {
|
2023-07-09 17:35:29 +00:00
|
|
|
data := &binary.UpdateConversationPayload{}
|
|
|
|
|
|
|
|
payload, buildErr := convBuilder.Build(data)
|
|
|
|
if buildErr != nil {
|
|
|
|
panic(buildErr)
|
|
|
|
}
|
|
|
|
|
|
|
|
actionType := binary.ActionType_UPDATE_CONVERSATION
|
|
|
|
|
2023-07-15 22:45:57 +00:00
|
|
|
response, err := c.sessionHandler.sendMessage(actionType, payload)
|
2023-07-09 17:35:29 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
res, ok := response.Data.Decrypted.(*binary.UpdateConversationResponse)
|
|
|
|
if !ok {
|
2023-07-15 21:16:36 +00:00
|
|
|
return nil, fmt.Errorf("unexpected response type %T, expected *binary.UpdateConversationResponse", response.Data.Decrypted)
|
2023-07-09 17:35:29 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return res, nil
|
|
|
|
}
|
2023-07-15 16:48:11 +00:00
|
|
|
|
2023-07-15 21:26:22 +00:00
|
|
|
func (c *Client) SetTyping(convID string) error {
|
2023-07-15 16:48:11 +00:00
|
|
|
payload := &binary.TypingUpdatePayload{Data: &binary.SetTypingIn{ConversationID: convID, Typing: true}}
|
|
|
|
actionType := binary.ActionType_TYPING_UPDATES
|
|
|
|
|
2023-07-15 22:45:57 +00:00
|
|
|
_, err := c.sessionHandler.sendMessage(actionType, payload)
|
|
|
|
return err
|
2023-07-15 16:48:11 +00:00
|
|
|
}
|