mitm-archive/server
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat: add config via args, log ListenAndServe error if any

Browse source
This commit is contained in:
DarkCat09 2024-07-02 20:33:36 +04:00
parent 94897e7711
commit 78305a063a
Signed by: DarkCat09
GPG key ID: 0A26CD5B3345D6E3
1 changed files with 25 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
server.go
View file

@ -4,7 +4,9 @@ import (
"bufio" "bufio"
"bytes" "bytes"
"database/sql" "database/sql"
"flag"
"fmt" "fmt"
"log"
"os" "os"
"strconv" "strconv"
"strings" "strings"
@ -13,7 +15,15 @@ import (
"github.com/valyala/fasthttp" "github.com/valyala/fasthttp"
) )
const behindProxy = true const pathsep = string(os.PathSeparator)
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{ var removeHeaders = map[string]bool{
"date": true, "date": true,
@ -25,7 +35,9 @@ var conn *sql.DB
var stmt *sql.Stmt var stmt *sql.Stmt
func main() { func main() {
db, err := sql.Open("sqlite3", "archive.db") flag.Parse()
db, err := sql.Open("sqlite3", *dbpath)
if err != nil { if err != nil {
return return
} }
@ -39,7 +51,10 @@ func main() {
stmt = sel_stmt stmt = sel_stmt
defer sel_stmt.Close() defer sel_stmt.Close()
fasthttp.ListenAndServe("127.0.0.1:4001", handler) err1 := fasthttp.ListenAndServe(*bind, handler)
if err1 != nil {
log.Fatalln(err1)
}
} }
func handler(ctx *fasthttp.RequestCtx) { func handler(ctx *fasthttp.RequestCtx) {
@ -47,7 +62,7 @@ func handler(ctx *fasthttp.RequestCtx) {
uri := ctx.URI() uri := ctx.URI()
var scheme []byte var scheme []byte
if behindProxy { if *proxy {
scheme = ctx.Request.Header.Peek("X-Forwarded-Proto") scheme = ctx.Request.Header.Peek("X-Forwarded-Proto")
} else { } else {
scheme = uri.Scheme() scheme = uri.Scheme()
@ -70,7 +85,9 @@ func handler(ctx *fasthttp.RequestCtx) {
urlToSearch, urlToSearch,
) )
// log.Println(urlToSearch) if *verbose {
log.Println(urlToSearch)
}
var id int var id int
var code int var code int
@ -88,9 +105,9 @@ func handler(ctx *fasthttp.RequestCtx) {
ctx.Response.SetStatusCode(code) ctx.Response.SetStatusCode(code)
// -- find in FS and read headers+body // -- find in FS and read headers+body
path := "storage/" + strconv.Itoa(id) path := *storage + pathsep + strconv.Itoa(id)
fh, err := os.Open(path + "/headers") fh, err := os.Open(path + pathsep + "headers")
if err != nil { if err != nil {
sendError(ctx, "Unable to read headers: ", err) sendError(ctx, "Unable to read headers: ", err)
return return
@ -106,7 +123,7 @@ func handler(ctx *fasthttp.RequestCtx) {
} }
fh.Close() fh.Close()
fb, err := os.Open(path + "/body") fb, err := os.Open(path + pathsep + "body")
if err != nil { if err != nil {
sendError(ctx, "Unable to read body: ", err) sendError(ctx, "Unable to read body: ", err)
return return