masqmail: 5781ba87df95 src/queue.c

masqmail

view src/queue.c @ 378:5781ba87df95

Removed ident. This had been discussed on the mailing list in Oct 2011. Ident is hardly useful in typical setups for masqmail. Probably Oliver had used it in his setup; that would make sense. Now, I know of nobody who needs it.

author	markus schnalke <meillo@marmaro.de>
date	Sat, 14 Jan 2012 21:36:58 +0100
parents	41958685480d
children	bdbedce60247

line source

1 /*

2 ** MasqMail

5 **

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

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

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

9 ** (at your option) any later version.

10 **

11 ** This program is distributed in the hope that it will be useful,

12 ** but WITHOUT ANY WARRANTY; without even the implied warranty of

13 ** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

14 ** GNU General Public License for more details.

15 **

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

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

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

19 */

21 #include <sys/stat.h>

22 #include <glob.h>

24 #include "masqmail.h"

26 static void

27 mix_arr(int *buf, int len)

28 {

29 int i;

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

32 buf[i] = i;

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

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

35 int tmp;

37 if (i != j) {

38 tmp = buf[i];

39 buf[i] = buf[j];

40 buf[j] = tmp;

41 }

42 }

43 }

45 GList*

46 read_queue(void)

47 {

48 GList *msg_list = NULL;

49 glob_t gl;

50 gchar *pattern;

51 int i, *idx_arr;

53 /*

54 ** Escaping the question marks prevents them from being

55 ** interpreted as trigraphs

56 */

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

58 gl.gl_offs = 0;

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

61 g_free(pattern);

63 DEBUG(4) {

64 int i;

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

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

67 }

68 }

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

71 mix_arr(idx_arr, gl.gl_pathc);

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

74 gchar *uid;

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

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

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

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

82 msg_list = g_list_append(msg_list, msg_spool_read(uid));

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

86 g_free(uid);

87 }

88 return msg_list;

89 }

91 gboolean

92 queue_run()

93 {

94 GList *msg_list;

95 gboolean ok = TRUE;

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

98 msg_list = read_queue();

99 if (msg_list) {

100 ok = deliver_msg_list(msg_list, DLVR_ALL);

101 DEBUG(5) debugf(" deliver_msg_list() returned: %d\n", ok);

102 destroy_msg_list(msg_list);

103 }

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

105

106 return ok;

107 }

108

109 gboolean

110 queue_run_online()

111 {

112 GList *msg_list;

113 gboolean ok = TRUE;

114

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

116 msg_list = read_queue();

117 if (msg_list) {

118 ok = deliver_msg_list(msg_list, DLVR_ONLINE);

119 DEBUG(5) debugf(" deliver_msg_list() returned: %d\n", ok);

120 destroy_msg_list(msg_list);

121 }

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

123

124 return ok;

125 }

126

127 static gchar*

128 format_difftime(double secs)

129 {

130 if (secs > 86400)

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

132 else if (secs > 3600)

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

134 else if (secs > 60)

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

136 else

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

138 }

139

140 void

141 queue_list()

142 {

143 GList *msg_list;

144 GList *msg_node;

145

146 msg_list = read_queue();

147

148 if (msg_list == NULL) {

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

150 return;

151 }

152

153 foreach(msg_list, msg_node) {

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

155 GList *rcpt_node;

156 gchar *size_str = NULL;

157 gchar *time_str = NULL;

158 gchar *host_str = NULL;

159 gchar *ident_str = NULL;

160

161 if (msg->data_size >= 0)

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

163 if (msg->received_time > 0) {

164 gchar *tmp_str;

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

166 g_free(tmp_str);

167 }

168 if (msg->received_host != NULL)

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

170 if (msg->ident != NULL)

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

172

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

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

175

176 if (size_str)

177 g_free(size_str);

178 if (time_str)

179 g_free(time_str);

180 if (host_str)

181 g_free(host_str);

182 if (ident_str)

183 g_free(ident_str);

184

185 foreach(msg->rcpt_list, rcpt_node) {

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

187

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

189 }

190 g_free(msg);

191 }

192 }

193

194 gboolean

195 queue_delete(gchar *uid)

196 {

197 gboolean hdr_ok = TRUE;

198 gboolean dat_ok = TRUE;

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

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

201 struct stat stat_buf;

202

203 if (!spool_lock(uid)) {

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

205 return FALSE;

206 }

207

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

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

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

211 hdr_ok = FALSE;

212 }

213 } else {

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

215 hdr_ok = FALSE;

216 }

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

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

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

220 dat_ok = FALSE;

221 }

222 } else {

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

224 dat_ok = FALSE;

225 }

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

227

228 spool_unlock(uid);

229

230 return (dat_ok && hdr_ok);

231 }