feat: 🎸 add identifier parameter to [graph]

packages/analytics/src/graph.js

@@ -45,22 +45,21 @@ export default function graph(data, feed) {
         feed.close();
         return;
     }
-    let fields = this.getParam('path', []);
-    if (!Array.isArray(fields)) {
-        fields = [fields];
-    }
-
-    const values = fields
+    const path = this.getParam('path', []);
+    const idt = this.getParam('identifier', false);
+    const weight = idt === false ? 1 : get(data, idt, 1);
+    const values = [].concat(path)
         .map((key) => get(data, key))
         .filter((x) => x)
         .map((item) => (item instanceof Array ? item : [item]))
         .reduce((pre, cur) => pre.concat(cur), [])
+        .filter(Boolean)
         .sort();
 
     values.forEach(
         (v, i) => values
             .slice(i + 1)
-            .forEach((w) => feed.write(core([v, w], 1))),
+            .forEach((w) => feed.write(core([v, w], weight))),
     );
     feed.end();
 }

packages/analytics/test/network.js

@@ -6,7 +6,7 @@ import statements from '../src';
 ezs.addPath(__dirname);
 
 describe('network', () => {
-    it('graph', (done) => {
+    it('graph #1', (done) => {
         ezs.use(statements);
         const res = [];
         from([
@@ -30,6 +30,30 @@ describe('network', () => {
             });
     });
 
+    it('graph #2', (done) => {
+        ezs.use(statements);
+        const res = [];
+        from([
+            { i: 'doc#1', a: ['x', 'b', 'z'] },
+            { i: 'doc#2', a: ['t', 'b', 'z'] },
+            { i: 'doc#3', a: ['t', 'c', 'z'] },
+            { i: 'doc#4', a: ['y', 'd', 'z'] },
+            { i: 'doc#5', a: ['x', 'b', 'z'] },
+        ])
+            .pipe(ezs('graph', { path: 'a', identifier: 'i' }))
+            .pipe(ezs('reducing'))
+            .on('data', (chunk) => {
+                assert(typeof chunk === 'object');
+                res.push(chunk);
+            })
+            .on('end', () => {
+                assert.equal(10, res.length);
+                assert.equal(2, res[1].value.length);
+                done();
+            });
+    });
+
+
     it('segment #3', (done) => {
         ezs.use(statements);
         const res = [];