Method getActivitySummary

server/src/db/slack-db.ts:569–615

* Get activity summary for a Slack user

(slackUserId: string, options: {
    days?: number;
  } = {})

   * Get activity summary for a Slack user
   */
  async getActivitySummary(slackUserId: string, options: {
    days?: number;
  } = {}): Promise<{
    total_messages: number;
    total_reactions: number;
    total_thread_replies: number;
    total_channel_joins: number;
    total_activity: number;
    active_days: number;
    last_activity_at: Date | null;
  }> {
    const days = options.days ?? 30;

    const result = await query<{
      total_messages: string;
      total_reactions: string;
      total_thread_replies: string;
      total_channel_joins: string;
      total_activity: string;
      active_days: string;
    }>(
      `SELECT
        COALESCE(SUM(message_count), 0)::text as total_messages,
        COALESCE(SUM(reaction_count), 0)::text as total_reactions,
        COALESCE(SUM(thread_reply_count), 0)::text as total_thread_replies,
        COALESCE(SUM(channel_join_count), 0)::text as total_channel_joins,
        COALESCE(SUM(total_activity), 0)::text as total_activity,
        COUNT(*)::text as active_days
       FROM slack_activity_daily
       WHERE slack_user_id = $1
         AND activity_date >= CURRENT_DATE - $2::integer`,
      [slackUserId, days]
    );

    const mapping = await this.getBySlackUserId(slackUserId);

    const row = result.rows[0];
    return {
      total_messages: parseInt(row.total_messages, 10),
      total_reactions: parseInt(row.total_reactions, 10),
      total_thread_replies: parseInt(row.total_thread_replies, 10),
      total_channel_joins: parseInt(row.total_channel_joins, 10),
      total_activity: parseInt(row.total_activity, 10),
      active_days: parseInt(row.active_days, 10),
      last_activity_at: mapping?.last_slack_activity_at || null,
    };
  }

  /**
   * Get organization activity summary from Slack (aggregates all mapped users)