node-workers 0.8.0

A pool of long-lived nodejs workers
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

const { bridge } = require('../dist/bridge');

function fib(n) {
  if (n <= 1) {
    return 1;
  }
  return fib(n - 1) + fib(n - 2);
}

const { Project } = require('ts-morph');
function getInterfaces(filePath) {
  const project = new Project();
  const source = project.addSourceFileAtPath(filePath);
  const interfaces = source.getInterfaces();
  const results = [];
  for (const interface of interfaces) {
    const members = interface.getMembers();
    const props = [];
    for (const member of members) {
      const key = member.compilerNode.name.text;
      const type = member.compilerNode.type?.getText();
      props.push({ key, type });
    }
    results.push({
      name: interface.getName(),
      props,
    });
  }
  return results;
}

bridge({
  fib: (payload) => {
    console.log(`fib ${payload} task start`);
    const val = fib(payload);
    console.log(`fib ${payload} task end: `, val);
  },
  fib2: (payload) => {
    return fib(payload);
  },
  ping: () => {
    console.log(`pong at ${new Date()}`);
  },
  getUser: () => {
    return {
      name: 'Foo',
      age: 50,
      phones: ['a', 'b']
    };
  },
  error: () => {
    throw new Error('task failed');
  },
  getInterfaces
});