masqmail: 0dd84c8f2524 src/route.c

227 if (fnmatch(pat->domain, rcpt->domain, FNM_CASEFOLD)==0 && fnmatch(pat->local_part, rcpt->local_part, 0)==0) { /* TODO: match local_part caseless? */

228 break;

229 }

230 }

231 if (pat_node) {

232 if (rl_matching)

233 *rl_matching = g_list_append(*rl_matching, rcpt);

234 } else {

235 if (rl_others)

236 *rl_others = g_list_append(*rl_others, rcpt);

237 }

238 }

239 }

240 }

241

242 /*

243 ** Return a new list of the local rcpts in the rcpt_list

244 ** TODO: This function is almost exactly the same as remote_rcpts(). Merge?

245 */

246 GList*

247 local_rcpts(GList *rcpt_list)

248 {

249 GList *rcpt_node;

250 GList *local_rcpts = NULL;

251 address *rcpt = NULL;

252

253 if (!rcpt_list) {

254 return NULL;

255 }

256 foreach(rcpt_list, rcpt_node) {

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

258 if (addr_is_local(rcpt)) {

259 local_rcpts = g_list_append(local_rcpts, rcpt);

260 }

261 }

262 return local_rcpts;

263 }

264

265 /*

266 ** Return a new list of non-local rcpts in the rcpt_list

267 ** TODO: This function is almost exactly the same as local_rcpts(). Merge?

268 */

269 GList*

270 remote_rcpts(GList *rcpt_list)

271 {

272 GList *rcpt_node;

273 GList *remote_rcpts = NULL;

274 address *rcpt = NULL;

275

276 if (!rcpt_list) {

277 return NULL;

278 }

279 foreach(rcpt_list, rcpt_node) {

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

281 if (!addr_is_local(rcpt)) {

282 remote_rcpts = g_list_append(remote_rcpts, rcpt);

283 }

284 }

285 return remote_rcpts;

286 }

287

288 static gint

289 _g_list_addrcmp(gconstpointer pattern, gconstpointer addr)

290 {

291 int res;

292 address *patternaddr = (address*) pattern;

293 address *stringaddr = (address*) addr;

294

295 DEBUG(6) debugf("_g_list_addrcmp: pattern `%s' `%s' on string `%s' `%s'\n",

296 patternaddr->local_part, patternaddr->domain,

297 stringaddr->local_part, stringaddr->domain);

298 /* TODO: check if we should match here dependent on caseless_matching */

299 res = fnmatch(patternaddr->local_part, stringaddr->local_part, 0);

300 if (res != 0) {

301 DEBUG(6) debugf("_g_list_addrcmp: ... failed on local_part\n");

302 return res;

303 }

304 res = fnmatch(patternaddr->domain, stringaddr->domain, FNM_CASEFOLD);

305 DEBUG(6) debugf("_g_list_addrcmp: ... %s\n", (res==0) ? "matched" : "failed on domain");

306 return res;

307 }

308

309 gboolean

310 route_sender_is_allowed(connect_route *route, address *ret_path)

311 {

312 if (route->denied_senders && g_list_find_custom(route->denied_senders, ret_path, _g_list_addrcmp)) {

313 return FALSE;

314 }

315 if (route->allowed_senders) {

316 if (g_list_find_custom(route->allowed_senders, ret_path, _g_list_addrcmp)) {

317 return TRUE;

318 } else {

319 return FALSE;

320 }

321 }

322 return TRUE;

323 }

324

325 /*

326 ** Make lists of matching/not matching rcpts.

327 ** Local domains are NOT regared here, these should be sorted out previously

328 */

329 void

330 route_split_rcpts(connect_route *route, GList *rcpt_list, GList **p_rcpt_list, GList **p_non_rcpt_list)

331 {

332 GList *tmp_list = NULL;

333 /* sort out those domains that can be sent over this connection: */

334 if (route->allowed_recipients) {

335 DEBUG(5) debugf("testing for route->allowed_recipients\n");

336 split_rcpts(rcpt_list, route->allowed_recipients, NULL, &tmp_list, p_non_rcpt_list);

337 } else {

338 DEBUG(5) debugf("route->allowed_recipients == NULL\n");

339 tmp_list = g_list_copy(rcpt_list);

340 }

341

342 /* sort out those domains that cannot be sent over this connection: */

343 split_rcpts(tmp_list, route->denied_recipients, NULL, p_non_rcpt_list, p_rcpt_list);

344 g_list_free(tmp_list);

345 }

346

347 msg_out*

348 route_prepare_msgout(connect_route *route, msg_out *msgout)

