Browse Source

Add access log for dokodemo inbound

lucifer9 5 years ago
parent
commit
9da4339d8a
1 changed files with 9 additions and 0 deletions
  1. 9 0
      proxy/dokodemo/dokodemo.go

+ 9 - 0
proxy/dokodemo/dokodemo.go

@@ -12,6 +12,7 @@ import (
 	"v2ray.com/core"
 	"v2ray.com/core"
 	"v2ray.com/core/common"
 	"v2ray.com/core/common"
 	"v2ray.com/core/common/buf"
 	"v2ray.com/core/common/buf"
+	"v2ray.com/core/common/log"
 	"v2ray.com/core/common/net"
 	"v2ray.com/core/common/net"
 	"v2ray.com/core/common/protocol"
 	"v2ray.com/core/common/protocol"
 	"v2ray.com/core/common/session"
 	"v2ray.com/core/common/session"
@@ -106,6 +107,14 @@ func (d *DokodemoDoor) Process(ctx context.Context, network net.Network, conn in
 		}
 		}
 	}
 	}
 
 
+	ctx = log.ContextWithAccessMessage(ctx, &log.AccessMessage{
+		From:   conn.RemoteAddr(),
+		To:     dest,
+		Status: log.AccessAccepted,
+		Reason: "",
+	})
+	newError("received request for ", conn.RemoteAddr()).WriteToLog(session.ExportIDToError(ctx))
+
 	plcy := d.policy()
 	plcy := d.policy()
 	ctx, cancel := context.WithCancel(ctx)
 	ctx, cancel := context.WithCancel(ctx)
 	timer := signal.CancelAfterInactivity(ctx, cancel, plcy.Timeouts.ConnectionIdle)
 	timer := signal.CancelAfterInactivity(ctx, cancel, plcy.Timeouts.ConnectionIdle)