feat: yönetici için 'şimdi gönder' (POST /api/notify/run?zorla=1)

Bildirim turunu temel-alma adımını atlayarak çalıştırır; abonelik kriterine uyan
ihaleler hemen e-posta olarak gönderilir. Test ve talep üzerine özet için.
This commit is contained in:
2026-08-29 03:22:03 +03:00
parent f86339417a
commit c64889782f
2 changed files with 10 additions and 8 deletions
+1 -1
View File
@@ -617,7 +617,7 @@ const server = http.createServer(async (req, res) => {
const user = userFromAuthHeader(req.headers['authorization']);
if (!user?.isAdmin) return json(res, 403, { success: false, error: 'yönetici yetkisi gerekli' });
try {
const sonuc = await bildirimleriIsle(() => tendersPayload());
const sonuc = await bildirimleriIsle(() => tendersPayload(), { zorla: url.searchParams.get('zorla') === '1' });
return json(res, 200, { success: true, ...sonuc });
} catch (e) {
return json(res, 502, { success: false, error: e.message });
+9 -7
View File
@@ -41,7 +41,7 @@ function bildirilebilir(t) {
* Tüm aktif abonelikleri işler.
* @param {Function} tenderGetir () => Promise<{tenders: []}>
*/
export async function bildirimleriIsle(tenderGetir) {
export async function bildirimleriIsle(tenderGetir, { zorla = false } = {}) {
if (process.env.NOTIFY_ENABLED === '0') return { atlandi: 'kapalı' };
if (!available()) return { atlandi: 'depo yok' };
if (!emailConfigured()) return { atlandi: 'e-posta yapılandırılmamış' };
@@ -63,11 +63,13 @@ export async function bildirimleriIsle(tenderGetir) {
const yeniler = eslesen.filter((t) => !gorulen.has(t.id));
// İlk kurulumda geçmişi spam'lemeyelim: sadece işaretle, gönderme.
if (!a.sonGonderim) {
// zorla=true ise (yönetici "şimdi gönder" dediğinde) bu adım atlanır.
if (!a.sonGonderim && !zorla) {
markSent(a.id, eslesen.map((t) => t.id));
continue;
}
if (!yeniler.length) continue;
const gonderilecek = zorla && !yeniler.length ? eslesen.slice(0, maxAdet) : yeniler;
if (!gonderilecek.length) continue;
const kriterMetni = [
a.sehir && `İl: ${a.sehir}`,
@@ -77,20 +79,20 @@ export async function bildirimleriIsle(tenderGetir) {
a.kurumlar?.length && `${a.kurumlar.length} favori kurum`,
].filter(Boolean).join(' · ') || 'Tüm ihaleler';
const html = tenderDigestHtml({ name: a.ad || a.email, tenders: yeniler.slice(0, maxAdet) })
const html = tenderDigestHtml({ name: a.ad || a.email, tenders: gonderilecek.slice(0, maxAdet) })
+ `<p style="font-family:Arial,sans-serif;font-size:11px;color:#8b93a4;max-width:640px;margin:12px auto 0">
Kriteriniz: ${kriterMetni} — toplam ${yeniler.length} yeni ihale.
Kriteriniz: ${kriterMetni} — toplam ${gonderilecek.length} ihale.
Bu bildirimi uygulamadaki Mobil PWA → E-posta Bildirimi bölümünden kapatabilirsiniz.
</p>`;
await sendEmail({
to: a.email,
subject: `İhaleist — ${yeniler.length} yeni ihale (${kriterMetni})`,
subject: `İhaleist — ${gonderilecek.length} ihale (${kriterMetni})`,
html,
});
markSent(a.id, eslesen.map((t) => t.id));
gonderilen++;
console.log(`[notifier] ${a.email} → ${yeniler.length} yeni ihale gönderildi (${kriterMetni})`);
console.log(`[notifier] ${a.email} → ${gonderilecek.length} ihale gönderildi (${kriterMetni})`);
} catch (e) {
hata++;
console.warn(`[notifier] abonelik ${a.id} gönderilemedi: ${e.message}`);