add database name to precog ingest path

gclaramunt · gclaramunt · commit e01200915722 · 2013-01-22T19:03:24.000-02:00
diff --git a/tools/import/mongodb/src/main/scala/com/precog/tools/importers/mongo/ImportMongo.scala b/tools/import/mongodb/src/main/scala/com/precog/tools/importers/mongo/ImportMongo.scala
@@ -86,7 +86,7 @@ object ImportMongo {
     }
     val (fds, fmaxId) = (fdsid map (_._1), fdsid map (_._2))
     val fjsons = fds.map(_.flatMap(MongoToJson(_).toStream))
-    val fullPath = "%s/ingest/v1/sync/fs%s/%s".format(precogHost, basePath, collName)
+    val fullPath = "%s/ingest/v1/sync/fs%s/%s/%s".format(precogHost, basePath, dbName, collName)
     val data = StreamT.fromStream[Future, JValue](fjsons)
     val fresult = M.lift2((a: HttpResponse[ByteChunk], b: ObjectId) => (a, b))(sendToPrecog(fullPath, apiKey, data), fmaxId)
 

Original file line number	Diff line number	Diff line change
`@@ -86,7 +86,7 @@ object ImportMongo {`
`86`	`86`	`}`
`87`	`87`	`val (fds, fmaxId) = (fdsid map (_._1), fdsid map (_._2))`
`88`	`88`	`val fjsons = fds.map(_.flatMap(MongoToJson(_).toStream))`
`89`		`- val fullPath = "%s/ingest/v1/sync/fs%s/%s".format(precogHost, basePath, collName)`
	`89`	`+ val fullPath = "%s/ingest/v1/sync/fs%s/%s/%s".format(precogHost, basePath, dbName, collName)`
`90`	`90`	`val data = StreamT.fromStream[Future, JValue](fjsons)`
`91`	`91`	`val fresult = M.lift2((a: HttpResponse[ByteChunk], b: ObjectId) => (a, b))(sendToPrecog(fullPath, apiKey, data), fmaxId)`
`92`	`92`