go.mod

@@ -2,13 +2,11 @@ module git.dc09.ru/mitm-archive/server
 
 go 1.22.3
 
-require (
+require github.com/valyala/fasthttp v1.55.0
-	github.com/mattn/go-sqlite3 v1.14.22
-	github.com/valyala/fasthttp v1.55.0
-)
 
 require (
 	github.com/andybalholm/brotli v1.1.0 // indirect
 	github.com/klauspost/compress v1.17.9 // indirect
+	github.com/mattn/go-sqlite3 v1.14.22 // indirect
 	github.com/valyala/bytebufferpool v1.0.0 // indirect
 )

server.go

@@ -4,9 +4,7 @@ import (
 	"bufio"
 	"bytes"
 	"database/sql"
-	"flag"
 	"fmt"
-	"log"
 	"os"
 	"strconv"
 	"strings"
@@ -15,15 +13,7 @@ import (
 	"github.com/valyala/fasthttp"
 )
 
-const pathsep = string(os.PathSeparator)
+const behindProxy = true
-
-var (
-	bind    = flag.String("bind", "127.0.0.1:4001", "Where to listen for connections")
-	proxy   = flag.Bool("proxy", true, "Whether server is behind a reverse proxy")
-	verbose = flag.Bool("verbose", false, "Whether to log all URLs")
-	dbpath  = flag.String("dbpath", "archive.db", "Path to SQLite3 DB generated by mitmproxy addon")
-	storage = flag.String("storage", "storage", "Path to archived responses storage")
-)
 
 var removeHeaders = map[string]bool{
 	"date":    true,
@@ -35,9 +25,7 @@ var conn *sql.DB
 var stmt *sql.Stmt
 
 func main() {
-	flag.Parse()
+	db, err := sql.Open("sqlite3", "archive.db")
-
-	db, err := sql.Open("sqlite3", *dbpath)
 	if err != nil {
 		return
 	}
@@ -51,10 +39,7 @@ func main() {
 	stmt = sel_stmt
 	defer sel_stmt.Close()
 
-	err1 := fasthttp.ListenAndServe(*bind, handler)
+	fasthttp.ListenAndServe("127.0.0.1:4001", handler)
-	if err1 != nil {
-		log.Fatalln(err1)
-	}
 }
 
 func handler(ctx *fasthttp.RequestCtx) {
@@ -62,7 +47,7 @@ func handler(ctx *fasthttp.RequestCtx) {
 	uri := ctx.URI()
 
 	var scheme []byte
-	if *proxy {
+	if behindProxy {
 		scheme = ctx.Request.Header.Peek("X-Forwarded-Proto")
 	} else {
 		scheme = uri.Scheme()
@@ -73,21 +58,16 @@ func handler(ctx *fasthttp.RequestCtx) {
 		bytes.Equal(scheme, []byte("https")),
 	)
 
-	urlToSearch := fmt.Sprintf(
+	row := stmt.QueryRow(
+		string(ctx.Method()),
+		fmt.Sprintf(
 			"%s://%s:%s%s",
 			scheme,
 			host,
 			port,
 			ctx.RequestURI(),
+		),
 	)
-	row := stmt.QueryRow(
-		string(ctx.Method()),
-		urlToSearch,
-	)
-
-	if *verbose {
-		log.Println(urlToSearch)
-	}
 
 	var id int
 	var code int
@@ -105,9 +85,9 @@ func handler(ctx *fasthttp.RequestCtx) {
 	ctx.Response.SetStatusCode(code)
 
 	// -- find in FS and read headers+body
-	path := *storage + pathsep + strconv.Itoa(id)
+	path := "storage/" + strconv.Itoa(id)
 
-	fh, err := os.Open(path + pathsep + "headers")
+	fh, err := os.Open(path + "/headers")
 	if err != nil {
 		sendError(ctx, "Unable to read headers: ", err)
 		return
@@ -123,7 +103,7 @@ func handler(ctx *fasthttp.RequestCtx) {
 	}
 	fh.Close()
 
-	fb, err := os.Open(path + pathsep + "body")
+	fb, err := os.Open(path + "/body")
 	if err != nil {
 		sendError(ctx, "Unable to read body: ", err)
 		return