# encoding: utf-8
require_relative 'spec_helper'

module FileWatch
  describe WatchedFilesCollection do
    let(:time) { Time.now }
    let(:filepath1) { "/var/log/z.log" }
    let(:filepath2) { "/var/log/m.log" }
    let(:filepath3) { "/var/log/a.log" }
    let(:filepath4) { "/var/log/b.log" }
    let(:stat1) { double("stat1", :size => 98, :modified_at => time - 30, :inode => 234567, :inode_struct => InodeStruct.new("234567", 3, 2)) }
    let(:stat2) { double("stat2", :size => 99, :modified_at => time - 20, :inode => 234568, :inode_struct => InodeStruct.new("234568", 3, 2)) }
    let(:stat3) { double("stat3", :size => 100, :modified_at => time, :inode => 234569, :inode_struct => InodeStruct.new("234569", 3, 2)) }
    let(:stat4) { double("stat4", :size => 99, :modified_at => time, :inode => 234570, :inode_struct => InodeStruct.new("234570", 3, 2)) }
    let(:wf1) { WatchedFile.new(filepath1, stat1, Settings.new) }
    let(:wf2) { WatchedFile.new(filepath2, stat2, Settings.new) }
    let(:wf3) { WatchedFile.new(filepath3, stat3, Settings.new) }
    let(:wf4) { WatchedFile.new(filepath4, stat4, Settings.new) }

    context "sort by last_modified in ascending order" do
      let(:sort_by) { "last_modified" }
      let(:sort_direction) { "asc" }

      it "sorts earliest modified first" do
        collection = described_class.new(Settings.from_options(:file_sort_by => sort_by, :file_sort_direction => sort_direction))
        expect(collection.empty?).to be true
        collection.add(wf2)
        expect(collection.empty?).to be false
        expect(collection.values).to eq([wf2])
        collection.add(wf3)
        expect(collection.values).to eq([wf2, wf3])
        collection.add(wf1)
        expect(collection.values).to eq([wf1, wf2, wf3])
        expect(collection.keys.size).to eq 3
      end

      it "sorts by path when mtime is same" do
        collection = described_class.new(Settings.from_options(:file_sort_by => sort_by, :file_sort_direction => sort_direction))
        expect(collection.size).to eq 0
        collection.add(wf2)
        collection.add(wf4)
        collection.add(wf1)
        expect(collection.size).to eq 3
        expect(collection.values).to eq([wf1, wf2, wf4])
        collection.add(wf3)
        expect(collection.size).to eq 4
        expect(collection.values).to eq([wf1, wf2, wf3, wf4])
        expect(collection.keys.size).to eq 4
      end
    end

    context "sort by path in ascending order" do
      let(:sort_by) { "path" }
      let(:sort_direction) { "asc" }

      it "sorts path A-Z" do
        collection = described_class.new(Settings.from_options(:file_sort_by => sort_by, :file_sort_direction => sort_direction))
        collection.add(wf2)
        expect(collection.values).to eq([wf2])
        collection.add(wf1)
        expect(collection.values).to eq([wf2, wf1])
        collection.add(wf3)
        expect(collection.values).to eq([wf3, wf2, wf1])
      end
    end

    context "sort by last_modified in descending order" do
      let(:sort_by) { "last_modified" }
      let(:sort_direction) { "desc" }

      it "sorts latest modified first" do
        collection = described_class.new(Settings.from_options(:file_sort_by => sort_by, :file_sort_direction => sort_direction))
        collection.add(wf2)
        expect(collection.values).to eq([wf2])
        collection.add(wf1)
        expect(collection.values).to eq([wf2, wf1])
        collection.add(wf3)
        expect(collection.values).to eq([wf3, wf2, wf1])
      end
    end

    context "sort by path in descending order" do
      let(:sort_by) { "path" }
      let(:sort_direction) { "desc" }

      it "sorts path Z-A" do
        collection = described_class.new(Settings.from_options(:file_sort_by => sort_by, :file_sort_direction => sort_direction))
        collection.add(wf2)
        expect(collection.values).to eq([wf2])
        collection.add(wf1)
        expect(collection.values).to eq([wf1, wf2])
        collection.add(wf3)
        expect(collection.values).to eq([wf1, wf2, wf3])
      end
    end

    context "remove_paths" do
      let(:sort_by) { "path" }
      let(:sort_direction) { "desc" }

      it "is able to delete multiple files at once" do
        collection = described_class.new(Settings.from_options(:file_sort_by => sort_by, :file_sort_direction => sort_direction))
        collection.add(wf1)
        collection.add(wf2)
        collection.add(wf3)
        expect(collection.keys).to eq([filepath1, filepath2, filepath3])

        ret = collection.remove_paths([filepath2, filepath3])
        expect(ret).to eq 2
        expect(collection.keys).to eq([filepath1])
        expect(collection.values.size).to eq 1

        ret = collection.remove_paths([filepath2])
        expect(ret).to eq 0
      end
    end

    context "update" do
      let(:sort_by) { "last_modified" }
      let(:sort_direction) { "asc" }

      let(:re_stat1) { double("restat1", :size => 99, :modified_at => time, :inode => 234567, :inode_struct => InodeStruct.new("234567", 3, 2)) }
      let(:re_stat2) { double("restat2", :size => 99, :modified_at => time, :inode => 234568, :inode_struct => InodeStruct.new("234568", 3, 2)) }

      it "updates entry with changed mtime" do
        collection = described_class.new(Settings.from_options(:file_sort_by => sort_by, :file_sort_direction => sort_direction))
        collection.add(wf1)
        collection.add(wf2)
        collection.add(wf3)
        expect(collection.files).to eq([wf1, wf2, wf3])

        wf2.send(:set_stat, re_stat2)
        expect( wf2.modified_at_changed? ).to be_truthy

        collection.update wf2
        expect(collection.files).to eq([wf1, wf3, wf2])

        wf1.send(:set_stat, re_stat1)
        expect( wf1.modified_at_changed? ).to be_truthy
        collection.update wf1
        expect(collection.files).to eq([wf3, wf2, wf1])

        collection.add(wf4)
        expect(collection.files).to eq([wf3, wf4, wf2, wf1])
      end
    end

  end
end