aboutsummaryrefslogtreecommitdiff
path: root/ssh.go
diff options
context:
space:
mode:
authorRunxi Yu <me@runxiyu.org>2025-02-13 00:31:48 +0800
committerRunxi Yu <me@runxiyu.org>2025-02-13 00:32:01 +0800
commitd87f80d3e14990e5d9fc83990ff04e29affa3a94 (patch)
tree5df543f16b96388c1dc7c6456c24d8b0d66b9d5d /ssh.go
parentREADME.md: Add a bit of detail (diff)
downloadforge-d87f80d3e14990e5d9fc83990ff04e29affa3a94.tar.gz
forge-d87f80d3e14990e5d9fc83990ff04e29affa3a94.tar.zst
forge-d87f80d3e14990e5d9fc83990ff04e29affa3a94.zip
*.go: Mass rename files for clarity
Diffstat (limited to 'ssh.go')
-rw-r--r--ssh.go96
1 files changed, 0 insertions, 96 deletions
diff --git a/ssh.go b/ssh.go
deleted file mode 100644
index a08e20c..0000000
--- a/ssh.go
+++ /dev/null
@@ -1,96 +0,0 @@
-package main
-
-import (
- "fmt"
- "net"
- "os"
- "os/exec"
-
- glider_ssh "github.com/gliderlabs/ssh"
- "go.lindenii.runxiyu.org/lindenii-common/clog"
- go_ssh "golang.org/x/crypto/ssh"
-)
-
-var server_public_key_string string
-var server_public_key_fingerprint string
-var server_public_key go_ssh.PublicKey
-
-func serve_ssh() error {
- host_key_bytes, err := os.ReadFile(config.SSH.Key)
- if err != nil {
- return err
- }
-
- host_key, err := go_ssh.ParsePrivateKey(host_key_bytes)
- if err != nil {
- return err
- }
-
- server_public_key = host_key.PublicKey()
- server_public_key_string = string(go_ssh.MarshalAuthorizedKey(server_public_key))
- server_public_key_fingerprint = string(go_ssh.FingerprintSHA256(server_public_key))
-
- server := &glider_ssh.Server{
- Handler: func(session glider_ssh.Session) {
- client_public_key := session.PublicKey()
- var client_public_key_string string
- if client_public_key != nil {
- client_public_key_string = string(go_ssh.MarshalAuthorizedKey(client_public_key))
- }
- _ = client_public_key_string
-
- cmd := session.Command()
-
- if len(cmd) < 2 {
- fmt.Fprintln(session.Stderr(), "Insufficient arguments")
- return
- }
-
- if cmd[0] != "git-upload-pack" {
- fmt.Fprintln(session.Stderr(), "Unsupported command")
- 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)
- 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 },
- }
-
- server.AddHostKey(host_key)
-
- listener, err := net.Listen(config.SSH.Net, config.SSH.Addr)
- if err != nil {
- return err
- }
-
- go func() {
- err = server.Serve(listener)
- if err != nil {
- clog.Fatal(1, "Serving SSH: "+err.Error())
- }
- }()
-
- return nil
-}