entities

type Event interface {
	//Validate checks if the event message is valid
	//Returns true if the event is valid or false and a error containing the reason it is not
	Validate(*TableSet) (bool, error)

	//GetID returns the id of the event
	GetID() uuid.UUID
}

type EventObserver interface {
	EventUpdate(Event)
}

type EventStream interface {
	//GetWriteChannel returns a channel which can be used by other components to write a new event to the stream
	//The EventStream is responsible for checking the validity and uniqueness of the event
	GetWriteChannel() chan<- Event

	//GetAllEvents returns all events currently in the event stream
	GetAllEvents() []Event

	//Attach can be used by other components to subscribe to updates of the event stream
	//The EventStream must only call the callback with validated and unique events.
	Attach(observerCallback EventObserver)

	//Detach removes a subscriber
	Detach(observerCallback EventObserver)

	//Run runs the goroutine which handles changes and requests to the EventStream
	Run(context.Context) error
}

type GenericEvent struct {
	abusemesh.TableEvent
}

type GetAllNodesRequest struct {
	//ResponseChan is the channel over which multiple nodes will be sent
	ResponseChan chan<- Node

	//Context can be used to cancel the sending of nodes
	Context context.Context
}

type GetNodeRequest struct {
	ResponseChan chan<- *Node
	NodeID       uuid.UUID
}

type Node struct {
	UUID            uuid.UUID
	ProtocolVersion string
	IPAddress       net.IP
	ContactDetails  abusemesh.ContactDetails
	ASN             int32
	PGPEntity       *openpgp.Entity
}

type NodeTable struct {
	Entities map[uuid.UUID]Node
}

type TableRequest interface {
	Process(*TableSet) error
}

type TableSet struct {
	Channel chan TableRequest
	// contains filtered or unexported fields
}

type UpdateTableRequest struct {
	Event Event
}