const driver = new Driver({});

// Reactive
driver.query('RETURN $foo', {foo: true}).subscribe({
next: console.log,
complete: () => driver.shutDown().toPromise(),
error: (err) => {
console.error(err);

driver.shutDown().toPromise();
}
})

import {Driver, List, Num, Result} from '.';

const driver = new Driver({});

// Reactive
driver.transaction().pipe(
flatMap((tx) => tx.query('CREATE (n {foo: $foo}) RETURN n', {foo: true}).pipe(
reduce((agg, next) => agg.concat(next), List.of([])),
tap(() => tx.rollback().toPromise())
))
).subscribe({
next: console.log,
complete: () => driver.shutDown().toPromise(),
error: (err) => {
console.error(err);

driver.shutDown().toPromise();
}
});

// Promise
getResults()
.then(console.log)
.catch(console.error)
.finally(() => driver.shutDown().toPromise())

async function getResults() {
const tx = await driver.transaction().toPromise();
const q1 = await tx.query('CREATE (n {foo: $foo}) RETURN n', {foo: true}).toPromise();

if (q1.data.length.equals(Num.ZERO)) {
await tx.rollback().toPromise();

return;
}

await tx.commit().toPromise();

import {Driver, DRIVER_RESULT_TYPE, List, Result} from '.';

const driver = new Driver({
useRouting: true,
maxPoolSize: 10
});

const query = driver.query('RETURN 1', {}).pipe(
filter(({type}) => type === DRIVER_RESULT_TYPE.RECORD),
reduce((agg, next) => agg.concat(next), List.of([]))
);

// Reactive
const result = forkJoin(_.map(Array(10), () => query));

result.subscribe({
next: console.log,
complete: () => driver.shutDown().toPromise(),
error: (err) => {
console.error(err);

driver.shutDown().toPromise();
}
})

// Promise
const result = Promise.all(_.map(Array(10), () => query.toPromise()));

import {DBMS_DB_ROLE, Driver, DRIVER_RESULT_TYPE, List, Result} from '.';

const driver = new Driver({
useRouting: true,
maxPoolSize: 10
});

getResults()
.then(console.log)
.catch(console.error)
.finally(() => driver.shutDown().toPromise())

async function getResults() {
// request WRITE transaction for db 'neo4j'
const tx = await driver.transaction({role: DBMS_DB_ROLE.LEADER, db: 'neo4j'}).toPromise();
const q1 = await tx.query('CREATE (n {foo: $foo}) RETURN n', {foo: true}).pipe(
filter(({type}) => type === DRIVER_RESULT_TYPE.RECORD),
reduce((agg, next) => agg.concat(next), List.of([]))
).toPromise();

await tx.commit().toPromise();

import {Driver, DRIVER_HEADERS, JsonUnpacker} from '.';

const driver = new Driver({
connectionConfig: {
unpacker: JsonUnpacker,
getResponseHeader: (data): DRIVER_HEADERS => data[0] || DRIVER_HEADERS.FAILURE,
getResponseData: (data): any => data[1] || []
},
mapToResult: (headerRecord, type, data) => ({header: headerRecord, type, data})
});

export interface IAuthToken {
scheme: 'basic',
principal: string,
credentials: string;
}

export interface IConnectionConfig {
secure?: true;
authToken: IAuthToken;
host: string;
port: number;
userAgent: string;
getResponseHeader?: (unpacked: Data) => DRIVER_HEADERS,
getResponseData?: (unpacked: Data) => Data,
packer?: Packer;
unpacker?: Unpacker;
}