messaging

type Conversation struct {
	ID        ids.ID           `json:"id"`
	Type      ConversationType `json:"type"`
	CreatedAt time.Time        `json:"createdAt"`
	UpdatedAt time.Time        `json:"updatedAt"`

	// Encrypted metadata
	EncryptedName        []byte `json:"encryptedName,omitempty"`
	EncryptedDescription []byte `json:"encryptedDescription,omitempty"`
	EncryptedAvatar      []byte `json:"encryptedAvatar,omitempty"`

	// CRDT state
	MembersCRDT     *MembershipCRDT `json:"membersCrdt"`
	ReadMarkersCRDT *ReadMarkerCRDT `json:"readMarkersCrdt"`

	// Key management
	KeyRotationEpoch uint64   `json:"keyRotationEpoch"`
	EncryptedKeys    [][]byte `json:"encryptedKeys"` // Per-member encrypted session key

	// Settings
	DisappearingMessages bool  `json:"disappearingMessages"`
	MessageTTL           int64 `json:"messageTtl"` // Seconds

	// Version for optimistic concurrency
	Version [32]byte `json:"version"`
}

type ConversationType uint8

type Encryptor interface {
	// Encrypt encrypts data for the given recipients
	Encrypt(ctx context.Context, data []byte, recipients [][32]byte) ([]byte, error)

	// Decrypt decrypts data using the given private key
	Decrypt(ctx context.Context, ciphertext []byte, privateKey []byte) ([]byte, error)

	// DeriveConversationKey derives a shared key for a conversation
	DeriveConversationKey(conversationID ids.ID, members [][32]byte) ([]byte, error)
}

type MemberEntry struct {
	AccountID [32]byte  `json:"accountId"`
	Role      string    `json:"role"` // "admin", "member", "viewer"
	AddedAt   time.Time `json:"addedAt"`
	AddedBy   [32]byte  `json:"addedBy"`

	// Encrypted member-specific data
	EncryptedNickname []byte `json:"encryptedNickname,omitempty"`
}

type MembershipCRDT struct {
	Added   map[string]*MemberEntry `json:"added"`   // uniqueTag -> MemberEntry
	Removed map[string]time.Time    `json:"removed"` // uniqueTag -> removal time
	// contains filtered or unexported fields
}

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

type RateCounter struct {
	AccountID   [32]byte
	MinuteCount int
	HourCount   int
	DayCount    int
	MinuteReset time.Time
	HourReset   time.Time
	DayReset    time.Time
}

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

type ReadMarker struct {
	AccountID    [32]byte  `json:"accountId"`
	LastReadID   ids.ID    `json:"lastReadId"`
	LastReadTime time.Time `json:"lastReadTime"`
	UpdatedAt    time.Time `json:"updatedAt"`
}

type ReadMarkerCRDT struct {
	Markers map[string]*ReadMarker `json:"markers"` // accountID hex -> ReadMarker
	// contains filtered or unexported fields
}