1
import {
2
  dstream as createDstream,
3
  type DStream,
4
  type DStreamOptions,
5
} from "@cocalc/conat/sync/dstream";
6
import {
7
  dkv as createDKV,
8
  type DKV,
9
  type DKVOptions,
10
} from "@cocalc/conat/sync/dkv";
11
import { dko as createDKO, type DKO } from "@cocalc/conat/sync/dko";
12
import { project_id } from "@cocalc/project/data";
13
import {
14
  createOpenFiles,
15
  type OpenFiles,
16
  Entry as OpenFileEntry,
17
} from "@cocalc/conat/sync/open-files";
18
import {
19
  inventory as createInventory,
20
  type Inventory,
21
} from "@cocalc/conat/sync/inventory";
22

23
import { akv as createAKV, type AKV } from "@cocalc/conat/sync/akv";
24
import {
25
  astream as createAStream,
26
  type AStream,
27
} from "@cocalc/conat/sync/astream";
28

29
export type { DStream, DKV, OpenFiles, OpenFileEntry };
30

31
export async function dstream<T = any>(
32
  opts: DStreamOptions,
33
): Promise<DStream<T>> {
34
  return await createDstream<T>({ project_id, ...opts });
35
}
36

37
export async function dkv<T = any>(opts: DKVOptions): Promise<DKV<T>> {
38
  return await createDKV<T>({ project_id, ...opts });
39
}
40

41
export function akv<T = any>(opts: DKVOptions): AKV<T> {
42
  return createAKV<T>({ project_id, ...opts });
43
}
44

45
export function astream<T = any>(opts: DStreamOptions): AStream<T> {
46
  return createAStream<T>({ project_id, ...opts });
47
}
48

49
export async function dko<T = any>(opts: DKVOptions): Promise<DKO<T>> {
50
  return await createDKO<T>({ project_id, ...opts });
51
}
52

53
export async function openFiles(): Promise<OpenFiles> {
54
  return await createOpenFiles({ project_id });
55
}
56

57
export async function inventory(): Promise<Inventory> {
58
  return await createInventory({ project_id });
59
}
60

61