added support for context via options

Author: bergos

lib/ParserStream.js

@@ -13,6 +13,7 @@ class ParserStream extends Readable {
     options = options || {}
 
     this.baseIRI = options.baseIRI || ''
+    this.context = options.context
     this.factory = options.factory || rdf
     this.blankNodes = {}
 
@@ -62,7 +63,14 @@ class ParserStream extends Readable {
         })
       }
 
-      return jsonld.promises().toRDF(json, {base: this.baseIRI})
+      const toRdfOptions = {base: this.baseIRI}
+
+      // use context from options if given
+      if (this.context) {
+        toRdfOptions.expandContext = this.context
+      }
+
+      return jsonld.promises().toRDF(json, toRdfOptions)
     }).then((rawGraph) => {
       Object.keys(rawGraph).forEach((graphIri) => {
         const graph = graphIri !== '@default' ? this.factory.namedNode(graphIri) : null

test/test.js

@@ -265,6 +265,34 @@ describe('rdf-parser-jsond', () => {
     })
   })
 
+  it('should use context option', () => {
+    const example = {
+      '@id': 'subject',
+      'predicate': 'object'
+    }
+
+    const context = {
+      '@vocab': 'http://example.org/'
+    }
+
+    const parser = new JSONLDParser({
+      baseIRI: 'http://example.org/',
+      context: context
+    })
+    const stream = parser.import(stringToStream(JSON.stringify(example)))
+    const output = []
+
+    stream.on('data', (triple) => {
+      output.push(triple)
+    })
+
+    return rdf.waitFor(stream).then(() => {
+      assert.equal(output.length, 1)
+      assert.equal(output[0].subject.termType, 'NamedNode')
+      assert.equal(output[0].subject.value, 'http://example.org/subject')
+    })
+  })
+
   it('should throw an error if JSON is invalid', () => {
     let parser = new JSONLDParser()
     let stream = parser.import(stringToStream('{'))