dpn-admin/dpn-server

# Copyright (c) 2015 The Regents of the University of Michigan.
# All Rights Reserved.
# Licensed according to the terms of the Revised BSD License
# See LICENSE.md for details.


class ReplicationTransfersController < ApplicationController
  include Authenticate
  include Adaptation
  include Pagination

  local_node_only :create, :destroy
  uses_pagination :index
  adapt!

  def index
    @replication_transfers = ReplicationTransfer.updated_after(params[:after])
      .updated_before(params[:before])
      .with_bag(params[:bag])
      .with_to_node(params[:to_node])
      .with_from_node(params[:from_node])
      .with_store_requested(params[:store_requested])
      .with_stored(params[:stored])
      .with_cancelled(params[:cancelled])
      .with_cancel_reason(params[:cancel_reason])
      .order(parse_ordering(params[:order_by]))
      .page(@page)
      .per(@page_size)

    render "shared/index", status: 200
  end



  def show
    @replication_transfer = ReplicationTransfer.find_by_replication_id!(params[:replication_id])
    render "shared/show", status: 200
  end


  def create
    if ReplicationTransfer.where(replication_id: params[:replication_id]).exists?
      render nothing: true, status: 409 and return
    else
      @replication_transfer = ReplicationTransfer.new(create_params(params))
      if @replication_transfer.save
        render "shared/create", status: 201
      else
        render "shared/errors", status: 400
      end
    end
  end


  def update
    @replication_transfer = ReplicationTransfer.find_by_replication_id!(params[:replication_id])

    if @requester != @replication_transfer.to_node && !@requester.local_node?
      render nothing: true, status: 403 and return
    end

    if ReplicationTransferUpdater.update(@replication_transfer, update_params(params))
      render "shared/update", status: 200
    else
      render "shared/errors", status: 400
    end

  end



  def destroy
    repl = ReplicationTransfer.find_by_replication_id!(params[:replication_id])
    repl.destroy!
    render nothing: true, status: 204
  end


  private

  SCALAR_PARAMS = [
    :link, :fixity_nonce, :fixity_value,
    :created_at, :updated_at,
    :replication_id, :store_requested, :stored,
    :cancelled, :cancel_reason, :cancel_reason_detail
  ]
  ASSOCIATED_PARAMS = [
    :bag, :from_node, :to_node, :protocol, :fixity_alg
  ]


  def create_params(params)
    params
      .permit(SCALAR_PARAMS)
      .merge(params.slice(*ASSOCIATED_PARAMS))
  end


  def update_params(params)
    create_params(params)
  end



end