Function TestCreateDelete

core/metadata/namespaces_test.go:31–96

(t *testing.T)

)

func TestCreateDelete(t *testing.T) {
	ctx, db := testDB(t)

	subtests := []struct {
		name     string
		create   func(t *testing.T, ctx context.Context)
		validate func(t *testing.T, err error)
	}{
		{
			name:   "empty",
			create: func(t *testing.T, ctx context.Context) {},
			validate: func(t *testing.T, err error) {
				require.NoError(t, err)
			},
		},
		{
			name: "not-empty",
			create: func(t *testing.T, ctx context.Context) {
				store := NewContainerStore(db)
				_, err := store.Create(ctx, containers.Container{
					ID:      "c1",
					Runtime: containers.RuntimeInfo{Name: "rt"},
					Spec:    &types.Any{},
				})
				require.NoError(t, err)

				db.Update(func(tx *bbolt.Tx) error {
					ns, err := namespaces.NamespaceRequired(ctx)
					if err != nil {
						return err
					}
					bucket, err := createSnapshotterBucket(tx, ns, "testss")
					if err != nil {
						return err
					}
					return bucket.Put([]byte("key"), []byte("value"))
				})
			},
			validate: func(t *testing.T, err error) {
				require.Error(t, err)
				assert.Contains(t, err.Error(), `still has containers, snapshots on "testss" snapshotter`)
			},
		},
	}

	for _, subtest := range subtests {
		ns := subtest.name
		ctx = namespaces.WithNamespace(ctx, ns)

		t.Run(subtest.name, func(t *testing.T) {
			err := db.Update(func(tx *bbolt.Tx) error {
				store := NewNamespaceStore(tx)
				return store.Create(ctx, ns, nil)
			})
			require.NoError(t, err)

			subtest.create(t, ctx)