From 7a29642bb5ef628e9586938293d77df64990a120 Mon Sep 17 00:00:00 2001
From: Erik Winter <ik@erikwinter.nl>
Date: Sat, 20 Jan 2024 13:27:19 +0100
Subject: [PATCH] fix job queue

---
 cmd/api-service/job/queue.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/cmd/api-service/job/queue.go b/cmd/api-service/job/queue.go
index 741f7f5..6643a5b 100644
--- a/cmd/api-service/job/queue.go
+++ b/cmd/api-service/job/queue.go
@@ -27,7 +27,7 @@ func (jq *JobQueue) Add(movieID, action string) error {
 		return errors.New("invalid action")
 	}
 
-	_, err := jq.db.Exec(`INSERT INTO job_queue (movie_id, action, status) 
+	_, err := jq.db.Exec(`INSERT INTO job_queue (action_id, action, status) 
 	VALUES (?, ?, 'todo')`, movieID, action)
 
 	return err
@@ -42,7 +42,7 @@ func (jq *JobQueue) Next(t Type) (Job, error) {
 	}
 	actionsStr := fmt.Sprintf("('%s')", strings.Join(actions, "', '"))
 	query := fmt.Sprintf(`
-SELECT id, movie_id, action
+SELECT id, action_id, action
 FROM job_queue
 WHERE status='todo'
 	AND action IN %s
@@ -93,7 +93,7 @@ WHERE id=?`, id); err != nil {
 
 func (jq *JobQueue) List() ([]Job, error) {
 	rows, err := jq.db.Query(`
-SELECT id, movie_id, action, status, created_at, updated_at
+SELECT id, action_id, action, status, created_at, updated_at
 FROM job_queue
 ORDER BY id DESC`)
 	if err != nil {