.gitignore

@@ -1,5 +1,3 @@
-mc/
-server/test.js
 server/servers.db
 ip.txt
 server/node_modules
@@ -7,3 +5,7 @@ nimscan/bin
 .vscode
 server_backup
 old_tests
+nim_bot/src/token.key
+nim_bot/src/tmp
+nim_bot/src/bin
+server/offline.db

README.md

@@ -0,0 +1,10 @@
+# TaxenHeimer
+TaxenHeimer is a project inspired by the famous CopenHeimer server scanner.
+
+## Description
+In this repository you'll find 2 directories, one with the scanner(client) and one with the backend(server)
+```
+Client: generate random IPs and ping for minecraft server with a handshake packet if received packet is valid sends the IP to the backend
+
+Server: Query the IPs for all the needed informations, sends the to a discord webhook and saves them to a local SQLite3 database
+```

nim_bot/README.md

@@ -0,0 +1,7 @@
+# TaxenHeimer Discord Bot
+Discord bot written in nim to help with easy query commands on the database
+
+## Running
+```
+nim c src/nim_bot.nim
+```

nim_bot/nim_bot.nimble

@@ -0,0 +1,13 @@
+# Package
+
+version       = "0.1.0"
+author        = "TaxMachine"
+description   = "A new awesome nimble package"
+license       = "MIT"
+srcDir        = "src"
+bin           = @["nim_bot"]
+
+
+# Dependencies
+
+requires "nim >= 1.6.6"

nim_bot/src/config.nims

@@ -0,0 +1,3 @@
+switch("d", "ssl")
+switch("d", "release")
+switch("o", "bin/nim_bot")

nim_bot/src/nim_bot.nim

