import {z} from 'zod'

export type GetApiIdMeasuresArgs = {datumType?: string | undefined, hasTelemetry: unknown, label: unknown, notation: unknown, observationType: unknown, 'observationType.label': unknown, observedProperty: unknown, 'observedProperty.label': unknown, parameter: unknown, parameterName: unknown, period: unknown, periodName: unknown, qualifier: unknown, station: unknown, 'station.RLOIid': unknown, 'station.label': unknown, 'station.stationReference': unknown, 'station.wiskiID': unknown, timeseriesID: unknown, unit?: string | undefined, unitName: unknown, valueStatistic: unknown, 'valueStatistic.label': unknown, valueType: unknown, _projection?: string | undefined, _limit?: number | undefined, _offset?: number | undefined, _sort?: string | undefined};

export type GetApiIdMeasuresOptions = {baseUrl: string, fetch?: typeof fetch | undefined};

export const metadataList = z.object({publisher: z.string().optional(), license: z.string().optional(), licenseName: z.string().optional(), documentation: z.string().optional(), version: z.string().optional(), comment: z.string().optional(), hasFormat: z.array(z.string()).optional(), limit: z.number().int().optional(), offset: z.number().int().optional()});

export const timeseriesEndpointDefault = z.object({"@id": z.string().optional(), label: z.string().nullable().optional(), parameter: z.string().nullable().optional(), parameterName: z.string().nullable().optional(), notation: z.string().nullable().optional(), qualifier: z.string().nullable().optional(), period: z.number().nullable().optional(), periodName: z.string().nullable().optional(), hasTelemetry: z.boolean().nullable().optional(), valueType: z.string().nullable().optional(), valueStatistic: z.object({"@id": z.string().optional(), label: z.string().nullable().optional()}).nullable().optional(), datumType: z.string().nullable().optional(), observationType: z.object({"@id": z.string().optional(), label: z.string().nullable().optional()}).nullable().optional(), observedProperty: z.object({"@id": z.string().optional(), label: z.string().nullable().optional()}).nullable().optional(), timeseriesID: z.string().nullable().optional(), station: z.object({"@id": z.string().optional(), label: z.string().nullable().optional(), wiskiID: z.string().nullable().optional(), stationReference: z.string().nullable().optional(), RLOIid: z.string().nullable().optional()}).nullable().optional(), unit: z.string().nullable().optional(), unitName: z.string().nullable().optional()});

export const getApiIdMeasuresResponse = z.object({meta: metadataList.optional(), items: z.array(timeseriesEndpointDefault).optional()});

export const validateResponse = async <Output>(
  schema: {
    readonly '~standard': {
      readonly validate: (value: unknown) => ({ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray<PropertyKey | { readonly key: PropertyKey }> | undefined }> }) | Promise<{ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray<PropertyKey | { readonly key: PropertyKey }> | undefined }> }>
    }
  },
  value: unknown
): Promise<Output> => {
  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
};

/**
 * List of all available measurement timeseries in the hydrology dataset.
 * 
 * GET /id/measures
 */
export const getApiIdMeasures = async (args: GetApiIdMeasuresArgs, options: GetApiIdMeasuresOptions) => {
const {baseUrl, fetch: fetchFn = fetch} = options ?? {}

const query = new URLSearchParams()
const headers = new Headers()
headers.set('accept', "application/json")

if (args.datumType != null) query.append("datumType", String(args.datumType))
if (args.hasTelemetry != null) query.append("hasTelemetry", String(args.hasTelemetry))
if (args.label != null) query.append("label", String(args.label))
if (args.notation != null) query.append("notation", String(args.notation))
if (args.observationType != null) query.append("observationType", String(args.observationType))
if (args['observationType.label'] != null) query.append("observationType.label", String(args['observationType.label']))
if (args.observedProperty != null) query.append("observedProperty", String(args.observedProperty))
if (args['observedProperty.label'] != null) query.append("observedProperty.label", String(args['observedProperty.label']))
if (args.parameter != null) query.append("parameter", String(args.parameter))
if (args.parameterName != null) query.append("parameterName", String(args.parameterName))
if (args.period != null) query.append("period", String(args.period))
if (args.periodName != null) query.append("periodName", String(args.periodName))
if (args.qualifier != null) query.append("qualifier", String(args.qualifier))
if (args.station != null) query.append("station", String(args.station))
if (args['station.RLOIid'] != null) query.append("station.RLOIid", String(args['station.RLOIid']))
if (args['station.label'] != null) query.append("station.label", String(args['station.label']))
if (args['station.stationReference'] != null) query.append("station.stationReference", String(args['station.stationReference']))
if (args['station.wiskiID'] != null) query.append("station.wiskiID", String(args['station.wiskiID']))
if (args.timeseriesID != null) query.append("timeseriesID", String(args.timeseriesID))
if (args.unit != null) query.append("unit", String(args.unit))
if (args.unitName != null) query.append("unitName", String(args.unitName))
if (args.valueStatistic != null) query.append("valueStatistic", String(args.valueStatistic))
if (args['valueStatistic.label'] != null) query.append("valueStatistic.label", String(args['valueStatistic.label']))
if (args.valueType != null) query.append("valueType", String(args.valueType))
if (args._projection != null) query.append("_projection", String(args._projection))
if (args._limit != null) query.append("_limit", String(args._limit))
if (args._offset != null) query.append("_offset", String(args._offset))
if (args._sort != null) query.append("_sort", String(args._sort))

const url = `${baseUrl.replace(/\/+$/, '')}/id/measures${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(getApiIdMeasuresResponse, await res.json())
};