connection.go

package plex

import (
	"net"

	"github.com/swxctx/plex/pack"
	"github.com/swxctx/plex/plog"
)

// plexConnection
type plexConnection struct {
	// 用户标识
	uid string
	// remote
	remoteAddr string
	// auth success
	isAuthenticated bool
	// conn cache info
	storeInfo *storeInfo
	// bind server info
	plexServer *plexServer
}

// storeInfo
type storeInfo struct {
	// connection client
	conn net.Conn
	// last heartbeat ts
	heartbeat int64
}

// close connection
func (c *plexConnection) close() {
	// close conn
	c.storeInfo.conn.Close()

	// del store
	c.plexServer.store.del(c.uid)

	// callback
	if len(c.uid) > 0 {
		c.plexServer.onlineStatusSubscribe(false, c.uid)
	}
}

// responseOnlyUri
func (c *plexConnection) responseOnlyUri(uri string) error {
	// pack message
	message, err := pack.Pack(&pack.Message{
		Seq: GetSeq(),
		URI: uri,
	})
	if err != nil {
		plog.Errorf("responseOnlyUri: err-> %v, uri-> %s", err, uri)
		return err
	}

	// send message
	return c.storeInfo.send(message)
}

// send
func (s *storeInfo) send(data []byte) error {
	_, err := s.conn.Write(data)
	return err
}