@@ -0,0 +1,188 @@
+import asyncdispatch, json, options, dimscord, strutils, harpoon, os, db_sqlite, strformat, tables
+from uri import parseUri
+discard os.execShellCmd("clear")
+let
+  keyfile = readFile("token.key")
+  discord = newDiscordClient(keyfile)
+  prefix = "$"
+proc onReady(s: Shard, r: Ready) {.event(discord).} =
+  echo "Login on " & $r.user
+
+proc messageCreate(s: Shard, m: Message) {.event(discord).} =
+  if m.author.bot: return
+  if not m.content.startsWith(prefix): return
+  let
+    args = m.content.toLowerAscii().substr(prefix.len).split(" ")
+    argument = m.content.split(" ")
+  case args[0]:
+    of "help":
+      discard await discord.api.sendMessage(
+        m.channel_id,
+        embeds = @[Embed(
+          title: some "TaxenHeimer Bot",
+          fields: some @[EmbedField(
+            name: fmt"**{prefix}help**",
+            value: "`Displays this menu`",
+            inline: some true
+          ),
+          EmbedField(
+            name: fmt"**{prefix}namemc**",
+            value: "`Displays informations about a minecraft account`",
+            inline: some true
+          ),
+          EmbedField(
+            name: fmt"**{prefix}status**",
+            value: "`Gives overall informations on the database`",
+            inline: some true
+          )],
+          color: some 0x000066
+        )]
+      )
+    of "namemc":
+      if (argument.len < 2):
+        discard await discord.api.sendMessage(m.channel_id, "User not found")
+      else:
+        let
+          url = "https://api.ashcon.app/mojang/v2/user/" & argument[1]
+          data = getJson(parseUri(url))
+        if (data{"code"}.getInt == 404):
+          discard await discord.api.sendMessage(m.channel_id, "User not found")
+        else:
+          var
+            uuid = data["uuid"].getStr
+            renderurl = "https://crafatar.com/avatars/" & uuid
+            bodyurl = "https://crafatar.com/renders/body/" & uuid
+            username = data["username"].getStr
+            date = data{"created_at"}.getStr
+            usernamehistory = data["username_history"]
+            hist = ""
+          if (usernamehistory.len > 0):
+            for names in usernamehistory:
+              if (names{"changed_at"}.isNil):
+                hist.add(names["username"].getStr & " : " & "Original\n")
+              else:
+                var
+                  cdate = names{"changed_at"}.getStr.split("T")
+                  pdate = cdate[1].split(".")[0] & " " & cdate[0]
+                hist.add(names["username"].getStr & " : " & pdate & "\n")
+          else:
+            hist.add("No Name History")
+          discard await discord.api.sendMessage(
+            m.channel_id,
+            embeds = @[Embed(
+              title: some "Namemc Lookup",
+              fields: some @[EmbedField(
+                  name: "**username**",
+                  value: fmt"```{'\n'}{username}{'\n'}```",
+                  inline: some true
+                ),
+                EmbedField(
+                  name: "**UUID**",
+                  value: fmt"```{'\n'}{uuid}{'\n'}```",
+                  inline: some true
+                ),
+                EmbedField(
+                  name: "**Creation Date(Might not be given)**",
+                  value: fmt"```{'\n'}{date}{'\n'}```",
+                  inline: some true
+                ),
+                EmbedField(
+                  name: "**Name History**",
+                  value: fmt"```fix{'\n'}{hist}{'\n'}```",
+                  inline: some false
+                )
+              ],
+              thumbnail: some EmbedThumbnail(
+                url: some renderurl
+              ),
+              image: some EmbedImage(
+                url: some bodyurl
+              ),
+              color: some 0x000066
+            )]
+          )
+    of "status":
+      let
+        db = open("../../server/servers.db", "", "", "")
+        offdb = open("../../server/offline.db", "", "", "")
+        server = db.getAllRows(sql"SELECT host FROM servers").len
+        offline = offdb.getAllRows(sql"SELECT host FROM servers").len
+        total = server + offline
+      discard await discord.api.sendMessage(
+        m.channel_id,
+        embeds = @[Embed(
+          title: some "**Server Database Status**",
+          color: some 0x000066,
+          fields: some @[EmbedField(
+            name: "**Online Servers**",
+            value: fmt"```{$server} online servers```"
+          ),
+          EmbedField(
+            name: "**Offline Servers**",
+            value: fmt"```{$offline} offline servers```"
+          ),
+          EmbedField(
+            name: "**Total Servers**",
+            value: fmt"```{total} total servers```"
+          )]
+        )]
+      )
+    of "info":
+      discard await discord.api.sendMessage(
+        m.channel_id,
+        embeds = @[Embed(
+          title: some "TaxenHeimer bot",
+          description: some "```Discord bot that help to manage TaxenHeimer database queries```",
+          color: some 0x000066,
+          fields: some @[EmbedField(
+            name: "**Author**",
+            value: "```TaxMachine```",
+            inline: some true
+          ),
+          EmbedField(
+            name: "**Language**",
+            value: "```nim```",
+            inline: some true
+          ),
+          EmbedField(
+            name: "**Credits**",
+            value: "```\nPackage: https://nimble.directory/pkg/dimscord\nHelp: https://discord.gg/nim https://discord.gg/dimscord```"
+          )]
+        )]
+      )
+
+proc guild_member_add(s: Shard, g: Guild, m: Member) {.event(discord).} =
+  discard await discord.api.sendMessage(
+    "999502028227227810",
+    embeds = @[Embed(
+      title: some "**Welcome**",
+      description: some fmt"Welcome <@{m.user.id}> to TaxenHeimer! Hope you'll have a great time :coffee:",
+      color: some 0x000066,
+      fields: some @[EmbedField(
+        name: "Member Count",
+        value: "```\n" & $g.members.len & "\n```"
+      )]
+    )]
+  )
+  discard discord.api.addGuildMemberRole(
+    g.id,
+    m.user.id,
+    "999538053943140463",
+    "Joining"
+  )
+
+proc guild_member_remove(s: Shard, g: Guild, m: Member) {.event(discord).} =
+  discard await discord.api.sendMessage(
+    "1001391863263150150",
+    embeds = @[Embed(
+      title: some "**Goodbye**",
+      description: some fmt"Goodbye {m.user.username} :brain: :clown:",
+      color: some 0x000066,
+      fields: some @[EmbedField(
+        name: "Member Count",
+        value: "```\n" & $g.members.len & "\n```"
+      )]
+    )]
+  )
+
+waitFor discord.startSession()

