summaryrefslogtreecommitdiff
path: root/data/datasource_env_test.go
blob: c7723b3b26b2f6150d4af046378e89a90b6d0a50 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
package data

import (
	"context"
	"net/url"
	"os"
	"testing"

	"github.com/stretchr/testify/assert"
)

func mustParseURL(in string) *url.URL {
	u, _ := url.Parse(in)
	return u
}

func TestReadEnv(t *testing.T) {
	ctx := context.Background()

	content := []byte(`hello world`)
	os.Setenv("HELLO_WORLD", "hello world")
	defer os.Unsetenv("HELLO_WORLD")
	os.Setenv("HELLO_UNIVERSE", "hello universe")
	defer os.Unsetenv("HELLO_UNIVERSE")

	source := &Source{Alias: "foo", URL: mustParseURL("env:HELLO_WORLD")}

	actual, err := readEnv(ctx, source)
	assert.NoError(t, err)
	assert.Equal(t, content, actual)

	source = &Source{Alias: "foo", URL: mustParseURL("env:/HELLO_WORLD")}

	actual, err = readEnv(ctx, source)
	assert.NoError(t, err)
	assert.Equal(t, content, actual)

	source = &Source{Alias: "foo", URL: mustParseURL("env:///HELLO_WORLD")}

	actual, err = readEnv(ctx, source)
	assert.NoError(t, err)
	assert.Equal(t, content, actual)

	source = &Source{Alias: "foo", URL: mustParseURL("env:HELLO_WORLD?foo=bar")}

	actual, err = readEnv(ctx, source)
	assert.NoError(t, err)
	assert.Equal(t, content, actual)

	source = &Source{Alias: "foo", URL: mustParseURL("env:///HELLO_WORLD?foo=bar")}

	actual, err = readEnv(ctx, source)
	assert.NoError(t, err)
	assert.Equal(t, content, actual)
}