Function TestCheckUpgrade

check_upgrade/check_upgrade_test.go:40–110

(t *testing.T)

}

func TestCheckUpgrade(t *testing.T) {
	skipIfFIPS(t)
	conf := dgraphtest.NewClusterConfig().WithNumAlphas(1).WithNumZeros(1).WithReplicas(1).
		WithACL(time.Hour).WithVersion("57aa5c4ac")
	c, err := dgraphtest.NewLocalCluster(conf)
	require.NoError(t, err)
	defer func() { c.Cleanup(t.Failed()) }()
	require.NoError(t, c.Start())

	gc, cleanup, err := c.Client()
	require.NoError(t, err)
	defer cleanup()
	require.NoError(t, gc.LoginIntoNamespace(context.Background(),
		dgraphapi.DefaultUser, dgraphapi.DefaultPassword, x.RootNamespace))

	hc, err := c.HTTPClient()
	require.NoError(t, err)
	require.NoError(t, hc.LoginIntoNamespace(dgraphapi.DefaultUser,
		dgraphapi.DefaultPassword, x.RootNamespace))

	rdfs := `
		_:a <dgraph.xid> "user1" .
	    _:a <dgraph.type> "dgraph.type.User"  .
		_:b <dgraph.xid> "user1" .
		_:b <dgraph.type> "dgraph.type.User"  .`

	mu := &api.Mutation{SetNquads: []byte(rdfs), CommitNow: true}
	_, err = gc.Mutate(mu)
	require.NoError(t, err)

	var nss []uint64
	for i := 0; i < 5; i++ {
		ns, err := hc.AddNamespace()
		require.NoError(t, err)
		require.NoError(t, gc.LoginIntoNamespace(context.Background(), "groot", "password", ns))
		mu = &api.Mutation{SetNquads: []byte(rdfs), CommitNow: true}
		_, err = gc.Mutate(mu)
		require.NoError(t, err)
		nss = append(nss, ns)
	}

	conf1 := dgraphtest.NewClusterConfig().WithNumAlphas(1).WithNumZeros(1).WithReplicas(1).WithACL(time.Hour).WithVersion("local")
	c1, err := dgraphtest.NewLocalCluster(conf1)
	require.NoError(t, err)
	defer func() { c1.Cleanup(t.Failed()) }()
	require.NoError(t, c1.Start())
	alphaHttp, err := c.GetAlphaHttpPublicPort(0)
	require.NoError(t, err)

	args := []string{
		"checkupgrade",
		"--http_port", "localhost:" + alphaHttp,
		"--dgUser", "groot",
		"--password", "password",
		"--namespace", "1",
	}

	cmd := exec.Command(c1.HostDgraphBinaryPath(), args...)