inventid/iaas

import uuid from "uuid/v4";
import log from "./log";

import database from './databases';

const shouldRunCleanup = () => Math.floor(Math.random() * 10) === 0;

export async function createToken(id) {
  try {
    const newToken = await database.createToken(id, uuid());
    if (newToken) {
      log('info', 'Created token successfully');
    }
    if (shouldRunCleanup()) {
      log('info', 'Running token database cleanup');
      await database.cleanupTokens();
    }
    return newToken;
  } catch (e) {
    log('error', e.stack);
    return null;
  }
}

export async function consumeToken(token, id) {
  return await database.consumeToken(token, id);
}

export async function deleteTokenForImageId(id) {
  return await database.deleteTokenForImageId(id);
}

export async function markAsCompleted(token, id) {
  return await database.markUploadAsCompleted(token, id);
}

export async function getImageIdsSince(threshold = new Date(1970, 1, 1)) {
  return await database.imagesCompletedAfter(threshold);
}