package supervisor

import (
	"time"

	"github.com/Sirupsen/logrus"
	"github.com/containerd/containerd/runtime"
)

// DeleteTask holds needed parameters to remove a container
type DeleteTask struct {
	baseTask
	ID      string
	Status  uint32
	PID     string
	NoEvent bool
	Process runtime.Process
}

func (s *Supervisor) delete(t *DeleteTask) error {
	if i, ok := s.containers[t.ID]; ok {
		start := time.Now()
		if err := s.deleteContainer(i.container); err != nil {
			logrus.WithField("error", err).Error("containerd: deleting container")
		}
		if t.Process != nil {
			t.Process.Wait()
		}
		if !t.NoEvent {
			execMap := s.getExecSyncMap(t.ID)
			go func() {
				// Wait for all exec processe events to be sent (we seem
				// to sometimes receive them after the init event)
				for _, ch := range execMap {
					<-ch
				}
				s.deleteExecSyncMap(t.ID)
				s.notifySubscribers(Event{
					Type:      StateExit,
					Timestamp: time.Now(),
					ID:        t.ID,
					Status:    t.Status,
					PID:       t.PID,
				})
			}()
		}
		ContainersCounter.Dec(1)
		ContainerDeleteTimer.UpdateSince(start)
	}
	return nil
}

func (s *Supervisor) deleteContainer(container runtime.Container) error {
	delete(s.containers, container.ID())
	return container.Delete()
}