File size: 3,758 Bytes
1477a90
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
// Code generated by @openmeter/typespec-typescript. DO NOT EDIT.

import { type Client } from '../core.js'
import { unwrap, type RequestOptions } from '../lib/types.js'
import { paginatePages } from '../lib/paginate.js'
import {
  createMeter,
  getMeter,
  listMeters,
  updateMeter,
  deleteMeter,
  queryMeter,
  queryMeterCsv,
} from '../funcs/meters.js'
import type {
  CreateMeterRequest,
  CreateMeterResponse,
  GetMeterRequest,
  GetMeterResponse,
  ListMetersRequest,
  ListMetersResponse,
  UpdateMeterRequest,
  UpdateMeterResponse,
  DeleteMeterRequest,
  DeleteMeterResponse,
  QueryMeterRequest,
  QueryMeterResponse,
  QueryMeterCsvRequest,
  QueryMeterCsvResponse,
} from '../models/operations/meters.js'
import type { Meter } from '../models/types.js'

export class Meters {
  constructor(private readonly _client: Client) {}

  /**
   * Create meter
   *
   * Create a meter.
   *
   * POST /openmeter/meters
   */
  async create(
    request: CreateMeterRequest,
    options?: RequestOptions,
  ): Promise<CreateMeterResponse> {
    return unwrap(await createMeter(this._client, request, options))
  }

  /**
   * Get meter
   *
   * Get a meter by ID.
   *
   * GET /openmeter/meters/{meterId}
   */
  async get(
    request: GetMeterRequest,
    options?: RequestOptions,
  ): Promise<GetMeterResponse> {
    return unwrap(await getMeter(this._client, request, options))
  }

  /**
   * List meters
   *
   * List meters.
   *
   * GET /openmeter/meters
   */
  async list(
    request?: ListMetersRequest,
    options?: RequestOptions,
  ): Promise<ListMetersResponse> {
    return unwrap(await listMeters(this._client, request, options))
  }

  /**
   * List meters
   *
   * List meters.
   *
   * Iterates every item across all pages, fetching more as the returned iterable is consumed.
   *
   * GET /openmeter/meters
   */
  listAll(
    request?: ListMetersRequest,
    options?: RequestOptions,
  ): AsyncIterable<Meter> {
    return paginatePages(
      (req, opts) => listMeters(this._client, req, opts),
      request ?? {},
      options,
    )
  }

  /**
   * Update meter
   *
   * Update a meter.
   *
   * PUT /openmeter/meters/{meterId}
   */
  async update(
    request: UpdateMeterRequest,
    options?: RequestOptions,
  ): Promise<UpdateMeterResponse> {
    return unwrap(await updateMeter(this._client, request, options))
  }

  /**
   * Delete meter
   *
   * Delete a meter.
   *
   * DELETE /openmeter/meters/{meterId}
   */
  async delete(
    request: DeleteMeterRequest,
    options?: RequestOptions,
  ): Promise<DeleteMeterResponse> {
    return unwrap(await deleteMeter(this._client, request, options))
  }

  /**
   * Query meter
   *
   * Query a meter for usage.
   *
   * Set `Accept: application/json` (the default) to get a structured JSON response.
   * Set `Accept: text/csv` to download the same data as a CSV file suitable for
   * spreadsheets. The CSV columns, in order, are:
   *
   * `from, to, [subject,] [customer_id, customer_key, customer_name,] <dimensions...>, value`
   *
   * The `subject` column is emitted only when `subject` is in the query's
   * `group_by_dimensions`. The three `customer_*` columns are emitted together only
   * when `customer_id` is in the query's `group_by_dimensions`.
   *
   * POST /openmeter/meters/{meterId}/query
   */
  async query(
    request: QueryMeterRequest,
    options?: RequestOptions,
  ): Promise<QueryMeterResponse> {
    return unwrap(await queryMeter(this._client, request, options))
  }

  /** POST /openmeter/meters/{meterId}/query */
  async queryCsv(
    request: QueryMeterCsvRequest,
    options?: RequestOptions,
  ): Promise<QueryMeterCsvResponse> {
    return unwrap(await queryMeterCsv(this._client, request, options))
  }
}