api

type AdminDeps struct {
	Credential policy.AdminCredential
	Metrics    *metrics.Registry
	Service    AdminService
	Events     AdminEvents
	Now        func() time.Time
}

type AdminEvents interface {
	AdminMutation(action, outcome string)
	AdminAuthFailure()
}

type AdminService interface {
	Status(ctx context.Context) (AdminStatus, error)
	Pair(ctx context.Context) (code string, err error)
	Reconnect(ctx context.Context) error
	Backfill(g policy.AdminGrant, ctx context.Context, chat policy.CanonicalChat, count int, anchor BackfillAnchor) (requestID string, err error)
	PauseMedia(paused bool)
	ClientService
}

type AdminStatus struct {
	State            string
	Reason           string
	Paired           bool
	Chats            int64
	Messages         int64
	BlobsPending     int64
	BlobsQuarantined int64
	InboxBacklog     int64
	InboxQuarantined int64
	BackfillsToday   int64
	MediaRefsLive    int64
	MediaRefsExpired int64
	RevokeTombstones int64
	Downloads        bool
	MediaPaused      bool
	Clients          ClientCounts
	LastIngest       time.Time
	Version          string
}

type Auditor interface {
	Record(ctx context.Context, e ReadEvent) error
}

type Authenticator interface {
	Authenticate(ctx context.Context, token string) (*policy.Client, bool, error)
}

type BackfillAnchor uint8

type ChatEntry struct {
	Chat policy.CanonicalChat
	Ref  string
	Name string
}

type ClientChatView struct {
	Chat  policy.CanonicalChat
	Known bool
	Name  string
}

type ClientCounts struct {
	Active           int64
	Expired          int64
	Revoked          int64
	AllChatsActive   int64
	MediaWriteActive int64
}

type ClientDeps struct {
	Authenticator Authenticator
	Metrics       *metrics.Registry
	Now           func() time.Time
	Archive       ReadArchive
	Audit         Auditor
	Session       func() string
	Cursors       *cursor.Sealer
	Refs          *cursor.Sealer
	Limits        ReadLimits
	Sender        SendService
	SendRejected  func(reason string)
	AuditFailed   func(action string, err error)
	Media         *MediaDeps
}

type ClientService interface {
	CreateClient(ctx context.Context, spec policy.ClientSpec) (view ClientView, credential string, err error)
	Clients(ctx context.Context) ([]ClientView, error)
	Client(ctx context.Context, id string) (ClientView, error)
	RevokeClient(ctx context.Context, id string) (ClientView, error)
	Chats(ctx context.Context, match string, limit int) (chats []ChatEntry, truncated bool, err error)
}

type ClientView struct {
	ID                string
	Name              string
	State             string
	CreatedAt         time.Time
	ExpiresAt         time.Time
	RevokedAt         time.Time
	AllChats          bool
	AllowFirstContact bool
	AllowMedia        bool
	ReadCount         int64
	WriteCount        int64
	Read              []ClientChatView
	Write             []ClientChatView
}

type MediaDeps struct {
	Service            MediaService
	MaxBytes           int64
	PerMinute          int
	GlobalPerHour      int
	GlobalBytesPerHour int64
	Root               context.Context
	ClientLive         func(ctx context.Context, client string) (bool, error)
	Stopped            func()
	Pause              *MediaPause
	// contains filtered or unexported fields
}

type MediaFetch struct {
	Chat     policy.CanonicalChat
	ID       string
	Sender   policy.CanonicalChat
	Kind     string
	Variant  string
	Declared int64
}

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

type MediaService interface {
	Precheck(declared int64) error
	Fetch(ctx context.Context, ref scoped.SealedRef, req MediaFetch) (MediaSpool, error)
}

type MediaSpool interface {
	Size() int64
	Fetched() int64
	ReadAt(p []byte, off int64) (int, error)
	Erase()
	ServedType() string
	Format() string
	Normalised() bool
	InMemory() bool
}

type ReadArchive interface {
	Chats(g policy.ReadGrant, ctx context.Context, pos scoped.ChatPosition, limit int) (scoped.ChatPage, error)
	Chat(g policy.ReadGrant, ctx context.Context, ref string) (scoped.Chat, bool, error)
	Messages(g policy.ReadGrant, ctx context.Context, ref string, pos scoped.MessagePosition, dir scoped.Direction, limit int) (scoped.MessagePage, bool, error)
	Message(g policy.ReadGrant, ctx context.Context, chat policy.CanonicalChat, id string, sender policy.CanonicalChat) (scoped.Message, bool, error)
	Changes(g policy.ReadGrant, ctx context.Context, ref string, pos scoped.ChangePosition, limit int) (scoped.ChangePage, bool, error)
	Search(g policy.ReadGrant, ctx context.Context, query scoped.Query, ref string, pos scoped.SearchPosition, limit int) (scoped.SearchPage, bool, error)
	Attachment(g policy.ReadGrant, ctx context.Context, chat policy.CanonicalChat, id string, sender policy.CanonicalChat, now time.Time) (scoped.Attachment, bool, error)
}

type ReadEvent struct {
	At      time.Time
	Client  string
	Action  string
	Chat    policy.CanonicalChat
	OK      bool
	Reason  string
	Peer    string
	Message cursor.Ref
	Bytes   int64
}

type ReadLimits struct {
	ReadsPerMinute    int
	SearchesPerMinute int
}

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

type SendReply struct {
	ID     string
	Sender policy.CanonicalChat
	Seq    int64
	Text   string
}

type SendRequest struct {
	Key     string
	Chat    policy.CanonicalChat
	ChatRef string
	Text    string
	Reply   *SendReply
}

type SendService interface {
	Send(g policy.WriteGrant, ctx context.Context, req SendRequest) (Sent, error)
}

type Sent struct {
	Chat     policy.CanonicalChat
	ID       string
	Sender   policy.CanonicalChat
	Replayed bool
}