www.pipapo.org Git - rxpd/blob - rxpd.h

   1 /*
   2     rxpd.h - regex policy daemon
   3
   4   Copyright (C)
   5     2007,               Christian Thaeter <ct@pipapo.org>
   6
   7   This program is free software; you can redistribute it and/or
   8   modify it under the terms of the GNU General Public License as
   9   published by the Free Software Foundation; either version 2 of the
  10   License, or (at your option) any later version.
  11
  12   This program is distributed in the hope that it will be useful,
  13   but WITHOUT ANY WARRANTY; without even the implied warranty of
  14   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  15   GNU General Public License for more details.
  16
  17   You should have received a copy of the GNU General Public License
  18   along with this program; if not, write to the Free Software
  19   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  20 */
  21 #ifndef RXPD_H
  22 #define RXPD_H
  23
  24 #include "llist.h"
  25 #include "psplay.h"
  26
  27 #include <errno.h>
  28 #include <string.h>
  29 #include <stdlib.h>
  30 #include <stdarg.h>
  31 #include <unistd.h>
  32 #include <regex.h>
  33 #include <sys/stat.h>
  34 #include <sys/time.h>
  35 #include <sys/types.h>
  36 #include <sys/socket.h>
  37 #include <netinet/in.h>
  38 #include <arpa/inet.h>
  39 #include <event.h>
  40
  41 #define RXPD_COMMANDS   \
  42   RXPD_CMD(CHECK)       \
  43   RXPD_CMD(APPEND)      \
  44   RXPD_CMD(PREPEND)     \
  45   RXPD_CMD(REMOVE)      \
  46   RXPD_CMD(REPLACE)     \
  47   RXPD_CMD(LOAD)        \
  48   RXPD_CMD(SAVE)        \
  49   RXPD_CMD(DUMP)        \
  50   RXPD_CMD(LIST)        \
  51   RXPD_CMD(SHUTDOWN)
  52
  53 #define RXPD_CMD(cmd) RXPD_CMD_##cmd,
  54 enum rxpd_cmd_e {RXPD_COMMANDS};
  55 #undef RXPD_CMD
  56
  57 struct rxpd_base;
  58 struct rxpd_file;
  59 struct rxpd_rule;
  60 struct rxpd_socket;
  61 struct rxpd_buffer;
  62 struct rxpd_connection;
  63
  64 struct rxpd_base
  65 {
  66   char* rulesdir;
  67   psplayroot files;
  68
  69   llist sockets_pending;
  70   llist sockets_active;
  71   llist connections_pending;
  72   llist connections_active;
  73 };
  74
  75
  76 struct rxpd_base*
  77 rxpd_init (char* rulesdir);
  78
  79 void
  80 rxpd_destroy (void);
  81
  82
  83
  84 //
  85 struct rxpd_rule
  86 {
  87   llist node;
  88   char* string;
  89   regex_t rx;
  90 };
  91
  92 struct rxpd_rule*
  93 rxpd_rule_new (const char* buf);
  94
  95 void
  96 rxpd_rule_delete (struct rxpd_rule*);
  97
  98
  99
 100 //
 101 struct rxpd_file
 102 {
 103   psplay node;          // key points to basename part of filename
 104   const char* filename; // full filename
 105   //TODO later     struct stat last_stat;
 106   llist rules;
 107 };
 108
 109 struct rxpd_file*
 110 rxpd_file_new (struct rxpd_base* base, const char* filename);
 111
 112 void
 113 rxpd_file_delete (PSplay file);
 114
 115 int
 116 rxpd_file_load (struct rxpd_file* self);
 117
 118 int
 119 rxpd_file_cmp (const void* A, const void* B);
 120
 121
 122 //
 123
 124 struct rxpd_socket
 125 {
 126   llist node;
 127   int fd;
 128   struct event ev;
 129   struct rxpd_base* base;
 130 };
 131
 132
 133 struct rxpd_socket*
 134 rxpd_socket_new_tcp4 (struct rxpd_base* base, const char* addr, unsigned short port);
 135
 136 //struct rxpd_socket*
 137 //rxpd_socket_new_unix (struct rxpd_base* base, const char* name);
 138
 139 void
 140 rxpd_socket_delete (struct rxpd_socket* self);
 141
 142 void
 143 rxpd_socket_accept (int sock, short event, void* ptr);
 144
 145 struct rxpd_socket*
 146 rxpd_socket_schedule (struct rxpd_socket* self);
 147
 148 struct rxpd_socket*
 149 rxpd_socket_suspend (struct rxpd_socket* self);
 150
 151
 152 //
 153
 154 enum rxpd_buffer_state_e
 155   {
 156     RXPD_OK,            // operational
 157     RXPD_EOF,           // connection closed
 158     RXPD_ERROR          // some other error
 159   };
 160
 161 struct rxpd_buffer
 162 {
 163   struct rxpd_connection* conn;
 164   enum rxpd_buffer_state_e state;
 165   char* eol;
 166   char* eob;
 167   char buffer[4096];
 168 };
 169
 170 struct rxpd_buffer*
 171 rxpd_buffer_init (struct rxpd_buffer* self, struct rxpd_connection* conn);
 172
 173 char*
 174 rxpd_buffer_readline (struct rxpd_buffer* self, int again);
 175
 176 inline static enum rxpd_buffer_state_e
 177 rxpd_buffer_state (struct rxpd_buffer* self)
 178 {
 179   return self->state;
 180 }
 181
 182
 183 //
 184 struct rxpd_connection
 185 {
 186   llist node;
 187   int fd;
 188   struct event ev;
 189   struct rxpd_base* base;
 190   struct rxpd_file* file;
 191   llist tmp_list;
 192
 193   struct sockaddr peer_addr;
 194
 195   struct rxpd_buffer in;
 196   struct rxpd_buffer out;
 197 };
 198
 199
 200 struct rxpd_connection*
 201 rxpd_connection_new (struct rxpd_base* base, int accept_fd);
 202
 203 void
 204 rxpd_connection_delete (struct rxpd_connection* self);
 205
 206
 207 struct rxpd_connection*
 208 rxpd_connection_schedule (struct rxpd_connection* self);
 209
 210
 211 struct rxpd_connection*
 212 rxpd_connection_suspend (struct rxpd_connection* self);
 213
 214
 215 int
 216 rxpd_connection_readline (struct rxpd_connection* self);
 217
 218 void
 219 rxpd_connection_parse_cmd (int fd, short event, void* ptr);
 220
 221 /* generate prototypes for each defined command */
 222 #define RXPD_CMD(cmd) void rxpd_connection_cmd_##cmd (int fd, short event, void* ptr);
 223 RXPD_COMMANDS
 224 #undef RXPD_CMD
 225
 226
 227 #endif