Method proxy

cmd/run/socket/proxy.go:861–984

()

}

func (w *websocket) proxy() ([]*tracer.WebsocketMessage, error) {
	defer w.cleanup()

	ctx, cancel := context.WithTimeout(context.Background(), websocketTimeLimit)
	defer cancel()
	errs := make(chan error, 2)

	readLoop := func(isClient bool) {
		var payload []byte
		var op byte
		var t time.Time
		var compressed bool
		first := true

		type frameResult struct {
			frame *websocketFrame
			err   error
		}
		for {
			ch := make(chan frameResult, 1)
			go func() {
				frame, err := w.readFrame(isClient)
				select {
				case <-ctx.Done():
				case ch <- frameResult{frame, err}:
				}
			}()

			var frame *websocketFrame
			select {
			case <-ctx.Done():
				return
			case result := <-ch:
				if result.err != nil {
					errs <- fmt.Errorf("read frame (isClient=%t): %w", isClient, result.err)
					return
				}
				frame = result.frame
			}

			switch frame.op {
			case wsOpcodeContinuation:
				if first {
					errs <- fmt.Errorf("unexpected continuation frame (isClient=%t)", isClient)
					return
				}
				payload = append(payload, frame.payload...)
				if frame.fin {
					if compressed {
						var err error
						payload, err = w.decompress(payload, isClient)
						if err != nil {
							errs <- fmt.Errorf("decompress: %w", err)
							return
						}
					}
					w.addMessage(op, payload, isClient, t)
					payload = nil