mirror of
https://github.com/zrepl/zrepl.git
synced 2024-11-22 08:23:50 +01:00
133 lines
2.4 KiB
Go
133 lines
2.4 KiB
Go
package config
|
|
|
|
import (
|
|
"fmt"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
)
|
|
|
|
func TestRecvOptions(t *testing.T) {
|
|
tmpl := `
|
|
jobs:
|
|
- name: foo
|
|
type: pull
|
|
connect:
|
|
type: local
|
|
listener_name: foo
|
|
client_identity: bar
|
|
root_fs: "zreplplatformtest"
|
|
%s
|
|
interval: manual
|
|
pruning:
|
|
keep_sender:
|
|
- type: last_n
|
|
count: 10
|
|
keep_receiver:
|
|
- type: last_n
|
|
count: 10
|
|
|
|
`
|
|
|
|
recv_properties_empty := `
|
|
recv:
|
|
properties:
|
|
`
|
|
|
|
recv_inherit_empty := `
|
|
recv:
|
|
properties:
|
|
inherit:
|
|
`
|
|
|
|
recv_inherit := `
|
|
recv:
|
|
properties:
|
|
inherit:
|
|
- testprop
|
|
`
|
|
|
|
recv_override_empty := `
|
|
recv:
|
|
properties:
|
|
override:
|
|
`
|
|
|
|
recv_override := `
|
|
recv:
|
|
properties:
|
|
override:
|
|
testprop2: "test123"
|
|
`
|
|
|
|
recv_override_and_inherit := `
|
|
recv:
|
|
properties:
|
|
inherit:
|
|
- testprop
|
|
override:
|
|
testprop2: "test123"
|
|
`
|
|
|
|
recv_empty := `
|
|
recv: {}
|
|
`
|
|
|
|
recv_not_specified := `
|
|
`
|
|
|
|
fill := func(s string) string { return fmt.Sprintf(tmpl, s) }
|
|
var c *Config
|
|
|
|
t.Run("recv_inherit_empty", func(t *testing.T) {
|
|
c, err := testConfig(t, fill(recv_inherit_empty))
|
|
assert.NoError(t, err)
|
|
assert.NotNil(t, c)
|
|
})
|
|
|
|
t.Run("recv_inherit", func(t *testing.T) {
|
|
c = testValidConfig(t, fill(recv_inherit))
|
|
inherit := c.Jobs[0].Ret.(*PullJob).Recv.Properties.Inherit
|
|
assert.NotEmpty(t, inherit)
|
|
})
|
|
|
|
t.Run("recv_override_empty", func(t *testing.T) {
|
|
c, err := testConfig(t, fill(recv_override_empty))
|
|
assert.NoError(t, err)
|
|
assert.NotNil(t, c)
|
|
})
|
|
|
|
t.Run("recv_override", func(t *testing.T) {
|
|
c = testValidConfig(t, fill(recv_override))
|
|
override := c.Jobs[0].Ret.(*PullJob).Recv.Properties.Override
|
|
assert.NotEmpty(t, override)
|
|
})
|
|
|
|
t.Run("recv_override_and_inherit", func(t *testing.T) {
|
|
c = testValidConfig(t, fill(recv_override_and_inherit))
|
|
inherit := c.Jobs[0].Ret.(*PullJob).Recv.Properties.Inherit
|
|
override := c.Jobs[0].Ret.(*PullJob).Recv.Properties.Override
|
|
assert.NotEmpty(t, inherit)
|
|
assert.NotEmpty(t, override)
|
|
})
|
|
|
|
t.Run("recv_properties_empty", func(t *testing.T) {
|
|
c, err := testConfig(t, fill(recv_properties_empty))
|
|
assert.NoError(t, err)
|
|
assert.NotNil(t, c)
|
|
})
|
|
|
|
t.Run("recv_empty", func(t *testing.T) {
|
|
c, err := testConfig(t, fill(recv_empty))
|
|
assert.NoError(t, err)
|
|
assert.NotNil(t, c)
|
|
})
|
|
|
|
t.Run("send_not_specified", func(t *testing.T) {
|
|
c, err := testConfig(t, fill(recv_not_specified))
|
|
assert.NoError(t, err)
|
|
assert.NotNil(t, c)
|
|
})
|
|
|
|
}
|