data

type BrokerEvent struct {
	Event   string      `json:"event"`
	Payload interface{} `json:"payload"`
}

type Configuration struct {
	TorPublicAddress string
	PublicKey        string
}

type Conversation struct {
	ConversationID string   `json:"conversation_id"` // it's the conversation name sha
	Name           string   `json:"name"`
	Recipients     []string `json:"recipients"` // recipient's publickey, for now with size 1, this will be used for group chats
	Lastupdate     string   `json:"-"`
}

type Device struct {
	URL       string `json:"url"`   // kxtfrw2fnlnby4nnuh77xeoaiokb6y7vik3nddjfryjk7bdj4xfz3hqd
	Alias     string `json:"alias"` // only local, to display
	PublicKey string `json:"public_key"`
	IsOnline  bool   `json:"is_online"`
	SharedKey string `json:"-"`
}

type DeviceRequest struct {
	URL       string        `json:"url"`
	PublicKey string        `json:"public_key"`
	Alias     string        `json:"alias"`
	Status    RequestStatus `json:"status"`
}

type DevicesDatabase interface {
	StoreRequest(request DeviceRequest) error
	GetRequests() []DeviceRequest
	GetRequestByURL(url string) *DeviceRequest
	DeleteRequest(request DeviceRequest) error

	StoreDevice(device Device) error
	GetDevices() []Device
	GetDeviceByURL(url string) *Device
	GetDeviceByPublicKey(publicKey string) *Device
	DeleteDevice(device Device) error

	ConfirmRequest(request DeviceRequest, sharedKey string) (*Device, error)
}

type DevicesSqliteDB struct {
	SqliteDB
}

type Identity struct {
	Name               string               `json:"name"`
	PublicServiceKeys  torHiddenServiceKeys `json:"public_service_keys"`
	PrivateServiceKeys torHiddenServiceKeys `json:"private_service_keys"`
	PublicKey          string               `json:"public_key"`
	PrivateKey         string               `json:"private_key"`
}

type Message struct {
	MessageID      string `json:"message_id"` // nonce
	ConversationID string `json:"conversation_id"`
	Recipient      string `json:"recipient"` // it's the device public key, "SELF" for your own messages
	Content        string `json:"content"`
	Timestamp      string `json:"timestamp"`
}

type MessageDB interface {
	GetConversations() []Conversation //sorted by lastupdate
	GetConversationByID(conversationID string) *Conversation
	GetConversationsByRecipient(recipient string) []Conversation
	StoreConversation(conversation Conversation) error
	RefreshConversationLastUpdate(conversationID string, timestamp string) error

	GetNewestMessages(conversationID string, count int) []Message
	//GetMessagesPage(conversationID string, limit int, offset int) []Message
	StoreMessage(message Message) error
}

type MessagesSqliteDB struct {
	SqliteDB
}

type OfflineRequest struct {
	ID        int
	Host      string
	Path      string
	Method    string
	Payload   []byte
	Encrypted bool
}

type OfflineSqliteDB struct {
	SqliteDB
}

type Presence struct {
	// contains filtered or unexported fields
}

type PrimalInterface interface {
	GetPublicURL() string
	GetPublicKey() string
	Notify(event BrokerEvent)
	Send(request http.Request, encrypt bool) (*http.Response, error)
	GetMiddleware(next http.Handler) func(w http.ResponseWriter, r *http.Request)
	ComputeSharedKey(publicKey string) string
	GetDevices() []Device
	GetOfflineQueue() OfflineSqliteDB
	SendPendingRequests(publicKey string)
	IsURLOnline(url string) bool
}

type RequestStatus int

type SqliteDB struct {
	// contains filtered or unexported fields
}