// ==UserScript== // @name Peatix Full Category Parser and Sender // @namespace tweeks.io // @author Tweeks // @version 3.4.1 // @description Parses Peatix categories, sends first messages in batches, sends second messages to each batch, then automatically resumes the same cycle until the event queue is finished. // @match https://peatix.com/* // @match https://peatix.com/search* // @match https://peatix.com/event/* // @match https://*.peatix.com/* // @grant GM_openInTab // @grant GM_registerMenuCommand // @grant GM_unregisterMenuCommand // @grant TW_notifications // @run-at document-idle // ==/UserScript== (function () { 'use strict'; const KEY = 'twPeatixSenderStateV1'; const OPEN_TABS_COMMAND_KEY = 'twPeatixOpenTabsCommandV1'; const FIXED_DELAY_SECONDS = 2; const DEFAULT_STATE = { running: false, phase: 'idle', queue: [], parsedQueue: [], index: 0, subject: '', message: '', secondMessages: ['', '', '', '', ''], followupLimit: 10, sentSinceFollowup: 0, sentFollowups: {}, followupQueue: [], followupIndex: 0, followupReturn: null, minDelay: FIXED_DELAY_SECONDS, maxDelay: FIXED_DELAY_SECONDS, processedOrganizers: {}, processedOrganizerKeys: {}, processedEvents: {}, parsedEvents: {}, searchUrl: '', nextSearchUrl: '', pageNumber: 0, hasNextPage: false, emptyPageStreak: 0, maxEmptyPages: 2, category: '', openTabsMax: 20, parserVisitedSearchUrls: {}, parserStartedAt: 0, sendOnlyParsed: true }; let menuIds = []; let floatingHost = null; let floatingRoot = null; const sleep = (ms) => new Promise(resolve => setTimeout(resolve, ms)); const text = (el) => (el?.textContent || '').replace(/\s+/g, ' ').trim(); const toast = async (message, type = 'info') => { try { await TW_toast(message, type, 'Peatix Sender', 5000); } catch (_) { console.log('[Peatix Sender]', message); } }; function normalizeSecondMessages(value, legacyValue) { const list = Array.isArray(value) ? value : []; const merged = list.concat(legacyValue ? [legacyValue] : []); const cleaned = merged.map(v => String(v || '').trim()).filter(Boolean); while (cleaned.length < 5) cleaned.push(''); return cleaned.slice(0, 5); } function getConfiguredSecondMessages(state) { return normalizeSecondMessages(state.secondMessages, state.secondMessage).filter(Boolean); } function getSecondMessageForIndex(state, index) { const messages = getConfiguredSecondMessages(state); return messages.length ? messages[index % messages.length] : ''; } function loadState() { try { const saved = JSON.parse(localStorage.getItem(KEY) || '{}'); const state = Object.assign({}, DEFAULT_STATE, saved); state.queue = sanitizeEventItems(Array.isArray(state.queue) ? state.queue : []); state.parsedQueue = sanitizeEventItems(Array.isArray(state.parsedQueue) ? state.parsedQueue : []); state.processedOrganizers = state.processedOrganizers || {}; state.processedOrganizerKeys = state.processedOrganizerKeys || {}; state.processedEvents = state.processedEvents || {}; state.parsedEvents = state.parsedEvents || {}; state.parserVisitedSearchUrls = state.parserVisitedSearchUrls || {}; state.secondMessages = normalizeSecondMessages(state.secondMessages, state.secondMessage); state.followupLimit = Math.max(1, Math.min(50, Number(state.followupLimit) || 10)); state.sentSinceFollowup = Math.max(0, Number(state.sentSinceFollowup) || 0); state.sentFollowups = state.sentFollowups || {}; state.followupQueue = Array.isArray(state.followupQueue) ? state.followupQueue : []; state.followupIndex = Math.max(0, Number(state.followupIndex) || 0); state.followupReturn = state.followupReturn && typeof state.followupReturn === 'object' ? state.followupReturn : null; if (typeof state.sendOnlyParsed !== 'boolean') state.sendOnlyParsed = true; state.minDelay = FIXED_DELAY_SECONDS; state.maxDelay = FIXED_DELAY_SECONDS; if (!state.phase) state.phase = state.running ? 'send' : 'idle'; return state; } catch (_) { return Object.assign({}, DEFAULT_STATE); } } function saveState(state) { localStorage.setItem(KEY, JSON.stringify(state)); rebuildMenu(); updateFloatingMenu(); } function stop(reason) { const state = loadState(); state.running = false; state.phase = 'idle'; saveState(state); const command = loadOpenTabsCommand(); if (command && command.running) { command.running = false; command.stoppedAt = Date.now(); saveOpenTabsCommand(command); } if (reason) toast(reason, 'warning'); } function randomDelayMs(_state) { return FIXED_DELAY_SECONDS * 1000; } function normalizeOrganizer(textValue) { return String(textValue || '').replace(/^By\s+/i, '').replace(/\s+/g, ' ').trim().toLowerCase(); } function normalizeOrganizerUrl(url) { if (!url) return ''; try { const u = new URL(url, location.href); u.hash = ''; u.search = ''; return u.href.replace(/\/$/, '').toLowerCase(); } catch (_) { return String(url || '').trim().toLowerCase(); } } function normalizeUrlNoHash(url) { try { const u = new URL(url, location.href); u.hash = ''; return u.href; } catch (_) { return String(url || '').replace(/#.*$/, ''); } } function cleanOrganizerUrlForItem(organizerUrl, eventUrl) { const normalizedOrganizer = normalizeOrganizerUrl(organizerUrl || ''); if (!normalizedOrganizer) return ''; const normalizedEvent = normalizeEventUrl(eventUrl || ''); if (normalizedEvent && normalizeEventUrl(normalizedOrganizer) === normalizedEvent) return ''; if (/\/event\/\d+\/?$/i.test(normalizedOrganizer)) return ''; return normalizedOrganizer; } function normalizeEventUrl(url) { try { const u = new URL(url, location.href); const eventPath = u.pathname.match(/^\/event\/(\d+)/); if (eventPath) return `https://peatix.com/event/${eventPath[1]}`; const idFromQuery = u.searchParams.get('utm_content') || u.searchParams.get('event_id') || u.searchParams.get('id'); if (/^\d{5,}$/.test(idFromQuery || '')) return `https://peatix.com/event/${idFromQuery}`; const content = u.href.match(/[?&]utm_content=(\d{5,})/); if (content) return `https://peatix.com/event/${content[1]}`; return u.origin + u.pathname; } catch (_) { return String(url || ''); } } function currentEventUrl() { return normalizeEventUrl(location.href); } function getEventId(url) { const m = String(url || '').match(/\/event\/(\d+)/); return m ? Number(m[1]) : 0; } function hasRealEventMetadata(item) { return !!String(item?.title || item?.organizer || item?.organizerName || item?.organizerUrl || '').trim(); } function isClearlyBadEventItem(item) { const normalized = normalizeEventUrl(item?.url || item?.rawUrl || item?.href || ''); const id = getEventId(normalized); if (!id) return true; // Peatix category/tag records in sessionStorage also have small numeric IDs. // Older script versions accidentally converted those category IDs into /event/, // which opens Peatix's "The requested page was not found on this server" page. const raw = String(item?.rawUrl || item?.href || item?.url || ''); const cameFromSearchClick = /[?&](utm_source=results|utm_campaign=search|srchid=|utm_medium=)/i.test(raw); return id < 100000 && !cameFromSearchClick; } function sanitizeEventItems(items) { return (Array.isArray(items) ? items : []) .filter(item => !isClearlyBadEventItem(item)) .map(item => { const url = normalizeEventUrl(item?.url || item?.rawUrl || item?.href || ''); const category = String(item?.category || '').split(',').map(s => s.trim()).filter(s => s && !isGenericPeatixKeyword(s)).join(', '); return Object.assign({}, item, { url, organizerUrl: cleanOrganizerUrlForItem(item?.organizerUrl || '', url), category }); }); } function getNavigationUrl(item) { const candidate = item?.rawUrl || item?.href || item?.url || ''; if (!candidate) return ''; try { const u = new URL(candidate, location.href); u.hash = ''; return u.href; } catch (_) { return String(candidate || ''); } } function isRequestedPageNotFound() { const pageText = `${document.title || ''} ${text(document.querySelector('h1'))} ${text(document.body).slice(0, 2000)}`.toLowerCase(); return /the requested page was not found on this server|requested page was not found|page not found|404 not found/.test(pageText); } function dedupeStrings(values) { const out = []; const seen = new Set(); values.map(v => String(v || '').replace(/\s+/g, ' ').trim()).filter(Boolean).forEach(v => { const k = v.toLowerCase(); if (!seen.has(k)) { seen.add(k); out.push(v); } }); return out; } function getOrganizerKeys(item) { const keys = []; const name = normalizeOrganizer(item?.organizer || item?.organizerName || ''); const url = cleanOrganizerUrlForItem(item?.organizerUrl || '', item?.url || item?.rawUrl || ''); if (name) keys.push(`name:${name}`); if (url) keys.push(`url:${url}`); return keys; } function isOrganizerProcessed(state, item) { const keys = getOrganizerKeys(item); if (keys.some(k => state.processedOrganizerKeys?.[k])) return true; const normalizedName = normalizeOrganizer(item?.organizer || item?.organizerName || ''); return !!(normalizedName && state.processedOrganizers?.[normalizedName]); } function markOrganizerProcessed(state, item) { const keys = getOrganizerKeys(item); const rec = { time: Date.now(), event: item?.url || currentEventUrl(), organizer: item?.organizer || '' }; keys.forEach(k => { state.processedOrganizerKeys[k] = rec; }); const normalizedName = normalizeOrganizer(item?.organizer || item?.organizerName || ''); if (normalizedName) state.processedOrganizers[normalizedName] = rec; } function isGenericPeatixKeyword(value) { return /^(online event management|sell tickets online|online payments|mobile tickets|ticketing app|find events|discover events)$/i.test(String(value || '').trim()); } function getCurrentCategoryFromPageOrUrl() { const params = new URLSearchParams(location.search); const direct = params.get('category') || params.get('cat') || params.get('tag') || params.get('tags') || params.get('q') || ''; if (direct) return direct; const visibleQuery = text(document.querySelector('input[type="search"], input[name="q"], .search-keyword, .search-query')); if (visibleQuery && !/search results|events near/i.test(visibleQuery)) return visibleQuery; const metaKeywords = document.querySelector('meta[name="keywords"]')?.getAttribute('content') || ''; const candidates = metaKeywords.split(',').map(s => s.trim()).filter(s => s && !isGenericPeatixKeyword(s)); return candidates.slice(0, 4).join(', '); } function extractCategoryFromUrl(url) { try { const u = new URL(url, location.href); return u.searchParams.get('category') || u.searchParams.get('cat') || u.searchParams.get('tag') || u.searchParams.get('tags') || ''; } catch (_) { return ''; } } function isSearchLikePage() { if (location.pathname === '/search' || location.pathname.startsWith('/search/')) return true; return !!document.querySelector('a.event-card[href], a.event-name[href], .event-card a[href], [data-testid*="event"] a[href*="/event/"]'); } function getPageNumberFromUrl(url) { try { const u = new URL(url, location.href); const p = Number(u.searchParams.get('p') || '1'); return Number.isFinite(p) && p > 0 ? p : 1; } catch (_) { return 1; } } function getCurrentSearchPageNumber() { const fromDom = text(document.querySelector('section.event-pagination .current')).match(/\d+/); if (fromDom) { const p = Number(fromDom[0]); if (Number.isFinite(p) && p > 0) return p; } return getPageNumberFromUrl(location.href); } function findNextPaginationControl() { const candidates = [ 'section.event-pagination .next[aria-label="Next"]', 'section.event-pagination .next', 'section.event-pagination [aria-label*="next" i]', 'section.event-pagination [aria-label*="след" i]' ]; for (const selector of candidates) { const el = document.querySelector(selector); if (!el) continue; const inline = String(el.getAttribute('style') || '').toLowerCase(); const cls = String(el.className || '').toLowerCase(); const ariaDisabled = String(el.getAttribute('aria-disabled') || '').toLowerCase() === 'true'; if (inline.includes('display: none') || inline.includes('visibility: hidden') || cls.includes('disabled') || ariaDisabled) continue; if (typeof isVisible === 'function' && !isVisible(el)) continue; return el; } return null; } function hasNextPaginationControl() { return !!findNextPaginationControl(); } function buildNextSearchPageUrlByParam(baseUrl = location.href) { try { const u = new URL(baseUrl, location.href); if (!u.pathname.startsWith('/search')) return ''; const p = getPageNumberFromUrl(u.href); u.searchParams.set('p', String(p + 1)); return u.href; } catch (_) { return ''; } } function inferNextSearchPageUrl(baseUrl = location.href) { // Peatix search pages use the p= query parameter. The requested flow is: // finish the current page, replace/increment the page number in the URL, open it, // parse that page, send, and repeat. const paramNext = buildNextSearchPageUrlByParam(baseUrl); if (paramNext) return paramNext; const relNext = document.querySelector('a[rel="next"][href], a[aria-label*="next" i][href], a[aria-label*="след" i][href]'); if (relNext?.href) return relNext.href; const nextByText = [...document.querySelectorAll('a[href]')].find(a => /^(next|older|›|»|след|далее)$/i.test(text(a))); if (nextByText?.href) return nextByText.href; return ''; } async function waitForNextPaginationControl(timeout = 15000) { const end = Date.now() + timeout; while (Date.now() < end) { const el = findNextPaginationControl(); if (el) return el; await sleep(300); } return null; } function getSearchPageSignature() { const current = text(document.querySelector('section.event-pagination .current')); const urls = collectQueueFromDOM().slice(0, 6).map(item => item.url).join('|'); return `${location.href}::${current}::${urls}`; } function extractCategoriesFromEventPage(title, organizer) { const meta = document.querySelector('meta[name="keywords"]')?.getAttribute('content') || ''; const bad = new Set([ normalizeOrganizer(title), normalizeOrganizer(organizer), 'online event management', 'sell tickets online', 'online payments', 'mobile tickets', 'ticketing app', 'find events', 'discover events' ]); const fromMeta = meta.split(',').map(s => s.trim()).filter(s => s && !bad.has(normalizeOrganizer(s))); const fromLinks = [...document.querySelectorAll('a[href*="tag"], a[href*="category"], a[href*="search"]')] .map(a => text(a)) .filter(s => s && s.length < 60 && !/^view more$/i.test(s)); return dedupeStrings([...fromMeta, ...fromLinks]).slice(0, 8); } function parseEventPageMetadata(baseItem = {}) { const title = text(document.querySelector('h1')) || document.querySelector('meta[property="og:title"]')?.getAttribute('content') || document.title.replace(/\s*\|\s*Peatix.*$/i, '').trim() || baseItem.title || ''; const organizerLink = document.querySelector('.event-organizer .pod-thumb__name-link[href], .event-organizer a[href*="peatix.com"]:not([aria-hidden="true"]), a.pod-thumb__name-link[href]'); const organizerHiddenLink = document.querySelector('.event-organizer a[aria-label][href*="peatix.com"]'); const bySpan = [...document.querySelectorAll('.event-summary__subtitle span, .group-organizer, p')].find(el => /^By\s+/i.test(text(el))); const organizer = text(organizerLink) || organizerHiddenLink?.getAttribute('aria-label') || normalizeOrganizer(text(bySpan)) || baseItem.organizer || ''; const organizerUrl = organizerLink?.href || organizerHiddenLink?.href || baseItem.organizerUrl || ''; const categories = extractCategoriesFromEventPage(title, organizer); const category = categories.join(', ') || baseItem.category || getCurrentCategoryFromPageOrUrl(); return Object.assign({}, baseItem, { url: currentEventUrl(), title, organizer, organizerUrl: cleanOrganizerUrlForItem(organizerUrl, currentEventUrl()), category, categories, parsedAt: Date.now() }); } function getCardOrganizer(card) { const selectors = ['.event-organizer', '.group-organizer', '[class*="organizer"]', '[data-testid*="organizer"]']; for (const selector of selectors) { const found = card.querySelector(selector); if (found) return normalizeOrganizer(text(found)); } const by = [...card.querySelectorAll('p, span, div')].map(text).find(t => /^By\s+/i.test(t)); return normalizeOrganizer(by || ''); } function getCardTitle(card, link) { return text(card.querySelector('.event-name, [class*="event-name"], [data-testid*="title"]')) || text(link) || ''; } function collectQueueFromDOM() { const pageCategory = getCurrentCategoryFromPageOrUrl(); const linkSelector = [ '.search-event-list a.event-card[href*="/event/"]', '.search-event-list a[href*="/event/"]', '.search-results a.event-card[href*="/event/"]', '.search-results a[href*="/event/"]', 'a.event-card[href*="/event/"]', 'a.event-name[href*="/event/"]', '.event-card a[href*="/event/"]', 'a[href*="utm_content="][href]' ].join(', '); const links = [...document.querySelectorAll(linkSelector)]; return links.map(link => { const rawUrl = link.href; if (/\/event\/\d+\/(attendees|tickets|orders|participants|tickets)|\/event\/create/i.test(rawUrl)) return null; const url = normalizeEventUrl(rawUrl); if (!/\/event\/\d+/.test(url)) return null; const card = link.closest('.event-card, .search-event-list li, .search-results li, article, [data-testid*="event"]') || link.closest('li') || link; const organizerLink = [...card.querySelectorAll('a[href*="peatix.com"], a[href^="/"]')] .find(a => a !== link && !/\/event\/\d+/i.test(a.getAttribute('href') || '') && !a.classList.contains('event-name')); return { url, rawUrl, organizer: getCardOrganizer(card), organizerUrl: cleanOrganizerUrlForItem(organizerLink?.href || '', url), title: getCardTitle(card, link), category: extractCategoryFromUrl(rawUrl) || pageCategory }; }).filter(Boolean); } function collectQueueFromSessionStorage() { const out = []; try { const raw = sessionStorage.getItem('peatix_search_results'); if (!raw) return out; const data = JSON.parse(raw); const currentKey = location.search.replace(/^\?/, ''); const currentPage = getCurrentSearchPageNumber(); const baseKey = (key) => { try { const p = new URLSearchParams(key || ''); p.delete('p'); return [...p.entries()].sort(([a], [b]) => a.localeCompare(b)).map(([k, v]) => `${k}=${v}`).join('&'); } catch (_) { return String(key || '').replace(/(^|&)p=[^&]*/g, '').replace(/^&|&$/g, ''); } }; const wantedBase = baseKey(currentKey); const matchingRecords = Object.entries(data || {}).filter(([key, rec]) => { if (key === currentKey) return true; const page = Number(rec?.data?.page || 1); return page === currentPage && baseKey(key) === wantedBase; }).map(([, rec]) => rec?.data || rec).filter(Boolean); const walk = (value) => { if (!value) return; if (Array.isArray(value)) return value.forEach(walk); if (typeof value === 'object') { const explicitEventUrl = value.event_url || value.eventUrl || value.href || value.tracking_url || value.event_uri || (/\/event\/\d+/i.test(String(value.url || '')) ? value.url : ''); const eventTitle = value.title || value.event_title || value.event_name || (explicitEventUrl ? value.name : '') || ''; const possibleId = value.event_id || value.eventId || value.content_id || (eventTitle ? value.id : ''); const possibleUrl = explicitEventUrl || (possibleId ? `https://peatix.com/event/${possibleId}` : ''); const url = normalizeEventUrl(possibleUrl); const organizerObj = value.organizer || value.owner || value.group || value.pod || {}; const item = { url, rawUrl: possibleUrl, title: eventTitle, organizer: normalizeOrganizer(value.organizer_name || value.group_name || value.pod_name || organizerObj.name || organizerObj.nickname || organizerObj.display_name || ''), organizerUrl: cleanOrganizerUrlForItem(value.organizer_url || value.group_url || organizerObj.url || '', url), category: value.category || value.tag || value.tags?.join?.(', ') || getCurrentCategoryFromPageOrUrl() }; if (/\/event\/\d+/.test(url) && !isClearlyBadEventItem(item) && (explicitEventUrl || eventTitle || item.organizer)) { out.push(item); } Object.values(value).forEach(v => { if (typeof v === 'object') walk(v); }); } }; matchingRecords.forEach(walk); } catch (_) {} return out; } function collectQueueFromSearch() { const state = loadState(); const rawItems = [...collectQueueFromDOM(), ...collectQueueFromSessionStorage()]; const seenUrls = new Set(); const seenOrganizerKeys = new Set(); return rawItems.filter(item => { if (isClearlyBadEventItem(item)) return false; if (!item.url || seenUrls.has(item.url) || state.processedEvents[item.url]) return false; if (isOrganizerProcessed(state, item)) return false; const keys = getOrganizerKeys(item); if (keys.length && keys.some(k => seenOrganizerKeys.has(k))) return false; seenUrls.add(item.url); keys.forEach(k => seenOrganizerKeys.add(k)); return true; }); } async function collectQueueFromSearchWithWait(timeout = 15000) { const end = Date.now() + timeout; let queue = collectQueueFromSearch(); while (!queue.length && Date.now() < end) { await sleep(500); queue = collectQueueFromSearch(); } return queue; } function mergeParsedItems(existing, additions) { const out = sanitizeEventItems(existing).slice(); const seenUrls = new Set(out.map(item => normalizeEventUrl(item?.url || '')).filter(Boolean)); const seenOrganizerKeys = new Set(); out.forEach(item => getOrganizerKeys(item).forEach(k => seenOrganizerKeys.add(k))); let added = 0; sanitizeEventItems(additions).forEach(item => { const url = normalizeEventUrl(item?.url || ''); if (!url || seenUrls.has(url)) return; const keys = getOrganizerKeys(item); if (keys.length && keys.some(k => seenOrganizerKeys.has(k))) return; seenUrls.add(url); keys.forEach(k => seenOrganizerKeys.add(k)); out.push(Object.assign({}, item, { url, parsedAt: item.parsedAt || Date.now() })); added += 1; }); return { items: out, added }; } async function startFullCategoryParser(resetRun = true) { if (!isSearchLikePage()) { const state = loadState(); if (state.searchUrl) { state.running = true; state.phase = 'category-collect'; state.sendOnlyParsed = true; saveState(state); await toast('Open the saved Peatix category/search page to continue parsing.', 'info'); location.href = state.searchUrl; } else { await toast('Open a Peatix search/category page first, then run the category parser.', 'warning'); } return; } const state = loadState(); if (resetRun) { state.queue = []; state.parsedQueue = []; state.index = 0; state.parsedEvents = {}; state.parserVisitedSearchUrls = {}; state.emptyPageStreak = 0; state.parserStartedAt = Date.now(); } state.running = true; state.phase = 'category-collect'; state.sendOnlyParsed = true; state.searchUrl = location.href; state.category = getCurrentCategoryFromPageOrUrl(); saveState(state); await collectFullCategoryPage(); } async function collectFullCategoryPage() { await sleep(1200); const state = loadState(); if (!state.running || state.phase !== 'category-collect') return; if (!isSearchLikePage()) { if (state.searchUrl) location.href = state.searchUrl; return; } const currentSearchUrl = normalizeUrlNoHash(location.href); state.parserVisitedSearchUrls = state.parserVisitedSearchUrls || {}; if (state.parserVisitedSearchUrls[currentSearchUrl]) { state.running = false; state.phase = 'idle'; state.sendOnlyParsed = true; saveState(state); await toast(`Parser stopped to avoid a loop. Parsed queue: ${state.parsedQueue.length}. Now run Sender.`, 'warning'); return; } const pageItems = await collectQueueFromSearchWithWait(15000); const merged = mergeParsedItems(state.parsedQueue, pageItems); state.parsedQueue = merged.items; state.queue = []; state.index = 0; state.parserVisitedSearchUrls[currentSearchUrl] = { time: Date.now(), added: merged.added, totalOnPage: pageItems.length }; state.pageNumber = getCurrentSearchPageNumber(); state.searchUrl = location.href; state.category = getCurrentCategoryFromPageOrUrl(); state.emptyPageStreak = pageItems.length ? 0 : Number(state.emptyPageStreak || 0) + 1; const hasNext = hasNextPaginationControl(); const nextUrl = hasNext ? inferNextSearchPageUrl(location.href) : ''; state.nextSearchUrl = nextUrl; state.hasNextPage = hasNext; saveState(state); await toast(`Parsed category page ${state.pageNumber}: +${merged.added} new, saved total ${state.parsedQueue.length}.`, merged.added ? 'success' : 'info'); if (nextUrl) { await toast(`Parser is opening the next results page: p=${getPageNumberFromUrl(nextUrl)}. Sender will not start automatically.`, 'info'); setTimeout(() => { const s = loadState(); if (s.running && s.phase === 'category-collect') location.href = nextUrl; }, 1200); return; } state.running = false; state.phase = 'idle'; state.sendOnlyParsed = true; state.nextSearchUrl = ''; saveState(state); await toast(`Full category parsing finished. Saved ${state.parsedQueue.length} unique events. Click "Start sender" when ready.`, 'success'); } async function startSenderFromParsed() { const state = loadState(); if (!state.subject.trim() || !state.message.trim()) { showSettings(true); await toast('Enter subject and message before starting sender.', 'warning'); return; } const merged = mergeParsedItems([], state.parsedQueue || []); const sendQueue = merged.items.filter(item => item.url && !state.processedEvents[item.url] && !isOrganizerProcessed(state, item)); if (!sendQueue.length) { await toast('No parsed events are ready to send. First run "Parse full category" on the search/category page.', 'warning'); return; } state.queue = sendQueue; state.index = 0; state.running = true; state.phase = 'send'; state.sendOnlyParsed = true; state.nextSearchUrl = ''; state.hasNextPage = false; saveState(state); await toast(`Sender started from parsed queue: ${sendQueue.length} events. It will not switch between search pages.`, 'success'); location.href = getNavigationUrl(sendQueue[0]); } async function startFromSearch() { const state = loadState(); if (!state.subject.trim() || !state.message.trim()) { showSettings(true); await toast('Enter subject and message before starting.', 'warning'); return; } if (!isSearchLikePage()) { if (state.searchUrl) { state.running = true; state.phase = 'collect'; saveState(state); await toast('Open the saved search/category page to continue page-by-page mode.', 'info'); location.href = state.searchUrl; } else { await toast('Start this sender from a Peatix search/category results page.', 'warning'); } return; } await startCurrentResultsPage(true); } async function startCurrentResultsPage(resetRun) { await sleep(1200); const state = loadState(); const queue = await collectQueueFromSearchWithWait(15000); const hasNext = hasNextPaginationControl(); const nextUrl = hasNext ? inferNextSearchPageUrl(location.href) : ''; if (!queue.length) { state.queue = []; state.parsedQueue = []; state.index = 0; state.emptyPageStreak = Number(state.emptyPageStreak || 0) + 1; if (nextUrl && state.emptyPageStreak <= Number(state.maxEmptyPages || 2)) { state.running = true; state.phase = 'advance'; state.searchUrl = location.href; state.nextSearchUrl = nextUrl; state.pageNumber = getCurrentSearchPageNumber(); state.hasNextPage = hasNext; saveState(state); await toast(`No new unique events on page ${getCurrentSearchPageNumber()}. Opening page ${getPageNumberFromUrl(nextUrl)} next.`, 'warning'); setTimeout(advanceToNextResultsPage, 800); return; } state.running = false; state.phase = 'idle'; saveState(state); await toast('No new unique events found on consecutive pages. Page-by-page run finished.', 'warning'); return; } state.queue = queue; state.parsedQueue = queue.slice(); state.index = 0; state.emptyPageStreak = 0; state.running = true; state.phase = 'send'; state.searchUrl = location.href; state.nextSearchUrl = nextUrl; state.pageNumber = getCurrentSearchPageNumber(); state.hasNextPage = hasNext; state.category = getCurrentCategoryFromPageOrUrl(); saveState(state); await toast(`Parsed page ${state.pageNumber}: ${queue.length} new events. Sending this page now${nextUrl ? ', then switching to the next page.' : '. No next page button found.'}`, 'success'); location.href = getNavigationUrl(queue[0]); } function findField(selectors, root = document) { for (const selector of selectors) { const el = root.querySelector(selector); if (el) return el; } return null; } function setValue(el, value) { el.focus(); const proto = el instanceof HTMLTextAreaElement ? HTMLTextAreaElement.prototype : HTMLInputElement.prototype; const setter = Object.getOwnPropertyDescriptor(proto, 'value')?.set; if (setter) setter.call(el, value); else el.value = value; el.dispatchEvent(new Event('input', { bubbles: true })); el.dispatchEvent(new Event('change', { bubbles: true })); el.blur(); } function clickElement(el) { if (!el) return; el.scrollIntoView({ block: 'center', inline: 'center' }); ['mouseover', 'pointerdown', 'mousedown', 'pointerup', 'mouseup', 'click'].forEach(type => { const Ctor = type.startsWith('pointer') && typeof PointerEvent === 'function' ? PointerEvent : MouseEvent; el.dispatchEvent(new Ctor(type, { bubbles: true, cancelable: true, view: window })); }); if (typeof el.click === 'function') { try { el.click(); } catch (_) {} } } function isVisible(el) { if (!el) return false; const style = getComputedStyle(el); const rect = el.getBoundingClientRect(); return style.display !== 'none' && style.visibility !== 'hidden' && style.opacity !== '0' && rect.width > 0 && rect.height > 0; } async function waitFor(selector, timeout = 12000, visibleOnly = false) { const end = Date.now() + timeout; while (Date.now() < end) { const el = document.querySelector(selector); if (el && (!visibleOnly || isVisible(el))) return el; await sleep(250); } return null; } async function waitForAny(selectors, timeout = 12000, visibleOnly = false) { const end = Date.now() + timeout; while (Date.now() < end) { const el = findField(selectors); if (el && (!visibleOnly || isVisible(el))) return el; await sleep(250); } return null; } function findContactButton() { const exact = document.querySelector('#contact-organizer-button'); if (exact) return exact; return [...document.querySelectorAll('button.button.large, button')] .find(btn => /contact/i.test(btn.textContent || '') || /contact.*organizer|organizer.*contact/i.test(btn.id || '')) || null; } async function waitForContactButton(timeout = 20000) { const end = Date.now() + timeout; while (Date.now() < end) { const btn = findContactButton(); if (btn) return btn; await sleep(250); } return null; } async function processParsePage(state) { await sleep(1200); state = loadState(); const base = state.queue[state.index] || { url: currentEventUrl() }; const parsed = parseEventPageMetadata(base); const parsedKey = parsed.url; if (!state.parsedQueue.some(x => x.url === parsed.url)) state.parsedQueue.push(parsed); state.parsedEvents[parsedKey] = { time: Date.now(), category: parsed.category || '', organizer: parsed.organizer || '' }; state.index += 1; saveState(state); await toast(`Parsed ${state.index}/${state.queue.length}: ${parsed.category || 'no category'}`, 'info'); if (state.index < state.queue.length && state.running && state.phase === 'parse') { location.href = getNavigationUrl(state.queue[state.index]); return; } finishParsingAndStartSending(); } function finishParsingAndStartSending() { const state = loadState(); const seenUrls = new Set(); const seenOrganizerKeys = new Set(); const sendQueue = state.parsedQueue.filter(item => { if (!item.url || seenUrls.has(item.url) || state.processedEvents[item.url]) return false; if (isOrganizerProcessed(state, item)) return false; const keys = getOrganizerKeys(item); if (keys.length && keys.some(k => seenOrganizerKeys.has(k))) return false; seenUrls.add(item.url); keys.forEach(k => seenOrganizerKeys.add(k)); return true; }); state.queue = sendQueue; state.index = 0; state.phase = sendQueue.length ? 'send' : 'idle'; state.running = !!sendQueue.length; saveState(state); if (!sendQueue.length) return stop('Parsing finished. No new unique organizers to contact.'); toast(`Parsing finished. Unique organizers to contact: ${sendQueue.length}`, 'success'); location.href = getNavigationUrl(sendQueue[0]); } async function processEventPage() { let state = loadState(); if (!state.running || !isEventLikePage()) return; if (state.phase === 'collect') { if (state.searchUrl) location.href = state.searchUrl; return; } if (state.phase === 'parse') return processParsePage(state); await sleep(1500); state = loadState(); const current = state.queue[state.index] || { url: currentEventUrl() }; if (!current) return stop('Queue finished.'); const parsed = parseEventPageMetadata(current); const item = Object.assign({}, current, parsed); if (isRequestedPageNotFound()) { return markAndNext('Peatix returned "The requested page was not found on this server"; skipped this bad listing URL.', true, item, false); } if (state.processedEvents[item.url] || isOrganizerProcessed(state, item)) { return markAndNext('Already contacted this organizer/event before; skipped duplicate.', true, item, false); } const contact = await waitForContactButton(20000); if (!contact) return markAndNext('Contact button (#contact-organizer-button) not found; skipped this event.', true, item, true); clickElement(contact); const trigger = await waitFor('#organizer-contact-form-trigger', 12000); if (trigger) clickElement(trigger); const form = await waitFor('#contact-form, form.js-contact-organizer-form, form', 12000); if (!form) return markAndNext('Organizer contact form not found after Contact click; skipped this event.', true, item, true); const subject = findField([ 'input[name="topic"]', 'input[placeholder="Subject"]', 'input[name="subject"]', '#subject', '#contact-subject', 'input[id*="subject"]', 'input[type="text"]' ], form); const message = findField([ 'textarea[name="body"]', 'textarea[placeholder="Add Message"]', 'textarea[name="message"]', '#message', '#contact-message', 'textarea[id*="message"]', 'textarea' ], form); if (!subject || !message) return markAndNext('Subject/message fields not found in contact form; skipped this event.', true, item, true); setValue(subject, state.subject); setValue(message, state.message); await sleep(500); const send = findField([ 'button.js-contact-organizer-submit[type="submit"]', 'button.js-contact-organizer-submit', '#contact-form button[type="submit"]', 'button[type="submit"].button.action.large.primary', 'button[type="submit"]' ], form) || await waitForAny(['button.js-contact-organizer-submit', 'button[type="submit"]'], 5000); if (!send) return markAndNext('Send button not found in contact form; skipped this event.', true, item, true); clickElement(send); await markAndNext('Message submitted through Contact form; moving to next unique organizer.', false, item, true); } function loadOpenTabsCommand() { try { return JSON.parse(localStorage.getItem(OPEN_TABS_COMMAND_KEY) || '{}') || {}; } catch (_) { return {}; } } function saveOpenTabsCommand(command) { localStorage.setItem(OPEN_TABS_COMMAND_KEY, JSON.stringify(command)); } function isFreshOpenTabsCommand(command) { return !!(command && command.action === 'process-open-tabs' && command.running && Date.now() - Number(command.createdAt || 0) < 60 * 60 * 1000); } function commandAllowsCurrentEvent(command, url = currentEventUrl()) { const urls = Array.isArray(command.urls) ? command.urls.map(normalizeEventUrl) : []; return !urls.length || urls.includes(normalizeEventUrl(url)); } function claimOpenTabForCommand(commandId, url) { const command = loadOpenTabsCommand(); if (!isFreshOpenTabsCommand(command) || String(command.id) !== String(commandId)) return false; url = normalizeEventUrl(url); if (!commandAllowsCurrentEvent(command, url)) return false; command.claimedEvents = command.claimedEvents || {}; command.completedEvents = command.completedEvents || {}; const maxTabs = Math.max(1, Math.min(20, Number(command.maxTabs) || 20)); if (command.completedEvents[url]) return false; if (command.claimedEvents[url]) return true; if (Object.keys(command.claimedEvents).length >= maxTabs) return false; command.claimedEvents[url] = { time: Date.now(), title: document.title }; saveOpenTabsCommand(command); return true; } function completeOpenTabCommand(commandId, url, result) { const command = loadOpenTabsCommand(); if (!command || String(command.id) !== String(commandId)) return; url = normalizeEventUrl(url); command.completedEvents = command.completedEvents || {}; command.completedEvents[url] = Object.assign({ time: Date.now() }, result || {}); const maxTabs = Math.max(1, Math.min(20, Number(command.maxTabs) || 20)); const targetTotal = Array.isArray(command.urls) && command.urls.length ? Math.min(maxTabs, command.urls.length) : maxTabs; if (Object.keys(command.completedEvents).length >= targetTotal) command.running = false; saveOpenTabsCommand(command); } async function processOpenTabsCommand(command, source = 'boot') { if (!isFreshOpenTabsCommand(command) || !isEventLikePage() || !commandAllowsCurrentEvent(command)) return; const runKey = `twps-open-tabs-run-${command.id}`; if (sessionStorage.getItem(runKey) === 'done' || sessionStorage.getItem(runKey) === 'running') return; await sleep(250 + Math.floor(Math.random() * 1750)); const eventUrl = currentEventUrl(); if (!claimOpenTabForCommand(command.id, eventUrl)) return; sessionStorage.setItem(runKey, 'running'); let state = loadState(); const subjectText = String(command.subject || state.subject || '').trim(); const messageText = String(command.message || state.message || '').trim(); if (!subjectText || !messageText) { completeOpenTabCommand(command.id, eventUrl, { skipped: true, note: 'Missing subject/message' }); sessionStorage.setItem(runKey, 'done'); await toast('Open-tabs mode skipped this tab: enter subject and message first.', 'warning'); return; } await toast(`Open-tabs mode: processing this tab (${source}).`, 'info'); await sleep(1000); state = loadState(); const item = parseEventPageMetadata({ url: eventUrl }); if (isRequestedPageNotFound()) { state.processedEvents[item.url] = { time: Date.now(), skipped: true, reason: 'Peatix Not Found page', category: item.category || '', organizer: item.organizer || '' }; saveState(state); completeOpenTabCommand(command.id, eventUrl, { skipped: true, note: 'Peatix Not Found page', organizer: item.organizer || '' }); sessionStorage.setItem(runKey, 'done'); await toast('Open-tabs mode: Peatix returned "The requested page was not found on this server"; this tab was skipped.', 'warning'); return; } if (state.processedEvents[item.url] || isOrganizerProcessed(state, item)) { state.processedEvents[item.url] = { time: Date.now(), skipped: true, category: item.category || '', organizer: item.organizer || '' }; saveState(state); completeOpenTabCommand(command.id, eventUrl, { skipped: true, note: 'Duplicate organizer/event', organizer: item.organizer || '' }); sessionStorage.setItem(runKey, 'done'); await toast('Open-tabs mode: duplicate organizer/event skipped.', 'warning'); return; } const contact = await waitForContactButton(20000); if (!contact) { state.processedEvents[item.url] = { time: Date.now(), skipped: true, reason: 'No contact button', category: item.category || '', organizer: item.organizer || '' }; saveState(state); completeOpenTabCommand(command.id, eventUrl, { skipped: true, note: 'Contact button not found', organizer: item.organizer || '' }); sessionStorage.setItem(runKey, 'done'); await toast('Open-tabs mode: Contact button was not found on this tab.', 'warning'); return; } try { window.focus(); } catch (_) {} clickElement(contact); const trigger = await waitFor('#organizer-contact-form-trigger', 12000); if (trigger) clickElement(trigger); const form = await waitFor('#contact-form, form.js-contact-organizer-form, form', 12000); if (!form) { state.processedEvents[item.url] = { time: Date.now(), skipped: true, reason: 'No contact form', category: item.category || '', organizer: item.organizer || '' }; saveState(state); completeOpenTabCommand(command.id, eventUrl, { skipped: true, note: 'Contact form not found', organizer: item.organizer || '' }); sessionStorage.setItem(runKey, 'done'); await toast('Open-tabs mode: contact form was not found.', 'warning'); return; } const subject = findField([ 'input[name="topic"]', 'input[placeholder="Subject"]', 'input[name="subject"]', '#subject', '#contact-subject', 'input[id*="subject"]', 'input[type="text"]' ], form); const message = findField([ 'textarea[name="body"]', 'textarea[placeholder="Add Message"]', 'textarea[name="message"]', '#message', '#contact-message', 'textarea[id*="message"]', 'textarea' ], form); if (!subject || !message) { state.processedEvents[item.url] = { time: Date.now(), skipped: true, reason: 'No fields', category: item.category || '', organizer: item.organizer || '' }; saveState(state); completeOpenTabCommand(command.id, eventUrl, { skipped: true, note: 'Subject/message fields not found', organizer: item.organizer || '' }); sessionStorage.setItem(runKey, 'done'); await toast('Open-tabs mode: subject/message fields were not found.', 'warning'); return; } setValue(subject, subjectText); setValue(message, messageText); await sleep(500); const send = findField([ 'button.js-contact-organizer-submit[type="submit"]', 'button.js-contact-organizer-submit', '#contact-form button[type="submit"]', 'button[type="submit"].button.action.large.primary', 'button[type="submit"]' ], form) || await waitForAny(['button.js-contact-organizer-submit', 'button[type="submit"]'], 5000); if (!send) { state.processedEvents[item.url] = { time: Date.now(), skipped: true, reason: 'No send button', category: item.category || '', organizer: item.organizer || '' }; saveState(state); completeOpenTabCommand(command.id, eventUrl, { skipped: true, note: 'Send button not found', organizer: item.organizer || '' }); sessionStorage.setItem(runKey, 'done'); await toast('Open-tabs mode: Send button was not found.', 'warning'); return; } clickElement(send); await sleep(1200); state = loadState(); state.processedEvents[item.url] = { time: Date.now(), skipped: false, category: item.category || '', organizer: item.organizer || '' }; if (item.organizer || item.organizerUrl) markOrganizerProcessed(state, item); saveState(state); completeOpenTabCommand(command.id, eventUrl, { success: true, organizer: item.organizer || '' }); sessionStorage.setItem(runKey, 'done'); await toast('Open-tabs mode: message submitted in this tab.', 'success'); } async function startOpenTabsBroadcast() { const state = loadState(); if (!state.subject.trim() || !state.message.trim()) { showSettings(true); await toast('Enter subject and message before processing open tabs.', 'warning'); return; } const maxTabs = Math.max(1, Math.min(20, Number(state.openTabsMax) || 20)); const command = { id: String(Date.now()), action: 'process-open-tabs', running: true, createdAt: Date.now(), maxTabs, subject: state.subject, message: state.message, urls: [], claimedEvents: {}, completedEvents: {} }; saveOpenTabsCommand(command); await toast(`Command sent: up to ${maxTabs} already-open Peatix event tabs will process themselves.`, 'success'); processOpenTabsCommand(command, 'current tab'); } async function openAndProcessTwentyTabsFromSearch() { const state = loadState(); if (!state.subject.trim() || !state.message.trim()) { showSettings(true); await toast('Enter subject and message before opening 20 tabs.', 'warning'); return; } if (!isSearchLikePage()) { await toast('Open a Peatix search/category page first, then run "Open/process 20 tabs".', 'warning'); return; } const queue = (await collectQueueFromSearchWithWait(15000)).slice(0, Math.max(1, Math.min(20, Number(state.openTabsMax) || 20))); if (!queue.length) { await toast('No new unique events found on this page to open in tabs.', 'warning'); return; } const command = { id: String(Date.now()), action: 'process-open-tabs', running: true, createdAt: Date.now(), maxTabs: queue.length, subject: state.subject, message: state.message, urls: queue.map(item => normalizeEventUrl(item.url)), claimedEvents: {}, completedEvents: {} }; saveOpenTabsCommand(command); await toast(`Opening ${queue.length} event tabs. Each opened tab will submit once and skip duplicates.`, 'success'); queue.forEach((item, i) => { const navUrl = getNavigationUrl(item); try { if (typeof GM_openInTab === 'function') GM_openInTab(navUrl, { active: i === 0, insert: true, setParent: true }); else window.open(navUrl, '_blank', 'noopener'); } catch (_) { window.open(navUrl, '_blank', 'noopener'); } }); } function isEventLikePage() { if (location.pathname.startsWith('/search')) return false; if (/^\/event\/\d+/.test(location.pathname)) return true; return !!document.querySelector('#contact-organizer-button, #organizer-contact-form-trigger, form.js-contact-organizer-form, meta[property="og:type"][content*="event"]'); } async function markAndNext(note, skipped, itemOverride, markOrganizer) { const state = loadState(); const item = itemOverride || state.queue[state.index]; if (item) { state.processedEvents[item.url] = { time: Date.now(), skipped: !!skipped, category: item.category || '', organizer: item.organizer || '' }; if (markOrganizer !== false && (item.organizer || item.organizerUrl)) markOrganizerProcessed(state, item); if (!skipped) state.sentSinceFollowup = Math.max(0, Number(state.sentSinceFollowup) || 0) + 1; } state.index += 1; const shouldStartFollowup = !skipped && state.sentSinceFollowup >= Math.max(1, Math.min(50, Number(state.followupLimit) || 10)); saveState(state); await toast(note, skipped ? 'warning' : 'success'); if (shouldStartFollowup && startFollowupBatchFromCurrentState(loadState(), `Reached ${state.sentSinceFollowup} first messages. Opening Sent to send second messages.`)) return; if (!state.running) return stop('Stopped.'); if (state.index >= state.queue.length) { if (state.sendOnlyParsed !== false) return stop('Sender finished parsed queue. No search-page switching will be done.'); return goToNextResultsPage(state); } const delay = randomDelayMs(state); await toast(`Waiting ${Math.round(delay / 1000)} seconds before next event on this page.`, 'info'); setTimeout(() => { const s = loadState(); if (s.running && s.phase === 'send' && s.queue[s.index]) location.href = getNavigationUrl(s.queue[s.index]); }, delay); } async function recoverFromNotFoundRedirect() { const state = loadState(); if (!state.running || state.phase !== 'send') return; const item = state.queue[state.index]; if (item) { state.processedEvents[item.url] = { time: Date.now(), skipped: true, reason: 'Peatix Not Found redirect', category: item.category || '', organizer: item.organizer || '' }; state.index += 1; } else { state.index = Math.max(0, Number(state.index || 0)); } saveState(state); await toast('Peatix showed "The requested page was not found on this server". Bad URL removed/skipped.', 'warning'); if (state.index >= state.queue.length) { return stop('Sender finished after removing bad Not Found URLs.'); } setTimeout(() => { const s = loadState(); if (s.running && s.phase === 'send' && s.queue[s.index]) location.href = getNavigationUrl(s.queue[s.index]); }, 1200); } async function resumeSendPhaseFromNonEventPage(reason = 'Continuing first-message queue') { await sleep(700); const state = loadState(); if (!state.running || state.phase !== 'send') return; if (isEventLikePage()) return processEventPage(); const total = Array.isArray(state.queue) ? state.queue.length : 0; if (state.index >= total) { if (state.sendOnlyParsed !== false) return stop('Sender finished parsed queue. No search-page switching will be done.'); return goToNextResultsPage(state); } const item = state.queue[state.index]; const navUrl = getNavigationUrl(item); if (!navUrl) { state.index += 1; saveState(state); await toast('Current queue item has no URL; skipped and continuing.', 'warning'); setTimeout(() => resumeSendPhaseFromNonEventPage(reason), 600); return; } await toast(`${reason}: opening event ${state.index + 1}/${total}.`, 'info'); location.href = navUrl; } async function goToNextResultsPage(state) { const currentSearchUrl = state.searchUrl || ''; if (state.hasNextPage === false && !state.nextSearchUrl) return stop('Finished this results page. Peatix does not show a Next page button.'); const nextUrl = state.nextSearchUrl || buildNextSearchPageUrlByParam(currentSearchUrl) || ''; if (!currentSearchUrl && !nextUrl) return stop('Finished this results page. Next page URL was not found.'); state.phase = 'advance'; state.queue = []; state.parsedQueue = []; state.index = 0; state.searchUrl = currentSearchUrl || nextUrl; state.nextSearchUrl = nextUrl; state.running = true; saveState(state); await toast(`Finished sending this page. Opening next results page by URL: p=${getPageNumberFromUrl(nextUrl || currentSearchUrl)}`, 'success'); const delay = randomDelayMs(state); setTimeout(() => { const s = loadState(); if (!s.running || s.phase !== 'advance') return; if (s.nextSearchUrl && normalizeUrlNoHash(location.href) !== normalizeUrlNoHash(s.nextSearchUrl)) location.href = s.nextSearchUrl; else advanceToNextResultsPage(); }, delay); } async function advanceToNextResultsPage() { await sleep(1000); const state = loadState(); if (!state.running || state.phase !== 'advance') return; const currentSearch = isSearchLikePage() ? location.href : (state.searchUrl || ''); const nextUrl = state.nextSearchUrl || buildNextSearchPageUrlByParam(currentSearch) || inferNextSearchPageUrl(currentSearch); if (nextUrl) { state.phase = 'collect'; state.searchUrl = nextUrl; state.nextSearchUrl = ''; state.pageNumber = getPageNumberFromUrl(nextUrl); state.running = true; saveState(state); await toast(`Opening next search page by replacing the URL page number: p=${state.pageNumber}`, 'info'); if (normalizeUrlNoHash(location.href) === normalizeUrlNoHash(nextUrl)) { await startCurrentResultsPage(false); } else { location.href = nextUrl; } return; } // Last fallback for unusual Peatix pages without a p= URL. if (isSearchLikePage()) { const nextButton = await waitForNextPaginationControl(5000); if (nextButton) { state.phase = 'collect'; saveState(state); await toast('No p= URL was available; using Peatix Next arrow fallback.', 'warning'); clickElement(nextButton); setTimeout(() => startCurrentResultsPage(false), 3000); return; } } stop('All done: next p= page URL was not found.'); } function getMessageBasePath() { const m = location.pathname.match(/^\/user\/(\d+)\/message(?:\/|$)/); return m ? `/user/${m[1]}/message` : ''; } function getSentMessagesUrl() { const base = getMessageBasePath(); if (base) return `${location.origin}${base}/sent`; const headerLink = document.querySelector('a[href*="/user/"][href*="/message/inbox"], a[href*="/user/"][href*="/message/sent"], #num-unread-link'); const href = headerLink?.href || ''; const m = href.match(/\/user\/(\d+)\/message\//); return m ? `${location.origin}/user/${m[1]}/message/sent` : `${location.origin}/user/message/sent`; } function isSentMessagesListPage() { return /^\/user\/\d+\/message\/sent\/?$/.test(location.pathname) && !!document.querySelector('ul.messages'); } function isMessageThreadPage() { return /^\/user\/\d+\/message\/\d+\/?$/.test(location.pathname); } function getThreadIdFromUrl(url) { const m = String(url || '').match(/\/message\/(\d+)/); return m ? m[1] : normalizeUrlNoHash(url || location.href); } function collectSentThreadsForFollowup(state) { const limit = Math.max(1, Math.min(50, Number(state.followupLimit) || 10)); const seen = new Set(); const links = [...document.querySelectorAll('ul.messages li.message > a[href*="/message/"], ul.messages li.message a[href*="/message/"]')]; const threads = []; links.forEach(link => { const href = normalizeUrlNoHash(link.href || ''); const id = getThreadIdFromUrl(href); if (!id || seen.has(id) || state.sentFollowups?.[id]) return; if (!/\/user\/\d+\/message\/\d+\/?$/i.test(new URL(href, location.href).pathname)) return; const row = link.closest('li.message'); seen.add(id); threads.push({ id, url: href, title: text(row?.querySelector('.object')) || text(row?.querySelector('.context')) || document.title, snippet: text(row?.querySelector('.body')), sent: text(row?.querySelector('.sent')) }); }); return threads.slice(0, limit); } function startFollowupBatchFromCurrentState(state, reason) { if (!getConfiguredSecondMessages(state).length) { state.sentSinceFollowup = 0; saveState(state); toast('10 first messages were sent, but no second-message text is configured. Follow-up batch skipped.', 'warning'); return false; } state.followupReturn = { queue: state.queue, index: state.index, searchUrl: state.searchUrl, nextSearchUrl: state.nextSearchUrl, hasNextPage: state.hasNextPage, sendOnlyParsed: state.sendOnlyParsed, pageNumber: state.pageNumber }; state.phase = 'followup-list'; state.running = true; state.followupQueue = []; state.followupIndex = 0; saveState(state); toast(reason || `Reached ${state.followupLimit} first messages. Opening Sent to send second messages.`, 'success'); location.href = getSentMessagesUrl(); return true; } async function startSecondMessagesFromSent() { const state = loadState(); if (!getConfiguredSecondMessages(state).length) { showSettings(true); await toast('Enter at least one second message before starting Sent follow-ups.', 'warning'); return; } state.phase = 'followup-list'; state.running = true; state.followupQueue = []; state.followupIndex = 0; state.followupReturn = null; saveState(state); if (!isSentMessagesListPage()) location.href = getSentMessagesUrl(); else processFollowupSentList(); } async function processFollowupSentList() { await sleep(900); const state = loadState(); if (!state.running || state.phase !== 'followup-list') return; if (!isSentMessagesListPage()) { location.href = getSentMessagesUrl(); return; } const threads = collectSentThreadsForFollowup(state); if (!threads.length) { return finishFollowupBatch('No Sent threads need a second message on this page.', 'warning'); } state.followupQueue = threads; state.followupIndex = 0; state.phase = 'followup-thread'; saveState(state); await toast(`Prepared ${threads.length} Sent threads for second messages.`, 'success'); location.href = threads[0].url; } function findReplyTextarea() { return findField([ 'textarea.reply-box', 'textarea[name="body"]', 'textarea[name="message"]', '#message_body', '#message', 'form textarea', 'textarea' ]); } function findReplySubmit(root) { return findField([ 'input[type="submit"].button.action.primary', 'button[type="submit"].button.action.primary', 'input[type="submit"]', 'button[type="submit"]', '.button.action.primary' ], root || document); } async function processFollowupThread() { await sleep(900); let state = loadState(); if (!state.running || state.phase !== 'followup-thread') return; const thread = state.followupQueue[state.followupIndex]; if (!thread) return finishFollowupBatch('Second-message queue finished.', 'success'); if (!isMessageThreadPage() || getThreadIdFromUrl(location.href) !== String(thread.id)) { location.href = thread.url; return; } const body = getSecondMessageForIndex(state, state.followupIndex); if (!body) return finishFollowupBatch('No second-message text is configured.', 'warning'); const textarea = await waitFor('textarea.reply-box, textarea[name="body"], textarea[name="message"], form textarea, textarea', 12000, true) || findReplyTextarea(); if (!textarea) return markFollowupAndNext('Reply textarea was not found; skipped this Sent thread.', true); const form = textarea.closest('form') || document; setValue(textarea, body); await sleep(400); const send = findReplySubmit(form) || findReplySubmit(document); if (!send) return markFollowupAndNext('Reply submit button was not found; skipped this Sent thread.', true); clickElement(send); await sleep(1400); await markFollowupAndNext('Second message submitted from Sent thread.', false); } async function markFollowupAndNext(note, skipped) { const state = loadState(); const thread = state.followupQueue[state.followupIndex]; if (thread) { state.sentFollowups[thread.id] = { time: Date.now(), skipped: !!skipped, url: thread.url, title: thread.title || '' }; } state.followupIndex += 1; saveState(state); await toast(note, skipped ? 'warning' : 'success'); if (!state.running || state.phase !== 'followup-thread') return; if (state.followupIndex >= state.followupQueue.length) return finishFollowupBatch('Second-message batch finished.', 'success'); const delay = randomDelayMs(state); setTimeout(() => { const s = loadState(); const next = s.followupQueue?.[s.followupIndex]; if (s.running && s.phase === 'followup-thread' && next) location.href = next.url; }, delay); } async function finishFollowupBatch(note, type = 'success') { const state = loadState(); state.sentSinceFollowup = 0; state.followupQueue = []; state.followupIndex = 0; const ret = state.followupReturn; state.followupReturn = null; if (ret && Array.isArray(ret.queue)) { state.queue = ret.queue; state.index = Math.max(0, Number(ret.index) || 0); state.searchUrl = ret.searchUrl || state.searchUrl; state.nextSearchUrl = ret.nextSearchUrl || state.nextSearchUrl; state.hasNextPage = ret.hasNextPage; state.sendOnlyParsed = ret.sendOnlyParsed; state.pageNumber = ret.pageNumber || state.pageNumber; state.phase = 'send'; state.running = true; saveState(state); const nextUrl = state.index < state.queue.length ? getNavigationUrl(state.queue[state.index]) : ''; toast(`${note} Returning to first-message queue.`, type); if (nextUrl) { location.href = nextUrl; setTimeout(() => { const s = loadState(); if (s.running && s.phase === 'send' && !isEventLikePage() && s.queue?.[s.index]) location.href = getNavigationUrl(s.queue[s.index]); }, 2500); } else if (state.sendOnlyParsed !== false) { stop('First-message queue finished after second-message batch.'); } else { goToNextResultsPage(state); } return; } state.phase = 'idle'; state.running = false; saveState(state); await toast(note, type); } function showSettings(openStartAfterSave = false) { injectStyle(); const old = document.getElementById('tw-peatix-sender-modal'); if (old) old.remove(); const state = loadState(); const wrap = document.createElement('div'); wrap.id = 'tw-peatix-sender-modal'; wrap.innerHTML = `

