Add clack-socket to abstract :clack.io sockets in handlers.

clack-handler-wookie.asd

@@ -22,6 +22,7 @@
   :author "Eitaro Fukamachi"
   :license "LLGPL"
   :depends-on (:wookie
+               :clack-socket
                :cl-async
                :fast-http
                :quri

clack-socket.asd

@@ -0,0 +1,10 @@
+(in-package :cl-user)
+(defpackage clack-socket-asd
+  (:use :cl :asdf))
+(in-package :clack-socket-asd)
+
+(defsystem clack-socket
+  :version "0.1"
+  :author "Eitaro Fukamachi"
+  :license "LLGPL"
+  :components ((:file "src/socket")))

src/handler/wookie.lisp

@@ -23,7 +23,9 @@
   (:import-from :cl-async
                 :with-event-loop
                 :close-tcp-server
-                :async-io-stream)
+                :async-io-stream
+                :socket-data
+                :write-socket-data)
   (:import-from :fast-http
                 :http-version)
   (:import-from :quri
@@ -160,3 +162,14 @@
                         :status status
                         :headers headers
                         :body body))))))
+
+(defmethod clack.socket:set-read-callback (socket callback)
+  (setf (getf (as:socket-data socket) :parser) callback))
+
+(defmethod clack.socket:write-to-socket (socket message &key callback)
+  (as:write-socket-data socket message
+                        :write-cb
+                        (and callback
+                             (lambda (socket)
+                               (declare (ignore socket))
+                               (funcall callback)))))

src/socket.lisp

@@ -0,0 +1,10 @@
+(in-package :cl-user)
+(defpackage clack.socket
+  (:use :cl)
+  (:export :set-read-callback
+           :write-to-socket))
+(in-package :clack.socket)
+
+(defgeneric set-read-callback (socket callback))
+
+(defgeneric write-to-socket (socket message &key callback))