Utilities/mailer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: Utilities:185b2abae425ac885b285d5fefc752d838c44d9c
Branches Tags
Utilities:main
...
compare: Utilities:main
Branches Tags
Utilities:main

20 Commits
185b2abae4 ... main

Author SHA1 Message Date
break27
b4afb01dfa minor fix 2026-06-03 17:19:37 +08:00
break27
d5e89768d5 minor fix 2026-06-02 18:40:48 +08:00
break27
aba6869f0f fix: added more locale keywords 2026-06-02 18:34:21 +08:00
break27
c65fbec79b update: removed recovery functionality 2026-06-02 18:33:40 +08:00
break27
d6c9575c82 fix: profile arguments 2026-06-02 16:20:18 +08:00
break27
42d6452e2d fix: recovery functionality 2026-06-02 15:19:20 +08:00
break27
5b99e222c4 fix: 'common' version 2026-05-26 11:55:48 +08:00
break27
03800e611c fix: 'common' version 2026-05-22 17:31:59 +08:00
break27
b6d93a707b fix: 'status' null check 2026-05-22 17:29:33 +08:00
break27
4943faa84e update: added 'common' dependency 2026-05-21 18:03:26 +08:00
break27
61fc828d6b update: README.md 2025-11-07 17:13:18 +08:00
break27
45aa6c4ff4 updated: fixed typo 2025-11-07 17:11:49 +08:00
break27
c15bc9fb4a cherry pick 2025-11-07 17:07:03 +08:00
break27
16d1de5f52 update: fixed typo 2025-11-07 16:58:32 +08:00
break27
a27afe47e9 update: add README.md 2025-11-07 16:56:16 +08:00
break27
f40669b63f update: properly set progress at the end 2025-09-25 16:20:04 +08:00
break27
2e9c1d3425 update: fixed connection issues when behind a proxy (selenium manager related) 2025-09-22 16:51:36 +08:00
break27
2040e711cd update: subject template string 2025-09-22 10:25:32 +08:00
break27
b7878de586 minor fix 2025-09-11 16:59:42 +08:00
break27
15ff6a17c6 minor fix 2025-09-10 20:02:39 +08:00
4 changed files with 800 additions and 831 deletions
Expand all files Collapse all files

644
index.html
View File

