wait to inject each object before we inject the next one

[mudsync.git] / mudsync / run-game.scm

diff --git a/mudsync/run-game.scm b/mudsync/run-game.scm
index ff58f23a91beadd32c95f2212f23110dc5ba1fea..c9d1f423a31262e6004480c7ea5c91c1480d289d 100644 (file)
--- a/mudsync/run-game.scm
+++ b/mudsync/run-game.scm
@@ -18,15 +18,15 @@
 
 (define-module (mudsync run-game)
   #:use-module (mudsync game-master)
-  #:use-module (8sync agenda)
+  #:use-module (8sync)
   #:use-module (8sync repl)
-  #:use-module (8sync systems actors)
-  #:use-module (8sync systems actors debug)
+  #:use-module (8sync debug)
   #:use-module (srfi srfi-1)
   #:use-module (ice-9 receive)
   #:use-module (ice-9 q)
+  #:use-module (ice-9 match)
   #:export (run-demo
-            inject-special!
+            do-inject-special!
             make-special-injector
 
             ;; Debug stuff, might go away
@@ -46,9 +46,32 @@
 ;; "quasi-evil for productivity's sake" anyway).  You can set up your own
 ;; solution which doesn't use a global though.
 
+(define %inject-queue #f)
+
 (define (inject-gameobj! game-spec special-symbol)
-  (display "Game hasn't been started...\n"))
+  (if %inject-queue
+      (let ((gameobj-spec
+             (or (find
+                  (lambda (entry) (eq? (car entry) special-symbol))
+                  game-spec)
+                 (throw 'no-such-symbol "Can't find such a symbol in the game-spec"
+                        #:symbol special-symbol))))
+        (enq! %inject-queue (cons gameobj-spec special-symbol)))
+      (display "Game hasn't been started...\n"))
+  'done)
+
+(define-actor <gameobj-injector> (<actor>)
+  ((repl-update gameobj-injector-inject-queued))
+  (gm #:init-keyword #:gm
+      #:getter .gm))
 
+(define (gameobj-injector-inject-queued injector message)
+  (while (not (q-empty? %inject-queue))
+    (match (deq! %inject-queue)
+      ((gameobj-spec . special-symbol)
+       (<-wait (.gm injector) 'inject-special!
+               #:special-symbol special-symbol
+               #:gameobj-spec gameobj-spec)))))
 
 \f
 ;;; Game running stuff
@@ -59,59 +82,21 @@
   (define new-conn-handler
     (make-default-room-conn-handler default-room))
   (define gm
-    (hive-create-actor-gimmie* hive <game-master> "gm"
-                               #:new-conn-handler new-conn-handler))
-  (define initial-tasks
-    (list (bootstrap-message hive (actor-id gm) 'init-world
-                             #:game-spec game-spec)))
-  (define agenda
-    (make-agenda #:pre-unwind-handler print-error-and-continue
-                 #:queue (list->q initial-tasks)))
+    (bootstrap-actor-gimmie* hive <game-master> "gm"
+                             #:new-conn-handler new-conn-handler))
+  (define injector
+    (bootstrap-actor hive <gameobj-injector>
+                     #:gm (actor-id gm)))
+
+  (define repl-manager
+    (bootstrap-actor* hive <repl-manager> "repl"
+                      #:subscribers (list injector)))
 
   (set! %live-gm gm)
   (set! %live-hive hive)
-  (receive (post-run-hook gameobj-injector)
-      (make-special-injector agenda hive (actor-id gm))
-    ;; Set up injector for live hacking
-    (set! inject-gameobj! gameobj-injector)
-
-    ;; Set up REPL sever
-    (cond
-     ;; If repl-server is an integer, we'll use that as the port
-     ((integer? repl-server)
-      (spawn-and-queue-repl-server! agenda repl-server))
-     (repl-server
-      (spawn-and-queue-repl-server! agenda)))
-
-    (start-agenda agenda
-                  #:post-run-hook post-run-hook)))
-
-
-(define (inject-special! queue hive gm-id game-spec special-symbol)
-  (define gameobj-spec
-    (or (find
-         (lambda (entry) (eq? (car entry) special-symbol))
-         game-spec)
-        (throw 'no-such-symbol "Can't find such a symbol in the game-spec"
-               #:symbol special-symbol)))
-  (define task
-    (bootstrap-message hive gm-id 'inject-special!
-                       #:special-symbol special-symbol
-                       #:gameobj-spec gameobj-spec))
-  (enq! queue task)
-  'done)
 
-(define (queue-injected-tasks-on-agenda! agenda inject-queue)
-  "Inject tasks from the inject-queue onto the agenda queue."
-  (while (not (q-empty? inject-queue))
-    (enq! (agenda-queue agenda) (q-pop! inject-queue))))
+  (set! %inject-queue (make-q))
 
-(define* (make-special-injector agenda hive gm-id)
-  "Make a post-run-hook and gameobj injector for quick live hacking."
-  (define inject-queue (make-q))
-  (values
-   (lambda (agenda)
-     (queue-injected-tasks-on-agenda! agenda inject-queue))
-   (lambda (game-spec special-symbol)
-     (inject-special! inject-queue hive gm-id
-                      game-spec special-symbol))))
+  (run-hive hive
+            (list (bootstrap-message hive (actor-id gm) 'init-world
+                                     #:game-spec game-spec))))