ROOT_PATH = File.expand_path(File.join(File.dirname(__FILE__), ".."))
$:.unshift File.join(ROOT_PATH, "lib")
$:.unshift File.join(ROOT_PATH, "vendor", "dropbox-ruby-sdk", "lib")

require "dropbox_sdk"
require "fileutils"
require "time"
require "yaml"
require "logger"
require "cgi"
require "sqlite3"
require "insensitive_hash/minimal"

require "dbox/loggable"
require "dbox/utils"
require "dbox/api"
require "dbox/database"
require "dbox/db"
require "dbox/syncer"

module Dbox
  def self.authorize
    Dbox::API.authorize
  end

  def self.create(remote_path, local_path)
    log.debug "Creating (remote: #{remote_path}, local: #{local_path})"
    remote_path = clean_remote_path(remote_path)
    local_path = clean_local_path(local_path)
    migrate_dbfile(local_path)
    Dbox::Syncer.create(remote_path, local_path)
  end

  def self.clone(remote_path, local_path)
    log.debug "Cloning (remote: #{remote_path}, local: #{local_path})"
    remote_path = clean_remote_path(remote_path)
    local_path = clean_local_path(local_path)
    migrate_dbfile(local_path)
    Dbox::Syncer.clone(remote_path, local_path)
  end

  def self.pull(local_path)
    log.debug "Pulling (local: #{local_path})"
    local_path = clean_local_path(local_path)
    migrate_dbfile(local_path)
    Dbox::Syncer.pull(local_path)
  end

  def self.clone_or_pull(remote_path, local_path)
    if exists?(local_path)
      pull(local_path)
    else
      clone(remote_path, local_path)
    end
  end

  def self.push(local_path)
    log.debug "Pushing (local: #{local_path})"
    local_path = clean_local_path(local_path)
    migrate_dbfile(local_path)
    Dbox::Syncer.push(local_path)
  end

  def self.sync(local_path)
    log.debug "Syncing (local: #{local_path})"
    res = {}
    res[:pull] = pull(local_path)
    res[:push] = push(local_path)
    res
  end

  def self.move(new_remote_path, local_path)
    log.debug "Moving (new remote: #{new_remote_path}, local: #{local_path})"
    new_remote_path = clean_remote_path(new_remote_path)
    local_path = clean_local_path(local_path)
    migrate_dbfile(local_path)
    Dbox::Syncer.move(new_remote_path, local_path)
  end

  def self.exists?(local_path)
    local_path = clean_local_path(local_path)
    migrate_dbfile(local_path)
    Dbox::Database.exists?(local_path)
  end

  def self.delete(remote_path, local_path = nil)
    log.debug "Deleting (remote: #{remote_path})"
    remote_path = clean_remote_path(remote_path)
    Dbox::Syncer.api.delete_dir(remote_path)
    if local_path
      local_path = clean_local_path(local_path)
      log.debug "Deleting (local_path: #{local_path})"
      FileUtils.rm_rf(local_path) if File.exists?(local_path)
    end
  end

  private

  def self.clean_remote_path(path)
    raise(ArgumentError, "Missing remote path") unless path
    path.sub(/\/$/,'')
    path[0].chr == "/" ? path : "/#{path}"
  end

  def self.clean_local_path(path)
    raise(ArgumentError, "Missing local path") unless path
    File.expand_path(path)
  end

  def self.migrate_dbfile(path)
    if Dbox::DB.exists?(path)
      log.warn "Old database file format found -- migrating to new database format"
      Dbox::Database.migrate_from_old_db_format(Dbox::DB.load(path))
      Dbox::DB.destroy!(path)
      log.warn "Migration complete"
    end
  end
end