Function NewSessionFromStream

helper/tunnel/session.go:64–79

(id uuid.UUID, conn net.Conn)

}

func NewSessionFromStream(id uuid.UUID, conn net.Conn) (*Session, error) {
	ctx, cancel := context.WithCancel(context.Background())
	r := &Session{
		ID:         id,
		Conn:       conn,
		Context:    ctx,
		cancelFunc: cancel,
		Buf:        bytes.Buffer{},
		Open:       true,
	}
	err := addSession(r)
	if err != nil {
		return nil, err
	}
	return r, nil
}

func addSession(r *Session) error {
	if _, ok := GetSession(r.ID); ok {