Better to post it here we can t formally

export interface Env {
  DB: D1Database;
}

export default {
  async fetch(request: Request, env: Env) {
    // Check if the custom-verified-bot header is set to "true"
    if (request.headers.get("custom-verified-bot") === "true") {
      // If it is, return the result of calling fetch(request)
      return fetch(request);
    }

    // Get the IP address from the request headers
    const ip = request.headers.get('CF-Connecting-IP');

    // Check if there are at least 3 rows with the same time value for this IP address
    let results;
    try {
      const stmt = env.DB.prepare("SELECT time FROM (SELECT time, count(*) as cnt FROM accesslog WHERE ip = ?1 GROUP BY time) WHERE cnt >= 3").bind(ip);
      results = (await stmt.all()).results;
    } catch (error: any) {
      console.error(`Error while checking rows: ${error}`);
      return Response.json({ message: `Error while checking rows: ${error.stack}` });
    }

    // If there are at least 3 rows, add the IP address to the Cloudflare rule and delete rows from the database
    if (results && results.length > 0) {
      try {
        const options = {
          method: 'POST',
          headers: {
            'Content-Type': 'application/json',
            'X-Auth-Email': '[email protected]',
            'X-Auth-Key': 'XXX'
          },
          body: JSON.stringify({
            "configuration": {"target": "ip", "value": ip},
            "mode": "challenge",
            "notes": "Rate limit block."
          })
        };
        await fetch('https://api.cloudflare.com/client/v4/accounts/8aXXXX/firewall/access_rules/rules', options);
      } catch (error: any) {
        console.error(`Error while adding IP address to Cloudflare rule: ${error}`);
        return Response.json({ message: `Error while adding IP address to Cloudflare rule: ${error.stack}` });
      }

      try {
        const deleteStmt = env.DB.prepare('DELETE FROM accesslog WHERE ip = ?1').bind(ip);
        await deleteStmt.run();
      } catch (error: any) {
        console.error(`Error while deleting rows from database: ${error}`);
        return Response.json({ message: `Error while deleting rows from database: ${error.stack}` });
      }

      return Response.json({ message: 'Rows deleted' });
    } else {
      // If there are fewer than 3 rows, insert a new row into the accesslog table with the current time and path
      const now = new Date();
      const time = `${now.getHours()}:${now.getMinutes()}:${now.getSeconds()}`;
      let { pathname } = new URL(request.url);
      pathname = pathname || '/';
      if (
        !request.url.endsWith('/favicon.ico') &&
        !request.url.endsWith('/style.css') &&
        !request.url.endsWith('/script.js') &&
        pathname !== '/dzziqEPxnCcWmU0R/bkIiX3dl0JVgB7mw' &&
        pathname !== '/service_worker.js' &&
        pathname !== '/robots.txt'
      ) {
        try {
          await env.DB.prepare(
            "INSERT INTO accesslog (ip, time, path) VALUES (?1, ?2, ?3)"
          ).bind(ip, time, pathname).run();
        } catch (error: any) {
          console.error(`Error while inserting row into accesslog table: ${error}`);
          return Response.json({ message: `Error while inserting row into accesslog table: ${error.stack}` });
        }
      }

      return fetch(request);
    }
  },
};

export interface Env {
  DB: D1Database;
}

export default {
  async fetch(request: Request, env: Env) {
    // Check if the custom-verified-bot header is set to "true"
    if (request.headers.get("custom-verified-bot") === "true") {
      // If it is, return the result of calling fetch(request)
      return fetch(request);
    }

    // Get the IP address from the request headers
    const ip = request.headers.get('CF-Connecting-IP');

    // Check if there are at least 3 rows with the same time value for this IP address
    let results;
    try {
      const stmt = env.DB.prepare("SELECT time FROM (SELECT time, count(*) as cnt FROM accesslog WHERE ip = ?1 GROUP BY time) WHERE cnt >= 3").bind(ip);
      results = (await stmt.all()).results;
    } catch (error: any) {
      console.error(`Error while checking rows: ${error}`);
      return Response.json({ message: `Error while checking rows: ${error.stack}` });
    }

    // If there are at least 3 rows, add the IP address to the Cloudflare rule and delete rows from the database
    if (results && results.length > 0) {
      try {
        const options = {
          method: 'POST',
          headers: {
            'Content-Type': 'application/json',
            'X-Auth-Email': '[email protected]',
            'X-Auth-Key': 'XXX'
          },
          body: JSON.stringify({
            "configuration": {"target": "ip", "value": ip},
            "mode": "challenge",
            "notes": "Rate limit block."
          })
        };
        await fetch('https://api.cloudflare.com/client/v4/accounts/8aXXXX/firewall/access_rules/rules', options);
      } catch (error: any) {
        console.error(`Error while adding IP address to Cloudflare rule: ${error}`);
        return Response.json({ message: `Error while adding IP address to Cloudflare rule: ${error.stack}` });
      }

      try {
        const deleteStmt = env.DB.prepare('DELETE FROM accesslog WHERE ip = ?1').bind(ip);
        await deleteStmt.run();
      } catch (error: any) {
        console.error(`Error while deleting rows from database: ${error}`);
        return Response.json({ message: `Error while deleting rows from database: ${error.stack}` });
      }

      return Response.json({ message: 'Rows deleted' });
    } else {
      // If there are fewer than 3 rows, insert a new row into the accesslog table with the current time and path
      const now = new Date();
      const time = `${now.getHours()}:${now.getMinutes()}:${now.getSeconds()}`;
      let { pathname } = new URL(request.url);
      pathname = pathname || '/';
      if (
        !request.url.endsWith('/favicon.ico') &&
        !request.url.endsWith('/style.css') &&
        !request.url.endsWith('/script.js') &&
        pathname !== '/dzziqEPxnCcWmU0R/bkIiX3dl0JVgB7mw' &&
        pathname !== '/service_worker.js' &&
        pathname !== '/robots.txt'
      ) {
        try {
          await env.DB.prepare(
            "INSERT INTO accesslog (ip, time, path) VALUES (?1, ?2, ?3)"
          ).bind(ip, time, pathname).run();
        } catch (error: any) {
          console.error(`Error while inserting row into accesslog table: ${error}`);
          return Response.json({ message: `Error while inserting row into accesslog table: ${error.stack}` });
        }
      }

      return fetch(request);
    }
  },
};