sse

type APIVersionEvent struct {
	APIVersion string `json:"ApiVersion"`
}

type BlockAdded struct {
	BlockHash string      `json:"block_hash"`
	Block     types.Block `json:"block"`
}

type BlockAddedEvent struct {
	BlockAdded BlockAdded `json:"BlockAdded"`
}

type Client struct {
	Streamer *Streamer
	Consumer *Consumer

	EventStream chan RawEvent

	StreamErrorHandler   func(<-chan error)
	ConsumerErrorHandler func(<-chan error)

	WorkersCount int
	// contains filtered or unexported fields
}

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

type CtxWorkerID string

type DeployAcceptedEvent struct {
	DeployAccepted types.Deploy `json:"DeployAccepted"`
}

type DeployExpiredEvent struct {
	DeployExpired DeployExpiredPayload `json:"DeployExpired"`
}

type DeployExpiredPayload struct {
	DeployHash key.Hash `json:"deploy_hash"`
}

type DeployProcessedEvent struct {
	DeployProcessed DeployProcessedPayload `json:"DeployProcessed"`
}

type DeployProcessedPayload struct {
	DeployHash      key.Hash                    `json:"deploy_hash"`
	Account         string                      `json:"account"`
	Timestamp       time.Time                   `json:"timestamp"`
	TTL             string                      `json:"ttl"`
	BlockHash       key.Hash                    `json:"block_hash"`
	ExecutionResult types.ExecutionResultStatus `json:"execution_result"`
}

type ErrUnknownEventType struct {
	RawData []byte
	// contains filtered or unexported fields
}

type EventData = json.RawMessage

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

type EventStreamReader struct {
	MaxBufferSize int
	// contains filtered or unexported fields
}

type EventType = int

type FaultEvent struct {
	Fault FaultPayload `json:"Fault"`
}

type FaultPayload struct {
	EraID     uint64            `json:"era_id"`
	PublicKey keypair.PublicKey `json:"public_key"`
	Timestamp types.Timestamp   `json:"timestamp"`
}

type FinalitySignatureEvent struct {
	FinalitySignature FinalitySignaturePayload `json:"FinalitySignature"`
}

type FinalitySignaturePayload struct {
	BlockHash key.Hash          `json:"block_hash"`
	EraID     uint64            `json:"era_id"`
	Signature types.HexBytes    `json:"signature"`
	PublicKey keypair.PublicKey `json:"public_key"`
}

type Handler interface {
	Handle(context.Context, RawEvent) error
}

type HandlerFunc func(context.Context, RawEvent) error

type HttpConnection struct {
	Headers map[string]string
	URL     string
	// contains filtered or unexported fields
}

type Middleware func(handler HandlerFunc) HandlerFunc

type MiddlewareHandler interface {
	Process(handler HandlerFunc) HandlerFunc
}

type RawEvent struct {
	EventType EventType
	Data      EventData
	EventID   uint64
}

type StepEvent struct {
	Step StepPayload `json:"step"`
}

type StepPayload struct {
	EraID           uint64       `json:"era_id"`
	ExecutionEffect types.Effect `json:"execution_effect"`
	// Todo: not sure, didn't found example to test
	Operations *[]types.Operation `json:"operations,omitempty"`
	// Todo: not sure, didn't found example to test
	Transform *types.TransformKey `json:"transform,omitempty"`
}

type Streamer struct {
	Connection *HttpConnection

	StreamReader *EventStreamReader
	// This duration allows the stream's buffer to stay in fill up completely state, which could indicate
	// that the workers are working too slowly and have not received any messages.
	// If this period elapses without any messages being received, an ErrFullStreamTimeoutError will be thrown.
	BlockedStreamLimit time.Duration
	// contains filtered or unexported fields
}