diff --git a/src/index.js b/src/index.js
index cde9e0e..73a4b29 100644
--- a/src/index.js
+++ b/src/index.js
@@ -45,7 +45,6 @@ const config = require("./cfg");
 const utils = require("./utils");
 const main = require("./main");
 const knex = require("./knex");
-const legacyMigrator = require("./legacy/legacyMigrator");
 
 // Force crash on unhandled rejections (use something like forever/pm2 to restart)
 process.on("unhandledRejection", err => {
@@ -68,31 +67,6 @@ process.on("unhandledRejection", err => {
     console.log("Done!");
   }
 
-  // Migrate legacy data if we need to
-  if (await legacyMigrator.shouldMigrate()) {
-    console.log("=== MIGRATING LEGACY DATA ===");
-    console.log("Do not close the bot!");
-    console.log("");
-
-    await legacyMigrator.migrate();
-
-    const relativeDbDir = (path.isAbsolute(config.dbDir) ? config.dbDir : path.resolve(process.cwd(), config.dbDir));
-    const relativeLogDir = (path.isAbsolute(config.logDir) ? config.logDir : path.resolve(process.cwd(), config.logDir));
-
-    console.log("");
-    console.log("=== LEGACY DATA MIGRATION FINISHED ===");
-    console.log("");
-    console.log("IMPORTANT: After the bot starts, please verify that all logs, threads, blocked users, and snippets are still working correctly.");
-    console.log("Once you've done that, the following files/directories are no longer needed. I would recommend keeping a backup of them, however.");
-    console.log("");
-    console.log("FILE: " + path.resolve(relativeDbDir, "threads.json"));
-    console.log("FILE: " + path.resolve(relativeDbDir, "blocked.json"));
-    console.log("FILE: " + path.resolve(relativeDbDir, "snippets.json"));
-    console.log("DIRECTORY: " + relativeLogDir);
-    console.log("");
-    console.log("Starting the bot...");
-  }
-
   // Start the bot
   main.start();
 })();
diff --git a/src/legacy/jsonDb.js b/src/legacy/jsonDb.js
deleted file mode 100644
index 1c534e9..0000000
--- a/src/legacy/jsonDb.js
+++ /dev/null
@@ -1,71 +0,0 @@
-const fs = require("fs");
-const path = require("path");
-const config = require("../cfg");
-
-const dbDir = config.dbDir;
-
-const databases = {};
-
-/**
- * @deprecated Only used for migrating legacy data
- */
-class JSONDB {
-  constructor(path, def = {}, useCloneByDefault = false) {
-    this.path = path;
-    this.useCloneByDefault = useCloneByDefault;
-
-    this.load = new Promise(resolve => {
-      fs.readFile(path, {encoding: "utf8"}, (err, data) => {
-        if (err) return resolve(def);
-
-        let unserialized;
-        try { unserialized = JSON.parse(data); }
-        catch (e) { unserialized = def; }
-
-        resolve(unserialized);
-      });
-    });
-  }
-
-  get(clone) {
-    if (clone == null) clone = this.useCloneByDefault;
-
-    return this.load.then(data => {
-      if (clone) return JSON.parse(JSON.stringify(data));
-      else return data;
-    });
-  }
-
-  save(newData) {
-    const serialized = JSON.stringify(newData);
-    this.load = new Promise((resolve, reject) => {
-      fs.writeFile(this.path, serialized, {encoding: "utf8"}, () => {
-        resolve(newData);
-      });
-    });
-
-    return this.get();
-  }
-}
-
-function getDb(dbName, def) {
-  if (! databases[dbName]) {
-    const dbPath = path.resolve(dbDir, `${dbName}.json`);
-    databases[dbName] = new JSONDB(dbPath, def);
-  }
-
-  return databases[dbName];
-}
-
-function get(dbName, def) {
-  return getDb(dbName, def).get();
-}
-
-function save(dbName, data) {
-  return getDb(dbName, data).save(data);
-}
-
-module.exports = {
-  get,
-  save,
-};
diff --git a/src/legacy/legacyMigrator.js b/src/legacy/legacyMigrator.js
deleted file mode 100644
index 18720ec..0000000
--- a/src/legacy/legacyMigrator.js
+++ /dev/null
@@ -1,222 +0,0 @@
-const fs = require("fs");
-const path = require("path");
-const promisify = require("util").promisify;
-const moment = require("moment");
-const Eris = require("eris");
-
-const knex = require("../knex");
-const config = require("../cfg");
-const jsonDb = require("./jsonDb");
-const threads = require("../data/threads");
-
-const {THREAD_STATUS, THREAD_MESSAGE_TYPE} = require("../data/constants");
-
-const readDir = promisify(fs.readdir);
-const readFile = promisify(fs.readFile);
-const access = promisify(fs.access);
-const writeFile = promisify(fs.writeFile);
-
-async function migrate() {
-  console.log("Migrating open threads...");
-  await migrateOpenThreads();
-
-  console.log("Migrating logs...");
-  await migrateLogs();
-
-  console.log("Migrating blocked users...");
-  await migrateBlockedUsers();
-
-  console.log("Migrating snippets...");
-  await migrateSnippets();
-
-  await writeFile(path.join(config.dbDir, ".migrated_legacy"), "");
-}
-
-async function shouldMigrate() {
-  // If there is a file marking a finished migration, assume we don't need to migrate
-  const migrationFile = path.join(config.dbDir, ".migrated_legacy");
-  try {
-    await access(migrationFile);
-    return false;
-  } catch (e) {}
-
-  // If there are any old threads, we need to migrate
-  const oldThreads = await jsonDb.get("threads", []);
-  if (oldThreads.length) {
-    return true;
-  }
-
-  // If there are any old blocked users, we need to migrate
-  const blockedUsers = await jsonDb.get("blocked", []);
-  if (blockedUsers.length) {
-    return true;
-  }
-
-  // If there are any old snippets, we need to migrate
-  const snippets = await jsonDb.get("snippets", {});
-  if (Object.keys(snippets).length) {
-    return true;
-  }
-
-  // If the log file dir exists and has logs in it, we need to migrate
-  try {
-    const files = await readDir(config.logDir);
-    if (files.length > 1) return true; // > 1, since .gitignore is one of them
-  } catch(e) {}
-
-  return false;
-}
-
-async function migrateOpenThreads() {
-  const bot = new Eris.Client(config.token);
-
-  const toReturn = new Promise(resolve => {
-    bot.on("ready", async () => {
-      const oldThreads = await jsonDb.get("threads", []);
-
-      const promises = oldThreads.map(async oldThread => {
-        const existingOpenThread = await knex("threads")
-          .where("channel_id", oldThread.channelId)
-          .first();
-
-        if (existingOpenThread) return;
-
-        const oldChannel = bot.getChannel(oldThread.channelId);
-        if (! oldChannel) return;
-
-        const threadMessages = await oldChannel.getMessages(1000);
-        const log = threadMessages.reverse().map(msg => {
-          const date = moment.utc(msg.timestamp, "x").format("YYYY-MM-DD HH:mm:ss");
-          return `[${date}] ${msg.author.username}#${msg.author.discriminator}: ${msg.content}`;
-        }).join("\n") + "\n";
-
-        const newThread = {
-          status: THREAD_STATUS.OPEN,
-          user_id: oldThread.userId,
-          user_name: oldThread.username,
-          channel_id: oldThread.channelId,
-          is_legacy: 1
-        };
-
-        const threadId = await threads.createThreadInDB(newThread);
-
-        await knex("thread_messages").insert({
-          thread_id: threadId,
-          message_type: THREAD_MESSAGE_TYPE.LEGACY,
-          user_id: oldThread.userId,
-          user_name: "",
-          body: log,
-          is_anonymous: 0,
-          created_at: moment.utc().format("YYYY-MM-DD HH:mm:ss")
-        });
-      });
-
-      resolve(Promise.all(promises));
-    });
-
-    bot.connect();
-  });
-
-  await toReturn;
-
-  bot.disconnect();
-}
-
-async function migrateLogs() {
-  const logDir = config.logDir || `${__dirname}/../../logs`;
-  const logFiles = await readDir(logDir);
-
-  for (let i = 0; i < logFiles.length; i++) {
-    const logFile = logFiles[i];
-    if (! logFile.endsWith(".txt")) continue;
-
-    const [rawDate, userId, threadId] = logFile.slice(0, -4).split("__");
-    const date = `${rawDate.slice(0, 10)} ${rawDate.slice(11).replace("-", ":")}`;
-
-    const fullPath = path.join(logDir, logFile);
-    const contents = await readFile(fullPath, {encoding: "utf8"});
-
-    const newThread = {
-      id: threadId,
-      status: THREAD_STATUS.CLOSED,
-      user_id: userId,
-      user_name: "",
-      channel_id: null,
-      is_legacy: 1,
-      created_at: date
-    };
-
-    await knex.transaction(async trx => {
-      const existingThread = await trx("threads")
-        .where("id", newThread.id)
-        .first();
-
-      if (existingThread) return;
-
-      await trx("threads").insert(newThread);
-
-      await trx("thread_messages").insert({
-        thread_id: newThread.id,
-        message_type: THREAD_MESSAGE_TYPE.LEGACY,
-        user_id: userId,
-        user_name: "",
-        body: contents,
-        is_anonymous: 0,
-        created_at: date
-      });
-    });
-
-    // Progress indicator for servers with tons of logs
-    if ((i + 1) % 500 === 0) {
-      console.log(`  ${i + 1}...`);
-    }
-  }
-}
-
-async function migrateBlockedUsers() {
-  const now = moment.utc().format("YYYY-MM-DD HH:mm:ss");
-  const blockedUsers = await jsonDb.get("blocked", []);
-
-  for (const userId of blockedUsers) {
-    const existingBlockedUser = await knex("blocked_users")
-      .where("user_id", userId)
-      .first();
-
-    if (existingBlockedUser) return;
-
-    await knex("blocked_users").insert({
-      user_id: userId,
-      user_name: "",
-      blocked_by: null,
-      blocked_at: now
-    });
-  }
-}
-
-async function migrateSnippets() {
-  const now = moment.utc().format("YYYY-MM-DD HH:mm:ss");
-  const snippets = await jsonDb.get("snippets", {});
-
-  const promises = Object.entries(snippets).map(async ([trigger, data]) => {
-    const existingSnippet = await knex("snippets")
-      .where("trigger", trigger)
-      .first();
-
-    if (existingSnippet) return;
-
-    return knex("snippets").insert({
-      trigger,
-      body: data.text,
-      is_anonymous: data.isAnonymous ? 1 : 0,
-      created_by: null,
-      created_at: now
-    });
-  });
-
-  return Promise.all(promises);
-}
-
-module.exports = {
-  migrate,
-  shouldMigrate,
-};