Function forwardEvent

webhook/forward.go:160–200

forwardEvent forwards events to the server running on the local port specified by the user

(w io.Writer, url string, ev wsEventReceived)

// forwardEvent forwards events to the server running on the local port specified by the user
func forwardEvent(w io.Writer, url string, ev wsEventReceived) (*httpEventForward, error) {
	if url == "" {
		event := ev.Header.Get("X-GitHub-Event")
		event = strings.ReplaceAll(event, "\n", "")
		event = strings.ReplaceAll(event, "\r", "")
		fmt.Fprintf(os.Stderr, "[LOG] received event %q\n", event)
		if _, err := w.Write(ev.Body); err != nil {
			return nil, err
		}
		if _, err := w.Write([]byte("\n")); err != nil {
			return nil, err
		}
		return &httpEventForward{Status: 200, Header: make(http.Header), Body: []byte("OK")}, nil
	}

	req, err := http.NewRequest(http.MethodPost, url, bytes.NewReader(ev.Body))
	if err != nil {
		return nil, err
	}

	for k := range ev.Header {
		req.Header.Set(k, ev.Header.Get(k))
	}

	resp, err := http.DefaultClient.Do(req)
	if err != nil {
		return nil, err
	}

	defer resp.Body.Close()
	body, err := io.ReadAll(resp.Body)
	if err != nil {
		return nil, err
	}

	return &httpEventForward{
		Status: resp.StatusCode,
		Header: resp.Header,
		Body:   body,
	}, nil
}