Skip to content

Commit 57e19b9

Browse files
committed
define null as the default database
1 parent 7dc5d08 commit 57e19b9

File tree

3 files changed

+249
-160
lines changed

3 files changed

+249
-160
lines changed

src/internal/Untitled-1.ts

Lines changed: 89 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,89 @@
1+
2+
interface ConnectionProviderConfiguration {
3+
url: URL
4+
}
5+
6+
interface ConnetionProviderFactory {
7+
(configuration: ConnectionProviderConfiguration): Promise<ConnectionProvider>
8+
9+
}
10+
11+
interface ConnectionProvider {
12+
acquire(mode): Promise<Connection>
13+
relase(connection: Connection): Promise<void>
14+
acquire<T>(mode, consumer: (connection: Connection) => Promise<T> ): Promise<T>
15+
}
16+
17+
interface Handle {
18+
19+
}
20+
21+
interface Result {
22+
23+
}
24+
25+
interface Connection {
26+
begin(): Promise<Handle>
27+
runProg(): Promise<Handle>
28+
run(txHandle: Handle): Promise<Result>
29+
commit(txHandle: Handle): Promise<Handle>
30+
rollback(txHandle: Handle): Promise<Handle>
31+
}
32+
33+
class ConnectionV4 implements Connection {
34+
35+
constructor(
36+
private reader: MessageReader,
37+
private write: MessageWriter,
38+
) {
39+
40+
}
41+
42+
begin(): Promise<Handle> {
43+
throw new Error("Method not implemented.");
44+
}
45+
runProg(): Promise<Handle> {
46+
throw new Error("Method not implemented.");
47+
}
48+
run(txHandle: Handle): Promise<Result> {
49+
throw new Error("Method not implemented.");
50+
}
51+
commit(txHandle: Handle): Promise<Handle> {
52+
throw new Error("Method not implemented.");
53+
}
54+
rollback(txHandle: Handle): Promise<Handle> {
55+
throw new Error("Method not implemented.");
56+
}
57+
58+
}
59+
60+
interface RxFunction<T> {
61+
(connectionProvider: ConnectionProvider, runner: (run: () => Promise<Result>) => Promise<T> ): Promise<T>
62+
}
63+
64+
interface Packer {
65+
pack(value: unknown): number[]
66+
}
67+
68+
interface UnPacker {
69+
unpack(buffer: number[], position: number): [value: unknown, consumed: number]
70+
}
71+
72+
interface Wire {
73+
read(bytes: number): Promise<number[]>
74+
write(buffer: number[], bytes: number): Promise<void>
75+
}
76+
77+
interface MessageReader {
78+
read(): Promise<Message>
79+
}
80+
81+
interface MessageWriter {
82+
write(message: Message): Promise<void>
83+
flush(): Promise<void>
84+
}
85+
86+
interface Message {
87+
tag: number
88+
fields: unknown[]
89+
}

src/internal/connection-provider-routing.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ const UNAUTHORIZED_ERROR_CODE = 'Neo.ClientError.Security.Unauthorized'
3737
const DATABASE_NOT_FOUND_ERROR_CODE =
3838
'Neo.ClientError.Database.DatabaseNotFound'
3939
const SYSTEM_DB_NAME = 'system'
40-
const DEFAULT_DB_NAME = ''
40+
const DEFAULT_DB_NAME = null
4141
const DEFAULT_ROUTING_TABLE_PURGE_DELAY = int(30000)
4242

4343
export default class RoutingConnectionProvider extends PooledConnectionProvider {

0 commit comments

Comments
 (0)