store

type Addr struct {
	Addr    string    `json:"addr"`
	Source  string    `json:"source"`
	Added   time.Time `json:"added"`
	LastOK  time.Time `json:"last_ok,omitzero"`
	LastErr string    `json:"last_err,omitempty"`
}

type Blob struct {
	Peer     string    `json:"peer"`
	Dir      string    `json:"dir"`
	Ref      string    `json:"ref"`
	Th       string    `json:"th,omitempty"`
	Name     string    `json:"name,omitempty"`
	Mime     string    `json:"mime,omitempty"`
	Size     int64     `json:"size"` // declared size, -1 if not yet known
	Received int64     `json:"received"`
	NextN    int       `json:"next_n"`
	Path     string    `json:"path,omitempty"`
	Status   string    `json:"status"` // in: pending; received (data in, awaiting the msg that names it); complete; refused. out: queued; sent (the msg that carries it was acked); refused
	Updated  time.Time `json:"updated"`
}

type Filter struct {
	Peer       string
	Th         string
	Dirs       []string // default: all
	Types      []string // default: all
	AfterSeq   int64
	UnreadOnly bool
	Inbox      bool // received records plus local events worth a reader's attention
	Limit      int  // default 1000
	Last       bool // with Limit: the last N records, still returned in order
	// Mirrors includes mirrored lines (dir "mirror"), which are left out
	// unless asked for by this or by Dirs: they are other agents' threads,
	// not this agent's business.
	Mirrors bool
}

type GrantQuery struct {
	Role     string
	Iss      string
	Sub      string
	Audience string
	ValidAt  time.Time // if set, only grants not expired at this time
}

type GrantRow struct {
	Hash     string    `json:"hash"`
	Role     string    `json:"role"`
	Iss      string    `json:"iss"`
	Sub      string    `json:"sub"`
	Caps     []string  `json:"caps"`
	Exp      time.Time `json:"exp"`
	Raw      []byte    `json:"-"`
	Audience string    `json:"audience,omitempty"`
	Created  time.Time `json:"created"`
}

type MirroredThread struct {
	Sharer  string    `json:"sharer"` // the agent that shares it
	Of      string    `json:"of"`     // the other party
	Th      string    `json:"th"`
	Subject string    `json:"subject,omitempty"`
	Lines   int       `json:"lines"`
	Updated time.Time `json:"updated"`
}

type OutboxRow struct {
	Seq     int64
	Peer    string
	ID      string
	T       string
	Th      string
	Ref     string
	Line    []byte
	Created time.Time
}

type Peer struct {
	Key       string    `json:"key"`
	Name      string    `json:"name,omitempty"`
	About     string    `json:"about,omitempty"`
	Caps      []string  `json:"caps,omitempty"`
	Alias     string    `json:"alias,omitempty"`
	FirstSeen time.Time `json:"first_seen"`
	LastSeen  time.Time `json:"last_seen,omitzero"`
	Parked    bool      `json:"parked,omitempty"`
	Addrs     []Addr    `json:"addrs,omitempty"`
}

type PresenceRow struct {
	Origin   string
	Seq      int64
	Name     string
	TS       time.Time // the origin's timestamp
	Received time.Time
	Via      string // the peer it arrived from
	Hops     int
	Doc      []byte // exactly as signed
}

type Q interface {
	Exec(query string, args ...any) (sql.Result, error)
	Query(query string, args ...any) (*sql.Rows, error)
	QueryRow(query string, args ...any) *sql.Row
}

type Record struct {
	Seq   int64          `json:"seq"`
	Peer  string         `json:"peer"`
	Dir   string         `json:"dir"`
	ID    string         `json:"id"`
	T     string         `json:"t"`
	Th    string         `json:"th,omitempty"`
	Line  []byte         `json:"-"`
	At    time.Time      `json:"at"`
	Acked bool           `json:"acked,omitempty"`
	Read  bool           `json:"read,omitempty"`
	Meta  map[string]any `json:"meta,omitempty"`
}

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

type Thread struct {
	Peer       string    `json:"peer"`
	Th         string    `json:"th"`
	Subject    string    `json:"subject,omitempty"`
	Origin     string    `json:"origin"`
	Created    time.Time `json:"created"`
	Updated    time.Time `json:"updated"`
	MyState    string    `json:"my_state"`
	MyNote     string    `json:"my_note,omitempty"`
	MySince    time.Time `json:"my_since"` // when my state or note last changed
	TheirState string    `json:"their_state"`
	TheirNote  string    `json:"their_note,omitempty"`
	TheirSince time.Time `json:"their_since"`
	Unread     int       `json:"unread,omitempty"`
}