`; (document.body || document.documentElement).appendChild(wrap); document.getElementById('twps-subject').value = state.subject; document.getElementById('twps-message').value = state.message; const secondMessages = normalizeSecondMessages(state.secondMessages, state.secondMessage); secondMessages.forEach((value, i) => { const el = document.getElementById(`twps-second-${i}`); if (el) el.value = value; }); document.getElementById('twps-min').value = state.minDelay; document.getElementById('twps-max').value = state.maxDelay; document.getElementById('twps-followup-limit').value = state.followupLimit || 10; document.getElementById('twps-open-tabs-max').value = state.openTabsMax || 20; const close = () => wrap.remove(); const save = () => { const s = loadState(); s.subject = document.getElementById('twps-subject').value; s.message = document.getElementById('twps-message').value; s.secondMessages = [0, 1, 2, 3, 4].map(i => document.getElementById(`twps-second-${i}`)?.value || ''); s.followupLimit = Math.max(1, Math.min(50, Number(document.getElementById('twps-followup-limit').value) || 10)); s.minDelay = Math.max(10, Math.min(120, Number(document.getElementById('twps-min').value) || 10)); s.maxDelay = Math.max(s.minDelay, Math.min(120, Number(document.getElementById('twps-max').value) || s.minDelay)); s.openTabsMax = Math.max(1, Math.min(20, Number(document.getElementById('twps-open-tabs-max').value) || 20)); saveState(s); toast('Settings saved.', 'success'); return s; }; document.getElementById('twps-save').onclick = save; document.getElementById('twps-parse-category').onclick = () => { save(); close(); startFullCategoryParser(true); }; document.getElementById('twps-start').onclick = () => { save(); close(); startSenderFromParsed(); }; document.getElementById('twps-second-from-sent').onclick = () => { save(); close(); startSecondMessagesFromSent(); }; document.getElementById('twps-open-tabs').onclick = () => { save(); close(); startOpenTabsBroadcast(); }; document.getElementById('twps-open-20').onclick = () => { save(); close(); openAndProcessTwentyTabsFromSearch(); }; document.getElementById('twps-stop').onclick = () => { stop('Stopped by user.'); close(); }; document.getElementById('twps-close').onclick = close; document.querySelector('.twps-backdrop').onclick = close; if (openStartAfterSave) document.getElementById('twps-start').focus(); } function injectStyle() { if (document.getElementById('twps-style')) return; const style = document.createElement('style'); style.id = 'twps-style'; style.textContent = `#tw-peatix-sender-modal{position:fixed!important;inset:0!important;z-index:2147481990!important;display:block!important;visibility:visible!important;opacity:1!important;pointer-events:auto!important}#tw-peatix-sender-modal .twps-backdrop{position:fixed!important;inset:0!important;background:rgba(0,0,0,.35)!important;z-index:2147481990!important}#tw-peatix-sender-modal .twps-box{position:fixed!important;top:8vh!important;left:50%!important;transform:translateX(-50%)!important;width:min(560px,92vw)!important;max-height:86vh!important;overflow:auto!important;background:#fff!important;color:#222!important;border-radius:10px!important;padding:18px!important;box-shadow:0 10px 40px rgba(0,0,0,.3)!important;z-index:2147481991!important;font:14px Arial,sans-serif!important}#tw-peatix-sender-modal h2{margin:0 0 12px!important;font-size:20px!important;color:#222!important}#tw-peatix-sender-modal label{display:block!important;margin:10px 0!important;font-weight:600!important;color:#222!important}#tw-peatix-sender-modal input,#tw-peatix-sender-modal textarea{box-sizing:border-box!important;width:100%!important;margin-top:4px!important;padding:8px!important;border:1px solid #bbb!important;border-radius:6px!important;background:#fff!important;color:#222!important;font:14px Arial,sans-serif!important}#tw-peatix-sender-modal .twps-row{display:grid!important;grid-template-columns:1fr 1fr!important;gap:12px!important}#tw-peatix-sender-modal .twps-note{font-size:12px!important;color:#555!important}#tw-peatix-sender-modal .twps-actions{display:flex!important;gap:8px!important;justify-content:flex-end!important;flex-wrap:wrap!important}#tw-peatix-sender-modal button{padding:8px 12px!important;border:1px solid #999!important;border-radius:6px!important;background:#f5f5f5!important;color:#222!important;cursor:pointer!important;font:14px Arial,sans-serif!important}#twps-parse-category,#twps-start,#twps-second-from-sent,#twps-save{background:#39b54a!important;color:#fff!important;border-color:#39b54a!important}#twps-stop{background:#c33!important;color:#fff!important;border-color:#c33!important}`; (document.head || document.documentElement).appendChild(style); } function ensureFloatingMenu() { if (floatingHost && document.documentElement.contains(floatingHost)) { updateFloatingMenu(); return; } floatingHost = document.createElement('div'); floatingHost.id = 'tw-peatix-sender-float-host'; floatingHost.style.cssText = 'all:initial!important;position:fixed!important;right:16px!important;bottom:16px!important;z-index:2147482000!important;display:block!important;visibility:visible!important;opacity:1!important;pointer-events:auto!important;'; floatingRoot = floatingHost.attachShadow ? floatingHost.attachShadow({ mode: 'open' }) : floatingHost; floatingRoot.innerHTML = `

