Skip to content

Commit

Permalink
no insights for the current release
Browse files Browse the repository at this point in the history
  • Loading branch information
AndriusA committed Jul 9, 2018
1 parent 420a02f commit 2bea135
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions hat/app/org/hatdex/hat/she/service/FeedGeneratorService.scala
Original file line number Diff line number Diff line change
Expand Up @@ -70,10 +70,10 @@ class FeedGeneratorService @Inject() ()(
"activity-records" new InsightsMapper())

def getFeed(endpoint: String, since: Option[Long], until: Option[Long], mergeLocations: Boolean = false)(implicit hatServer: HatServer): Future[Seq[DataFeedItem]] =
feedForMappers(dataMappers.filter(_._1.startsWith(endpoint)), since, until, mergeLocations, includeInsights = false)
feedForMappers(dataMappers.filter(_._1.startsWith(endpoint)), since, until, mergeLocations)

def fullFeed(since: Option[Long], until: Option[Long], mergeLocations: Boolean = false)(implicit hatServer: HatServer): Future[Seq[DataFeedItem]] =
feedForMappers(dataMappers, since, until, mergeLocations, includeInsights = true)
feedForMappers(dataMappers, since, until, mergeLocations)

def insights(since: Option[Long], until: Option[Long])(implicit hatServer: HatServer): Source[DataFeedItem, NotUsed] = {
val now = DateTime.now()
Expand All @@ -91,7 +91,7 @@ class FeedGeneratorService @Inject() ()(
private val defaultTimeBack = 180.days
private val defaultTimeForward = 30.days
protected def feedForMappers(mappers: Seq[(String, DataEndpointMapper)], since: Option[Long], until: Option[Long],
mergeLocations: Boolean, includeInsights: Boolean)(
mergeLocations: Boolean)(
implicit
hatServer: HatServer): Future[Seq[DataFeedItem]] = {
logger.debug(s"Fetching feed data for ${mappers.unzip._1}")
Expand Down

0 comments on commit 2bea135

Please sign in to comment.