get-current-observations-by-reporting-area-by-lat-long

Instructions

Implementation Reference

• src/tools/current-observations-by-reporting-area-by-lat-long.ts:28-52 (handler)

  The MCP tool handler function that fetches data using the AirNow API helper and returns it as text content or an error message.

  async (params) => {
    const result =
      await airnowApi.fetchCurrentObservationsByReportingAreaByLatLong(
        params
      );
    if (result === null) {
      return {
        content: [
          {
            type: "text",
            text: "Failed to fetch current observations data from AirNow API.",
          },
        ],
        isError: true,
      };
    }
    return {
      content: [
        {
          type: "text",
          text: result,
        },
      ],
    };
  }

• src/tools/current-observations-by-reporting-area-by-lat-long.ts:9-27 (schema)

  Zod schema for tool input parameters: latitude, longitude, format, and optional distance.

  {
    latitude: z
      .string()
      .describe("Latitude in decimal degrees. Example: 38.33"),
    longitude: z
      .string()
      .describe("Longitude in decimal degrees. Example: -122.28"),
    format: z
      .enum(["text/csv", "application/json", "application/xml"])
      .describe(
        "Format of the payload file returned. Example: application/json"
      ),
    distance: z
      .string()
      .optional()
      .describe(
        "If no reporting area is associated with the latitude and longitude, current observations from a nearby reporting area within this distance (in miles) will be returned, if available. Example: 150"
      ),
  },

• src/tools/current-observations-by-reporting-area-by-lat-long.ts:6-53 (registration)

  The server.tool call that registers the tool, including name, description, input schema, and handler function.

  server.tool(
    "get-current-observations-by-reporting-area-by-lat-long",
    "Get current AQI values and categories for a reporting area by latitude and longitude.",
    {
      latitude: z
        .string()
        .describe("Latitude in decimal degrees. Example: 38.33"),
      longitude: z
        .string()
        .describe("Longitude in decimal degrees. Example: -122.28"),
      format: z
        .enum(["text/csv", "application/json", "application/xml"])
        .describe(
          "Format of the payload file returned. Example: application/json"
        ),
      distance: z
        .string()
        .optional()
        .describe(
          "If no reporting area is associated with the latitude and longitude, current observations from a nearby reporting area within this distance (in miles) will be returned, if available. Example: 150"
        ),
    },
    async (params) => {
      const result =
        await airnowApi.fetchCurrentObservationsByReportingAreaByLatLong(
          params
        );
      if (result === null) {
        return {
          content: [
            {
              type: "text",
              text: "Failed to fetch current observations data from AirNow API.",
            },
          ],
          isError: true,
        };
      }
      return {
        content: [
          {
            type: "text",
            text: result,
          },
        ],
      };
    }
  );

• src/airnow-api.ts:52-61 (helper)

  Helper function that constructs the API request to AirNow's current observations endpoint by lat/long and calls the generic airnowGet fetcher.

  export async function fetchCurrentObservationsByReportingAreaByLatLong(params: Record<string, string>): Promise<string | null> {
    const endpoint = 'aq/observation/latlong/current/';
    const queryParams = new URLSearchParams();
    queryParams.append('latitude', params.latitude);
    queryParams.append('longitude', params.longitude);
    queryParams.append('format', params.format);
    if (params.distance) queryParams.append('distance', params.distance);
  
    return airnowGet(endpoint, queryParams);
  }

• src/tools/index.ts:18-18 (registration)

  Invocation of the tool registration function within the central registerTools function.

  registerCurrentObservationsByLatLong(server);