Changeset 199

Timestamp:

04/24/07 22:15:07 (18 years ago)

Author:

Erik Huelsmann

Message:

Add a dcc-chat-connection class; a non-abstract subclass of dcc-connection.

Location:

trunk

Files:

• package.lisp (modified) (1 diff)
• protocol.lisp (modified) (6 diffs)

trunk/package.lisp ¶

@@ -142 +142 @@
              ;; DCC specific dictionary
              :dcc-connection
+             :dcc-chat-connection
              :irc-connection
              :close-on-main
              :remote-user
              :dcc-close
+             :make-dcc-chat-connection
              )))
 

trunk/protocol.lisp ¶

@@ -336 +336 @@
     #+armedbear (ext:destroy-thread process))
 
-(defun read-message-loop (connection)
+(defgeneric read-message-loop (connection))
+(defmethod read-message-loop (connection)
   (loop while (read-message connection)))
 
@@ -361 +362 @@
     raw-message))
 
-(defmethod get-hooks ((connection connection) (class symbol))
+;;applies to both irc and dcc-connections
+(defmethod get-hooks (connection (class symbol))
   "Return a list of all hooks for `class'."
   (gethash class (hooks connection)))
 
-(defmethod add-hook ((connection connection) class hook)
+;;applies to both irc and dcc-connections
+(defmethod add-hook (connection class hook)
   "Add `hook' to `class'."
   (setf (gethash class (hooks connection))
@@ -480 +483 @@
 ;; CHAT related generic functions
 (defgeneric send-dcc-message (connection message))
+;;already defined in relation to `connection'
+;; (defgeneric read-message (connection))
+;;(defgeneric dcc-message-event (message)) <defined in event.lisp>
 
 ;; SEND related generic functions
@@ -487 +493 @@
     (and (streamp stream)
          (open-stream-p stream))))
+
+(defmethod send-dcc-message ((connection dcc-connection) message)
+  (format (output-stream connection) "~A~%" message)
+  (force-output (network-stream connection)))
 
 (defmethod dcc-close ((connection dcc-connection))
@@ -498 +508 @@
         (dcc-connections (irc-connection connection))
         (remove connection (dcc-connections (irc-connection connection)))))
+
+
+(defclass dcc-chat-connection (dcc-connection)
+  ((output-stream
+    :initarg :output-stream
+    :initform nil
+    :accessor output-stream
+    :documentation "Stream used to communicate with the other end
+of the network pipe.")
+   (hooks
+    :initform (make-hash-table :test #'equal)
+    :accessor hooks))
+  (:documentation ""))
+
+
+(defun make-dcc-chat-connection (&key (remote-user nil)
+;;                                      (remote-address nil)
+;;                                      (remote-port nil)
+                                      (client-stream nil)
+                                      (irc-connection nil)
+                                      (close-on-main t)
+                                      (socket nil)
+                                      (network-stream nil)
+                                      (outgoing-external-format *default-outgoing-external-format*)
+                                      (hooks nil))
+  (let* ((output-stream (flexi-streams:make-flexi-stream
+                         network-stream
+                         :element-type 'character
+                         :external-format (external-format-fixup
+                                           outgoing-external-format)))
+         (connection (make-instance 'dcc-chat-connection
+                                    :remote-user remote-user
+                                    :client-stream client-stream
+                                    :output-stream output-stream
+                                    :irc-connection irc-connection
+                                    :close-on-main close-on-main
+                                    :socket socket
+                                    :network-stream network-stream)))
+    (dolist (hook hooks)
+      (add-hook connection (car hook) (cdar hook)))
+    connection))
+
+(defmethod read-message ((connection dcc-chat-connection))
+  (when (connectedp connection)
+    (let* ((msg-string (read-protocol-line connection))
+           (message (create-dcc-message msg-string)))
+      (setf (connection message) connection)
+      (when *debug-p*
+        (format *debug-stream* "~A" (describe message))
+        (force-output *debug-stream*))
+      (dcc-message-event connection message)
+      message))) ; needed because of the "loop while" in read-message-loop
+
+(defmethod read-message-loop ((connection dcc-chat-connection))
+  ;; no special setup
+  (call-next-method)
+  ;; now, make sure the connection was closed and cleaned up properly...
+  ;; it *was* the last message, after all...
+  ;;##TODO, maybe we need some kind of 'auto-clean' slot to indicate
+  ;; this is the desired behaviour?
+  )
+
 
 ;;
@@ -969 +1041 @@
     (force-output stream)))
 
-
-(defmethod apply-to-hooks ((message irc-message))
+;; applies to both irc- and dcc-messages
+(defmethod apply-to-hooks (message)
   "Applies any applicable hooks to `message'.