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       (widen)
 344       (narrow-to-region
 345        (save-excursion
 346          (re-search-backward (concat "^" nnbabyl-mail-delimiter) nil t)
 347          (if leave-delim (progn (forward-line 1) (point))
 348            (match-beginning 0)))
 349        (progn
 350          (forward-line 1)
 351          (or (and (re-search-forward (concat "^" nnbabyl-mail-delimiter)
 352                                      nil t)
 353                   (if (and (not (bobp)) leave-delim)
 354                       (progn (forward-line -2) (point))
 355                     (match-beginning 0)))
 356              (point-max))))
 357       (goto-char (point-min))
 358       ;; Only delete the article if no other groups owns it as well.
 359       (if (or force (not (re-search-forward "^X-Gnus-Newsgroup: " nil t)))
 360           (delete-region (point-min) (point-max))))))
 361
 362 (defun nnbabyl-possibly-change-newsgroup (newsgroup)
 363   (if (or (not nnbabyl-mbox-buffer)
 364           (not (buffer-name nnbabyl-mbox-buffer)))
 365       (save-excursion (nnbabyl-read-mbox)))
 366   (or nnbabyl-group-alist
 367       (progn
 368         (nnbabyl-request-list)
 369         (setq nnbabyl-group-alist (nnmail-get-active))))
 370   (if newsgroup
 371       (if (assoc newsgroup nnbabyl-group-alist)
 372           (setq nnbabyl-current-group newsgroup)
 373         (setq nnbabyl-status-string "No such group in file")
 374         nil)))
 375
 376 (defun nnbabyl-article-string (article)
 377   (concat "\nX-Gnus-Newsgroup: " nnbabyl-current-group ":"
 378           (int-to-string article) " "))
 379
 380 (defun nnbabyl-insert-lines ()
 381   "Insert how many lines and chars there are in the body of the mail."
 382   (let (lines chars)
 383     (save-excursion
 384       (goto-char (point-min))
 385       (if (search-forward "\n\n" nil t)
 386           (progn
 387             ;; There may be an EOOH line here...
 388             (if (looking-at "\\*\\*\\* EOOH \\*\\*\\*")
 389                 (search-forward "\n\n" nil t))
 390             (setq chars (- (point-max) (point)))
 391             (setq lines (- (count-lines (point) (point-max)) 1))
 392             ;; Move back to the end of the headers.
 393             (goto-char (point-min))
 394             (search-forward "\n\n" nil t)
 395             (forward-char -1)
 396             (save-excursion
 397               (if (re-search-backward "^Lines: " nil t)
 398                   (delete-region (point) (progn (forward-line 1) (point)))))
 399             (insert (format "Lines: %d\n" lines))
 400             chars)))))
 401
 402 (defun nnbabyl-save-mail ()
 403   ;; Called narrowed to an article.
 404   (let ((group-art (nreverse (nnmail-article-group 'nnbabyl-active-number))))
 405     (nnbabyl-insert-lines)
 406     (nnmail-insert-xref group-art)
 407     (nnbabyl-insert-newsgroup-line group-art)
 408     (run-hooks 'nnbabyl-prepare-save-mail-hook)
 409     group-art))
 410
 411 (defun nnbabyl-insert-newsgroup-line (group-art)
 412   (save-excursion
 413     (goto-char (point-min))
 414     ;; If there is a C-l at the beginning of the narrowed region, this
 415     ;; isn't really a "save", but rather a "scan".
 416     (while (looking-at "From ")
 417       (replace-match "Mail-from: From " t t)
 418       (forward-line 1))
 419     (goto-char (point-min))
 420     (or (looking-at "\^L")
 421         (save-excursion
 422           (insert "\^L\n0, unseen,,\n*** EOOH ***\n")
 423           (goto-char (point-max))
 424           (insert "\^_\n")))
 425     (if (search-forward "\n\n" nil t)
 426         (progn
 427           (forward-char -1)
 428           (while group-art
 429             (insert (format "X-Gnus-Newsgroup: %s:%d   %s\n"
 430                             (car (car group-art)) (cdr (car group-art))
 431                             (current-time-string)))
 432             (setq group-art (cdr group-art)))))
 433     t))
 434
 435 (defun nnbabyl-active-number (group)
 436   ;; Find the next article number in GROUP.
 437   (let ((active (car (cdr (assoc group nnbabyl-group-alist)))))
 438     (setcdr active (1+ (cdr active)))
 439     (cdr active)))
 440
 441 (defun nnbabyl-read-mbox ()
 442   (nnbabyl-request-list)
 443   (setq nnbabyl-group-alist (nnmail-get-active))
 444   (or (file-exists-p nnbabyl-mbox-file)
 445       (save-excursion
 446         (set-buffer (setq nnbabyl-mbox-buffer
 447                           (create-file-buffer nnbabyl-mbox-file)))
 448         (setq buffer-file-name nnbabyl-mbox-file)
 449         (insert "BABYL OPTIONS:\n\n\^_")
 450         (write-region (point-min) (point-max) nnbabyl-mbox-file t 'nomesg)))
 451
 452   (if (and nnbabyl-mbox-buffer
 453            (buffer-name nnbabyl-mbox-buffer)
 454            (save-excursion
 455              (set-buffer nnbabyl-mbox-buffer)
 456              (= (buffer-size) (nth 7 (file-attributes nnbabyl-mbox-file)))))
 457       ()
 458     (save-excursion
 459       (let ((delim (concat "^" nnbabyl-mail-delimiter))
 460             (buf (or (get-buffer (file-name-nondirectory nnbabyl-mbox-file))
 461                      (create-file-buffer nnbabyl-mbox-file)))
 462             start end)
 463         (set-buffer (setq nnbabyl-mbox-buffer buf))
 464         (buffer-disable-undo (current-buffer))
 465
 466         (insert-file-contents nnbabyl-mbox-file)
 467         (setq buffer-file-name nnbabyl-mbox-file)
 468         (set-buffer-modified-p nil)
 469
 470         (goto-char (point-min))
 471         (while (re-search-forward delim nil t)
 472           (setq start (match-beginning 0))
 473           (if (and
 474                (save-excursion (re-search-forward delim nil t))
 475                (not (search-forward
 476                      "\nX-Gnus-Newsgroup: "
 477                      (save-excursion
 478                        (setq end (or (and (re-search-forward delim nil t)
 479                                           (match-beginning 0))
 480                                      (point-max)))) t)))
 481               (progn
 482                 (goto-char end)
 483                 (save-excursion
 484                   (save-restriction
 485                     (goto-char start)
 486                     (narrow-to-region (1+ start) end)
 487                     (nnbabyl-save-mail))))))
 488         (and (buffer-modified-p (current-buffer)) (save-buffer))
 489         (nnmail-save-active nnbabyl-group-alist nnbabyl-active-file)))))
 490
 491 (defun nnbabyl-remove-incoming-delims ()
 492   (goto-char (point-min))
 493   (while (search-forward "\^_" nil t)
 494     (replace-match "?" t t)))
 495
 496 (defun nnbabyl-get-new-mail (&optional group)
 497   "Read new incoming mail."
 498   (let* ((spools (nnmail-get-spool-files group))
 499          (all-spools spools)
 500          incoming incomings)
 501     (nnbabyl-read-mbox)
 502     (if (or (not nnbabyl-get-new-mail) (not nnmail-spool-file))
 503         ()
 504       ;; We go through all the existing spool files and split the
 505       ;; mail from each.
 506       (while spools
 507         (and
 508          (file-exists-p (car spools))
 509          (> (nth 7 (file-attributes (car spools))) 0)
 510          (progn
 511            (and gnus-verbose-backends
 512                 (message "nnbabyl: Reading incoming mail..."))
 513            (setq incoming
 514                  (nnmail-move-inbox
 515                   (car spools) (concat nnbabyl-mbox-file "-Incoming")))
 516            (setq incomings (cons incoming incomings))
 517            (save-excursion
 518              (setq group (nnmail-get-split-group (car spools) group))
 519              (let* ((nnmail-prepare-incoming-hook
 520                      (cons 'nnbabyl-remove-incoming-delims
 521                            nnmail-prepare-incoming-hook))
 522                     in-buf)
 523                (setq in-buf (nnmail-split-incoming
 524                              incoming 'nnbabyl-save-mail t group))
 525                (set-buffer in-buf)
 526                (goto-char (point-min))
 527                (while (search-forward "\n\^_\n" nil t)
 528                  (delete-char -1))
 529                (set-buffer nnbabyl-mbox-buffer)
 530                (goto-char (point-max))
 531                (search-backward "\n\^_" nil t)
 532                (goto-char (match-end 0))
 533                (insert-buffer-substring in-buf)
 534                (kill-buffer in-buf)))))
 535         (setq spools (cdr spools)))
 536       ;; If we did indeed read any incoming spools, we save all info.
 537       (and (buffer-modified-p nnbabyl-mbox-buffer)
 538            (save-excursion
 539              (nnmail-save-active nnbabyl-group-alist nnbabyl-active-file)
 540              (set-buffer nnbabyl-mbox-buffer)
 541              (save-buffer)))
 542       (if incomings (run-hooks 'nnmail-read-incoming-hook))
 543       (while incomings
 544         (and nnmail-delete-incoming
 545              (file-writable-p incoming)
 546              (delete-file incoming))
 547         (setq incomings (cdr incomings))))))
 548
 549 (provide 'nnbabyl)
 550
 551 ;;; nnbabyl.el ends here