nimscan/README.md

@@ -0,0 +1,7 @@
+# TaxenHeimer Server Scanner
+The project core, the program that is used to scan port on random IPs, written in nim for faster results. runs on 300 threads
+
+## Running
+```
+nim c scanner.nim
+```

nimscan/config.nims

@@ -1 +1,4 @@
 --threads:on
+switch("d", "release")
+switch("d", "ssl")
+switch("o", "bin/scanner")

nimscan/scanner.nim

@@ -37,13 +37,14 @@ proc hit(host: string) {.gcsafe.} =
 
 proc main(): void {.thread.} =
     while true:
-        var ip = GenerateIP()
+        var
-        var ping = status(ip)
+            ip = GenerateIP()
+            ping = status(ip)
         if ping:
             hit(ip)
         discard
 
-var cmd = os.execShellCmd("clear")
+discard os.execShellCmd("clear")
 var cLock: Lock
 initLock(cLock)
 var thread: Thread[void]

server/README.md

@@ -0,0 +1,14 @@
+# TaxenHeimer Backend Server
+Backend server for TaxenHeimer written in Node.JS
+
+## Running it
+Test environment
+```
+npm run test
+```
+Release<br>
+(Uses bytenode to compile and makes scripts a bit faster)
+```
+npm run compile
+npm run runc
+```

server/config.json

@@ -1,5 +0,0 @@
-{
-    "main": "https://discord.com/api/webhooks/999381041041129573/5vmF56GsDdg8D3HJWnu-pRsBmxqPqnzHBTQAu1yLcZQ93xhR36V2UUUVNhRrAHZQyKzA",
-    "neit": "https://discord.com/api/webhooks/1000916905600761887/yeC4nbJYeS38JlNdI42dh8cfcmeX0SZeFSvqmeCIdCZJtJewkq6DjIMXAjwmBhF65XtA",
-    "fronce": "https://discord.com/api/webhooks/1000903130222952518/cRK-SXahsWl8OT_N4HLnt7I0JebGnQh0gN3p3iOvCW_QIVC7hq2oWlmt6txC7NSXtv55"
-}

server/css/index.css

@@ -0,0 +1,20 @@
+@import url('https://fonts.googleapis.com/css2?family=Nunito+Sans:wght@200&display=swap');
+.😳 {
+    padding: 10px;
+    color: #dcddde;
+    font-size: 20px;
+    border: solid rgba(168, 168, 168, 0.89) 1px;
+}
+.👽 {
+    font-family: 'Nunito Sans';
+    padding: 10px;
+    font-size: 25px;
+    color: rgba(255, 255, 255, 0.959);
+    text-align: center;
+}
+.💀 {
+    background-color: rgba(49, 49, 49, 0.89);
+}
+body {
+    background-color: rgb(20, 20, 20);
+}

server/index.js

@@ -1,24 +1,45 @@
-const express = require('express'),
+const express = require("express"),
-    sqlite3 = require('sqlite3'),
+    sqlite3 = require("sqlite3"),
-    bodyParser = require('body-parser'),
+    bodyParser = require("body-parser"),
+    mc = require("minecraft-server-util"),
+    Discord = require("discord-webhook-node"),
+    geoIP = require("geoip-lite"),
+    fs = require("fs"),
+    config = require("./config.json"),
     app = express(),
