ratatxt

type AppKey struct {
	ID        ID         `json:"id" gorm:"primaryKey;type:CHAR(20)"`
	UserID    ID         `json:"user_id"`
	Token     string     `json:"token"`
	Note      string     `json:"note"`
	LastUsed  *time.Time `json:"last_used"`
	CreatedAt time.Time  `json:"created_at"`
	UpdatedAt time.Time  `json:"updated_at"`
}

type AppKeyCreateParam struct {
	UserID ID     `json:"user_id"`
	Note   string `json:"note"`
}

type AppKeyDeleteParam struct {
	ID     ID `json:"ID"`
	UserID ID `json:"user_id"`
}

type AppKeyFilter struct {
	ID     ID     `db:"id,omitempty"`
	UserID ID     `db:"user_id,omitempty"`
	Token  string `db:"token,omitempty"`
	Note   string `db:"note,omitempty"`
}

type Auth struct {
	ID               ID         `json:"id" gorm:"primaryKey;type:CHAR(20)"`
	UserID           ID         `json:"user_id"`
	Username         string     `json:"username"`
	Password         string     `json:"-"`
	RefreshToken     string     `json:"refresh_token"`
	Level            AuthLevel  `json:"level"`
	VerificationCode string     `json:"-"`
	VerifiedAt       *time.Time `json:"verified_at"`
	CreatedAt        time.Time  `json:"created_at"`
	UpdatedAt        time.Time  `json:"updated_at"`
}

type AuthFilter struct {
	ID               ID        `db:"id,omitempty"`
	UserID           ID        `db:"user_id,omitempty"`
	Username         string    `db:"username,omitempty"`
	Password         string    `db:"password,omitempty"`
	RefreshToken     string    `db:"refresh_token,omitempty"`
	Level            AuthLevel `db:"level,omitempty"`
	VerificationCode string    `db:"verification_code,omitempty"`
}

type AuthLevel uint

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

type DataStoreUtil interface {
	AutoMigrate(obj ...interface{}) error
}

type Datastore interface {
	DatastoreSearch
	DatastoreCRUD
	DataStoreUtil

	// MessageStats Custom operations
	MessageStats(dst interface{}, scope StatsScope, filter *MessageFilter) error
	MessageGraph(dst interface{}, scope StatsScope, filter *MessageFilter) error
	OutboxGraph(dst interface{}, scope StatsScope, filter *MessageFilter) error
}

type DatastoreCRUD interface {
	List(rows, filter interface{}) error
	Get(row interface{}, id ID) error
	Create(input interface{}) error
	Update(input interface{}) error
	Delete(input interface{}) error
}

type DatastoreSearch interface {
	Search(data interface{}, opts *SearchOpts) (*SearchMetadata, error)
	Count(model interface{}, opts *SearchOpts) (int, error)
}

type Device struct {
	ID         ID           `json:"id" gorm:"primaryKey;type:CHAR(20)"`
	UserID     ID           `json:"user_id"`
	Name       string       `json:"name"`
	Address    string       `json:"address"`
	Status     DeviceStatus `json:"status"`
	LastActive *time.Time   `json:"last_active"`
	CreatedAt  time.Time    `json:"created_at"`
	UpdatedAt  time.Time    `json:"updated_at"`
}

type DeviceCmd interface {
	// Forward commands device to send an outgoing message.
	Forward(topic, msgID, targetAddr, text string) error

	// Ping sends a ping message for testing device connection to service.
	Ping(topic string) error

	// ActiveHandler callback triggers when device is connected and responded on ping.
	ActiveHandler(func(clientID string))
}

type DeviceCreateParam struct {
	UserID  ID     `json:"user_id"`
	Name    string `json:"name"`
	Address string `json:"address"`
}

type DeviceFilter struct {
	ID      ID           `db:"id,omitempty"`
	UserID  ID           `db:"user_id,omitempty"`
	Name    string       `db:"name,omitempty"`
	Address string       `db:"address,omitempty"`
	Status  DeviceStatus `db:"status,omitempty"`
}

type DeviceStatus uint

type DeviceUpdateParam struct {
	ID         ID           `json:"id"`
	UserID     ID           `json:"user_id"`
	Name       string       `json:"name"`
	Address    string       `json:"address"`
	Status     DeviceStatus `json:"status"`
	LastActive *time.Time   `json:"last_active"`
}

type Errors uint

type ID string

type LoginParams struct {
	Username string `json:"username"`
	Password string `json:"password"`
}

type Mailer interface {
	// Send a simple text email.
	Send(to []string, subject, text string) error
	// SendHTML sends an email with HTML header.
	SendHTML(to []string, subject, tmpl string, data map[string]interface{}) error
}

type Message struct {
	ID         ID            `json:"id" gorm:"primaryKey;type:CHAR(20)"`
	UserID     ID            `json:"user_id"`
	DeviceID   ID            `json:"device_id"`
	Kind       MessageKind   `json:"kind"`
	Status     MessageStatus `json:"status"`
	Address    string        `json:"address"`
	Text       string        `json:"text"`
	Timestamp  int64         `json:"timestamp"`
	RetryCount int           `json:"retry_count"`
	CreatedAt  time.Time     `json:"created_at"`
	UpdatedAt  time.Time     `json:"updated_at"`

	Device *Device `json:"device,omitempty" gorm:"-"`
}

