@integration-app/sdk - npm Package Compare versions

Comparing version 0.1.27 to 0.1.28

flow-node-runs.d.ts

@@ -8,2 +8,3 @@ import { ErrorData } from './errors';
 export interface FlowNodeRun {
+    id: string;
     flowId: string;
@@ -10,0 +11,0 @@ flowNodeId: string;

flow-nodes.d.ts

@@ -19,2 +19,3 @@ import { ErrorData } from './errors';
 export interface FlowNode {
+    id: string;
     key: string;
@@ -21,0 +22,0 @@ name: string;

flow-runs.d.ts

@@ -0,1 +1,2 @@
+import { ErrorData } from './errors';
 export declare enum FlowRunState {
@@ -6,1 +7,9 @@ RUNNING = "running",
 }
+export interface FlowRun {
+    id: string;
+    flowId: string;
+    state: FlowRunState;
+    startTime: Date;
+    endTime?: Date;
+    errorsData?: ErrorData[];
+}

flows.d.ts

 import { FlowNode } from './flow-nodes';
 import { JSONSchema } from './json-schema';
 export interface Flow {
+    id: string;
     blueprintKey?: string;
@@ -13,1 +14,4 @@ endpointKey: string;
 }
+export declare function getLinkedNodes(flow: Flow, node: FlowNode): FlowNode[];
+export declare function getDownstreamNodes(flow: Flow, node: FlowNode): FlowNode[];
+export declare function getUpstreamNodes(flow: Flow, node: FlowNode): FlowNode[];

flows.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.getUpstreamNodes = exports.getDownstreamNodes = exports.getLinkedNodes = void 0;
+function getLinkedNodes(flow, node) {
+    return node.links
+        ? node.links.map((nodeLink) => getNodeByKey(flow, nodeLink.key))
+        : [];
+}
+exports.getLinkedNodes = getLinkedNodes;
+function getDownstreamNodes(flow, node) {
+    const linkedNodes = getLinkedNodes(flow, node);
+    return linkedNodes.concat(linkedNodes.map((n) => getLinkedNodes(flow, n)).flat());
+}
+exports.getDownstreamNodes = getDownstreamNodes;
+function getUpstreamNodes(flow, node) {
+    const upLinkedNodes = flow.nodes.filter((n) => n.links.some((l) => l.key == node.key));
+    return upLinkedNodes.concat(upLinkedNodes.map((n) => getUpstreamNodes(flow, n)).flat());
+}
+exports.getUpstreamNodes = getUpstreamNodes;
+function getNodeByKey(flow, nodeKey) {
+    return flow.nodes.find((n) => n.key == nodeKey);
+}
 //# sourceMappingURL=flows.js.map

package.json

 {
   "name": "@integration-app/sdk",
-  "version": "0.1.27",
+  "version": "0.1.28",
   "description": "JavaScript SDK for Integration.app",
@@ -5,0 +5,0 @@ "main": "index.js",

src/flow-node-runs.ts

@@ -10,2 +10,4 @@ import { ErrorData } from './errors'
 export interface FlowNodeRun {
+  id: string
+
   flowId: string
@@ -12,0 +14,0 @@

src/flow-nodes.ts

@@ -22,2 +22,4 @@ import { ErrorData } from './errors'
 export interface FlowNode {
+  id: string // Backwards compatibility - will be removed soon.
+
   /**
@@ -24,0 +26,0 @@ * Key that uniquely identifies this node inside a flow.

src/flow-runs.ts

@@ -0,1 +1,3 @@
+import { ErrorData } from './errors'
+
 export enum FlowRunState {
@@ -6,1 +8,15 @@ RUNNING = 'running',
 }
+
+export interface FlowRun {
+  id: string
+
+  flowId: string
+
+  state: FlowRunState
+
+  startTime: Date
+
+  endTime?: Date
+
+  errorsData?: ErrorData[]
+}

src/flows.ts

@@ -5,2 +5,4 @@ import { FlowNode } from './flow-nodes'
 export interface Flow {
+  id: string
+
   blueprintKey?: string
@@ -22,1 +24,38 @@
 }
+
+/**
+ * Returns nodes of a given flow linked from the given node via `node.links`
+ */
+export function getLinkedNodes(flow: Flow, node: FlowNode): FlowNode[] {
+  return node.links
+    ? node.links.map((nodeLink) => getNodeByKey(flow, nodeLink.key))
+    : []
+}
+
+/**
+ * Return nodes that follow a given node - all the way until the end of the flow.
+ */
+export function getDownstreamNodes(flow: Flow, node: FlowNode): FlowNode[] {
+  const linkedNodes = getLinkedNodes(flow, node)
+  // Recursively find linked nodes for each linked node
+  return linkedNodes.concat(
+    linkedNodes.map((n) => getLinkedNodes(flow, n)).flat(),
+  )
+}
+
+/**
+ * Return nodes that precede a given node - all the way to the beginning(s) of the flow.
+ */
+export function getUpstreamNodes(flow: Flow, node: FlowNode): FlowNode[] {
+  const upLinkedNodes = flow.nodes.filter((n) =>
+    n.links.some((l) => l.key == node.key),
+  )
+  // Recursively find previous nodes for each directly previous node
+  return upLinkedNodes.concat(
+    upLinkedNodes.map((n) => getUpstreamNodes(flow, n)).flat(),
+  )
+}
+
+function getNodeByKey(flow, nodeKey): FlowNode {
+  return flow.nodes.find((n) => n.key == nodeKey)
+}

tsconfig.json

 {
   "compilerOptions": {
     "lib": [
-      "ES2017",
+      "ES2019",
       "DOM"
@@ -6,0 +6,0 @@ ],

No alert changes

Improved metrics

Total package byte prevSize

977526

increased by0.39%

Lines of code

11294

increased by0.71%

No dependency changes