encode as utf8 in send/receive-message-using-transport

transport/stdio.lisp

@@ -6,6 +6,7 @@
                 #:connection
                 #:connection-socket)
   (:import-from #:yason)
+  (:import-from #:babel)
   (:import-from #:bordeaux-threads
                 #:make-thread
                 #:destroy-thread)
@@ -60,23 +61,30 @@
     connection))
 
 (defmethod send-message-using-transport ((transport stdio-transport) connection message)
-  (let ((json (with-output-to-string (s)
-                (yason:encode message s)))
+  (let ((json (babel:string-to-octets
+               (with-output-to-string (s)
+                 (yason:encode message s))))
         (stream (connection-socket connection)))
-    (format stream "Content-Length: ~A~C~C~:*~:*~C~C~A"
+    (format stream "Content-Length: ~A~C~C~:*~:*~C~C"
             (length json)
             #\Return
-            #\Newline
-            json)
+            #\Newline)
+    (write-sequence json stream)
     (force-output stream)))
 
 (defmethod receive-message-using-transport ((transport stdio-transport) connection)
   (let* ((stream (connection-socket connection))
          (headers (read-headers stream))
          (length (ignore-errors (parse-integer (gethash "content-length" headers)))))
     (when length
-      (let ((body (make-string length)))
-        (read-sequence body (stdio-transport-input transport))
+      (let ((body
+              (with-output-to-string (out)
+                (loop
+                  :for c := (read-char stream)
+                  :do (write-char c out)
+                      (decf length (babel:string-size-in-octets (string c)))
+                      (when (<= length 0)
+                        (return))))))
         (parse-message body)))))
 
 ;; character stream