-    mc = require('minecraft-server-util'),
+    db = new sqlite3.Database("./servers.db"),
-    discord = require('discord-webhook-node'),
+    offline = new sqlite3.Database("./offline.db");
-    geoip = require('geoip-lite'),
+
-    fs = require('fs'),
+const createWebhook = url => new Discord.Webhook(url).setUsername("TaxenHeimer").setAvatar("https://cdn.discordapp.com/attachments/999167321631363126/999495738943868928/nn.png")
-    config = require('./config.json')
+const countrify = e => require("./countrycode.json")[e]
-var webhook = new discord.Webhook(config.main)
+const replaceMOTD = e => e.replace(/'/g, "\\'").replace(/-/g, '\\-')
-    .setUsername("TaxenHeimer")
+const makeEmbed = (mc, neit) => {
-    .setAvatar("https://cdn.discordapp.com/attachments/999167321631363126/999495738943868928/nn.png")
+    var Embed = new Discord.MessageBuilder()
-var webhookfronce = new discord.Webhook(config.fronce)
+        .setTitle("TaxenHeimer")
-    .setAvatar("https://cdn.discordapp.com/attachments/999167321631363126/999495738943868928/nn.png")
+        .setColor("#00ff00")
-    .setUsername("TaxenHeimer")
+        .addField("**Host**", `\`${mc.Server}\``, true)
-var neithook = new discord.Webhook(config.neit)
+        .addField("**Country**", `\`${countrify(mc.ip.country)}\``)
-    .setAvatar("https://cdn.discordapp.com/attachments/999167321631363126/999495738943868928/nn.png")
+        .addField("**Version**", `\`${mc.version.name}\``, true)
-    .setUsername("TaxenHeimer")
+        .addField("**Players**", `\`${mc.players.online}/${mc.players.max}\``, true)
-app.use(bodyParser.json())
+        .addField("**Ping**", `\`${mc.roundTripLatency}ms\``, true)
-app.use(bodyParser.urlencoded({extended: true}))
+        .addField("**Motd**", "```\n" + mc.motd.clean + "\n```")
-db = new sqlite3.Database('./servers.db')
+        .addField("**Playerlist Sample**", "```fix\n" + mc.PlayerList + "\n```")
+        .addField("**IP Range**", "```\n" + geoIP.pretty(mc.ip.range[0]) + " - " + geoIP.pretty(mc.ip.range[1]) + "```")
+        .setTimestamp()
+
+    if (neit) Embed.setText("<@390491795655622657>")
+    return Embed
+}
+var webhooks = [
+    createWebhook(config.main),
+    createWebhook(config.fronce),
+    createWebhook(config.neit)
+]
+
+app.use(bodyParser.json()).use(bodyParser.urlencoded({
+    extended: true
+}))
+
 db.exec(`CREATE TABLE IF NOT EXISTS servers (
     host text not null,
     version text not null,
@@ -28,87 +49,114 @@ db.exec(`CREATE TABLE IF NOT EXISTS servers (
     motd text not null,
     timestamp text not null
 )`)
-function countrify(code) {
+offline.exec(`CREATE TABLE IF NOT EXISTS servers (
-    var config = require('./countrycode.json')
+    host text not null,
-    return config[code]
+    timestamp text not null
-}
+)`)
-app.post('/server', async(req, res) => {
+app.post("/server", async (req, res) => {
-    var server = req.body.server
+    var Server = req.body.server
-    if (!server) return res.send("specify a server")
+    if (!Server) return res.send("specify a server")
-    var ipfile = fs.readFileSync(`${__dirname}/ip.txt`, 'utf8')
-    if (ipfile.includes(server)) return;
     res.send("allah")
-    mc.status(server, 25565, {enableSRV: true}).then(res => {
+    if (fs.readFileSync(`${__dirname}/ip.txt`).toString().includes(Server)) return
-        var playerlist = ""
+    var Minecraft = await mc.status(Server, 25565, {
-        if (res.players.sample != null) {
+        enableSRV: true
-            res.players.sample.forEach(e => playerlist += `${e.name}::${e.id}\n`)
+    }).catch(e => {
-        } else {
+        offline.exec(`INSERT INTO servers VALUES (
-            playerlist += "No players"
+            '${Server}',
-        }
+            '${new Date().toLocaleDateString("en-US")}'
-        var ip = geoip.lookup(server)
-        if (res.motd.clean.includes("'")) var cleanmotd = res.motd.clean.replace(/'/g, "\\'")
-        else cleanmotd = res.motd.clean
-        if (res.motd.clean.includes('-')) var cleanmotd = res.motd.clean.replace(/-/g, '\\-')
-        else cleanmotd = res.motd.clean
-        db.exec(`INSERT INTO servers VALUES (
-            '${server}:25565',
-            '${res.version.name}',
-            '${res.players.online}/${res.players.max}',
-            '${playerlist}',
-            '${res.roundTripLatency}ms',
-            '${cleanmotd}',
-            '${(new Date()).toLocaleDateString('en-US')}'
         )`)
-        if (ip.country === "FR") {
+    })
-            const embed = new discord.MessageBuilder()
+    fs.appendFileSync(`${__dirname}/ip.txt`, `${Server}\n`)
-                .setTitle("TaxenHeimer")
+    Minecraft.ip = geoIP.lookup(Server)
-                .setColor("#00ff00")
+    Minecraft.Server = `${Server}:25565`
-                .addField("**Host**", `\`${server}:25565\``, true)
+    var cleanMOTD = replaceMOTD(Minecraft.motd.clean)
-                .addField("**Country**", `\`${countrify(ip.country)}\``)
+    Minecraft.PlayerList = ""
-                .addField("**Version**", `\`${res.version.name} (${res.version.protocol})\``, true)
+    Minecraft.players.sample ? Minecraft.players.sample.forEach(e => Minecraft.PlayerList += `${e.name} : ${e.id}\n`) : Minecraft.PlayerList = "No Players"
-                .addField("**Players**", `\`${res.players.online}/${res.players.max}\``, true)
+    db.exec(`INSERT INTO servers VALUES (
-                .addField("**Ping**", `\`${res.roundTripLatency}ms\``, true)
+        '${Minecraft.Server}',
-                .addField("**Motd**", "```\n"+res.motd.clean+"\n```")
+        '${Minecraft.version.name}',
-                .addField("**Playerlist Sample**", "```\n"+playerlist+"\n```")
+        '${Minecraft.players.online}/${Minecraft.players.max}',
-                .addField("**IP Range**", "```\n" + geoip.pretty(ip.range[0]) + " - " + geoip.pretty(ip.range[1]) + "```")
+        '${Minecraft.PlayerList.replace(/\n/g, "\\n")}',
-            .setTimestamp()
+        '${Minecraft.roundTripLatency}ms',
-            webhookfronce.send(embed)
+        '${cleanMOTD}',
-        }
+        '${new Date().toLocaleDateString('en-US')}'
-        if (res.version.name.includes("1.17")) {
+    )`)
-            const embed = new discord.MessageBuilder()
+    switch (Minecraft.ip.country) {
-                .setText("<@390491795655622657>")
+        default: break;
-                .setTitle("TaxenHeimer")
+        case "FR":
-                .setColor("#00ff00")
+            webhooks[1].send(makeEmbed(Minecraft))
-                .addField("**Host**", `\`${server}:25565\``, true)
+            break
-                .addField("**Country**", `\`${countrify(ip.country)}\``)
+    }
-                .addField("**Version**", `\`${res.version.name} (${res.version.protocol})\``, true)
+    switch(true) {
-                .addField("**Players**", `\`${res.players.online}/${res.players.max}\``, true)
+        case Minecraft.version.name === "1.17":
-                .addField("**Ping**", `\`${res.roundTripLatency}ms\``, true)
+            webhooks[2].send(makeEmbed(Minecraft, "neit"))
-                .addField("**Motd**", "```\n"+res.motd.clean+"\n```")
+            break;
-                .addField("**Playerlist Sample**", "```\n"+playerlist+"\n```")
+        default:
-                .addField("**IP Range**", "```\n" + geoip.pretty(ip.range[0]) + " - " + geoip.pretty(ip.range[1]) + "```")
+            webhooks[0].send(makeEmbed(Minecraft))
-                .setTimestamp()
+            break
-            neithook.send(embed)
+    }
-        }
-        const embed = new discord.MessageBuilder()
-            .setTitle("TaxenHeimer")
-            .setColor("#00ff00")
-            .addField("**Host**", `\`${server}:25565\``, true)
-            .addField("**Country**", `\`${countrify(ip.country)}\``)
-            .addField("**Version**", `\`${res.version.name} (${res.version.protocol})\``, true)
-            .addField("**Players**", `\`${res.players.online}/${res.players.max}\``, true)
-            .addField("**Ping**", `\`${res.roundTripLatency}ms\``, true)
-            .addField("**Motd**", "```\n"+res.motd.clean+"\n```")
-            .addField("**Playerlist Sample**", "```\n"+playerlist+"\n```")
-            .addField("**IP Range**", "```\n" + geoip.pretty(ip.range[0]) + " - " + geoip.pretty(ip.range[1]) + "```")
-            .setTimestamp()
-        webhook.send(embed)
-        fs.appendFileSync(`${server}\n`)
-    }).catch(e => {})
 })
 app.listen(9000, () => {
     console.clear()
     console.log("server ready")
 })
