X-Git-Url: https://jxself.org/git/?p=8sync.git;a=blobdiff_plain;f=tests%2Ftest-agenda.scm;h=868d4ce3b9545538d6a59668486730d319b53c2e;hp=691310905b29bbdc7b82b8451e9e62ba2753677f;hb=d7d268fd056bd54a42859534057fc80b25c75c8b;hpb=a9e932ba04d488a5492afe0dd6d88337f4b01686 diff --git a/tests/test-agenda.scm b/tests/test-agenda.scm index 6913109..868d4ce 100644 --- a/tests/test-agenda.scm +++ b/tests/test-agenda.scm @@ -1,29 +1,27 @@ -;; Copyright (C) 2015 Christopher Allan Webber - -;; This library is free software; you can redistribute it and/or -;; modify it under the terms of the GNU Lesser General Public -;; License as published by the Free Software Foundation; either -;; version 3 of the License, or (at your option) any later version. -;; -;; This library 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 -;; Lesser General Public License for more details. -;; -;; You should have received a copy of the GNU Lesser General Public -;; License along with this library; if not, write to the Free Software -;; Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA -;; 02110-1301 USA - -#!/usr/bin/guile \ --s -!# +;;; 8sync --- Asynchronous programming for Guile +;;; Copyright (C) 2015 Christopher Allan Webber +;;; +;;; This library is free software; you can redistribute it and/or +;;; modify it under the terms of the GNU Lesser General Public +;;; License as published by the Free Software Foundation; either +;;; version 3 of the License, or (at your option) any later version. +;;; +;;; This library 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 +;;; Lesser General Public License for more details. +;;; +;;; You should have received a copy of the GNU Lesser General Public +;;; License along with this library; if not, write to the Free Software +;;; Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA +;;; 02110-1301 USA (define-module (tests test-agenda) #:use-module (srfi srfi-64) #:use-module (ice-9 q) + #:use-module (ice-9 match) #:use-module (ice-9 receive) - #:use-module (eightsync agenda) + #:use-module (8sync agenda) #:use-module (tests utils)) (test-begin "test-agenda") @@ -40,8 +38,25 @@ messages))) -;; Timer tests -;; =========== +;;; queue helpers +;;; ============= + +(define test-q (list->q '(1 2 3))) +(test-equal (deq! test-q) 1) +(test-equal (deq! test-q) 2) +(test-equal (deq! test-q) 3) +(test-assert (q-empty? test-q)) + +(define test-q (make-q* 'apple 'banana 'carrot)) +(test-equal (deq! test-q) 'apple) +(test-equal (deq! test-q) 'banana) +(test-equal (deq! test-q) 'carrot) +(test-assert (q-empty? test-q)) + + + +;;; Timer tests +;;; =========== (test-assert (time= '(1 . 1) '(1 . 1))) (test-assert (not (time= '(1 . 1) '(1 . 0)))) @@ -239,35 +254,54 @@ (test-equal (run-request-when run-two-squared) '(88 . 0))) -;;; %run, %8sync and friends tests +;;; %run, 8sync and friends tests ;;; ============================== -(define (test-%run-and-friends async-request expected-when) - (let* ((fake-kont (speak-it)) - (run-request ((@@ (eightsync agenda) setup-async-request) - fake-kont async-request))) - (test-equal (car async-request) '*async-request*) - (test-equal (run-request-when run-request) expected-when) - ;; we're using speaker as a fake continuation ;p - ((run-request-proc run-request)) - (test-equal (fake-kont) - '("applesauce")))) - -(test-%run-and-friends (%run (string-concatenate '("apple" "sauce"))) +(define-syntax-rule (run-in-fake-agenda + code-to-run) + (let ((agenda (make-agenda))) + (parameterize ((%current-agenda agenda)) + (call-with-prompt + (agenda-prompt-tag agenda) + (lambda () + (list '*normal-result* code-to-run)) + (lambda (kont async-request) + (list '*caught-kont* + kont async-request + ((@@ (8sync agenda) setup-async-request) + kont async-request))))))) + +(define (test-%run-and-friends run-result expected-when) + (match run-result + (('*caught-kont* kont async-request setup-request) + (let* ((fake-kont (speak-it)) + (run-request ((@@ (8sync agenda) setup-async-request) + fake-kont async-request))) + (test-equal (car async-request) '*async-request*) + (test-equal (run-request-when run-request) expected-when) + ;; we're using speaker as a fake continuation ;p + ((run-request-proc run-request)) + (test-equal (fake-kont) + '("applesauce")))))) + +(test-%run-and-friends (run-in-fake-agenda + (8sync (string-concatenate '("apple" "sauce")))) #f) -(test-%run-and-friends (%run-at (string-concatenate '("apple" "sauce")) - '(8 . 0)) +(test-%run-and-friends (run-in-fake-agenda + (8sync (string-concatenate '("apple" "sauce")) + '(8 . 0))) '(8 . 0)) -(test-%run-and-friends (%run-delay (string-concatenate '("apple" "sauce")) - 8) +(test-%run-and-friends (run-in-fake-agenda + (8sync-delay (string-concatenate '("apple" "sauce")) + 8)) ;; whoa, I'm surprised equal? can ;; compare records like this (tdelta 8)) ;; TODO: test %port-request -;; TODO: test %8sync and friends! +;; TODO: test 8sync and friends! ;;; Agenda tests @@ -292,20 +326,18 @@ (speaker "I bet I can make you say you're a dummy!\n") (run-it dummy-func)) -(let ((q (make-q))) +(begin (set! speaker (speak-it)) ; reset the speaker - (enq! q run-dummy) - (start-agenda (make-agenda #:queue q) + (start-agenda (make-agenda #:queue (make-q* run-dummy)) #:stop-condition (true-after-n-times 2)) (test-equal (speaker) '("I bet I can make you say you're a dummy!\n" "I'm a dummy\n"))) ;; should only do the first one after one round though -(let ((q (make-q))) +(begin (set! speaker (speak-it)) ; reset the speaker - (enq! q run-dummy) - (start-agenda (make-agenda #:queue q) + (start-agenda (make-agenda #:queue (make-q* run-dummy)) #:stop-condition (true-after-n-times 1)) (test-equal (speaker) '("I bet I can make you say you're a dummy!\n"))) @@ -320,13 +352,12 @@ (speaker "Today I went to the zoo and I saw...\n") (speaker (string-concatenate - `("A " ,(symbol->string (%8sync (%run (return-monkey)))) "!\n")))) + `("A " ,(symbol->string (8sync (return-monkey))) "!\n")))) -(let ((q (make-q))) +(begin (set! speaker (speak-it)) - (enq! q talk-about-the-zoo) ;; (enq! q talk-about-the-zoo-but-wait) - (start-agenda (make-agenda #:queue q) + (start-agenda (make-agenda #:queue (make-q* talk-about-the-zoo)) #:stop-condition (true-after-n-times 10)) (test-equal (speaker) '("Today I went to the zoo and I saw...\n" @@ -344,59 +375,83 @@ (define (indirection-remote-func-breaks) (speaker "bebop\n") - (%8sync (%run (remote-func-breaks))) + (8sync (remote-func-breaks)) (speaker "bidop\n")) (define* (local-func-gets-break #:key with-indirection) (speaker "Time for exception fun!\n") (let ((caught-exception #f)) - (catch '%8sync-caught-error - (lambda () - (%8sync (%run (if with-indirection - (indirection-remote-func-breaks) - (remote-func-breaks))))) - (lambda (_ orig-key orig-args orig-stacks) - (set! caught-exception #t) - (speaker "in here now!\n") - (test-equal orig-key 'numerical-overflow) - (test-equal orig-args '("/" "Numerical overflow" #f #f)) - (test-assert (list? orig-stacks)) - (test-equal (length orig-stacks) - (if with-indirection 2 1)) - (for-each - (lambda (x) - (test-assert (stack? x))) - orig-stacks))) + (catch-8sync + (8sync-run (if with-indirection + (indirection-remote-func-breaks) + (remote-func-breaks))) + ('numerical-overflow + (lambda (orig-stacks . orig-args) + (set! caught-exception #t) + (speaker "in here now!\n") + (test-equal orig-args '("/" "Numerical overflow" #f #f)) + (test-assert (list? orig-stacks)) + (test-equal (length orig-stacks) + (if with-indirection 2 1)) + (for-each + (lambda (x) + (test-assert (stack? x))) + orig-stacks)))) (test-assert caught-exception)) (speaker "Well that was fun :)\n")) -(let ((q (make-q))) +(begin (set! speaker (speak-it)) - (enq! q local-func-gets-break) - (start-agenda (make-agenda #:queue q) + (start-agenda (make-agenda #:queue (make-q* local-func-gets-break)) #:stop-condition (true-after-n-times 10)) - (test-assert (speaker) - '("Time for exception fun!\n" - "Here we go...\n" - "in here now!\n" - "Well that was fun :)\n"))) + (test-equal (speaker) + '("Time for exception fun!\n" + "Here we go...\n" + "in here now!\n" + "Well that was fun :)\n"))) -(let ((q (make-q))) +(begin (set! speaker (speak-it)) - (enq! q (wrap (local-func-gets-break #:with-indirection #t))) - (start-agenda (make-agenda #:queue q) + (start-agenda (make-agenda + #:queue (make-q* (wrap (local-func-gets-break + #:with-indirection #t)))) #:stop-condition (true-after-n-times 10)) - (test-assert (speaker) - '("Time for exception fun!\n" - "bebop\n" - "Here we go...\n" - "in here now!\n" - "Well that was fun :)\n"))) + (test-equal (speaker) + '("Time for exception fun!\n" + "bebop\n" + "Here we go...\n" + "in here now!\n" + "Well that was fun :)\n"))) + +;; Make sure catching tools work + +(let ((speaker (speak-it)) + (catch-result #f)) + (catch-8sync + (begin + (speaker "hello") + (throw '8sync-caught-error + 'my-orig-key '(apple orange banana) '(*fake-stack* *fake-stack* *fake-stack*)) + (speaker "no goodbyes")) + ('some-key + (lambda (stacks . rest) + (speaker "should not happen"))) + ('my-orig-key + (lambda (stacks fruit1 fruit2 fruit3) + (set! catch-result + `((fruit1 ,fruit1) + (fruit2 ,fruit2) + (fruit3 ,fruit3)))))) + (test-equal (speaker) '("hello")) + (test-equal catch-result '((fruit1 apple) + (fruit2 orange) + (fruit3 banana)))) ;; End tests (test-end "test-agenda") +;; @@: A better way to handle this at the repl? (test-exit)