packaged @tsdi/platform-server-activities

@tsdi/platform-server-activities is activities framework for nodejs, base on AOP, Ioc container, via @tsdi. file stream pipes activities.

This repo is for distribution on npm. The source for this module is in the
main repo.
Please file issues and pull requests against that repo.

Install

1. install modules:

``shell
npm install @tsdi/platform-server-activities
`

3. install cli | build pack:

$3


`shell
npm install -g '@tsdi/cli'
`

$3

`
npm install '@tsdi/pack'
`

use command: pk run [taskfile.ts], pk run [taskfile.js]


You can import modules:




Doc

$3

* Single task

`ts
@Task('test')
class SimpleTask extends AbstractTask implements ITask {

constructor(name: string) {
super(name);
}

run(): Promise {
// console.log('before simple activity:', this.name);
return Promise.resolve('simple task')
.then(val => {
console.log('return simple activity:', val);
return val;
});
}
}

`

* control flow activities.

see control flow codes


* Task module

`ts


`

$3

`ts
1.
let wf = new Worflow(moudles)
2.
Workflow.create( moudles)
.bootstrap({
...
activity:...
});
3.
Workflow.create( moudles)
.bootstrap(TestTask);
4.
Workflow.create()
.sequence(TestTask, TsCompile, {
...
activity: ...
});
5.
Workflow.create()
.run(...[TestTask, TsCompile, {
...
activity: ...
}]);

`

Simples

`ts
import { Workflow, IfActivityToken, SequenceActivityToken, ExecuteToken } from '@tsdi/activities';
import { INodeActivityContext, Asset, BuildModule, AssetToken, ShellModule, TransformModule, NodeActivityContext } from '@tsdi/build';
import * as through from 'through2';
import * as path from 'path';
import { isPackClass, PackModule } from '@tsdi/pack';

@Asset({
pipes: [
{
ifBody: {
sequence: [
{
src: ['packages//package.json', '!packages/activities//package.json', '!node_modules/**/package.json'],
pipes: [
ctx => versionSetting(ctx)
],
dest: 'packages',
activity: AssetToken
},
{
src: ['package.json'],
pipes: [
ctx => versionSetting(ctx)
],
dest: '.',
activity: AssetToken
}
],
activity: SequenceActivityToken
},
if: ctx => ctx.getEnvArgs().setvs,
activity: IfActivityToken
},
{
execute: (ctx: INodeActivityContext) => {
let envArgs = ctx.getEnvArgs();
let packages = ctx.getFolders('packages').filter(f => !/activities/.test(f)); // (f => !/(annotations|aop|bootstrap)/.test(f));

let activities = [];
packages.forEach(fd => {
let objs = require(path.join(fd, 'taskfile.ts'));
let builder = Object.values(objs).find(v => isPackClass(v));
activities.push(builder);
});
if (envArgs.deploy) {
let cmd = 'npm publish --access=public'; // envArgs.deploy ? 'npm publish --access=public' : 'npm run build';
let cmds = packages.map(fd => {
return cd ${fd} && ${cmd};
});
console.log(cmds);
activities.push({
shell: cmds,
activity: 'shell'
});
}
return {
contextType: NodeActivityContext,
sequence: activities,
activity: SequenceActivityToken
}
},
activity: ExecuteToken
}
]
})
export class BuilderIoc {
}

@Asset({
pipes: [
{
if: ctx => ctx.getEnvArgs().setvs,
ifBody: {
src: ['packages/activities//package.json', '!node_modules//package.json'],
pipes: [
(ctx) => actVersionSetting(ctx)
],
dest: 'packages/activities',
activity: AssetToken
},
activity: IfActivityToken
},
{
execute: (ctx: INodeActivityContext) => {
let envArgs = ctx.getEnvArgs();
let packages = ctx.getFolders('packages/activities');

let activities = [];
packages.forEach(fd => {
// console.log(path.join(fd, 'taskfile.ts'));
let objs = require(path.join(fd, 'taskfile.ts'));
let builder = Object.values(objs).find(v => isPackClass(v));
activities.push(builder);
});
if (envArgs.deploy) {
let cmd = 'npm publish --access=public';
let cmds = packages.map(fd => {
return cd ${fd} && ${cmd};
});
console.log(cmds);
activities.push({
shell: cmds,
activity: 'shell'
});
}
return {
sequence: activities,
activity: SequenceActivityToken
}
},
activity: ExecuteToken
}
]
})
export class BuilderActivities {
}

Workflow.create()
.use(PackModule)
.bootstrap({
contextType: NodeActivityContext,
if: ctx => ctx.getEnvArgs().act,
ifBody: BuilderActivities,
elseBody: BuilderIoc,
activity: IfActivityToken
});

``

Documentation

Documentation is available on the
* @tsdi/ioc document.
* @tsdi/aop document.
* @tsdi/core document.
* @tsdi/boot document.
* @tsdi/components document.
* @tsdi/activities document.
* @tsdi/typeorm-adapter document.
* @tsdi/unit document.
* @tsdi/unit-console document.
* @tsdi/cli document.

License

MIT © Houjun