app

type App interface {
	// ValidateNetRecordBody provides the app an opportunity to validate the contents
	// of a record before it's committed to a thread log.
	// identity is the author's public key.
	ValidateNetRecordBody(ctx context.Context, body format.Node, identity thread.PubKey) error

	// HandleNetRecord handles an inbound thread record from net.
	HandleNetRecord(ctx context.Context, rec net.ThreadRecord, key thread.Key) error
}

type Connection func(context.Context, thread.ID) (<-chan net.ThreadRecord, error)

type Connector struct {
	Net Net
	// contains filtered or unexported fields
}

type LocalEvent struct {
	Node  format.Node
	Token thread.Token
}

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

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

type Net interface {
	net.Net

	// ConnectApp returns an app<->thread connector.
	ConnectApp(App, thread.ID) (*Connector, error)

	// Validate thread ID and token against the net host.
	// If token is present and was issued the net host (is valid), the embedded public key is returned.
	// If token is not present, both the returned public key and error will be nil.
	Validate(id thread.ID, token thread.Token, readOnly bool) (thread.PubKey, error)
}