From 18a9061d56ee20e74ccdf0f083a354182603ec7f Mon Sep 17 00:00:00 2001
From: Jesse Crocker <jesse@gaiagps.com>
Date: Tue, 13 Nov 2018 09:00:27 -0700
Subject: [PATCH] fix error in last release

---
 lib/cacher.js | 10 +++++-----
 package.json  |  2 +-
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/lib/cacher.js b/lib/cacher.js
index 248be9f..8d31f88 100644
--- a/lib/cacher.js
+++ b/lib/cacher.js
@@ -69,7 +69,7 @@ module.exports = function(opts) {
       pipe.on("data", function processLine(line) {
         if (line.length) {
           requestCount++;
-          processRequest(
+          processRequestMessage(
             line,
             function() {
               debug("Request finished " + line);
@@ -149,7 +149,7 @@ module.exports = function(opts) {
               return errorC(err);
             }
             sinks[sourceName] = dest;
-            processRequest(tileComponents, source, dest, success, errorC);
+            processRequest(tileComponents, source, dest, sourceName, success, errorC);
           });
         });
       } else {
@@ -158,11 +158,11 @@ module.exports = function(opts) {
         return errorC(null);
       }
     } else {
-      processRequest(tileComponents, source, dest, success, errorC);
+      processRequest(tileComponents, source, dest, sourceName, success, errorC);
     }
   }
 
-  function processRequest(tileComponents, source, dest, success, errorC) {
+  function processRequest(tileComponents, source, dest, sourceName, success, errorC) {
     var z = parseInt(tileComponents[0]);
     var startX, endX, startY, endY;
     var xComponents = tileComponents[1].split("-");
@@ -181,7 +181,7 @@ module.exports = function(opts) {
       endY = parseInt(yComponents[1]);
     }
 
-    debug("opening source " + config[sourceName]["destination"] + " for writing");
+    debug("opening source " + destination + " for writing");
     dest.startWriting(function(err) {
       if (err) {
         console.log(err);
diff --git a/package.json b/package.json
index 39a47e1..d08c785 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "tile-squirrel",
-  "version": "1.6.0",
+  "version": "1.6.1",
   "description": "Tile Squirrel reads from a rabbit queue and cache tiles from a tilelive source to a tilelive sink",
   "main": "lib/cacher.js",
   "bin": "bin/squirrel.js",