diff --git a/.dockerignore b/.dockerignore new file mode 100644 index 0000000..8604b6c --- /dev/null +++ b/.dockerignore @@ -0,0 +1,24 @@ +.git +.vscode + +# dependencies +/node_modules +/.pnp +.pnp.js + +# testing +/coverage + +# production +/build + +# misc +.DS_Store +.env.local +.env.development.local +.env.test.local +.env.production.local + +npm-debug.log* +yarn-debug.log* +yarn-error.log* diff --git a/.github/workflows/main.yml b/.github/workflows/main.yml index cba5dcb..7be4877 100644 --- a/.github/workflows/main.yml +++ b/.github/workflows/main.yml @@ -31,6 +31,7 @@ jobs: run: | python3 -m pip install --upgrade pip pip3 install pipenv + cd back-end pipenv install pipenv run echo "SECRET_KEY='TEMPORARY SECRET KEY'" > vp/.environment @@ -61,4 +62,3 @@ jobs: with: collection: Postman/Visual\ Programming-Tests.postman_collection.json environment: Postman/Local\ Testing.postman_environment.json - \ No newline at end of file diff --git a/CLI/__init__.py b/back-end/CLI/__init__.py similarity index 100% rename from CLI/__init__.py rename to back-end/CLI/__init__.py diff --git a/CLI/cli.py b/back-end/CLI/cli.py similarity index 100% rename from CLI/cli.py rename to back-end/CLI/cli.py diff --git a/CLI/setup.py b/back-end/CLI/setup.py similarity index 100% rename from CLI/setup.py rename to back-end/CLI/setup.py diff --git a/CLI/test.py b/back-end/CLI/test.py similarity index 100% rename from CLI/test.py rename to back-end/CLI/test.py diff --git a/back-end/Dockerfile b/back-end/Dockerfile new file mode 100644 index 0000000..1fb0106 --- /dev/null +++ b/back-end/Dockerfile @@ -0,0 +1,19 @@ +FROM python:3.8 + +WORKDIR /visual-programming/back-end + +COPY Pipfile Pipfile.lock ./ +COPY CLI/ ./CLI/ +COPY pyworkflow/ ./pyworkflow/ + +RUN pip install pipenv +RUN pipenv install --dev --ignore-pipfile + +COPY vp/ ./vp +RUN echo "SECRET_KEY=tmp" > vp/.environment + +EXPOSE 8000 + +WORKDIR /visual-programming/back-end/vp + +CMD pipenv run python manage.py runserver 0.0.0.0:8000 diff --git a/Pipfile b/back-end/Pipfile similarity index 100% rename from Pipfile rename to back-end/Pipfile diff --git a/Pipfile.lock b/back-end/Pipfile.lock similarity index 100% rename from Pipfile.lock rename to back-end/Pipfile.lock diff --git a/pyworkflow/pyworkflow/.coveragerc b/back-end/pyworkflow/pyworkflow/.coveragerc similarity index 100% rename from pyworkflow/pyworkflow/.coveragerc rename to back-end/pyworkflow/pyworkflow/.coveragerc diff --git a/pyworkflow/pyworkflow/__init__.py b/back-end/pyworkflow/pyworkflow/__init__.py similarity index 100% rename from pyworkflow/pyworkflow/__init__.py rename to back-end/pyworkflow/pyworkflow/__init__.py diff --git a/pyworkflow/pyworkflow/node.py b/back-end/pyworkflow/pyworkflow/node.py similarity index 98% rename from pyworkflow/pyworkflow/node.py rename to back-end/pyworkflow/pyworkflow/node.py index 0a3bc20..898fe1c 100644 --- a/pyworkflow/pyworkflow/node.py +++ b/back-end/pyworkflow/pyworkflow/node.py @@ -54,6 +54,7 @@ def get_execution_options(self, workflow, flow_nodes): if key in flow_nodes: replacement_value = flow_nodes[key].get_replacement_value() + option.set_value(replacement_value) else: replacement_value = option.get_value() diff --git a/pyworkflow/pyworkflow/node_factory.py b/back-end/pyworkflow/pyworkflow/node_factory.py similarity index 100% rename from pyworkflow/pyworkflow/node_factory.py rename to back-end/pyworkflow/pyworkflow/node_factory.py diff --git a/pyworkflow/pyworkflow/nodes/__init__.py b/back-end/pyworkflow/pyworkflow/nodes/__init__.py similarity index 100% rename from pyworkflow/pyworkflow/nodes/__init__.py rename to back-end/pyworkflow/pyworkflow/nodes/__init__.py diff --git a/pyworkflow/pyworkflow/nodes/custom_nodes/table_creator.py b/back-end/pyworkflow/pyworkflow/nodes/custom_nodes/table_creator.py similarity index 100% rename from pyworkflow/pyworkflow/nodes/custom_nodes/table_creator.py rename to back-end/pyworkflow/pyworkflow/nodes/custom_nodes/table_creator.py diff --git a/pyworkflow/pyworkflow/nodes/flow_control/__init__.py b/back-end/pyworkflow/pyworkflow/nodes/flow_control/__init__.py similarity index 100% rename from pyworkflow/pyworkflow/nodes/flow_control/__init__.py rename to back-end/pyworkflow/pyworkflow/nodes/flow_control/__init__.py diff --git a/pyworkflow/pyworkflow/nodes/flow_control/integer_input.py b/back-end/pyworkflow/pyworkflow/nodes/flow_control/integer_input.py similarity index 95% rename from pyworkflow/pyworkflow/nodes/flow_control/integer_input.py rename to back-end/pyworkflow/pyworkflow/nodes/flow_control/integer_input.py index 086eb89..0ecb0cf 100644 --- a/pyworkflow/pyworkflow/nodes/flow_control/integer_input.py +++ b/back-end/pyworkflow/pyworkflow/nodes/flow_control/integer_input.py @@ -8,8 +8,8 @@ class IntegerNode(FlowNode): Allows for Strings to replace 'string' fields in Nodes """ name = "Integer Input" - num_in = 1 - num_out = 1 + num_in = 0 + num_out = 0 color = 'purple' OPTIONS = { diff --git a/pyworkflow/pyworkflow/nodes/flow_control/string_input.py b/back-end/pyworkflow/pyworkflow/nodes/flow_control/string_input.py similarity index 95% rename from pyworkflow/pyworkflow/nodes/flow_control/string_input.py rename to back-end/pyworkflow/pyworkflow/nodes/flow_control/string_input.py index eaade18..81a785b 100644 --- a/pyworkflow/pyworkflow/nodes/flow_control/string_input.py +++ b/back-end/pyworkflow/pyworkflow/nodes/flow_control/string_input.py @@ -8,8 +8,8 @@ class StringNode(FlowNode): Allows for Strings to replace 'string' fields in Nodes """ name = "String Input" - num_in = 1 - num_out = 1 + num_in = 0 + num_out = 0 color = 'purple' OPTIONS = { diff --git a/pyworkflow/pyworkflow/nodes/io/__init__.py b/back-end/pyworkflow/pyworkflow/nodes/io/__init__.py similarity index 100% rename from pyworkflow/pyworkflow/nodes/io/__init__.py rename to back-end/pyworkflow/pyworkflow/nodes/io/__init__.py diff --git a/pyworkflow/pyworkflow/nodes/io/read_csv.py b/back-end/pyworkflow/pyworkflow/nodes/io/read_csv.py similarity index 100% rename from pyworkflow/pyworkflow/nodes/io/read_csv.py rename to back-end/pyworkflow/pyworkflow/nodes/io/read_csv.py diff --git a/pyworkflow/pyworkflow/nodes/io/write_csv.py b/back-end/pyworkflow/pyworkflow/nodes/io/write_csv.py similarity index 100% rename from pyworkflow/pyworkflow/nodes/io/write_csv.py rename to back-end/pyworkflow/pyworkflow/nodes/io/write_csv.py diff --git a/pyworkflow/pyworkflow/nodes/manipulation/__init__.py b/back-end/pyworkflow/pyworkflow/nodes/manipulation/__init__.py similarity index 100% rename from pyworkflow/pyworkflow/nodes/manipulation/__init__.py rename to back-end/pyworkflow/pyworkflow/nodes/manipulation/__init__.py diff --git a/pyworkflow/pyworkflow/nodes/manipulation/filter.py b/back-end/pyworkflow/pyworkflow/nodes/manipulation/filter.py similarity index 100% rename from pyworkflow/pyworkflow/nodes/manipulation/filter.py rename to back-end/pyworkflow/pyworkflow/nodes/manipulation/filter.py diff --git a/pyworkflow/pyworkflow/nodes/manipulation/join.py b/back-end/pyworkflow/pyworkflow/nodes/manipulation/join.py similarity index 100% rename from pyworkflow/pyworkflow/nodes/manipulation/join.py rename to back-end/pyworkflow/pyworkflow/nodes/manipulation/join.py diff --git a/pyworkflow/pyworkflow/nodes/manipulation/pivot.py b/back-end/pyworkflow/pyworkflow/nodes/manipulation/pivot.py similarity index 100% rename from pyworkflow/pyworkflow/nodes/manipulation/pivot.py rename to back-end/pyworkflow/pyworkflow/nodes/manipulation/pivot.py diff --git a/pyworkflow/pyworkflow/nodes/visualization/__init__.py b/back-end/pyworkflow/pyworkflow/nodes/visualization/__init__.py similarity index 100% rename from pyworkflow/pyworkflow/nodes/visualization/__init__.py rename to back-end/pyworkflow/pyworkflow/nodes/visualization/__init__.py diff --git a/pyworkflow/pyworkflow/nodes/visualization/graph.py b/back-end/pyworkflow/pyworkflow/nodes/visualization/graph.py similarity index 100% rename from pyworkflow/pyworkflow/nodes/visualization/graph.py rename to back-end/pyworkflow/pyworkflow/nodes/visualization/graph.py diff --git a/pyworkflow/pyworkflow/parameters.py b/back-end/pyworkflow/pyworkflow/parameters.py similarity index 100% rename from pyworkflow/pyworkflow/parameters.py rename to back-end/pyworkflow/pyworkflow/parameters.py diff --git a/pyworkflow/pyworkflow/tests/sample_test_data.py b/back-end/pyworkflow/pyworkflow/tests/sample_test_data.py similarity index 100% rename from pyworkflow/pyworkflow/tests/sample_test_data.py rename to back-end/pyworkflow/pyworkflow/tests/sample_test_data.py diff --git a/pyworkflow/pyworkflow/tests/test_node.py b/back-end/pyworkflow/pyworkflow/tests/test_node.py similarity index 100% rename from pyworkflow/pyworkflow/tests/test_node.py rename to back-end/pyworkflow/pyworkflow/tests/test_node.py diff --git a/pyworkflow/pyworkflow/tests/test_parameters.py b/back-end/pyworkflow/pyworkflow/tests/test_parameters.py similarity index 100% rename from pyworkflow/pyworkflow/tests/test_parameters.py rename to back-end/pyworkflow/pyworkflow/tests/test_parameters.py diff --git a/pyworkflow/pyworkflow/tests/test_pyworkflow.py b/back-end/pyworkflow/pyworkflow/tests/test_pyworkflow.py similarity index 100% rename from pyworkflow/pyworkflow/tests/test_pyworkflow.py rename to back-end/pyworkflow/pyworkflow/tests/test_pyworkflow.py diff --git a/pyworkflow/pyworkflow/tests/test_workflow.py b/back-end/pyworkflow/pyworkflow/tests/test_workflow.py similarity index 100% rename from pyworkflow/pyworkflow/tests/test_workflow.py rename to back-end/pyworkflow/pyworkflow/tests/test_workflow.py diff --git a/pyworkflow/pyworkflow/workflow.py b/back-end/pyworkflow/pyworkflow/workflow.py similarity index 99% rename from pyworkflow/pyworkflow/workflow.py rename to back-end/pyworkflow/pyworkflow/workflow.py index c8ce491..aa561e3 100644 --- a/pyworkflow/pyworkflow/workflow.py +++ b/back-end/pyworkflow/pyworkflow/workflow.py @@ -172,7 +172,7 @@ def get_all_flow_var_options(self, node_id): for predecessor_id in self.get_node_predecessors(node_id): node = self.get_node(predecessor_id) - if node.node_type == 'FlowNode': + if node.node_type == 'flow_control': flow_variables.append(node.to_json()) return flow_variables @@ -314,7 +314,7 @@ def execute(self, node_id): except NodeException as e: raise e - if node_to_execute.data is None: + if node_to_execute.data is None and node_to_execute.node_type != "flow_control": raise WorkflowException('execute', 'There was a problem saving node output.') return node_to_execute @@ -384,7 +384,7 @@ def load_input_data(self, node_id): if node_to_retrieve is None: raise WorkflowException('retrieve node data', 'The workflow does not contain node %s' % predecessor_id) - if node_to_retrieve.node_type != 'FlowNode': + if node_to_retrieve.node_type != 'flow_control': input_data.append(self.retrieve_node_data(node_to_retrieve)) except WorkflowException: diff --git a/pyworkflow/setup.py b/back-end/pyworkflow/setup.py similarity index 100% rename from pyworkflow/setup.py rename to back-end/pyworkflow/setup.py diff --git a/vp/manage.py b/back-end/vp/manage.py similarity index 100% rename from vp/manage.py rename to back-end/vp/manage.py diff --git a/vp/node/__init__.py b/back-end/vp/node/__init__.py similarity index 100% rename from vp/node/__init__.py rename to back-end/vp/node/__init__.py diff --git a/vp/node/admin.py b/back-end/vp/node/admin.py similarity index 100% rename from vp/node/admin.py rename to back-end/vp/node/admin.py diff --git a/vp/node/apps.py b/back-end/vp/node/apps.py similarity index 100% rename from vp/node/apps.py rename to back-end/vp/node/apps.py diff --git a/vp/node/migrations/__init__.py b/back-end/vp/node/migrations/__init__.py similarity index 100% rename from vp/node/migrations/__init__.py rename to back-end/vp/node/migrations/__init__.py diff --git a/vp/node/models.py b/back-end/vp/node/models.py similarity index 100% rename from vp/node/models.py rename to back-end/vp/node/models.py diff --git a/vp/node/tests.py b/back-end/vp/node/tests.py similarity index 100% rename from vp/node/tests.py rename to back-end/vp/node/tests.py diff --git a/vp/node/urls.py b/back-end/vp/node/urls.py similarity index 100% rename from vp/node/urls.py rename to back-end/vp/node/urls.py diff --git a/vp/node/views.py b/back-end/vp/node/views.py similarity index 100% rename from vp/node/views.py rename to back-end/vp/node/views.py diff --git a/vp/vp/__init__.py b/back-end/vp/vp/__init__.py similarity index 100% rename from vp/vp/__init__.py rename to back-end/vp/vp/__init__.py diff --git a/vp/vp/asgi.py b/back-end/vp/vp/asgi.py similarity index 100% rename from vp/vp/asgi.py rename to back-end/vp/vp/asgi.py diff --git a/vp/vp/settings.py b/back-end/vp/vp/settings.py similarity index 94% rename from vp/vp/settings.py rename to back-end/vp/vp/settings.py index 49453f9..79ff0ec 100644 --- a/vp/vp/settings.py +++ b/back-end/vp/vp/settings.py @@ -25,7 +25,12 @@ # SECURITY WARNING: don't run with debug turned on in production! DEBUG = True -ALLOWED_HOSTS = [] +ALLOWED_HOSTS = ['back-end:8000', + 'back-end', + 'localhost', + '127.0.0.1', + '0.0.0.0', + '[::1]'] # Application definition @@ -81,7 +86,7 @@ # Database # https://docs.djangoproject.com/en/3.0/ref/settings/#databases -### Not yet setup +# Not yet setup DATABASES = {} MEDIA_ROOT = '/tmp' diff --git a/vp/vp/urls.py b/back-end/vp/vp/urls.py similarity index 100% rename from vp/vp/urls.py rename to back-end/vp/vp/urls.py diff --git a/vp/vp/views.py b/back-end/vp/vp/views.py similarity index 100% rename from vp/vp/views.py rename to back-end/vp/vp/views.py diff --git a/vp/vp/wsgi.py b/back-end/vp/vp/wsgi.py similarity index 100% rename from vp/vp/wsgi.py rename to back-end/vp/vp/wsgi.py diff --git a/vp/workflow/__init__.py b/back-end/vp/workflow/__init__.py similarity index 100% rename from vp/workflow/__init__.py rename to back-end/vp/workflow/__init__.py diff --git a/vp/workflow/admin.py b/back-end/vp/workflow/admin.py similarity index 100% rename from vp/workflow/admin.py rename to back-end/vp/workflow/admin.py diff --git a/vp/workflow/apps.py b/back-end/vp/workflow/apps.py similarity index 100% rename from vp/workflow/apps.py rename to back-end/vp/workflow/apps.py diff --git a/vp/workflow/middleware.py b/back-end/vp/workflow/middleware.py similarity index 100% rename from vp/workflow/middleware.py rename to back-end/vp/workflow/middleware.py diff --git a/vp/workflow/migrations/__init__.py b/back-end/vp/workflow/migrations/__init__.py similarity index 100% rename from vp/workflow/migrations/__init__.py rename to back-end/vp/workflow/migrations/__init__.py diff --git a/vp/workflow/models.py b/back-end/vp/workflow/models.py similarity index 100% rename from vp/workflow/models.py rename to back-end/vp/workflow/models.py diff --git a/vp/workflow/tests.py b/back-end/vp/workflow/tests.py similarity index 100% rename from vp/workflow/tests.py rename to back-end/vp/workflow/tests.py diff --git a/vp/workflow/urls.py b/back-end/vp/workflow/urls.py similarity index 100% rename from vp/workflow/urls.py rename to back-end/vp/workflow/urls.py diff --git a/vp/workflow/views.py b/back-end/vp/workflow/views.py similarity index 100% rename from vp/workflow/views.py rename to back-end/vp/workflow/views.py diff --git a/docker-compose.yml b/docker-compose.yml new file mode 100644 index 0000000..7b2a9a0 --- /dev/null +++ b/docker-compose.yml @@ -0,0 +1,21 @@ +version: "3.3" +services: + back-end: + build: ./back-end + ports: + - "8000:8000" + command: bash -c "pipenv run python manage.py runserver 0.0.0.0:8000" + environment: + - DJANGO_ENV=development + front-end: + build: ./front-end + stdin_open: true + ports: + - "3000:3000" + environment: + - NODE_ENV=development + depends_on: + - back-end + links: + - back-end + command: npm start diff --git a/front-end/Dockerfile b/front-end/Dockerfile new file mode 100644 index 0000000..2e7842e --- /dev/null +++ b/front-end/Dockerfile @@ -0,0 +1,14 @@ +FROM node:14-alpine + +WORKDIR /visual-programming/front-end + +COPY package.json . + +RUN npm install + +COPY src/ ./src/ +COPY public/ ./public/ + +EXPOSE 3000 + +CMD npm start diff --git a/front-end/package.json b/front-end/package.json index 5cd81a3..64507d6 100644 --- a/front-end/package.json +++ b/front-end/package.json @@ -67,7 +67,7 @@ "last 1 safari version" ] }, - "proxy": "http://localhost:8000", + "proxy": "http://back-end:8000", "devDependencies": { "@babel/preset-env": "^7.9.5", "@babel/preset-react": "^7.9.4", diff --git a/front-end/src/API.js b/front-end/src/API.js index a61e6e8..a184885 100644 --- a/front-end/src/API.js +++ b/front-end/src/API.js @@ -26,6 +26,16 @@ function fetchWrapper(endpoint, options = {}) { } +/** + * Retrieve node info from server side workflow + * @param {string} nodeId - ID of node to retrieve + * @returns {Promise} - server response (node info and flow variables) + */ +export async function getNode(nodeId) { + return fetchWrapper(`/node/${nodeId}`); +} + + /** * Add node to server-side workflow * @param {CustomNodeModel} node - JS node to add diff --git a/front-end/src/components/CustomNode/CustomNodeModel.js b/front-end/src/components/CustomNode/CustomNodeModel.js index c382e3a..a3d05ff 100644 --- a/front-end/src/components/CustomNode/CustomNodeModel.js +++ b/front-end/src/components/CustomNode/CustomNodeModel.js @@ -13,6 +13,24 @@ export default class CustomNodeModel extends NodeModel { this.configParams = options.option_types; this.options.status = options.status || "unconfigured"; + // add flow control input port + this.addPort( + new VPPortModel({ + in: true, + type: 'vp-port', + name: 'flow-in' + }) + ); + // if flow node, add flow control output port + if (this.options.node_type === "flow_control") { + this.addPort( + new VPPortModel({ + in: false, + type: 'vp-port', + name: 'flow-out' + }) + ); + } const nIn = options.num_in === undefined ? 1 : options.num_in; const nOut = options.num_out === undefined ? 1 : options.num_out; // setup in and out ports diff --git a/front-end/src/components/CustomNode/CustomNodeWidget.js b/front-end/src/components/CustomNode/CustomNodeWidget.js index a5a8e2b..6bc38eb 100644 --- a/front-end/src/components/CustomNode/CustomNodeWidget.js +++ b/front-end/src/components/CustomNode/CustomNodeWidget.js @@ -47,7 +47,10 @@ export default class CustomNodeWidget extends React.Component { render() { const engine = this.props.engine; - const ports = _.values(this.props.node.getPorts()); + const allPorts = _.values(this.props.node.getPorts()); + const ports = allPorts.filter(p => !p.options.name.includes("flow")); + const flowInPort = allPorts.find(p => p.options.name === "flow-in"); + const flowOutPort = allPorts.find(p => p.options.name === "flow-out"); // group ports by type (in/out) const sortedPorts = _.groupBy(ports, p => p.options.in === true ? "in" : "out"); // create PortWidget array for each type @@ -55,11 +58,19 @@ export default class CustomNodeWidget extends React.Component { for (let portType in sortedPorts) { portWidgets[portType] = sortedPorts[portType].map(port => -
+
); } + const flowPortWidgets = [flowInPort, flowOutPort].filter(p => p).map(port => + +
+ + ); + + let graphView; let width = 40; if (this.props.node.options.node_type !== "flow_control") { @@ -75,19 +86,23 @@ export default class CustomNodeWidget extends React.Component {
{this.props.node.options.name}
-
{String.fromCharCode(this.icon)}
- - {graphView} - +
+
+ {String.fromCharCode(this.icon)} +
+ + {graphView} + +
+ {flowPortWidgets}
{ portWidgets["in"] }
diff --git a/front-end/src/components/CustomNode/NodeConfig.js b/front-end/src/components/CustomNode/NodeConfig.js index 67c8f94..a30df87 100644 --- a/front-end/src/components/CustomNode/NodeConfig.js +++ b/front-end/src/components/CustomNode/NodeConfig.js @@ -12,13 +12,25 @@ export default class NodeConfig extends React.Component { this.state = { disabled: false, data: {}, - flowData: {} + flowData: {}, + flowNodes: [] }; this.updateData = this.updateData.bind(this); this.handleDelete = this.handleDelete.bind(this); this.handleSubmit = this.handleSubmit.bind(this); } + getFlowNodes() { + if (!this.props.node) return; + API.getNode(this.props.node.options.id) + .then(node => this.setState({flowNodes: node.flow_variables})) + .catch(err => console.log(err)); + } + + componentDidUpdate(prevProps) { + if (!prevProps.show && this.props.show) this.getFlowNodes(); + } + // callback to update form data in state; // resulting state will be sent to node config callback updateData(key, value, flow = false) { @@ -82,7 +94,7 @@ export default class NodeConfig extends React.Component { value={this.props.node.config[key]} flowValue={this.props.node.options.option_replace ? this.props.node.options.option_replace[key] : null} - globals={this.props.globals} + flowNodes={this.state.flowNodes} disableFunc={(v) => this.setState({disabled: v})}/> )} @@ -149,7 +161,7 @@ function OptionInput(props) { } const hideFlow = props.node.options.is_global - || props.type === "file" || props.globals.length === 0 + || props.type === "file" || props.flowNodes.length === 0; return ( {props.label} @@ -159,7 +171,7 @@ function OptionInput(props) { {hideFlow ? null : @@ -290,7 +302,7 @@ function FlowVariableOverride(props) { const handleSelect = (event) => { const uuid = event.target.value; - const flow = props.flowNodes.find(d => d.id === uuid); + const flow = props.flowNodes.find(d => d.node_id === uuid); const obj = { node_id: uuid, is_global: flow.is_global @@ -308,9 +320,9 @@ function FlowVariableOverride(props) { )} diff --git a/front-end/src/components/VPLink/VPLinkModel.js b/front-end/src/components/VPLink/VPLinkModel.js index a29e2bb..832c6fd 100644 --- a/front-end/src/components/VPLink/VPLinkModel.js +++ b/front-end/src/components/VPLink/VPLinkModel.js @@ -5,8 +5,8 @@ export default class VPLinkModel extends DefaultLinkModel { constructor() { super({ type: 'default', - width: 5, - color: 'orange' + width: 2, + color: 'black' }); this.registerListener({ targetPortChanged: event => { diff --git a/front-end/src/components/VPPort/VPPortModel.js b/front-end/src/components/VPPort/VPPortModel.js index 4c0897a..c72778d 100644 --- a/front-end/src/components/VPPort/VPPortModel.js +++ b/front-end/src/components/VPPort/VPPortModel.js @@ -9,8 +9,16 @@ export default class VPPortModel extends DefaultPortModel { } canLinkToPort(port) { - // can't both be in or out ports - return port instanceof VPPortModel - && this.options.in !== port.options.in; + // if connecting to flow port, make sure this is a flow port + // and opposite of other's direction + if (port.options.name.includes("flow")) { + return this.options.name.includes("flow") + && this.options.in !== port.options.in + // otherwise, make sure this is NOT a flow port, and ensure + // in/out compatibility + } else { + return !this.options.name.includes("flow") + && this.options.in !== port.options.in + } } } diff --git a/front-end/src/components/Workspace.js b/front-end/src/components/Workspace.js index d12410b..1d06abb 100644 --- a/front-end/src/components/Workspace.js +++ b/front-end/src/components/Workspace.js @@ -53,7 +53,6 @@ class Workspace extends React.Component { API.getGlobalVars() .then(vars => { this.setState({globals: vars}); - this.model.globals = vars; }) .catch(err => console.log(err)); } diff --git a/front-end/src/styles/CustomNode.css b/front-end/src/styles/CustomNode.css index 0787cb9..2060c0b 100644 --- a/front-end/src/styles/CustomNode.css +++ b/front-end/src/styles/CustomNode.css @@ -14,6 +14,10 @@ position: relative; } +.custom-node-name { + margin-bottom: 3px; +} + .port-col { display: flex; flex-direction: column; @@ -40,21 +44,41 @@ border-left-color: mediumpurple; } +.flow-port-div { + position: absolute; + top: -5px; +} + +.flow-port-div-in { + left: -5px; +} + +.flow-port-div-out { + left: 85%; +} + +.flow-port { + width: 10px; + height: 10px; + border-radius: 5px; + background-color: purple; +} + +.custom-node-icons { + width: 100%; + position: absolute; + display: flex; + justify-content: space-evenly; + align-items: center; +} + .custom-node-configure { font-size: 1.5rem; cursor: pointer; - position: absolute; - left: 25%; - top: 50%; - transform: translate(-50%, -50%); } .custom-node-tabular { cursor: pointer; - position: absolute; - right: 25%; - top: 25%; - transform: translate(50%, -25%); } .custom-node-description { diff --git a/vp/db.sqlite3 b/vp/db.sqlite3 deleted file mode 100644 index e69de29..0000000