;;; ravanan --- High-reproducibility CWL runner powered by Guix
;;; Copyright © 2024–2025 Arun Isaac <arunisaac@systemreboot.net>
;;;
;;; This file is part of ravanan.
;;;
;;; ravanan is free software: you can redistribute it and/or modify it
;;; under the terms of the GNU General Public License as published by
;;; the Free Software Foundation, either version 3 of the License, or
;;; (at your option) any later version.
;;;
;;; ravanan is distributed in the hope that it will be useful, but
;;; WITHOUT ANY WARRANTY; without even the implied warranty of
;;; MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
;;; General Public License for more details.
;;;
;;; You should have received a copy of the GNU General Public License
;;; along with ravanan.  If not, see <https://www.gnu.org/licenses/>.

(use-modules (srfi srfi-64)
             (ravanan propnet))

(test-begin "propnet")

(test-equal "Trigger propagator with no inputs"
  '((out . #t))
  (run-with-state
    (let loop ((mstate (schedule-propnet
                        (propnet (list (propagator "const"
                                                   (const '((out . #t)))
                                                   '()
                                                   '()
                                                   '((out . out))))
                                 (@@ (ravanan workflow) value=?)
                                 (@@ (ravanan workflow) merge-values)
                                 (scheduler (lambda (proc inputs scheduler)
                                              (state-return proc))
                                            (lambda (state)
                                              (state-return (state+status state
                                                                          'completed)))
                                            (lambda (proc)
                                              (state-return (proc)))))
                        '())))
      ;; Poll.
      (state-let* ((state mstate)
                   (state+status (poll-propnet state)))
        (if (eq? (state+status-status state+status)
                 'pending)
            (loop (state-return (state+status-state state+status)))
            ;; Capture outputs.
            (capture-propnet-output (state+status-state state+status)))))))

(test-end "propnet")