diff options
author | Runxi Yu <me@runxiyu.org> | 2025-02-16 00:32:46 +0800 |
---|---|---|
committer | Runxi Yu <me@runxiyu.org> | 2025-02-16 00:33:04 +0800 |
commit | 2cd785fc9e7d25e7504fa552cd94607d250665b0 (patch) | |
tree | 8c72000e687ad1841358353aae87693e05e266cf /ssh_server.go | |
parent | README.md: Add Libera channel (diff) | |
download | forge-2cd785fc9e7d25e7504fa552cd94607d250665b0.tar.gz forge-2cd785fc9e7d25e7504fa552cd94607d250665b0.tar.zst forge-2cd785fc9e7d25e7504fa552cd94607d250665b0.zip |
ssh_*: Use pure go-git SSH handling (receive and upload)
Diffstat (limited to 'ssh_server.go')
-rw-r--r-- | ssh_server.go | 39 |
1 files changed, 16 insertions, 23 deletions
diff --git a/ssh_server.go b/ssh_server.go index 0dde4b4..b3a6a52 100644 --- a/ssh_server.go +++ b/ssh_server.go @@ -4,7 +4,6 @@ import ( "fmt" "net" "os" - "os/exec" "strings" glider_ssh "github.com/gliderlabs/ssh" @@ -51,33 +50,27 @@ func serve_ssh(listener net.Listener) error { return } - if cmd[0] != "git-upload-pack" { - fmt.Fprintln(session.Stderr(), "Unsupported command\r") + switch cmd[0] { + case "git-upload-pack": + if len(cmd) > 2 { + fmt.Fprintln(session.Stderr(), "Too many arguments\r") + return + } + err = ssh_handle_upload_pack(session, cmd[1]) + case "git-receive-pack": + if len(cmd) > 2 { + fmt.Fprintln(session.Stderr(), "Too many arguments\r") + return + } + err = ssh_handle_receive_pack(session, cmd[1]) + default: + fmt.Fprintln(session.Stderr(), "Unsupported command: "+cmd[0]+"\r") return } - - fs_path, err := get_repo_path_from_ssh_path(session.Context(), cmd[1]) if err != nil { - fmt.Fprintln(session.Stderr(), "Error while getting repo path:", err, "\r") + fmt.Fprintln(session.Stderr(), err.Error()) return } - - proc := exec.CommandContext(session.Context(), cmd[0], fs_path) - proc.Stdin = session - proc.Stdout = session - proc.Stderr = session.Stderr() - - err = proc.Start() - if err != nil { - fmt.Fprintln(session.Stderr(), "Error while starting process:", err) - return - } - err = proc.Wait() - if exit_error, ok := err.(*exec.ExitError); ok { - fmt.Fprintln(session.Stderr(), "Process exited with error", exit_error.ExitCode()) - } else if err != nil { - fmt.Fprintln(session.Stderr(), "Error while waiting for process:", err) - } }, PublicKeyHandler: func(ctx glider_ssh.Context, key glider_ssh.PublicKey) bool { return true }, KeyboardInteractiveHandler: func(ctx glider_ssh.Context, challenge go_ssh.KeyboardInteractiveChallenge) bool { return true }, |