349 {

350 message *msg = msgout->msg;

351 GList *rcpt_list = msgout->rcpt_list;

352

353 if (rcpt_list != NULL) {

354 /* found a few */

355 DEBUG(5) {

356 GList *node;

357 debugf("rcpts for routed delivery, route = %s, id = %s\n", route->name, msg->uid);

358 foreach(rcpt_list, node) {

359 address *rcpt = (address *) (node->data);

360 debugf(" rcpt for routed delivery: <%s@%s>\n",

361 rcpt->local_part, rcpt->domain);

362 }

363 }

364

365 /*

366 ** rewrite return path if there is a table, use that

367 ** if an address is found and if it has a domain, use that

368 */

369 if (route->map_return_path_addresses) {

370 address *ret_path = NULL;

371 DEBUG(5) debugf("looking up %s in map_return_path_addresses\n", msg->return_path->local_part);

372 ret_path = (address *) table_find_fnmatch(route->map_return_path_addresses, msg->return_path->local_part);

373 if (ret_path) {

374 DEBUG(5) debugf("found <%s@%s>\n", ret_path->local_part, ret_path->domain);

375 if (ret_path->domain == NULL)

376 ret_path->domain = route->set_return_path_domain

377 ? route->set_return_path_domain

378 : msg->return_path->domain;

379 msgout->return_path = copy_address(ret_path);

380 }

381 }

382 if (msgout->return_path == NULL) {

383 DEBUG(5) debugf("setting return path to %s\n", route->set_return_path_domain);

384 msgout->return_path = copy_modify_address(msg->return_path, NULL, route->set_return_path_domain);

385 }

386 rewrite_headers(msgout, route);

387

388 return msgout;

389 }

390 return NULL;

391 }

392

393 /*

394 ** put msgout's is msgout_list into bins (msgout_perhost structs) for each

395 ** host. Used if there is no mail_host.

396 ** route param is not used, we leave it here because that may change.

397 */

398 GList*

399 route_msgout_list(connect_route *route, GList *msgout_list)

400 {

401 GList *mo_ph_list = NULL;

402 GList *msgout_node;

403

404 foreach(msgout_list, msgout_node) {

405 msg_out *msgout = (msg_out *) (msgout_node->data);

406 msg_out *msgout_new;

407 GList *rcpt_list = msgout->rcpt_list;

408 GList *rcpt_node;

409

410 foreach(rcpt_list, rcpt_node) {

411 address *rcpt = rcpt_node->data;

412 msgout_perhost *mo_ph = NULL;

413 GList *mo_ph_node = NULL;

414

415 /* search host in mo_ph_list */

416 foreach(mo_ph_list, mo_ph_node) {

417 mo_ph = (msgout_perhost *) (mo_ph_node->data);

418 if (strcasecmp(mo_ph->host, rcpt->domain) == 0)

419 break;

420 }

421 if (mo_ph_node != NULL) {

422 /* there is already a rcpt for this host */

423 msg_out *msgout_last = (msg_out *) ((g_list_last(mo_ph->msgout_list))->data);

424 if (msgout_last->msg == msgout->msg) {

425 /*

426 ** if it is also the same message,

427 ** it must be the last one

428 ** appended to mo_ph->msgout_list

429 ** (since outer loop goes through

430 ** msgout_list)

431 */

432 msgout_last->rcpt_list = g_list_append(msgout_last->rcpt_list, rcpt);

433 } else {

434 /* if not, we append a new msgout */

435 /* make a copy of msgout */

436 msgout_new = create_msg_out(msgout->msg);

437 msgout_new->return_path = msgout->return_path;

438 msgout_new->hdr_list = msgout->hdr_list;

439

440 /* append our rcpt to it */

441 /* It is the 1st rcpt for this msg to this host, therefore we safely give NULL */

442 msgout_new->rcpt_list = g_list_append(NULL, rcpt);

443 mo_ph->msgout_list = g_list_append(mo_ph->msgout_list, msgout_new);

444 }

445 } else {

446 /* this rcpt to goes to another host */

447 mo_ph = create_msgout_perhost(rcpt->domain);

448 mo_ph_list = g_list_append(mo_ph_list, mo_ph);

449

450 /* make a copy of msgout */

451 msgout_new = create_msg_out(msgout->msg);

452 msgout_new->return_path = msgout->return_path;

453 msgout_new->hdr_list = msgout->hdr_list;

454

455 /* append our rcpt to it */

456 /* It is the 1st rcpt for this msg to this host, therefore we safely give NULL */

457 msgout_new->rcpt_list = g_list_append(NULL, rcpt);

458 mo_ph->msgout_list = g_list_append(mo_ph->msgout_list, msgout_new);

459 } /* if mo_ph != NULL */

460 } /* foreach(rcpt_list, ... */

461 } /* foreach(msgout_list, ... */

462

463 return mo_ph_list;

464 }