add tests

This commit is contained in:
DieMyst
2021-09-10 14:25:32 +03:00
parent 3b944d9589
commit 5c9a59f14d
43 changed files with 4504 additions and 4014 deletions

View File

@ -1,9 +1,9 @@
/**
*
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.3.0-222
* Aqua version: 0.3.0-SNAPSHOT
*
*/
import { FluencePeer } from '@fluencelabs/fluence';
@ -14,20 +14,21 @@ import {
CallParams,
} from '@fluencelabs/fluence/dist/internal/compilerSupport/v1';
// Services
export interface TestServiceDef {
get_records: (key: string, callParams: CallParams<'key'>) => string[];
}
export interface TestServiceDef {
get_records: (key: string, callParams: CallParams<'key'>) => string[];
}
export function registerTestService(service: TestServiceDef): void;
export function registerTestService(service: TestServiceDef): void;
export function registerTestService(serviceId: string, service: TestServiceDef): void;
export function registerTestService(peer: FluencePeer, service: TestServiceDef): void;
export function registerTestService(peer: FluencePeer, serviceId: string, service: TestServiceDef): void;
export function registerTestService(...args) {
export function registerTestService(...args: any) {
let peer: FluencePeer;
let serviceId;
let service;
let serviceId: any;
let service: any;
if (args[0] instanceof FluencePeer) {
peer = args[0];
} else {
@ -38,9 +39,10 @@ export function registerTestService(...args) {
serviceId = args[0];
} else if (typeof args[1] === 'string') {
serviceId = args[1];
} else {
serviceId = 'test-service';
}
}
else {
serviceId = "test-service"
}
if (!(args[0] instanceof FluencePeer) && typeof args[0] === 'object') {
service = args[0];
@ -50,59 +52,59 @@ export function registerTestService(...args) {
service = args[2];
}
peer.internals.callServiceHandler.use((req, resp, next) => {
if (req.serviceId !== serviceId) {
next();
return;
}
peer.internals.callServiceHandler.use((req, resp, next) => {
if (req.serviceId !== serviceId) {
next();
return;
}
if (req.fnName === 'get_records') {
const callParams = {
...req.particleContext,
tetraplets: {
key: req.tetraplets[0]
},
};
resp.retCode = ResultCodes.success;
resp.result = service.get_records(req.args[0], callParams)
if (req.fnName === 'get_records') {
const callParams = {
...req.particleContext,
tetraplets: {
key: req.tetraplets[0],
},
};
resp.retCode = ResultCodes.success;
resp.result = service.get_records(req.args[0], callParams);
}
next();
});
}
}
next();
});
}
// Functions
export function append_records(peer_: string, srum: string[][], config?: { ttl?: number }): Promise<void>;
export function append_records(
peer: FluencePeer,
peer_: string,
srum: string[][],
config?: { ttl?: number },
): Promise<void>;
export function append_records(...args) {
let peer: FluencePeer;
let peer_;
let srum;
let config;
if (args[0] instanceof FluencePeer) {
peer = args[0];
peer_ = args[1];
srum = args[2];
config = args[3];
} else {
peer = FluencePeer.default;
peer_ = args[0];
srum = args[1];
config = args[2];
}
let request: RequestFlow;
const promise = new Promise<void>((resolve, reject) => {
const r = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
export function append_records(peer_: string, srum: string[][], config?: {ttl?: number}) : Promise<void>;
export function append_records(peer: FluencePeer, peer_: string, srum: string[][], config?: {ttl?: number}) : Promise<void>;
export function append_records(...args: any) {
let peer: FluencePeer;
let peer_: any;
let srum: any;
let config: any;
if (args[0] instanceof FluencePeer) {
peer = args[0];
peer_ = args[1];
srum = args[2];
config = args[3];
} else {
peer = FluencePeer.default;
peer_ = args[0];
srum = args[1];
config = args[2];
}
let request: RequestFlow;
const promise = new Promise<void>((resolve, reject) => {
const r = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
@ -126,18 +128,16 @@ export function append_records(...args) {
)
`,
)
.configHandler((h) => {
h.on('getDataSrv', '-relay-', () => {
return peer.connectionInfo.connectedRelay;
)
.configHandler((h) => {
h.on('getDataSrv', '-relay-', () => {
return peer.connectionInfo.connectedRelay ;
});
h.on('getDataSrv', 'peer', () => {
return peer_;
});
h.on('getDataSrv', 'srum', () => {
return srum;
});
h.onEvent('callbackSrv', 'response', (args) => {});
h.on('getDataSrv', 'peer', () => {return peer_;});
h.on('getDataSrv', 'srum', () => {return srum;});
h.onEvent('callbackSrv', 'response', (args) => {
});
h.onEvent('errorHandlingSrv', 'error', (args) => {
const [err] = args;
@ -147,38 +147,40 @@ export function append_records(...args) {
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out for append_records');
});
if (config && config.ttl) {
r.withTTL(config.ttl);
})
if(config && config.ttl) {
r.withTTL(config.ttl)
}
request = r.build();
});
peer.internals.initiateFlow(request!);
return Promise.race([promise, Promise.resolve()]);
}
export function retrieve_records(peer_: string, config?: { ttl?: number }): Promise<string[][]>;
export function retrieve_records(peer: FluencePeer, peer_: string, config?: { ttl?: number }): Promise<string[][]>;
export function retrieve_records(...args) {
let peer: FluencePeer;
let peer_;
let config;
if (args[0] instanceof FluencePeer) {
peer = args[0];
peer_ = args[1];
config = args[2];
} else {
peer = FluencePeer.default;
peer_ = args[0];
config = args[1];
}
let request: RequestFlow;
const promise = new Promise<string[][]>((resolve, reject) => {
const r = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
export function retrieve_records(peer_: string, config?: {ttl?: number}) : Promise<string[][]>;
export function retrieve_records(peer: FluencePeer, peer_: string, config?: {ttl?: number}) : Promise<string[][]>;
export function retrieve_records(...args: any) {
let peer: FluencePeer;
let peer_: any;
let config: any;
if (args[0] instanceof FluencePeer) {
peer = args[0];
peer_ = args[1];
config = args[2];
} else {
peer = FluencePeer.default;
peer_ = args[0];
config = args[1];
}
let request: RequestFlow;
const promise = new Promise<string[][]>((resolve, reject) => {
const r = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
@ -197,18 +199,16 @@ export function retrieve_records(...args) {
)
`,
)
.configHandler((h) => {
h.on('getDataSrv', '-relay-', () => {
return peer.connectionInfo.connectedRelay;
});
h.on('getDataSrv', 'peer', () => {
return peer_;
)
.configHandler((h) => {
h.on('getDataSrv', '-relay-', () => {
return peer.connectionInfo.connectedRelay ;
});
h.on('getDataSrv', 'peer', () => {return peer_;});
h.onEvent('callbackSrv', 'response', (args) => {
const [res] = args;
resolve(res);
});
const [res] = args;
resolve(res);
});
h.onEvent('errorHandlingSrv', 'error', (args) => {
const [err] = args;
@ -218,12 +218,13 @@ export function retrieve_records(...args) {
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out for retrieve_records');
});
if (config && config.ttl) {
r.withTTL(config.ttl);
})
if(config && config.ttl) {
r.withTTL(config.ttl)
}
request = r.build();
});
peer.internals.initiateFlow(request!);
return promise;
}