Function TestEmitRunningEvents

pkg/compose/observed_state_test.go:214–303

(t *testing.T)

}

func TestEmitRunningEvents(t *testing.T) {
	runningWeb := ObservedContainer{ID: "c-web", Name: "p-web-1", State: container.StateRunning}
	runningDB := ObservedContainer{ID: "c-db", Name: "p-db-1", State: container.StateRunning}
	runningDisabled := ObservedContainer{ID: "c-misc", Name: "p-misc-1", State: container.StateRunning}
	exitedWeb := ObservedContainer{ID: "c-web-old", Name: "p-web-2", State: container.StateExited}

	t.Run("emits Running for active services not in plan", func(t *testing.T) {
		project := &types.Project{
			Services: types.Services{
				"web": {Name: "web"},
				"db":  {Name: "db"},
			},
		}
		observed := &ObservedState{
			Containers: map[string][]ObservedContainer{
				"web": {runningWeb},
				"db":  {runningDB},
			},
		}
		events := &capturingEvents{}

		emitRunningEvents(project, observed, &Plan{}, events)

		assert.Equal(t, len(events.resources), 2)
		names := map[string]bool{}
		for _, r := range events.resources {
			names[r.ID] = true
			assert.Equal(t, r.Text, api.StatusRunning)
		}
		assert.Assert(t, names["Container p-web-1"])
		assert.Assert(t, names["Container p-db-1"])
	})

	t.Run("skips containers belonging to disabled services", func(t *testing.T) {
		// Reproduces issue 13882: `compose run --no-deps misc` leaves the
		// project with project.Services empty (misc moved to DisabledServices).
		// Running containers for disabled services must not be reported.
		project := &types.Project{
			Services: types.Services{},
			DisabledServices: types.Services{
				"misc": {Name: "misc"},
				"db":   {Name: "db"},
			},
		}
		observed := &ObservedState{
			Containers: map[string][]ObservedContainer{
				"misc": {runningDisabled},
				"db":   {runningDB},
			},
		}
		events := &capturingEvents{}

		emitRunningEvents(project, observed, &Plan{}, events)

		assert.Equal(t, len(events.resources), 0)
	})

	t.Run("skips containers that have a plan operation", func(t *testing.T) {