diff --git a/breadbot.js b/breadbot.js index d48349b..6d1edea 100644 --- a/breadbot.js +++ b/breadbot.js @@ -96,11 +96,29 @@ client.on(Events.MessageCreate, async message => { var user_registered = sqlutil.isUserRegistered(message.author.id) if(!(await channel_registered).valueOf()) { - await sqlutil.registerChannel(message.channel.id, message.channel.guildId, message.channel.name) + console.log(`Registering Channel ${message.channel.name} ${message.channel.guild.name}`) + + var channel_registered_result = await sqlutil.registerChannel(message.channel.id, message.channel.guildId, message.channel.name) + + if(channel_registered_result.valueOf()) { + console.log(`Channel Registered ${message.channel.name} ${message.channel.guild.name}`) + } else { + console.log(`Failed to register channel ${message.channel.name} ${message.channel.guild.name}`) + return + } } if(!(await user_registered).valueOf()) { - await sqlutil.registerUser(messsage.author.id, message.author.username, message.author.displayName) + console.log(`Registering user ${message.author.username}`) + + var user_registered_result = await sqlutil.registerUser(messsage.author.id, message.author.username, message.author.displayName) + + if(user_registered_result.valueOf()) { + console.log(`User Registered ${message.author.username}`) + } else { + console.log(`failed to register user ${message.author.username}`) + return + } } sqlutil.registerMessage(message.id, message.channelId, message.author.id, message.content, message.createdAt).then(message_add => { diff --git a/utilities/sqlutil.js b/utilities/sqlutil.js index e070e9d..1ecd7b0 100644 --- a/utilities/sqlutil.js +++ b/utilities/sqlutil.js @@ -145,7 +145,7 @@ async function registerUser(user_snowflake, user_name, user_displayname) { } async function registerMessage(message_snowflake, channel_snowflake, user_snowflake, message_content, message_timestamp) { - var sql = `INSERT INTO users VALUES (?, ?, ?, ?, ?, 0, 0);` + var sql = `INSERT INTO messages VALUES (?, ?, ?, ?, ?, 0, 0);` var result = null await connection_pool.query(sql, [message_snowflake, channel_snowflake, user_snowflake, message_content, message_timestamp], (error, results, fields) => {