messaging

type Ack struct {
	LastSeqAck    uint64 `bencode:"s"`
	LastSparseAck []byte `bencode:"sp"`
}

type AddressedMessage struct {
	From string
	URLs []string
	Body []byte
}

type Backfill struct {
	ID    ids.ID `bencode:"i"`
	Total uint64 `bencode:"t"`
	Body  []byte `bencode:"b"`
}

type BackfillAbort struct {
	ID ids.ID `bencode:"i"`
}

type BackfillComplete struct {
	ID    ids.ID `bencode:"i"`
	Total uint64 `bencode:"t"`
}

type BackfillRequest struct {
	ID   ids.ID `bencode:"i"`
	Type uint8  `bencode:"t"`
}

type BackfillStart struct {
	ID   ids.ID    `bencode:"i"`
	Acks GroupAcks `bencode:"a"`
}

type DeviceInvite struct {
	ID      ids.ID
	CtimeMs uint64
}

type EncryptedBody struct {
	PublicKey [32]byte `bencode:"k"`
	Body      []byte   `bencode:"b"`
}

type EndpointInfo struct {
	Priority uint8 `bencode:"p"`
}

type Group struct {
	ID               ids.ID
	Name             string
	AuthorTag        [7]byte
	SelfIdentityID   [16]byte
	SelfMembershipID [16]byte
	State            int
	// contains filtered or unexported fields
}

type GroupAcks struct {
	Acks map[ids.ID]map[ids.ID]*Ack `bencode:"a"`
}

type GroupDescription struct {
	Name        *LWWString  `bencode:"n"`
	Description *LWWString  `bencode:"d"`
	Icon        *LWWBlob    `bencode:"ic"`
	IconType    *LWWString  `bencode:"it"`
	Identities  IdentityMap `bencode:"i"`
}

type GroupMembership []*Member

type GroupMessage struct {
	GroupMessages    []*GroupMessageBody `bencode:"b"`
	GroupAckSeq      uint64              `bencode:"gs"`
	GroupAckSparse   []byte              `bencode:"gss"`
	PrivateAckSeq    uint64              `bencode:"ps"`
	PrivateAckSparse []byte              `bencode:"pss"`
	BaseDigest       []byte              `bencode:"bd"`
	GroupChanges     []byte              `bencode:"gc"`
	NewDigest        []byte              `bencode:"nd"`
	PrivateMessages  []*PrivateMessage   `bencode:"m"`
	Lost             []*LostBody         `bencode:"l"`
}

type GroupMessageBody struct {
	Body                []byte              `bencode:"b"`
	Seq                 uint64              `bencode:"s"`
	UnhandledRecipients map[ids.ID][]ids.ID `bencode:"u"`
}

type GroupUpdate struct {
	GroupID              ids.ID
	GroupState           int
	MemberCount          uint
	ConnectedMemberCount uint
	Seq                  uint64
	PendingMessageCount  uint
	AckedMemberCount     uint
}

type IdentityMap map[ids.ID]MembershipMap

type IncomingGroupMessage struct {
	GroupID      ids.ID
	IdentityID   ids.ID
	MembershipID ids.ID
	Seq          uint64
	Body         []byte
}

type IntroFailed struct {
	IntroID ids.ID
	GroupID ids.ID
}

type IntroSucceeded struct {
	IntroID ids.ID
	GroupID ids.ID
}

type IntroUpdate struct {
	GroupID   ids.ID
	Initiator bool
	Stage     uint32
	Type      uint32
}

type Jpake1 struct {
	ID        [16]byte                 `bencode:"id"`
	UserID    [16]byte                 `bencode:"u"`
	PublicKey [32]byte                 `bencode:"k"`
	X1G       []byte                   `bencode:"x1g"`
	X2G       []byte                   `bencode:"x2g"`
	X1ZKP     *ZKPBody                 `bencode:"x1zkp"`
	X2ZKP     *ZKPBody                 `bencode:"x2zkp"`
	ReplyTo   map[string]*EndpointInfo `bencode:"r"`
}

type LWWBlob struct {
	Value []byte `bencode:"v"`
	Type  string `bencode:"y"`
	Time  uint64 `bencode:"t"`
}

type LWWString struct {
	Value string `bencode:"v"`
	Time  uint64 `bencode:"t"`
}

type LostBody struct {
	Type uint8  `bencode:"t"`
	Body []byte `bencode:"b"`
}

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

type Member struct {
	ID      ids.ID
	Members []ids.ID
}

type Membership struct {
	Description *MembershipDescription `bencode:"d"`
	Signature   []byte                 `bencode:"s"`
}

type MembershipDescription struct {
	IntroKey  [32]byte                 `bencode:"k"`
	Version   uint32                   `bencode:"v"`
	Protocol  uint32                   `bencode:"p"`
	Endpoints map[string]*EndpointInfo `bencode:"es"`
}

type MembershipMap map[ids.ID]*Membership

type MembershipUpdater func(ids.ID, ids.ID, ids.ID, *Membership) error

type PrivateMessage struct {
	Type uint8  `bencode:"t"`
	Body []byte `bencode:"b"`
	Seq  uint64 `bencode:"s"`
}

type RepairBody struct {
	IdentityID   ids.ID `bencode:"i"`
	MembershipID ids.ID `bencode:"m"`
	Seq          uint64 `bencode:"s"`
	Body         []byte `bencode:"b"`
}

type Transports interface {
	URLsForGroup(id ids.ID) ([]string, error)
	ReportGroup(id ids.ID) error
	Preflight([]string) []bool
	StatusChanged(func(string, bool))
}

type UpdateChannel chan interface{}

type ZKPBody struct {
	T []byte `bencode:"t"`
	R []byte `bencode:"r"`
}