common

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

type BootstrapNode struct {
	PublicKey solana.PublicKey // Node's Solana public key
	IP        string           // IP address
	QUICPort  int              // QUIC port
	TCPPort   int              // TCP port
}

type Config struct {
	WalletPrivateKey     string                   // Base58-encoded Solana private key
	DatabaseName         string                   // Namespace for topics
	GetAuthorizedWallets GetAuthorizedWalletsFunc // Function to get authorized wallets
	GetBootstrapNodes    GetBootstrapNodesFunc    // Function to get bootstrap nodes
	Logger               Logger                   // Logger for all internal operations
	ListenPorts          ListenPorts              // Ports for different transports
	RefreshInterval      time.Duration            // How often to refresh authorized wallets cache (default: 30s)
	Debug                bool                     // Enable debug logging for p2p operations
	SkipBootstrapWait    bool                     // Skip waiting for bootstrap nodes (useful for tests)
}

type Event struct {
	ID         string      `json:"id"`        // Unique event identifier
	FromPeerId string      `json:"from_peer"` // Peer ID of sender
	Message    interface{} `json:"message"`   // The actual message content
	Timestamp  int64       `json:"timestamp"` // Unix timestamp

}

type GetAuthorizedWalletsFunc func(ctx context.Context) ([]solana.PublicKey, error)

type GetBootstrapNodesFunc func(ctx context.Context) ([]BootstrapNode, error)

type ListenPorts struct {
	QUIC int // QUIC listen port (default: 4001)
	TCP  int // TCP listen port (default: 4002)
}

type LiveKitLogger interface {
	Debugw(msg string, keysAndValues ...interface{})
	Infow(msg string, keysAndValues ...interface{})
	Warnw(msg string, err error, keysAndValues ...interface{})
	Errorw(msg string, err error, keysAndValues ...interface{})
}

type Logger interface {
	Debug(msg string, keysAndValues ...interface{})
	Info(msg string, keysAndValues ...interface{})
	Warn(msg string, keysAndValues ...interface{})
	Error(msg string, keysAndValues ...interface{})
}

type PubSubHandler func(Event)

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