se que a algunos les va a gustar esto
acabo de hacer un robot que me ayuda a realizar tareas básicas como por ejemplo actualizar las noticias de mi foro
Lo entrete es que siempre me responde de diferentes maneras segun su estado de animo que aun no termino de perfeccionar xD
¿Como lo hago en la práctica?1. Primero que nada tengo un monton de paginas webs y resultados de google noticias en google reader.
2. Desde mi celular con android utilizo un lector de rss y le agregué mi cuenta de google reader (utilizo reader hd)
3. cada ves que leo las noticias y me gusta una la marco simplemente con una estrella y se va a favoritos en mi cuenta de google reader.
4. andres.js se loguea en google reader y sincroniza los items favoritos y los postea de forma automatica en el foro logueandose previamente con un usuario "Andres".
5. despues de marcar con estrella los temas que me gustan abro la consola y ejecuto control.js y le digo que necesito sincronizar las noticias del foro.
6. control.js llama a andres.js para que los sincronize y ya está
Paso1 (Agrego mis lecturas rss favoritas a google reader, se sincronizan solas):
Paso 2 (leo google reader desde mi celular en el metro, en la calle, en mi casa y marco la noticia interesante):
Paso 3 (cuando me siento frente a la pc le digo a control que sincronize el foro):
Paso 4 (posteado!
):
El robot es capaz de sincronizar todas las noticias al mismo tiempo, si tienes 50 marcadas posteará los 50 una por una.
Acá les dejo el código fuente de control por si alguien lo quiere utilizar, también les dejo el de andres que aun me falta perfeccionarlo mas, tambien quiero que tome temas desde mi correo directamente pero eso aun no lo he implementado.
Saludos y a disfrutar
control.js:
/* control ia por WHK */
var readline = require('readline');
var exec = require('child_process').exec;
/* Configuración inicial */
var nombreRobot = 'Control';
var nivelFelicidad = 2;
var ultimoComando = {
comando : false,
argumentos : {},
esperandoConfirmacion : false
};
///////////////////////////////////////////////////
String.prototype.repeat = function(num){
return new Array(num + 1).join(this);
}
function rand(min, max){
return Math.floor(Math.random() * (max - min + 1)) + min;
}
/* Expresiones */
var expresiones = {
felicidad_0 : new Array(':\'(', ':(', 'D\':', 'x__x'),
felicidad_1 : new Array(':(', ':-/', 'D:', ':-\\'),
felicidad_2 : new Array(':)', 'u.u', 'o.o', ':3', ':B'),
felicidad_3 : new Array(':D', 'xD', 'xDD'),
asombro : new Array(':O', ':-O', ':-o', ':-0', '0__0', '0___o', 'o__0', '0____0', '0_0'),
pensando : new Array('mmmmm... ', 'eehmmmm... ', 'eehhh... ', 'mmmmmmmmm... ', 'mmmm... ', 'ehmmm... ')
}
var disculpas = new Array('disculpa pero', 'sorry pero', 'omg, ', 'sorry');
/* Funciones */
var varRand = function(arr){
var max = (arr.length - 1);
if(max < 0)
max = 0;
var res = arr[rand(0, max)];
if(res == 'undefined')
res = arr[0];
return res;
}
var caritaFelicidad = function(){
if(typeof(expresiones['felicidad_' + nivelFelicidad]) == 'undefined')
return ':)';
else
return varRand(expresiones['felicidad_' + nivelFelicidad]);
}
var saludo = function(){
var decir = '';
var saludo_a = new Array('hola', 'buenas');
var saludo_b = new Array('k tal', 'como estas', 'como has estado');
var saludo_c = new Array(
'¿en que puedo ayudar?', '¿en que puedo ayudarte?',
'¿que puedo hacer por ti?', 'estoy atento a tus ordenes',
'estoy preparado para ayudarte', 'cuentame, que necesitas?',
'dime, que necesitas', 'dime, que hago?',
'cuentame', 'cuentame, que hago?',
'¿que necesitas?', '¿que debo hacer?'
);
decir += varRand(saludo_a);
if(rand(0, 100) < 51) // 50% de probabilidades para que salude con una doble entrada
decir += ' ' + varRand(saludo_b);
decir += ', ' + varRand(saludo_c);
return decir;
}
var despedida = function(){
var despedida_a = new Array('nos vemos', 'adios', 'bye', 'chao', 'chau');
var despedida_b = new Array('un abrazo', 'fue un gusto', ':)')
return varRand(despedida_a) + ', ' + varRand(despedida_b);
}
var enQueMasPuedoAyudar = function(){
var enQueMasPuedoAyudar_a = new Array(
'¿en que mas te puedo ayudar?', '¿que mas debo hacer?',
'¿en que mas puedo ayudar?', '¿en que mas puedo ayudarte?',
'¿que mas puedo hacer por ti?', 'estoy atento a tus ordenes',
'que mas necesitas?', 'que mas hago?'
);
return varRand(enQueMasPuedoAyudar_a);
}
var yaLoHize = function(){
var yaLoHize_a = new Array('listo!', 'listooo ' + caritaFelicidad(), 'listoooo! ' + caritaFelicidad() + ' ' + caritaFelicidad(), 'yap,');
var yaLoHize_b = new Array('ya terminé', 'terminé', 'ya lo hize.. wiii ' + caritaFelicidad(), 'termineee wii ' + caritaFelicidad(), 'terminé por fin ' + risa());
return varRand(yaLoHize_a) + ' ' + varRand(yaLoHize_b);
}
var noEntender = function(){
var noEntender_b = new Array(
'no entendí nada de lo que me escribiste ' + caritaFelicidad() + ' ' + risa(),
'no entendí nada de lo que me escribiste ' + risa() + ' ' + caritaFelicidad(),
'no entendí lo que dijiste :-/',
'no entendí ' + risa() + ' :p',
'no entendí xd',
'no comprendo lo que me quieres decir',
'no tengo ni idea que me quieres decir',
'no tengo ni idea de lo que me escribes'
);
var noEntender_c = new Array(
'me lo puedes explicar con otras palabras?',
'me lo explicas nuevamente?',
'escribemelo otraves pero explicate mejor',
'explicamelo con otras palabras',
'explicate bien',
'explicamelo bien nuevamente'
);
var noEntender_d = new Array(
'porfa',
'por favor'
);
return varRand(disculpas) + ' ' + varRand(noEntender_b) + ', ' + varRand(noEntender_c) + ' ' + varRand(noEntender_d);
}
var risa = function(){
var risaTexto = '';
var selectorPrimero = new Array('j', 'h');
/* Prioriza la letra j antes que la h */
if(rand(0, 100) < 15)
selectorPrimero = selectorPrimero[1];
else
selectorPrimero = selectorPrimero[0];
var selectorSegundo = 'a';
var cantidadPlaneada = parseInt((parseInt(nivelFelicidad) * 2.5));
/* Si todos escribieramos "jajaja" siempre con exactamente 6 letras seriamos robots. */
cantidadPlaneada = rand(cantidadPlaneada - 1, cantidadPlaneada + 2);
for(var i = 0; i <= cantidadPlaneada; i++){
if(i == 0){ // La primera letra de una risa casi siempre comienza con ja o ha o ka, etc
if(rand(0, 100) < 7) // 6% de probabilidades de que no comienze con una letra primaria
risaTexto += selectorSegundo;
else
risaTexto += selectorPrimero;
}else{
if(i%2 == 0){ // Letras primarias y secundarias intercaladas
if(rand(0, 100) < 5) // 9% de probabilidades de que repita la misma letra
risaTexto += selectorSegundo;
else // Letra que normalmente debiera ser escrita
risaTexto += selectorPrimero;
}else{
if(rand(0, 100) < 5) // 9% de probabilidades de que repita la misma letra
risaTexto += selectorPrimero;
else // Letra que normalmente debiera ser escrita
risaTexto += selectorSegundo;
}
}
}
/* La ultima letra preferentemente debe ser una letra secundaria */
if(rand(0, 100) < 7) // 6% de probabilidades de que no comienze con una letra primaria
risaTexto += selectorPrimero;
else
risaTexto += selectorSegundo;
return risaTexto;
}
/* Funciones */
var escribir = function(texto, quien){
texto = '' + texto;
/* Retorna con la primera letra en mayuscula */
if(quien == 'control')
console.log(nombreRobot + ' : ' + texto.substr(0,1).toUpperCase() + texto.substr(1, texto.length) + '.');
else if(quien == 'usuario')
console.log('Yo' + ' '.repeat(nombreRobot.length - 2) + ' : ' + texto.substr(0,1).toUpperCase() + texto.substr(1, texto.length) + '.');
else
console.log(' ' + texto);
}
var bashExec = function(cmd, callback){
var codeReturn = 0;
var ex = exec(cmd, function (error, stdout, stderr){});
ex.stdout.on('data', function (data){
escribir(data.trim(), 'shell');
});
ex.on('exit', function (code){
codeReturn = code;
if(typeof(callback) == 'function')
callback(code);
});
}
var interactuar = function(saludar){
/* Saluda si corresponde */
if(saludar) // Ha comensado la sesión
escribir(saludo(), 'control');
var rl = readline.createInterface({
input: process.stdin,
output: process.stdout
});
rl.question('Yo' + ' '.repeat(nombreRobot.length - 2) + ' : ', function(escuchado){
rl.close();
if(ultimoComando.esperandoConfirmacion){
if(/.*?(^si|asi es|^claro$)/.test(escuchado)){
/* Ejecuta el comando */
if(ultimoComando.comando == 'bash'){
escribir('ejecutando: ' + ultimoComando.argumentos.cmd + ' ...', 'control');
bashExec(ultimoComando.argumentos.cmd, function(code){
escribir(yaLoHize(), 'control');
escribir(enQueMasPuedoAyudar(), 'control');
ultimoComando.esperandoConfirmacion = false;
interactuar(false);
});
}else{
escribir(disculpas[rand(0, disculpas.length - 1)] + ' no se cual es el comando ' + ultimoComando.comando + ' :-s', 'control');
escribir(enQueMasPuedoAyudar(), 'control');
ultimoComando.esperandoConfirmacion = false;
interactuar(false);
}
/* no era lo que se quería */
}else if(/.*?(^no|nop|^err|^lol)/.test(escuchado)){
ultimoComando = {
comando : false,
argumentos : {},
esperandoConfirmacion : false
};
var disculparse_a = new Array(
'he cancelado el comando',
'ya cancelé el comando'
);
var disculparse_b = new Array(
'te habia entendido mal',
'no te habia entendido bien',
'leí mal',
'casi la kgo xD'
);
escribir(disculpas[rand(0, disculpas.length - 1)] + ' ' + disculpas_a[rand(0, disculpas_a.length - 1)] + ', ' + disculpas_b[rand(0, disculpas_b.length - 1)], 'control');
interactuar(false);
}else{
escribir(noEntender(), 'control');
interactuar(false);
}
}else{
/* ¿Que debo hacer y/o decir? */
if(/(bye|chao|adios|a dios|nos vemos|hasta luego|hasta la vista|hasta la prox|buenas noches|me voy|salir|cierrate|arrancate|largate|pierdete|pudrete)/.test(escuchado)){
escribir(despedida(), 'control');
}else if(/^(nada|nada mas|en nada|ninguna)/.test(escuchado)){
escribir(despedida(), 'control');
}else if(/(andate a la)/.test(escuchado)){
escribir('allá mismo me voy, ' + despedida(), 'control');
}else if(/(andate a(.*)tirate|anda a(.*)tirate)/.test(escuchado)){
escribir('allá mismo voy y me tiro ' + risa() + ', ' + despedida(), 'control');
}else if(/.*?(actualiza|sincroniza|actualizar|actualices|actualises|actualizes|sincronices|sincronises|sincronizar).*?(rss|noticias|noticia).*?(del|para|sobre|en).*?(foro)/.test(escuchado)){
escribir(varRand(Array(
'entiendo que necesitas que sincronize el rss de google reader con el foro verdad?',
'necesitas que sincronize el rss de google reader con el foro?',
'¿actualizo las noticias del foro?',
'¿debo actualizar las noticias del foro?',
'si entendí bién, quieres que actualize las noticias del foro?'
)), 'control');
ultimoComando = {
comando : 'bash',
argumentos : { cmd: 'node ./andres.js' },
esperandoConfirmacion : true
};
interactuar(false);
}else{
escribir(noEntender(), 'control');
interactuar(false);
}
}
delete(escuchado);
});
}
interactuar(true);
andres.js:
/* Andres V 1.1 - Revisa y postea temas en SMF 2.0.x de forma automatizada. por WHK */
/* Para no repetir los temas lo que hace es crear un directorio con subcarpetas,
* una carpeta por cada md5(titulo) de los post, luego se verifica que el directorio exista o si no
* se posteará y lo creará. Evita la utilización de archivos para ahorrar espacio en disco. */
var http = require("http");
var https = require("https");
var crypto = require('crypto');
var fs = require('fs');
/* Función rápida de MD5 */
md5 = function(str){
var md = crypto.createHash('md5');
md.update(str);
return md.digest('hex');
}
/* Configuración */
var sesion = {
SID : '',
LSID : '',
Auth : '',
token : ''
};
var bufferIO = '';
var obNoticias = {};
var nNoticias = 0;
var bufferGoogle = '';
var dirNombreDB = 'dbAndres';
/* Cuenta gmail para acceder a google reader */
var loginData = {
mail : 'yan.uniko.102@gmail.com',
pass : '*****'
};
var foro = {
host : 'whk.drawcoders.com',
port : 80,
pathPhp : '/index.php',
idForo : 61, /* Foro de noticias, id 61 */
user : 'Andres',
pass : '*****',
cookies : '' /* No modificar */
}
console.log(' - Conectando al servidor de Google Reader ...');
https.get('https://www.google.com/accounts/ClientLogin?service=reader&source=reader&Email=' + escape(loginData.mail) + '&Passwd=' + escape(loginData.pass),
function(res){
/* esperando un HTTP 200 */
if(res.statusCode == 200){
console.log(' - Obteniendo llaves de acceso ...');
/* Procesa el contenido */
res.on('data', function(chunk){
bufferIO += chunk.toString() + '';
}).on('end', function(){
bufferIO = bufferIO.trim(); /* Limpia el buffer de cualquier basura extra */
/* Autentificado? */
if(bufferIO == 'Error=BadAuthentication'){
console.log(' - Clave de acceso erronea.');
return false;
}
var partes = bufferIO.split('\n');
if(!partes.length){
console.log(' - Imposible ingresar, google no ha respondido correctamente.');
return false;
}
bufferIO = ''; /* Limpia la memoria */
var linea;
for(_id in partes){
linea = partes[_id].trim().split('=');
if((linea[0] == 'SID') || (linea[0] == 'LSID') || (linea[0] == 'Auth')){
sesion[linea[0]] = linea[1];
}
}
console.log(' - Obteniendo token de seguridad ...');
http.get({
host : 'www.google.com',
port : 80,
path : '/reader/api/0/token',
headers: {
'Authorization': 'GoogleLogin auth=' + sesion['Auth']
}
}, function(res2){
/* esperando un HTTP 200 */
if(res2.statusCode == 200){
/* Procesa el contenido */
res2.on('data', function(chunk2){
bufferIO += chunk2.toString() + '';
}).on('end', function(){
sesion['token'] = bufferIO;
console.log(' - Acceso concedido!');
bufferIO = ''; /* Limpia la memoria */
console.log(' - Obteniendo temas ...');
/* ############################ Obtiene las noticias ############################ */
http.get({
host : 'www.google.com',
port : 80,
path : '/reader/api/0/stream/contents/user/-/state/com.google/starred?ck=' + Math.floor(new Date().getTime() / 1000),
headers: {
'Authorization': 'GoogleLogin auth=' + sesion['Auth']
}
}, function(res3){
/* esperando un HTTP 200 */
if(res3.statusCode == 200){
bufferIO = '';
/* Procesa el contenido */
res3.on('data', function(chunk3){
bufferIO += chunk3.toString() + '';
}).on('end', function(){
bufferGoogle = bufferIO; /* Guarda el buffer para futuras auditorias */
try{
eval('obNoticias = ' + bufferIO + ';'); /* Procesa el Json entregado por Google */
}catch(e){
console.log(' - Error en el servidor de Google Reader : Json corrupto.');
return false;
}
var tmpNoticiasItems = {};
for(_id in obNoticias.items){
/* Verifica si ya ha sido posteado para sincronizar y no repostear */
if(!fs.existsSync('./' + dirNombreDB + '/' + md5(obNoticias.items[_id].title))){
/* Agrega al objeto */
tmpNoticiasItems[nNoticias] = obNoticias.items[_id];
/* Cuenta la cantidad de items */
nNoticias++;
}
}
/* Traspasa los items encontrados */
obNoticias.items = tmpNoticiasItems;
delete tmpNoticiasItems;
if(nNoticias > 0){
console.log(' - ' + nNoticias + ' Items obtenidos sin sincronizar.');
console.log(' - Autentificandose en el foro ...');
/* Obtiene las cookies necesarias para postear en el foro con SMF 2.0 */
var post_data = 'user=' + escape(foro.user) + '&passwrd=' + escape(foro.pass) + '&cookielength=1000';
var post = http.get({
host : foro.host,
port : foro.port,
path : foro.pathPhp + '?action=login2',
method : 'POST',
headers: {
'Content-Type' : 'application/x-www-form-urlencoded',
'Content-Length' : post_data.length
}
}, function(res4){
/* esperando un HTTP 302 */
if(res4.statusCode == 302){
/* Procesa el contenido */
res2.on('data', function(chunk2){
// Página de error con el formulario de reingreso
}).on('end', function(){
// Página de error con el formulario de reingreso
});
var cookiesMatris = {};
var partesCookie = {};
for(_key in res4.headers['set-cookie']){
partesCookie = res4.headers['set-cookie'][_key].split(';');
partesCookie = partesCookie[0].split('=');
if(typeof(cookiesMatris[partesCookie[0]]) == 'undefined')
cookiesMatris[partesCookie[0]] = ''; // var? bug nodejs
cookiesMatris[partesCookie[0]] = partesCookie[1].trim();
}
/* Parsea las cookies a String */
for(_key in cookiesMatris)
foro.cookies += _key + '=' + cookiesMatris[_key] + '; ';
foro.cookies = foro.cookies.trim();
if(foro.cookies.length){
console.log(' - Verificando la cuenta ...');
/* Carga la url de redirección que previene el ingreso de robots (menos este) */
http.get(res4.headers.location, function(res5){
/* Se ha finalizado la conexión de verificación, no es necesario procesar los datos */
/* Postea en el foro los items */
var idPost = 0;
var postea = function(data, hash){
/* Vuelve a verificar por segunda ves que la noticia no fue posteada para asegurarnos */
if(fs.existsSync('./' + dirNombreDB + '/' + escape(hash))){
console.log(' - El post ya existe.');
idPost++;
obtieneToken();
return false;
}
var post2 = http.get({
host : foro.host,
port : foro.port,
path : foro.pathPhp + '?action=post2;start=0;board=' + parseInt(foro.idForo),
method : 'POST',
headers: {
'Cookie' : foro.cookies,
'Content-Type' : 'application/x-www-form-urlencoded',
'Content-Length' : data.length
}
}, function(res6){
/* esperando un HTTP 302 */
if(res6.statusCode == 302){
/* Si no existe el directorio de la base de datos lo creará */
if(!fs.existsSync('./' + dirNombreDB))
fs.mkdir('./' + dirNombreDB);
fs.mkdir('./' + dirNombreDB + '/' + escape(hash));
/* Se ha finalizado el posteo, no es necesario procesar los datos */
idPost++;
obtieneToken();
}else if(res6.statusCode == 200){
/* Acceso denegado? */
bufferIO = '';
/* Procesa el contenido */
res6.on('data', function(chunk6){
bufferIO += chunk6.toString() + '';
}).on('end', function(){
// console.log(bufferIO);
console.log(' - Error al postear en el servidor del foro : ' + res6.statusCode + '. Baneado?');
return false;
});
}else{
console.log(' - Error al postear en el servidor del foro : ' + res6.statusCode);
return false;
}
});
try{ post2.write(data); }catch(e){}
}
var obtieneToken = function(){
if(typeof(obNoticias.items[idPost]) == 'undefined'){
console.log(' - Finalizado!');
return true;
}else{
console.log(' - Posteando [' + (idPost + 1) + '/' + nNoticias + ']: ' + obNoticias.items[idPost].title.substr(0, 48) + ' ...');
if(typeof(obNoticias.items[idPost].summary) == 'undefined')
var content = obNoticias.items[idPost].content.content;
else
var content = obNoticias.items[idPost].summary.content + ' ... Seguir link de la fuente para continuar leyendo.';
/* Agrega la referencia */
content += '<br /><br />Fuente: [url]' + obNoticias.items[idPost].alternate[0].href + '[/url]';
http.get({
host : foro.host,
port : foro.port,
path : foro.pathPhp + '?action=post;board=' + parseInt(foro.idForo) + '.0',
headers: { 'Cookie' : foro.cookies }
}, function(res5){
/* esperando un HTTP 200 */
if(res5.statusCode == 200){
bufferIO = '';
/* Procesa el contenido */
res5.on('data', function(chunk5){
bufferIO += chunk5.toString() + '';
}).on('end', function(){
/* Obtiene el hash de posteo que no sirve de nada */
var seqnum = bufferIO.split('input type="hidden" name="seqnum" value="');
seqnum = seqnum[1].split('"');
seqnum = seqnum[0].trim();
var svEdit = bufferIO.split("sSessionVar: '");
svEdit = svEdit[1].split("'");
svEdit = svEdit[0];
var siEdit = bufferIO.split("sSessionId: '");
siEdit = siEdit[1].split("'");
siEdit = siEdit[0];
postea(
'topic=0&icon=xx&sel_face=&sel_size=&sel_color=&message_mode=1¬ify=0&lock=0&goback=1&sticky=0&move=0&additional_options=0seqnum=' + escape(seqnum) + '&' + escape(svEdit) + '=' + escape(siEdit) + '&subject=' + escape(obNoticias.items[idPost].title) + '&message=' + escape(content),
md5(obNoticias.items[idPost].title)
);
});
}else{
console.log(' - Error en el servidor del foro : ' + res5.statusCode);
return false;
}
}).on('error', function(e){
console.log(' - Imposible conectar al servidor del foro.');
return false;
});
}
}
/* Inicia el loop de posteos */
console.log(' - Sincronizando temas ...');
obtieneToken();
}).on('error', function(e){
console.log(' - Imposible conectar al servidor del foro.');
return false;
});
}else{ /* 302 sin cookies? */
console.log(' - La clave de acceso al foro es incorrecta.');
return false;
}
}else{
console.log(' - La clave de acceso al foro es incorrecta.');
return false;
}
}).on('error', function(e){
console.log(' - Imposible conectar al servidor del foro.');
return false;
});
try{ post.write(post_data); }catch(e){}
}else{
console.log(' - No hay items para sincronizar :)');
return false;
}
});
}else{
console.log(' - Error en el servidor de Google Reader : ' + res3.statusCode);
return false;
}
}).on('error', function(e){
console.log(' - Imposible conectar al servidor de Google Reader.');
return false;
});
});
}else{
console.log(' - Error en el servidor de Google Reader : ' + res2.statusCode);
return false;
}
}).on('error', function(e){
console.log(' - Imposible conectar al servidor de Google Reader.');
return false;
});
});
}else{
console.log(' - Error en el servidor de cuentas de Google : ' + res.statusCode);
return false;
}
}
).on('error', function(e){
console.log(' - Imposible conectar al servidor de cuentas de Google.');
return false;
});
return true;
Si van a retocar el código por favor les pido que mantengan en la parte superior del código el nombre del autor, o sea yo.
Mostrar Temas
asi que hacemos lo siguiente....