masqmail: ee2afbf92428 src/queue.c

masqmail

view src/queue.c @ 156:ee2afbf92428

require host_name to be set in config file exit otherwise there is no portable way to determine the hostname (actually the hostname that masqmail should use) thus it must be set by the administrator

author	meillo@marmaro.de
date	Thu, 08 Jul 2010 09:49:05 +0200
parents	83a182793503
children	996b53a50f55

line source

1 /* MasqMail

4 This program is free software; you can redistribute it and/or modify

5 it under the terms of the GNU General Public License as published by

6 the Free Software Foundation; either version 2 of the License, or

7 (at your option) any later version.

9 This program 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

12 GNU General Public License for more details.

14 You should have received a copy of the GNU General Public License

15 along with this program; if not, write to the Free Software

16 Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.

17 */

19 #include <sys/stat.h>

20 #include <glob.h>

22 #include "masqmail.h"

24 static void

25 mix_arr(int *buf, int len)

26 {

27 int i;

29 for (i = 0; i < len; i++)

30 buf[i] = i;

31 for (i = 0; i < len - 1; i++) {

32 int j = (int) ((float) (len - i) * ((float) rand()) / (RAND_MAX + 1.0));

33 int tmp;

35 if (i != j) {

36 tmp = buf[i];

37 buf[i] = buf[j];

38 buf[j] = tmp;

39 }

40 }

41 }

43 GList*

44 read_queue(gboolean do_readdata)

45 {

46 GList *msg_list = NULL;

47 glob_t gl;

48 gchar *pattern;

49 int i, *idx_arr;

51 /* Escaping the question marks prevents them from being

52 interpreted as trigraphs */

53 pattern = g_strdup_printf("%s/input/?????\?-??\?-?\?-H", conf.spool_dir);

54 gl.gl_offs = 0;

55 glob(pattern, 0, NULL, &gl);

57 g_free(pattern);

59 DEBUG(4) {

60 int i;

61 for (i = 0; i < gl.gl_pathc; i++) {

62 debugf("spoolfile: %s\n", gl.gl_pathv[i]);

63 }

64 }

66 idx_arr = g_malloc(sizeof(int) * gl.gl_pathc);

67 mix_arr(idx_arr, gl.gl_pathc);

69 for (i = 0; i < gl.gl_pathc; i++) {

70 gchar *uid;

72 /* copy 13 chars, offset spooldir path + 7 chars for /input/ */

73 /* uid length = 6 chars + '-' + 3 chars + '-' + 2 = 13 chars */

74 uid = g_strndup(&(gl.gl_pathv[idx_arr[i]][strlen(conf.spool_dir) + 7]), 13);

76 DEBUG(5) debugf("uid: %s\n", uid);

78 msg_list = g_list_append(msg_list, msg_spool_read(uid, do_readdata));

80 DEBUG(5) debugf("after read spool file for %s\n", uid);

82 g_free(uid);

83 }

84 return msg_list;

85 }

87 gboolean

88 queue_run()

89 {

90 GList *msg_list;

91 gboolean ok = TRUE;

93 logwrite(LOG_NOTICE, "Starting queue run.\n");

95 msg_list = read_queue(FALSE);

97 if (msg_list != NULL) {

98 ok = deliver_msg_list(msg_list, DLVR_ALL);

99 destroy_msg_list(msg_list);

100 logwrite(LOG_NOTICE, " deliver_msg_list()=%d.\n", ok);

101 }

102 logwrite(LOG_NOTICE, "Finished queue run.\n");

103

104 return ok;

105 }

106

107 gboolean

108 queue_run_online()

109 {

110 GList *msg_list = read_queue(FALSE);

111 gboolean ok = TRUE;

112

113 logwrite(LOG_NOTICE, "Starting online queue run.\n");

114 if (msg_list != NULL) {

115 ok = deliver_msg_list(msg_list, DLVR_ONLINE);

116 destroy_msg_list(msg_list);

117 }

118 logwrite(LOG_NOTICE, "Finished online queue run.\n");

119

120 return ok;

121 }

