asgi

type ChannelFullError struct {
	Channel string
}

type ChannelLayer interface {
	// Send sends a message to a channel. The first argument has to be a channel
	// name. The second argument has to be a raw message dict.
	Send(channel string, message Message) (err error)

	// Receive listens to a list of channels and gets a message from it. The first
	// argument is a slice (list) of channel names. The second argument determinis
	// if the method should block until there is a message to receive or if the
	// method should return at once.
	// The method returns the channel name from which a value was received or an
	// empty string, if no value could be received. The second return value is the
	// received raw message.
	Receive(channels []string, block bool) (channelname string, message Message, err error)

	// NewChannel taks a prefix of a channlname and adds a unique suffix. It also
	// returns an error, if some happen.
	NewChannel(string) (string, error)
}

type ConnectionMessage struct {
	ReplyChannel string
	Scheme       string
	Path         string
	QueryString  []byte
	RootPath     string
	Headers      http.Header
	Client       string
	Server       string
}

type DisconnectionMessage struct {
	ReplyChannel string
	Code         int
	Path         string
	Order        int
}

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

type Message map[string]interface{}

type Messager interface {
	SendMessenger
	ReceiveMessenger
}

type ReceiveMessage struct {
	ReplyChannel string
	Path         string
	Content      []byte
	Type         int // See websocket.TextMessage and websocket.BinaryMessage
	Order        int
}

type ReceiveMessenger interface {
	// Sets the values of the variable with the values of a Message dict.
	Set(Message) error
}

type RequestBodyChunkMessage struct {
	Content     []byte
	Closed      bool
	MoreContent bool
}

type RequestMessage struct {
	ReplyChannel string
	HTTPVersion  string
	Method       string
	Scheme       string
	Path         string
	QueryString  []byte
	RootPath     string
	Headers      http.Header
	Body         []byte
	BodyChannel  string
	Client       string
	Server       string
}

type ResponseChunkMessage struct {
	Content     []byte
	MoreContent bool
}

type ResponseMessage struct {
	ResponseChunkMessage
	Status  int
	Headers http.Header
}

type SendCloseAcceptMessage struct {
	Bytes  []byte
	Text   string
	Close  int
	Accept bool
}

type SendMessenger interface {
	// Converts a Message to a Message dict, that can be send through a asgi channel.
	Raw() Message
}