engine

type BackfillRequest struct {
	Chat         string
	AnchorID     string
	AnchorFromMe bool
	AnchorTime   time.Time
	Count        int
}

type CATRefreshFailed struct{}

type Canonicaliser interface {
	Canonical(ctx context.Context, c policy.CanonicalChat) (policy.CanonicalChat, error)
}

type Client interface {
	Connect(ctx context.Context) error
	Disconnect()
	Paired() bool
	Account() string
	PairPhone(ctx context.Context, digits string) (code string, err error)
	Logout(ctx context.Context) error
	Version() Version
	SetVersion(Version)
	DownloadHistory(ctx context.Context, ref HistoryRef, dst io.Writer) error
	AckHistory(ctx context.Context, ref HistoryRef) error
	OnEvent(handler func(Event) bool) (cancel func())
	NewMessageID() string
	Send(ctx context.Context, req SendRequest) (Sent, error)
	Backfill(ctx context.Context, req BackfillRequest) (requestID string, err error)
	FetchMedia(ctx context.Context, req MediaRequest) (Staged, error)
}

type ClientOutdated struct{}

type Clock interface {
	Now() time.Time
	After(d time.Duration) <-chan time.Time
}

type ConnectFailure struct{ Code int }

type Connected struct{}

type Contact struct {
	User     string
	PushName string
}

type ContactName struct {
	User      string `json:"user"`
	FullName  string `json:"full_name,omitempty"`
	FirstName string `json:"first_name,omitempty"`
}

type Conversation struct {
	Chat     string
	Subject  string
	Members  []Participant
	Messages []Message
}

type Disconnected struct{}

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

type Event interface {
	// contains filtered or unexported methods
}

type Group struct {
	Chat      string        `json:"chat"`
	Subject   string        `json:"subject,omitempty"`
	Members   []Participant `json:"members,omitempty"`
	Joined    []Participant `json:"joined,omitempty"`
	Left      []string      `json:"left,omitempty"`
	Timestamp time.Time     `json:"ts"`
}

type History struct {
	Conversations []Conversation
	LIDMappings   []LIDMapping
	Contacts      []Contact
}

type HistoryDecoder interface {
	Decode(blob []byte) (History, error)
}

type HistoryNotification struct {
	Sender string
	FromMe bool
	Ref    HistoryRef
}

type HistoryRef struct {
	ID            string `json:"id"`
	DirectPath    string `json:"direct_path,omitempty"`
	MediaKey      []byte `json:"media_key,omitempty"`
	FileSHA256    []byte `json:"file_sha256,omitempty"`
	FileEncSHA256 []byte `json:"file_enc_sha256,omitempty"`
	FileLength    uint64 `json:"file_length,omitempty"`
	Inline        []byte `json:"inline,omitempty"`
	SyncType      string `json:"sync_type,omitempty"`
	RequestID     string `json:"request_id,omitempty"`
}

type Identity struct {
	PN  string
	LID string
}

type Key struct {
	RemoteJID   string `json:"remote_jid,omitempty"`
	FromMe      bool   `json:"from_me,omitempty"`
	ID          string `json:"id"`
	Participant string `json:"participant,omitempty"`
}

type Kind string

type LIDMapping struct {
	PN  string
	LID string
}

type LoggedOut struct{}

type MediaKind string

type MediaRequest struct {
	ID        string
	Ref       string
	Kind      MediaKind
	Declared  int64
	Deadline  time.Time
	Chat      policy.CanonicalChat
	Sender    policy.CanonicalChat
	Canonical Canonicaliser
}

type Message struct {
	Chat         string        `json:"chat"`
	ID           string        `json:"id"`
	Sender       string        `json:"sender"`
	SenderAlt    string        `json:"sender_alt,omitempty"`
	RecipientAlt string        `json:"recipient_alt,omitempty"`
	Addressing   string        `json:"addressing,omitempty"`
	FromMe       bool          `json:"from_me,omitempty"`
	Timestamp    time.Time     `json:"ts"`
	PushName     string        `json:"push_name,omitempty"`
	Kind         Kind          `json:"kind,omitempty"`
	Text         string        `json:"text,omitempty"`
	MediaType    string        `json:"media_type,omitempty"`
	MediaRef     string        `json:"media_ref,omitempty"`
	MediaKind    MediaKind     `json:"media_kind,omitempty"`
	MediaVariant string        `json:"media_variant,omitempty"`
	MediaBytes   int64         `json:"media_bytes,omitempty"`
	Target       *Key          `json:"target,omitempty"`
	Reply        *Reply        `json:"reply,omitempty"`
	Expiration   time.Duration `json:"expiration,omitempty"`
}

type Notifier interface {
	Unpaired()
	Disconnected(reason string)
	PairRejected(stage string)
	LogoutFailed(attempt int, errorType string)
	Quarantine(queue string, attempts int)
	RekeyConflict(conflict string)
	IngestPaused(freeBytes, floorBytes uint64)
}

type Options struct {
	Client            Client
	Versions          VersionSource
	Decoder           HistoryDecoder
	Archive           *ingest.Store
	DataDir           string
	OwnerPhone        string
	HistoryMaxBytes   int64
	MediaOn           bool
	MediaRefRetention time.Duration
	Logger            *slog.Logger
	Notify            Notifier
	Metrics           *metrics.Registry
	Clock             Clock
	Jitter            func(time.Duration) time.Duration
}

type PairRejected struct{}

type Paired struct{ JID string }

type Participant struct {
	User  string `json:"user"`
	Admin bool   `json:"admin,omitempty"`
}

type Reason string

type RejectedError struct{ Code int }

type Reply struct {
	ID          string `json:"id"`
	Participant string `json:"participant,omitempty"`
	RemoteJID   string `json:"remote_jid,omitempty"`
	Text        string `json:"text,omitempty"`
}

type SendQuote struct {
	ID          string
	Participant string
	Text        string
}

type SendRequest struct {
	ID         string
	Chat       string
	Text       string
	Quote      *SendQuote
	Expiration time.Duration
}

type Sent struct {
	ID        string
	Chat      string
	Sender    string
	Timestamp time.Time
}

type Staged interface {
	Size() int64
	ReadAt(p []byte, off int64) (int, error)
	WriteAt(p []byte, off int64) (int, error)
	Truncate(size int64) error
	Erase()
}

type State string

type Status struct {
	State  State
	Reason Reason
	Paired bool
}

type StreamReplaced struct{}

type TemporaryBan struct{ Expire time.Duration }

type ThrottledError struct{ RetryAfter time.Duration }

type Version [3]uint32

type VersionSource interface {
	Latest(ctx context.Context) (Version, error)
}