handlers.go

package main

import (
	"log"
	"net"
	"net/http"
	"strconv"
	"time"
)

func (s *server) handlePlainGet() http.HandlerFunc {
	return func(w http.ResponseWriter, r *http.Request) {
		log.Print("handling new request")

		repo, branch, files, err := parseGetRequest(r, s.param.proxy.FileMatching)

		if err != nil {
			log.Print(err)
			log.Print("aborting request handling")

			w.WriteHeader(http.StatusBadRequest)

			return
		}

		if err := s.processMatching(repo, branch, files); err != nil {
			log.Print(err)
			http.NotFound(w, r)

			return
		}

		w.WriteHeader(http.StatusOK)

		log.Print("handling of request finished")
	}
}

func (s *server) handleJSONPost() http.HandlerFunc {
	return func(w http.ResponseWriter, r *http.Request) {
		log.Print("handling new request")

		repos, branch, files, err := parseJSONRequest(r, s.param.proxy.FileMatching)

		if err != nil {
			log.Print(err)
			log.Print("aborting request handling")

			w.WriteHeader(http.StatusBadRequest)

			return
		}

		for _, repo := range repos {
			if err := s.processMatching(repo, branch, files); err != nil {
				log.Print(err)
			}
		}

		w.WriteHeader(http.StatusOK)

		log.Print("handling of request finished")
	}
}

func (s *server) handleReadiness() http.HandlerFunc {
	return func(w http.ResponseWriter, r *http.Request) {
		if len(s.mappingHash) == 0 {
			w.WriteHeader(http.StatusInternalServerError)
		}

		conn, _ := net.DialTimeout("tcp", net.JoinHostPort("", strconv.Itoa(s.param.proxy.port)), time.Millisecond*time.Duration(100))
		if conn == nil {
			w.WriteHeader(http.StatusInternalServerError)
		}
		conn.Close()

		w.WriteHeader(http.StatusOK)
	}
}