Fixed small error and NullPointerException

Commit for sync purposes
This commit is contained in:
Anthony committed 2018-02-15 06:42:04 -05:00
1 parent e45ecab762
commit b577f10c2f
5 files changed
+31 -20

No files matched your search

@@ -63,14 +63,14 @@ public class BlacklistCommand extends AbstractCommand {
event.getTextChannel().sendMessage("Retreiving list, please wait...").queue(t -> { event.getTextChannel().sendMessage("Retreiving list, please wait...").queue(t -> {
String out = ""; String out = "";
ArrayList<MBlacklist> blacklist = null; ArrayList<MBlacklist> blacklist = new ArrayList<>();
try { try {
blacklist = ((DBBlacklist) DBController.get("blacklist")).getBlacklistFromServer(event.getGuild().getId()); blacklist = ((DBBlacklist) DBController.get("blacklist")).getBlacklistFromServer(event.getGuild().getId());
for (MBlacklist bl : blacklist) { for (MBlacklist bl : blacklist) {
out += bl.getWord() + " -> " + (bl.isEnabled() ? "enabled" : "disabled") + "\n"; out += bl.getWord() + " -> " + (bl.isEnabled() ? "enabled" : "disabled") + "\n";
} }
} catch (RuntimeException e) { } catch (RuntimeException e) {
e.printStackTrace();
} }
t.editMessage("List of blacklisted words for this server [" + event.getGuild().getName() + "] :\n" + (blacklist.isEmpty() ? "No word found" : out)).queue(); t.editMessage("List of blacklisted words for this server [" + event.getGuild().getName() + "] :\n" + (blacklist.isEmpty() ? "No word found" : out)).queue();
@@ -87,7 +87,7 @@ public class BlacklistCommand extends AbstractCommand {
event.getTextChannel().sendMessage("Error adding \"" + word + "\" to the blacklist. It's already blacklisted!").queue(); event.getTextChannel().sendMessage("Error adding \"" + word + "\" to the blacklist. It's already blacklisted!").queue();
LogHandler.log(e); LogHandler.log(e);
} }
break; break;
case "remove": case "remove":
@@ -5,7 +5,7 @@ import java.sql.SQLException;
public abstract class AbstractController { public abstract class AbstractController {
protected MysqlDatabase database; protected MysqlDatabase database;
/** /**
* The controller name to be used in {@link DBController} get(String controller) method * The controller name to be used in {@link DBController} get(String controller) method
* *
@@ -13,7 +13,7 @@ public abstract class AbstractController {
*/ */
public abstract String getControllerName(); public abstract String getControllerName();
public void reconnect() throws SQLException { public void reconnect() {
database.reconnect(); database.reconnect();
} }
@@ -152,6 +152,7 @@ public class MysqlDatabase {
* @throws SQLException * @throws SQLException
*/ */
public void close() throws SQLException { public void close() throws SQLException {
System.out.println("Closing database...");
connection.close(); connection.close();
} }
@@ -160,9 +161,17 @@ public class MysqlDatabase {
* *
* @throws SQLException * @throws SQLException
*/ */
public void reconnect() throws SQLException { public void reconnect() {
connection = new MysqlConnector(dbName, "root", "localhost", "").connect().getConnection();
} try {
System.out.println("Reconnecting to database...");
connection = new MysqlConnector(dbName, "root", "localhost", "").connect().getConnection();
} catch (SQLException e) {
System.err.println("Error connecting to database. Shutting down..");
MusicBot.disconnect();
System.exit(0);
}
}
/** /**
* Check if the database is closed. * Check if the database is closed.
@@ -23,16 +23,14 @@ public class DBMessage extends AbstractController {
return database; return database;
} }
public int log(String servername, String channelname, String username, String datesent, String messageId, String message) { public void log(String servername, String channelname, String username, String datesent, String messageId, String message) {
try { try {
return database.insert("INSERT INTO log_message VALUES(?,?,?,?,?,?,?)", servername, channelname, username, datesent, messageId, message, null); database.insert("INSERT INTO log_message VALUES(?,?,?,?,?,?,?)", servername, channelname, username, datesent, messageId, message, null);
} catch (SQLException e) { } catch (SQLException e) {
LogHandler.log(e); LogHandler.log(e);
} }
return -1;
} }
public int logEdit(String messageId, String newMessage) { public int logEdit(String messageId, String newMessage) {
@@ -45,11 +45,14 @@ public class NewCommandListener extends ListenerAdapter {
if (MessageRateLimit.check(event)) return; if (MessageRateLimit.check(event)) return;
if (event.isFromType(ChannelType.TEXT)) if (event.isFromType(ChannelType.TEXT)) {
((DBMessage) DBController.get("message")).log(event.getGuild().getName(), event.getTextChannel().getName(), ((DBMessage) DBController.get("message")).log(event.getGuild().getName(), event.getTextChannel().getName(),
event.getMember().getUser().getName(), event.getMember().getUser().getName(),
event.getMessage().getCreationTime().format(DateTimeFormatter.ofPattern(Settings.DATETIMEFORMAT)), event.getMessage().getId(), event.getMessage().getCreationTime().format(DateTimeFormatter.ofPattern(Settings.DATETIMEFORMAT)), event.getMessage().getId(),
event.getMessage().getContentDisplay().trim()); event.getMessage().getContentDisplay().trim());
}
Message message = event.getMessage(); Message message = event.getMessage();
String msg = message.getContentDisplay().trim(); String msg = message.getContentDisplay().trim();
@@ -81,6 +84,8 @@ public class NewCommandListener extends ListenerAdapter {
} }
} else { } else {
String finalMsg = msg;
ArrayList<MBlacklist> blacklist = new ArrayList<>(); ArrayList<MBlacklist> blacklist = new ArrayList<>();
try { try {
@@ -91,7 +96,7 @@ public class NewCommandListener extends ListenerAdapter {
boolean found = false; boolean found = false;
for (int i = 0; i < blacklist.size(); i++) { for (int i = 0; i < blacklist.size(); i++) {
if (msg.toLowerCase().contains(blacklist.get(i).getWord())) if (finalMsg.toLowerCase().contains(blacklist.get(i).getWord()))
found = true; found = true;
} }
@@ -99,7 +104,6 @@ public class NewCommandListener extends ListenerAdapter {
event.getMessage().delete().queue(); event.getMessage().delete().queue();
event.getTextChannel().sendMessage("Not in my christian server").queue(); event.getTextChannel().sendMessage("Not in my christian server").queue();
} }
} }
} }
} }