mirror of
https://github.com/containers/buildah.git
synced 2026-02-05 18:44:58 +01:00
1ede7ddce7
Brought to you by
gofmt -r 'interface{} -> any' -w .
Signed-off-by: Kir Kolyshkin <kolyshkin@gmail.com>
56 lines
1.0 KiB
Go
56 lines
1.0 KiB
Go
package sshagent
|
|
|
|
import (
|
|
"crypto/rand"
|
|
"crypto/rsa"
|
|
"net"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
"golang.org/x/crypto/ssh/agent"
|
|
)
|
|
|
|
func testNewKeySource() (*Source, error) {
|
|
k, err := rsa.GenerateKey(rand.Reader, 2048)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return &Source{
|
|
Keys: []any{k},
|
|
}, nil
|
|
}
|
|
|
|
func testClient(path string) ([]*agent.Key, error) {
|
|
conn, err := net.Dial("unix", path)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
ac := agent.NewClient(conn)
|
|
keys, err := ac.List()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return keys, nil
|
|
}
|
|
|
|
func TestAgentServer(t *testing.T) {
|
|
t.Parallel()
|
|
src, err := testNewKeySource()
|
|
require.NoError(t, err)
|
|
ag, err := NewAgentServer(src)
|
|
require.NoError(t, err)
|
|
sock, err := ag.Serve("")
|
|
require.NoError(t, err)
|
|
// Get key from agent
|
|
keys, err := testClient(sock)
|
|
require.NoError(t, err)
|
|
require.Equal(t, len(keys), 1)
|
|
require.Equal(t, keys[0].Type(), "ssh-rsa")
|
|
// Check for proper shutdown
|
|
err = ag.Shutdown()
|
|
require.NoError(t, err)
|
|
|
|
_, err = testClient(sock)
|
|
require.Error(t, err)
|
|
}
|