core/go-ansible
8
0
Fork 0
Code Issues 4 Pull requests Projects Releases Packages Wiki Activity Actions

feat(ansible): support remote_src in copy module

Browse source 
Co-Authored-By: Virgil <virgil@lethean.io>
This commit is contained in:
Virgil 2026-04-01 23:11:42 +00:00
parent e7a0298db8
commit 187f157435
3 changed files with 44 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
mock_ssh_test.go
View file

@ -626,14 +626,22 @@ func moduleCopyWithClient(e *Executor, client sshFileRunner, args map[string]any
return nil, mockError("moduleCopyWithClient", "copy: dest required")
}
force := getBoolArg(args, "force", true)
remoteSrc := getBoolArg(args, "remote_src", false)
var content []byte
var err error
if src := getStringArg(args, "src", ""); src != "" {
content, err = readTestFile(src)
if err != nil {
return nil, mockWrap("moduleCopyWithClient", "read src", err)
if remoteSrc {
content, err = client.Download(context.Background(), src)
if err != nil {
return nil, mockWrap("moduleCopyWithClient", "download src", err)
}
} else {
content, err = readTestFile(src)
if err != nil {
return nil, mockWrap("moduleCopyWithClient", "read src", err)
}
}
} else if c := getStringArg(args, "content", ""); c != "" {
content = []byte(c)

18
modules.go
View file

@ -434,15 +434,25 @@ func (e *Executor) moduleCopy(ctx context.Context, client sshExecutorClient, arg
return nil, coreerr.E("Executor.moduleCopy", "dest required", nil)
}
force := getBoolArg(args, "force", true)
remoteSrc := getBoolArg(args, "remote_src", false)
var content string
var err error
if src := getStringArg(args, "src", ""); src != "" {
src = e.resolveLocalPath(src)
content, err = coreio.Local.Read(src)
if err != nil {
return nil, coreerr.E("Executor.moduleCopy", "read src", err)
if remoteSrc {
var data []byte
data, err = client.Download(ctx, src)
if err != nil {
return nil, coreerr.E("Executor.moduleCopy", "download src", err)
}
content = string(data)
} else {
src = e.resolveLocalPath(src)
content, err = coreio.Local.Read(src)
if err != nil {
return nil, coreerr.E("Executor.moduleCopy", "read src", err)
}
}
} else if c := getStringArg(args, "content", ""); c != "" {
content = c

19
modules_file_test.go
View file

@ -57,6 +57,25 @@ func TestModulesFile_ModuleCopy_Good_SrcFile(t *testing.T) {
assert.Equal(t, []byte("worker_processes auto;"), up.Content)
}
func TestModulesFile_ModuleCopy_Good_RemoteSrc(t *testing.T) {
e, mock := newTestExecutorWithMock("host1")
mock.addFile("/tmp/remote-source.txt", []byte("remote payload"))
result, err := e.moduleCopy(context.Background(), mock, map[string]any{
"src": "/tmp/remote-source.txt",
"dest": "/etc/app/remote.txt",
"remote_src": true,
}, "host1", &Task{})
require.NoError(t, err)
assert.True(t, result.Changed)
up := mock.lastUpload()
require.NotNil(t, up)
assert.Equal(t, "/etc/app/remote.txt", up.Remote)
assert.Equal(t, []byte("remote payload"), up.Content)
}
func TestModulesFile_ModuleCopy_Good_OwnerGroup(t *testing.T) {
e, mock := newTestExecutorWithMock("host1")