X-Git-Url: https://cgit.sxemacs.org/?p=riece;a=blobdiff_plain;f=lisp%2Friece-ruby.el;h=a58b4f71f6533390039111361e505031b3dc262a;hp=fe5c6f157c62d76bc5bacbaa425c08abac97e383;hb=99671e472d9a929d583bfa41823250bbfdd15f19;hpb=11277f5cc09a50109d75f6ef99f0144916be8e55 diff --git a/lisp/riece-ruby.el b/lisp/riece-ruby.el index fe5c6f1..a58b4f7 100644 --- a/lisp/riece-ruby.el +++ b/lisp/riece-ruby.el @@ -3,7 +3,7 @@ ;; Author: Daiki Ueno ;; Created: 1998-09-28 -;; Keywords: IRC, riece +;; Keywords: IRC, riece, Ruby ;; This file is part of Riece. @@ -24,7 +24,7 @@ ;;; Commentary: -;; riece-ruby.el is a library to interact with the Ruby interpreter. +;; riece-ruby.el is a library to interact with Ruby interpreter. ;; It supports concurrent execution of Ruby programs in a single ;; session. For example: ;; @@ -38,18 +38,21 @@ ;; => "rubyserv2" ;; ;; (riece-ruby-inspect "rubyserv0") -;; => ((OK nil) nil "running") +;; => ((OK nil) nil (("running"))) ;; ;; (riece-ruby-inspect "rubyserv1") -;; => ((OK nil) "2" "finished") +;; => ((OK nil) "2" (("finished"))) ;; ;; (riece-ruby-inspect "rubyserv2") -;; => ((OK nil) "(eval):1: unterminated string meets end of file" "exited") +;; => ((OK nil) "(eval):1: unterminated string meets end of file" (("exited"))) ;;; Code: +(require 'riece-debug) + (defgroup riece-ruby nil - "Interact with the Ruby interpreter." + "Interact with Ruby interpreter." + :prefix "riece-" :group 'riece) (defcustom riece-ruby-command "ruby" @@ -57,12 +60,35 @@ :type 'string :group 'riece-ruby) +(defcustom riece-ruby-out-file (expand-file-name "riece-ruby.out" + riece-directory) + "A file which records stdout of Ruby programs." + :type 'string + :group 'riece-ruby) + +(defcustom riece-ruby-err-file (expand-file-name "riece-ruby.err" + riece-directory) + "A file which records stderr of Ruby programs." + :type 'string + :group 'riece-ruby) + +(defcustom riece-ruby-log-file (expand-file-name "riece-ruby.log" + riece-directory) + "A file used to logging." + :type 'string + :group 'riece-ruby) + (defvar riece-ruby-server-program "server.rb" "The server program file. If the filename is not absolute, it is assumed that the file is in the same directory of this file.") +(defvar riece-ruby-server-program-arguments (list "-o" riece-ruby-out-file + "-e" riece-ruby-err-file + "-l" riece-ruby-log-file) + "Command line arguments passed to `riece-ruby-server-program'.") + (defvar riece-ruby-process nil - "Process object of the Ruby interpreter.") + "Process object of Ruby interpreter.") (defvar riece-ruby-lock nil "Lock for waiting server response. @@ -81,6 +107,8 @@ Local to the process buffer.") "Status from server. Local to the process buffer.") +(defvar riece-ruby-output-queue-alist nil + "An alist mapping from program name to output data.") (defvar riece-ruby-output-handler-alist nil "An alist mapping from program name to output handler. Output handlers are called every time \"# output\" line arrives. @@ -93,22 +121,6 @@ Use `riece-ruby-set-exit-handler' to set this variable.") "An alist mapping from program name to the property list. Use `riece-ruby-set-property' to set this variable.") -(defvar riece-ruby-enabled nil) - -(defconst riece-ruby-description - "Evaluate an input string as Ruby program.") - -(defun riece-ruby-substitute-variables (program alist) - (setq program (copy-sequence program)) - (while alist - (let ((pointer program)) - (while pointer - (setq pointer (memq (car (car alist)) program)) - (if pointer - (setcar pointer (cdr (car alist)))))) - (setq alist (cdr alist))) - (apply #'concat program)) - (defun riece-ruby-escape-data (data) (let ((index 0)) (while (string-match "[%\r\n]+" data index) @@ -172,7 +184,7 @@ Use `riece-ruby-set-property' to set this variable.") (set-buffer (process-buffer process)) (goto-char (point-max)) (insert input) - (goto-char (process-mark process)) + (goto-char (point-min)) (beginning-of-line) (while (looking-at ".*\r\n") (if (looking-at "OK\\( \\(.*\\)\\)?\r") @@ -187,7 +199,7 @@ Use `riece-ruby-set-property' to set this variable.") (progn (setq riece-ruby-escaped-data nil riece-ruby-response - (list 'ERR (string-to-number (match-string 2)) + (list 'ERR (string-to-number (match-string 1)) (match-string 3)) riece-ruby-lock nil)) (if (looking-at "D \\(.*\\)\r") @@ -203,43 +215,57 @@ Use `riece-ruby-set-property' to set this variable.") (riece-ruby-run-exit-handler (cdr (car riece-ruby-status-alist))))) (if (looking-at "# output \\([^ ]*\\) \\(.*\\)\r") - (let ((entry (assoc (match-string 1) - riece-ruby-output-handler-alist))) - (if entry - (funcall (cdr entry) (car entry) (match-string 2)))) + (riece-ruby-run-output-handler (match-string 1) + (match-string 2) + (current-time)) (if (looking-at "# exit \\(.*\\)\r") (riece-ruby-run-exit-handler (match-string 1)))))))) (forward-line)) - (set-marker (process-mark process) (point-marker)))) + (delete-region (point-min) (point)))) (defun riece-ruby-run-exit-handler (name) (let ((entry (assoc name riece-ruby-exit-handler-alist))) - (if entry - (progn - (setq riece-ruby-exit-handler-alist - (delq entry riece-ruby-exit-handler-alist)) - (funcall (cdr entry) (car entry)) - (riece-ruby-clear name))))) + (when entry + (setq riece-ruby-exit-handler-alist + (delq entry riece-ruby-exit-handler-alist)) + (riece-funcall-ignore-errors (if (symbolp (cdr entry)) + (symbol-name (cdr entry)) + (format "%s-exit-handler" name)) + (cdr entry) (car entry)) + (riece-ruby-clear name)))) + +(defun riece-ruby-run-output-handler (name output time) + (let ((handler-entry (assoc name riece-ruby-output-handler-alist)) + (entry (assoc name riece-ruby-output-queue-alist))) + (if handler-entry + (riece-funcall-ignore-errors (if (symbolp (cdr handler-entry)) + (symbol-name (cdr handler-entry)) + (format "%s-output-handler" name)) + (cdr handler-entry) name output time) + (if entry + (setcdr entry (cons (cons output time) (cdr entry))) + (setq riece-ruby-output-queue-alist + (cons (list name (cons output time)) + riece-ruby-output-queue-alist)))))) (defun riece-ruby-sentinel (process status) (kill-buffer (process-buffer process))) (defun riece-ruby-execute (program) + "Schedule an execution of a Ruby PROGRAM. +Return a string name assigned by the server." (unless (and riece-ruby-process (eq (process-status riece-ruby-process) 'run)) (let (selective-display (coding-system-for-write 'binary) (coding-system-for-read 'binary)) (setq riece-ruby-process - (start-process "riece-ruby" (generate-new-buffer " *Ruby*") - riece-ruby-command - (if (file-name-absolute-p riece-ruby-server-program) - riece-ruby-server-program - (expand-file-name - riece-ruby-server-program - (file-name-directory - (locate-library - (symbol-file 'riece-ruby-execute))))))) + (apply #'start-process "riece-ruby" (generate-new-buffer " *Ruby*") + riece-ruby-command + (expand-file-name riece-ruby-server-program + riece-data-directory) + riece-ruby-server-program-arguments)) + (process-kill-without-query riece-ruby-process) (set-process-filter riece-ruby-process #'riece-ruby-filter) (set-process-sentinel riece-ruby-process #'riece-ruby-sentinel))) (save-excursion @@ -255,6 +281,12 @@ Use `riece-ruby-set-property' to set this variable.") (cdr (assoc "name" riece-ruby-status-alist)))) (defun riece-ruby-inspect (name) + "Inspect a result of program execution distinguished by NAME. +Return a three element list. +The car is protocol response line which looks like: + \(ERR 103 \"Not implemented\"). +The cadr is data from the server, that is, the result of the program. +The caddr is status from the server." (save-excursion (set-buffer (process-buffer riece-ruby-process)) (riece-ruby-reset-process-buffer) @@ -268,6 +300,9 @@ Use `riece-ruby-set-property' to set this variable.") riece-ruby-status-alist))) (defun riece-ruby-clear (name) + "Clear a result of program execution distinguished by NAME. +Note that riece-ruby-clear is automatically called iff an exit-handler +is specified. Otherwise, it should be called explicitly." (save-excursion (set-buffer (process-buffer riece-ruby-process)) (riece-ruby-reset-process-buffer) @@ -281,6 +316,11 @@ Use `riece-ruby-set-property' to set this variable.") (delq entry riece-ruby-property-alist)))) (defun riece-ruby-set-exit-handler (name handler) + "Set an exit-handler HANDLER for the program distinguished by NAME. +An exit-handler is called when the program is finished or exited abnormally. +An exit-handler is called with an argument same as NAME. +Note that riece-ruby-clear is automatically called iff an exit-handler +is specified. Otherwise, it should be called explicitly." (let ((entry (assoc name riece-ruby-exit-handler-alist))) (if handler (progn @@ -296,9 +336,27 @@ Use `riece-ruby-set-property' to set this variable.") (delq entry riece-ruby-exit-handler-alist)))))) (defun riece-ruby-set-output-handler (name handler) - (let ((entry (assoc name riece-ruby-output-handler-alist))) + "Set an output-handler HANDLER for the program distinguished by NAME. +An output-handler is called when the program sends any output by using +`output' method in the Ruby program. +An output-handler is called with three argument. The first argument +is the same as NAME. The second argument is the output string. The +third argument is the timestamp of the output event." + (let ((entry (assoc name riece-ruby-output-handler-alist)) + queue-entry pointer) (if handler (progn + (when (setq queue-entry (assoc name riece-ruby-output-queue-alist)) + (setq pointer (nreverse (cdr queue-entry)) + riece-ruby-output-queue-alist + (delq queue-entry riece-ruby-output-queue-alist)) + (while pointer + (riece-funcall-ignore-errors (if (symbolp handler) + (symbol-name handler) + (format "%s-output-handler" name)) + handler name (car (car pointer)) + (cdr (car pointer))) + (setq pointer (cdr pointer)))) (if entry (setcdr entry handler) (setq riece-ruby-output-handler-alist @@ -309,6 +367,7 @@ Use `riece-ruby-set-property' to set this variable.") (delq entry riece-ruby-output-handler-alist)))))) (defun riece-ruby-set-property (name property value) + "Set given PROPERTY/VALUE pair to the program distinguished by NAME." (let ((entry (assoc name riece-ruby-property-alist)) property-entry) (unless entry @@ -319,50 +378,21 @@ Use `riece-ruby-set-property' to set this variable.") (setcdr entry (cons (cons property value) (cdr entry)))))) (defun riece-ruby-property (name property) + "Return the value of PROPERTY set to the program distinguished by NAME." (cdr (assoc property (cdr (assoc name riece-ruby-property-alist))))) -(defun riece-ruby-exit-handler (name) - (riece-ruby-inspect name) - (let* ((data (copy-sequence riece-ruby-data)) - (length (length data)) - (index 0)) - (while (< index length) - (if (eq (aref data index) ?\n) - (aset data index ? )) - (setq index (1+ index))) - (riece-send-string - (format "NOTICE %s :%s\r\n" - (riece-identity-prefix - (riece-ruby-property name 'riece-ruby-target)) - data)) - (riece-display-message - (riece-make-message (riece-current-nickname) - (riece-ruby-property name 'riece-ruby-target) - data - 'notice)))) - -(defun riece-ruby-display-message-function (message) - (if (and riece-ruby-enabled - (riece-message-own-p message) - (string-match "^,ruby\\s-+" (riece-message-text message))) - (let ((name (riece-ruby-execute - (substring (riece-message-text message) - (match-end 0))))) - (riece-ruby-set-property name - 'riece-ruby-target - (riece-message-target message)) - (riece-ruby-set-exit-handler name - #'riece-ruby-exit-handler)))) - -(defun riece-ruby-insinuate () - (add-hook 'riece-after-display-message-functions - 'riece-ruby-display-message-function)) - -(defun riece-ruby-enable () - (setq riece-ruby-enabled t)) - -(defun riece-ruby-disable () - (setq riece-ruby-enabled nil)) +(defun riece-ruby-substitute-variables (program alist) + "Substitute symbols in PROGRAM by looking up ALIST. +Return a string concatenating elements in PROGRAM." + (setq program (copy-sequence program)) + (while alist + (let ((pointer program)) + (while pointer + (setq pointer (memq (car (car alist)) program)) + (if pointer + (setcar pointer (cdr (car alist)))))) + (setq alist (cdr alist))) + (apply #'concat program)) (provide 'riece-ruby)