server.v4.go

package socketio

import (
	"net/http"

	nmem "github.com/njones/socketio/adaptor/transport/memory"
	eio "github.com/njones/socketio/engineio"
	siop "github.com/njones/socketio/protocol"
)

// https://socket.io/docs/v4/migrating-from-3-x-to-4-0/

type handshakeV4 struct {
	Auth func() map[string]interface{}
}

func (v4 *handshakeV4) init() {
	if v4.Auth == nil {
		v4.Auth = func() map[string]interface{} { return map[string]interface{}{} }
	}
}

type ServerV4 struct {
	inSocketV4

	prev *ServerV3
}

func NewServerV4(opts ...Option) *ServerV4 {
	v4 := &ServerV4{}
	v4.new(opts...)

	v3 := v4.prev
	v2 := v3.prev
	v1 := v2.prev

	v1.eio = eio.NewServerV5(eio.WithPath(*v1.path)).(eio.EIOServer)
	v1.eio.With(opts...)

	v4.With(opts...)
	return v4
}

func (v4 *ServerV4) new(opts ...Option) Server {
	v4.prev = (&ServerV3{}).new(opts...).(*ServerV3)
	v4.onConnect = make(map[Namespace]onConnectCallbackVersion4)

	v3 := v4.prev
	v2 := v3.prev
	v1 := v2.prev

	v1.run = runV4(v4)

	v1.transport = nmem.NewInMemoryTransport(siop.NewPacketV5)
	v1.setTransporter(v1.transport)

	v1.protectedEventName = v4ProtectedEventName
	v1.doConnectPacket = doConnectPacketV4(v4)

	v4.inSocketV4.prev = v3.inSocketV3.clone()

	return v4
}

func (v4 *ServerV4) With(opts ...Option) {
	v4.prev.With(opts...)
	for _, opt := range opts {
		opt(v4)
	}
}

func (v4 *ServerV4) Except(room ...Room) innTooExceptEmit {
	rtn := v4.clone()
	rtn.setIsServer(true)
	return rtn.Except(room...)
}

func (v4 *ServerV4) In(room ...Room) innTooExceptEmit {
	rtn := v4.clone()
	rtn.setIsServer(true)
	return rtn.In(room...)
}

func (v4 *ServerV4) Of(namespace Namespace) inSocketV4 {
	rtn := v4.clone()
	rtn.setIsServer(true)
	return rtn.Of(namespace)
}

func (v4 *ServerV4) To(room ...Room) innTooExceptEmit {
	rtn := v4.clone()
	rtn.setIsServer(true)
	return rtn.To(room...)
}

func (v4 *ServerV4) ServeHTTP(w http.ResponseWriter, r *http.Request) {
	v1 := v4.prev.prev.prev
	v1.ServeHTTP(w, r)
}