cgit.sxemacs.org Git - gnus/blob - lisp/nnbabyl.el

   1 ;;; nnbabyl.el --- rmail mbox access for Gnus
   2 ;; Copyright (C) 1995 Free Software Foundation, Inc.
   3
   4 ;; Author: Lars Magne Ingebrigtsen <larsi@ifi.uio.no>
   5 ;;      Masanobu UMEDA <umerin@flab.flab.fujitsu.junet>
   6 ;; Keywords: news, mail
   7
   8 ;; This file is part of GNU Emacs.
   9
  10 ;; GNU Emacs is free software; you can redistribute it and/or modify
  11 ;; it under the terms of the GNU General Public License as published by
  12 ;; the Free Software Foundation; either version 2, or (at your option)
  13 ;; any later version.
  14
  15 ;; GNU Emacs is distributed in the hope that it will be useful,
  16 ;; but WITHOUT ANY WARRANTY; without even the implied warranty of
  17 ;; MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  18 ;; GNU General Public License for more details.
  19
  20 ;; You should have received a copy of the GNU General Public License
  21 ;; along with GNU Emacs; see the file COPYING.  If not, write to
  22 ;; the Free Software Foundation, 675 Mass Ave, Cambridge, MA 02139, USA.
  23
  24 ;;; Commentary:
  25
  26 ;; For an overview of what the interface functions do, please see the
  27 ;; Gnus sources.
  28
  29 ;;; Code:
  30
  31 (require 'nnheader)
  32 (require 'rmail)
  33 (require 'nnmail)
  34
  35 (defvar nnbabyl-mbox-file (expand-file-name "~/RMAIL")
  36   "The name of the rmail box file in the users home directory.")
  37
  38 (defvar nnbabyl-active-file (expand-file-name "~/.rmail-active")
  39   "The name of the active file for the rmail box.")
  40
  41 (defvar nnbabyl-get-new-mail t
  42   "If non-nil, nnbabyl will check the incoming mail file and split the mail.")
  43
  44 (defvar nnbabyl-prepare-save-mail-hook nil
  45   "Hook run narrowed to an article before saving.")
  46
  47 \f
  48
  49 (defvar nnbabyl-mail-delimiter "\^_")
  50
  51 (defconst nnbabyl-version "nnbabyl 0.1"
  52   "nnbabyl version.")
  53
  54 (defvar nnbabyl-mbox-buffer nil)
  55 (defvar nnbabyl-current-group nil)
  56 (defvar nnbabyl-status-string "")
  57 (defvar nnbabyl-group-alist nil)
  58
  59 \f
  60
  61 (defvar nnbabyl-current-server nil)
  62 (defvar nnbabyl-server-alist nil)
  63 (defvar nnbabyl-server-variables
  64   (list
  65    (list 'nnbabyl-mbox-file nnbabyl-mbox-file)
  66    (list 'nnbabyl-active-file nnbabyl-active-file)
  67    (list 'nnbabyl-get-new-mail nnbabyl-get-new-mail)
  68    '(nnbabyl-current-group nil)
  69    '(nnbabyl-status-string "")
  70    '(nnbabyl-group-alist nil)))
  71
  72 \f
  73
  74 ;;; Interface functions
  75
  76 (defun nnbabyl-retrieve-headers (sequence &optional newsgroup server)
  77   (save-excursion
  78     (set-buffer nntp-server-buffer)
  79     (erase-buffer)
  80     (let ((file nil)
  81           (number (length sequence))
  82           (count 0)
  83           article art-string start stop)
  84       (nnbabyl-possibly-change-newsgroup newsgroup)
  85       (if (stringp (car sequence))
  86           'headers
  87         (while sequence
  88           (setq article (car sequence))
  89           (setq art-string (nnbabyl-article-string article))
  90           (set-buffer nnbabyl-mbox-buffer)
  91           (if (or (search-forward art-string nil t)
  92                   (search-backward art-string nil t))
  93               (progn
  94                 (re-search-backward (concat "^" nnbabyl-mail-delimiter) nil t)
  95                 (while (and (not (looking-at ".+:"))
  96                             (zerop (forward-line 1))))
  97                 (setq start (point))
  98                 (search-forward "\n\n" nil t)
  99                 (setq stop (1- (point)))
 100                 (set-buffer nntp-server-buffer)
 101                 (insert "221 " (int-to-string article) " Article retrieved.\n")
 102                 (insert-buffer-substring nnbabyl-mbox-buffer start stop)
 103                 (goto-char (point-max))
 104                 (insert ".\n")))
 105           (setq sequence (cdr sequence))
 106           (setq count (1+ count))
 107           (and (numberp nnmail-large-newsgroup)
 108                (> number nnmail-large-newsgroup)
 109                (zerop (% count 20))
 110                gnus-verbose-backends
 111                (message "nnbabyl: Receiving headers... %d%%"
 112                         (/ (* count 100) number))))
 113
 114         (and (numberp nnmail-large-newsgroup)
 115              (> number nnmail-large-newsgroup)
 116              gnus-verbose-backends
 117              (message "nnbabyl: Receiving headers...done"))
 118
 119         ;; Fold continuation lines.
 120         (goto-char (point-min))
 121         (while (re-search-forward "\\(\r?\n[ \t]+\\)+" nil t)
 122           (replace-match " " t t))
 123         'headers))))
 124
 125 (defun nnbabyl-open-server (server &optional defs)
 126   (nnheader-init-server-buffer)
 127   (if (equal server nnbabyl-current-server)
 128       t
 129     (if nnbabyl-current-server
 130         (setq nnbabyl-server-alist
 131               (cons (list nnbabyl-current-server
 132                           (nnheader-save-variables nnbabyl-server-variables))
 133                     nnbabyl-server-alist)))
 134     (let ((state (assoc server nnbabyl-server-alist)))
 135       (if state
 136           (progn
 137             (nnheader-restore-variables (nth 1 state))
 138             (setq nnbabyl-server-alist (delq state nnbabyl-server-alist)))
 139         (nnheader-set-init-variables nnbabyl-server-variables defs)))
 140     (setq nnbabyl-current-server server)))
 141
 142 (defun nnbabyl-close-server (&optional server)
 143   t)
 144
 145 (defun nnbabyl-server-opened (&optional server)
 146   (and (equal server nnbabyl-current-server)
 147        nnbabyl-mbox-buffer
 148        (buffer-name nnbabyl-mbox-buffer)
 149        nntp-server-buffer
 150        (buffer-name nntp-server-buffer)))
 151
 152 (defun nnbabyl-status-message (&optional server)
 153   nnbabyl-status-string)
 154
 155 (defun nnbabyl-request-article (article &optional newsgroup server buffer)
 156   (nnbabyl-possibly-change-newsgroup newsgroup)
 157   (if (stringp article)
 158       nil
 159     (save-excursion
 160       (set-buffer nnbabyl-mbox-buffer)
 161       (goto-char (point-min))
 162       (if (search-forward (nnbabyl-article-string article) nil t)
 163           (let (start stop)
 164             (re-search-backward (concat "^" nnbabyl-mail-delimiter) nil t)
 165             (while (and (not (looking-at ".+:"))
 166                         (zerop (forward-line 1))))
 167             (setq start (point))
 168             (or (and (re-search-forward
 169                       (concat "^" nnbabyl-mail-delimiter) nil t)
 170                      (forward-line -1))
 171                 (goto-char (point-max)))
 172             (setq stop (point))
 173             (let ((nntp-server-buffer (or buffer nntp-server-buffer)))
 174               (set-buffer nntp-server-buffer)
 175               (erase-buffer)
 176               (insert-buffer-substring nnbabyl-mbox-buffer start stop)
 177               (goto-char (point-min))
 178               (if (search-forward "\n*** EOOH ***" nil t)
 179                   (progn
 180                     (delete-region (progn (beginning-of-line) (point))
 181                                    (or (search-forward "\n\n" nil t)
 182                                        (point)))))
 183               t))))))
 184
 185 (defun nnbabyl-request-group (group &optional server dont-check)
 186   (save-excursion
 187     (if (nnbabyl-possibly-change-newsgroup group)
 188         (if dont-check
 189             t
 190           (nnbabyl-get-new-mail group)
 191           (save-excursion
 192             (set-buffer nntp-server-buffer)
 193             (erase-buffer)
 194             (let ((active (assoc group nnbabyl-group-alist)))
 195               (insert (format "211 %d %d %d %s\n"
 196                               (1+ (- (cdr (car (cdr active)))
 197                                      (car (car (cdr active)))))
 198                               (car (car (cdr active)))
 199                               (cdr (car (cdr active)))
 200                               (car active))))
 201             t)))))
 202
 203 (defun nnbabyl-close-group (group &optional server)
 204   t)
 205
 206 (defun nnbabyl-request-list (&optional server)
 207   (if server (nnbabyl-get-new-mail))
 208   (save-excursion
 209     (or (nnmail-find-file nnbabyl-active-file)
 210         (progn
 211           (setq nnbabyl-group-alist (nnmail-get-active))
 212           (nnmail-save-active nnbabyl-group-alist nnbabyl-active-file)
 213           (nnmail-find-file nnbabyl-active-file)))))
 214
 215 (defun nnbabyl-request-newgroups (date &optional server)
 216   (nnbabyl-request-list server))
 217
 218 (defun nnbabyl-request-list-newsgroups (&optional server)
 219   (setq nnbabyl-status-string "nnbabyl: LIST NEWSGROUPS is not implemented.")
 220   nil)
 221
 222 (defun nnbabyl-request-post (&optional server)
 223   (mail-send-and-exit nil))
 224
 225 (defalias 'nnbabyl-request-post-buffer 'nnmail-request-post-buffer)
 226
 227 (defun nnbabyl-request-expire-articles (articles newsgroup &optional server force)
 228   (nnbabyl-possibly-change-newsgroup newsgroup)
 229   (let* ((days (or (and nnmail-expiry-wait-function
 230                         (funcall nnmail-expiry-wait-function newsgroup))
 231                    nnmail-expiry-wait))
 232          article rest)
 233     (save-excursion
 234       (set-buffer nnbabyl-mbox-buffer)
 235       (while articles
 236         (goto-char (point-min))
 237         (if (search-forward (nnbabyl-article-string (car articles)) nil t)
 238             (if (or force
 239                     (> (nnmail-days-between
 240                         (current-time-string)
 241                         (buffer-substring
 242                          (point) (progn (end-of-line) (point))))
 243                        days))
 244                 (progn
 245                   (and gnus-verbose-backends
 246                        (message "Deleting: %s" (car articles)))
 247                   (nnbabyl-delete-mail))
 248               (setq rest (cons (car articles) rest))))
 249         (setq articles (cdr articles)))
 250       (save-buffer)
 251       ;; Find the lowest active article in this group.
 252       (let ((active (nth 1 (assoc newsgroup nnbabyl-group-alist))))
 253         (goto-char (point-min))
 254         (while (not (search-forward
 255                      (nnbabyl-article-string (car active)) nil t))
 256           (setcar active (1+ (car active)))
 257           (goto-char (point-min))))
 258       (nnmail-save-active nnbabyl-group-alist nnbabyl-active-file)
 259       rest)))
 260
 261 (defun nnbabyl-request-move-article
 262   (article group server accept-form &optional last)
 263   (nnbabyl-possibly-change-newsgroup group)
 264   (let ((buf (get-buffer-create " *nnbabyl move*"))
 265         result)
 266     (and
 267      (nnbabyl-request-article article group server)
 268      (save-excursion
 269        (set-buffer buf)
 270        (insert-buffer-substring nntp-server-buffer)
 271        (goto-char (point-min))
 272        (if (re-search-forward
 273             "^X-Gnus-Newsgroup:"
 274             (save-excursion (search-forward "\n\n" nil t) (point)) t)
 275            (delete-region (progn (beginning-of-line) (point))
 276                           (progn (forward-line 1) (point))))
 277        (setq result (eval accept-form))
 278        (kill-buffer (current-buffer))
 279        result)
 280      (save-excursion
 281        (set-buffer nnbabyl-mbox-buffer)
 282        (goto-char (point-min))
 283        (if (search-forward (nnbabyl-article-string article) nil t)
 284            (nnbabyl-delete-mail))
 285        (and last (save-buffer))))
 286     result))
 287
 288 (defun nnbabyl-request-accept-article (group &optional last)
 289   (let ((buf (current-buffer))
 290         result beg)
 291     (and
 292      (nnbabyl-request-list)
 293      (setq nnbabyl-group-alist (nnmail-get-active))
 294      (save-excursion
 295        (goto-char (point-min))
 296        (search-forward "\n\n" nil t)
 297        (forward-line -1)
 298        (save-excursion
 299          (while (re-search-backward "^X-Gnus-Newsgroup: " beg t)
 300            (delete-region (point) (progn (forward-line 1) (point)))))
 301        (let ((nnmail-split-methods
 302               (if (stringp group) (list (list group ""))
 303                 nnmail-split-methods)))
 304          (setq result (car (nnbabyl-save-mail))))
 305        (set-buffer nnbabyl-mbox-buffer)
 306        (goto-char (point-max))
 307        (search-backward "\n\^_")
 308        (goto-char (match-end 0))
 309        (insert-buffer buf)
 310        (and last (progn
 311                    (save-buffer)
 312                    (nnmail-save-active
 313                     nnbabyl-group-alist nnbabyl-active-file)))
 314        result))))
 315
 316 (defun nnbabyl-request-replace-article (article group buffer)
 317   (nnbabyl-possibly-change-newsgroup group)
 318   (save-excursion
 319     (set-buffer nnbabyl-mbox-buffer)
 320     (goto-char (point-min))
 321     (if (not (search-forward (nnbabyl-article-string article) nil t))
 322         nil
 323       (nnbabyl-delete-mail t t)
 324       (insert-buffer-substring buffer)
 325       (save-buffer)
 326       t)))
 327
 328 \f
 329 ;;; Low-Level Interface
 330
 331 ;; If FORCE, delete article no matter how many X-Gnus-Newsgroup
 332 ;; headers there are. If LEAVE-DELIM, don't delete the Unix mbox
 333 ;; delimeter line.
 334 (defun nnbabyl-delete-mail (&optional force leave-delim)
 335   ;; Delete the current X-Gnus-Newsgroup line.
 336   (or force
 337       (delete-region
 338        (progn (beginning-of-line) (point))
 339        (progn (forward-line 1) (point))))
 340   ;; Beginning of the article.
 341   (save-excursion
 342     (save-restriction
 343       (narrow-to-region
 344        (save-excursion
 345          (re-search-backward (concat "^" nnbabyl-mail-delimiter) nil t)
 346          (if leave-delim (progn (forward-line 1) (point))
 347            (match-beginning 0)))
 348        (progn
 349          (forward-line 1)
 350          (or (and (re-search-forward (concat "^" nnbabyl-mail-delimiter)
 351                                      nil t)
 352                   (if (and (not (bobp)) leave-delim)
 353                       (progn (forward-line -2) (point))
 354                     (match-beginning 0)))
 355              (point-max))))
 356       (goto-char (point-min))
 357       ;; Only delete the article if no other groups owns it as well.
 358       (if (or force (not (re-search-forward "^X-Gnus-Newsgroup: " nil t)))
 359           (delete-region (point-min) (point-max))))))
 360
 361 (defun nnbabyl-possibly-change-newsgroup (newsgroup)
 362   (if (or (not nnbabyl-mbox-buffer)
 363           (not (buffer-name nnbabyl-mbox-buffer)))
 364       (save-excursion (nnbabyl-read-mbox)))
 365   (or nnbabyl-group-alist
 366       (progn
 367         (nnbabyl-request-list)
 368         (setq nnbabyl-group-alist (nnmail-get-active))))
 369   (if newsgroup
 370       (if (assoc newsgroup nnbabyl-group-alist)
 371           (setq nnbabyl-current-group newsgroup)
 372         (setq nnbabyl-status-string "No such group in file")
 373         nil)))
 374
 375 (defun nnbabyl-article-string (article)
 376   (concat "\nX-Gnus-Newsgroup: " nnbabyl-current-group ":"
 377           (int-to-string article) " "))
 378
 379 (defun nnbabyl-insert-lines ()
 380   "Insert how many lines and chars there are in the body of the mail."
 381   (let (lines chars)
 382     (save-excursion
 383       (goto-char (point-min))
 384       (if (search-forward "\n\n" nil t)
 385           (progn
 386             ;; There may be an EOOH line here...
 387             (if (looking-at "\\*\\*\\* EOOH \\*\\*\\*")
 388                 (search-forward "\n\n" nil t))
 389             (setq chars (- (point-max) (point)))
 390             (setq lines (- (count-lines (point) (point-max)) 1))
 391             ;; Move back to the end of the headers.
 392             (goto-char (point-min))
 393             (search-forward "\n\n" nil t)
 394             (forward-char -1)
 395             (save-excursion
 396               (if (re-search-backward "^Lines: " nil t)
 397                   (delete-region (point) (progn (forward-line 1) (point)))))
 398             (insert (format "Lines: %d\n" lines))
 399             chars)))))
 400
 401 (defun nnbabyl-save-mail ()
 402   ;; Called narrowed to an article.
 403   (let ((group-art (nreverse (nnmail-article-group 'nnbabyl-active-number))))
 404     (nnbabyl-insert-lines)
 405     (nnmail-insert-xref group-art)
 406     (nnbabyl-insert-newsgroup-line group-art)
 407     (run-hooks 'nnbabyl-prepare-save-mail-hook)
 408     group-art))
 409
 410 (defun nnbabyl-insert-newsgroup-line (group-art)
 411   (save-excursion
 412     (goto-char (point-min))
 413     ;; If there is a C-l at the beginning of the narrowed region, this
 414     ;; isn't really a "save", but rather a "scan".
 415     (while (looking-at "From ")
 416       (replace-match "Mail-from: From " t t)
 417       (forward-line 1))
 418     (goto-char (point-min))
 419     (or (looking-at "\^L")
 420         (save-excursion
 421           (insert "\^L\n0, unseen,,\n*** EOOH ***\n")
 422           (goto-char (point-max))
 423           (insert "\^_\n")))
 424     (if (search-forward "\n\n" nil t)
 425         (progn
 426           (forward-char -1)
 427           (while group-art
 428             (insert (format "X-Gnus-Newsgroup: %s:%d   %s\n"
 429                             (car (car group-art)) (cdr (car group-art))
 430                             (current-time-string)))
 431             (setq group-art (cdr group-art)))))
 432     t))
 433
 434 (defun nnbabyl-active-number (group)
 435   ;; Find the next article number in GROUP.
 436   (let ((active (car (cdr (assoc group nnbabyl-group-alist)))))
 437     (setcdr active (1+ (cdr active)))
 438     (cdr active)))
 439
 440 (defun nnbabyl-read-mbox ()
 441   (nnbabyl-request-list)
 442   (setq nnbabyl-group-alist (nnmail-get-active))
 443   (or (file-exists-p nnbabyl-mbox-file)
 444       (save-excursion
 445         (set-buffer (setq nnbabyl-mbox-buffer
 446                           (create-file-buffer nnbabyl-mbox-file)))
 447         (setq buffer-file-name nnbabyl-mbox-file)
 448         (insert "BABYL OPTIONS:\n\n\^_")
 449         (write-region (point-min) (point-max) nnbabyl-mbox-file t 'nomesg)))
 450
 451   (if (and nnbabyl-mbox-buffer
 452            (buffer-name nnbabyl-mbox-buffer)
 453            (save-excursion
 454              (set-buffer nnbabyl-mbox-buffer)
 455              (= (buffer-size) (nth 7 (file-attributes nnbabyl-mbox-file)))))
 456       ()
 457     (save-excursion
 458       (let ((delim (concat "^" nnbabyl-mail-delimiter))
 459             (buf (or (get-buffer (file-name-nondirectory nnbabyl-mbox-file))
 460                      (create-file-buffer nnbabyl-mbox-file)))
 461             start end)
 462         (set-buffer (setq nnbabyl-mbox-buffer buf))
 463         (buffer-disable-undo (current-buffer))
 464
 465         (insert-file-contents nnbabyl-mbox-file)
 466         (setq buffer-file-name nnbabyl-mbox-file)
 467         (set-buffer-modified-p nil)
 468
 469         (goto-char (point-min))
 470         (while (re-search-forward delim nil t)
 471           (setq start (match-beginning 0))
 472           (if (and
 473                (save-excursion (re-search-forward delim nil t))
 474                (not (search-forward
 475                      "\nX-Gnus-Newsgroup: "
 476                      (save-excursion
 477                        (setq end (or (and (re-search-forward delim nil t)
 478                                           (match-beginning 0))
 479                                      (point-max)))) t)))
 480               (progn
 481                 (goto-char end)
 482                 (save-excursion
 483                   (save-restriction
 484                     (goto-char start)
 485                     (narrow-to-region (1+ start) end)
 486                     (nnbabyl-save-mail))))))
 487         (and (buffer-modified-p (current-buffer)) (save-buffer))
 488         (nnmail-save-active nnbabyl-group-alist nnbabyl-active-file)))))
 489
 490 (defun nnbabyl-get-new-mail (&optional group)
 491   "Read new incoming mail."
 492   (let ((spools (nnmail-get-spool-files group))
 493         incoming incomings)
 494     (nnbabyl-read-mbox)
 495     (if (or (not nnbabyl-get-new-mail) (not nnmail-spool-file))
 496         ()
 497       ;; We go through all the existing spool files and split the
 498       ;; mail from each.
 499       (while spools
 500         (and
 501          (file-exists-p (car spools))
 502          (> (nth 7 (file-attributes (car spools))) 0)
 503          (progn
 504            (and gnus-verbose-backends
 505                 (message "nnbabyl: Reading incoming mail..."))
 506            (setq incoming
 507                  (nnmail-move-inbox
 508                   (car spools) (concat nnbabyl-mbox-file "-Incoming")))
 509            (setq incomings (cons incoming incomings))
 510            (save-excursion
 511              (let ((in-buf (nnmail-split-incoming
 512                             incoming 'nnbabyl-save-mail t group)))
 513                (set-buffer in-buf)
 514                (goto-char (point-min))
 515                (while (search-forward "\n\^_\n" nil t)
 516                  (delete-char -1))
 517                (set-buffer nnbabyl-mbox-buffer)
 518                (goto-char (point-max))
 519                (search-backward "\n\^_" nil t)
 520                (goto-char (match-end 0))
 521                (insert-buffer-substring in-buf)
 522                (kill-buffer in-buf)))))
 523         (setq spools (cdr spools)))
 524       ;; If we did indeed read any incoming spools, we save all info.
 525       (and (buffer-modified-p nnbabyl-mbox-buffer)
 526            (save-excursion
 527              (nnmail-save-active nnbabyl-group-alist nnbabyl-active-file)
 528              (set-buffer nnbabyl-mbox-buffer)
 529              (save-buffer)))
 530       (while incomings
 531         (and nnmail-delete-incoming
 532              (file-writable-p incoming)
 533              (delete-file incoming))
 534         (setq incomings (cdr incomings))))))
 535
 536 (provide 'nnbabyl)
 537
 538 ;;; nnbabyl.el ends here