core

type ApiError struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

type CodeMessage struct {
	Message
	Code     string `json:"code"`
	Language string `json:"language"`
	Title    string `json:"title"`
	LockedBy int    `json:"lockedBy" pg:"lockedby"`
}

type Conversation struct {
	Title           string `json:"title"`
	ID              int    `json:"id"`
	Repourl         string `json:"repoUrl"`
	NUnreadMessages int    `json:"nUnreadMessages" pg:"unreadmessagescount"`
}

type ConversationRepo interface {

	// Mutations
	DeleteConversation(id int) error
	CreateConversation(userID int, c Conversation, initialMembers []int) (Conversation, error)
	MarkAsInvited(userID, conversationID int) error
	MarkAsJoined(userID, conversationID int) (int, error)
	RemoveGroupAssociation(userID, conversationID int) error
	SetMetaDataOfConversation(conversation Conversation) error
	SetAsLeft(userID, conversationID int) error
	SetAdminState(userID, conversationID int, state bool) error

	// Queries
	FindInvitations(userid int) ([]Invitation, error)
	FindConversations() ([]Conversation, error)
	FindConversationForID(conversationID int) (Conversation, error)
	FindConversationsForUser(userid int) ([]Conversation, error)
	IsUserInConversation(userID, conversationID int) (bool, error)
	IsUserAdminOfConveration(userID, conversationID int) (bool, error)
	GetUsersInConversation(conversationID int) ([]UserInConversation, error)
	CountAdminsOfConversation(conversationID int) (int, error)
}

type Cronological interface {
	GetDate() time.Time
}

type DataBaseError struct {
	APIError ApiError
	Err      error
}

type Invitation struct {
	ConversationID    int    `json:"conversationId"`
	ConversationTitle string `json:"conversationTitle"`
	Recipient         int    `json:"recipient"`
}

type MailingService interface {
	SendEmail(to, subject, body string) error
}

type MediaMessage struct {
	Message
	Text  string        `json:"text"`
	Files []MediaObject `json:"files"`
}

type MediaObject struct {
	ID       int             `json:"id"`
	MIMEType string          `json:"mimeType" pg:"filetype"`
	Name     string          `json:"name"`
	Meta     json.RawMessage `json:"meta"`
}

type Message struct {
	ID             int         `json:"id"`
	Type           MessageType `json:"type"`
	Sentdate       time.Time   `json:"sentdate"`
	ProvisionaryID int         `json:"provisionaryId,omitempty"`
	Author         string      `json:"author"`
}

type MessageRepo interface {

	// Mutations
	StoreTextMessage(conversation, user int, m TextMessage) (int, error)
	StoreCodeMessage(conversation, user int, m CodeMessage) (int, error)
	StoreMediaMessage(conversation, user int, m MediaMessage) (int, error)
	SetReadFlags(userid, conversationID int) error
	UpdateCode(messageID int, newCode, title, language string) error
	SetLockedSateForCodeMessage(messageID int, lockingUserID int) error
	CreateMediaObject(messageID int, name, fileType string) (int, error)
	SetMetaOfMediaMessage(id int, meta interface{}) error
	DeleteMessage(id int) error
	UpdateCompleteFlag(id int) error

	// Queries
	FindForConversation(conversationID, beforeInSequence, limit int) ([]interface{}, error)
	FindCodeMessagesForConversation(conversationID, beforeInSequence, limit int) ([]interface{}, error)
	FindTextMessagesForConversation(conversationID, beforeInSequence, limit int) ([]interface{}, error)
	FindMediaMessagesForConversation(conversationID, beforeInSequence, limit int) ([]interface{}, error)
	FindCodeMessageForID(messageID, conversationID int) (CodeMessage, error)
	FindTextMessageForID(messageID, conversationID int) (TextMessage, error)
	FindMediaMessageForID(messageID, conversationID int) (MediaMessage, error)
	FindMessageStubForConversation(conversationID, messageID int) (Message, error)
	FindAllProgrammingLanguages() ([]ProgrammingLanguage, error)
	FindMediaObjectForID(id, conversationID int) (MediaObject, error)
}

type MessageType int

type ProgrammingLanguage struct {
	Name       string `json:"name"`
	IsRunnable bool   `pg:"IsRunnable" json:"isRunnable"`
}

type Pusher interface {
	BroadcastToRoom(roomNumber int, payload interface{}, ctx context.Context)
	Unicast(ctx context.Context, userID int, payload interface{})
}

type RequestLimitExceededError struct {
	Err       ApiError
	RateLimit map[string]int
}

type Sequencable interface {
	GetSequenceNumber() int
}

type Size struct {
	Width  int `json:"width"`
	Height int `json:"height"`
}

type TextMessage struct {
	Message
	Text string `json:"text"`
}

type User struct {
	ID                  int       `pg:"id" json:"id"`
	Email               string    `pg:"email" json:"email,omitempty"`
	Name                string    `pg:"name" json:"name"`
	ConfirmationUUID    uuid.UUID `json:"-"`
	LockedOutSince      time.Time `json:"-"`
	FailedLoginAttempts int       `json:"-"`
	LastFailedLogin     time.Time `json:"-"`
	IsDeleted           bool      `pg:"isdeleted" json:"isDeleted"`
}

type UserInConversation struct {
	User
	IsAdmin    bool `pg:"isadmin" json:"isAdmin"`
	ColorIndex int  `pg:"colorindex" json:"colorIndex"`
	HasJoined  bool `pg:"hasjoined" json:"hasJoined"`
	HasLeft    bool `pg:"hasleft" json:"hasLeft"`
}

type UserRepo interface {

	// Mutations
	LockUser(userID int) error
	UnlockUser(userID int) error
	SetConfirmationIDToNULL(token string) (string, error)
	SoftDeleteUser(userid int) error
	CreateUser(user User, password string) (User, error)
	IncrementFailedLoginAttempts(user string) error
	SetPassword(user int, newPassword string) error
	CreateRecoverID(emailAddress string) (uuid.UUID, error)
	UpdateOnlineState(userID int) error
	RecoverPassword(recoveryUUID uuid.UUID, password string) (string, error)

	// Queries
	CompareCredentials(userID int, password string) (int, error)
	GetUserForID(userID int) (User, error)
	GetUserForName(name string) (User, error)
	GetUsersForPrefix(prefix string, limit int) ([]User, error)
	SelectRecoveryTokenIssueDate(recoveryUUID uuid.UUID) (time.Time, error)

	// Internal
	DeleteUser(userid int) error
}