diff --git a/pkg/bastionsession/bastionsession.go b/pkg/bastionsession/bastionsession.go index 496288a..1a08e8a 100644 --- a/pkg/bastionsession/bastionsession.go +++ b/pkg/bastionsession/bastionsession.go @@ -46,14 +46,14 @@ func ChannelHandler(srv *ssh.Server, conn *gossh.ServerConn, newChan gossh.NewCh return pipe(lreqs, rreqs, lch, rch, config.Logs, user) } -func pipe(lreqs, rreqs <-chan *gossh.Request, lch, rch gossh.Channel, logs_location string, user string) error { +func pipe(lreqs, rreqs <-chan *gossh.Request, lch, rch gossh.Channel, logsLocation string, user string) error { defer func() { _ = lch.Close() _ = rch.Close() }() errch := make(chan error, 1) - file_name := strings.Join([]string{logs_location, "/", user, "-", time.Now().Format(time.RFC3339)}, "") // get user + file_name := strings.Join([]string{logsLocation, "/", user, "-", time.Now().Format(time.RFC3339)}, "") // get user f, err := os.OpenFile(file_name, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, 0640) if err != nil { go func() { diff --git a/ssh.go b/ssh.go index 52822d8..2d86740 100644 --- a/ssh.go +++ b/ssh.go @@ -96,7 +96,7 @@ func channelHandler(srv *ssh.Server, conn *gossh.ServerConn, newChan gossh.NewCh } actx := ctx.Value(authContextKey).(*authContext) - logs_location := actx.globalContext.String("logs-location") + logsLocation := actx.globalContext.String("logs-location") switch actx.userType() { case UserTypeBastion: @@ -130,7 +130,7 @@ func channelHandler(srv *ssh.Server, conn *gossh.ServerConn, newChan gossh.NewCh err = bastionsession.ChannelHandler(srv, conn, newChan, ctx, bastionsession.Config{ Addr: host.Addr, - Logs: logs_location, + Logs: logsLocation, ClientConfig: clientConfig, })