Peatix Sender

`; (document.body || document.documentElement).appendChild(floatingHost); const byId = (id) => floatingRoot.getElementById(id); byId('float-toggle').addEventListener('click', () => byId('float-wrap').classList.toggle('open')); byId('float-settings').addEventListener('click', () => showSettings(false)); byId('float-parse-category').addEventListener('click', () => startFullCategoryParser(true)); byId('float-start').addEventListener('click', startSenderFromParsed); byId('float-second-from-sent').addEventListener('click', startSecondMessagesFromSent); byId('float-open-tabs').addEventListener('click', startOpenTabsBroadcast); byId('float-open-20').addEventListener('click', openAndProcessTwentyTabsFromSearch); byId('float-stop').addEventListener('click', () => stop('Stopped by user.')); updateFloatingMenu(); } function updateFloatingMenu() { if (!floatingRoot) return; const status = floatingRoot.getElementById('float-status'); if (!status) return; const s = loadState(); const tabCommand = loadOpenTabsCommand(); const total = Array.isArray(s.queue) ? s.queue.length : 0; const current = total ? Math.min(total, Number(s.index || 0) + 1) : 0; const parsed = Array.isArray(s.parsedQueue) ? s.parsedQueue.length : 0; const mode = s.phase === 'category-collect' ? 'Parsing full category' : (s.phase === 'advance' ? 'Switching to next results page' : (s.phase === 'collect' ? 'Parsing one results page' : (s.phase === 'parse' ? 'Parsing event data' : (s.phase === 'followup-list' ? 'Opening Sent for second messages' : (s.phase === 'followup-thread' ? 'Sending second messages from Sent' : 'Sending parsed queue'))))); if (isFreshOpenTabsCommand(tabCommand)) { const done = Object.keys(tabCommand.completedEvents || {}).length; const claimed = Object.keys(tabCommand.claimedEvents || {}).length; const target = Array.isArray(tabCommand.urls) && tabCommand.urls.length ? Math.min(Number(tabCommand.maxTabs) || 20, tabCommand.urls.length) : (Number(tabCommand.maxTabs) || 20); status.textContent = `Open-tabs mode: completed ${done}/${target}, claimed ${claimed}.`; } else { status.textContent = s.running ? `${mode}: ${current}/${total}. Parsed on page: ${parsed}` : `Stopped. Queue: ${total}. Parsed on page: ${parsed}`; } } function rebuildMenu() { if (typeof GM_unregisterMenuCommand === 'function') menuIds.forEach(id => { try { GM_unregisterMenuCommand(id); } catch (_) {} }); menuIds = []; if (typeof GM_registerMenuCommand !== 'function') return; const s = loadState(); menuIds.push(GM_registerMenuCommand(`Settings (${s.running ? s.phase : 'stopped'})`, () => showSettings(false))); menuIds.push(GM_registerMenuCommand('Parse full category into saved queue', () => startFullCategoryParser(true))); menuIds.push(GM_registerMenuCommand('Start sender from parsed queue (no search-page switching)', startSenderFromParsed)); menuIds.push(GM_registerMenuCommand('Start second messages from Sent (limit-controlled)', startSecondMessagesFromSent)); menuIds.push(GM_registerMenuCommand('Process up to 20 already-open event tabs', startOpenTabsBroadcast)); menuIds.push(GM_registerMenuCommand('Open/process up to 20 tabs from this search page', openAndProcessTwentyTabsFromSearch)); menuIds.push(GM_registerMenuCommand('Stop', () => stop('Stopped by user.'))); } injectStyle(); ensureFloatingMenu(); rebuildMenu(); window.addEventListener('storage', (event) => { if (event.key !== OPEN_TABS_COMMAND_KEY || !event.newValue) return; let command = null; try { command = JSON.parse(event.newValue); } catch (_) { command = null; } processOpenTabsCommand(command, 'storage event'); updateFloatingMenu(); }); const latestOpenTabsCommand = loadOpenTabsCommand(); if (isFreshOpenTabsCommand(latestOpenTabsCommand)) processOpenTabsCommand(latestOpenTabsCommand, 'page load'); const bootState = loadState(); if (bootState.running && bootState.phase === 'category-collect' && isSearchLikePage()) collectFullCategoryPage(); else if (bootState.running && bootState.phase === 'advance') advanceToNextResultsPage(); else if (bootState.running && bootState.phase === 'collect' && isSearchLikePage()) startCurrentResultsPage(false); else if (bootState.running && bootState.phase === 'send' && isRequestedPageNotFound()) recoverFromNotFoundRedirect(); else if (bootState.running && bootState.phase === 'send' && !isEventLikePage()) resumeSendPhaseFromNonEventPage('Continuing after second-message batch'); else if (bootState.running && bootState.phase === 'followup-list') processFollowupSentList(); else if (bootState.running && bootState.phase === 'followup-thread') processFollowupThread(); else if (isEventLikePage()) processEventPage(); })();