Merge pull request #9 from retejs/new-linter

fix: update cli and fix linting errors

.gitignore

@@ -4,3 +4,6 @@ node_modules
 npm-debug.log
 dist
 docs
+/coverage
+.rete-cli
+.sonar

eslint.config.mjs

@@ -0,0 +1,6 @@
+import tseslint from 'typescript-eslint';
+import configs from 'rete-cli/configs/eslint.mjs';
+
+export default tseslint.config(
+  ...configs
+)

package.json

@@ -29,7 +29,7 @@
   },
   "devDependencies": {
     "rete": "^2.0.1",
-    "rete-cli": "^1.0.2",
+    "rete-cli": "~2.0.1",
     "typescript": "4.8.4"
   },
   "dependencies": {

src/control-flow.ts

@@ -61,7 +61,7 @@ export class ControlFlow<Schemes extends ClassicScheme> {
 
     if (input && !inputKeys.includes(input)) throw new Error('inputs don\'t have a key')
 
-    setup.execute(input, (output) => {
+    setup.execute(input, output => {
       const outputKeys = setup.outputs()
 
       if (!outputKeys.includes(output)) throw new Error('outputs don\'t have a key')

src/dataflow-engine.ts

@@ -62,7 +62,7 @@ export class DataflowEngine<Schemes extends DataflowEngineScheme> extends Scope<
     this.getDataflow().add(node, {
       inputs: options.inputs,
       outputs: options.outputs,
-      data: async (fetchInputs) => {
+      data: async fetchInputs => {
         const cache = this.cache.get(node.id)
 
         if (cache) return cache
@@ -91,14 +91,16 @@ export class DataflowEngine<Schemes extends DataflowEngineScheme> extends Scope<
     if (nodeId) {
       const setup = this.getDataflow().setups.get(nodeId)
 
-      if (!setup) throw 'setup'
+      if (!setup) throw new Error('setup')
 
       const outputKeys = setup.outputs()
 
       this.cache.delete(nodeId)
       this.editor.getConnections()
         .filter(c => c.source === nodeId && outputKeys.includes(c.sourceOutput))
-        .forEach(c => this.reset(c.target))
+        .forEach(c => {
+          this.reset(c.target)
+        })
     } else {
       this.cache.clear()
     }

src/dataflow.ts

@@ -75,7 +75,9 @@ export class Dataflow<Schemes extends ClassicScheme> {
     }))
 
     for (const { c, sourceData } of consWithSourceData) {
-      const previous = inputs[c.targetInput] ? inputs[c.targetInput] : []
+      const previous = inputs[c.targetInput]
+        ? inputs[c.targetInput]
+        : []
 
       inputs[c.targetInput] = [...previous, sourceData[c.sourceOutput]]
     }

src/utils/cache.ts

@@ -21,7 +21,9 @@ export class Cache<Key, T> {
     const item = this.cache.get(key)
 
     this.cache.delete(key)
-    this.onDelete && this.onDelete(item)
+    if (this.onDelete) {
+      this.onDelete(item)
+    }
   }
 
   clear() {

src/utils/cancellable.ts

@@ -30,7 +30,7 @@ function createCancellblePromise(...sequence: S<any, any>[]): Cancellable<any> {
     res()
   })
 
-  const n = (sequence as S<any, any>[]).reduce((p, item) => {
+  const n = sequence.reduce((p, item) => {
     const t = p.then(item as any).then(commit)
 
     return t

tsconfig.json

@@ -1,6 +1,4 @@
 {
-    "compilerOptions": {
-        "strict": true
-    },
+    "extends": "rete-cli/configs/tsconfig.json",
     "include": ["src"]
 }