client_actions.go

package matrixapi

import (
	"fmt"
)

// JoinedRooms returns a list of the user's current rooms.
// If fromCache is true then local cache will be used.
// https://matrix.org/docs/spec/client_server/r0.4.0.html#get-matrix-client-r0-joined-rooms
func (client *Client) JoinedRooms(fromCache bool) (map[string]*JoinedRoomC, error) {
	const path = "/_matrix/client/r0/joined_rooms"

	if !fromCache { // Update current room list from server
		var joinedRoomReply JoinedRoomReply
		err := client.do("GET", path, nil, &joinedRoomReply)
		if err != nil {
			return nil, err
		}

		updatedJoinedRooms := make(map[string]*JoinedRoomC)
		for _, roomID := range joinedRoomReply.JoinedRooms {
			if _, exists := client.joinedRooms[roomID]; exists {
				updatedJoinedRooms[roomID] = client.joinedRooms[roomID]
			} else {
				updatedJoinedRooms[roomID] = &JoinedRoomC{}
			}
		}
		client.joinedRooms = updatedJoinedRooms
	}

	return client.joinedRooms, nil
}

// TODO: make universal {roomId}/send/{eventType}/{txnId}
// https://matrix.org/docs/spec/client_server/r0.4.0.html#id258
func (client *Client) SendTextMessage(roomID string, text string) (eventID string, err error) {
	path := fmt.Sprintf("/_matrix/client/r0/rooms/%s/send/m.room.message", roomID)

	request := SendMessageRequest{
		MessageType: MessageTypeText,
		Body:        text}

	var reply SendMessageReply

	err = client.do("POST", path, request, &reply)
	if err != nil {
		return "", err
	}

	return reply.EventID, nil
}

// TODO: make universal {roomId}/send/{eventType}/{txnId}
// https://matrix.org/docs/spec/client_server/r0.4.0.html#id258
func (client *Client) SendTextReply(roomID string, messageID string, text string) (eventID string, err error) {
	path := fmt.Sprintf("/_matrix/client/r0/rooms/%s/send/m.room.message", roomID)

	request := SendMessageRequest{
		MessageType: MessageTypeText,
		Body:        text,
		RelatesTo: MRelatesTo{
			InReplyTo: MInReplyTo{
				EventID: messageID}}}

	var reply SendMessageReply

	err = client.do("POST", path, request, &reply)
	if err != nil {
		return "", err
	}

	return reply.EventID, nil
}

func (client *Client) Logout() error {
	const path = "/_matrix/client/r0/logout"

	return client.do("POST", path, struct{}{}, nil)
}

func (client *Client) CreateRoom(createRoomRequest CreateRoomRequest) (roomID string, err error) {
	const path = "/_matrix/client/r0/createRoom"

	var reply CreateRoomReply
	err = client.do("POST", path, createRoomRequest, &reply)
	if err != nil {
		return
	}

	return reply.RoomID, nil
}

func (client *Client) LeaveRoom(room string) error {
	path := fmt.Sprintf("/_matrix/client/r0/rooms/%s/leave", room)

	return client.do("POST", path, struct{}{}, nil)
}

func (client *Client) Sync() error {
	// https://matrix.org/docs/spec/client_server/r0.4.0.html#get-matrix-client-r0-sync
	const path = "/_matrix/client/r0/sync"

	var syncRequest SyncRequest
	syncRequest.Since = client.nextBatch

	var reply SyncReply
	err := client.do("GET", path, &syncRequest, &reply)
	if err != nil {
		return err
	}
	client.nextBatch = reply.NextBatch

	for roomID, room := range reply.Rooms.Join {
		for _, event := range room.Timeline.Events {
			client.processRoomEvent(roomID, event)
		}
	}

	for roomID, invite := range reply.Rooms.Invite {
		inviteC := &InviteC{Members: make(map[string]*RoomMember)}
		client.Invites[roomID] = inviteC
		for _, event := range invite.InviteState.Events {
			client.processInviteEvent(inviteC, event)
		}
		if client.InviteHandler != nil {
			client.InviteHandler(roomID, inviteC.InviterID)
		}
	}

	return nil
}

func (client *Client) JoinRoom(roomID string) error {
	// https://matrix.org/docs/spec/client_server/r0.4.0.html#id276
	var path = fmt.Sprintf("/_matrix/client/r0/rooms/%s/join", roomID)

	var reply JoinRoomReply
	err := client.do("POST", path, struct{}{}, &reply)
	if err != nil {
		return err
	}

	// Удаляем инвайты
	delete(client.Invites, roomID)

	return nil
}

// Versions returns versions of the specification supported by the server
// https://matrix.org/docs/spec/client_server/r0.4.0.html#get-well-known-matrix-client
func (client *Client) Versions() ([]string, error) {
	const path = "/_matrix/client/versions"

	var reply VersionsReply
	err := client.do("GET", path, struct{}{}, &reply)
	if err != nil {
		return nil, err
	}

	return reply.Versions, nil
}

// https://matrix.org/docs/spec/client_server/r0.4.0.html#post-matrix-client-r0-logout-all
func (client *Client) LogoutAll() error {
	const path = "/_matrix/client/r0/logout/all"

	err := client.do("POST", path, nil, nil)
	if err != nil {
		return err
	}

	return nil
}

// TODO: return cached client.UserID?
// https://matrix.org/docs/spec/client_server/r0.4.0.html#get-matrix-client-r0-account-whoami
func (client *Client) WhoAmI() (userID string, err error) {
	const path = "/_matrix/client/r0/account/whoami"

	var whoAmIReply WhoAmIReply
	err = client.do("GET", path, nil, &whoAmIReply)
	if err != nil {
		return "", err
	}

	return whoAmIReply.UserID, nil
}