mirror of
https://github.com/zrepl/zrepl.git
synced 2025-02-18 03:11:55 +01:00
daemon/job: test that sample configs are buildable
This commit is contained in:
parent
4e702eedc9
commit
95fc299733
@ -2,12 +2,16 @@ package job
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"path"
|
||||||
|
"path/filepath"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
|
"github.com/kr/pretty"
|
||||||
"github.com/stretchr/testify/assert"
|
"github.com/stretchr/testify/assert"
|
||||||
"github.com/stretchr/testify/require"
|
"github.com/stretchr/testify/require"
|
||||||
|
|
||||||
"github.com/zrepl/zrepl/config"
|
"github.com/zrepl/zrepl/config"
|
||||||
|
"github.com/zrepl/zrepl/transport/tls"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestValidateReceivingSidesDoNotOverlap(t *testing.T) {
|
func TestValidateReceivingSidesDoNotOverlap(t *testing.T) {
|
||||||
@ -108,3 +112,35 @@ jobs:
|
|||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestSampleConfigsAreBuiltWithoutErrors(t *testing.T) {
|
||||||
|
paths, err := filepath.Glob("../../config/samples/*")
|
||||||
|
if err != nil {
|
||||||
|
t.Errorf("glob failed: %+v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, p := range paths {
|
||||||
|
|
||||||
|
if path.Ext(p) != ".yml" {
|
||||||
|
t.Logf("skipping file %s", p)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
t.Run(p, func(t *testing.T) {
|
||||||
|
c, err := config.ParseConfig(p)
|
||||||
|
if err != nil {
|
||||||
|
t.Errorf("error parsing %s:\n%+v", p, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
t.Logf("file: %s", p)
|
||||||
|
t.Log(pretty.Sprint(c))
|
||||||
|
|
||||||
|
tls.FakeCertificateLoading(t)
|
||||||
|
jobs, err := JobsFromConfig(c)
|
||||||
|
t.Logf("jobs: %#v", jobs)
|
||||||
|
assert.NoError(t, err)
|
||||||
|
})
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
@ -23,6 +23,10 @@ func TLSConnecterFromConfig(in *config.TLSConnect) (*TLSConnecter, error) {
|
|||||||
Timeout: in.DialTimeout,
|
Timeout: in.DialTimeout,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if fakeCertificateLoading {
|
||||||
|
return &TLSConnecter{in.Address, dialer, nil}, nil
|
||||||
|
}
|
||||||
|
|
||||||
ca, err := tlsconf.ParseCAFile(in.Ca)
|
ca, err := tlsconf.ParseCAFile(in.Ca)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, errors.Wrap(err, "cannot parse ca file")
|
return nil, errors.Wrap(err, "cannot parse ca file")
|
||||||
|
@ -25,6 +25,10 @@ func TLSListenerFactoryFromConfig(c *config.Global, in *config.TLSServe) (transp
|
|||||||
return nil, errors.New("fields 'ca', 'cert' and 'key'must be specified")
|
return nil, errors.New("fields 'ca', 'cert' and 'key'must be specified")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if fakeCertificateLoading {
|
||||||
|
return func() (transport.AuthenticatedListener, error) { return nil, nil }, nil
|
||||||
|
}
|
||||||
|
|
||||||
clientCA, err := tlsconf.ParseCAFile(in.Ca)
|
clientCA, err := tlsconf.ParseCAFile(in.Ca)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, errors.Wrap(err, "cannot parse ca file")
|
return nil, errors.Wrap(err, "cannot parse ca file")
|
||||||
|
10
transport/tls/tls_test_helper.go
Normal file
10
transport/tls/tls_test_helper.go
Normal file
@ -0,0 +1,10 @@
|
|||||||
|
package tls
|
||||||
|
|
||||||
|
import "testing"
|
||||||
|
|
||||||
|
var fakeCertificateLoading bool
|
||||||
|
|
||||||
|
func FakeCertificateLoading(t *testing.T) {
|
||||||
|
t.Logf("faking certificate loading")
|
||||||
|
fakeCertificateLoading = true
|
||||||
|
}
|
Loading…
Reference in New Issue
Block a user