2c29861e9825d5512011b0bfb37d86c9f5406b2a
[elisp/gnus.git-] / lisp / nnmbox.el
1 ;;; nnmbox.el --- mail mbox access for Gnus
2
3 ;; Copyright (C) 1995, 1996, 1997, 1998, 1999, 2000
4 ;;      Free Software Foundation, Inc.
5
6 ;; Author: Lars Magne Ingebrigtsen <larsi@gnus.org>
7 ;;      Masanobu UMEDA <umerin@flab.flab.fujitsu.junet>
8 ;; Keywords: news, mail
9
10 ;; This file is part of GNU Emacs.
11
12 ;; GNU Emacs is free software; you can redistribute it and/or modify
13 ;; it under the terms of the GNU General Public License as published by
14 ;; the Free Software Foundation; either version 2, or (at your option)
15 ;; any later version.
16
17 ;; You should have received a copy of the GNU General Public License
18 ;; along with GNU Emacs; see the file COPYING.  If not, write to the
19 ;; Free Software Foundation, Inc., 59 Temple Place - Suite 330,
20 ;; Boston, MA 02111-1307, USA.
21
22 ;;; Commentary:
23
24 ;; For an overview of what the interface functions do, please see the
25 ;; Gnus sources.
26
27 ;;; Code:
28
29 (eval-when-compile (require 'cl))
30 (eval-when-compile (require 'static))
31
32 (require 'nnheader)
33 (require 'message)
34 (require 'nnmail)
35 (require 'nnoo)
36 (require 'gnus-range)
37
38 (nnoo-declare nnmbox)
39
40 (defvoo nnmbox-mbox-file (expand-file-name "~/mbox")
41   "The name of the mail box file in the user's home directory.")
42
43 (defvoo nnmbox-active-file (expand-file-name "~/.mbox-active")
44   "The name of the active file for the mail box.")
45
46 (defvoo nnmbox-get-new-mail t
47   "If non-nil, nnmbox will check the incoming mail file and split the mail.")
48
49 (defvoo nnmbox-prepare-save-mail-hook nil
50   "Hook run narrowed to an article before saving.")
51
52 \f
53
54 (defconst nnmbox-version "nnmbox 1.0"
55   "nnmbox version.")
56
57 (defvoo nnmbox-current-group nil
58   "Current nnmbox news group directory.")
59
60 (defconst nnmbox-mbox-buffer nil)
61
62 (defvoo nnmbox-status-string "")
63
64 (defvoo nnmbox-group-alist nil)
65 (defvoo nnmbox-active-timestamp nil)
66
67 (defvoo nnmbox-file-coding-system 'binary)
68 (defvoo nnmbox-file-coding-system-for-write nil)
69 (defvoo nnmbox-active-file-coding-system 'binary)
70 (defvoo nnmbox-active-file-coding-system-for-write nil)
71
72 (defvar nnmbox-group-building-active-articles nil)
73 (defvar nnmbox-group-active-articles nil)
74 \f
75
76 ;;; Interface functions
77
78 (nnoo-define-basics nnmbox)
79
80 (deffoo nnmbox-retrieve-headers (sequence &optional newsgroup server fetch-old)
81   (save-excursion
82     (set-buffer nntp-server-buffer)
83     (erase-buffer)
84     (let ((number (length sequence))
85           (count 0)
86           article start stop)
87       (nnmbox-possibly-change-newsgroup newsgroup server)
88       (while sequence
89         (setq article (car sequence))
90         (set-buffer nnmbox-mbox-buffer)
91         (when (nnmbox-find-article article)
92           (setq start
93                 (save-excursion
94                   (re-search-backward
95                    (concat "^" message-unix-mail-delimiter) nil t)
96                   (point)))
97           (search-forward "\n\n" nil t)
98           (setq stop (1- (point)))
99           (set-buffer nntp-server-buffer)
100           (insert (format "221 %d Article retrieved.\n" article))
101           (insert-buffer-substring nnmbox-mbox-buffer start stop)
102           (goto-char (point-max))
103           (insert ".\n"))
104         (setq sequence (cdr sequence))
105         (setq count (1+ count))
106         (and (numberp nnmail-large-newsgroup)
107              (> number nnmail-large-newsgroup)
108              (zerop (% count 20))
109              (nnheader-message 5 "nnmbox: Receiving headers... %d%%"
110                                (/ (* count 100) number))))
111
112       (and (numberp nnmail-large-newsgroup)
113            (> number nnmail-large-newsgroup)
114            (nnheader-message 5 "nnmbox: Receiving headers...done"))
115
116       (set-buffer nntp-server-buffer)
117       (nnheader-fold-continuation-lines)
118       'headers)))
119
120 (deffoo nnmbox-open-server (server &optional defs)
121   (nnoo-change-server 'nnmbox server defs)
122   (nnmbox-create-mbox)
123   (cond
124    ((not (file-exists-p nnmbox-mbox-file))
125     (nnmbox-close-server)
126     (nnheader-report 'nnmbox "No such file: %s" nnmbox-mbox-file))
127    ((file-directory-p nnmbox-mbox-file)
128     (nnmbox-close-server)
129     (nnheader-report 'nnmbox "Not a regular file: %s" nnmbox-mbox-file))
130    (t
131     (nnheader-report 'nnmbox "Opened server %s using mbox %s" server
132                      nnmbox-mbox-file)
133     t)))
134
135 (deffoo nnmbox-close-server (&optional server)
136   (when (and nnmbox-mbox-buffer
137              (buffer-name nnmbox-mbox-buffer))
138     (kill-buffer nnmbox-mbox-buffer))
139   (nnoo-close-server 'nnmbox server)
140   t)
141
142 (deffoo nnmbox-server-opened (&optional server)
143   (and (nnoo-current-server-p 'nnmbox server)
144        nnmbox-mbox-buffer
145        (buffer-name nnmbox-mbox-buffer)
146        nntp-server-buffer
147        (buffer-name nntp-server-buffer)))
148
149 (deffoo nnmbox-request-article (article &optional newsgroup server buffer)
150   (nnmbox-possibly-change-newsgroup newsgroup server)
151   (save-excursion
152     (set-buffer nnmbox-mbox-buffer)
153     (when (nnmbox-find-article article)
154       (let (start stop)
155         (re-search-backward (concat "^" message-unix-mail-delimiter) nil t)
156         (setq start (point))
157         (forward-line 1)
158         (or (and (re-search-forward
159                   (concat "^" message-unix-mail-delimiter) nil t)
160                  (forward-line -1))
161             (goto-char (point-max)))
162         (setq stop (point))
163         (let ((nntp-server-buffer (or buffer nntp-server-buffer)))
164           (set-buffer nntp-server-buffer)
165           (erase-buffer)
166           (insert-buffer-substring nnmbox-mbox-buffer start stop)
167           (goto-char (point-min))
168           (while (looking-at "From ")
169             (delete-char 5)
170             (insert "X-From-Line: ")
171             (forward-line 1))
172           (if (numberp article)
173               (cons nnmbox-current-group article)
174             (nnmbox-article-group-number nil)))))))
175
176 (deffoo nnmbox-request-group (group &optional server dont-check)
177   (nnmbox-possibly-change-newsgroup nil server)
178   (let ((active (cadr (assoc group nnmbox-group-alist))))
179     (cond
180      ((or (null active)
181           (null (nnmbox-possibly-change-newsgroup group server)))
182       (nnheader-report 'nnmbox "No such group: %s" group))
183      (dont-check
184       (nnheader-report 'nnmbox "Selected group %s" group)
185       (nnheader-insert ""))
186      (t
187       (nnheader-report 'nnmbox "Selected group %s" group)
188       (nnheader-insert "211 %d %d %d %s\n"
189                        (1+ (- (cdr active) (car active)))
190                        (car active) (cdr active) group)))))
191
192 (static-if (boundp 'MULE)
193     (defun nnmbox-save-buffer ()
194       (let ((output-coding-system
195              (or nnmbox-file-coding-system-for-write
196                  nnmbox-file-coding-system)))
197         (save-buffer)))
198   (defun nnmbox-save-buffer ()
199     (let ((coding-system-for-write
200            (or nnmbox-file-coding-system-for-write
201                nnmbox-file-coding-system)))
202       (save-buffer)))
203   )
204
205 (defun nnmbox-save-active (group-alist active-file)
206   (let ((nnmail-active-file-coding-system
207          (or nnmbox-active-file-coding-system-for-write
208              nnmbox-active-file-coding-system)))
209     (nnmail-save-active group-alist active-file)))
210
211 (deffoo nnmbox-request-scan (&optional group server)
212   (nnmbox-possibly-change-newsgroup group server)
213   (nnmbox-read-mbox)
214   (nnmail-get-new-mail
215    'nnmbox
216    (lambda ()
217      (save-excursion
218        (set-buffer nnmbox-mbox-buffer)
219        (nnmbox-save-buffer)))
220    (file-name-directory nnmbox-mbox-file)
221    group
222    (lambda ()
223      (save-excursion
224        (let ((in-buf (current-buffer)))
225          (set-buffer nnmbox-mbox-buffer)
226          (goto-char (point-max))
227          (insert-buffer-substring in-buf)))
228      (nnmbox-save-active nnmbox-group-alist nnmbox-active-file))))
229
230 (deffoo nnmbox-close-group (group &optional server)
231   t)
232
233 (deffoo nnmbox-request-create-group (group &optional server args)
234   (nnmail-activate 'nnmbox)
235   (unless (assoc group nnmbox-group-alist)
236     (push (list group (cons 1 0))
237           nnmbox-group-alist)
238     (nnmbox-save-active nnmbox-group-alist nnmbox-active-file))
239   t)
240
241 (deffoo nnmbox-request-list (&optional server)
242   (save-excursion
243     (let ((nnmail-file-coding-system
244            nnmbox-active-file-coding-system))
245       (nnmail-find-file nnmbox-active-file))
246     (setq nnmbox-group-alist (nnmail-get-active))
247     t))
248
249 (deffoo nnmbox-request-newgroups (date &optional server)
250   (nnmbox-request-list server))
251
252 (deffoo nnmbox-request-list-newsgroups (&optional server)
253   (nnheader-report 'nnmbox "LIST NEWSGROUPS is not implemented."))
254
255 (deffoo nnmbox-request-expire-articles
256     (articles newsgroup &optional server force)
257   (nnmbox-possibly-change-newsgroup newsgroup server)
258   (let* ((is-old t)
259          rest)
260     (nnmail-activate 'nnmbox)
261
262     (save-excursion
263       (set-buffer nnmbox-mbox-buffer)
264       (while (and articles is-old)
265         (when (nnmbox-find-article (car articles))
266           (if (setq is-old
267                     (nnmail-expired-article-p
268                      newsgroup
269                      (buffer-substring
270                       (point) (progn (end-of-line) (point))) force))
271               (progn
272                 (unless (eq nnmail-expiry-target 'delete)
273                   (with-temp-buffer
274                     (nnmbox-request-article (car articles)
275                                             newsgroup server
276                                             (current-buffer))
277                     (let ((nnml-current-directory nil))
278                       (nnmail-expiry-target-group
279                        nnmail-expiry-target newsgroup))))
280                 (nnheader-message 5 "Deleting article %d in %s..."
281                                   (car articles) newsgroup)
282                 (nnmbox-delete-mail))
283             (push (car articles) rest)))
284         (setq articles (cdr articles)))
285       (nnmbox-save-buffer)
286       ;; Find the lowest active article in this group.
287       (let ((active (nth 1 (assoc newsgroup nnmbox-group-alist))))
288         (while (and (not (nnmbox-find-article (car active)))
289                     (<= (car active) (cdr active)))
290           (setcar active (1+ (car active)))))
291       (nnmbox-save-active nnmbox-group-alist nnmbox-active-file)
292       (nconc rest articles))))
293
294 (deffoo nnmbox-request-move-article
295     (article group server accept-form &optional last)
296   (let ((buf (get-buffer-create " *nnmbox move*"))
297         result)
298     (and
299      (nnmbox-request-article article group server)
300      (save-excursion
301        (set-buffer buf)
302        (erase-buffer)
303        (insert-buffer-substring nntp-server-buffer)
304        (goto-char (point-min))
305        (while (re-search-forward
306                "^X-Gnus-Newsgroup:"
307                (save-excursion (search-forward "\n\n" nil t) (point)) t)
308          (delete-region (progn (beginning-of-line) (point))
309                         (progn (forward-line 1) (point))))
310        (setq result (eval accept-form))
311        (kill-buffer buf)
312        result)
313      (save-excursion
314        (nnmbox-possibly-change-newsgroup group server)
315        (set-buffer nnmbox-mbox-buffer)
316        (when (nnmbox-find-article article)
317          (nnmbox-delete-mail))
318        (and last (nnmbox-save-buffer))))
319     result))
320
321 (deffoo nnmbox-request-accept-article (group &optional server last)
322   (nnmbox-possibly-change-newsgroup group server)
323   (nnmail-check-syntax)
324   (let ((buf (current-buffer))
325         result)
326     (goto-char (point-min))
327     ;; The From line may have been quoted by movemail.
328     (when (looking-at (concat ">" message-unix-mail-delimiter))
329       (delete-char 1))
330     (if (looking-at "X-From-Line: ")
331         (replace-match "From ")
332       (insert "From nobody " (current-time-string) "\n"))
333     (and
334      (nnmail-activate 'nnmbox)
335      (progn
336        (set-buffer buf)
337        (goto-char (point-min))
338        (search-forward "\n\n" nil t)
339        (forward-line -1)
340        (while (re-search-backward "^X-Gnus-Newsgroup: " nil t)
341          (delete-region (point) (progn (forward-line 1) (point))))
342        (when nnmail-cache-accepted-message-ids
343          (nnmail-cache-insert (nnmail-fetch-field "message-id")))
344        (setq result (if (stringp group)
345                         (list (cons group (nnmbox-active-number group)))
346                       (nnmail-article-group 'nnmbox-active-number)))
347        (if (and (null result)
348                 (yes-or-no-p "Moved to `junk' group; delete article? "))
349            (setq result 'junk)
350          (setq result (car (nnmbox-save-mail result)))))
351      (save-excursion
352        (set-buffer nnmbox-mbox-buffer)
353        (goto-char (point-max))
354        (insert-buffer-substring buf)
355        (when last
356          (when nnmail-cache-accepted-message-ids
357            (nnmail-cache-close))
358          (nnmbox-save-active nnmbox-group-alist nnmbox-active-file)
359          (nnmbox-save-buffer))))
360     result))
361
362 (deffoo nnmbox-request-replace-article (article group buffer)
363   (nnmbox-possibly-change-newsgroup group)
364   (save-excursion
365     (set-buffer nnmbox-mbox-buffer)
366     (if (not (nnmbox-find-article article))
367         nil
368       (nnmbox-delete-mail t t)
369       (insert-buffer-substring buffer)
370       (nnmbox-save-buffer)
371       t)))
372
373 (deffoo nnmbox-request-delete-group (group &optional force server)
374   (nnmbox-possibly-change-newsgroup group server)
375   ;; Delete all articles in GROUP.
376   (if (not force)
377       ()                                ; Don't delete the articles.
378     (save-excursion
379       (set-buffer nnmbox-mbox-buffer)
380       (goto-char (point-min))
381       ;; Delete all articles in this group.
382       (let ((ident (concat "\nX-Gnus-Newsgroup: " nnmbox-current-group ":"))
383             found)
384         (while (search-forward ident nil t)
385           (setq found t)
386           (nnmbox-delete-mail))
387         (when found
388           (nnmbox-save-buffer)))))
389   ;; Remove the group from all structures.
390   (setq nnmbox-group-alist
391         (delq (assoc group nnmbox-group-alist) nnmbox-group-alist)
392         nnmbox-current-group nil)
393   ;; Save the active file.
394   (nnmbox-save-active nnmbox-group-alist nnmbox-active-file)
395   t)
396
397 (deffoo nnmbox-request-rename-group (group new-name &optional server)
398   (nnmbox-possibly-change-newsgroup group server)
399   (save-excursion
400     (set-buffer nnmbox-mbox-buffer)
401     (goto-char (point-min))
402     (let ((ident (concat "\nX-Gnus-Newsgroup: " nnmbox-current-group ":"))
403           (new-ident (concat "\nX-Gnus-Newsgroup: " new-name ":"))
404           found)
405       (while (search-forward ident nil t)
406         (replace-match new-ident t t)
407         (setq found t))
408       (when found
409         (nnmbox-save-buffer))))
410   (let ((entry (assoc group nnmbox-group-active-articles)))
411     (when entry
412       (setcar entry new-name)))
413   (let ((entry (assoc group nnmbox-group-alist)))
414     (when entry
415       (setcar entry new-name))
416     (setq nnmbox-current-group nil)
417     ;; Save the new group alist.
418     (nnmbox-save-active nnmbox-group-alist nnmbox-active-file)
419     t))
420
421 \f
422 ;;; Internal functions.
423
424 ;; If FORCE, delete article no matter how many X-Gnus-Newsgroup
425 ;; headers there are.  If LEAVE-DELIM, don't delete the Unix mbox
426 ;; delimiter line.
427 (defun nnmbox-delete-mail (&optional force leave-delim)
428   ;; Delete the current X-Gnus-Newsgroup line.
429   ;; First delete record of active article, unless the article is being
430   ;; replaced, indicated by FORCE being non-nil.
431   (if (not force)
432       (nnmbox-record-deleted-article (nnmbox-article-group-number t)))
433   (or force
434       (delete-region
435        (progn (beginning-of-line) (point))
436        (progn (forward-line 1) (point))))
437   ;; Beginning of the article.
438   (save-excursion
439     (save-restriction
440       (narrow-to-region
441        (save-excursion
442          (re-search-backward (concat "^" message-unix-mail-delimiter) nil t)
443          (if leave-delim (progn (forward-line 1) (point))
444            (match-beginning 0)))
445        (progn
446          (forward-line 1)
447          (or (and (re-search-forward (concat "^" message-unix-mail-delimiter)
448                                      nil t)
449                   (if (and (not (bobp)) leave-delim)
450                       (progn (forward-line -2) (point))
451                     (match-beginning 0)))
452              (point-max))))
453       (goto-char (point-min))
454       ;; Only delete the article if no other group owns it as well.
455       (when (or force (not (re-search-forward "^X-Gnus-Newsgroup: " nil t)))
456         (delete-region (point-min) (point-max))))))
457
458 (defun nnmbox-possibly-change-newsgroup (newsgroup &optional server)
459   (when (and server
460              (not (nnmbox-server-opened server)))
461     (nnmbox-open-server server))
462   (when (or (not nnmbox-mbox-buffer)
463             (not (buffer-name nnmbox-mbox-buffer)))
464     (nnmbox-read-mbox))
465   (when (not nnmbox-group-alist)
466     (nnmail-activate 'nnmbox))
467   (if newsgroup
468       (when (assoc newsgroup nnmbox-group-alist)
469         (setq nnmbox-current-group newsgroup))
470     t))
471
472 (defun nnmbox-article-string (article)
473   (if (numberp article)
474       (concat "\nX-Gnus-Newsgroup: " nnmbox-current-group ":"
475               (int-to-string article) " ")
476     (concat "\nMessage-ID: " article)))
477
478 (defun nnmbox-article-group-number (this-line)
479   (save-excursion
480     (if this-line
481         (beginning-of-line)
482       (goto-char (point-min)))
483     (when (re-search-forward "^X-Gnus-Newsgroup: +\\([^:]+\\):\\([0-9]+\\) "
484                              nil t)
485       (cons (buffer-substring (match-beginning 1) (match-end 1))
486             (string-to-int
487              (buffer-substring (match-beginning 2) (match-end 2)))))))
488
489 (defun nnmbox-in-header-p (pos)
490   "Return non-nil if POS is in the header of an article."
491   (save-excursion
492     (goto-char pos)
493     (re-search-backward (concat "^" message-unix-mail-delimiter) nil t)
494     (search-forward "\n\n" nil t)
495     (< pos (point))))
496
497 (defun nnmbox-find-article (article)
498   "Leaves point on the relevant X-Gnus-Newsgroup line if found."
499   ;; Check that article is in the active range first, to avoid an
500   ;; expensive exhaustive search if it isn't.
501   (if (and (numberp article)
502            (not (nnmbox-is-article-active-p article)))
503       nil
504     (let ((art-string (nnmbox-article-string article))
505           (found nil))
506       ;; There is the possibility that the X-Gnus-Newsgroup line appears
507       ;; in the body of an article (for instance, if an article has been
508       ;; forwarded from someone using Gnus as their mailer), so check
509       ;; that the line is actually part of the article header.
510       (or (and (search-forward art-string nil t)
511                (nnmbox-in-header-p (point)))
512           (progn
513             (goto-char (point-min))
514             (while (not found)
515               (setq found (and (search-forward art-string nil t)
516                                (nnmbox-in-header-p (point)))))
517             found)))))
518
519 (defun nnmbox-record-active-article (group-art)
520   (let* ((group (car group-art))
521          (article (cdr group-art))
522          (entry
523           (or (assoc group nnmbox-group-active-articles)
524               (progn
525                 (push (list group)
526                       nnmbox-group-active-articles)
527                 (car nnmbox-group-active-articles)))))
528     ;; add article to index, either by building complete list
529     ;; in reverse order, or as a list of ranges.
530     (if (not nnmbox-group-building-active-articles)
531         (setcdr entry (gnus-add-to-range (cdr entry) (list article)))
532       (when (memq article (cdr entry))
533         (switch-to-buffer nnmbox-mbox-buffer)
534         (error "Article %s:%d already exists!" group article))
535       (when (and (cadr entry) (< article (cadr entry)))
536         (switch-to-buffer nnmbox-mbox-buffer)
537         (error "Article %s:%d out of order" group article))
538       (setcdr entry (cons article (cdr entry))))))
539
540 (defun nnmbox-record-deleted-article (group-art)
541   (let* ((group (car group-art))
542          (article (cdr group-art))
543          (entry
544           (or (assoc group nnmbox-group-active-articles)
545               (progn
546                 (push (list group)
547                       nnmbox-group-active-articles)
548                 (car nnmbox-group-active-articles)))))
549     ;; remove article from index
550     (setcdr entry (gnus-remove-from-range (cdr entry) (list article)))))
551
552 (defun nnmbox-is-article-active-p (article)
553   (gnus-member-of-range
554    article
555    (cdr (assoc nnmbox-current-group
556                nnmbox-group-active-articles))))
557
558 (defun nnmbox-save-mail (group-art)
559   "Called narrowed to an article."
560   (let ((delim (concat "^" message-unix-mail-delimiter)))
561     (goto-char (point-min))
562     ;; This might come from somewhere else.
563     (unless (looking-at delim)
564       (insert "From nobody " (current-time-string) "\n")
565       (goto-char (point-min)))
566     ;; Quote all "From " lines in the article.
567     (forward-line 1)
568     (while (re-search-forward delim nil t)
569       (beginning-of-line)
570       (insert "> "))
571     (nnmail-insert-lines)
572     (nnmail-insert-xref group-art)
573     (nnmbox-insert-newsgroup-line group-art)
574     (let ((alist group-art))
575       (while alist
576         (nnmbox-record-active-article (car alist))
577         (setq alist (cdr alist))))
578     (run-hooks 'nnmail-prepare-save-mail-hook)
579     (run-hooks 'nnmbox-prepare-save-mail-hook)
580     group-art))
581
582 (defun nnmbox-insert-newsgroup-line (group-art)
583   (save-excursion
584     (goto-char (point-min))
585     (when (search-forward "\n\n" nil t)
586       (forward-char -1)
587       (while group-art
588         (insert (format "X-Gnus-Newsgroup: %s:%d   %s\n"
589                         (caar group-art) (cdar group-art)
590                         (current-time-string)))
591         (setq group-art (cdr group-art))))
592     t))
593
594 (defun nnmbox-active-number (group)
595   ;; Find the next article number in GROUP.
596   (let ((active (cadr (assoc group nnmbox-group-alist))))
597     (if active
598         (setcdr active (1+ (cdr active)))
599       ;; This group is new, so we create a new entry for it.
600       ;; This might be a bit naughty... creating groups on the drop of
601       ;; a hat, but I don't know...
602       (push (list group (setq active (cons 1 1)))
603             nnmbox-group-alist))
604     (cdr active)))
605
606 (defun nnmbox-create-mbox ()
607   (when (not (file-exists-p nnmbox-mbox-file))
608     (let ((nnmail-file-coding-system
609            (or nnmbox-file-coding-system-for-write
610                nnmbox-file-coding-system)))
611       (nnmail-write-region 1 1 nnmbox-mbox-file t 'nomesg))))
612
613 (defun nnmbox-read-mbox ()
614   (nnmail-activate 'nnmbox)
615   (nnmbox-create-mbox)
616   (if (and nnmbox-mbox-buffer
617            (buffer-name nnmbox-mbox-buffer)
618            (save-excursion
619              (set-buffer nnmbox-mbox-buffer)
620              (= (buffer-size) (nnheader-file-size nnmbox-mbox-file))))
621       ()
622     (save-excursion
623       (let ((delim (concat "^" message-unix-mail-delimiter))
624             (alist nnmbox-group-alist)
625             (nnmbox-group-building-active-articles t)
626             start end end-header number)
627         (set-buffer (setq nnmbox-mbox-buffer
628                           (let ((nnheader-file-coding-system
629                                  nnmbox-file-coding-system))
630                             (nnheader-find-file-noselect
631                              nnmbox-mbox-file t t))))
632         (buffer-disable-undo)
633
634         ;; Go through the group alist and compare against the mbox file.
635         (while alist
636           (goto-char (point-max))
637           (when (and (re-search-backward
638                       (format "^X-Gnus-Newsgroup: %s:\\([0-9]+\\) "
639                               (caar alist)) nil t)
640                      (> (setq number
641                               (string-to-number
642                                (buffer-substring
643                                 (match-beginning 1) (match-end 1))))
644                         (cdadar alist)))
645             (setcdr (cadar alist) number))
646           (setq alist (cdr alist)))
647
648         ;; Examine all articles for our private X-Gnus-Newsgroup
649         ;; headers.  This is done primarily as a consistency check, but
650         ;; it is convenient for building an index of the articles
651         ;; present, to avoid costly searches for missing articles
652         ;; (eg. when expiring articles).
653         (goto-char (point-min))
654         (setq nnmbox-group-active-articles nil)
655         (while (re-search-forward delim nil t)
656           (setq start (match-beginning 0))
657           (save-excursion
658             (search-forward "\n\n" nil t)
659             (setq end-header (point))
660             (setq end (or (and
661                            (re-search-forward delim nil t)
662                            (match-beginning 0))
663                           (point-max))))
664           (if (search-forward "\nX-Gnus-Newsgroup: " end-header t)
665               ;; Build a list of articles in each group, remembering
666               ;; that each article may be in more than one group.
667               (progn
668                 (nnmbox-record-active-article (nnmbox-article-group-number t))
669                 (while (search-forward "\nX-Gnus-Newsgroup: " end-header t)
670                   (nnmbox-record-active-article (nnmbox-article-group-number t))))
671             ;; The article is either new, or for some other reason
672             ;; hasn't got our private headers, so add them now.  The
673             ;; only situation I've encountered when the X-Gnus-Newsgroup
674             ;; header is missing is if the article contains a forwarded
675             ;; message which does contain that header line (earlier
676             ;; versions of Gnus didn't restrict their search to the
677             ;; headers).  In this case, there is an Xref line which
678             ;; provides the relevant information to construct the
679             ;; missing header(s).
680             (save-excursion
681               (save-restriction
682                 (narrow-to-region start end)
683                 (if (re-search-forward "\nXref: [^ ]+" end-header t)
684                     ;; generate headers from Xref:
685                     (let (alist)
686                       (while (re-search-forward " \\([^:]+\\):\\([0-9]+\\)" end-header t)
687                         (push (cons (match-string 1)
688                                     (string-to-int (match-string 2))) alist))
689                       (nnmbox-insert-newsgroup-line alist))
690                   ;; this is really a new article
691                   (nnmbox-save-mail
692                    (nnmail-article-group 'nnmbox-active-number))))))
693           (goto-char end))
694         ;; put article lists in order
695         (setq alist nnmbox-group-active-articles)
696         (while alist
697           (setcdr (car alist) (gnus-compress-sequence (nreverse (cdar alist))))
698           (setq alist (cdr alist)))))))
699
700 (provide 'nnmbox)
701
702 ;;; nnmbox.el ends here