Method addMessage

cmd/run/socket/proxy.go:630–654

(op byte, payload []byte, isClient bool, t time.Time)

}

func (w *websocket) addMessage(op byte, payload []byte, isClient bool, t time.Time) {
	w.mu.Lock()
	defer w.mu.Unlock()

	data := ""
	if op == wsOpcodeText {
		data = string(payload)
	} else {
		data = base64.StdEncoding.EncodeToString(payload)
	}

	var dir string
	if (isClient && w.isOutgoing) || (!isClient && !w.isOutgoing) {
		dir = "send"
	} else {
		dir = "receive"
	}

	w.msgs = append(w.msgs, &tracer.WebsocketMessage{
		Type:   dir,
		Time:   float64(t.UnixNano()) / 1e9,
		Opcode: int(op),
		Data:   data,
	})
}

func (w *websocket) getMessages() []*tracer.WebsocketMessage {
	w.mu.RLock()