bigbluebutton / greenlight

# BigBlueButton open source conferencing system - http://www.bigbluebutton.org/.

#

# Copyright (c) 2018 BigBlueButton Inc. and by respective authors (see below).

#

# This program is free software; you can redistribute it and/or modify it under the

# terms of the GNU Lesser General Public License as published by the Free Software

# Foundation; either version 3.0 of the License, or (at your option) any later

# version.

#

# BigBlueButton is distributed in the hope that it will be useful, but WITHOUT ANY

# WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A

# PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.

#

# You should have received a copy of the GNU Lesser General Public License along

# with BigBlueButton; if not, see <http://www.gnu.org/licenses/>.

module Recorder

  extend ActiveSupport::Concern

  include ::BbbApi

  # Fetches all recordings for a room.

  # Fetches a rooms public recordings.

  def public_recordings(room_bbb_id, provider, search_params = {}, ret_search_params = false)

    search, order_col, order_dir, recs = recordings(room_bbb_id, provider, search_params, ret_search_params)

    [search, order_col, order_dir, recs.select { |r| r[:metadata][:"gl-listed"] == "true" }]

  end

  # Makes paginated API calls to get recordings

  def all_recordings(room_bbb_ids, provider, search_params = {}, ret_search_params = false, search_name = false)

    pag_num = Rails.configuration.pagination_number

    pag_loops = room_bbb_ids.length / pag_num - 1

    res = { recordings: [] }

    (0..pag_loops).each do |i|

      pag_rooms = room_bbb_ids[pag_num * i, pag_num]

      # bbb.get_recordings returns an object

      # take only the array portion of the object that is returned

      full_res = bbb(provider).get_recordings(meetingID: pag_rooms)

      res[:recordings].push(*full_res[:recordings])

    end

    last_pag_room = room_bbb_ids[pag_num * (pag_loops + 1), room_bbb_ids.length % pag_num]

    full_res = bbb(provider).get_recordings(meetingID: last_pag_room)

    res[:recordings].push(*full_res[:recordings])

    format_recordings(res, search_params, ret_search_params, search_name)

  end

  # Format, filter, and sort recordings to match their current use in the app

  def format_recordings(api_res, search_params, ret_search_params, search_name = false)

    search = search_params[:search] || ""

    order_col = search_params[:column] && search_params[:direction] != "none" ? search_params[:column] : "end_time"

    order_dir = search_params[:column] && search_params[:direction] != "none" ? search_params[:direction] : "desc"

    search = search.downcase

    api_res[:recordings].each do |r|

      next if r.key?(:error)

      # Format playbacks in a more pleasant way.

      r[:playbacks] = if !r[:playback] || !r[:playback][:format]

        []

      elsif r[:playback][:format].is_a?(Array)

        r[:playback][:format]

      else

        [r[:playback][:format]]

      end

      r.delete(:playback)

    end

    recs = filter_recordings(api_res, search, search_name)

    recs = sort_recordings(recs, order_col, order_dir)

    if ret_search_params

      [search, order_col, order_dir, recs]

    else

      recs

    end

  end

  def filter_recordings(api_res, search, search_name = false)

    api_res[:recordings].select do |r|

             (!r[:metadata].nil? && ((!r[:metadata][:name].nil? &&

                    r[:metadata][:name].downcase.include?(search)) ||

                  (r[:metadata][:"gl-listed"] == "true" && search == "public") ||

                  (r[:metadata][:"gl-listed"] == "false" && search == "unlisted"))) ||

               ((r[:metadata].nil? || r[:metadata][:name].nil?) &&

                 r[:name].downcase.include?(search)) ||

               r[:participants].include?(search) ||

               !r[:playbacks].select { |p| p[:type].downcase.include?(search) }.empty? ||

               (search_name && Room.find_by(bbb_id: r[:meetingID]).owner.email.downcase.include?(search))

    end

  end

  def sort_recordings(recs, order_col, order_dir)

    recs = case order_col

           when "end_time"

              recs.sort_by { |r| r[:endTime] }

           when "name"

              recs.sort_by do |r|

                if !r[:metadata].nil? && !r[:metadata][:name].nil?

                  r[:metadata][:name].downcase

                else

                  r[:name].downcase

                end

              end

           when "length"

              recs.sort_by { |r| r[:playbacks].reject { |p| p[:type] == "statistics" }.first[:length] }

           when "users"

              recs.sort_by { |r| r[:participants] }

           when "visibility"

              recs.sort_by { |r| r[:metadata][:"gl-listed"] }

           when "formats"

              recs.sort_by { |r| r[:playbacks].first[:type].downcase }

            else

              recs.sort_by { |r| r[:endTime] }

            end

    if order_dir == 'asc'

      recs

    else

      recs.reverse

    end

  end

end