X-Git-Url: http://cgit.sxemacs.org/?p=riece;a=blobdiff_plain;f=lisp%2Friece-rdcc.el;h=9b5286f68db595e789d8212538f235a29601b51f;hp=4a34937801fcd47f845328671d66582c1a9f1233;hb=bc34a63003955546c07a672ffedba63935817011;hpb=c3700928a40b2507148bfcc767cad5f47e909211 diff --git a/lisp/riece-rdcc.el b/lisp/riece-rdcc.el index 4a34937..9b5286f 100644 --- a/lisp/riece-rdcc.el +++ b/lisp/riece-rdcc.el @@ -1,4 +1,4 @@ -;;; riece-rdcc.el --- ruby implementation of DCC add-on +;;; riece-rdcc.el --- DCC file sending protocol support (written in Ruby) ;; Copyright (C) 1998-2003 Daiki Ueno ;; Author: Daiki Ueno @@ -18,8 +18,12 @@ ;; You should have received a copy of the GNU General Public License ;; along with GNU Emacs; see the file COPYING. If not, write to the -;; Free Software Foundation, Inc., 59 Temple Place - Suite 330, -;; Boston, MA 02111-1307, USA. +;; Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, +;; Boston, MA 02110-1301, USA. + +;;; Commentary: + +;; NOTE: This is an add-on module for Riece. ;;; Code: @@ -28,9 +32,11 @@ (require 'riece-channel) (require 'riece-identity) (require 'riece-ctcp) ;for riece-ctcp-additional-clientinfo +(require 'riece-ruby) +(require 'riece-mcat) (defgroup riece-rdcc nil - "DCC implementation using ruby" + "DCC written in Ruby." :prefix "riece-" :group 'riece) @@ -40,13 +46,9 @@ Only used for sending files." :type 'string :group 'riece-rdcc) -(defcustom riece-rdcc-ruby-command "ruby" - "Command name for Ruby interpreter." - :type 'string - :group 'riece-rdcc) - (defcustom riece-rdcc-send-program '("\ +require 'socket' address = " address " unless address sock = UDPSocket.new @@ -54,15 +56,14 @@ unless address address = sock.getsockname[4 .. 7].unpack('CCCC').join('.') end server = TCPServer.new(address, 0) -puts(\"#{server.addr[3].split(/\\./).collect{|c| c.to_i}.pack('CCCC').unpack('N')[0]} #{server.addr[1]}\") -$stdout.flush +output(\"#{server.addr[3].split(/\\./).collect{|c| c.to_i}.pack('CCCC').unpack('N')[0]} #{server.addr[1]}\") session = server.accept if session total = 0 File.open(" file ") {|file| while (bytes = file.read(" block-size ")) total += bytes.length - puts(total) + output(total) session.write(bytes) begin buf = session.read(4) @@ -77,9 +78,8 @@ end :group 'riece-rdcc) (defcustom riece-rdcc-decode-address-program - '("\ -puts(\"#{" address " >> 24 & 0xFF}.#{" address " >> 16 & 0xFF}.#{" - address " >> 8 & 0xFF}.#{" address " & 0xFF}\")") + '("\"#{" address " >> 24 & 0xFF}.#{" address " >> 16 & 0xFF}.#{" + address " >> 8 & 0xFF}.#{" address " & 0xFF}\"") "Ruby program to numeric IP address." :type 'list :group 'riece-rdcc) @@ -103,95 +103,63 @@ puts(\"#{" address " >> 24 & 0xFF}.#{" address " >> 16 & 0xFF}.#{" (defvar riece-rdcc-temp-file nil) (defvar riece-rdcc-received-size nil) -(defvar riece-rdcc-enabled nil) - (defconst riece-rdcc-description - "DCC file sending extension implemented in Ruby") + "DCC file sending protocol support (written in Ruby.)") (defvar temporary-file-directory) (defvar jka-compr-compression-info-list) (defvar jam-zcat-filename-list) -(defun riece-rdcc-substitute-variables (program variable value) - (setq program (copy-sequence program)) - (let ((pointer program)) - (while pointer - (setq pointer (memq variable program)) - (if pointer - (setcar pointer value))) - program)) - -(defun riece-rdcc-server-filter (process input) - (save-excursion - (set-buffer (process-buffer process)) - (goto-char (point-max)) - (insert input) - (goto-char (point-min)) - (while (and (not (eobp)) - (looking-at "\\([0-9]+\\)\n")) - (message "Sending %s...(%s/%d)" - riece-rdcc-request-file - (match-string 1) riece-rdcc-request-size) - (forward-line)) - (unless (eobp) - (delete-region (point-min) (point))))) - -(defun riece-rdcc-server-sentinel (process status) - (with-current-buffer (process-buffer process) - (message "Sending %s...done" riece-rdcc-request-file)) - (kill-buffer (process-buffer process))) + +(defun riece-rdcc-output-handler (name output time) + (if (string-match "\\([0-9]+\\) \\([0-9]+\\)" output) + (let ((address (match-string 1 output)) + (port (match-string 2 output))) + (riece-send-string + (format "PRIVMSG %s :\1DCC SEND %s %s %s %d\1\r\n" + (riece-identity-prefix + (riece-ruby-property name 'riece-rdcc-request-user)) + (file-name-nondirectory + (riece-ruby-property name 'riece-rdcc-request-file)) + address port + (riece-ruby-property name 'riece-rdcc-request-size))))) + (riece-ruby-set-output-handler name #'riece-rdcc-output-handler-2)) + +(defun riece-rdcc-output-handler-2 (name output time) + (message (riece-mcat "Sending %s...(%s/%d)") + (riece-ruby-property name 'riece-rdcc-request-file) + (string-to-number output) + (riece-ruby-property name 'riece-rdcc-request-size))) + +(defun riece-rdcc-exit-handler (name) + (message (riece-mcat "Sending %s...done") + (riece-ruby-property name 'riece-rdcc-request-file))) (defun riece-command-dcc-send (user file) (interactive (let ((completion-ignore-case t)) (list (riece-completing-read-identity - "User: " + (riece-mcat "User: ") (riece-get-users-on-server (riece-current-server-name))) - (expand-file-name (read-file-name "File: "))))) - (let* ((process-connection-type nil) - (process (start-process "DCC" (generate-new-buffer " *DCC*") - "ruby" "-rsocket"))) - (process-send-string process - (apply #'concat - (riece-rdcc-substitute-variables - (riece-rdcc-substitute-variables - (riece-rdcc-substitute-variables - riece-rdcc-send-program - 'address - (if riece-rdcc-server-address - (concat "'" riece-rdcc-server-address - "'") - "nil")) - 'file - (concat "'" file "'")) - 'block-size - (number-to-string riece-rdcc-block-size)))) - (process-send-eof process) - (save-excursion - (set-buffer (process-buffer process)) - (while (and (eq (process-status process) 'run) - (progn - (goto-char (point-min)) - (not (looking-at "\\([0-9]+\\) \\([0-9]+\\)")))) - (accept-process-output process)) - (if (eq (process-status process) 'run) - (let ((address (match-string 1)) - (port (match-string 2)) - (filename (file-name-nondirectory file))) - (while (string-match "[ \t]+" filename) - (setq filename (replace-match "_" nil nil filename))) - (erase-buffer) - (make-local-variable 'riece-rdcc-request-size) - (setq riece-rdcc-request-file file - riece-rdcc-request-size (nth 7 (file-attributes file))) - (set-buffer-modified-p nil) - (set-process-filter process #'riece-rdcc-server-filter) - (set-process-sentinel process #'riece-rdcc-server-sentinel) - (riece-send-string - (format "PRIVMSG %s :\1DCC SEND %s %s %s %d\1\r\n" - (riece-identity-prefix user) - filename - address port - riece-rdcc-request-size))))))) + (expand-file-name (read-file-name (riece-mcat "File: ")))))) + (let ((name (riece-ruby-execute + (riece-ruby-substitute-variables + riece-rdcc-send-program + (list (cons 'address + (if riece-rdcc-server-address + (concat "'" riece-rdcc-server-address + "'") + "nil")) + (cons 'file + (concat "'" file "'")) + (cons 'block-size + (number-to-string + riece-rdcc-block-size))))))) + (riece-ruby-set-property name 'riece-rdcc-request-user user) + (riece-ruby-set-property name 'riece-rdcc-request-file file) + (riece-ruby-set-property name 'riece-rdcc-request-size + (nth 7 (file-attributes file))) + (riece-ruby-set-output-handler name #'riece-rdcc-output-handler) + (riece-ruby-set-exit-handler name #'riece-rdcc-exit-handler))) (defun riece-rdcc-filter (process input) (save-excursion @@ -209,7 +177,7 @@ puts(\"#{" address " >> 24 & 0xFF}.#{" address " >> 16 & 0xFF}.#{" (logand (lsh riece-rdcc-received-size -16) 255) (logand (lsh riece-rdcc-received-size -8) 255) (logand riece-rdcc-received-size 255))) - (message "Receiving %s from %s...(%s/%s)" + (message (riece-mcat "Receiving %s from %s...(%s/%s)") (file-name-nondirectory riece-rdcc-request-file) riece-rdcc-request-user (riece-rdcc-format-size riece-rdcc-received-size) @@ -222,7 +190,7 @@ puts(\"#{" address " >> 24 & 0xFF}.#{" address " >> 16 & 0xFF}.#{" (set-buffer (process-buffer process)) (unless (= riece-rdcc-received-size riece-rdcc-request-size) (error "Premature end of file")) - (message "Receiving %s from %s...done" + (message (riece-mcat "Receiving %s from %s...done") (file-name-nondirectory riece-rdcc-request-file) riece-rdcc-request-user) (condition-case nil @@ -235,14 +203,15 @@ puts(\"#{" address " >> 24 & 0xFF}.#{" address " >> 16 & 0xFF}.#{" (kill-buffer (process-buffer process))) (defun riece-rdcc-decode-address (address) - (with-temp-buffer - (call-process riece-rdcc-ruby-command nil t nil "-e" - (apply #'concat - (riece-rdcc-substitute-variables - riece-rdcc-decode-address-program - 'address - address))) - (buffer-substring (point-min) (1- (point-max))))) + (let ((name (riece-ruby-execute + (riece-ruby-substitute-variables + riece-rdcc-decode-address-program + (list (cons 'address address))))) + response) + (while (equal (nth 2 (setq response (riece-ruby-inspect name))) "running") + (accept-process-output riece-ruby-process)) + (riece-ruby-clear name) + (nth 1 response))) (defun riece-command-dcc-receive (request file) (interactive @@ -256,7 +225,7 @@ puts(\"#{" address " >> 24 & 0xFF}.#{" address " >> 16 & 0xFF}.#{" (let ((requests riece-rdcc-requests) (index 1)) (while requests - (princ (format "%2d: %s %s (%d bytes)\n" + (princ (format (riece-mcat "%2d: %s %s (%d bytes)\n") index (car (car requests)) (nth 1 (car requests)) @@ -278,8 +247,8 @@ puts(\"#{" address " >> 24 & 0xFF}.#{" address " >> 16 & 0xFF}.#{" (list request (expand-file-name (read-file-name - (concat "Save as (default " - (file-name-nondirectory default-name) ") ") + (format (riece-mcat "Save as (default %s) ") + (file-name-nondirectory default-name)) (file-name-directory default-name) default-name)))))) (let* ((temp-file (expand-file-name @@ -335,7 +304,7 @@ puts(\"#{" address " >> 24 & 0xFF}.#{" address " >> 16 & 0xFF}.#{" (defun riece-handle-dcc-request (prefix target message) (let ((case-fold-search t)) - (when (and riece-rdcc-enabled + (when (and (get 'riece-rdcc 'riece-addon-enabled) (string-match "SEND \\(\\([^ ]+\\)\\|\"\\(.+\\)\"\\) \\([^ ]+\\) \\([^ ]+\\) \\([^ ]+\\)" message)) @@ -355,7 +324,8 @@ puts(\"#{" address " >> 24 & 0xFF}.#{" address " >> 16 & 0xFF}.#{" (with-current-buffer (window-buffer (selected-window)) (substitute-command-keys (format - "Type \\[riece-command-dcc-receive] to receive" + (riece-mcat + "Type \\[riece-command-dcc-receive] to receive") user)))) (riece-insert-change buffer (format "DCC SEND from %s: %s (%s)\n" user file @@ -385,15 +355,18 @@ puts(\"#{" address " >> 24 & 0xFF}.#{" address " >> 16 & 0xFF}.#{" (add-to-list 'riece-ctcp-additional-clientinfo "DCC") (add-hook 'riece-ctcp-dcc-request-hook 'riece-handle-dcc-request)) +(defun riece-rdcc-uninstall () + (setq riece-ctcp-additional-clientinfo + (delete "DCC" riece-ctcp-additional-clientinfo)) + (remove-hook 'riece-ctcp-dcc-request-hook 'riece-handle-dcc-request)) + (defun riece-rdcc-enable () (define-key riece-dialogue-mode-map "\C-ds" 'riece-command-dcc-send) - (define-key riece-dialogue-mode-map "\C-dr" 'riece-command-dcc-receive) - (setq riece-rdcc-enabled t)) + (define-key riece-dialogue-mode-map "\C-dr" 'riece-command-dcc-receive)) (defun riece-rdcc-disable () (define-key riece-dialogue-mode-map "\C-ds" nil) - (define-key riece-dialogue-mode-map "\C-dr" nil) - (setq riece-rdcc-enabled nil)) + (define-key riece-dialogue-mode-map "\C-dr" nil)) (provide 'riece-rdcc)