From 68ffa097e187da663fa3f537b430428ea5e8de2e Mon Sep 17 00:00:00 2001
From: Eric Wong <normalperson@yhbt.net>
Date: Sun, 25 Aug 2013 09:25:07 +0000
Subject: split out source handling to prepare for avconv/ffmpeg support

We should've done this at the start, but we didn't.
---
 lib/dtas/source.rb | 145 +----------------------------------------------------
 1 file changed, 1 insertion(+), 144 deletions(-)

(limited to 'lib/dtas/source.rb')

diff --git a/lib/dtas/source.rb b/lib/dtas/source.rb
index 747fa9f..1093b18 100644
--- a/lib/dtas/source.rb
+++ b/lib/dtas/source.rb
@@ -2,149 +2,6 @@
 # Copyright (C) 2013, Eric Wong <normalperson@yhbt.net>
 # License: GPLv3 or later (https://www.gnu.org/licenses/gpl-3.0.txt)
 require_relative '../dtas'
-require_relative 'command'
-require_relative 'format'
-require_relative 'replaygain'
-require_relative 'process'
-require_relative 'serialize'
 
-# this is usually one input file
-class DTAS::Source # :nodoc:
-  attr_reader :infile
-  attr_reader :offset
-  require_relative 'source/common'
-  require_relative 'source/mp3'
-
-  include DTAS::Command
-  include DTAS::Process
-  include DTAS::Source::Common
-  include DTAS::Source::Mp3
-
-  SOURCE_DEFAULTS = COMMAND_DEFAULTS.merge(
-    "command" => 'exec sox "$INFILE" $SOXFMT - $TRIMFX $RGFX',
-    "comments" => nil,
-  )
-
-  SIVS = %w(infile comments command env)
-
-  def initialize(infile, offset = nil)
-    command_init(SOURCE_DEFAULTS)
-    @format = nil
-    @infile = infile
-    @offset = offset
-    @comments = nil
-    @samples = nil
-    @rg = nil
-  end
-
-  # this exists mainly to make the mpris interface easier, but it's not
-  # necessary, the mpris interface also knows the sample rate
-  def offset_us
-    (offset_samples / format.rate.to_f) * 1000000
-  end
-
-  # returns any offset in samples (relative to the original source file),
-  # likely zero unless seek was used
-  def offset_samples
-    return 0 unless @offset
-    case @offset
-    when /\A\d+s\z/
-      @offset.to_i
-    else
-      format.hhmmss_to_samples(@offset)
-    end
-  end
-
-  def precision
-    qx(%W(soxi -p #@infile), err: "/dev/null").to_i # sox.git f4562efd0aa3
-  rescue # fallback to parsing the whole output
-    s = qx(%W(soxi #@infile), err: "/dev/null")
-    s =~ /Precision\s+:\s*(\d+)-bit/
-    v = $1.to_i
-    return v if v > 0
-    raise TypeError, "could not determine precision for #@infile"
-  end
-
-  def format
-    @format ||= begin
-      fmt = DTAS::Format.new
-      fmt.from_file(@infile)
-      fmt.bits ||= precision
-      fmt
-    end
-  end
-
-  # A user may be downloading the file and start playing
-  # it before the download completes, this refreshes
-  def samples!
-    @samples = nil
-    samples
-  end
-
-  # This is the number of samples according to the samples in the source
-  # file itself, not the decoded output
-  def samples
-    @samples ||= qx(%W(soxi -s #@infile)).to_i
-  rescue => e
-    warn e.message
-    0
-  end
-
-  # just run soxi -a
-  def __load_comments
-    tmp = {}
-    case @infile
-    when String
-      err = ""
-      cmd = %W(soxi -a #@infile)
-      begin
-        qx(cmd, err: err).split(/\n/).each do |line|
-          key, value = line.split(/=/, 2)
-          key && value or next
-          # TODO: multi-line/multi-value/repeated tags
-          tmp[key.upcase] = value
-        end
-      rescue => e
-        if /FAIL formats: no handler for file extension/ =~ err
-          warn("#{xs(cmd)}: #{err}")
-        else
-          warn("#{e.message} (#{e.class})")
-        end
-        # TODO: fallbacks
-      end
-    end
-    tmp
-  end
-
-  def comments
-    @comments ||= __load_comments
-  end
-
-  def replaygain
-    @rg = DTAS::ReplayGain.new(comments) ||
-          DTAS::ReplayGain.new(mp3gain_comments)
-  end
-
-  def spawn(format, rg_state, opts)
-    raise "BUG: #{self.inspect}#spawn called twice" if @to_io
-    e = format.to_env
-    e["INFILE"] = @infile
-
-    # make sure these are visible to the "current" command...
-    @env["TRIMFX"] = @offset ? "trim #@offset" : nil
-    @env["RGFX"] = rg_state.effect(self) || nil
-    e.merge!(@rg.to_env) if @rg
-
-    @pid = dtas_spawn(e.merge!(@env), command_string, opts)
-  end
-
-  def to_hsh
-    to_hash.delete_if { |k,v| v == SOURCE_DEFAULTS[k] }
-  end
-
-  def to_hash
-    rv = ivars_to_hash(SIVS)
-    rv["samples"] = samples
-    rv
-  end
+module DTAS::Source # :nodoc:
 end
-- 
cgit v1.2.3-24-ge0c7