Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- var provider;
- var mongo_utils = require('./../lib/mongodb/utils');
- var mongo_provider = require('./../lib/mongodb/provider');
- var hashlib = require('./../hashlib/build/default/hashlib');
- var fs = require('fs');
- exports.provider = function(callback){
- if (exports._provider){
- callback.call(exports._provider);
- } else {
- function on_db(err, db){
- if (err){
- throw(err);
- }
- function on_provider (){
- exports._provider = this;
- callback.call(this);
- }
- new mongo_provider.Provider(db, 'events', on_provider, {});
- }
- mongo_utils.db('pools', 'localhost', 27017, on_db);
- }
- }
- exports._provider = null;
- exports.save_mail_message = function(txt, callback){
- var hash = hashlib.md5(txt);
- console.log('message: ');
- console.log(txt);
- console.log('hash: ' + hash);
- var s = fs.openWriteStream(__dirname + '/mail/' + hash + '.txt');
- s.write(txt);
- s.end();
- var mongo_data ={
- raw_data: txt,
- event_type: 'mail',
- collectors: ['whitelock-gamers.co.uk'],
- parse_status: 'raw',
- created: new Date(),
- idexed_in_solr: false,
- alert_sent: false,
- raw_data_md5: hash
- };
- exports.provider(function(){
- this.insert(mongo_data, callback);
- });
- }
Add Comment
Please, Sign In to add comment