types

type Agent struct {
	ID     string `json:"id" gorm:"type:varchar(20);primary_key"`
	Secret string `json:"-" gorm:"type:varchar(20);index"`
	UserID string `json:"user_id" gorm:"type:varchar(20);index:idx_uid;uniqueIndex:idx_un1;uniqueIndex:idx_un2"`
	Name   string `json:"name" gorm:"type:varchar(50);uniqueIndex:idx_un1"`
	Alias  string `json:"alias" gorm:"type:varchar(50);uniqueIndex:idx_un2"`
	Remark string `json:"remark"`
	// IP address last connected from
	IP string `json:"ip" gorm:"type:varchar(50)"`
	// Only update after a agent offline, means last activated at that time.
	ActivatedAt *time.Time `json:"activated_at"`
	CreatedAt   time.Time  `json:"created_at"`
	UpdatedAt   time.Time  `json:"updated_at"`
}

type AgentBasic struct {
	Name   string `json:"name"`
	Alias  string `json:"alias"`
	Remark string `json:"remark"`
}

type EventCenter interface {
	// Pub publish a event to a queue or pool
	Pub(e *Message) error
	// Get a event, nil if no event found
	Get() (*Message, error)
	// StartWorker to check and get new event periodically in background
	StartWorker(ctx context.Context, handler EventHandler)
}

type EventHandler func(e *Message)

type Job struct {
	ID string `json:"id" gorm:"type:varchar(20);primary_key"`
	JobInput
	// queuing/canceled/sent/expired/succeeded/failed
	Status string `json:"status" gorm:"type:varchar(10)"`
	// agent returned, job log or other message
	Result      string     `json:"result" gorm:"type:varchar(1024)"`
	CreatedAt   time.Time  `json:"created_at" gorm:"index:by_user;index:by_agent"`
	SentAt      *time.Time `json:"sent_at,omitempty"`
	CanceledAt  *time.Time `json:"canceled_at,omitempty"`
	ExpiredAt   *time.Time `json:"expired_at,omitempty"`
	SucceededAt *time.Time `json:"succeeded_at,omitempty"`
	FailedAt    *time.Time `json:"failed_at,omitempty"`
}

type JobBasic struct {
	ID      string `json:"id"`
	Message string `json:"message"`
}

type JobInput struct {
	UserID  string `json:"user_id" gorm:"type:varchar(20);index:by_user"`
	AgentID string `json:"agent_id" gorm:"type:varchar(20);index:by_agent"`
	// job payload
	Message string `json:"message" gorm:"type:varchar(255)" validate:"required,lte=255"`
	// source context, any string defined by source
	Source string `json:"source" gorm:"type:varchar(255)" validate:"omitempty,lte=255"`
	// callback url, if exists, will be called after sent/expired/succeeded/failed
	Callback string `json:"callback" gorm:"type:varchar(255)" validate:"omitempty,lte=255"`
}

type JobResult struct {
	// agent returned, job log or other message
	Result string `json:"result,omitempty"`
}

type Message struct {
	ID        string    `json:"id"`
	AgentID   string    `json:"agent_id"`
	UserID    string    `json:"user_id"`
	Type      string    `json:"type"`
	Message   string    `json:"message"`
	CreatedAt time.Time `json:"created_at"`
}

type MessageInput struct {
	Message string `json:"message"`
}