Release 1.99.0:

* exclude 2.x versions of the mongo gem dependency
* Add :user and :password options to initialization, to authenticate against Mongo Connection.
* Don't insert incomplete statements.
* Use `graph_name`, not `context`.

Author: gkellogg

.travis.yml

@@ -5,8 +5,11 @@ env:
   - CI=true
 rvm:
   - 1.9.3
-  - 2.0.0
-  - jruby-19mode
-  - rbx
+  - 2.0
+  - 2.1
+  - 2.2
+  - jruby
+  - rbx-2
 services:
   - mongodb
+cache: bundler

Gemfile

@@ -2,9 +2,14 @@ source "http://rubygems.org"
 
 gemspec
 
-gem "rdf",            :git => "git://github.com/ruby-rdf/rdf.git", :branch => "develop"
+gem "rdf",            git: "git://github.com/ruby-rdf/rdf.git", branch: "develop"
 
 group :development do
-  gem "rdf-spec",       :git => "git://github.com/ruby-rdf/rdf-spec.git", :branch => "develop"
+  gem "rdf-spec",       git: "git://github.com/ruby-rdf/rdf-spec.git", branch: "develop"
   gem "wirble"
 end
+
+platforms :rbx do
+  gem 'rubysl', '~> 2.0'
+  gem 'rubinius', '~> 2.0'
+end

Rakefile

@@ -5,7 +5,7 @@ require 'rspec/core/rake_task'
 namespace :gem do
   desc "Build the rdf-mongo-#{File.read('VERSION').chomp}.gem file"
   task :build do
-    sh "gem build .gemspec && mv rdf-mongo-#{File.read('VERSION').chomp}.gem pkg/"
+    sh "gem build rdf-mongo.gemspec && mv rdf-mongo-#{File.read('VERSION').chomp}.gem pkg/"
   end
 
   desc "Release the rdf-mongo-#{File.read('VERSION').chomp}.gem file"
@@ -34,5 +34,5 @@ namespace :doc do
   end
 end
 
-task :default => :spec
-task :specs => :spec
+task default: :spec
+task specs: :spec

VERSION

@@ -1 +1 @@
-1.1.0
+1.99.0

lib/rdf/mongo.rb

@@ -14,17 +14,17 @@ def to_mongo
     end
 
     ##
-    # Create BSON for a statement representation. Note that if the statement has no context,
+    # Create BSON for a statement representation. Note that if the statement has no graph name,
     # a value of `false` will be used to indicate the default context
     #
     # @param [RDF::Statement] statement
     # @return [Hash] Generated BSON representation of statement.
     def self.from_mongo(statement)
       RDF::Statement.new(
-        :subject   => RDF::Mongo::Conversion.from_mongo(statement['s'], statement['st'], statement['sl']),
-        :predicate => RDF::Mongo::Conversion.from_mongo(statement['p'], statement['pt'], statement['pl']),
-        :object    => RDF::Mongo::Conversion.from_mongo(statement['o'], statement['ot'], statement['ol']),
-        :context   => RDF::Mongo::Conversion.from_mongo(statement['c'], statement['ct'], statement['cl']))
+        subject:    RDF::Mongo::Conversion.from_mongo(statement['s'], statement['st'], statement['sl']),
+        predicate:  RDF::Mongo::Conversion.from_mongo(statement['p'], statement['pt'], statement['pl']),
+        object:     RDF::Mongo::Conversion.from_mongo(statement['o'], statement['ot'], statement['ol']),
+        graph_name: RDF::Mongo::Conversion.from_mongo(statement['c'], statement['ct'], statement['cl']))
     end
   end
 
@@ -37,9 +37,9 @@ class Conversion
       #
       # @param [RDF::Value, Symbol, false, nil] value
       #   URI, BNode or Literal. May also be a Variable or Symbol to indicate
-      #   a pattern for a named context, or `false` to indicate the default context.
+      #   a pattern for a named graph, or `false` to indicate the default graph.
       #   A value of `nil` indicates a pattern that matches any value.
-      # @param [:subject, :predicate, :object, :context] place_in_statement
+      # @param [:subject, :predicate, :object, :graph_name] place_in_statement
       #   Position within statement.
       # @return [Hash] BSON representation of the statement
       def self.to_mongo(value, place_in_statement)
@@ -76,7 +76,7 @@ def self.to_mongo(value, place_in_statement)
           t, k1, lt = :pt, :p, :pl
         when :object
           t, k1, lt = :ot, :o, :ol
-        when :context
+        when :graph_name
           t, k1, lt = :ct, :c, :cl
         end
         h = {k1 => v, t => k, lt => ll}
@@ -92,9 +92,9 @@ def self.from_mongo(value, value_type = :u, literal_extra = nil)
         when :u
           RDF::URI.intern(value)
         when :ll
-          RDF::Literal.new(value, :language => literal_extra.to_sym)
+          RDF::Literal.new(value, language: literal_extra.to_sym)
         when :lt
-          RDF::Literal.new(value, :datatype => RDF::URI.intern(literal_extra))
+          RDF::Literal.new(value, datatype: RDF::URI.intern(literal_extra))
         when :l
           RDF::Literal.new(value)
         when :n
@@ -126,12 +126,15 @@ class Repository < ::RDF::Repository
       # @option options [String] :host
       # @option options [Integer] :port
       # @option options [String] :db
+      # @option options [String] :user for authentication
+      # @option options [String] :password for authentication
       # @option options [String] :collection ('quads')
       # @yield  [repository]
       # @yieldparam [Repository] repository
       def initialize(options = {}, &block)