type MessageCreateParam struct {
	UserID    ID            `json:"user_id"`
	DeviceID  ID            `json:"device_id"`
	Kind      MessageKind   `json:"kind"`
	Status    MessageStatus `json:"status"`
	Address   string        `json:"address"`
	Text      string        `json:"text"`
	Timestamp int64         `json:"timestamp"`
}

type MessageFilter struct {
	ID       ID            `db:"id,omitempty"`
	UserID   ID            `db:"user_id,omitempty"`
	DeviceID ID            `db:"device_id,omitempty"`
	Kind     MessageKind   `db:"kind,omitempty"`
	Status   MessageStatus `db:"status,omitempty"`
	Address  string        `db:"address,omitempty"`
}

type MessageKind uint

type MessageStats struct {
	MessageStatsData
	OutboxStatsData
}

type MessageStatsData struct {
	Scope  string `json:"scope"`
	Total  int    `json:"total"`
	Inbox  int    `json:"inbox"`
	Outbox int    `json:"outbox"`
}

type MessageStatus uint

type OutboxStatsData struct {
	Scope         string `json:"scope"`
	OutboxQueued  int    `json:"outbox_queued"`
	OutboxSending int    `json:"outbox_sending"`
	OutboxSent    int    `json:"outbox_sent"`
	OutboxFailed  int    `json:"outbox_failed"`
	OutboxError   int    `json:"outbox_error"`
}

type OutboxUpdateParam struct {
	ID     ID            `json:"id"`
	UserID ID            `json:"user_id"`
	Status MessageStatus `json:"status"`
}

type Poster interface {
	// Post sends a POST request with application/json content-type.
	Post(payloadURL string, payload interface{}) (statusCode int, err error)
}

type RegisterAccountParam struct {
	FirstName string `json:"first_name"`
	LastName  string `json:"last_name"`
	Email     string `json:"email"`
	Password  string `json:"password"`
}

type SMSGuardCreateParam struct {
	UserID   ID     `json:"user_id"`
	DeviceID ID     `json:"device_id"`
	Address  string `json:"address"`
	From     string `json:"from"`
	Minutes  int    `json:"duration_min"`
}

type SearchMetadata struct {
	ResultCount int
	TotalCount  int
}

type SearchOpts struct {
	Keyword       string
	KeywordFields []string
	Filter        interface{}
	UserID        ID
	Page          int
	Limit         int
	IndexSorting  bool
	Sort          string
	Desc          bool
}

type StatsScope struct {
	From, To time.Time
	Unit     StatsScopeUnit
	All      bool
}

type StatsScopeUnit uint

type User struct {
	ID        ID        `json:"id" gorm:"primaryKey;type:CHAR(20)"`
	FirstName string    `json:"first_name"`
	LastName  string    `json:"last_name"`
	Email     string    `json:"email"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

type UserCreateParam struct {
	FirstName string `json:"first_name"`
	LastName  string `json:"last_name"`
	Email     string `json:"email"`
}

type UserFilter struct {
	ID        ID     `db:"id,omitempty"`
	FirstName string `db:"first_name,omitempty"`
	LastName  string `db:"last_name,omitempty"`
	Email     string `db:"email,omitempty"`
}

type VerifyParams struct {
	Username string `json:"username"`
	Code     string `json:"code"`
}

type Webhook struct {
	ID           ID         `json:"id" gorm:"primaryKey;type:CHAR(20)"`
	UserID       ID         `json:"user_id"`
	PayloadURL   string     `json:"payload_url"`
	Secret       string     `json:"secret"`
	Active       *bool      `json:"active"`
	LastRespCode int        `json:"last_resp_code"`
	LastUsed     *time.Time `json:"last_used"`
	CreatedAt    time.Time  `json:"created_at"`
	UpdatedAt    time.Time  `json:"updated_at"`
}

type WebhookCreateParam struct {
	UserID     ID     `json:"user_id"`
	PayloadURL string `json:"payload_url"`
	Secret     string `json:"secret"`
	Active     *bool  `json:"active,omitempty"`
}

type WebhookDeleteParam struct {
	ID     ID `json:"ID"`
	UserID ID `json:"user_id"`
}

type WebhookFilter struct {
	ID           ID     `db:"id,omitempty"`
	UserID       ID     `db:"user_id,omitempty"`
	PayloadURL   string `db:"payload_url,omitempty"`
	Secret       string `db:"secret,omitempty"`
	Active       *bool  `db:"active,omitempty"`
	LastRespCode int    `db:"last_resp_code,omitempty"`
}

type WebhookPayload struct {
	ID         ID      `json:"webhook_id"`
	PayloadURL string  `json:"payload_url"`
	Secret     string  `json:"secret"`
	Message    Message `json:"message"`
}

type WebhookUpdateParam struct {
	ID         ID     `json:"ID"`
	UserID     ID     `json:"user_id"`
	PayloadURL string `json:"payload_url"`
	Secret     string `json:"secret"`
	Active     *bool  `json:"active,omitempty"`
}