Commit f091595326d478c3d14da432418b79035650ccd2
1 parent
35eec57498
Exists in
master
bugfix
Showing 1 changed file with 14 additions and 7 deletions Inline Diff
adaptor-ym.js
| 1 | var YM = require('yahoomessenger'); | 1 | var YM = require('yahoomessenger'); |
| 2 | 2 | ||
| 3 | var username; | 3 | var username; |
| 4 | var password; | 4 | var password; |
| 5 | 5 | ||
| 6 | var callbacks; | 6 | var callbacks; |
| 7 | 7 | ||
| 8 | function onReady() { | 8 | function onReady() { |
| 9 | logger.info('Going to login to YM as ' + username); | 9 | var _username = username; |
| 10 | setTimeout( | 10 | var _password = password; |
| 11 | YM.login, | 11 | |
| 12 | 10000, | 12 | if (!_username || !-password) { |
| 13 | username, password | 13 | logger.warn('Undefined YM username and password') |
| 14 | ) | 14 | process.exit(5); |
| 15 | } | ||
| 15 | 16 | ||
| 17 | logger.info('Going to login to YM as ' + username); | ||
| 18 | YM.login(username, password); | ||
| 16 | } | 19 | } |
| 17 | 20 | ||
| 18 | function onLoginSuccessful(data) { | 21 | function onLoginSuccessful(data) { |
| 19 | logger.info('YM login successful', {data: data}); | 22 | logger.info('YM login successful', {data: data}); |
| 20 | if (callbacks.onLoginSuccessful) { | 23 | if (callbacks.onLoginSuccessful) { |
| 21 | callbacks.onLoginSuccessful(); | 24 | callbacks.onLoginSuccessful(); |
| 22 | } | 25 | } |
| 23 | } | 26 | } |
| 24 | 27 | ||
| 25 | function onLoginError(data) { | 28 | function onLoginError(data) { |
| 26 | logger.warn('YM login error', {data: data}); | 29 | logger.warn('YM login error', {data: data}); |
| 27 | } | 30 | } |
| 28 | 31 | ||
| 29 | function onFriendsList(data) { | 32 | function onFriendsList(data) { |
| 30 | logger.verbose('Got list of friendlist', {data: data}); | 33 | logger.verbose('Got list of friendlist', {data: data}); |
| 31 | } | 34 | } |
| 32 | 35 | ||
| 33 | function onPM(data) { | 36 | function onPM(data) { |
| 34 | logger.verbose('Got a message', {data: data}) | 37 | logger.verbose('Got a message', {data: data}) |
| 35 | if (callbacks.onPM) { | 38 | if (callbacks.onPM) { |
| 36 | callbacks.onPM(data.sender, data.message); | 39 | callbacks.onPM(data.sender, data.message); |
| 37 | } | 40 | } |
| 38 | } | 41 | } |
| 39 | 42 | ||
| 40 | function onPing(data) { | 43 | function onPing(data) { |
| 41 | logger.verbose('Got ping', {data: data}); | 44 | logger.verbose('Got ping', {data: data}); |
| 42 | } | 45 | } |
| 43 | 46 | ||
| 44 | function init(_username, _password, _logger, _callbacks) { | 47 | function init(_username, _password, _logger, _callbacks) { |
| 45 | username = _username; | 48 | username = _username; |
| 46 | password = _password; | 49 | password = _password; |
| 47 | logger = _logger; | 50 | logger = _logger; |
| 48 | callbacks = _callbacks; | 51 | callbacks = _callbacks; |
| 49 | 52 | ||
| 50 | YM.on('ready', onReady); | 53 | YM.on('ready', onReady); |
| 51 | YM.on('loginSuccessful', onLoginSuccessful); | 54 | YM.on('loginSuccessful', onLoginSuccessful); |
| 52 | YM.on('loginError', onLoginError); | 55 | YM.on('loginError', onLoginError); |
| 53 | YM.on('friendsList', onFriendsList); | 56 | YM.on('friendsList', onFriendsList); |
| 54 | YM.on('pm', onPM); | 57 | YM.on('pm', onPM); |
| 55 | YM.on('offlinePM', onPM); | 58 | YM.on('offlinePM', onPM); |
| 56 | 59 | ||
| 57 | YM.newInstance(); | 60 | setTimeout( |
| 61 | YM.newInstance, | ||
| 62 | 3000 | ||
| 63 | ) | ||
| 64 | //YM.newInstance(); | ||
| 58 | } | 65 | } |
| 59 | 66 | ||
| 60 | function sendMessage(destination, msg) { | 67 | function sendMessage(destination, msg) { |
| 61 | logger.verbose('Sending message', {from: username, destination: destination, msg: msg}); | 68 | logger.verbose('Sending message', {from: username, destination: destination, msg: msg}); |
| 62 | YM.sendPM(destination, msg); | 69 | YM.sendPM(destination, msg); |
| 63 | } | 70 | } |
| 64 | 71 | ||
| 65 | exports.init = init; | 72 | exports.init = init; |
| 66 | exports.sendMessage = sendMessage; | 73 | exports.sendMessage = sendMessage; |
| 67 | 74 |