Method TestContainer_LoadFromDB

cmd/incusd/instance_test.go:158–220

()

}

func (s *containerTestSuite) TestContainer_LoadFromDB() {
	args := db.InstanceArgs{
		Type:      instancetype.Container,
		Ephemeral: false,
		Config:    map[string]string{"security.privileged": "true"},
		Devices: deviceConfig.Devices{
			"eth0": deviceConfig.Device{
				"type":    "nic",
				"nictype": "bridged",
				"parent":  "unknownbr0",
			},
		},
		Name: "testFoo",
	}

	state := s.d.State()

	err := state.DB.Cluster.Transaction(context.TODO(), func(ctx context.Context, tx *db.ClusterTx) error {
		_, err := tx.CreateNetwork(ctx, api.ProjectDefaultName, "unknownbr0", "", db.NetworkTypeBridge, nil)

		return err
	})
	s.Req.Nil(err)

	// Create the container
	c, op, _, err := instance.CreateInternal(s.d.State(), args, nil, true, true, false)
	s.Req.Nil(err)
	op.Done(nil)
	defer func() { _ = c.Delete(true, true) }()

	poolName, err := c.StoragePool()
	s.Req.Nil(err)

	pool, err := storagePools.LoadByName(state, poolName)
	s.Req.Nil(err)

	err = state.DB.Cluster.Transaction(context.TODO(), func(ctx context.Context, tx *db.ClusterTx) error {
		_, err = tx.CreateStoragePoolVolume(ctx, c.Project().Name, c.Name(), "", db.StoragePoolVolumeContentTypeFS, pool.ID(), nil, db.StoragePoolVolumeContentTypeFS, time.Now())

		return err
	})
	s.Req.Nil(err)

	// Load the container and trigger initLXC()
	c2, err := instance.LoadByProjectAndName(state, "default", "testFoo")
	c2.IsRunning()
	s.Req.Nil(err)

	hostInterfaces, _ := net.Interfaces()

	apiC1, etagC1, err := c.RenderFull(hostInterfaces)
	s.Req.Nil(err)

	apiC2, etagC2, err := c2.RenderFull(hostInterfaces)
	s.Req.Nil(err)

	s.Equal(etagC1, etagC2)
	s.Exactly(