import {z} from 'zod' export type GetApiStationsStationIdObservationsTimeArgs = {time: string}; export type GetApiStationsStationIdObservationsTimeOptions = {baseUrl?: string | undefined, userAgent?: string | undefined, fetch?: typeof fetch | undefined}; export const jsonLdContext = z.union([z.array(z.unknown()), z.object({})]); export const geoJsonCoordinate = z.array(z.number()); export const geoJsonBoundingBox = z.array(z.number()); export const geoJsonLineString = z.array(geoJsonCoordinate); export const geoJsonPolygon = z.array(z.array(geoJsonCoordinate)); export const geoJsonGeometry = z.union([z.object({type: z.literal("Point"), coordinates: geoJsonCoordinate, bbox: geoJsonBoundingBox.optional()}), z.object({type: z.literal("LineString"), coordinates: geoJsonLineString, bbox: geoJsonBoundingBox.optional()}), z.object({type: z.literal("Polygon"), coordinates: geoJsonPolygon, bbox: geoJsonBoundingBox.optional()}), z.object({type: z.literal("MultiPoint"), coordinates: z.array(geoJsonCoordinate), bbox: geoJsonBoundingBox.optional()}), z.object({type: z.literal("MultiLineString"), coordinates: z.array(geoJsonLineString), bbox: geoJsonBoundingBox.optional()}), z.object({type: z.literal("MultiPolygon"), coordinates: z.array(geoJsonPolygon), bbox: geoJsonBoundingBox.optional()})]).nullable(); export const geometryString = z.string().nullable(); export const unitOfMeasure = z.string(); export const quantitativeValue = z.object({value: z.number().nullable().optional(), maxValue: z.number().optional(), minValue: z.number().optional(), unitCode: unitOfMeasure.optional(), qualityControl: z.enum(["Z", "C", "S", "V", "X", "Q", "G", "B", "T"]).optional()}); export const metarPhenomenon = z.object({intensity: z.enum(["light", "heavy"]).nullable(), modifier: z.enum(["patches", "blowing", "low_drifting", "freezing", "shallow", "partial", "showers"]).nullable(), weather: z.enum(["fog_mist", "dust_storm", "dust", "drizzle", "funnel_cloud", "fog", "smoke", "hail", "snow_pellets", "haze", "ice_crystals", "ice_pellets", "dust_whirls", "spray", "rain", "sand", "snow_grains", "snow", "squalls", "sand_storm", "thunderstorms", "unknown", "volcanic_ash"]), rawString: z.string(), inVicinity: z.boolean().optional()}); export const metarSkyCoverage = z.enum(["OVC", "BKN", "SCT", "FEW", "SKC", "CLR", "VV"]); export const observationGeoJson = z.object({"@context": jsonLdContext.optional(), id: z.string().optional(), type: z.literal("Feature"), geometry: geoJsonGeometry, properties: z.object({"@context": jsonLdContext.optional(), geometry: geometryString.optional(), "@id": z.string().optional(), "@type": z.literal("wx:ObservationStation").optional(), elevation: quantitativeValue.optional(), station: z.string().optional(), stationId: z.string().optional(), stationName: z.string().optional(), timestamp: z.string().optional(), rawMessage: z.string().optional(), textDescription: z.string().optional(), icon: z.string().nullable().optional(), presentWeather: z.array(metarPhenomenon).optional(), temperature: quantitativeValue.optional(), dewpoint: quantitativeValue.optional(), windDirection: quantitativeValue.optional(), windSpeed: quantitativeValue.optional(), windGust: quantitativeValue.optional(), barometricPressure: quantitativeValue.optional(), seaLevelPressure: quantitativeValue.optional(), visibility: quantitativeValue.optional(), maxTemperatureLast24Hours: quantitativeValue.optional(), minTemperatureLast24Hours: quantitativeValue.optional(), precipitationLastHour: quantitativeValue.optional(), precipitationLast3Hours: quantitativeValue.optional(), precipitationLast6Hours: quantitativeValue.optional(), relativeHumidity: quantitativeValue.optional(), windChill: quantitativeValue.optional(), heatIndex: quantitativeValue.optional(), cloudLayers: z.array(z.object({base: quantitativeValue, amount: metarSkyCoverage})).nullable().optional()})}); export const validateResponse = async ( schema: { readonly '~standard': { readonly validate: (value: unknown) => ({ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray | undefined }> }) | Promise<{ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray | undefined }> }> } }, value: unknown ): Promise => { const result = await schema['~standard'].validate(value) if (result.issues !== undefined) { const detail = result.issues .map(({ message, path }) => path?.length ? `${path.map((segment) => String(typeof segment === 'object' ? segment.key : segment)).join('.')}: ${message}` : message ) .join('; ') throw new Error(`Response does not match the schema: ${detail}`, { cause: { issues: result.issues } }) } return result.value }; /** * Returns a single observation. * * GET /stations/{stationId}/observations/{time} * * Also accepts auth: apiKeyAuth */ export const getApiStationsStationIdObservationsTime = async (args: GetApiStationsStationIdObservationsTimeArgs, options?: GetApiStationsStationIdObservationsTimeOptions) => { const {baseUrl = "https://api.weather.gov", fetch: fetchFn = fetch, userAgent} = options ?? {} const query = new URLSearchParams() const headers = new Headers() headers.set('accept', "application/geo+json") if (userAgent !== undefined) headers.set("User-Agent", userAgent) const url = `${baseUrl.replace(/\/+$/, '')}/stations/${encodeURIComponent(String(args.stationId))}/observations/${encodeURIComponent(String(args.time))}${query.size > 0 ? `?${query}` : ''}` const res = await fetchFn(url, {method: "GET", headers}) if (!res.ok) throw new Error(`Request failed with status ${res.status}`, {cause: {status: res.status, body: await res.text()}}) return validateResponse(observationGeoJson, await res.json()) };