First stab at implementing ListActions

This commit is contained in:
Zack Mullaly 2018-10-26 14:55:05 -04:00
Родитель 19b5c42ba4
Коммит 05a3f05d29
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: 1486642516ED3535
1 изменённых файлов: 16 добавлений и 1 удалений

Просмотреть файл

@ -7,6 +7,8 @@
package actions
import (
"fmt"
"github.com/mozilla/mig"
migdb "github.com/mozilla/mig/database"
)
@ -24,5 +26,18 @@ func NewListActionsPostgres(db *migdb.DB, queue string) ListActionsPostgres {
}
func (list ListActionsPostgres) ListActions(limit uint) ([]mig.Action, error) {
return []mig.Action{}, nil
now := time.Now().Add(-15 * time.Minute)
agents, err := list.db.ActiveAgentsByQueue(limit.queueLoc, now)
if err != nil {
return []mig.Action{}, err
}
if len(agents) == 0 {
err := fmt.Errorf("No agents listening to queue %s", list.queueLoc)
return []mig.Action{}, err
}
actions, err := list.db.SetupRunnableActionsForAgent(agents[0])
if err != nil {
return []mig.Action{}, err
}
return actions, nil
}