require File.dirname(__FILE__) + '/spec_helper' 
gem 'rspec'
require 'spec'

require DataMapper.root / 'lib' / 'dm-core' / 'spec' / 'adapter_shared_spec'
agg_dir = path_to("dm-aggregates", "0.10.2")[0]
require agg_dir / 'spec' / 'public' / 'shared' / 'aggregate_shared_spec'

require Pathname(__FILE__).dirname.expand_path.parent + 'lib/persevere_adapter'

describe DataMapper::Adapters::PersevereAdapter do
  before :all do
    # This needs to point to a valid persevere server
    @adapter = DataMapper.setup(:default, { :adapter => 'persevere', :host => 'localhost', :port => '8080', :versioned => true })
    @repository = DataMapper.repository(@adapter.name)

    class ::Bozon
      include DataMapper::Resource

      property :id, Serial
      property :author, String
      property :created_at, DateTime
      property :title, String
    end

    class ::Dataino
      include DataMapper::Resource
      property :id, Serial
      property :author, String
      property :created_at, DateTime
      property :title, String
    end
    
    class ::Nugaton
      include DataMapper::Resource
      
      property :id, Serial
      property :name, String
    end
    
    class ::Mukatron
      include DataMapper::Resource
      
      property :id, Serial
      property :street1, String
      property :b8te, String
      property :name, String
    end
    
    class ::Pantsarator
      include DataMapper::Resource
      
      property :id, String, :key => true
      property :pants, Boolean, :field => 'trousers'
    end
    
    @test_schema_hash = {
      'id' => 'Vanilla',
      'properties' => {
        'cid' => {'type' => 'string' },
        'parent' => { 'type' => 'string'},
        'data' => { 'type' => 'string'}
      }
    }

    @test_schema_hash_alt = {
      'id' => 'test1/Vanilla',
      'properties' => {
        'cid' => {'type' => 'string' },
        'parent' => { 'type' => 'string'},
        'data' => { 'type' => 'string'}
      }
    }
    @test_schema_hash_mod = {
      'id' => 'Vanilla',
      'properties' => {
        'cid' => {'type' => 'string' },
        'newdata' => { 'type' => 'any'}
      }
    }

    @test_schema_hash_alt_mod = {
      'id' => 'test1/Vanilla',
      'properties' => {
        'cid' => {'type' => 'string' },
        'newdata' => { 'type' => 'any'}
      }
    }
  end

  after :all do 
   DataMapper::Model.descendants.each{|cur_model| cur_model.auto_migrate_down! }
  end
  
  it_should_behave_like 'An Adapter'
   
  describe 'migrations' do
     it 'should create the Bozon storage' do
       Bozon.auto_migrate!
       Bozon.auto_migrate_down!
     end
        
     it "should destroy Create then Remove the Bozon Storage" do
       @adapter.get_schema(Bozon.storage_name).should == false
       Bozon.auto_migrate_up!
       @adapter.get_schema(Bozon.storage_name).should_not == false
       Bozon.auto_migrate_down!
       @adapter.get_schema(Bozon.storage_name).should == false
     end
   
     describe '#put_schema' do
       it 'should create the json schema for the hash' do
         @adapter.put_schema(@test_schema_hash).should_not == false
       end 
       
       it 'should create the schema as an extension of the Versioned schema' do
        @adapter.put_schema(@test_schema_hash).should_not == false
        test_result = @adapter.get_schema(@test_schema_hash['id'])
        test_result[0]['extends']['$ref'].should eql "Versioned"
       end
   
       it 'should create the json schema for the hash under the specified project' do
         @adapter.put_schema(@test_schema_hash, "test").should_not == false
       end
   
       it 'should create the json schema for the hash under the specified project' do
         @adapter.put_schema(@test_schema_hash_alt).should_not == false
       end 
    end
   
     describe '#get_schema' do       
       it 'should return all of the schemas (in json) if no name is provided' do
         Bozon.auto_migrate!
         Dataino.auto_migrate!
         result = @adapter.get_schema
         result.should_not == false
         result.class.should == Array
         Bozon.auto_migrate_down!
         Dataino.auto_migrate_down!
       end 
   
       it 'should return the json schema of the class specified' do
         Bozon.auto_migrate!
         result = @adapter.get_schema("bozon")
         result.should_not == false
         result[0]["id"].should == "bozon"
         Bozon.auto_migrate_down!
       end
     end
   
     describe '#update_schema' do
       it 'should update a previously existing schema' do
         result = @adapter.update_schema(@test_schema_hash_mod)
         result.should_not == false
   
         @test_schema_hash_mod['id'].should match(JSON.parse(result)['id'])
       end
   
       it 'should update a previously created schema under the specified project' do
         result = @adapter.update_schema(@test_schema_hash_mod, "test")
         result.should_not == false
         @test_schema_hash_mod['id'].should match(JSON.parse(result)['id'])
       end
   
       it 'should update a previously created schema under the specified project' do
         result = @adapter.update_schema(@test_schema_hash_alt_mod)
         result.should_not == false
         @test_schema_hash_alt_mod['id'].should match(JSON.parse(result)['id'])
       end
     end
   
     describe '#delete_schema' do
       it 'should delete the specified schema' do
         @adapter.delete_schema(@test_schema_hash).should == true
       end
   
       it 'should delete the specified schema in the specified project' do
         @adapter.delete_schema(@test_schema_hash, "test").should == true
       end
   
       it 'should delete the specified schema in the specified project' do
         @adapter.delete_schema(@test_schema_hash_alt).should == true
       end
     end
   end

  describe 'aggregates' do
    it_should_behave_like 'It Has Setup Resources'
    before :all do
      @dragons   = Dragon.all
      @countries = Country.all
    end
   
    it_should_behave_like 'An Aggregatable Class'
    
    it "should be able to get a count of objects within a range of dates" do
      Bozon.auto_migrate!
      orig_date = DateTime.now - 7
      Bozon.create(:author => 'Robbie', :created_at => orig_date, :title => '1 week ago')
      Bozon.create(:author => 'Ivan',   :created_at => DateTime.now, :title => 'About Now')
      Bozon.create(:author => 'Sean',   :created_at => DateTime.now + 7, :title => 'Sometime later')

      Bozon.count.should eql(3)
      Bozon.count(:created_at => orig_date).should eql(1)
      Bozon.count(:created_at.gt => orig_date).should eql(2)
      Bozon.auto_migrate_down!
    end
    
    it "should count with like conditions" do
      Country.count(:name.like => '%n%').should == 4
    end
  end

  describe 'limiting and offsets' do
    before(:all) do
      Bozon.auto_migrate!
      (0..99).each{|i| Bozon.create!(:author => i, :title => i)}
    end

    it "should limit" do
      result = Bozon.all(:limit => 2)
      result.length.should == 2
    end

    it "should return data from an offset" do
      result = Bozon.all(:limit => 5, :offset => 10)
      result.length.should == 5
      result.map { |item| item.id }.should == [11, 12, 13, 14, 15]
    end

    after(:all) do
      Bozon.auto_migrate_down!
    end
  end
  
  describe 'auto updating models' do
    before :each do
      Nugaton.auto_migrate!
    end
    
    it "should auto upgrade correctly" do
      before_schema = @adapter.get_schema('nugaton')[0]
      before_schema['properties'].should have_key('name')
      before_schema['properties'].should_not have_key('big_value')
      Nugaton.send(:property, :big_value, Integer)
      Nugaton.auto_upgrade!
      before_schema = @adapter.get_schema('nugaton')[0]
      before_schema['properties'].should have_key('name')
      before_schema['properties'].should have_key('big_value')
    end
    
    after(:all) do
      Nugaton.auto_migrate_down!
    end
  end
  
  # From Ryan's Gist:
  # s = Patron::Session.new
  # s.base_url = "http://localhost:8080"
  # s.headers['Content-Type'] = "application/json"
  # resp = []
  # resp << s.put("/Versioned/1", %{{"id":1, "name":"first version"}})
  # resp << s.put("/Versioned/1", %{{"id":1, "name":"second version"}})
  # resp << s.put("/Versioned/1", %{{"id":1, "name":"third version"}})
  # resp << s.get("/Versioned/1")
  # resp << s.get("/Versioned/1", {"Accept" => "application/json+versioned"})
  # 
  # resp.each do |r|
  #   puts r.status
  #   puts r.headers['Content-Type']
  #   puts r.body
  #   puts
  # end
  
  describe 'when using versioned data' do
    before(:each) do
      Nugaton.auto_migrate!
    end
    
    it "should store all the versions of the data element" do
      version = 1
      
      # Create the first version
      nugat = Nugaton.create(:name => "version #{version}")
      
      # Create a second version
      nugat.name = "version #{version += 1}"
      nugat.save
      
      # Create a third version
      
      nugat.name = "version #{version += 1}"
      nugat.save
      
      # Retrieve all versions and see if there are three
      raw_result = @adapter.persevere.retrieve("/nugaton/1", { "Accept" => "application/json+versioned" })
      results = JSON.parse( raw_result.body )
      results['current']['name'].should eql "version #{version}"
      results['versions'].length.should eql 2
    end
    
    after(:each) do
      Nugaton.auto_migrate_down!
    end
  end
  
  describe 'when finding models,' do
    before(:each) do
      Bozon.auto_migrate!
      Mukatron.auto_migrate!
      Pantsarator.auto_migrate!
    end
    
    it "should find simple strings" do
      Bozon.create(:title => "Story")
      Bozon.all(:title => "Story").length.should eql(1)
    end
    
    it "should find strings containing spaces" do
      
      Bozon.create(:title => "Name with Space", :author => "Mr. Bean")
      # [?(title = "Name with Space")][/id]
      # debugger
      Bozon.all(:title => "Name with Space").length.should eql(1)
    end
    
    it "should find by DateTime" do
      time = Time.now
      b = Bozon.create(:title => "To Search with Date Time", :author => 'Bloo Reguard', :created_at => time)
      Bozon.all(:created_at => time).length.should eql(1)
    end

    it "should be able to pull one field" do
      Bozon.create(:title => 'Story')
      Bozon.create(:title => 'Tail')
      
      # /bozon/[/id][={'title':title}]

      Bozon.all(:fields => [:title]).length.should == 2
    end

    it "should retrieve properties that end in a number" do
      Mukatron.create(:street1 => "11th", :b8te => 'true', :name => 'Porky')
      Mukatron.create(:street1 => "12th", :b8te => 'false', :name => 'Porky')

      # /mukatron/[/id][={id:id,'street1':street1,'b8te':b8te,name:name}]
      
      Mukatron.all(:fields => [:id,:street1]).length.should == 2
      Mukatron.first(:fields => [:id,:street1]).street1.should == "11th"
    end

    it "should retrieve properties that have a number in the middle" do
      Mukatron.create(:street1 => "11th", :b8te => 'true', :name => 'Porky')
      Mukatron.create(:street1 => "12th", :b8te => 'false', :name => 'Porky')
      # /mukatron/[/id][={'b8te':'b8te'}]

      Mukatron.all(:fields => [:b8te]).length.should == 2
    end
    
    it "should works with fields and properties that have different names" do
      Pantsarator.create(:id => 'pants', :pants => true)
      Pantsarator.create(:id => 'underware', :pants => false)
      
      result = @adapter.get_schema("pantsarator")
      result.should_not be_false
      result[0]['properties'].keys.should include('trousers')
      
      Pantsarator.all(:pants => true).length.should eql 1
      
    end
    
    after(:all) do
      Bozon.auto_migrate_down!
      Mukatron.auto_migrate_down!
      Pantsarator.auto_migrate_down!
    end
  end
  
  describe 'associations' do
    before(:all) do
      class ::BlogPost
        include DataMapper::Resource
        property :id, Serial
        property :title, String
        property :body, Text
        
        # property :comment, JsonReference, :reference => ::Comment
     end

      class ::Comment
        include DataMapper::Resource
        property :id,     Serial
        property :contents, Text
        property :rating, Integer
        
        property :blog_post, JsonReference, :reference => BlogPost
      end
      
      class ::Author
        include DataMapper::Resource
        property :id,     Serial
        property :name, String
      end

      class ::Address
        include DataMapper::Resource
        property :id,     Serial
        property :addr,   String
      end      
    end
    
    before(:each) do
      BlogPost.auto_migrate!
      Author.auto_migrate!
      Comment.auto_migrate!
      Address.auto_migrate!
      BlogPost.send(:property, :comments, DataMapper::Types::JsonReferenceCollection, :reference => :Comment)
      BlogPost.auto_migrate!
    end
    
    it "should create associations between models" do

      # Create the instances
      bpost = BlogPost.create(:title => "Test Post", :body => "This is the body of the test post.")
      comment = Comment.new(:contents => "I think the post is great!", :rating => 4)
      comment.blog_post = bpost
      # bpost.comment = comment
      # bpost.save
      comment.save
      
      Comment.first.blog_post.should be_kind_of(BlogPost)
      Comment.first.blog_post.id.should eql(1)
      
      # confirm it actually works with tests
      # bpost.comments.length.should eql 2
    end
    
    it "should be able to handle collections of relationships" do
      bpost = BlogPost.new(:title => "A new post", :body => "This one will have many comments")

      bpost.comments = [Comment.new(:contents => "This is the best", :rating => 5)]
      bpost.save
      BlogPost.first.comments.should be_kind_of(Array)
      BlogPost.first.comments.length.should eql(1)
      BlogPost.first.comments.first.should be_kind_of(Comment)

      bpost.comments << Comment.new(:contents => "No, this is the best!", :rating => 3)
      bpost.save
      BlogPost.first.comments.length.should eql(2)
    end
    
    after(:all) do
      BlogPost.auto_migrate_down!
      Author.auto_migrate_down!
      Address.auto_migrate_down!
      Comment.auto_migrate_down!
    end
  end
end