stream-chat-go/import_test.go at master · GetStream/stream-chat-go · GitHub

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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
package stream_chat

import (
	"context"
	"encoding/json"
	"net/http"
	"strings"
	"testing"

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

func TestImportsEndToEnd(t *testing.T) {
	t.Skip("The backend isn't deployed yet.")
	filename := randomString(10) + ".json"
	content := "[]"
	c := initClient(t)
	ctx := context.Background()

	createURLResp, err := c.CreateImportURL(ctx, filename)
	require.NoError(t, err)
	require.NotEmpty(t, createURLResp.Path)
	require.NotEmpty(t, createURLResp.UploadURL)

	_, err = c.CreateImport(ctx, createURLResp.Path, "upsert")
	require.Error(t, err)

	data := strings.NewReader(content)
	r, err := http.NewRequestWithContext(ctx, http.MethodPut, createURLResp.UploadURL, data)
	require.NoError(t, err)

	r.Header.Set("Content-Type", "application/json")
	r.ContentLength = data.Size()
	uploadResp, err := c.HTTP.Do(r)
	require.NoError(t, err)
	uploadResp.Body.Close()

	createResp, err := c.CreateImport(ctx, createURLResp.Path, "upsert")
	require.NoError(t, err)
	require.NotNil(t, createResp.ImportTask.ID)
	require.True(t, strings.HasSuffix(createResp.ImportTask.Path, filename))

	getResp, err := c.GetImport(ctx, createResp.ImportTask.ID)
	require.NoError(t, err)
	require.Equal(t, createResp.ImportTask.ID, getResp.ImportTask.ID)

	listResp, err := c.ListImports(ctx, &ListImportsOptions{Limit: 1, Offset: 0})
	require.NoError(t, err)
	require.NotEmpty(t, listResp.ImportTasks)
}

func TestCreateImportRequest_MergeCustomJSON(t *testing.T) {
	t.Run("without merge_custom option", func(t *testing.T) {
		req := createImportRequest{
			Path: "some/path.json",
			Mode: string(UpsertMode),
		}

		data, err := json.Marshal(req)
		require.NoError(t, err)

		var m map[string]interface{}
		require.NoError(t, json.Unmarshal(data, &m))

		require.Equal(t, "some/path.json", m["path"])
		require.Equal(t, "upsert", m["mode"])
		require.NotContains(t, m, "merge_custom")
	})

	t.Run("with merge_custom true", func(t *testing.T) {
		req := createImportRequest{
			Path: "some/path.json",
			Mode: string(UpsertMode),
		}
		WithMergeCustom(true)(&req)

		data, err := json.Marshal(req)
		require.NoError(t, err)

		var m map[string]interface{}
		require.NoError(t, json.Unmarshal(data, &m))

		require.Equal(t, "some/path.json", m["path"])
		require.Equal(t, "upsert", m["mode"])
		require.Equal(t, true, m["merge_custom"])
	})

	t.Run("with merge_custom false", func(t *testing.T) {
		req := createImportRequest{
			Path: "some/path.json",
			Mode: string(InsertMode),
		}
		WithMergeCustom(false)(&req)

		data, err := json.Marshal(req)
		require.NoError(t, err)

		var m map[string]interface{}
		require.NoError(t, json.Unmarshal(data, &m))

		require.Equal(t, "some/path.json", m["path"])
		require.Equal(t, "insert", m["mode"])
		require.Equal(t, false, m["merge_custom"])
	})
}