Op/init.js at master · Fleetwit/Op · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
var mysql				= require('mysql');
var mongodb 			= require('mongodb');
var _ 					= require('underscore');
var datastore 			= require('./datastore').datastore;

var debug_mode		= true;


function main() {
	var scope = this;

	console.log("Connecting to MongoDB...");
	this.mongo = new datastore({
		database:		"fleetwit"
	});
	this.mongo.init(function() {
		console.log("MongoDB: Connected.");
		console.log("Connecting to MySQL...");
		scope.mysql = mysql.createConnection({
			host     : 'localhost',
			user     : 'root',
			password : '',
			database : 'fleetwit'
		});
		scope.mysql.connect(function(err) {
			console.log("MySQL: Connected.");
			scope.initOp();
		});
	});

}
main.prototype.initOp = function() {
	this.__convertRaceData();
}

main.prototype.__convertRaceData = function() {
	this.mongo.open("datastore", function(collection) {
		collection.find().toArray(function(err, docs) {

			for (i=0;i<docs.length;i++) {
				console.dir(docs[i]);
				if (docs[i].race == undefined) {
					continue;
				}
				var buffer = [];
				for (j=0;j<docs[i].race.length;j++) {
					for (k=0;k<docs[i].race[j].levels.length;k++) {
						buffer.push(_.extend({
							race:	docs[i].race[j].race
						}, docs[i].race[j].levels[k]));
					}
				}
				console.dir(buffer);
				collection.update({
					_id:	docs[i]._id
				}, {
					race: buffer
				}, function() {

				});
			}
		});
	});
}
/*
main.prototype.__convertRaceData = function() {
	this.mongo.open("datastore", function(collection) {
		collection.find().toArray(function(err, docs) {

			for (i=0;i<docs.length;i++) {
				console.dir(docs[i]);
				if (docs[i].race == undefined) {
					continue;
				}
				var buffer = [];
				for (j in docs[i].race) {
					var subbuffer = [];
					for (k in docs[i].race[j]) {

						buffer.push(_.extend({
							race:	j,
							level:	k,

						}, docs[i].race[j][k]));
					}

				}

				collection.update({
					_id:	docs[i]._id
				}, {
					race: buffer
				}, function() {

				});
			}
		});
	});
}*/

new main();

// Crash Management
if (!debug_mode) {
	process.on('uncaughtException', function(err) {
		console.log("uncaughtException",err);
	});
}