Method sendPing

psynetrpc.go:161–192

()

}

func (p *PsyNetRPC) sendPing() {
	pingMessage, err := p.buildMessage(map[string]string{"PsyPing": ""}, nil)
	if err != nil {
		p.logger.Error("failed to build ping message", slog.Any("err", err))
		return
	}

	p.mu.Lock()
	if !p.connected || p.wsConn == nil {
		p.logger.Error("connection lost while preparing to ping")
		p.mu.Unlock()
		return
	}
	if err := p.wsConn.WriteMessage(websocket.TextMessage, []byte(pingMessage)); err != nil {
		p.logger.Error("failed to send ping", slog.Any("err", err))
		p.mu.Unlock()
		return
	}
	p.mu.Unlock()

	p.logger.Debug("sent ping")

	select {
	case <-p.pongChan:
		p.logger.Debug("received pong")
		p.schedulePing()
	case <-time.After(pongTimeout):
		p.logger.Error("pong timeout reached")
		_ = p.Close()
		return
	}
}

func (p *PsyNetRPC) readMessages() {
	defer func() {