122

123 static gchar*

124 format_difftime(double secs)

125 {

126 if (secs > 86400)

127 return g_strdup_printf("%.1fd", secs / 86400);

128 else if (secs > 3600)

129 return g_strdup_printf("%.1fh", secs / 3600);

130 else if (secs > 60)

131 return g_strdup_printf("%.1fm", secs / 60);

132 else

133 return g_strdup_printf("%.0fs", secs);

134 }

135

136 void

137 queue_list()

138 {

139 GList *msg_list;

140 GList *msg_node;

141

142 msg_list = read_queue(FALSE);

143

144 if (msg_list == NULL) {

145 printf("mail queue is empty.\n");

146 return;

147 }

148

149 foreach(msg_list, msg_node) {

150 message *msg = (message *) (msg_node->data);

151 GList *rcpt_node;

152 gchar *size_str = NULL;

153 gchar *time_str = NULL;

154 gchar *host_str = NULL;

155 gchar *ident_str = NULL;

156

157 if (msg->data_size >= 0)

158 size_str = g_strdup_printf(" size=%d", msg->data_size);

159 if (msg->received_time > 0) {

160 gchar *tmp_str;

161 time_str = g_strdup_printf(" age=%s", tmp_str = format_difftime(difftime(time(NULL), msg->received_time)));

162 g_free(tmp_str);

163 }

164 if (msg->received_host != NULL)

165 host_str = g_strdup_printf(" host=%s", msg->received_host);

166 if (msg->ident != NULL)

167 ident_str = g_strdup_printf(" ident=%s", msg->ident);

168

169 printf("%s <= %s%s%s%s%s\n", msg->uid, addr_string(msg->return_path), size_str ? size_str : "",

170 time_str ? time_str : "", host_str ? host_str : "", ident_str ? ident_str : "");

171

172 if (size_str)

173 g_free(size_str);

174 if (time_str)

175 g_free(time_str);

176 if (host_str)

177 g_free(host_str);

178 if (ident_str)

179 g_free(ident_str);

180

181 foreach(msg->rcpt_list, rcpt_node) {

182 address *rcpt = (address *) (rcpt_node->data);

183

184 printf(" %s %s\n", addr_is_delivered(rcpt) ? "=>" : (addr_is_failed(rcpt) ? "!=" : "=="), addr_string(rcpt));

185 }

186 g_free(msg);

187 }

188 }

189

190 gboolean

191 queue_delete(gchar * uid)

192 {

193 gboolean hdr_ok = TRUE;

194 gboolean dat_ok = TRUE;

195 gchar *hdr_name = g_strdup_printf("%s/input/%s-H", conf.spool_dir, uid);

196 gchar *dat_name = g_strdup_printf("%s/input/%s-D", conf.spool_dir, uid);

197 struct stat stat_buf;

198

199 if (!spool_lock(uid)) {

200 fprintf(stderr, "message %s is locked.\n", uid);

201 return FALSE;

202 }

203

204 if (stat(hdr_name, &stat_buf) == 0) {

205 if (unlink(hdr_name) != 0) {

206 fprintf(stderr, "could not unlink %s: %s\n", hdr_name, strerror(errno));

207 hdr_ok = FALSE;

208 }

209 } else {

210 fprintf(stderr, "could not stat file %s: %s\n", hdr_name, strerror(errno));

211 hdr_ok = FALSE;

212 }

213 if (stat(dat_name, &stat_buf) == 0) {

214 if (unlink(dat_name) != 0) {

215 fprintf(stderr, "could not unlink %s: %s\n", dat_name, strerror(errno));

216 dat_ok = FALSE;

217 }

218 } else {

219 fprintf(stderr, "could not stat file %s: %s\n", dat_name, strerror(errno));

220 dat_ok = FALSE;

221 }

222 printf("message %s deleted\n", uid);

223

224 spool_unlock(uid);

225

226 return (dat_ok && hdr_ok);

227 }