diff --git a/index.js b/index.js index 7735e21..fb12b60 100644 --- a/index.js +++ b/index.js @@ -95,9 +95,17 @@ function onYmPM(data) { lastDataOnPM = data; + direction = 'IN'; + + partner = data.sender; + if (partner = data.sender) { + partner = data.target_user; + direction = 'OUT'; + } + var message = striptags(data.message) - logger.info('New message received from ' + data.sender + ': ' + message); + logger.info('New ' + direction + ' message from ' + data.sender + ' to ' + data.target_user + ': ' + message); if (isAdmin(data.sender)) { logger.info('Sender (' + data.sender + ') is an admin'); @@ -110,8 +118,8 @@ function onYmPM(data) { insertMessages( db_connection, data.user_id, - 'IN', - data.sender, + direction, + partner, message, sentdate );