var cluster = require('cluster'); 
if (cluster.isMaster) { 
var async = require('async'); 
var config = require('./config')(); 
var fs = require('fs'); 
var path = require('path'); 
var sharp = require('sharp'); 
var io = require('socket.io')(config.stats_port); 
var vnstat = require('vnstat-dumpdb'); 
var metadata = require(config.metadata_path); 
var moment = require('moment'); 
console.log('Config:'); 
console.log(config); 
try { 
var stats = require(config.stats_path); 
} 
catch (error) { 
var stats = { 
count: 0}
; 
} 
try { 
var images = require(config.image_store_path); 
} 
catch (e) { 
var images = [] ; 
} 
try { 
var cache = require(config.cache_metadata_path); 
} 
catch (e) { 
var cache = { 
}
; 
} 
var publicStats = { 
}
; 
var bandWidth = 0; 
io.on('connection', function (socket){ 
socket.emit('stats', publicStats); 
} 
); 
var fetchStats = function (){ 
publicStats = { 
count: stats.count,
bandWidth: bandWidth,
images: _AN_Read_length('length', images)}
; 
io.emit('stats', publicStats); 
} 
; 
var fetchBandwidth = function (){ 
vnstat.dumpdb(function (error, data){ 
if (error) { 
console.log('Couldn\'t fetch bandwidth: ' + error); 
} 
 else { 
bandWidth = data.traffic? data.traffic.total.tx: data.eth0.traffic.total.tx; 
} 
} 
); 
} 
; 
_AN_Call_setinterval('setInterval', window, fetchBandwidth, 1000 * 30); 
_AN_Call_setinterval('setInterval', window, fetchStats, 1000); 
fetchBandwidth(); 
fetchStats(); 
var exited = false ; 
var saveToFileAndExit = function (){ 
if (exited) { 
return ; 
} 
 else { 
exited = true ; 
} 
console.log('Current stats:', stats); 
fs.writeFileSync(config.stats_path, JSON.stringify(stats), 'utf8'); 
fs.writeFileSync(config.cache_metadata_path, JSON.stringify(cache), 'utf8'); 
process.exit(0); 
} 
; 
var saveToFile = function (callback){ 
fs.writeFile(config.stats_path, JSON.stringify(stats), 'utf8', function (error){ 
fs.writeFile(config.cache_metadata_path, JSON.stringify(cache), 'utf8', function (error){ 
callback(); 
} 
); 
} 
); 
} 
; 
process.on('exit', saveToFileAndExit); 
process.on('SIGINT', saveToFileAndExit); 
process.on('SIGTERM', saveToFileAndExit); 
process.on('uncaughtException', function (error){ 
console.log('Uncaught exception: '); 
console.trace(error); 
saveToFileAndExit(); 
} 
); 
var loadImages = function (){ 
var newImages = [] ; 
async.each(metadata, function (image, next){ 
if (image.deleted) { 
return setImmediate(next); 
} 
var existingImage = imageExists(image); 
if (existingImage) { 
existingImage.post_url = image.post_url; 
existingImage.author = image.author; 
existingImage.author_url = image.author_url; 
newImages.push(existingImage); 
return setImmediate(next); 
} 
var filename = path.resolve(config.folder_path, image.filename); 
console.log('Getting info for new image %s', filename); 
sharp(filename).metadata(function (error, result){ 
if (error) { 
console.trace('imageScan error: %s filename: %s', error, filename); 
return setImmediate(next); 
} 
result.filename = filename; 
result.id = image.id; 
result.post_url = image.post_url; 
result.author = image.author; 
result.author_url = image.author_url; 
newImages.push(result); 
next(); 
} 
); 
} 
, function (error){ 
writeImagesToFile(newImages); 
} 
); 
} 
; 
var imageExists = function (image){ 
for (var i in images){ 
if (images[i].id === image.id) { 
return images[i]; 
} 
} 
return false ; 
} 
; 
var writeImagesToFile = function (newImages){ 
newImages.sort(function (a, b){ 
return a.id - b.id; 
} 
); 
images = newImages; 
fs.writeFile(config.image_store_path, JSON.stringify(newImages), 'utf8', function (error){ 
findMissingCacheFiles(function (){ 
startWebServers(); 
} 
); 
} 
); 
} 
; 
var findMissingCacheFiles = function (callback){ 
fs.readdir(config.cache_folder_path, function (error, list){ 
if (error) { 
console.log('Error reading cache directory!'); 
return callback(); 
} 
async.each(list, function (filename, next){ 
filename = path.resolve(config.cache_folder_path, filename); 
if (cache[filename] === undefined) { 
fs.unlink(filename, function (error){ 
setImmediate(next); 
} 
); 
} 
 else { 
setImmediate(next); 
} 
} 
, function (error){ 
callback(); 
} 
); 
} 
); 
} 
; 
var startWebServers = function (){ 
var cpuCount = _AN_Read_length('length', require('os').cpus()) - 1; 
if (cpuCount < 2) { 
cpuCount = 2; 
} 
for (var i = 0, il = cpuCount; 
i < il; i++ ){ 
startWorker(); 
} 
cluster.on('exit', function (worker){ 
console.log('Worker ' + worker.id + ' died'); 
startWorker(); 
} 
); 
var triggerSaveToFile = function (){ 
saveToFile(function (){ 
setImmediate(setTimeout, triggerSaveToFile, 1000 * 5); 
} 
); 
} 
; 
_AN_Call_settimeout('setTimeout', window, triggerSaveToFile, 1000 * 5); 
var triggerCacheCleanup = function (){ 
cleanupCache(function (){ 
setImmediate(setTimeout, triggerCacheCleanup, 1000 * 60 * 5); 
} 
); 
} 
; 
_AN_Call_settimeout('setTimeout', window, triggerCacheCleanup, 1000 * 60 * 5); 
} 
; 
var cleanupCache = function (callback){ 
async.eachLimit(Object.keys(cache), 100, function (filename, next){ 
if (moment().diff(cache[filename], 'days') >= 14) { 
fs.unlink(filename, function (error){ 
delete cache[filename]; 
setImmediate(next); 
} 
); 
} 
 else { 
setImmediate(next); 
} 
} 
, function (error){ 
callback(); 
} 
); 
} 
; 
var startWorker = function (){ 
var worker = cluster.fork(); 
worker.on('message', handleWorkerMessage); 
console.log('Worker ' + worker.id + ' started'); 
} 
; 
var handleWorkerMessage = function (msg){ 
stats.count++ ; 
cache[msg] = new Date(); 
} 
; 
fs.mkdir(config.cache_folder_path, function (error){ 
loadImages(); 
} 
); 
} 
 else { 
var config = require('./config')(); 
require('./server')(function (callback){ 
callback.listen(_AN_Read_port('PORT', process.env) || _AN_Read_port('port', config), '0.0.0.0'); 
} 
); 
}