require 'spec_helper'

describe Bankserv::Engine do
  include Helpers
  
  before(:all) do
    FileUtils.mkdir(Dir.pwd + "/spec/examples/host2host/archives") unless File.directory?(Dir.pwd + "/spec/examples/host2host/archives")
    FileUtils.copy(Dir.pwd + "/spec/examples/tmp/OUTPUT0412153500.txt", Dir.pwd + "/spec/examples/host2host/")
    FileUtils.copy(Dir.pwd + "/spec/examples/tmp/REPLY0412153000.txt", Dir.pwd + "/spec/examples/host2host/")
    Bankserv::EngineConfiguration.create!(interval_in_minutes: 15, input_directory: "/tmp", output_directory: "/tmp", archive_directory: "/tmp")
  end
  
  after(:all) do
    Dir.glob(Dir.pwd + "/spec/examples/host2host/*.txt").each do |input_file|
      File.delete(input_file)
    end
    
    FileUtils.rm_rf(Dir.pwd + "/spec/examples/host2host/archives", secure: true)
    File.delete(Dir.pwd + "/spec/tmp/harry.txt")
    File.delete(Dir.pwd + "/spec/tmp/sally.txt")
  end
  
  context "Prepare engine" do
    
    it "should contain default values from the migration" do
      Bankserv::Engine.config.should == { interval_in_minutes: 15, input_directory: "/tmp", output_directory: "/tmp", archive_directory: "/tmp" }
    end
    
    it "should be able to update engines config" do
      Bankserv::Engine.interval = 15
      Bankserv::Engine.output_directory = Dir.pwd + "/spec/examples/host2host"
      Bankserv::Engine.config[:interval_in_minutes].should == 15
      Bankserv::Engine.config[:output_directory].should == Dir.pwd + "/spec/examples/host2host"
    end
    
    it "should not have any running processes" do
      Bankserv::Engine.running?.should be_false
    end
    
  end
  
  context "Testing individual methods of engine" do
    
    before(:all) do
      create(:configuration, client_code: "986", client_name: "TESTTEST", user_code: "9999", user_generation_number: 846, client_abbreviated_name: "TESTTEST")
      t = Time.local(2012, 1, 23, 10, 5, 0)
      Timecop.travel(t)
      file_contents = File.open("./spec/examples/eft_input_with_2_sets.txt", "rb").read
      Bankserv::InputDocument.store(file_contents)
      
      Bankserv::Document.last.mark_processed!
      
      Bankserv::Engine.output_directory = Dir.pwd + "/spec/examples/host2host"
      Bankserv::Engine.input_directory = Dir.pwd + "/spec/examples/host2host"
      Bankserv::Engine.archive_directory = Dir.pwd + "/spec/examples/host2host/archives"
      
      @queue = Bankserv::Engine.new
    end
    
    it "should be able to start processing work" do
      @queue.start!.should be_true
    end
    
    it "should be set to running" do
      @queue.running?.should be_true
    end
    
    it "should be expecting a reply file" do
      @queue.expecting_reply_file?.should be_true
    end
    
    it "should be able to return a list of reply files" do
      Bankserv::Engine.reply_files.should == ["REPLY0412153000.txt"]
    end
    
    it "should be able to return a list of output files" do
      Bankserv::Engine.output_files.should == ["OUTPUT0412153500.txt"]
    end
    
    it "should be able to process reply files" do
      @queue.process_reply_files
      Bankserv::Document.first.reply_status.should == "ACCEPTED"
      @queue.expecting_reply_file?.should be_false
    end
    
    it "should be able to process output files" do
      @queue.process_output_files
    end
    
    it "should be able to set the process to finished" do
      @queue.finish!.should be_true
      @queue.running?.should be_false
      @queue.process.success.should be_true
    end
    
    it "should not have any processes running" do
      Bankserv::Engine.running?.should be_false
    end
    
  end
  
  context "Processing an input document." do
    
    before(:all) do
      tear_it_down      
      
      Timecop.travel(Time.local(2008, 8, 8, 10, 5, 0))
      Bankserv::EngineConfiguration.create!(interval_in_minutes: 15, input_directory: "/tmp", output_directory: "/tmp", archive_directory: "/tmp")
      create(:configuration, client_code: "986", client_name: "TESTTEST", user_code: "9999", user_generation_number: 846, client_abbreviated_name: "TESTTEST")
      
      create_credit_request
      
      Bankserv::Configuration.stub!(:live_env?).and_return(true)
      Bankserv::InputDocument.stub!(:fetch_next_transmission_number).and_return("846")
      Bankserv::Transmission::UserSet::Eft.stub!(:last_sequence_number_today).and_return(77)
      
      Bankserv::Engine.output_directory = Dir.pwd + "/spec/examples/host2host"
      Bankserv::Engine.input_directory = Dir.pwd + "/spec/examples/host2host"
      Bankserv::Engine.archive_directory = Dir.pwd + "/spec/examples/host2host/archives"
      
      @queue = Bankserv::Engine.new
      @queue.start! # create a process
    end
     
    it "should process the document" do
      @queue.process_input_files
      @document = Bankserv::Document.last
      @document.processed.should be_true
      @queue.expecting_reply_file?.should be_true
    end
    
    it "should write a file to the input directory" do
      (Dir.glob(Dir.pwd + "/spec/examples/host2host/INPUT*.txt").size == 1).should be_true
    end
    
  end
  
  context "integration testing" do
    
    before(:each) do
      Timecop.travel(Time.local(2012, 4, 10, 10, 5, 0))
      @tmpdir = Dir.pwd + "/spec/tmp"
      tear_it_down
      create(:configuration, client_code: "12345", client_name: "TESTTEST", user_code: "9999", user_generation_number: 1, client_abbreviated_name: "TESTTEST", department_code: "506")
      Bankserv::EngineConfiguration.create!(interval_in_minutes: 15, input_directory: @tmpdir, output_directory: @tmpdir, archive_directory: @tmpdir)
    end
  
    it "should process ahv requests" do
      Bankserv::AccountHolderVerification.should_receive(:generate_reference_number).exactly(8).times.and_return("AHV67","AHV68","AHV69","AHV70","AHV71","AHV72","AHV73","AHV74")
      create_ahv_requests_scenario
      e = Bankserv::Engine.new
      e.should_receive(:generate_input_file_name).and_return("harry.txt")
      e.process!
    
      expected_string = File.open("./spec/examples/INPUT.120410144410.txt", "rb").read
      got_string = File.open(@tmpdir + '/harry.txt', "rb").read
    
      got_string.should == expected_string
    end
  
    it "should process debit requests" do
      create_debit_requests_scenario
      
      e = Bankserv::Engine.new
      e.should_receive(:generate_input_file_name).and_return("sally.txt")
      e.process!
      puts e.inspect
    
      expected_string = File.open("./spec/examples/INPUT.120411110604.txt", "rb").read
      got_string = File.open(@tmpdir + '/sally.txt', "rb").read
    
      got_string.should == expected_string
    end
  
    it "should process credit requests" do
      pending
    end
  
  end
  
end