Method handleResp

sockjsclient/xhr.go:176–261

(resp *http.Response)

}

func (x *XHRSession) handleResp(resp *http.Response) (msg string, again bool, err error) {
	defer resp.Body.Close()

	switch resp.StatusCode {
	case http.StatusOK:
	case http.StatusNotFound:
		x.Close(3000, "session not found") // invalidate session - see details: sockjs/sockjs-client#66

		return "", false, &ErrSession{
			Type:  config.XHRPolling,
			State: sockjs.SessionClosed,
			Err:   errors.New("session does not exist: " + x.sessionID),
		}
	default:
		return "", false, fmt.Errorf("Receiving data failed. Want: 200 Got: %d", resp.StatusCode)
	}

	fr := newFrameReader(resp.Body, x.timeout)

	frame, err := fr.ReadByte()
	if err == ErrPollTimeout {
		return "", true, nil
	}
	if err != nil {
		return "", false, err
	}

	switch frame {
	case 'o':
		x.setState(sockjs.SessionActive)

		return "", true, nil
	case 'm':
		var message string
		if err := json.NewDecoder(fr).Decode(&message); err != nil {
			return "", false, err
		}

		if message == "" {
			return "", false, errors.New("unexpected empty message")
		}

		x.messages = append(x.messages, message)

		message, x.messages = x.messages[0], x.messages[1:]

		return message, false, nil
	case 'a':
		// received an array of messages
		var messages []string
		if err := json.NewDecoder(fr).Decode(&messages); err != nil {
			return "", false, err
		}

		x.messages = append(x.messages, messages...)

		if len(x.messages) == 0 {
			return "", false, errors.New("no message")