func (q *querier) GetUserActivityInsights(ctx context.Context, arg database.GetUserActivityInsightsParams) ([]database.GetUserActivityInsightsRow, error) {

panic("not implemented")

}

func (q *FakeQuerier) GetUserActivityInsights(ctx context.Context, arg database.GetUserActivityInsightsParams) ([]database.GetUserActivityInsightsRow, error) {

err := validateDatabaseType(arg)

if err != nil {

return nil, err

}

panic("not implemented")

}

WITH app_stats_by_user_and_agent AS (

SELECT

s.start_time,

60 as seconds,

w.template_id,

was.user_id

FROM workspace_app_stats was

JOIN workspaces w ON (

w.id = was.workspace_id

AND CASE WHEN COALESCE(array_length(@template_ids::uuid[], 1), 0) > 0 THEN w.template_id = ANY(@template_ids::uuid[]) ELSE TRUE END

)

-- This table contains both 1 minute entries and >1 minute entries,

-- to calculate this with our uniqueness constraints, we generate series

-- for the longer intervals.

CROSS JOIN LATERAL generate_series(

date_trunc('minute', was.session_started_at),

-- Subtract 1 microsecond to avoid creating an extra series.

date_trunc('minute', was.session_ended_at - '1 microsecond'::interval),

'1 minute'::interval

) s(start_time)

WHERE

s.start_time >= @start_time::timestamptz

-- Subtract one minute because the series only contains the start time.

AND s.start_time < (@end_time::timestamptz) - '1 minute'::interval

GROUP BY s.start_time, w.template_id, was.user_id

)

users.id,

users.username,

users.avatar_url,

array_agg(DISTINCT template_id)::uuid[] AS template_ids,

SUM(seconds) AS usage_seconds

FROM app_stats_by_user_and_agent

JOIN users ON (users.id = app_stats_by_user_and_agent.user_id)

GROUP BY user_id, username, avatar_url

ORDER BY user_id ASC;