recently published

bizo · Feb 20, 2015 · 13daf9e · 13daf9e
1 parent 835b816
commit 13daf9e
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 0 deletions.
diff --git a/src/main/scala/depsearch/db/CachedDependencyDB.scala b/src/main/scala/depsearch/db/CachedDependencyDB.scala
@@ -36,6 +36,10 @@ class CachedDependencyDB(db: DependencyDB) extends DependencyDB {
     downstreamCache.get(DependencyGroup(org, group))
   }
 
+  override def recentlyPublished(limit: Int): Seq[Dependency] = {
+    db.recentlyPublished(limit)
+  }
+
   override def stats(): IndexStats = db.stats
   override def setLastUpdated(when: java.util.Date) = db.setLastUpdated(when)
 }
diff --git a/src/main/scala/depsearch/db/DependencyDB.scala b/src/main/scala/depsearch/db/DependencyDB.scala
@@ -8,6 +8,8 @@ trait DependencyDB {
   def dependency(org: String, group: String, numVersions: Int): Option[DependencyResult]
   def downstream(org: String, group: String): Seq[DependencyGroup]
 
+  def recentlyPublished(limit: Int): Seq[Dependency]
+
   def stats(): IndexStats
   def setLastUpdated(when: java.util.Date)
 }
diff --git a/src/main/scala/depsearch/db/mongo/MongoDependencyDB.scala b/src/main/scala/depsearch/db/mongo/MongoDependencyDB.scala
@@ -98,6 +98,15 @@ class MongoDependencyDB(db: DB) extends DependencyDB {
     )
   }
 
+  override def recentlyPublished(limit: Int): Seq[Dependency] = {
+    val cur = db.getCollection("repo_v2").find()
+    cur.sort(new BasicDBObject("publication", -1))
+
+    val results = cur.limit(limit).toArray().asScala
+
+    results.map { toDependency }
+  }
+
   override def setLastUpdated(when: java.util.Date) {
     val col = db.getCollection("repo_v2_meta")