@@ -1,12 +1,7 @@
<link rel="icon" href="https://s3.dualstack.us-east-2.amazonaws.com/pythondotorg-assets/media/files/python-logo-only.svg" type="image/svg+xml"> <link rel="icon" href="https://s3.dualstack.us-east-2.amazonaws.com/pythondotorg-assets/media/files/python-logo-only.svg" type="image/svg+xml">
<link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/purecss@3.0.0/build/pure-min.css" integrity="sha384-X38yfunGUhNzHpBaEBsWLO+A0HDYOQi8ufWDkZ0k9e0eXz/tH3II7uKZ9msv++Ls" crossorigin="anonymous"> <link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/purecss@3.0.0/build/pure-min.css" integrity="sha384-X38yfunGUhNzHpBaEBsWLO+A0HDYOQi8ufWDkZ0k9e0eXz/tH3II7uKZ9msv++Ls" crossorigin="anonymous">
<link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/purecss@3.0.0/build/grids-responsive-min.css"> <link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/purecss@3.0.0/build/grids-responsive-min.css">
<script src="https://cdn.jsdelivr.net/npm/dayjs@1/dayjs.min.js"></script> <title>Mailer</title>
<script src="https://cdn.jsdelivr.net/npm/dayjs@1/plugin/utc.js"></script>
<script src="https://cdn.jsdelivr.net/npm/dayjs@1/plugin/timezone.js"></script>
<script src="https://cdn.jsdelivr.net/npm/dayjs@1/plugin/duration.js"></script>
<script src="https://cdn.jsdelivr.net/npm/dayjs@1/plugin/relativeTime.js"></script>
<title>Python Application</title>
<form class="pure-form pure-form-stacked pure-u-11-12 pure-u-lg-3-4 pure-u-xl-2-3"> <form class="pure-form pure-form-stacked pure-u-11-12 pure-u-lg-3-4 pure-u-xl-2-3">
<fieldset> <fieldset>
@@ -50,28 +45,30 @@
</div> </div>
</div> </div>
<br> <br>
<button type="button" class="inline-flex pure-button pure-button-primary" id="send"> <div id="actions" class="inline-flex">
<span class="text">Open</span> <button type="button" class="inline-flex pure-button pure-button-primary" id="send">
<span class="icon spin hidden"> <span class="text">Open</span>
<svg xmlns="http://www.w3.org/2000/svg" width="24" height="24" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round" class="icon icon-tabler icons-tabler-outline icon-tabler-loader"> <span class="icon spin" hidden>
<path stroke="none" d="M0 0h24v24H0z" fill="none"/> <svg xmlns="http://www.w3.org/2000/svg" width="24" height="24" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round" class="icon icon-tabler icons-tabler-outline icon-tabler-loader">
<path d="M12 6l0 -3" /> <path stroke="none" d="M0 0h24v24H0z" fill="none"/>
<path d="M16.25 7.75l2.15 -2.15" /> <path d="M12 6l0 -3" />
<path d="M18 12l3 0" /> <path d="M16.25 7.75l2.15 -2.15" />
<path d="M16.25 16.25l2.15 2.15" /> <path d="M18 12l3 0" />
<path d="M12 18l0 3" /> <path d="M16.25 16.25l2.15 2.15" />
<path d="M7.75 16.25l-2.15 2.15" /> <path d="M12 18l0 3" />
<path d="M6 12l-3 0" /> <path d="M7.75 16.25l-2.15 2.15" />
<path d="M7.75 7.75l-2.15 -2.15" /> <path d="M6 12l-3 0" />
</svg> <path d="M7.75 7.75l-2.15 -2.15" />
</span> </svg>
</button> </span>
<button type="button" class="pure-button" id="skip" disabled> </button>
Skip <button type="button" class="pure-button" id="skip" disabled>
</button> Skip
<button type="button" class="pure-button" id="cancel" disabled> </button>
Cancel <button type="button" class="pure-button" id="cancel" disabled>
</button> Cancel
</button>
</div>
</fieldset> </fieldset>
<br> <br>
<fieldset> <fieldset>
@@ -79,19 +76,19 @@
<div class="pure-g"> <div class="pure-g">
<div class="pure-u-1 pure-u-md-1-3"> <div class="pure-u-1 pure-u-md-1-3">
<label for="timeout">Timeout</label> <label for="timeout">Timeout</label>
<input id="timeout" class="pure-u-23-24" type="number" min="0"/> <input id="timeout" class="pure-u-23-24 params" type="number" min="0"/>
</div> </div>
<div class="pure-u-1 pure-u-md-1-3"> <div class="pure-u-1 pure-u-md-1-3">
<label for="interval">Interval</label> <label for="interval">Interval</label>
<input id="interval" class="pure-u-23-24" type="number" min="0"/> <input id="interval" class="pure-u-23-24 params" type="number" min="0"/>
</div> </div>
<div class="pure-u-1 pure-u-md-1-3"> <div class="pure-u-1 pure-u-md-1-3">
<label for="max_occurrence">Max Occurrence</label> <label for="occurrence">Max Occurrence</label>
<input id="max_occurrence" class="inactive pure-u-23-24" type="number" min="0" value="5" disabled/> <input id="occurrence" class="inactive pure-u-23-24" type="number" min="0" value="5" disabled/>
</div> </div>
<div class="pure-u-1 pure-u-md-1-3"> <div class="pure-u-1 pure-u-md-1-3">
<label for="attempts">Attempts</label> <label for="attempts">Attempts</label>
<input id="attempts" class="pure-u-23-24" type="number" min="1"/> <input id="attempts" class="pure-u-23-24 params" type="number" min="1"/>
</div> </div>
<div class="pure-u-1 pure-u-md-1-3"> <div class="pure-u-1 pure-u-md-1-3">
<label for="locale">Locale</label> <label for="locale">Locale</label>
@@ -103,8 +100,8 @@
<label for="greet" class="pure-checkbox"> <label for="greet" class="pure-checkbox">
<input id="greet" type="checkbox"/> Greet recipients (by proper names if possible) <input id="greet" type="checkbox"/> Greet recipients (by proper names if possible)
</label> </label>
<label for="recovery" class="pure-checkbox"> <label for="force" class="pure-checkbox">
<input id="recovery" type="checkbox"/> Try recover from a mismatched address/subject error <input id="force" type="checkbox"/> Ignore address/subject mismatch errors
</label> </label>
<label for="slice" class="pure-checkbox"> <label for="slice" class="pure-checkbox">
<input id="slice" type="checkbox"/> Enable task slicing <input id="slice" type="checkbox"/> Enable task slicing
@@ -115,71 +112,75 @@
<label for="save" class="pure-checkbox"> <label for="save" class="pure-checkbox">
<input id="save" type="checkbox" checked/> Save to file <input id="save" type="checkbox" checked/> Save to file
</label> </label>
<label for="logs" class="pure-checkbox">
<input id="logs" class="local-only" type="checkbox"/> Show logs
</label>
<textarea id="messages" name="messages" rows="30" hidden readonly></textarea>
</fieldset> </fieldset>
<br> <br>
<fieldset> <fieldset>
<legend>Columns</legend> <legend>Columns</legend>
<div class="pure-g"> <div class="pure-g">
<div class="pure-u-1 pure-u-md-1-3"> <div class="pure-u-1 pure-u-md-1-3">
<label for="column_address">Receipient Address</label> <label for="email">Recipient Address</label>
<select id="column_address" class="columns pure-u-23-24" required> <select id="email" class="columns pure-u-23-24" required>
<option value="">&nbsp;</option>
</select> </select>
</div> </div>
<div class="pure-u-1 pure-u-md-1-3"> <div class="pure-u-1 pure-u-md-1-3">
<label for="column_name">Receipient Name</label> <label for="recipient">Recipient Name</label>
<select id="column_name" class="columns pure-u-23-24"> <select id="recipient" class="pure-u-23-24 columns">
<option value="">&nbsp;</option>
</select> </select>
</div> </div>
<div class="pure-u-1 pure-u-md-1-3"> <div class="pure-u-1 pure-u-md-1-3">
<label for="column_code">Reference Code</label> <label for="code">Reference Code</label>
<select id="column_code" class="columns pure-u-23-24"> <select id="code" class="pure-u-23-24 columns">
<option value="">&nbsp;</option>
</select> </select>
</div> </div>
<div class="pure-u-1 pure-u-md-1-3"> <div class="pure-u-1 pure-u-md-1-3">
<label for="column_pays">Country</label> <label for="region">Region</label>
<select id="column_pays" class="columns pure-u-23-24"> <select id="region" class="pure-u-23-24 columns">
<option value="">&nbsp;</option>
</select> </select>
</div> </div>
<div class="pure-u-1 pure-u-md-1-3"> <div class="pure-u-1 pure-u-md-1-3">
<label for="column_sent">Remarks</label> <label for="sent">Sent</label>
<select id="column_sent" class="columns pure-u-23-24"> <select id="sent" class="pure-u-23-24 columns">
<option value="">&nbsp;</option> </select>
</div>
<div class="pure-u-1 pure-u-md-1-3">
<label for="variables">Variables</label>
<select id="variables" class="pure-u-23-24 columns">
</select> </select>
</div> </div>
</div> </div>
</fieldset> </fieldset>
<br> <br>
<fieldset> <fieldset>
<legend>Slicing</legend> <legend>Advanced</legend>
<div class="pure-g"> <div class="pure-g">
<div class="pure-u-1 pure-u-md-1-3"> <div class="pure-u-1 pure-u-md-1-3">
<label for="group_by">Group by</label> <label for="groupby">Group by</label>
<select id="group_by" class="slicing localonly pure-u-23-24" disabled> <select id="groupby" class="slicing local-only pure-u-23-24" disabled>
<option value="none">None</option> <option value="none">None</option>
<option value="locale">Locale</option> <option value="locale">Locale</option>
<option value="country">Country</option> <option value="region">Region</option>
</select> </select>
<label for="subcategory">Subcategory</label> <label for="subcategory">Subcategory</label>
<select id="subcategory" class="slicing inactive localonly pure-u-23-24" multiple disabled> <select id="subcategory" class="slicing inactive local-only pure-u-23-24" multiple disabled>
</select> </select>
</div> </div>
<div class="pure-u-1 pure-u-md-1-3"> <div class="pure-u-1 pure-u-md-1-3">
<label for="chunk_size">Chunk Size</label> <label for="chunksize">Chunk Size</label>
<input id="chunk_size" class="slicing pure-u-23-24" type="number" min="100" value="1000" disabled/> <input id="chunksize" class="slicing local-only pure-u-23-24" type="number" min="100" value="1000" disabled/>
</div> </div>
<div class="pure-u-1 pure-u-md-1-3"> <div class="pure-u-1 pure-u-md-1-3">
<div class="inline-flex"> <div class="inline-flex">
<div class="pure-u-1-2"> <div class="pure-u-1-2">
<label for="offset">Offset</label> <label for="offset">Offset</label>
<input id="offset" class="slicing pure-u-23-24" type="number" min="0" disabled/> <input id="offset" class="slicing local-only pure-u-23-24" type="number" min="0" disabled/>
</div> </div>
<div class="pure-u-1-2"> <div class="pure-u-1-2">
<label for="limit">Max. (limit)</label> <label for="limit">Max. (limit)</label>
<input id="limit" class="slicing localonly pure-u-23-24" type="number" readonly disabled/> <input id="limit" class="slicing local-only pure-u-23-24" type="number" readonly disabled/>
</div> </div>
</div> </div>
</div> </div>
@@ -187,178 +188,157 @@
</fieldset> </fieldset>
</form> </form>
<script type="text/javascript"> <script type="module">
dayjs.extend(dayjs_plugin_utc); import { default as $, LogRecord, Rpc2 } from '/';
dayjs.extend(dayjs_plugin_timezone); if (performance.getEntriesByType('navigation')[0].type === 'reload') await Rpc2.invoke('exit');
dayjs.extend(dayjs_plugin_duration);
dayjs.extend(dayjs_plugin_relativeTime);
const Timer = { let limit = 0;
setTimestamp: (reset=false) => { let length = 0;
$('#uptimeLabel').dataset.timestamp = dayjs().unix(); let busy = false;
if (reset) $('#uptimeLabel').dataset.timedelta = 0; let status = null;
}, let locale = null;
setTimedelta: () => { let unique = null;
$('#uptimeLabel').dataset.timedelta = Timer.getTimedelta().asSeconds(); let writable = null;
}, let filereader = null;
getTimedelta: () => { let subcategories = [];
let timedelta = dayjs.duration(dayjs().diff(dayjs.unix($('#uptimeLabel').dataset.timestamp)));
let sum = dayjs.duration($('#uptimeLabel').dataset.timedelta||0, 'second').add(timedelta);
return sum;
},
};
const $ = (selectors) => { let { locales, mapping, parameters } = await Rpc2.invoke('context');
return document.querySelector(selectors); let account = new String(parameters.account);
}; let name = account.split('@', 1).pop();
name = name.charAt(0).toLocaleUpperCase() + name.slice(1);
document.title += ` (${name})`;
const $$ = (selectors) => { async function handlePrimaryButtonClick() {
return document.querySelectorAll(selectors); switch (status) {
}; case 'IDLE':
let PickerOptions = {
types: [
{
description: "Excel Spreadsheet",
accept: {
"application/vnd.openxmlformats-officedocument.spreadsheetml.sheet": ['.xlsx']
}
}
]
};
let [handle] = await showOpenFilePicker(PickerOptions);
filereader = () => handle.getFile().then(file => new Promise((resolve, reject) => {
let reader = new FileReader();
reader.onload = () => resolve([file, reader.result]);
reader.onerror = () => reject(reader.error);
reader.readAsArrayBuffer(file);
}));
const $$$ = (selectors, event, listener) => { let [file, buffer] = await filereader().catch(() => []);
$(selectors).addEventListener(event, listener); writable = await handle.createWritable().catch(() => null);
}; limit = await Rpc2.invoke('ready', file.name, new Uint8Array(buffer).toBase64());
$.get('#fileLabel').innerText = file.name;
let Limit = null; $.get('#fromLabel').innerText = parameters.account;
let Status = null; $.all('.columns').forEach(e => e.dispatchEvent(new Event('change')));
let Columns = null;
let Locales = null;
let Connection = null;
$$$('#send', 'click', async (e) => {
switch (Status) {
case 'STANDBY':
Connection.send('RESUME');
$('#send > span.text').innerText = 'Pause';
$('#send > span.icon').classList.remove('hidden');
$('#send').disabled = true;
break;
case 'RUNNING':
Connection.send('ONHOLD');
$('#send > span.text').innerText = 'Resume';
$('#send > span.icon').classList.add('hidden');
$('#send').disabled = true;
break; break;
case 'READY': case 'READY':
let parameters = {}; let locale = $('#locale').value;
let options = { locale, mapping: new Object()};
for (let element of $$("input[type='number']:not([disabled]):not(.localonly)")) { for (let element of $.all("input[type='number'].params")) {
parameters[element.id] = element.valueAsNumber; parameters[element.id] = element.disabled ? null : element.valueAsNumber;
} }
for (let element of $$("select:not([disabled]):not(.localonly)")) { for (let element of $.all("input[type='number']:not(.local-only):not(.params)")) {
parameters[element.id] = element.value || element.dataset.default; options[element.id] = element.disabled ? null : element.valueAsNumber;
} }
for (let element of $$("input[type='checkbox']:not([disabled])")) { for (let element of $.all("select:not(.local-only).columns")) {
parameters[element.id] = element.checked; options.mapping[element.id] = element.value;
} }
if (parameters.slice && $('#subcategory').dataset.values) { for (let element of $.all("select:not(.local-only):not(.columns)")) {
parameters.subcategory = $('#subcategory').dataset.values.split(','); options[element.id] = element.disabled ? null : element.value;
} }
for (let element of $$("input:not(.inactive), select:not(.inactive)")) { for (let element of $.all("input[type='checkbox']:not([disabled]):not(.local-only)")) {
element.disabled = true; options[element.id] = element.checked;
} }
Connection.send(JSON.stringify(parameters)); if (options.slice) {
Status = 'RUNNING'; options.start = $('#offset').valueAsNumber * $('#chunksize').valueAsNumber + 2;
Timer.setTimestamp(true); options.limit = length;
options.subcategories = subcategories.length > 0 ? subcategories: null;
}
$('#send > span.text').innerText = 'Pause'; await Rpc2.invoke('begin', options, parameters);
$('#send > span.icon').classList.remove('hidden'); break;
$('#skip').disabled = false; case 'RUNNING':
await Rpc2.invoke('pause');
break;
case 'STANDBY':
await Rpc2.invoke('resume');
break; break;
default:
try {
let PickerOptions = {
types: [
{
description: "Excel Spreadsheet",
accept: {
"application/vnd.openxmlformats-officedocument.spreadsheetml.sheet": ['.xlsx']
}
}
]
};
$('#send > span.icon').classList.remove('hidden');
let [handle] = await showOpenFilePicker(PickerOptions);
let file = await handle.getFile();
let buffer = await new Promise((resolve, reject) => {
let reader = new FileReader();
reader.onload = () => resolve(reader.result);
reader.onerror = () => reject(reader.error);
reader.readAsArrayBuffer(file);
});
Connection.send(file.name);
Connection.send(buffer);
Status = 'READY';
$('#fileLabel').innerText = file.name;
$('#send > span.text').innerText = 'Send';
$('#cancel').disabled = false;
$('#send').disabled = true;
} finally {
$('#send > span.icon').classList.add('hidden');
}
} }
}
$.set('#send', 'click', async () => {
$('#send > span.icon').removeAttribute('hidden');
$('#send > span.text').innerText = '';
$('#send').classList.remove('pulse');
$('#send').disabled = true;
busy = true;
busy = await handlePrimaryButtonClick().then(() => false, () => false);
}); });
$$$('#skip', 'click', (e) => { $.set('#cancel', 'click', async () => {
Connection.send('BYPASS');
if (Status === 'STANDBY') Connection.send('ONHOLD');
$('#skip').disabled = true;
});
$$$('#cancel', 'click', (e) => {
Connection.send('CANCEL');
$('#cancel').disabled = true; $('#cancel').disabled = true;
await Rpc2.notify('cancel');
}); });
$$$('#locale', 'change', (e) => { $.set('#skip', 'click', async () => {
$('#group_by').dispatchEvent(new Event('change')); $('#skip').disabled = true;
$('#timezoneLabel').dataset.timezone = Locales.find((x) => x.locale == e.target.value).timezone; await Rpc2.notify('skip');
}); });
$$$('#slice', 'change', (e) => { $.set('#locale', 'change', (e) => {
for (let element of $$('.slicing:not(.inactive)')) { locale = Array.from(locales).find(o => o.name == e.target.value);
$('#groupby').dispatchEvent(new Event('change'));
});
$.set('#logs', 'change', (e) => {
if (e.target.checked) $('#messages').removeAttribute('hidden');
else $('#messages').setAttribute('hidden', '');
$('#messages').scrollIntoView({ block: 'center' });
$('#messages').scrollTop = $('#messages').scrollHeight;
});
$.set('#slice', 'change', (e) => {
for (let element of $.all('.slicing:not(.inactive)')) {
element.disabled = !e.target.checked; element.disabled = !e.target.checked;
} }
$('#subcategory').dispatchEvent(new Event('change'));
}); });
$$$('#nospam', 'change', (e) => { $.set('#nospam', 'change', (e) => {
$('#max_occurrence').classList.toggle('inactive'); $('#occurrence').classList.toggle('inactive');
$('#max_occurrence').disabled = !e.target.checked; $('#occurrence').disabled = !e.target.checked;
$('#column_code').required = e.target.checked; $('#code').required = e.target.checked;
}); });
$$$('#column_pays', 'change', (e) => { $.set('#region', 'change', async (e) => {
$('#group_by').dispatchEvent(new Event('change')); unique = await Rpc2.invoke('unique', e.target.value).catch(() => new Object());
$('#groupby').dispatchEvent(new Event('change'));
}); });
$$$('#group_by', 'change', (e) => { $.set('#groupby', 'change', (e) => {
let columns = Columns ? Columns[$('#column_pays').value] : null; let countries = Object.assign({}, unique);
let countries = Object.assign({}, columns); let results = new Object();
let results = {};
switch (e.target.value) { switch (e.target.value) {
case 'none': case 'none':
case 'country': case 'region':
results = countries; Object.assign(results, countries);
break; break;
case 'locale': case 'locale':
let locale = $('#locale').value; for (let target of locales.toReversed()) {
let targets = Locales.toReversed();
for (let target of targets) {
for (let key of Object.keys(countries)) { for (let key of Object.keys(countries)) {
if (target.predicate.length == 0 || target.predicate.includes(key)) { if (target.keywords.length == 0 || target.keywords.includes(key)) {
if (target.locale === locale) { if (target.name === locale.name) {
results[key] = countries[key]; results[key] = countries[key];
} }
delete countries[key]; delete countries[key];
@@ -373,7 +353,7 @@ $$$('#group_by', 'change', (e) => {
$('#subcategory').classList.add('inactive'); $('#subcategory').classList.add('inactive');
$('#subcategory').disabled = true; $('#subcategory').disabled = true;
break; break;
case 'country': case 'region':
case 'locale': case 'locale':
$('#subcategory').classList.remove('inactive'); $('#subcategory').classList.remove('inactive');
$('#subcategory').disabled = false; $('#subcategory').disabled = false;
@@ -383,172 +363,118 @@ $$$('#group_by', 'change', (e) => {
for (let [key, value] of Object.entries(results)) { for (let [key, value] of Object.entries(results)) {
let option = new Option(`${key} (${value})`, key); let option = new Option(`${key} (${value})`, key);
option.dataset.count = value;
$('#subcategory').options.add(option); $('#subcategory').options.add(option);
} }
$('#subcategory').dispatchEvent(new Event('change')); $('#subcategory').dispatchEvent(new Event('change'));
}); });
$$$('#subcategory', 'change', (e) => { $.set('#subcategory', 'change', (e) => {
let options = Array.from(e.target.options).filter((v) => v.selected); if (!unique) return;
let values = options.map((o) => o.value).join(','); subcategories = Array.from(e.target.options).filter(o => o.selected).map(o => o.value);
let limit = options.reduce((i, v) => i + Number(v.dataset.count), 0); length = Object.entries(unique).filter(([k]) => subcategories.includes(k)).reduce((o, [_, v]) => o + v, 0);
$('#chunksize').dispatchEvent(new Event('change'));
$('#subcategory').dataset.limit = limit;
$('#subcategory').dataset.values = values;
$('#chunk_size').dispatchEvent(new Event('change'));
}); });
$$$('#chunk_size', 'change', (e) => { $.set('#chunksize', 'change', (e) => {
let limit = Number($('#subcategory').dataset.limit) || Limit; let n = length || limit;
let size = Math.floor(limit / e.target.value); let size = Math.floor(n / e.target.valueAsNumber);
$('#limit').value = size; $('#limit').value = size;
$('#offset').max = size; $('#offset').max = size;
$('#offset').value = 0; $('#offset').value = 0;
$('#offset').dispatchEvent(new Event('change')); $('#offset').dispatchEvent(new Event('change'));
}); });
$$$('#offset', 'change', (e) => { $.set('#offset', 'change', (e) => {
let limit = Number($('#subcategory').dataset.limit) || Limit; let n = length || limit;
let size = Number($('#chunk_size').value) || 0; let size = $('#chunksize').valueAsNumber;
let offset = n - size * e.target.valueAsNumber;
if ($('#slice').checked) { length = Math.min(size, offset);
limit = Math.min(size, limit - size * Number(e.target.value));
}
e.target.dataset.limit = limit;
}); });
function main(url, parameters, locales) { for (let item of Array.from(locales)) {
Connection = new WebSocket(url); $('#locale').add(new Option(item.name.toUpperCase(), item.name));
Locales = JSON.parse(locales); $('#locale').dispatchEvent(new Event('change'));
}
for (let [key, value] of Object.entries(parameters)) { for (let element of $.all('.columns')) {
$(`input#${key}`)?.setAttribute('value', value); for (let [key, value] of Object.entries(mapping)) {
element.options.add(new Option(value, value, false, element.id === key));
}
}
for (let element of $.all('.params')) {
element.value = parameters[element.id];
}
while (await new Promise(o => setTimeout(o, 1000, true))) {
let history = await Rpc2.invoke('history').catch(() => []);
let logs = Array.from(history);
for (let record of logs) {
if ($('#messages').childNodes.length >= 500) $('#messages').childNodes.item(0)?.remove();
if (record.levelno >= 40) alert(`(${record.levelname}) ` + [record.msg, record.exc_text].filter(Boolean).join('\n'));
let message = LogRecord.format(record);
let node = document.createTextNode(new String(message).concat('\n'));
$('#messages').appendChild(node);
$('#messages').scrollTop = $('#messages').scrollHeight;
} }
for (let item of Locales) { if (busy) continue;
$('#locale').add(new Option(item.locale.toUpperCase(), item.locale)); status = await Rpc2.invoke('status').catch(() => null);
$('#locale').dispatchEvent(new Event('change')) $('#statusLabel').innerText = status ? status.charAt(0).toUpperCase() + status.slice(1).toLowerCase() : '';
switch (status) {
case 'IDLE':
$('#send > span.text').innerText = 'Open';
$('#send').classList.remove('pulse');
await writable?.abort().catch(() => void 0).finally(() => writable = null);
break;
case 'READY':
$('#send > span.text').innerText = 'Send';
$('#send').classList.remove('pulse');
$('#progressLabel').innerText = '';
$('#remainingLabel').innerText = '';
break;
case 'CLOSING':
try {
if (writable === null) break;
let data = await filereader().then(([_, b]) => Rpc2.invoke('merge', new Uint8Array(b).toBase64()));
await writable.write(Uint8Array.fromBase64(data));
await writable.close();
await Rpc2.notify('close');
} catch (e) {
alert('(ERROR) ' + String(e ?? 'File operation failed'));
await writable.abort().catch(() => void 0);
}
writable = null;
case 'RUNNING':
$('#send > span.text').innerText = 'Pause';
$('#send').classList.add('pulse');
$('#timezoneLabel').innerText = Temporal.Now.zonedDateTimeISO(locale.timezone).toLocaleString(locale.name);
let { done, email, subject, recipient } = await Rpc2.invoke('progress').catch(() => new Object());
$('#progressLabel').innerText = `${parseFloat(done / (length || limit) * 100).toFixed(2)}% (${done}/${length || limit})`
$('#subjectLabel').innerText = subject ?? '';
$('#recipientLabel').innerText = recipient ? `${recipient} <${email}>` : email ?? '';
let uptime = await Rpc2.invoke('uptime').catch(() => 0);
$('#uptimeLabel').innerText = Temporal.Duration.from({ seconds: uptime }).round({ largestUnit: 'hours' }).toLocaleString('en', { style: 'digital' });
let rate = done / uptime
let remaining = done ? Math.floor(((length || limit) - done) / rate) : 0;
$('#remainingLabel').innerText = remaining ? `${Temporal.Duration.from({ seconds: remaining }).round({ largestUnit: 'hours' }).toLocaleString('en')} (${rate.toFixed(2)}/min)` : '';
break;
case 'STANDBY':
$('#send > span.text').innerText = 'Resume';
$('#send').classList.remove('pulse');
break;
} }
$('#send > span.icon').setAttribute('hidden', '');
$('#send').disabled = false;
Connection.addEventListener('message', (e) => { let actions = await Rpc2.invoke('actions').catch(() => new Object());
let command = JSON.parse(e.data); $('#cancel').disabled = !actions['Cancel'];
let {name, args} = command; $('#skip').disabled = !actions['Skip'];
switch (name) {
case 'setAddress':
let [person, address] = args;
document.title = `${person} (${address})`;
$('#fromLabel').innerText = address;
break;
case 'setSubject':
let [subject] = args;
$('#subjectLabel').innerText = subject;
break;
case 'setMetadata':
[Limit, Columns] = args;
for (let element of $$('.columns')) {
let options = element.options;
options.length = 1;
for (let column of Object.keys(Columns)) {
options.add(new Option(column, column, false, column === parameters[element.id]));
}
element.dataset.default = parameters[element.id];
element.dispatchEvent(new Event('change'));
}
$('#send').disabled = false;
$('#cancel').disabled = false;
break;
case 'setProgress':
let [index, name, recipient, sent, warnings, errors, attempt] = args;
let label = name ? `${name} <${recipient}>` : recipient;
$('#recipientLabel').innerText = label;
$('#progressLabel').dataset.sent = sent;
$('#progressLabel').dataset.index = index;
$('#progressLabel').dataset.errors = errors;
$('#progressLabel').dataset.attempt = attempt;
$('#progressLabel').dataset.warnings = warnings;
break;
case 'setStatus':
switch (args[0]) {
case 'RESUME':
Timer.setTimestamp();
case 'BYPASS':
Status = 'RUNNING';
$('#send').disabled = false;
$('#skip').disabled = false;
break;
case 'ONHOLD':
Status = 'STANDBY';
$('#send').disabled = false;
Timer.setTimedelta();
break;
case 'FAILED':
Status = 'STANDBY';
$('#send > span.text').innerText = 'Resume';
$('#send > span.icon').classList.add('hidden');
Timer.setTimedelta();
break;
case 'FINISH':
let {sent, warnings, errors} = $('#progressLabel').dataset;
alert(`${sent||0} Sent; ${warnings||0} Warning(s); ${errors||0} Error(s)`);
case 'CANCEL':
Status = null;
$('#send > span.text').innerText = 'Open';
$('#send > span.icon').classList.add('hidden');
$('#cancel').disabled = true;
$('#skip').disabled = true;
for (let element of $$("input:not(.inactive):not(.slicing)")) {
element.disabled = false;
}
for (let element of $$("select:not(.inactive):not(.slicing)")) {
element.disabled = false;
}
for (let element of $$("input[type='checkbox']")) {
element.dispatchEvent(new Event('change'));
}
break;
}
break;
case 'tell':
let [message, level] = args;
let prefix = level === 0 ? 'ERROR' : level === 1 ? 'WARNING' : 'INFO';
console.log(`[${prefix}] ${message}`);
if (level === 0) alert(message);
break;
}
});
let clock = setInterval(() => {
let timezone = $('#timezoneLabel').dataset.timezone;
let city = timezone.split('/')[1];
let date = dayjs().tz(timezone).format("YYYY-MM-DD HH:mm:ss");
$('#timezoneLabel').innerText = `${date} (${city})`;
$('#statusLabel').innerText = Status ? Status.charAt(0).toUpperCase() + Status.slice(1).toLowerCase() : 'Idle';
if (Status === 'RUNNING') {
let index = Number($('#progressLabel').dataset.index) || 0;
let limit = Number($('#offset').dataset.limit) || 0;
let percentage = parseFloat((index / limit * 100).toFixed(2));
$('#progressLabel').innerText = `${index} / ${limit} (${percentage} %)`;
let uptime = Timer.getTimedelta();
$('#uptimeLabel').innerText = uptime.format("HH:mm:ss");
let rate = Number($('#progressLabel').dataset.sent) / uptime.asSeconds();
let spm = parseFloat(Number(rate*60).toFixed(2));
$('#remainingLabel').innerHTML = rate > 0 ? `<span>${dayjs.duration((limit - index) / rate, 'second').humanize()}</span>` : '';
$('#remainingLabel').innerHTML += spm >= 1 ? `<span class="${spm > 8.33 ? 'rate warning' : 'rate'}">${spm} per minute</span>` : '';
}
}, 500);
} }
</script> </script>
@@ -564,15 +490,33 @@ form {
padding: 0 1em 0 1em; padding: 0 1em 0 1em;
} }
select, option, input[type='checkbox'] {
cursor: pointer;
}
label { label {
user-select: none; user-select: none;
width: fit-content; width: fit-content;
} }
.rate:not(:first-child)::before { #actions {
padding: 0em 0.4em; max-height: 2.5em;
content: '–'; column-gap: 0.4em;
color: #666; }
#actions > button {
height: stretch;
}
#messages {
resize: none;
white-space: pre-wrap;
margin-top: 24px;
width: 100%;
}
#mesages:focus {
outline: none;
} }
.inline-flex { .inline-flex {
@@ -586,14 +530,6 @@ label {
white-space: nowrap; white-space: nowrap;
} }
.warning {
color: orangered;
}
.hidden {
display: none;
}
.gaps { .gaps {
row-gap: 0.4em; row-gap: 0.4em;
} }
@@ -611,9 +547,19 @@ label {
animation: spin 1s linear infinite; animation: spin 1s linear infinite;
} }
.pulse {
animation: pulse 2s cubic-bezier(0.4, 0, 0.6, 1) infinite;
}
@keyframes spin { @keyframes spin {
to { to {
transform: rotate(360deg); transform: rotate(360deg);
} }
} }
@keyframes pulse {
50% {
opacity: 0.6;
}
}
</style> </style>

980
main.py
View File

File diff suppressed because it is too large Load Diff

3
profiles/profile-example.bat
View File

@@ -1,3 +1,4 @@
cd /D .\..\ cd /D .\..\
.\venv\Scripts\pythonw.exe .\main.py --address "user@example.com" --password "example" --interval 10 set SE_PROXY=http://127.0.0.1:10809
.\venv\Scripts\pythonw.exe .\main.py "user@example.com" "example" --interval 10
@pause @pause

BIN
requirements.txt
View File

Binary file not shown.