From d910366dac72b64f745f0dbe8eb55c6659453309 Mon Sep 17 00:00:00 2001
From: Helmut Merz <helmutm@cy55.de>
Date: Thu, 24 Sep 2026 12:36:49 +0200
Subject: [PATCH] environ:send-message: use customer instead of :to data field
 for receiver

---
 core/actor.lisp   |  2 +-
 core/message.lisp |  7 ++++---
 csys/environ.lisp | 22 ++++++++++++----------
 csys/space.lisp   |  1 -
 4 files changed, 17 insertions(+), 15 deletions(-)

diff --git a/core/actor.lisp b/core/actor.lisp
index 9772ed9..8dd2aee 100644
--- a/core/actor.lisp
+++ b/core/actor.lisp
@@ -32,7 +32,7 @@
 
 (defgeneric update-content (msg fn)
   (:documentation "Create a new message with content returned by calling `fn`
-                   with the content of the input `msg`.")
+                   on the content of the input `msg`.")
   (:method (msg fn) (funcall fn msg))
   (:method ((msg message) fn) 
     (message (funcall fn (content msg)) (customer msg))))
diff --git a/core/message.lisp b/core/message.lisp
index 489718e..78e0991 100644
--- a/core/message.lisp
+++ b/core/message.lisp
@@ -27,10 +27,11 @@
           (shape:head msg) (actor:customer msg) (shape:data msg)))
 
 (defmethod actor:content ((msg message))
-  (list (shape:head-plist msg) (shape:data msg)))
+  (list (shape:head msg) (shape:data msg)))
 
-(defmethod actor:update-content ((msg message) fn)
-  (create (shape:head msg) :data (fn (shape:data msg)) :customer (actor:customer msg)))
+(defmethod update-content ((msg message) fn)
+  (destructuring-bind (head data) (funcall fn (actor:content msg)) 
+    (create head :data data :customer (actor:customer msg))))
 
 (defun domain (msg)
   (car (shape:head msg)))
diff --git a/csys/environ.lisp b/csys/environ.lisp
index 236a535..3306780 100644
--- a/csys/environ.lisp
+++ b/csys/environ.lisp
@@ -90,24 +90,25 @@
     (if addr 
       (let ((cell (find-cell (spaces scope) (message:addr msg)))) 
         (actor:send cell msg))
-      (let ((rcvr (getf (shape:data msg) :to)))
+      (let ((rcvr (actor:customer msg)))
         (if rcvr
           (actor:send rcvr msg)
-          (util:lgw "no addr and no :to field in message" msg scope)))))
+          (util:lgw "no addr and no customer in message" msg scope)))))
   nil)
 
 (defun forward-connect (msg scope)
   ;; TODO: target may be nil => replace with list of candidates
   (let* ((data (shape:data msg))
-         (tgt (getf data :target)))
+         (tgt (getf data :target))
+         (cust (actor:customer msg)))
     (when (listp tgt) 
       (setf (getf data :target) (find-cell (spaces scope) tgt)))
-    (forward (message:create (shape:head msg) :data data) scope)))
+    (forward (message:create (shape:head msg) :data data :customer cust) scope)))
 
 ;;;; public shortcuts
 
-(defun send-message (head data &key (env *env*))
-  (actor:send env (message:create head :data data)))
+(defun send-message (head data &key customer (env *env*))
+  (actor:send env (message:create head :data data :customer customer)))
 
 (defun send-value (cat-loc val &key (domain csys:*domain*) (env *env*))
   (let ((head (cons domain (cons :value cat-loc))))
@@ -117,12 +118,13 @@
   ;; TODO: use msg.customer instead of :to in data
   (let* ((cat-loc (when (listp rcvr) rcvr))
          (head (cons domain (cons :connect cat-loc)))
-         (data (unless cat-loc (list :to rcvr))))
-    (when op (util:plist-add data :op op))
+         (cust (unless cat-loc rcvr))
+         data)
     (when (and (listp target) (< (length target) 3)) 
       (setf target (cons domain target)))
-    (util:plist-add data :target target)
-    (send-message head data :env env)))
+    (setf data (list :target target))
+    (when op (util:plist-add data :op op))
+    (send-message head data :customer cust :env env)))
 
 ;;;; internal helpers
 
diff --git a/csys/space.lisp b/csys/space.lisp
index 67acf3c..809d0aa 100644
--- a/csys/space.lisp
+++ b/csys/space.lisp
@@ -16,7 +16,6 @@
 (defun put (spc loc obj)
   (let ((current (gethash loc spc))) 
     (if current
-      ;(util:lgw "location already occupied" spc loc current obj)
       (error "location already occupied! space: ~s, loc: ~s, current: ~s, new: ~s" 
              spc loc current obj)
       (setf (gethash loc spc) obj))))