index.js

(async () => {
    // Check for correct page
    if (!window.location.href.startsWith('https://www.reddit.com/r/place/') && !window.location.href.startsWith('https://new.reddit.com/r/place/')) {
        return;
    }

    // Check for marker; only load the script once!
    if (document.head.querySelector('meta[name="zinnsoldat"]')) {
        console.warn('Script already loaded!');
        return;
    }
    const marker = document.createElement('meta');
    marker.setAttribute('name', 'zinnsoldat');
    document.head.appendChild(marker);

    const zs_style = document.createElement('style');
    zs_style.innerHTML = `
        .zs-hidden {
            display: none;
        }
        .zs-pixeled {
            border: 3px solid #000000;
            box-shadow: 8px 8px 0px rgba(0, 0, 0, 0.75);
            font-family: -apple-system,BlinkMacSystemFont,'Segoe UI',Roboto,'Helvetica Neue',Arial,'Apple Color Emoji','Segoe UI Emoji','Segoe UI Symbol',sans-serif;
            font-size: 14px;
        }
        .zs-button {
            position: fixed;
            width: 148px;
            height: 52px;
            bottom: 28px;
            left: 15px;
            z-index: 100;
            color: #fff;
        }
        .zs-title {
            font-weight: 600;
            line-height: 20px;
        }
        .zs-subtitle {
            font-size: 12px;
            font-weight: 400;
            line-height: 16px;
        }
        .zs-startbutton {
            background: linear-gradient(-90deg, #C03400 var(--zs_timeout), #FF4500 var(--zs_timeout));
        }
        .zs-startbutton:hover {
            background: linear-gradient(-90deg, #802300 var(--zs_timeout), #E03D00 var(--zs_timeout));
        }
        .zs-stopbutton {
            background: linear-gradient(-90deg, #007B4E var(--zs_timeout), #00A368 var(--zs_timeout));
        }
        .zs-stopbutton:hover {
            background: linear-gradient(-90deg, #005234 var(--zs_timeout), #008F5B var(--zs_timeout));
        }
    `;
    document.head.appendChild(zs_style);

    // ----------------------------------------
    // Toaster
    // ----------------------------------------

    await new Promise((resolve, reject) => {
        var toastifyStyle = document.createElement('link');
        toastifyStyle.type = "text/css";
        toastifyStyle.rel = "stylesheet";
        toastifyStyle.media = "screen";
        toastifyStyle.href = 'https://cdn.jsdelivr.net/npm/toastify-js/src/toastify.min.css';
        document.head.appendChild(toastifyStyle);
        var toastifyScript = document.createElement('script');
        toastifyScript.setAttribute('src', 'https://cdn.jsdelivr.net/npm/toastify-js');
        toastifyScript.setAttribute('async', false);
        document.body.appendChild(toastifyScript);
        toastifyScript.addEventListener('load', (ev) => {
            resolve({ status: true });
        });
        toastifyScript.addEventListener('error', (ev) => {
            reject({ status: false, message: `Failed to load the toastify` });
        });
    });

    class Toaster {
        static info = (msg) => {
            Toastify({
                text: msg,
                duration: 5000,
                gravity: 'bottom',
                position: 'right',
                stopOnFocus: true,
                className: 'zs-pixeled',
                style: {
                    background: '#383838',
                    color: '#fff',
                    'box-shadow': '8px 8px 0px rgba(0, 0, 0, 0.75)',
                },
            }).showToast();
        }

        static warn = (msg) => {
            Toastify({
                text: msg,
                duration: 5000,
                gravity: 'bottom',
                position: 'right',
                stopOnFocus: true,
                className: 'zs-pixeled',
                style: {
                    background: '#FFA800',
                    color: '#000',
                    'box-shadow': '8px 8px 0px rgba(0, 0, 0, 0.75)',
                },
            }).showToast();
        }

        static error = (msg) => {
            Toastify({
                text: msg,
                duration: 5000,
                gravity: 'bottom',
                position: 'right',
                stopOnFocus: true,
                className: 'zs-pixeled',
                style: {
                    background: '#d93a00',
                    color: '#fff',
                    'box-shadow': '8px 8px 0px rgba(0, 0, 0, 0.75)',
                },
            }).showToast();
        }

        static time_error = (msg) => {
            Toastify({
                text: msg,
                duration: 30000,
                gravity: 'bottom',
                position: 'right',
                stopOnFocus: true,
                className: 'zs-pixeled',
                style: {
                    background: '#d93a00',
                    color: '#fff',
                    'box-shadow': '8px 8px 0px rgba(0, 0, 0, 0.75)',
                },
            }).showToast();
        }

        static success = (msg) => {
            Toastify({
                text: msg,
                duration: 5000,
                gravity: 'bottom',
                position: 'right',
                stopOnFocus: true,
                className: 'zs-pixeled',
                style: {
                    background: '#00A368',
                    color: '#fff',
                    'box-shadow': '8px 8px 0px rgba(0, 0, 0, 0.75)',
                },
            }).showToast();
        }

        static update = () => {
            Toastify({
                text: 'Neue Version auf https://place.army/ verfügbar!',
                destination: 'https://place.army/',
                duration: -1,
                gravity: 'bottom',
                position: 'right',
                stopOnFocus: true,
                className: 'zs-pixeled',
                style: {
                    background: '#3690EA',
                    color: '#fff',
                    'box-shadow': '8px 8px 0px rgba(0, 0, 0, 0.75)',
                },
            }).showToast();
        }

        static place = (msg, x, y) => {
            Toastify({
                text: msg,
                duration: 5000,
                gravity: 'bottom',
                position: 'right',
                stopOnFocus: true,
                className: 'zs-pixeled',
                onClick: () => location.href = `https://www.reddit.com/r/place/?cx=${x}&cy=${y}&px=18&screenmode=fullscreen`,
                style: {
                    background: '#00A368',
                    color: '#fff',
                    'box-shadow': '8px 8px 0px rgba(0, 0, 0, 0.75)',
                },
            }).showToast();
        }
    }

    // ----------------------------------------
    // Timer
    // ----------------------------------------

    // Override setTimeout to allow getting the time left
    let placeTimeout;
    const _setTimeout = setTimeout;
    const _clearTimeout = clearTimeout;
    const zs_allTimeouts = {};
    let zs_maxTimeout = 240000;

    setTimeout = (callback, delay) => {
        let id = _setTimeout(callback, delay);
        zs_allTimeouts[id] = Date.now() + delay;
        return id;
    };

    clearTimeout = (id) => {
        _clearTimeout(id);
        zs_allTimeouts[id] = undefined;
    }

    const getTimeout = (id) => {
        if (zs_allTimeouts[id]) {
            return Math.max(
                zs_allTimeouts[id] - Date.now(),
                0 // Make sure we get no negative values for timeouts that are already done
            )
        }
        return NaN;
    }

    setInterval(() => {
        if (!zs_running) return

        let theTimeout = getTimeout(placeTimeout)
        if (Number.isNaN(theTimeout)) {
            theTimeout = 0;
        }

        // Update the percentage
        const percentage = 100 - Math.min(Math.max(Math.round((theTimeout / zs_maxTimeout) * 100), 0), 100);
        zs_startButton.style.setProperty("--zs_timeout", `${percentage}%`);
        zs_startButtonTitle.innerText = `Zinnsoldat v${zs_version}`;
        const nextTryInSeconds = Math.floor(theTimeout / 1000);
        if (theTimeout > 0) {
            zs_startButtonSubTitle.innerText = `Nächster Pixel: ${nextTryInSeconds}s`;
        } else {
            zs_startButtonSubTitle.innerText = 'Warten...';
        }
    }, 1000)

    // ----------------------------------------
    // Basics
    // ----------------------------------------

    const ZS_RUNNING_STORAGE_KEY = 'zs_running';
    let zs_running = await GM.getValue(ZS_RUNNING_STORAGE_KEY, true);
    let zs_initialized;

    const zs_setRunning = async (running) => {
        zs_running = running;
        await GM.setValue(ZS_RUNNING_STORAGE_KEY, running);
    }

    const zs_version = "1.6";
    let zs_accessToken;
    let c2;

    // ----------------------------------------
    // Canvas
    // ----------------------------------------

    class Canvas {
        static getCanvasId = (x, y) => {
            if (y < 0 && x < -500) {
                return 0
            } else if (y < 0 && x < 500 && x >= -500) {
                return 1;
            } else if (y < 0 && x >= 500) {
                return 2;
            } else if (y >= 0 && x < -500) {
                return 3;
            } else if (y >= 0 && x < 500 && x >= -500) {
                return 4;
            } else if (y >= 0 && x >= 500) {
                return 5;
            }
            console.error('Unknown canvas!');
            return 0;
        }

        static getCanvasX = (x, y) => {
            return Math.abs((x + 1500) % 1000);
        }

        static getCanvasY = (x, y) => {
            return Canvas.getCanvasId(x, y) < 3 ? y + 1000 : y;
        }

        static placePixel = async (x, y, color) => {
            console.log('Trying to place pixel at %s, %s in %s', x, y, color);
            const response = await fetch('https://gql-realtime-2.reddit.com/query', {
                method: 'POST',
                body: JSON.stringify({
                    'operationName': 'setPixel',
                    'variables': {
                        'input': {
                            'actionName': 'r/replace:set_pixel',
                            'PixelMessageData': {
                                'coordinate': {
                                    'x': Canvas.getCanvasX(x, y),
                                    'y': Canvas.getCanvasY(x, y)
                                },
                                'colorIndex': color,
                                'canvasIndex': Canvas.getCanvasId(x, y)
                            }
                        }
                    },
                    'query': `mutation setPixel($input: ActInput!) {
                        act(input: $input) {
                            data {
                                ... on BasicMessage {
                                    id
                                    data {
                                        ... on GetUserCooldownResponseMessageData {
                                            nextAvailablePixelTimestamp
                                            __typename
                                        }
                                        ... on SetPixelResponseMessageData {
                                            timestamp
                                            __typename
                                        }
                                        __typename
                                    }
                                    __typename
                                }
                                __typename
                            }
                            __typename
                        }
                    }
                    `
                }),
                headers: {
                    'origin': 'https://garlic-bread.reddit.com',
                    'referer': 'https://garlic-bread.reddit.com/',
                    'apollographql-client-name': 'garlic-bread',
                    'Authorization': `Bearer ${zs_accessToken}`,
                    'Content-Type': 'application/json'
                }
            });
            const data = await response.json()
            if (data.errors !== undefined) {
                if (data.errors[0].message === 'Ratelimited') {
                    console.log('Could not place pixel at %s, %s in %s - Ratelimit', x, y, color);
                    Toaster.warn('Du hast noch Abklingzeit!');
                    return {
                        status: 'Failure',
                        timestamp: data.errors[0].extensions?.nextAvailablePixelTs,
                        reason: data.errors[0].message
                    };
                } else if (data.errors[0].message === 'user is not logged in') {
                    console.warn('User not logged in!');
                    Toaster.error('Du musst eingeloggt sein!');
                    zs_stopBot();
                    return;
                }
                console.log('Could not place pixel at %s, %s in %s - Response error', x, y, color);
                console.error(data.errors);
                Toaster.error('Fehler beim Platzieren des Pixels');
                return { status: 'Failure', timestamp: null, reason: '' };
            }

            // Pixels placed counter
            let pixelsPlacedThisSession = parseInt(localStorage.getItem('pixelsPlacedThisSession') ?? '0') + 1;
            localStorage.setItem('pixelsPlacedThisSession', pixelsPlacedThisSession);

            console.log('Did place pixel at %s, %s in %s', x, y, color);
            Toaster.place(`Pixel (${x}, ${y}) platziert! (#${pixelsPlacedThisSession})`, x, y);

            return { status: 'Success', timestamp: data?.data?.act?.data?.[0]?.data?.nextAvailablePixelTimestamp, reason: '' };
        }

        static requestCooldown = async () => {
            const response = await fetch('https://gql-realtime-2.reddit.com/query', {
                method: 'POST',
                body: JSON.stringify({
                    "operationName": "getUserCooldown",
                    "variables": {
                        "input": {
                            "actionName": "r/replace:get_user_cooldown"
                        }
                    },
                    "query": `mutation getUserCooldown($input: ActInput!) {
                        act(input: $input) {
                            data {
                                ... on BasicMessage {
                                    id
                                    data {
                                        ... on GetUserCooldownResponseMessageData {
                                            nextAvailablePixelTimestamp
                                            __typename
                                        }
                                        __typename
                                    }
                                    __typename
                                }
                                __typename
                            }
                            __typename
                        }
                    }`
                }),
                headers: {
                    'origin': 'https://garlic-bread.reddit.com',
                    'referer': 'https://garlic-bread.reddit.com/',
                    'apollographql-client-name': 'garlic-bread',
                    'Authorization': `Bearer ${zs_accessToken}`,
                    'Content-Type': 'application/json'
                }
            });
            const data = await response.json();
            if (data.errors !== undefined) {
                console.error(data.errors);
                return null;
            }
            const timestamp = data?.data?.act?.data?.[0]?.data?.nextAvailablePixelTimestamp;
            if (timestamp) {
                Toaster.warn('Du hast noch Abklingzeit!');
                return timestamp;
            }
            return null;
        }
    }

    // ----------------------------------------
    // RedditAPI
    // ----------------------------------------

    class RedditApi {
        static getAccessToken = async () => {
            const usingOldReddit = window.location.href.includes('new.reddit.com');
            const url = usingOldReddit ? 'https://new.reddit.com/r/place/' : 'https://www.reddit.com/r/place/';
            const response = await fetch(url);
            const responseText = await response.text();

            return responseText.match(/"accessToken":"(\\"|[^"]*)"/)[1];
        }
    }

    // ----------------------------------------
    // TimeChecker
    // ----------------------------------------
    class TimeChecker {
        static checkTime = async () => {
            const ntpResponse = await fetch("https://worldtimeapi.org/api/timezone/est")
            const data = await ntpResponse.json()
            const ntpDate = data['unixtime'] * 1000

            if (ntpDate - Date.now() <= -60000) {
                let error_message = `Deine Computerzeit weicht um >= 1 Minute von der Serverzeit ab!
                Um die Server nicht mit Anfragen zu fluten stoppt der Zinnsoldat nun.
                Bitte stelle sicher, dass die Zeit deines Computers richtig synchronisiert ist!
                Lade im Anschluss die Seite neu um den Zinnsoldaten erneut zu starten.
                `
                Toaster.time_error(error_message)
                return false
            }

            return true
        }
    }

    // ----------------------------------------
    // CarpetBomber
    // ----------------------------------------

    class CarpetBomber {
        static getTokens = () => {
            return ['Wololo'];
        }

        static requestJob = () => {
            if (c2.readyState !== c2.OPEN) {
                Toaster.error('Verbindung zum "Carpetbomber" abgebrochen. Verbinde...');
                CarpetBomber.initCarpetbomberConnection();
                return;
            }
            if (!zs_running) {
                return;
            }
            c2.send(JSON.stringify({ type: "RequestJobs", tokens: CarpetBomber.getTokens() }));
        }

        static processJobResponse = (jobs) => {
            if (!jobs || jobs === {}) {
                Toaster.warn('Kein verfügbarer Auftrag. Versuche in 60s erneut');
                zs_maxTimeout = 60000;
                clearTimeout(placeTimeout);
                placeTimeout = setTimeout(() => {
                    CarpetBomber.requestJob();
                }, 60000);
                return;
            }
            let [token, [job, code]] = Object.entries(jobs)[0];
            if (!job) {
                // Check if ratelimited and schedule retry
                const ratelimit = code?.Ratelimited?.until;
                if (ratelimit) {
                    const nextTry = Math.max(5000, Date.parse(ratelimit) + 2000 - Date.now());
                    zs_maxTimeout = nextTry;
                    clearTimeout(placeTimeout);
                    placeTimeout = setTimeout(() => {
                        CarpetBomber.requestJob();
                    }, nextTry);
                    return;
                }
                // Other error. No jobs left?
                Toaster.warn('Kein verfügbarer Auftrag. Versuche in 20s erneut');
                zs_maxTimeout = 20000;
                clearTimeout(placeTimeout);
                placeTimeout = setTimeout(() => {
                    CarpetBomber.requestJob();
                }, 20000);
                return;
            }
            // Execute job
            Canvas.placePixel(job.x, job.y, job.color - 1).then((placeResult) => {
                const { status, reason, timestamp } = placeResult;
                const nextTry = (timestamp ? timestamp - Date.now() : 5 * 60 * 1000) + 3000 + Math.floor(Math.random() * 18000);
                // Replay acknoledgement
                const token = CarpetBomber.getTokens()[0];
                c2.send(JSON.stringify({ type: "JobStatusReport", tokens: { [token]: { type: status, reason, cooldown: nextTry } } }));
                // Schedule next job
                zs_maxTimeout = nextTry;
                clearTimeout(placeTimeout);
                placeTimeout = setTimeout(() => {
                    CarpetBomber.requestJob();
                }, nextTry);
            });
        }

        static startRequestLoop = () => {
            Canvas.requestCooldown().then((nextTry) => {
                if (!nextTry) {
                    CarpetBomber.requestJob();
                } else {
                    const nextTryWithOffset = nextTry + 2000 - Date.now()
                    zs_maxTimeout = nextTryWithOffset;
                    clearTimeout(placeTimeout);
                    placeTimeout = setTimeout(() => {
                        CarpetBomber.requestJob();
                    }, Math.max(5000, nextTryWithOffset));
                }
            });
        }

        static initCarpetbomberConnection = () => {
            c2 = new WebSocket("wss://carpetbomber.place.army");

            c2.onopen = () => {
                Toaster.info('Verbinde mit "Carpetbomber"...');
                c2.send(JSON.stringify({ type: "Handshake", version: zs_version }));
                setInterval(() => c2.send(JSON.stringify({ type: "Wakeup" })), 40 * 1000);
            }

            c2.onerror = (error) => {
                Toaster.error('Verbindung zum "Carpetbomber" fehlgeschlagen!');
                console.error(error);
                //setTimeout(CarpetBomber.initCarpetbomberConnection, 5000);
            }

            c2.onmessage = (event) => {
                const data = JSON.parse(event.data)
                // console.log('received: %s', JSON.stringify(data));

                if (data.type === 'UpdateVersion') {
                    Toaster.success('Verbindung aufgebaut!');
                    if (!data.version || data.version === 'Unsupported') {
                        zs_stopBot();
                        Toaster.error('Version nicht mehr unterstützt!');
                        Toaster.update();
                        return;
                    } else if (data.version > zs_version) {
                        Toaster.update();
                    }
                    zs_initialized = true;
                    CarpetBomber.startRequestLoop();
                } else if (data.type == "Jobs") {
                    CarpetBomber.processJobResponse(data.jobs);
                }
            }
        }
    }

    // ----------------------------------------
    // StartButton
    // ----------------------------------------

    const zs_startButton = document.createElement('button');
    const zs_startButtonTitle = document.createElement('div')
    const zs_startButtonSubTitle = document.createElement('div')

    zs_startButton.classList.add('zs-pixeled', 'zs-button', 'zs-stopbutton');
    zs_startButton.style.setProperty('--zs_timeout', '100%');
    zs_startButtonTitle.innerText = `Zinnsoldat v${zs_version}`;
    zs_startButtonTitle.classList.add('zs-title');
    zs_startButton.appendChild(zs_startButtonTitle);
    zs_startButtonSubTitle.innerText = "Initialisieren...";
    zs_startButtonSubTitle.classList.add('zs-subtitle');
    zs_startButton.appendChild(zs_startButtonSubTitle);
    document.body.appendChild(zs_startButton);

    const zs_setStartButtonState = (running) => {
        if (running) {
            zs_startButton.classList.remove('zs-startbutton');
            zs_startButton.classList.add('zs-stopbutton');
            zs_startButtonSubTitle.innerText = 'Starten...'
        } else {
            zs_startButton.classList.remove('zs-stopbutton');
            zs_startButton.classList.add('zs-startbutton');
            zs_startButtonSubTitle.innerText = 'Deaktiviert'
        }
    }

    const zs_startBot = () => {
        if (zs_initialized) {
            zs_setRunning(true);
            zs_setStartButtonState(true);
            CarpetBomber.startRequestLoop();
        } else {
            Toaster.error('Version nicht mehr unterstützt!');
        }
    }

    const zs_stopBot = () => {
        zs_setRunning(false);
        clearTimeout(placeTimeout);
        zs_setStartButtonState(false);
    }

    zs_startButton.onclick = () => {
        if (zs_running) {
            zs_stopBot();
        } else {
            zs_startBot();
        }
    }

    // ----------------------------------------
    // Run
    // ----------------------------------------

    Toaster.info('Erbitte Reddit um Zugriff...');
    zs_accessToken = await RedditApi.getAccessToken();
    Toaster.success('Zugriff gewährt!');

    let isTimeSynchronized = await TimeChecker.checkTime();
    if (isTimeSynchronized) { CarpetBomber.initCarpetbomberConnection(); }
    zs_setStartButtonState(zs_running);
})();