82 lines
1.9 KiB
Go
82 lines
1.9 KiB
Go
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"net/http"
|
|
"os/exec"
|
|
"regexp"
|
|
"runtime"
|
|
"strconv"
|
|
"strings"
|
|
)
|
|
|
|
func tracerouteTryExecute(cmd []string, args [][]string) ([]byte, string) {
|
|
var output []byte
|
|
var errString = ""
|
|
for i := range cmd {
|
|
var err error
|
|
var cmdCombined = cmd[i] + " " + strings.Join(args[i], " ")
|
|
|
|
instance := exec.Command(cmd[i], args[i]...)
|
|
output, err = instance.CombinedOutput()
|
|
if err == nil {
|
|
return output, ""
|
|
}
|
|
errString += fmt.Sprintf("+ (Try %d) %s\n%s\n\n", (i + 1), cmdCombined, output)
|
|
}
|
|
return nil, errString
|
|
}
|
|
|
|
func tracerouteHandler(httpW http.ResponseWriter, httpR *http.Request) {
|
|
query := string(httpR.URL.Query().Get("q"))
|
|
query = strings.TrimSpace(query)
|
|
if query == "" {
|
|
invalidHandler(httpW, httpR)
|
|
} else {
|
|
var result []byte
|
|
var errString string
|
|
skippedCounter := 0
|
|
|
|
if runtime.GOOS == "freebsd" || runtime.GOOS == "netbsd" || runtime.GOOS == "openbsd" {
|
|
result, errString = tracerouteTryExecute(
|
|
[]string{
|
|
"traceroute",
|
|
},
|
|
[][]string{
|
|
{"-q1", "-w1", query},
|
|
},
|
|
)
|
|
} else if runtime.GOOS == "linux" {
|
|
result, errString = tracerouteTryExecute(
|
|
[]string{
|
|
"traceroute",
|
|
"traceroute",
|
|
},
|
|
[][]string{
|
|
{"-q1", "-N32", "-w1", query},
|
|
{"-q1", "-w1", query},
|
|
},
|
|
)
|
|
} else {
|
|
httpW.WriteHeader(http.StatusInternalServerError)
|
|
httpW.Write([]byte("traceroute not supported on this node.\n"))
|
|
return
|
|
}
|
|
if errString != "" {
|
|
httpW.WriteHeader(http.StatusInternalServerError)
|
|
httpW.Write([]byte(errString))
|
|
}
|
|
if result != nil {
|
|
errString = string(result)
|
|
errString = regexp.MustCompile(`(?m)^\s*(\d*)\s*\*\n`).ReplaceAllStringFunc(errString, func(w string) string {
|
|
skippedCounter++
|
|
return ""
|
|
})
|
|
httpW.Write([]byte(strings.TrimSpace(errString)))
|
|
if skippedCounter > 0 {
|
|
httpW.Write([]byte("\n\n" + strconv.Itoa(skippedCounter) + " hops not responding."))
|
|
}
|
|
}
|
|
}
|
|
}
|