1 ;;; riece-async.el --- connect to IRC server via asynchronous proxy
2 ;; Copyright (C) 1998-2003 Daiki Ueno
4 ;; Author: Daiki Ueno <ueno@unixuser.org>
5 ;; Keywords: IRC, riece
7 ;; This file is part of Riece.
9 ;; This program is free software; you can redistribute it and/or modify
10 ;; it under the terms of the GNU General Public License as published by
11 ;; the Free Software Foundation; either version 2, or (at your option)
14 ;; This program is distributed in the hope that it will be useful,
15 ;; but WITHOUT ANY WARRANTY; without even the implied warranty of
16 ;; MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 ;; GNU General Public License for more details.
19 ;; You should have received a copy of the GNU General Public License
20 ;; along with GNU Emacs; see the file COPYING. If not, write to the
21 ;; Free Software Foundation, Inc., 59 Temple Place - Suite 330,
22 ;; Boston, MA 02111-1307, USA.
26 ;; This program allows to connect to an IRC server via local proxy
27 ;; which responds to PING requests from server.
29 ;; To use, add the following line to your ~/.riece/init.el:
30 ;; (add-to-list 'riece-addons 'riece-async)
32 ;; If you want to enable this feature per server, write the server
34 ;; (add-to-list 'riece-server-alist
35 ;; '("async" :host "irc.tokyo.wide.ad.jp"
36 ;; :function riece-async-open-network-stream))
40 (require 'riece-options)
42 (defgroup riece-async nil
43 "Connect to IRC server via asynchronous proxy"
47 (defcustom riece-async-ruby-command "ruby"
48 "Command name for Ruby interpreter."
52 (defcustom riece-async-server-program
55 socket = TCPSocket.new(" host ", " service ")
56 $stdout.write(\"NOTICE CONNECTED #{$$}\\r\\n\")
58 $stdout.nonblock = true
59 trap('STOP', 'IGNORE')
60 trap('TSTP', 'IGNORE')
64 rfds, wfds, = select([socket, $stdin], wfds_in)
66 until buf.length <= " max-buffer-size "
67 i = buf.index(\"\\r\\n\")
69 buf.slice!(0 .. i + 1)
73 len = $stdout.syswrite(buf)
80 if rfds.include?(socket)
81 line = socket.gets(\"\\r\\n\")
83 if line =~ /^(?::[^ ]+ +)?PING +(.+)\\r\\n/i
84 socket.write(\"PONG #{$1}\\r\\n\")
91 if rfds.include?($stdin)
92 line = $stdin.gets(\"\\r\\n\")
100 "Ruby program of asynchronous proxy."
104 (defcustom riece-async-max-buffer-size 65535
105 "Maximum size of the write buffer."
109 (defun riece-async-substitute-variables (program variable value)
110 (setq program (copy-sequence program))
111 (let ((pointer program))
113 (setq pointer (memq variable program))
115 (setcar pointer value)))
119 (defun riece-async-open-network-stream (name buffer host service)
120 (let* ((process-connection-type nil)
121 (process (start-process name buffer "ruby" "-rsocket")))
122 (process-kill-without-query process)
123 (process-send-string process
125 (riece-async-substitute-variables
126 (riece-async-substitute-variables
127 (riece-async-substitute-variables
128 riece-async-server-program
130 (concat "'" host "'"))
132 (if (numberp service)
133 (number-to-string service)
134 (concat "'" service "'")))
137 riece-async-max-buffer-size))))
138 (process-send-string process "\0\n") ;input to process is needed
141 (set-buffer (process-buffer process))
142 (while (and (eq (process-status process) 'run)
144 (goto-char (point-min))
145 (not (looking-at (format "NOTICE CONNECTED %d"
146 (process-id process))))))
147 (accept-process-output process))))
150 (defun riece-async-insinuate ()
151 (setq riece-default-open-connection-function
152 #'riece-async-open-network-stream))
154 (provide 'riece-async)
156 ;;; riece-rdcc.el ends here