fix issue if key is specified, use that url

toHero · Mar 30, 2017 · 218a256 · 218a256
1 parent ebd2f58
commit 218a256
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lib/index.js b/lib/index.js
@@ -60,6 +60,7 @@ module.exports = function (config, log, since) {
 
     var doc = change.doc
     var es_doc_url = config.elasticsearch + '/' + change.id
+    if (config.key) es_doc_url = config.elasticsearch + '/' + doc[config.key]
     if (config.urlTemplate) es_doc_url = run_compile(es_doc_url, doc, log)
     if (doc._deleted) return handle_delete(config, es_doc_url, change, log, onDone, endTask)