application

type AppPeer struct {
	// identifier
	ID string
	// name
	Name string
	// relay string
	Relay string
	// addr string
	Addr string
	// app origin name string
	AppOrigin string

	// ai model hash string
	ModelHash string
	// mac addr
	Mac string
	// memory info
	MemInfo string
	// cpu info
	CpuInfo string

	// peer's distance
	Distance *big.Int
	// app startup time
	Starup_time uint64
	// app uptime
	Uptime uint64
	// amount of slots currently occupying the app
	Guage_height uint64
	// max limit
	Guage_max uint64
	// average e power value
	AveragePower float32
	//gpu info
	GpuInfo string
	// version
	Version string
}

type Application struct {
	Name    string
	Tag     string
	Version string
	PeerID  peer.ID

	// ip4 addr string
	IpAddr string
	// ai app origin name
	AppOrigin string
	// ai model hash string
	ModelHash string
	// mac addr
	Mac string
	// memory info
	MemInfo string
	// cpu info
	CpuInfo string
	// gpu info
	GpuInfo string

	// app startup time
	StartupTime uint64
	// app uptime
	Uptime uint64
	// amount of slots currently occupying the app
	GuageHeight uint64
	// max limit
	GuageMax uint64
	// average e power value
	AveragePower float32
	// relay host
	RelayHost string
	// proxy port of relay
	RelayProxyPort uint64
}

type ApplicationStore interface {
	// ApplicationStore returns the application of endpoint
	GetEndpointApplication() *Application
}

type EdgeCall struct {
	PeerId   string          `json:"peerId"`
	Endpoint string          `json:"endpoint"`
	Input    json.RawMessage `json:"input"`
}

type Endpoint struct {
	sync.Mutex
	// contains filtered or unexported fields
}

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

type Event struct {
	// New Application
	NewApp []*Application

	// Type is the type of event
	Type EventType

	// Source is the source that generated the blocks for the event
	// right now it can be either the Sealer or the Syncer
	Source string
}

type EventType int

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

type Network interface {
	// AddrInfo returns Network Info
	AddrInfo() *peer.AddrInfo
	// RegisterProtocol registers gRPC service
	RegisterProtocol(string, network.Protocol)
	// Peers returns current connected peers
	Peers() []*network.PeerConnInfo
	// SubscribeCh returns a channel of peer event
	SubscribeCh(context.Context) (<-chan *event.PeerEvent, error)
	// GetPeerDistance returns the distance between the node and given peer
	GetPeerDistance(peer.ID) *big.Int
	// NewProtoConnection opens up a new stream on the set protocol to the peer,
	// and returns a reference to the connection
	NewProtoConnection(protocol string, peerID peer.ID) (*rawGrpc.ClientConn, error)
	// NewTopic Creates New Topic for gossip
	NewTopic(protoID string, obj proto.Message) (*network.Topic, error)
	// IsConnected returns the node is connecting to the peer associated with the given ID
	IsConnected(peerID peer.ID) bool
	// SaveProtocolStream saves stream
	SaveProtocolStream(protocol string, stream *rawGrpc.ClientConn, peerID peer.ID)
	// CloseProtocolStream closes stream
	CloseProtocolStream(protocol string, peerID peer.ID) error
}

type PeerMap struct {
	sync.Map
}

type Subscription interface {
	GetEventCh() chan *Event
	GetEvent() *Event
	Close()
}

type SyncAppPeerClient interface {
	// Start processes for SyncAppPeerClient
	Start(topicSubFlag bool) error
	// Close terminates running processes for SyncAppPeerClient
	Close()
	// GetPeerStatus fetches peer status
	GetPeerStatus(id peer.ID) (*AppPeer, error)
	// GetPeerData fetches peer data
	GetPeerData(peerID peer.ID, dataHash string, timeout time.Duration) (map[string][]byte, error)
	// GetConnectedPeerStatuses fetches the statuses of all connecting peers
	GetConnectedPeerStatuses() []*AppPeer
	// GetPeerStatusUpdateCh returns a channel of peer's status update
	GetPeerStatusUpdateCh() <-chan *AppPeer
	// GetPeerConnectionUpdateEventCh returns peer's connection change event
	GetPeerConnectionUpdateEventCh() <-chan *event.PeerEvent
	// CloseStream close a stream
	CloseStream(peerID peer.ID) error
	// DisablePublishingPeerStatus disables publishing status in syncer topic
	DisablePublishingPeerStatus()
	// EnablePublishingPeerStatus enables publishing status in syncer topic
	EnablePublishingPeerStatus()
	// PublishApplicationStatus publish application status
	PublishApplicationStatus(status *proto.AppStatus)
	// SubscribeAppEvents returns a application event subscription
	SubscribeAppEvents() Subscription
}

type SyncAppPeerService interface {
	// Start starts server
	Start()
	// Close terminates running processes for SyncPeerService
	Close() error
}

type Syncer interface {
	// Start starts syncer processes
	Start(topicSubFlag bool) error
	// Close terminates syncer process
	Close() error
	// GetAppPeer get AppPeer by PeerID
	GetAppPeer(id string) *AppPeer
}