Method TestQuery

service/client_test.go:82–92

(query string)

}

func (c *testClient) TestQuery(query string) string {
	r, err := c.Connection.Query(c.Context(), srcfiles.Plain(query))
	require.NoError(c, err)
	defer r.Body.Close()
	zr := bsupio.NewReader(super.NewContext(), r.Body)
	defer zr.Close()
	var buf bytes.Buffer
	zw := supio.NewWriter(sio.NopCloser(&buf), supio.WriterOpts{})
	require.NoError(c, sio.Copy(zw, zr))
	return buf.String()
}

func (c *testClient) TestLoad(poolID ksuid.KSUID, branchName string, r io.Reader) ksuid.KSUID {
	commit, err := c.Connection.Load(c.Context(), poolID, branchName, "", r, api.CommitMessage{})