-
Notifications
You must be signed in to change notification settings - Fork 7
/
sequenceRowsApi.ts
58 lines (53 loc) · 1.37 KB
/
sequenceRowsApi.ts
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
// Copyright 2020 Cognite AS
import {
BaseResourceAPI,
CursorAndAsyncIterator,
HttpResponse,
} from '@cognite/sdk-core';
import {
CursorResponse,
SequenceRowsDelete,
SequenceRowsInsert,
SequenceRowsResponseData,
SequenceRowsRetrieve,
} from '../../types';
import { SequenceRow } from './sequenceRow';
export class SequenceRowsAPI extends BaseResourceAPI<SequenceRow> {
public async insert(items: SequenceRowsInsert[]): Promise<{}> {
await this.postInParallelWithAutomaticChunking({
path: this.url(),
items,
chunkSize: 10000,
});
return {};
}
public retrieve(
query: SequenceRowsRetrieve
): CursorAndAsyncIterator<SequenceRow> {
return super.listEndpoint(
(data) =>
this.post<SequenceRowsResponseData>(this.listPostUrl, { data }).then(
this.transformRetrieveResponse
),
query
);
}
public delete(items: SequenceRowsDelete[]): Promise<{}> {
return this.deleteEndpoint(items);
}
private transformRetrieveResponse(
response: HttpResponse<SequenceRowsResponseData>
): HttpResponse<CursorResponse<SequenceRow[]>> {
const { rows, nextCursor, columns } = response.data;
const items = rows.map(
({ rowNumber, values }) => new SequenceRow(rowNumber, values, columns)
);
return {
...response,
data: {
items,
nextCursor,
},
};
}
}