123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126 |
- // Copyright (C) 2019 The Syncthing Authors.
- //
- // This Source Code Form is subject to the terms of the Mozilla Public
- // License, v. 2.0. If a copy of the MPL was not distributed with this file,
- // You can obtain one at https://mozilla.org/MPL/2.0/.
- // Command stcrashreceiver is a trivial HTTP server that allows two things:
- //
- // - uploading files (crash reports) named like a SHA256 hash using a PUT request
- // - checking whether such file exists using a HEAD request
- //
- // Typically this should be deployed behind something that manages HTTPS.
- package main
- import (
- "encoding/json"
- "flag"
- "fmt"
- "io"
- "log"
- "net/http"
- "os"
- "path/filepath"
- "github.com/syncthing/syncthing/lib/sha256"
- "github.com/syncthing/syncthing/lib/ur"
- raven "github.com/getsentry/raven-go"
- )
- const maxRequestSize = 1 << 20 // 1 MiB
- func main() {
- dir := flag.String("dir", ".", "Parent directory to store crash and failure reports in")
- dsn := flag.String("dsn", "", "Sentry DSN")
- listen := flag.String("listen", ":22039", "HTTP listen address")
- flag.Parse()
- mux := http.NewServeMux()
- cr := &crashReceiver{
- dir: filepath.Join(*dir, "crash_reports"),
- dsn: *dsn,
- }
- mux.Handle("/", cr)
- if *dsn != "" {
- mux.HandleFunc("/newcrash/failure", handleFailureFn(*dsn, filepath.Join(*dir, "failure_reports")))
- }
- log.SetOutput(os.Stdout)
- if err := http.ListenAndServe(*listen, mux); err != nil {
- log.Fatalln("HTTP serve:", err)
- }
- }
- func handleFailureFn(dsn, failureDir string) func(w http.ResponseWriter, req *http.Request) {
- return func(w http.ResponseWriter, req *http.Request) {
- lr := io.LimitReader(req.Body, maxRequestSize)
- bs, err := io.ReadAll(lr)
- req.Body.Close()
- if err != nil {
- http.Error(w, err.Error(), 500)
- return
- }
- var reports []ur.FailureReport
- err = json.Unmarshal(bs, &reports)
- if err != nil {
- http.Error(w, err.Error(), 400)
- return
- }
- if len(reports) == 0 {
- // Shouldn't happen
- log.Printf("Got zero failure reports")
- return
- }
- version, err := parseVersion(reports[0].Version)
- if err != nil {
- http.Error(w, err.Error(), 400)
- return
- }
- for _, r := range reports {
- pkt := packet(version, "failure")
- pkt.Message = r.Description
- pkt.Extra = raven.Extra{
- "count": r.Count,
- }
- for k, v := range r.Extra {
- pkt.Extra[k] = v
- }
- if r.Goroutines != "" {
- url, err := saveFailureWithGoroutines(r.FailureData, failureDir)
- if err != nil {
- log.Println("Saving failure report:", err)
- http.Error(w, "Internal server error", http.StatusInternalServerError)
- return
- }
- pkt.Extra["goroutinesURL"] = url
- }
- message := sanitizeMessageLDB(r.Description)
- pkt.Fingerprint = []string{message}
- if err := sendReport(dsn, pkt, userIDFor(req)); err != nil {
- log.Println("Failed to send failure report:", err)
- } else {
- log.Println("Sent failure report:", r.Description)
- }
- }
- }
- }
- func saveFailureWithGoroutines(data ur.FailureData, failureDir string) (string, error) {
- bs := make([]byte, len(data.Description)+len(data.Goroutines))
- copy(bs, data.Description)
- copy(bs[len(data.Description):], data.Goroutines)
- id := fmt.Sprintf("%x", sha256.Sum256(bs))
- path := fullPathCompressed(failureDir, id)
- err := compressAndWrite(bs, path)
- if err != nil {
- return "", err
- }
- return reportServer + path, nil
- }
|