Add to git.
[monolith.git] / chat / lib.c
1 /* Monolith chat library.
2  * - by Richard W.M. Jones <rich@annexia.org>
3  *
4  * This library is free software; you can redistribute it and/or
5  * modify it under the terms of the GNU Library General Public
6  * License as published by the Free Software Foundation; either
7  * version 2 of the License, or (at your option) any later version.
8  *
9  * This library is distributed in the hope that it will be useful,
10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
12  * Library General Public License for more details.
13  *
14  * You should have received a copy of the GNU Library General Public
15  * License along with this library; if not, write to the Free
16  * Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
17  *
18  * $Id: lib.c,v 1.3 2003/02/22 15:34:27 rich Exp $
19  */
20
21 #include "config.h"
22
23 #include <stdio.h>
24 #include <stdlib.h>
25
26 #include <pool.h>
27 #include <pthr_dbi.h>
28 #include <pthr_iolib.h>
29
30 #include <monolith.h>
31
32 void
33 chat_fill_buffer (io_handle io, ml_session session, const char *conninfo)
34 {
35   int userid;
36   int bufsize;
37   db_handle dbh;
38   st_handle sth;
39   int i;
40
41   /* Calculate the size of the buffer. Anonymous users always get
42    * the default, which is 4096 bytes. For other users, we go to the
43    * database. (We always need to go to the database to cope with the
44    * case of multiple rws instances ... doh!)
45    */
46   userid = ml_session_userid (session);
47   if (userid == 0)
48     bufsize = 4096;
49   else
50     {
51       dbh = get_db_handle (conninfo, DBI_THROW_ERRORS);
52
53       sth = st_prepare_cached
54         (dbh,
55          "select fill_buffer from ml_chat_userprefs where userid = ?",
56          DBI_INT);
57       st_execute (sth, userid);
58
59       st_bind (sth, 0, bufsize, DBI_INT);
60
61       if (!st_fetch (sth)) bufsize = 4096; /* Default. */
62
63       put_db_handle (dbh);
64     }
65
66   /* Send the fill buffer back to the user. */
67   for (i = 0; i < bufsize; ++i)
68     io_fputc (' ', io);
69
70   io_fflush (io);
71 }