share

type Account interface {
	// ID returns the unique identifier of the account, typically the string representation of the peer ID.
	ID() string

	// Address returns the derived address from the MasterPublicKey.
	Address() types.Address

	// PeerID returns the associated libp2p PeerID.
	PeerID() peer.ID

	// Name returns the name of the account.
	Name() string

	// Comment returns the optional comment or description of the account.
	Comment() string

	// MasterPrivateKey returns the master private key associated with the account.
	MasterPrivateKey() libp2pCrypto.PrivKey

	// MasterPublicKey returns the master public key associated with the account.
	MasterPublicKey() libp2pCrypto.PubKey

	// Roles returns the list of roles assigned to the account.
	Roles() []types.Role

	// ExtraPermissions returns the additional permissions associated with each role.
	ExtraPermissions() map[types.Role][]types.Permission

	// AssignRole assigns a new role with specified permissions to the account.
	AssignRole(role types.Role, permissions ...types.Permission) error

	// RemoveRole removes an existing role from the account.
	RemoveRole(role types.Role) error

	// HasPermission checks if the account has the specified permission.
	HasPermission(permission types.Permission) bool

	// MarshalPublicKey marshals the account's master public key into bytes.
	MarshalPublicKey() ([]byte, error)
}

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

type ActorCallbackFn func(ctx context.Context, actor *Actor, force bool) error

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

type BaseSigner interface {
	Address() (types.Address, error)
	Sign(data []byte) ([]byte, error)
	Verify(data []byte, signature []byte) (bool, error)
	Pair() KeyPair
	Type() types.SignerType
}

type Collector interface {
	// UpdateResponsiveness updates the responsiveness metric for a peer.
	//
	// Parameters:
	//   - p: The peer ID of the peer being updated.
	//   - latency: The latency observed in communication with the peer.
	//   - success: Indicates whether the communication attempt was successful.
	UpdateResponsiveness(p peer.ID, latency float64, success bool)

	// UpdateReliability updates the reliability metric for a peer.
	//
	// Parameters:
	//   - p: The peer ID of the peer being updated.
	//   - success: Indicates whether the communication attempt was successful.
	UpdateReliability(p peer.ID, success bool)

	// UpdateBandwidthUsage updates the bandwidth usage metric for a peer.
	//
	// Parameters:
	//   - p: The peer ID of the peer being updated.
	//   - value: The new bandwidth usage value.
	UpdateBandwidthUsage(p peer.ID, value float64)

	// UpdateComputational updates the computational metric for a peer.
	//
	// Parameters:
	//   - p: The peer ID of the peer being updated.
	//   - value: The new computational metric value.
	UpdateComputational(p peer.ID, value float64)

	// UpdateStorage updates the storage metric for a peer.
	//
	// Parameters:
	//   - p: The peer ID of the peer being updated.
	//   - value: The new storage metric value.
	UpdateStorage(p peer.ID, value float64)

	// UpdateUptime updates the uptime metric for a peer.
	//
	// Parameters:
	//   - p: The peer ID of the peer being updated.
	//   - value: The new uptime metric value.
	UpdateUptime(p peer.ID, value float64)

	// CalculateUtilityScore computes the overall utility score for a peer.
	//
	// Parameters:
	//   - p: The peer ID of the peer for which the utility score is computed.
	//
	// Returns:
	//   - The computed utility score as a float64.
	CalculateUtilityScore(p peer.ID) float64

	// GetMetrics retrieves the metrics for a given peer.
	//
	// Parameters:
	//   - p: The peer ID of the peer whose metrics are retrieved.
	//
	// Returns:
	//   - A pointer to the Metrics struct containing the peer's metrics.
	GetMetrics(p peer.ID) *Metrics

	// GetAllMetrics returns a copy of all collected metrics.
	//
	// Returns:
	//   - A map of peer IDs to their corresponding Metrics structs.
	GetAllMetrics() map[peer.ID]*Metrics

	// RemoveOldMetrics removes metrics that haven't been updated within the specified threshold.
	//
	// Parameters:
	//   - threshold: A duration specifying the age threshold for removing old metrics.
	RemoveOldMetrics(threshold time.Duration)

	// AdjustEmaAlpha dynamically adjusts the smoothing factor used in Exponential Moving Average calculations.
	//
	// Parameters:
	//   - newAlpha: The new EMA alpha value to be set.
	AdjustEmaAlpha(newAlpha float64)
}

type Epoch int

type KeyPair interface {
	GenerateKey() error
	SerializePrivate() ([]byte, error)
	SerializePublic() ([]byte, error)
	DeserializePrivate(data []byte) error
	DeserializePublic(data []byte) error
	GetPublic() any
	GetPrivate() any
	GetPublicKeyBytes() ([]byte, error)
}

type Metrics struct {
	BandwidthUsage float64      // Bandwidth usage metric
	Computational  float64      // Computational power metric
	Storage        float64      // Storage capacity metric
	Uptime         float64      // Uptime percentage metric
	Responsiveness float64      // Responsiveness metric based on latency
	Reliability    float64      // Reliability metric based on successful interactions
	Stake          *uint256.Int // Stake or trust level associated with the peer
	LastUpdated    time.Time    // Timestamp of the last update
}

type PartialSignature struct {
	Signature  []byte
	ShareIndex int
}

type Signer interface {
	BaseSigner
}

type ThresholdSigner interface {
	BaseSigner
	GeneratePartialSignature(data []byte) ([]byte, error)
	VerifyAggregatedSignature(data []byte, signature []byte) (bool, error)
	AggregateAndVerifySignature(blockHash types.Hash, data []byte, partialSigs [][]byte) ([]byte, error)
	AggregatePartialSignatures(blockHash types.Hash, data []byte, partialSigs [][]byte) ([]byte, error)
}