mirror of
https://github.com/mailscope/kumomta.git
synced 2026-09-08 11:38:56 +00:00
Wez Furlong
e21bb1c672
We'll expand these to a list of candidate addresses, trying each in turn. We use the same overall connect timeout regardless of how many candidates are present, to respect that timeout bound. closes: https://github.com/KumoCorp/kumomta/pull/402
98 lines
2.6 KiB
Lua
98 lines
2.6 KiB
Lua
-- Policy file for testing ConnectError aggregation across multiple
|
|
-- failing proxy candidates. The proxy hostname resolves to two A
|
|
-- records, both pointing to addresses that are guaranteed to be
|
|
-- unreachable from this host. Every candidate must fail and the
|
|
-- error surfaced via the log must list each candidate and its
|
|
-- per-candidate failure reason.
|
|
local kumo = require 'kumo'
|
|
package.path = '../../assets/?.lua;' .. package.path
|
|
|
|
local TEST_DIR = os.getenv 'KUMOD_TEST_DIR'
|
|
local SINK_PORT = tonumber(os.getenv 'KUMOD_SMTP_SINK_PORT')
|
|
|
|
kumo.on('init', function()
|
|
kumo.configure_accounting_db_path(TEST_DIR .. '/accounting.db')
|
|
|
|
-- Both candidates are unreachable. 255.255.255.255 is the broadcast
|
|
-- address (Linux returns ENETUNREACH instantly). 127.0.0.99 has no
|
|
-- listener on port 1 (Linux returns ECONNREFUSED instantly). Two
|
|
-- distinct candidate addresses are required to exercise the
|
|
-- aggregation path in combine_connect_errors.
|
|
kumo.dns.configure_test_resolver {
|
|
[[
|
|
$ORIGIN bad-proxy.test.
|
|
@ 30 IN A 255.255.255.255
|
|
@ 30 IN A 127.0.0.99
|
|
]],
|
|
}
|
|
|
|
local relay_hosts = { '0.0.0.0/0' }
|
|
kumo.start_esmtp_listener {
|
|
listen = '127.0.0.1:0',
|
|
relay_hosts = relay_hosts,
|
|
deferred_queue = false,
|
|
}
|
|
|
|
kumo.start_http_listener {
|
|
listen = '127.0.0.1:0',
|
|
}
|
|
|
|
kumo.configure_local_logs {
|
|
log_dir = TEST_DIR .. '/logs',
|
|
max_segment_duration = '1s',
|
|
}
|
|
|
|
kumo.define_spool {
|
|
name = 'data',
|
|
path = TEST_DIR .. '/data-spool',
|
|
}
|
|
|
|
kumo.define_spool {
|
|
name = 'meta',
|
|
path = TEST_DIR .. '/meta-spool',
|
|
}
|
|
end)
|
|
|
|
kumo.on('get_listener_domain', function(domain, listener, conn_meta)
|
|
return kumo.make_listener_domain {
|
|
relay_to = true,
|
|
}
|
|
end)
|
|
|
|
kumo.on('get_queue_config', function(domain, tenant, campaign, routing_domain)
|
|
return kumo.make_queue_config {
|
|
protocol = {
|
|
smtp = {
|
|
mx_list = { '127.0.0.1:' .. SINK_PORT },
|
|
},
|
|
},
|
|
egress_pool = 'default',
|
|
}
|
|
end)
|
|
|
|
kumo.on('get_egress_pool', function(pool_name)
|
|
return kumo.make_egress_pool {
|
|
name = pool_name,
|
|
entries = {
|
|
{ name = 'default' },
|
|
},
|
|
}
|
|
end)
|
|
|
|
kumo.on('get_egress_source', function(source_name)
|
|
return kumo.make_egress_source {
|
|
name = source_name,
|
|
ha_proxy_source_address = '127.0.0.1',
|
|
ha_proxy_server = 'bad-proxy.test:1',
|
|
}
|
|
end)
|
|
|
|
kumo.on('get_egress_path_config', function(domain, source_name, _site_name)
|
|
return kumo.make_egress_path {
|
|
enable_tls = 'OpportunisticInsecure',
|
|
prohibited_hosts = {},
|
|
opportunistic_tls_reconnect_on_failed_handshake = false,
|
|
ip_lookup_strategy = 'Ipv4Only',
|
|
}
|
|
end)
|