DHT搜索

    本文地址:http://tongxinmao.com/Article/Detail/id/196

    'use strict';


    var fs = require('fs');

    var path = require('path');


    var bencode = require('bencode');

    var P2PSpider = require('./lib');

    var db = require('./lib/db'); 


    var p2p = P2PSpider({

        nodesMaxSize: 400,

        maxConnections: 800,

        timeout: 10000

    });


    p2p.ignore(function (infohash, rinfo, callback) {

        var torrentFilePathSaveTo = path.join(__dirname, "torrents", infohash + ".torrent");

        fs.exists(torrentFilePathSaveTo, function(exists) {

            callback(exists); //if is not exists, download the metadata.

        });

    });


    p2p.on('metadata', function (metadata) {

        //

        //

        var record={};

        if(metadata.info.hasOwnProperty("name.utf-8"))

       {

          console.log(metadata);

             record.name=metadata.info['name.utf-8'];


      }else

      {

         record.name=metadata.info.name

      }


     if(metadata.info.hasOwnProperty('files'))

    {

          record.filenum=metadata.info.files.length;

    }else

    {

    record.filenum=1;

    }


           record.infohash=metadata.infohash;

    record.address=metadata.address;

            

           if(metadata.info.length)//.hasOwnProperty("key") // true

    {

             record.length=metadata.info.length;

    }

    else

    {

                    record.length=metadata.info['piece length']*(metadata.info.pieces.length/20);

    }


        var  userAddSql = 'INSERT INTO bt2(name,keywords,filenum,length,infohash,address) VALUES(?,?,?,?,?,?)';

    var  userAddSql_Params = [record.name, '', record.filenum,record.length,record.infohash,record.address];


    db.query(userAddSql,userAddSql_Params,function (err, rows, fields) {

            if(err){

             console.log('[INSERT ERROR] - ',err.message);

             return;

            }       

           console.log('-------INSERT----------');

           

    });


        var torrentFilePathSaveTo = path.join(__dirname, "torrents", metadata.infohash + ".torrent");

        fs.writeFile(torrentFilePathSaveTo, bencode.encode({'info': metadata.info}), function(err) {

            if (err) {

                return console.error(err);

            }

            console.log(metadata.info.name + ".torrent has saved.\n");

        });

    });


    p2p.listen(6881, '0.0.0.0');





    var db    = {};  

    var mysql = require('mysql');  

    var conn  = mysql.createConnection({  

      host            : 'localhost',  

      user            : 'xx',  

      password        : 'xx',  

      database        : 'xx'  

    });  

      

    conn.connect();


    db.query = function(sql,para, callback){  

      

        if (!sql) {  

            callback();  

            return;  

        }  

        conn.query(sql,para, function(err, rows, fields) {  

          if (err) {  

            console.log(err);  

            callback(err, null);  

            return;  

          };  

      

          callback(null, rows, fields);  

        });  

    }  

    module.exports = db;


    上一篇:txm2017产品规划
    下一篇:mingw32 mingw64 msys cygwin TDM-GCC