// ==UserScript== // @name Peatix Contact Sender with 20-Tab Mode // @namespace tweeks.io // @author Tweeks // @version 1.7.0 // @description Parses Peatix search results, contacts unique organizers page-by-page, and can process up to 20 already-open or newly-opened event tabs. // @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 DEFAULT_STATE = { running: false, phase: 'idle', queue: [], parsedQueue: [], index: 0, subject: '', message: '', minDelay: 10, maxDelay: 120, processedOrganizers: {}, processedOrganizerKeys: {}, processedEvents: {}, parsedEvents: {}, searchUrl: '', nextSearchUrl: '', pageNumber: 0, emptyPageStreak: 0, maxEmptyPages: 2, category: '', openTabsMax: 20 }; 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 loadState() { try { const saved = JSON.parse(localStorage.getItem(KEY) || '{}'); const state = Object.assign({}, DEFAULT_STATE, saved); state.queue = Array.isArray(state.queue) ? state.queue : []; state.parsedQueue = Array.isArray(state.parsedQueue) ? state.parsedQueue : []; state.processedOrganizers = state.processedOrganizers || {}; state.processedOrganizerKeys = state.processedOrganizerKeys || {}; state.processedEvents = state.processedEvents || {}; state.parsedEvents = state.parsedEvents || {}; 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) { const min = Math.max(10, Math.min(120, Number(state.minDelay) || 10)); const max = Math.max(min, Math.min(120, Number(state.maxDelay) || min)); return Math.floor((min + Math.random() * (max - min)) * 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 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 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 = normalizeOrganizerUrl(item?.organizerUrl || ''); 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 getCurrentCategoryFromPageOrUrl() { const params = new URLSearchParams(location.search); const direct = params.get('category') || params.get('cat') || params.get('tag') || params.get('tags') || params.get('q') || ''; const metaKeywords = document.querySelector('meta[name="keywords"]')?.getAttribute('content') || ''; const candidates = metaKeywords.split(',').map(s => s.trim()).filter(Boolean); return direct || 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 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: normalizeOrganizerUrl(organizerUrl), 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 links = [...document.querySelectorAll('a.event-card[href], a.event-name[href], .event-card a[href], a[href*="/event/"][href], a[href*="utm_content="][href]')]; return links.map(link => { const rawUrl = link.href; if (/\/event\/\d+\/(attendees|tickets|orders|participants)/i.test(rawUrl) || /\/event\/create/i.test(rawUrl)) return null; const url = normalizeEventUrl(rawUrl); if (!/\/event\/\d+/.test(url)) return null; const card = link.closest('.event-card, li, article, [data-testid*="event"], div') || link; const organizerLink = card.querySelector('a[href*="peatix.com"]:not(.event-name)'); return { url, rawUrl, organizer: getCardOrganizer(card), organizerUrl: normalizeOrganizerUrl(organizerLink?.href || ''), 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 walk = (value) => { if (!value) return; if (Array.isArray(value)) return value.forEach(walk); if (typeof value === 'object') { const possibleId = value.id || value.event_id || value.eventId || value.content_id; const possibleUrl = value.url || value.event_url || value.eventUrl || value.href || (possibleId ? `https://peatix.com/event/${possibleId}` : ''); const url = normalizeEventUrl(possibleUrl); if (/\/event\/\d+/.test(url)) { const organizerObj = value.organizer || value.owner || value.group || {}; out.push({ url, rawUrl: possibleUrl, title: value.title || value.name || value.event_name || '', organizer: normalizeOrganizer(value.organizer_name || value.group_name || organizerObj.name || organizerObj.display_name || ''), organizerUrl: normalizeOrganizerUrl(value.organizer_url || value.group_url || organizerObj.url || ''), category: value.category || value.tag || value.tags?.join?.(', ') || getCurrentCategoryFromPageOrUrl() }); } Object.values(value).forEach(v => { if (typeof v === 'object') walk(v); }); } }; walk(data); } 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 (!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; } 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 nextUrl = 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 = getPageNumberFromUrl(location.href); saveState(state); await toast(`No new unique events on page ${getPageNumberFromUrl(location.href)}. Opening p=${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 = getPageNumberFromUrl(location.href); state.category = getCurrentCategoryFromPageOrUrl(); saveState(state); await toast(`Parsed this page only: ${queue.length} new events. Sending now, then next page.`, 'success'); location.href = queue[0].url; } 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 = state.queue[state.index].url; 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 = sendQueue[0].url; } 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 (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 (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) => { try { if (typeof GM_openInTab === 'function') GM_openInTab(item.url, { active: i === 0, insert: true, setParent: true }); else window.open(item.url, '_blank', 'noopener'); } catch (_) { window.open(item.url, '_blank', 'noopener'); } }); } function isEventLikePage() { return location.pathname.startsWith('/event/') || !!document.querySelector('#contact-organizer-button, .event-organizer, 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); } state.index += 1; saveState(state); await toast(note, skipped ? 'warning' : 'success'); if (!state.running) return stop('Stopped.'); if (state.index >= state.queue.length) 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 = s.queue[s.index].url; }, delay); } async function goToNextResultsPage(state) { const currentSearchUrl = state.searchUrl || ''; 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 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; document.getElementById('twps-min').value = state.minDelay; document.getElementById('twps-max').value = state.maxDelay; 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.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-start').onclick = () => { save(); close(); startFromSearch(); }; 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-start,#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-start').addEventListener('click', startFromSearch); 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 === 'advance' ? 'Opening next p= page URL' : (s.phase === 'collect' ? 'Opening/parsing next page' : (s.phase === 'parse' ? 'Parsing event data' : 'Sending current page')); 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 current page, send, then next', startFromSearch)); 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 === 'advance') advanceToNextResultsPage(); else if (bootState.running && bootState.phase === 'collect' && isSearchLikePage()) startCurrentResultsPage(false); else if (isEventLikePage()) processEventPage(); })();