#!/usr/bin/env node
'use strict';
var mongo = require('mongodb');

var cachedDb;
var cachedClient;

var posts;
var threads;
var references;

exports.fixPostings = function(reference, callback) {

  var path = '/.media/' + reference.sha256;

  if (reference.extension) {
    path += '.' + reference.extension;
  }

  var match = {
    'files.path' : path
  };

  var update = {
    $set : {
      'files.$[file].thumb' : path
    }
  };

  var ops = {
    arrayFilters : [ {
      'file.path' : path
    } ]
  };

  posts.updateOne(match, update, ops, function(error) {

    if (error) {
      callback(error);
    } else {
      threads.updateOne(match, update, ops, callback);
    }

  });

};

function startIteration(callback, lastId) {

  references.find({
    sha256 : {
      $exists : true
    },
    hasThumb : {
      $ne : true
    },
    _id : lastId ? {
      $gt : lastId
    } : {
      $exists : true
    }
  }).sort({
    _id : 1
  }).limit(1).toArray(function(error, foundReferences) {

    if (error || !foundReferences.length) {
      return callback(error);
    }

    exports.fixPostings(foundReferences[0], function(error, sha256) {

      if (error) {
        callback(error);
      } else {
        startIteration(callback, foundReferences[0]._id);
      }

    });
  });

}

function connect(connectString, dbToUse, callback, attempts) {

  attempts = attempts || 0;

  mongo.MongoClient.connect(connectString, {
    useNewUrlParser : true,
    useUnifiedTopology : true
  }, function connectedDb(error, client) {

    if (error) {

      if (attempts > 9) {
        callback(error);
      } else {

        console.log(error);
        console.log('Retrying in 10 seconds');

        setTimeout(function() {
          connect(connectString, dbToUse, callback, ++attempts);
        }, 10000);
      }

    } else {

      cachedClient = client;
      cachedDb = client.db(dbToUse);

      posts = cachedDb.collection('posts');
      threads = cachedDb.collection('threads');
      references = cachedDb.collection('uploadReferences');

      startIteration(callback);
    }

  });

}

exports.init = function(callback) {

  var dbSettings = require('./settings/db.json');



  var connectString = 'mongodb://';

  if (dbSettings.user) {
    connectString += dbSettings.user + ':' + dbSettings.password + '@';
  }

  connectString += dbSettings.address + ':';
  connectString += dbSettings.port + '/' + dbSettings.db;

  if (dbSettings.ssl) {
    connectString += '?ssl=true';
  }

  connect(connectString, dbSettings.db, callback);

};

exports.init(function(error) {

  if (error) {
    console.log(error);
  }

  cachedClient.close();

});