-process.on("unhandledRejection", callback => {})
+app.use(express.static(`${__dirname}/css`))
-process.on("uncaughtException", callback => {})
+app.get('/', async(req, res) => {
+    db.all(`SELECT host, version FROM servers`, async(err, servers) => {
+        var table = ""
+        for (var srv of servers) {
+            var proto = srv.version.split(" ")
+            proto.length >= 2 ? software = proto[0] : software = "Vanilla"
+            proto.length <= 1 ? version = proto[0] : version = proto[1]
+            table += `<tr><td class="😳">${srv.host}</td><td class="😳">${version}</td><td class="😳">${software}</td></tr>`
+        }
+        let content = `
+        <html>
+            <head>
+                <title>TaxenHeimer</title>
+                <link rel="stylesheet" href="index.css">
+            </head>
+            <body>
+                <center>
+                    <table class="👽" id="allah">
+                        <tr><td class="💀">Host</td><td class="💀">Version</td><td class="💀">Software</td></tr>
+                        ${table}
+                    </table>
+                </center>
+            </body>
+        </html>
+        `
+        res.send(content)
+    })
+})
+async function updatedb() {
+    db.all(`SELECT host FROM servers`, async(err, serv) => {
+        for (var servs of serv) {
+            var srv = servs.host
+            mc.status(srv.split(":")[0], parseInt(srv.split(":")[1]), {
+                enableSRV: true
+            }).then(minecraft => {
+            var cleanMOTD = replaceMOTD(minecraft.motd.clean)
+            minecraft.PlayerList = ""
+            minecraft.players.sample ? minecraft.players.sample.forEach(e => minecraft.PlayerList += `${e.name} : ${e.id}\n`) : minecraft.PlayerList = "No Players"
+            db.exec(`UPDATE servers SET
+                version='${minecraft.version.name}',
+                players='${minecraft.players.online}/${minecraft.players.max}',
+                playerlist='${minecraft.PlayerList.replace(/\n/g, "\\n")}',
+                ping='${minecraft.roundTripLatency}ms',
+                motd='${cleanMOTD}',
+                timestamp='Last updated ${new Date().toLocaleDateString('en-US')}'
+            WHERE host='${srv}'`)
+            }).catch(e => {
+                db.exec(`DELETE FROM servers WHERE host='${srv}'`)
+                offline.exec(`INSERT INTO servers VALUES (
+                    '${srv}',
+                    '${new Date().toLocaleDateString("en-US")}'
+                )`)
+            })
+        }
+    })
+    return "Update finished"
+}
+process.on("unhandledRejection", callback => console.log(callback.message))
+process.on("uncaughtException", callback => console.log(callback.message))

server/package.json

@@ -4,7 +4,7 @@
   "description": "",
   "main": "index.js",
   "scripts": {
-    "test": "nodemon index",
+    "test": "nodemon --ignore servers.db index",
     "compile": "bytenode --compile index.js",
     "runc": "bytenode index.js"
   },