feat: Added timeframe and status parameter to list_problems tool

Author: christian-kreuzberger-dtx

CHANGELOG.md

@@ -1,5 +1,12 @@
 # @dynatrace-oss/dynatrace-mcp-server
 
+## Unreleased Changes
+
+### Tools
+
+- Added `status` parameter to `list_problems` tool to filter problems by status (ACTIVE, CLOSED, or ALL).
+- Added `timeframe` parameter to `list_problems` tool to support flexible time ranges (e.g., "12h", "24h", "7d", "30d"). Default: "24h".
+
 ## 0.12.0
 
 - Fixed OAuth callback URL to work in GitHub Codespaces by detecting the environment and using the forwarded URL instead of localhost

src/capabilities/list-problems.ts

@@ -1,13 +1,35 @@
 import { HttpClient } from '@dynatrace-sdk/http-client';
 import { executeDql } from './execute-dql';
 
-export const listProblems = async (dtClient: HttpClient, additionalFilter?: string) => {
-  // DQL Statement from Problems App to fetch all Davis Problems for the last 12 hours to now
-  const dql = `fetch dt.davis.problems, from: now()-12h, to: now()
+/**
+ * List all problems via dt.davis.problems
+ * @param dtClient Dynatrace HTTP Client
+ * @param additionalFilter Any additional DQL filter
+ * @param status Status (ACTIVE, CLOSED, or ALL)
+ * @param timeframe Timeframe to query problems (e.g., '24h', '7d', '30d'). Default: '24h'
+ * @returns DQL query result
+ */
+export const listProblems = async (
+  dtClient: HttpClient,
+  additionalFilter?: string,
+  status?: string,
+  timeframe: string = '24h',
+) => {
+  // DQL Statement from Problems App to fetch all Davis Problems
+  let statusFilter = '';
+  if (status === 'ACTIVE') {
+    statusFilter = '| filter isNull(event.end)';
+  } else if (status === 'CLOSED') {
+    statusFilter = '| filter not(isNull(event.end))';
+  }
+  // For 'ALL' or undefined, no additional filter
+
+  const dql = `fetch dt.davis.problems, from: now()-${timeframe}, to: now()
 | filter isNull(dt.davis.is_duplicate) OR not(dt.davis.is_duplicate)
+${statusFilter}
 ${additionalFilter ? `| filter ${additionalFilter}` : ''}
 | fieldsAdd
-   duration = coalesce(event.end, now()) - event.start,
+   duration = (coalesce(event.end, now()) - event.start)/1000000000,
    affected_entities_count = arraySize(affected_entity_ids),
    event_count = arraySize(dt.davis.event_ids),
    affected_users_count = dt.davis.affected_users_count,
@@ -20,7 +42,7 @@ ${additionalFilter ? `| filter ${additionalFilter}` : ''}
          dt.cost.costcenter, dt.cost.product, dt.host_group.id, dt.security_context, gcp.project.id,
          host.name,
          k8s.cluster.name, k8s.cluster.uid, k8s.container.name, k8s.namespace.name, k8s.node.name, k8s.pod.name, k8s.service.name, k8s.workload.kind, k8s.workload.name
-| sort event.status asc, event.start desc
+| sort event.start desc
 `;
 
   return await executeDql(dtClient, { query: dql, maxResultRecords: 5000, maxResultBytes: /* 5 MB */ 5000000 });

src/index.ts

@@ -399,40 +399,59 @@ const main = async () => {
 
   tool(
     'list_problems',
-    'List all problems (dt.davis.problems) known on Dynatrace, sorted by their recency, for the last 12h. An additional DQL based filter, like filtering for specific entities, can be provided.',
+    'List all problems (based on "fetch dt.davis.problems") known on Dynatrace, sorted by their recency.',
     {
+      timeframe: z
+        .string()
+        .optional()
+        .default('24h')
+        .describe(
+          'Timeframe to query problems (e.g., "12h", "24h", "7d", "30d"). Default: "24h". Supports hours (h) and days (d).',
+        ),
+      status: z
+        .enum(['ACTIVE', 'CLOSED', 'ALL'])
+        .optional()
+        .default('ALL')
+        .describe(
+          'Fitler problems by their status. "ACTIVE": only active problems (those without an end time set), "CLOSED": only closed problems (those with an end time set), "ALL": active and closed problems (default)',
+        ),
       additionalFilter: z
         .string()
         .optional()
         .describe(
           'Additional DQL filter for dt.davis.problems - filter by entity type (preferred), like \'dt.entity.<service|host|application|$type> == "<entity-id>"\', or by entity tags \'entity_tags == array("dt.owner:team-foobar", "tag:tag")\'',
         ),
-      maxProblemsToDisplay: z.number().default(10).describe('Maximum number of problems to display in the response.'),
+      maxProblemsToDisplay: z
+        .number()
+        .min(1)
+        .max(5000)
+        .default(10)
+        .describe('Maximum number of problems to display in the response.'),
     },
     {
       readOnlyHint: true,
     },
-    async ({ additionalFilter, maxProblemsToDisplay }) => {
+    async ({ timeframe, status, additionalFilter, maxProblemsToDisplay }) => {
       const dtClient = await createAuthenticatedHttpClient(
         scopesBase.concat('storage:events:read', 'storage:buckets:read'),
       );
       // get problems (uses fetch)
-      const result = await listProblems(dtClient, additionalFilter);
+      const result = await listProblems(dtClient, additionalFilter, status, timeframe);
       if (result && result.records && result.records.length > 0) {
         let resp = `Found ${result.records.length} problems! Displaying the top ${maxProblemsToDisplay} problems:\n`;
         // iterate over dqlResponse and create a string with the problem details, but only show the top maxProblemsToDisplay problems
         result.records.slice(0, maxProblemsToDisplay).forEach((problem) => {
           if (problem) {
             resp += `Problem ${problem['display_id']} (please refer to this problem with \`problemId\` or \`event.id\` ${problem['problem_id']}))
                   with event.status ${problem['event.status']}, event.category ${problem['event.category']}: ${problem['event.name']} -
-                  affects ${problem['affected_users_count']} users and ${problem['affected_entity_count']} entities for a duration of ${problem['duration']}\n`;
+                  affects ${problem['affected_users_count']} users and ${problem['affected_entity_count']} entities for a duration of ${problem['duration']}s\n`;
           }
         });
 
         resp +=
           `\nNext Steps:` +
           `\n1. Use "execute_dql" tool with the following query to get more details about a specific problem:
-          "fetch dt.davis.problems, from: now()-10h, to: now() | filter event.id == \"<problem-id>\" | fields event.description, event.status, event.category, event.start, event.end,
+          "fetch dt.davis.problems, from: now()-${timeframe}, to: now() | filter event.id == \"<problem-id>\" | fields event.description, event.status, event.category, event.start, event.end,
             root_cause_entity_id, root_cause_entity_name, duration, affected_entities_count,
             event_count, affected_users_count, problem_id, dt.davis.mute.status, dt.davis.mute.user,
             entity_tags, labels.alerting_profile, maintenance.is_under_maintenance,