phateio/kiris

class Bridge::TracksController < ApplicationController
  skip_before_filter :verify_authenticity_token

  layout false

  def index
    @items = []
    unless params[:type]
      render nothing: true, status: :not_found and return
    end
    case params[:type]
    when 'niconico_for_new'
      search_niconico_for_new
    when 'niconico_for_renew'
      search_niconico_for_renew
    when 'szhash'
      search_by_szhash
    else
      render nothing: true, status: :not_found and return
    end
    respond_to do |format|
      format.xml { render xml: @items }
      format.json { render json: @items }
      format.any { head :not_found }
    end
  end

  def search_niconico_for_new
    tracks = Track.niconico_tracks.where(szhash: '').order(id: :asc)
    tracks.each do |track|
      @items << track_item(track)
    end
  end

  def search_niconico_for_renew
    arel_old_tracks = Track.arel_table[:updated_at].lt(Time.parse('2015-11-01 00:00:00 UTC'))
    tracks = Track.niconico_tracks.requestable.where('status ILIKE ?', 'RENEW:OK').where(arel_old_tracks)
    tracks.each do |track|
      @items << track_item(track)
    end
  end

  def search_by_szhash
    szhash = request.GET[:szhash]
    tracks = Track.where(szhash: szhash).order(id: :asc)
    tracks.each do |track|
      @items << track_item(track)
    end
  end

  def utaitedb
    @items = []

    tracks = Track.niconico_tracks.where(szhash: '', uploader: 'utaitedb.net', identity: '').order(id: :asc)
    tracks.each do |track|
      @items << track_item(track)
    end

    respond_to do |format|
      format.xml { render xml: @items }
      format.json { render json: @items }
      format.any { head :not_found }
    end
  end

  def update
    secret_key = request.POST[:secret_key]
    if secret_key != $BRIDGE_SECRET_KEY
      render json: { status: '403 Forbidden' }, status: :forbidden and return
    end
    @track = Track.find(track_id)
    @track.update!(track_params.merge(mtime: Time.now.utc))
    render json: { status: 'OK' }
  end

  private

  def track_id
    request.POST[:id]
  end

  def track_params
    request.POST.slice(
      :szhash,
      :duration,
      :status,
      :source_format,
      :source_bitrate,
      :source_channels,
      :source_frequency
    )
  end

  def track_item(track)
    {
      id: track.id,
      szhash: track.szhash,
      status: track.status,
      niconico: track.niconico
    }
  end
end