package chat

import (
	"go.m3o.com/client"
)

type Chat interface {
	Create(*CreateRequest) (*CreateResponse, error)
	Delete(*DeleteRequest) (*DeleteResponse, error)
	History(*HistoryRequest) (*HistoryResponse, error)
	Invite(*InviteRequest) (*InviteResponse, error)
	Join(*JoinRequest) (*JoinResponseStream, error)
	Kick(*KickRequest) (*KickResponse, error)
	Leave(*LeaveRequest) (*LeaveResponse, error)
	List(*ListRequest) (*ListResponse, error)
	Send(*SendRequest) (*SendResponse, error)
}

func NewChatService(token string) *ChatService {
	return &ChatService{
		client: client.NewClient(&client.Options{
			Token: token,
		}),
	}
}

type ChatService struct {
	client *client.Client
}

// Create a new chat room
func (t *ChatService) Create(request *CreateRequest) (*CreateResponse, error) {

	rsp := &CreateResponse{}
	return rsp, t.client.Call("chat", "Create", request, rsp)

}

// Delete a chat room
func (t *ChatService) Delete(request *DeleteRequest) (*DeleteResponse, error) {

	rsp := &DeleteResponse{}
	return rsp, t.client.Call("chat", "Delete", request, rsp)

}

// List the messages in a chat
func (t *ChatService) History(request *HistoryRequest) (*HistoryResponse, error) {

	rsp := &HistoryResponse{}
	return rsp, t.client.Call("chat", "History", request, rsp)

}

// Invite a user to a chat room
func (t *ChatService) Invite(request *InviteRequest) (*InviteResponse, error) {

	rsp := &InviteResponse{}
	return rsp, t.client.Call("chat", "Invite", request, rsp)

}

// Join a chat room
func (t *ChatService) Join(request *JoinRequest) (*JoinResponseStream, error) {
	stream, err := t.client.Stream("chat", "Join", request)
	if err != nil {
		return nil, err
	}
	return &JoinResponseStream{
		stream: stream,
	}, nil

}

type JoinResponseStream struct {
	stream *client.Stream
}

func (t *JoinResponseStream) Recv() (*JoinResponse, error) {
	var rsp JoinResponse
	if err := t.stream.Recv(&rsp); err != nil {
		return nil, err
	}
	return &rsp, nil
}

// Kick a user from a chat room
func (t *ChatService) Kick(request *KickRequest) (*KickResponse, error) {

	rsp := &KickResponse{}
	return rsp, t.client.Call("chat", "Kick", request, rsp)

}

// Leave a chat room
func (t *ChatService) Leave(request *LeaveRequest) (*LeaveResponse, error) {

	rsp := &LeaveResponse{}
	return rsp, t.client.Call("chat", "Leave", request, rsp)

}

// List available chats
func (t *ChatService) List(request *ListRequest) (*ListResponse, error) {

	rsp := &ListResponse{}
	return rsp, t.client.Call("chat", "List", request, rsp)

}

// Connect to a chat to receive a stream of messages
// Send a message to a chat
func (t *ChatService) Send(request *SendRequest) (*SendResponse, error) {

	rsp := &SendResponse{}
	return rsp, t.client.Call("chat", "Send", request, rsp)

}

type CreateRequest struct {
	// chat description
	Description string `json:"description"`
	// name of the room
	Name string `json:"name"`
	// whether its a private room
	Private bool `json:"private"`
	// optional list of user ids
	UserIds string `json:"user_ids"`
}

type CreateResponse struct {
	// the unique chat room
	Room *Room `json:"room"`
}

type DeleteRequest struct {
	// the chat room id to delete
	RoomId string `json:"room_id"`
}

type DeleteResponse struct {
	Room *Room `json:"room"`
}

type HistoryRequest struct {
	// the chat room id to get
	RoomId string `json:"room_id"`
}

type HistoryResponse struct {
	// messages in the chat room
	Messages []Message `json:"messages"`
}

type InviteRequest struct {
	// the room id
	RoomId string `json:"room_id"`
	// the user id
	UserId string `json:"user_id"`
}

type InviteResponse struct {
	Room *Room `json:"room"`
}

type JoinRequest struct {
	// chat room to join
	RoomId string `json:"room_id"`
	// user id joining
	UserId string `json:"user_id"`
}

type JoinResponse struct {
	Message *Message `json:"message"`
}

type KickRequest struct {
	// the chat room id
	RoomId string `json:"room_id"`
	// the user id
	UserId string `json:"user_id"`
}

type KickResponse struct {
	Room *Room `json:"room"`
}

type LeaveRequest struct {
	// the chat room id
	RoomId string `json:"room_id"`
	// the user id
	UserId string `json:"user_id"`
}

type LeaveResponse struct {
	Room *Room `json:"room"`
}

type ListRequest struct {
	// optional user id to filter by
	UserId string `json:"user_id"`
}

type ListResponse struct {
	Rooms []Room `json:"rooms"`
}

type Message struct {
	// a client side id, should be validated by the server to make the request retry safe
	Client string `json:"client"`
	// id of the message, allocated by the server
	Id string `json:"id"`
	// id of the chat the message is being sent to / from
	RoomId string `json:"room_id"`
	// time the message was sent in RFC3339 format
	SentAt string `json:"sent_at"`
	// subject of the message
	Subject string `json:"subject"`
	// text of the message
	Text string `json:"text"`
	// id of the user who sent the message
	UserId string `json:"user_id"`
}

type Room struct {
	// time of creation
	CreatedAt string `json:"created_at"`
	// description of the that
	Description string `json:"description"`
	// unique room id
	Id string `json:"id"`
	// name of the chat
	Name string `json:"name"`
	// whether its a private room
	Private bool `json:"private"`
	// list of users
	UserIds string `json:"user_ids"`
}

type SendRequest struct {
	// a client side id, should be validated by the server to make the request retry safe
	Client string `json:"client"`
	// id of the chat room the message is being sent to / from
	RoomId string `json:"room_id"`
	// subject of the message
	Subject string `json:"subject"`
	// text of the message
	Text string `json:"text"`
	// id of the user who sent the message
	UserId string `json:"user_id"`
}

type SendResponse struct {
	// the message which was created
	Message *Message `json:"message"`
}