def observeResults()

in tweetypie/server/src/main/scala/com/twitter/tweetypie/service/observer/GetTweetsObserver.scala [34:98]
62 lines of code
23 McCabe index (conditional complexity)

  def observeResults(stats: StatsReceiver, byClient: Boolean): Effect[Seq[GetTweetResult]] =
    countStates(stats).also(countTweetReadAttributes(stats, byClient))

  def observeRequest(stats: StatsReceiver, byClient: Boolean): Effect[GetTweetsRequest] = {
    val requestSizeStat = stats.stat("request_size")
    val optionsScope = stats.scope("options")
    val languageScope = optionsScope.scope("language")
    val includeSourceTweetCounter = optionsScope.counter("source_tweet")
    val includeQuotedTweetCounter = optionsScope.counter("quoted_tweet")
    val includePerspectiveCounter = optionsScope.counter("perspective")
    val includeConversationMutedCounter = optionsScope.counter("conversation_muted")
    val includePlacesCounter = optionsScope.counter("places")
    val includeCardsCounter = optionsScope.counter("cards")
    val includeRetweetCountsCounter = optionsScope.counter("retweet_counts")
    val includeReplyCountsCounter = optionsScope.counter("reply_counts")
    val includeFavoriteCountsCounter = optionsScope.counter("favorite_counts")
    val includeQuoteCountsCounter = optionsScope.counter("quote_counts")
    val bypassVisibilityFilteringCounter = optionsScope.counter("bypass_visibility_filtering")
    val excludeReportedCounter = optionsScope.counter("exclude_reported")
    val cardsPlatformKeyScope = optionsScope.scope("cards_platform_key")
    val extensionsArgsCounter = optionsScope.counter("extensions_args")
    val doNotCacheCounter = optionsScope.counter("do_not_cache")
    val additionalFieldsScope = optionsScope.scope("additional_fields")
    val safetyLevelScope = optionsScope.scope("safety_level")
    val includeProfileGeoEnrichment = optionsScope.counter("profile_geo_enrichment")
    val includeMediaAdditionalMetadata = optionsScope.counter("media_additional_metadata")
    val simpleQuotedTweet = optionsScope.counter("simple_quoted_tweet")
    val forUserIdCounter = optionsScope.counter("for_user_id")

    def includesPerspectivals(options: GetTweetOptions) =
      options.includePerspectivals && options.forUserId.nonEmpty

    Effect {
      case GetTweetsRequest(tweetIds, _, Some(options), _) =>
        requestSizeStat.add(tweetIds.size)
        if (!byClient) languageScope.counter(options.languageTag).incr()
        if (options.includeSourceTweet) includeSourceTweetCounter.incr()
        if (options.includeQuotedTweet) includeQuotedTweetCounter.incr()
        if (includesPerspectivals(options)) includePerspectiveCounter.incr()
        if (options.includeConversationMuted) includeConversationMutedCounter.incr()
        if (options.includePlaces) includePlacesCounter.incr()
        if (options.includeCards) includeCardsCounter.incr()
        if (options.includeRetweetCount) includeRetweetCountsCounter.incr()
        if (options.includeReplyCount) includeReplyCountsCounter.incr()
        if (options.includeFavoriteCount) includeFavoriteCountsCounter.incr()
        if (options.includeQuoteCount) includeQuoteCountsCounter.incr()
        if (options.bypassVisibilityFiltering) bypassVisibilityFilteringCounter.incr()
        if (options.excludeReported) excludeReportedCounter.incr()
        if (options.extensionsArgs.nonEmpty) extensionsArgsCounter.incr()
        if (options.doNotCache) doNotCacheCounter.incr()
        if (options.includeProfileGeoEnrichment) includeProfileGeoEnrichment.incr()
        if (options.includeMediaAdditionalMetadata) includeMediaAdditionalMetadata.incr()
        if (options.simpleQuotedTweet) simpleQuotedTweet.incr()
        if (options.forUserId.nonEmpty) forUserIdCounter.incr()
        if (!byClient) {
          options.cardsPlatformKey.foreach { cardsPlatformKey =>
            cardsPlatformKeyScope.counter(cardsPlatformKey).incr()
          }
        }
        options.additionalFieldIds.foreach { id =>
          additionalFieldsScope.counter(id.toString).incr()
        }
        options.safetyLevel.foreach { level => safetyLevelScope.counter(level.toString).incr() }
    }
  }