Move box-protocol to a #lang preserves-schema module

syndicate-examples/speed-tests/box-and-client/protocol.rkt

@@ -1,5 +1,6 @@
+#lang preserves-schema #:plugin syndicate/schema-compiler
+
 version 1 .
-embeddedType Actor.Ref .
 
 BoxState = <BoxState @value int>.
 SetBox = <SetBox @value int>.

syndicate-examples/speed-tests/box-and-client/stats.rkt

@@ -0,0 +1,15 @@
+#lang racket/base
+
+(provide report-stats)
+
+(define (report-stats REPORT_EVERY)
+  (define start-time (current-inexact-milliseconds))
+  (define prev-value 0)
+  (lambda (new-value)
+    (when (zero? (remainder new-value REPORT_EVERY))
+      (define end-time (current-inexact-milliseconds))
+      (define delta (/ (- end-time start-time) 1000.0))
+      (define count (- new-value prev-value))
+      (set! prev-value new-value)
+      (set! start-time end-time)
+      (log-info "Box got ~a (~a Hz)" new-value (/ count delta)))))

syndicate-examples/speed-tests/box-and-client/with-dataspace.rkt

@@ -1,30 +1,18 @@
 #lang syndicate
 
-(require syndicate/schemas/gen/box-protocol)
+(require "protocol.rkt")
-
+(require "stats.rkt")
-(define (report-stats REPORT_EVERY)
-  (define start-time (current-inexact-milliseconds))
-  (define prev-value 0)
-  (lambda (new-value)
-    (when (zero? (remainder new-value REPORT_EVERY))
-      (define end-time (current-inexact-milliseconds))
-      (define delta (/ (- end-time start-time) 1000.0))
-      (define count (- new-value prev-value))
-      (set! prev-value new-value)
-      (set! start-time end-time)
-      (log-info "Box got ~a (~a Hz)" new-value (/ count delta)))))
 
 (define box
   (action (ds LIMIT REPORT_EVERY)
     (spawn #:name 'box
-           (define root-facet this-facet)
            (define-field value 0)
            (define reporter (report-stats REPORT_EVERY))
            (at ds
                (assert (BoxState (value)))
                (when (message (SetBox $new-value))
                  (reporter new-value)
-                 (when (= new-value LIMIT) (stop-facet root-facet))
+                 (when (= new-value LIMIT) (stop-current-facet))
                  (value new-value))))))
 
 (define client

syndicate-examples/speed-tests/box-and-client/without-dataspace.rkt

@@ -1,16 +1,6 @@
 #lang syndicate
 
-(define (report-stats REPORT_EVERY)
+(require "stats.rkt")
-  (define start-time (current-inexact-milliseconds))
-  (define prev-value 0)
-  (lambda (new-value)
-    (when (zero? (remainder new-value REPORT_EVERY))
-      (define end-time (current-inexact-milliseconds))
-      (define delta (/ (- end-time start-time) 1000.0))
-      (define count (- new-value prev-value))
-      (set! prev-value new-value)
-      (set! start-time end-time)
-      (log-info "Box got ~a (~a Hz)" new-value (/ count delta)))))
 
 (define box
   (action (k LIMIT REPORT_EVERY)
@@ -26,7 +16,6 @@
                           'setter
                           (ref (entity #:message
                                        (action (new-value)
-                                         ;; (log-info "new-value ~v" new-value)
                                          (reporter new-value)
                                          (when (= new-value LIMIT) (stop-facet root-facet))
                                          (value new-value)))))))))

syndicate/private/install.rkt

@@ -6,15 +6,18 @@
 (require preserves-schema/bin/preserves-schema-rkt)
 (require (only-in racket/file delete-directory/files))
 
-(require (only-in "../schema-compiler.rkt" schema-compiler-plugin))
+(require (only-in "../schema-compiler.rkt"
+                  schema-compiler-plugin
+                  schema-compiler-plugin-mode))
 
 (define (pre-installer _collects-path syndicate-path)
   (define output-directory (build-path syndicate-path "schemas/gen"))
   (delete-directory/files output-directory #:must-exist? #f)
-  (batch-compile #:inputs (list (build-path syndicate-path "schemas/**.prs"))
+  (parameterize ((schema-compiler-plugin-mode 'meta))
-                 #:additional-modules (hash '(Actor) 'syndicate/actor)
+    (batch-compile #:inputs (list (build-path syndicate-path "schemas/**.prs"))
-                 #:output-directory output-directory
+                   #:additional-modules (hash '(Actor) 'syndicate/actor)
-                 #:plugins (list schema-compiler-plugin)))
+                   #:output-directory output-directory
+                   #:plugins (list schema-compiler-plugin))))
 
 (define-runtime-path syndicate-path "..")
 (define (regenerate!)

syndicate/schema-compiler.rkt

@@ -1,6 +1,7 @@
 #lang racket/base
 
-(provide schema-compiler-plugin)
+(provide schema-compiler-plugin
+         schema-compiler-plugin-mode)
 
 (require racket/pretty)
 (require racket/match)
@@ -12,12 +13,20 @@
 (require preserves-schema/type)
 (require preserves-schema/gen/schema)
 
+(define schema-compiler-plugin-mode (make-parameter 'normal))
+
 (define (schema-compiler-plugin schema options)
   (match-define (schema-compiler-options _name
                                          lookup-module-path
                                          paths) options)
-  (define ds-path (lookup-module-path '(dataspace-patterns)))
+  (define ds-path
-  (define meta? (equal? ds-path (schema-translation-paths-relative-output-path paths)))
+    (match (schema-compiler-plugin-mode)
+      ['normal 'syndicate/schemas/gen/dataspace-patterns]
+      ['meta (lookup-module-path '(dataspace-patterns))]))
+  (define meta?
+    (match (schema-compiler-plugin-mode)
+      ['normal #f]
+      ['meta (equal? ds-path (schema-translation-paths-relative-output-path paths))]))
 
   (define (N sym)
     (if meta?