-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathProgram.cs
More file actions
338 lines (286 loc) · 19.5 KB
/
Copy pathProgram.cs
File metadata and controls
338 lines (286 loc) · 19.5 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
// Клиент API «Проверка почты» Atlorium — существует ли ящик, не спам-ловушка ли это.
//
// Запуск (работает сразу, без регистрации — на демо-ключе):
// dotnet run
// dotnet run "anna@example.com,promo@spamtrap.example.com"
//
// Боевой ключ: получить на https://atlorium.com и положить в переменную окружения
// ATLORIUM_API_KEY. Код при этом не меняется.
using System.Globalization;
using System.Net;
using System.Net.Http.Headers;
using System.Text.Json;
// Публичный демо-ключ. С ним API отвечает правдоподобными МОКАМИ (не реальными
// данными) — чтобы можно было встроить и протестировать интеграцию до оплаты.
// Ответы детерминированы: один и тот же адрес всегда даёт один и тот же результат,
// поэтому на них можно писать стабильные тесты.
const string SandboxKey = "ak_sandbox_demo_mockdata_v1";
var apiKey = Environment.GetEnvironmentVariable("ATLORIUM_API_KEY") ?? SandboxKey;
var baseUrl = Environment.GetEnvironmentVariable("ATLORIUM_BASE_URL") ?? "https://atlorium.com";
// Проверка ящика — синхронное обращение к почтовому серверу домена, он может тянуть
// с ответом. Отсюда таймаут заметно больше, чем у справочников.
using var http = new HttpClient
{
BaseAddress = new Uri(baseUrl),
Timeout = TimeSpan.FromSeconds(30),
};
http.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", apiKey);
http.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
var client = new EmailValidationClient(http);
if (apiKey == SandboxKey)
{
Console.WriteLine("Демо-ключ: ответы сгенерированы (моки), не реальные данные.\n");
}
// Список короткий намеренно: проверка почты — платный сервис с жёстким лимитом.
// Домены ниже — сценарии песочницы, см. README.
string[] defaultList =
[
"anna.petrova@example.com", // обычный живой ящик
"ivan@invalid.example.com", // ящика не существует
"promo@spamtrap.example.com", // спам-ловушка
"pavel@gmial.com", // опечатка в домене: gmial → gmail
];
var emails = args.Length > 0
? args[0].Split(',', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries)
: defaultList;
Console.WriteLine($"Чистка списка рассылки. Адресов на входе: {emails.Length}\n");
List<Decision> decisions;
try
{
decisions = await MailingList.FilterAsync(client, emails);
}
catch (AtloriumException error)
{
Console.Error.WriteLine($"Ошибка: {error.Message}");
return 1;
}
Console.WriteLine($"{Pad("АДРЕС", 32)}{Pad("СТАТУС", 11)}{Pad("РЕШЕНИЕ", 13)}КОММЕНТАРИЙ");
foreach (var d in decisions)
{
Console.WriteLine($"{Pad(d.Email, 32)}{Pad(d.StatusRaw, 11)}{Pad(d.Action, 13)}{d.Reason}");
}
var typos = decisions.Where(d => d.DidYouMean is not null).ToList();
if (typos.Count > 0)
{
Console.WriteLine("\nПОДСКАЗКИ ПО ОПЕЧАТКАМ (это спасённый контакт, а не потерянный):");
foreach (var d in typos)
{
Console.WriteLine($" [~] возможно, опечатка: {d.Email} → {d.DidYouMean}");
}
}
var spamtraps = decisions.Where(d => d.SpamTrap).ToList();
if (spamtraps.Count > 0)
{
Console.WriteLine($"\n!!! СПАМ-ЛОВУШКА В СПИСКЕ: {spamtraps.Count} !!!");
foreach (var d in spamtraps)
{
Console.WriteLine($" {d.Email}");
}
Console.WriteLine(" Такой адрес никто не заводил и ни на что не подписывал — его публикуют,");
Console.WriteLine(" чтобы ловить рассылки по купленным базам. Одно попадание роняет репутацию");
Console.WriteLine(" домена-отправителя, после чего в спам уходит ВСЯ рассылка, включая письма");
Console.WriteLine(" живым клиентам. Удалять безусловно и выяснять, откуда адрес взялся.");
}
// Какой был бы bounce rate, если бы список отправили как есть.
var invalid = decisions.Count(d => d.StatusRaw == "invalid");
var bounceRate = decisions.Count > 0 ? 100.0 * invalid / decisions.Count : 0.0;
Console.WriteLine("\nИТОГО");
Console.WriteLine($" Проверено адресов: {decisions.Count}");
Console.WriteLine($" К отправке (SEND): {decisions.Count(d => d.Action == MailingList.Send)}");
Console.WriteLine($" На свой риск (RISKY): {decisions.Count(d => d.Action == MailingList.SendRisky)}");
Console.WriteLine($" Повторить позже: {decisions.Count(d => d.Action == MailingList.RetryLater)} (не тарифицируется)");
Console.WriteLine($" Выброшено (DROP): {decisions.Count(d => d.Action == MailingList.Drop)}");
// InvariantCulture: иначе под локалью с запятой в качестве разделителя вывод
// разъедется с остальными пятью примерами (25,0 вместо 25.0).
Console.WriteLine($" Bounce rate без чистки: {bounceRate.ToString("F1", CultureInfo.InvariantCulture)} % "
+ $"(несуществующих ящиков: {invalid} из {decisions.Count})");
if (spamtraps.Count > 0)
{
Console.WriteLine($" Спам-ловушек: {spamtraps.Count} <-- критично");
}
return 0;
// Дополняет строку пробелами до нужной ширины, чтобы колонки не разъезжались.
static string Pad(string value, int width) => value.PadRight(width);
// ── Клиент ───────────────────────────────────────────────────────────────────
/// <summary>Ошибка API: HTTP-код разложен в человекочитаемую причину.</summary>
public sealed class AtloriumException(HttpStatusCode status, string body)
: Exception($"HTTP {(int)status}: {Explain(status)}. Ответ сервера: {body[..Math.Min(200, body.Length)]}")
{
public HttpStatusCode Status { get; } = status;
private static string Explain(HttpStatusCode status) => (int)status switch
{
400 => "Адрес не передан или синтаксически некорректен (запрос НЕ тарифицируется)",
401 => "API-ключ отсутствует, просрочен или недействителен",
402 => "Недостаточно кредитов на балансе — пополните на https://atlorium.com",
429 => "Превышен лимит запросов — повторите позже",
503 => "Сервис проверки почты временно недоступен (за сбой на своей стороне мы не списываем деньги)",
_ => "Неизвестная ошибка",
};
}
public sealed class EmailValidationClient(HttpClient http)
{
private static readonly JsonSerializerOptions JsonOptions = new(JsonSerializerDefaults.Web);
// Проверка почты — платный сервис, лимит жёсткий.
// Список рассылки длиннее двух адресов гарантированно упрётся в 429 — поэтому
// повтор после паузы здесь не «на всякий случай», а штатный режим работы.
private static readonly TimeSpan RetryDelay = TimeSpan.FromSeconds(30);
private const int MaxRetries = 3;
// Потолок ожидания. Исчерпав ЧАСОВОЙ лимит, сервер честно отвечает Retry-After на
// 40+ минут — и клиент, слепо доверяющий заголовку, «зависнет» на эти 40 минут
// (а в CI просто съест весь бюджет джоба). Дольше потолка не ждём.
private static readonly TimeSpan MaxRetryDelay = TimeSpan.FromSeconds(120);
/// <summary>
/// Проверка одного адреса: GET /api/EmailValidation?email=...
///
/// Письмо на адрес НЕ отправляется: провайдер обращается к почтовому серверу домена
/// и выясняет, принял бы тот письмо на этот ящик.
/// </summary>
public async Task<EmailReport> VerifyAsync(string email)
{
var path = $"/api/EmailValidation?email={Uri.EscapeDataString(email)}";
for (var attempt = 0; ; attempt++)
{
using var response = await http.GetAsync(path);
// 429 — не поломка, а реальный лимит продукта. Ждём и повторяем.
if (response.StatusCode == HttpStatusCode.TooManyRequests && attempt < MaxRetries)
{
var delay = RetryAfter(response);
if (delay == TimeSpan.Zero)
{
// Сервер просит ждать дольше потолка — значит, исчерпан часовой лимит.
// Спать 40 минут бессмысленно: честно говорим об этом и выходим.
throw new AtloriumException(HttpStatusCode.TooManyRequests,
"лимит запросов по IP исчерпан, повторите позже");
}
Console.Error.WriteLine($" ... лимит запросов, пауза {delay.TotalSeconds:F0} с");
await Task.Delay(delay);
continue;
}
var body = await response.Content.ReadAsStringAsync();
if (!response.IsSuccessStatusCode)
{
throw new AtloriumException(response.StatusCode, body);
}
return JsonSerializer.Deserialize<EmailReport>(body, JsonOptions)
?? throw new InvalidOperationException("Пустой ответ API.");
}
}
/// <summary>
/// Сколько ждать после 429. Ноль/мусор и слишком большие значения не берём на веру.
///
/// Значение 0 (или мусор) означало бы «повторяй немедленно» — клиент ушёл бы в
/// busy-loop и выжег остаток лимита за секунду. Значение в 40+ минут (так сервер
/// отвечает на исчерпанный часовой лимит) означало бы «спи почти час» — этого мы
/// тоже не делаем. Возвращаем TimeSpan.Zero, если ждать бессмысленно долго.
/// </summary>
private static TimeSpan RetryAfter(HttpResponseMessage response)
{
var seconds = response.Headers.RetryAfter?.Delta?.TotalSeconds ?? 0;
if (seconds <= 0)
{
return RetryDelay;
}
var delay = TimeSpan.FromSeconds(seconds);
return delay <= MaxRetryDelay ? delay : TimeSpan.Zero;
}
}
// ── Модель ответа ────────────────────────────────────────────────────────────
/// <summary>Карточка проверки одного адреса.</summary>
public sealed record EmailReport
{
public string Email { get; init; } = "";
/// <summary>Valid | Invalid | CatchAll | Unknown | SpamTrap | Abuse | DoNotMail.</summary>
public string Status { get; init; } = "";
/// <summary>Статус как его вернул источник: "valid", "catch-all", "do_not_mail".</summary>
public string StatusRaw { get; init; } = "";
/// <summary>Уточнение: "mailbox_not_found", "disposable", "role_based", "greylisted".</summary>
public string? SubStatus { get; init; }
public string? Account { get; init; }
public string? Domain { get; init; }
public bool FreeEmail { get; init; }
public bool? CatchAllDomain { get; init; }
/// <summary>Подсказка по опечатке в домене: gmial.com → gmail.com.</summary>
public string? DidYouMean { get; init; }
public int? DomainAgeDays { get; init; }
public string? SmtpProvider { get; init; }
public bool MxFound { get; init; }
public string? MxRecord { get; init; }
public string? ActiveInDays { get; init; }
public string? ActiveFirstSeen { get; init; }
public DateTimeOffset? ProcessedAtUtc { get; init; }
public long ElapsedMs { get; init; }
/// <summary>true только при Status = Valid. catch-all и unknown — неопределённость.</summary>
public bool Deliverable { get; init; }
}
// ── Применение данных: чистка списка рассылки ─────────────────────────────────
// Отчёт по адресу сам по себе — просто JSON. Ценность появляется, когда по нему
// принимают решение: слать письмо или нет. Ниже — ровно это решение.
/// <summary>
/// Решение по адресу. SpamTrap вынесен в отдельный флаг: это не «ещё один DROP»,
/// а причина остановить рассылку и разобраться, откуда взялся адрес.
/// </summary>
public sealed record Decision(
string Email,
string StatusRaw,
string Action,
string Reason,
bool SpamTrap = false,
string? DidYouMean = null);
public static class MailingList
{
public const string Send = "SEND"; // отправляем
public const string SendRisky = "SEND_RISKY"; // можно отправить, но на свой риск
public const string RetryLater = "RETRY_LATER"; // проверить не удалось, повторить позже
public const string Drop = "DROP"; // из списка выбросить
/// <summary>Чистка списка рассылки: каждый адрес проверяется и получает решение.</summary>
public static async Task<List<Decision>> FilterAsync(EmailValidationClient client, IEnumerable<string> emails)
{
var decisions = new List<Decision>();
foreach (var email in emails)
{
decisions.Add(Decide(await client.VerifyAsync(email)));
}
return decisions;
}
/// <summary>Что делать с адресом, исходя из вердикта проверки.</summary>
public static Decision Decide(EmailReport report) => report.Status switch
{
"Valid" => new Decision(report.Email, report.StatusRaw, Send,
"Ящик существует, домен принимает почту", DidYouMean: report.DidYouMean),
// Домен отвечает «принято» на ЛЮБОЙ адрес, поэтому существование конкретного
// ящика проверить снаружи невозможно. Это не «плохо» — это неопределённость.
// Слать можно, но отдельным сегментом и следя за bounce rate.
"CatchAll" => new Decision(report.Email, report.StatusRaw, SendRisky,
"Домен принимает всё подряд — доставляемость не гарантирована", DidYouMean: report.DidYouMean),
// Сервер домена применил greylisting, не ответил или заблокировал проверку.
// За такой исход деньги НЕ списываются — адрес просто проверяем позже.
"Unknown" => new Decision(report.Email, report.StatusRaw, RetryLater,
"Сервер домена не ответил (greylisting) — запрос не тарифицирован", DidYouMean: report.DidYouMean),
// Ящика не существует. Отправка = hard bounce, а bounce rate выше 2 %
// почтовые провайдеры считают признаком грязной базы.
"Invalid" => new Decision(report.Email, report.StatusRaw, Drop,
"Ящика не существует — письмо отскочит (hard bounce)", DidYouMean: report.DidYouMean),
// Технически ящик может работать, но рассылать на него нельзя.
"DoNotMail" => new Decision(report.Email, report.StatusRaw, Drop, report.SubStatus switch
{
"role_based" => "Ролевой адрес (info@, sales@) — читает не человек, а отдел",
"disposable" => "Одноразовый ящик — создан на 10 минут, писать бессмысленно",
_ => "Адрес из списка «не писать»",
}, DidYouMean: report.DidYouMean),
// Владелец адреса уже жаловался на спам. Ещё одна жалоба — минус к репутации.
"Abuse" => new Decision(report.Email, report.StatusRaw, Drop,
"Жалобщик: ранее отмечал письма как спам", DidYouMean: report.DidYouMean),
// САМОЕ ВАЖНОЕ, ЧТО ДАЁТ СЕРВИС.
// Спам-ловушка — адрес, который никто не заводил и на который никто не
// подписывался: его специально публикуют, чтобы поймать тех, кто рассылает
// по купленным и спарсенным базам. Ящик отвечает как живой, поэтому отличить
// его самому невозможно. Одно попадание — и репутация домена-отправителя
// падает, а в спам уходит ВСЯ рассылка, включая письма живым клиентам.
"SpamTrap" => new Decision(report.Email, report.StatusRaw, Drop,
"СПАМ-ЛОВУШКА — убивает репутацию домена-отправителя",
SpamTrap: true, DidYouMean: report.DidYouMean),
// Провайдер вернул статус, которого мы не знаем. Не рискуем.
_ => new Decision(report.Email, report.StatusRaw, Drop,
$"Неизвестный статус: {report.StatusRaw}", DidYouMean: report.DidYouMean),
};
}