package websocket

import (
	"net"
	"net/http"
	"net/url"

	ice "shylinux.com/x/icebergs"
	"shylinux.com/x/toolkits/task"
	"shylinux.com/x/websocket"
)

const bufs = 10 * ice.MOD_BUFS

type Conn struct {
	*websocket.Conn
	lock task.Lock
}

func (c *Conn) WriteMessage(messageType int, data []byte) error {
	defer c.lock.Lock()()
	return c.Conn.WriteMessage(messageType, data)
}
func Upgrade(w http.ResponseWriter, r *http.Request) (*Conn, error) {
	conn, e := websocket.Upgrade(w, r, nil, bufs, bufs)
	return &Conn{Conn: conn}, e
}
func NewClient(c net.Conn, u *url.URL) (*Conn, error) {
	conn, _, e := websocket.NewClient(c, u, nil, bufs, bufs)
	return &Conn{Conn: conn}, e
}