-        options = {:host => 'localhost', :port => 27017, :db => 'quadb', :collection => 'quads'}.merge(options)
+        options = {host: 'localhost', port: 27017, db: 'quadb', collection: 'quads'}.merge(options)
         @db = ::Mongo::Connection.new(options[:host], options[:port]).db(options[:db])
+        @db.authenticate(options[:user], options[:password]) if options[:user] && options[:password]
         @coll = @db[options[:collection]]
         @coll.create_index("s")
         @coll.create_index("p")
@@ -146,21 +149,22 @@ def initialize(options = {}, &block)
       # @see RDF::Mutable#insert_statement
       def supports?(feature)
         case feature.to_sym
-          when :context then true
+          when :graph_name then true
           else false
         end
       end
 
       def insert_statement(statement)
+        raise ArgumentError, "Statement #{statement.inspect} is incomplete" if statement.incomplete?
         st_mongo = statement.to_mongo
-        st_mongo[:ct] ||= :default # Indicate statement is in the default context
+        st_mongo[:ct] ||= :default # Indicate statement is in the default graph
         #puts "insert statement: #{st_mongo.inspect}"
-        @coll.update(st_mongo, st_mongo, :upsert => true)
+        @coll.update(st_mongo, st_mongo, upsert: true)
       end
 
       # @see RDF::Mutable#delete_statement
       def delete_statement(statement)
-        case statement.context
+        case statement.graph_name
         when nil
           @coll.remove(statement.to_mongo.merge('ct'=>:default))
         else
@@ -213,8 +217,8 @@ def each_statement(&block)
 
       ##
       # @private
-      # @see RDF::Enumerable#has_context?
-      def has_context?(value)
+      # @see RDF::Enumerable#has_graph?
+      def has_graph?(value)
         !!@coll.find_one(RDF::Mongo::Conversion.to_mongo(value, :context))
       end
 
@@ -227,9 +231,9 @@ def has_context?(value)
       def query_pattern(pattern, &block)
         @nodes = {} # reset cache. FIXME this should probably be in Node.intern
 
-        # A pattern context of `false` is used to indicate the default context
+        # A pattern graph_name of `false` is used to indicate the default graph
         pm = pattern.to_mongo
-        pm.merge!(:c => nil, :ct => :default) if pattern.context == false
+        pm.merge!(c: nil, ct: :default) if pattern.graph_name == false
         #puts "query using #{pm.inspect}"
         @coll.find(pm) do |cursor|
           cursor.each do |data|

rdf-mongo.gemfile

@@ -27,14 +27,15 @@ Gem::Specification.new do |gem|
   gem.test_files         = Dir.glob('spec/*.spec')
   gem.has_rdoc           = false
 
-  gem.required_ruby_version      = '>= 1.9.2'
+  gem.required_ruby_version      = '>= 1.9.3'
   gem.requirements               = []
-  gem.add_runtime_dependency     'rdf',         '>= 1.1'
-  gem.add_runtime_dependency     'mongo',       '>= 1.8.6',    '< 2.0'
+  gem.add_runtime_dependency     'rdf',             '~> 1.99'
+  gem.add_runtime_dependency     'mongo',           '~> 1.10'
 
-  gem.add_development_dependency 'rdf-spec',    '>= 1.1'
-  gem.add_development_dependency 'rspec',       '>= 2.14.0'
-  gem.add_development_dependency 'yard' ,       '>= 0.8.7'
+  gem.add_development_dependency 'rdf-spec',        '~> 1.99'
+  gem.add_development_dependency 'rspec',           '~> 3.0'
+  gem.add_development_dependency 'rspec-its',       '~> 1.0'
+  gem.add_development_dependency 'yard' ,           '~> 0.8'
   gem.add_development_dependency 'bson_ext' unless  defined?(:RUBY_ENGINE) && RUBY_ENGINE == "jruby"
 
   # Rubinius has it's own dependencies

.gemspec rdf-mongo.gemspec.gemspec renamed to rdf-mongo.gemspec

@@ -5,19 +5,31 @@
 require 'rdf/mongo'
 
 describe RDF::Mongo::Repository do
-  context "Mongo RDF Repository" do
-    before :each do
-      @repository = RDF::Mongo::Repository.new() # TODO: Do you need constructor arguments?
-      @repository.coll.drop
-    end
-   
-    after :each do
-      @repository.coll.drop
-    end
+  before :each do
+    @repository = RDF::Mongo::Repository.new() # TODO: Do you need constructor arguments?
+    @repository.coll.drop
+  end
+ 
+  after :each do
+    @repository.coll.drop
+  end
 
-    # @see lib/rdf/spec/repository.rb in RDF-spec
-    include RDF_Repository
+  # @see lib/rdf/spec/repository.rb in RDF-spec
+  it_behaves_like "an RDF::Repository" do
+    let(:repository) {@repository}
   end
 
+  context "problemantic examples" do
+    subject {@repository}
+    {
+      "Insert key too large to index" => %(
+        <http://repository.librario.de/publications/0cbdc7f4-728d-4f85-ab09-01060c7b2922> <http://purl.org/ontology/bibo/abstract> "#{'a' * 1001}" .
+      )
+    }.each do |name, nt|
+      it name do
+        expect {subject << RDF::Graph.new << RDF::NTriples::Reader.new(nt)}.not_to raise_error
+      end
+    end
+  end
 end
 

spec/mongo_repository_spec.rb

@@ -4,9 +4,9 @@
 require 'rdf/mongo'
 
 RSpec.configure do |config|
-  config.filter_run :focus => true
+  config.filter_run focus: true
   config.run_all_when_everything_filtered = true
   config.exclusion_filter = {
-    :ruby           => lambda { |version| RUBY_VERSION.to_s !~ /^#{version}/},
+    ruby:           lambda { |version| RUBY_VERSION.to_s !~ /^#{version}/},
   }
 end