src/app/tests/mocks/shared-app.ts
Methods |
constructor()
|
Defined in src/app/tests/mocks/shared-app.ts:138
|
getAppInfo | ||||||||||||||||
getAppInfo(appType: ApplicationType, appName: string, appVersion?: string)
|
||||||||||||||||
Defined in src/app/tests/mocks/shared-app.ts:159
|
||||||||||||||||
Parameters :
Returns :
Observable<DetailedAppRegistration>
|
getApps | ||||||||||||||||||||
getApps(pageRequest: PageRequest, type?: ApplicationType, search?: string, sort?: Array
|
||||||||||||||||||||
Defined in src/app/tests/mocks/shared-app.ts:144
|
||||||||||||||||||||
Parameters :
Returns :
Observable<Page<AppRegistration>>
|
import { SharedAppsService } from '../../shared/services/shared-apps.service';
import { PageRequest } from '../../shared/model/pagination/page-request.model';
import { ApplicationType } from '../../shared/model/application-type';
import { Page } from '../../shared/model/page';
import { AppRegistration } from '../../shared/model/app-registration.model';
import { DetailedAppRegistration } from '../../shared/model/detailed-app-registration.model';
import { Flo } from 'spring-flo';
import { Observable, EMPTY, of } from 'rxjs';
const METAMODEL_DATA: Array<RawMetadata> = [
{
name: 'file-app', type: 'app', description: 'File App',
options: [
{ id: 'port', name: 'port', defaultValue: '80', description: 'Port on which to listen', type: 'number' }
],
},
{
name: 'time-app', type: 'app', description: 'Time App',
options: [
{ id: 'port', name: 'port', defaultValue: '80', description: 'Port on which to listen', type: 'number' }
],
},
{
name: 'http-app', type: 'app', description: 'HTTP app',
options: [
{ id: 'port', name: 'port', defaultValue: '80', description: 'Port on which to listen', type: 'number' }
],
},
{
name: 'http', type: 'source', description: 'Receive HTTP input',
options: [
{ id: 'port', name: 'port', defaultValue: '80', description: 'Port on which to listen', type: 'number' }
],
}, {
name: 'rabbit', type: 'source', description: 'Receives messages from RabbitMQ',
options: [
{ id: 'queue', name: 'queue', description: 'the queue(s) from which messages will be received' },
{
id: 'time-unit', name: 'time-unit', description: 'Time unit for heart beat messages', type: 'enum',
options: ['HOURS', 'MINUTES', 'SECONDS', 'MILIOSECONDS'], defaultValue: 'SECONDS'
},
{ id: 'heart-beat', name: 'heart-beat', description: 'Heart beat on/off', type: 'boolean', defaultValue: false },
{
id: 'interval',
name: 'interval',
description: 'Time period being consecutive heart beat messages',
type: 'number',
defaultValue: 20
},
{ id: 'url', name: 'url', description: 'Service URL', type: 'url' },
{ id: 'password', name: 'password', description: 'Password to login to service', type: 'password' },
{ id: 'messages', name: 'messages', description: 'List of messages', type: 'list' },
{ id: 'counts', name: 'counts', description: 'List of counts', type: 'list[number]' },
{ id: 'successes', name: 'successes', description: 'List of successes', type: 'list[boolean]' },
],
}, {
name: 'filewatch', type: 'source', description: 'Produce messages from the content of files created in a directory',
options: [
{ id: 'dir', name: 'dir', description: 'the absolute path to monitor for files' }
],
}, {
name: 'transform', type: 'processor', description: 'Apply an expression to modify incoming messages',
options: [
{ id: 'expression', name: 'expression', defaultValue: 'payload', description: 'SpEL expression to apply' }
],
}, {
name: 'filter', type: 'processor', description: 'Only allow messages through that pass the filter expression',
options: [
{
id: 'expression',
name: 'expression',
defaultValue: 'true',
description: 'SpEL expression to use for filtering'
}
],
}, {
name: 'filesave', type: 'sink', description: 'Writes messages to a file',
options: [
{ id: 'dir', name: 'dir', description: 'Absolute path to directory' },
{ id: 'name', name: 'name', description: 'The name of the file to create' }
],
}, {
name: 'end', type: 'sink', description: 'Writes messages to a file',
options: [
{ id: 'dir', name: 'dir', description: 'Absolute path to directory' },
{ id: 'name', name: 'name', description: 'The name of the file to create' }
],
}, {
name: 'null', type: 'sink', description: 'Writes messages to a file',
options: [
{ id: 'dir', name: 'dir', description: 'Absolute path to directory' },
{ id: 'name', name: 'name', description: 'The name of the file to create' }
],
}, {
name: 'console', type: 'sink', description: 'Writes messages to a file',
options: [
{ id: 'dir', name: 'dir', description: 'Absolute path to directory' },
{ id: 'name', name: 'name', description: 'The name of the file to create' }
],
}, {
name: 'hdfs', type: 'sink', description: 'Writes messages to a file',
options: [
{ id: 'dir', name: 'dir', description: 'Absolute path to directory' },
{ id: 'name', name: 'name', description: 'The name of the file to create' }
],
}, {
name: 'jdbc', type: 'sink', description: 'Writes messages to a file',
options: [
{ id: 'dir', name: 'dir', description: 'Absolute path to directory' },
{ id: 'name', name: 'name', description: 'The name of the file to create' }
],
}, {
name: 'ftp', type: 'sink', description: 'Send messages over FTP',
options: [
{ id: 'host', name: 'host', description: 'the host name for the FTP server' },
{ id: 'port', name: 'port', description: 'The port for the FTP server', type: 'number' },
{ id: 'remoteDir', name: 'remoteDir', description: 'The remote directory on the server' },
],
}, {
name: 'a', type: 'task', description: 'Task a', options: []
}, {
name: 'b', type: 'task', description: 'Task b', options: []
}, {
name: 'c', type: 'task', description: 'Task c', options: []
}, {
name: 'd', type: 'task', description: 'Task d', options: []
}, {
name: 'super-very-long-task-name', type: 'task', description: 'Task d', options: []
}];
interface RawMetadata {
name: string;
type: string;
description: string;
options: Array<Flo.PropertyMetadata>;
}
export class MockSharedAppService extends SharedAppsService {
constructor() {
super(null, null, null);
}
getApps(pageRequest: PageRequest, type?: ApplicationType, search?: string,
sort?: Array<{ sort: string, order: string }>): Observable<Page<AppRegistration>> {
const page = new Page<AppRegistration>();
const apps = METAMODEL_DATA
.filter(d => !type || d.type === ApplicationType[type])
.map(AppRegistration.fromJSON);
page.items = apps;
page.pageNumber = 0;
page.pageSize = apps.length;
page.totalElements = apps.length;
page.totalPages = 1;
return of(page);
}
getAppInfo(appType: ApplicationType, appName: string, appVersion?: string): Observable<DetailedAppRegistration> {
const rawData = METAMODEL_DATA.find(d => d.name === appName && (!appType || d.type === ApplicationType[appType]));
if (rawData) {
return of(new DetailedAppRegistration().deserialize(rawData));
} else {
return EMPTY;
}
}
}