chore: finish addressing ~easy gosec warnings

cmd/ooniprobe/internal/autorun/autorun_darwin.go

@@ -109,11 +109,11 @@ func (managerDarwin) writePlist() error {
 		return err
 	}
 	log.Infof("exec: mkdir -p %s", plistDir)
-	if err := os.MkdirAll(plistDir, 0755); err != nil {
+	if err := os.MkdirAll(plistDir, 0700); err != nil {
 		return err
 	}
 	log.Infof("exec: writePlist(%s)", plistPath)
-	return os.WriteFile(plistPath, out.Bytes(), 0644)
+	return os.WriteFile(plistPath, out.Bytes(), 0600)
 }
 
 func (managerDarwin) start() error {

cmd/ooniprobe/internal/cli/reset/reset.go

@@ -26,7 +26,9 @@ func init() {
 			return err
 		}
 		if *force {
-			os.RemoveAll(ctx.Home())
+			// trade off: we're not checking for an error here to make the
+			// OONI directory deletion idempotent
+			_ = os.RemoveAll(ctx.Home())
 			log.Infof("Deleted %s", ctx.Home())
 		} else {
 			log.Infof("Run with --force to delete %s", ctx.Home())

cmd/ooniprobe/internal/cli/rm/rm.go

@@ -9,6 +9,7 @@ import (
 	"github.com/apex/log"
 	"github.com/ooni/probe-cli/v3/cmd/ooniprobe/internal/cli/root"
 	"github.com/ooni/probe-cli/v3/internal/database"
+	"github.com/ooni/probe-cli/v3/internal/runtimex"
 	"github.com/upper/db/v4"
 )
 
@@ -20,7 +21,7 @@ func deleteAll(d *database.Database, skipInteractive bool) error {
 			Options: []string{"true", "false"},
 			Default: "false",
 		}
-		survey.AskOne(confirm, &answer, nil)
+		runtimex.Try0(survey.AskOne(confirm, &answer, nil))
 		if answer == "false" {
 			return errors.New("canceled by user")
 		}
@@ -80,7 +81,7 @@ func init() {
 			Options: []string{"true", "false"},
 			Default: "false",
 		}
-		survey.AskOne(confirm, &answer, nil)
+		runtimex.Try0(survey.AskOne(confirm, &answer, nil))
 		if answer == "false" {
 			return errors.New("canceled by user")
 		}

cmd/ooniprobe/internal/config/parser.go

@@ -67,7 +67,7 @@ func (c *Config) Write() error {
 	if c.path == "" {
 		return errors.New("config file path is empty")
 	}
-	if err := os.WriteFile(c.path, configJSON, 0644); err != nil {
+	if err := os.WriteFile(c.path, configJSON, 0600); err != nil {
 		return errors.Wrap(err, "writing config JSON")
 	}
 	return nil

cmd/ooniprobe/internal/nettests/nettests.go

@@ -246,9 +246,9 @@ func (c *Controller) Run(builder model.ExperimentBuilder, inputs []string) error
 			return errors.Wrap(err, "failed to add test keys to summary")
 		}
 	}
-	db.UpdateUploadedStatus(c.res)
+	err := db.UpdateUploadedStatus(c.res)
 	log.Debugf("status.end")
-	return nil
+	return err
 }
 
 // OnProgress should be called when a new progress event is available.

cmd/ooniprobe/internal/ooni/ooni.go

@@ -290,7 +290,7 @@ func InitDefaultConfig(home string) (*config.Config, error) {
 	if err != nil {
 		if os.IsNotExist(err) {
 			log.Debugf("writing default config to %s", configPath)
-			if err = os.WriteFile(configPath, defaultConfig, 0644); err != nil {
+			if err = os.WriteFile(configPath, defaultConfig, 0600); err != nil {
 				return nil, err
 			}
 			// If the user did the informed consent procedure in

internal/cmd/oohelperd/main.go

@@ -100,12 +100,16 @@ func main() {
 		} else {
 			w.Header().Set("WWW-Authenticate", "Basic realm=metrics")
 			w.WriteHeader(401)
-			w.Write([]byte("401 Unauthorized\n"))
+			_, _ = w.Write([]byte("401 Unauthorized\n"))
 		}
 	})
 
 	// create a listening server for serving ooniprobe requests
-	srv := &http.Server{Addr: *apiEndpoint, Handler: mux}
+	srv := &http.Server{
+		Addr:              *apiEndpoint,
+		Handler:           mux,
+		ReadHeaderTimeout: 8 * time.Second,
+	}
 	listener, err := net.Listen("tcp", *apiEndpoint)
 	runtimex.PanicOnError(err, "net.Listen failed")
 
@@ -121,7 +125,11 @@ func main() {
 	pprofMux := http.NewServeMux()
 	pprofMux.Handle("/debug/pprof/profile", http.HandlerFunc(pprof.Profile))
 	pprofMux.Handle("/debug/pprof/trace", http.HandlerFunc(pprof.Trace))
-	pprofSrv := &http.Server{Addr: *pprofEndpoint, Handler: pprofMux}
+	pprofSrv := &http.Server{
+		Addr:              *pprofEndpoint,
+		Handler:           pprofMux,
+		ReadHeaderTimeout: 8 * time.Second,
+	}
 	go pprofSrv.ListenAndServe()
 	log.Infof("serving CPU profile at http://%s/debug/pprof/profile", *pprofEndpoint)
 	log.Infof("serving execution traces at http://%s/debug/pprof/trace", *pprofEndpoint)

internal/database/actions.go

@@ -198,11 +198,10 @@ func (d *Database) DeleteResult(resultID int64) error {
 		return err
 	}
 	if err := res.Delete(); err != nil {
-		log.WithError(err).Error("failed to delete the result directory")
+		log.WithError(err).Error("failed to delete the result")
 		return err
 	}
-	os.RemoveAll(result.MeasurementDir)
-	return nil
+	return os.RemoveAll(result.MeasurementDir)
 }
 
 // UpdateUploadedStatus implements WritableDatabase.UpdateUploadedStatus
@@ -337,7 +336,10 @@ func (d *Database) CreateOrUpdateURL(urlStr string, categoryCode string, country
 			return err
 		} else {
 			url.CategoryCode = sql.NullString{String: categoryCode, Valid: true}
-			res.Update(url)
+			if err := res.Update(url); err != nil {
+				log.WithError(err).Error("Failed to update the database")
+				return err
+			}
 		}
 
 		return nil

internal/netemx/http.go

@@ -99,7 +99,7 @@ func (srv *httpCleartextServer) mustListenPortLocked(handler http.Handler, ipAdd
 	listener := runtimex.Try1(srv.unet.ListenTCP("tcp", addr))
 
 	// serve requests in a background goroutine
-	srvr := &http.Server{Handler: handler}
+	srvr := &http.Server{Handler: handler} // #nosec G112 - just a testing server
 	go srvr.Serve(listener)
 
 	// make sure we track the server (the .Serve method will close the

internal/netemx/https.go

@@ -97,7 +97,7 @@ func (srv *httpSecureServer) mustListenPortLocked(handler http.Handler, ipAddr n
 	tlsConfig := srv.unet.MustNewServerTLSConfig(srv.serverNameMain, srv.serverNameExtras...)
 
 	// serve requests in a background goroutine
-	srvr := &http.Server{
+	srvr := &http.Server{ // #nosec G112 - just a testing server
 		Handler:   handler,
 		TLSConfig: tlsConfig,
 	}

internal/testingx/httptestx.go

@@ -68,7 +68,7 @@ func MustNewHTTPServerEx(addr *net.TCPAddr, httpListener TCPListener, handler ht
 		Path:   "/",
 	}
 	srv := &HTTPServer{
-		Config:       &http.Server{Handler: handler},
+		Config:       &http.Server{Handler: handler}, // #nosec G112 - just a testing server
 		Listener:     listener,
 		TLS:          nil,
 		URL:          baseURL.String(),
@@ -113,7 +113,7 @@ func MustNewHTTPServerTLSEx(
 	otherNames = append(otherNames, extraSNIs...)
 
 	srv := &HTTPServer{
-		Config:       &http.Server{Handler: handler},
+		Config:       &http.Server{Handler: handler}, // #nosec G112 - just a testing server
 		Listener:     listener,
 		TLS:          ca.MustNewServerTLSConfig(commonName, otherNames...),
 		URL:          baseURL.String(),

pkg/gobash/version.go

@@ -284,7 +284,7 @@ func unpackZip(targetDir, archiveFile string) error {
 		}
 
 		// File
-		if err := os.MkdirAll(filepath.Dir(outpath), 0755); err != nil {
+		if err := os.MkdirAll(filepath.Dir(outpath), 0700); err != nil {
 			return err
 		}
 		out, err := os.OpenFile( // #nosec G304 - this is working as intended