1
import {
2
  dstream as createDstream,
3
  type DStream,
4
  type DStreamOptions as DstreamCreateOptions,
5
} from "@cocalc/conat/sync/dstream";
6
import { dkv as createDKV, type DKV, type DKVOptions } from "@cocalc/conat/sync/dkv";
7
import { dko as createDKO, type DKO } from "@cocalc/conat/sync/dko";
8
import { akv as createAKV, type AKV } from "@cocalc/conat/sync/akv";
9
import { astream as createAStream, type AStream } from "@cocalc/conat/sync/astream";
10
import { createOpenFiles, type OpenFiles } from "@cocalc/conat/sync/open-files";
11
export { inventory } from "@cocalc/conat/sync/inventory";
12
import "./index";
13

14
export type { DStream, DKV, DKO, AKV };
15

16
export async function dstream<T = any>(
17
  opts: DstreamCreateOptions,
18
): Promise<DStream<T>> {
19
  return await createDstream<T>(opts);
20
}
21

22
export function astream<T = any>(opts: DstreamCreateOptions): AStream<T> {
23
  return createAStream<T>(opts);
24
}
25

26
export async function dkv<T = any>(opts: DKVOptions): Promise<DKV<T>> {
27
  return await createDKV<T>(opts);
28
}
29

30
export function akv<T = any>(opts: DKVOptions): AKV<T> {
31
  return createAKV<T>(opts);
32
}
33

34
export async function dko<T = any>(opts: DKVOptions): Promise<DKO<T>> {
35
  return await createDKO(opts);
36
}
37

38
export async function openFiles(project_id: string, opts?): Promise<OpenFiles> {
39
  return await createOpenFiles({ project_id, ...opts });
40
}
41

42