(use sql-de-lite)
(use args)
(use data-structures)
(use ports)

(define (check-schema-is-ok db)
  (when (null? (schema db))
        (exec (sql db "CREATE TABLE queue (id INTEGER PRIMARY KEY AUTOINCREMENT, ts INTEGER, expiry INTEGER, priority INTEGER, event TEXT, retries INTEGER NOT NULL DEFAULT 0, error TEXT);"))))

(define (queue-event db-path priority ttl event)
  (call-with-database
   db-path
   (lambda (db)
     (check-schema-is-ok db)
     (let ((now (current-seconds)))
       (exec (sql db "INSERT INTO queue (ts, expiry, priority, event) VALUES (?,?,?,?);")
             now
             (if ttl (+ now ttl) #f)
             priority
             (with-output-to-string (lambda () (write event))))))))

(define opts
 (list (args:make-option (p priority) (#:required "priority") "event priority (higher numbers are more urgent)")
       (args:make-option (t ttl) (#:optional "time to live") "event expiry time (seconds)")
       (args:make-option (d db-path) (#:optional "database path") "database path")
       (args:make-option (h help)      #:none     "Display this text"
         (usage))))

(define (usage)
 (with-output-to-port (current-error-port)
   (lambda ()
     (print "Usage: " (car (argv)) " [options...] event")
     (newline)
     (print (args:usage opts))))
 (exit 1))

(receive (options operands)
    (args:parse (command-line-arguments) opts)
    (let ((priority (alist-ref 'priority options))
          (ttl (alist-ref 'ttl options))
          (db-path (alist-ref 'db-path options)))
      (for-each (lambda (ev-string)
                  (unless (list? (with-input-from-string ev-string read))
                          (printf "Invalid event: ~S\n" ev-string)
                          (exit 1))) operands)
      (map
       (lambda (ev-string)
         (queue-event
          (if db-path db-path "/tmp/speakd.sqlite")
          (if priority (string->number priority) 0)
          ttl
          (with-input-from-string ev-string read)))
       operands)))

        (display text)
        (close-output-port out)
        (close-input-port in)))))

(define (text-jbo . text)
  (let-values (((fd temp-path) (file-mkstemp "/tmp/speakd.XXXXXX")))
    (file-close fd)
    (text-to-wav '("-v" "jbo+f1" "-s" "120") (apply string-append text) temp-path)
    temp-path))

(define (text-en . text)
  (let-values (((fd temp-path) (file-mkstemp "/tmp/speakd.XXXXXX")))
    (file-close fd)
    (text-to-wav '("-v" "en+f3" "-s" "100") (apply string-append text) temp-path)
    temp-path))

(define (jingle-wav name)  (list 'nodelete name))

(define (jingle-mp3 name)
  (let-values (((fd temp-path) (file-mkstemp "/tmp/speakd.XXXXXX")))
    (file-close fd)

                             #f)))       ; Unknown action
                     ev-responses)))
          (for-each execute-event-step!
                    ev-response-steps)))))

(define (check-schema-is-ok db)
  (when (null? (schema db))
        (exec (sql db "CREATE TABLE queue (id INTEGER PRIMARY KEY AUTOINCREMENT, ts INTEGER, expiry INTEGER, priority INTEGER, event TEXT, retries INTEGER NOT NULL DEFAULT 0, error TEXT);"))))

(define (delete-expired-events! db)
  (exec (sql db "DELETE FROM queue WHERE expiry < ?;") (current-seconds)))

(define (run-event! db ev)
  (unless ev
          (thread-sleep! 1))
  (when ev
        (let ((handlers
               (eval (with-input-from-file (handlers-path) read))))

    (exec s (exn->string exn) (event-id ev))))

(define (handle-one-event!)
  (call-with-database
   (db-path)
   (lambda (db)
     (check-schema-is-ok db)
     (delete-expired-events! db)
     (let ((ev (poll-for-event db)))
       (handle-exceptions
        exn (if ((condition-predicate 'user-interrupt) exn)
                (raise exn)
                (log-failure! db ev exn))
        (run-event! db ev))))))