| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230 |
- // Licensed to Cloudera, Inc. under one
- // or more contributor license agreements. See the NOTICE file
- // distributed with this work for additional information
- // regarding copyright ownership. Cloudera, Inc. licenses this file
- // to you under the Apache License, Version 2.0 (the
- // "License"); you may not use this file except in compliance
- // with the License. You may obtain a copy of the License at
- //
- // http://www.apache.org/licenses/LICENSE-2.0
- //
- // Unless required by applicable law or agreed to in writing, software
- // distributed under the License is distributed on an "AS IS" BASIS,
- // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- // See the License for the specific language governing permissions and
- // limitations under the License.
- /**
- * Provides file, archive, property, param
- * arg, argument, EnvVar, prepares, delete,
- * mkdir, touch, chmod, move, and touchz
- * field operations.
- */
- var NodeFields = {
- removeFile: function(data, event) {
- var self = this;
- self.files.remove(data);
- $(document).trigger('remove.file.workflow', [data]);
- },
- addFile: function(data, event) {
- var self = this;
- var prop = { name: ko.observable(""), dummy: ko.observable("") };
- prop.name.subscribe(function(value) {
- self.files.valueHasMutated();
- });
- self.files.push(prop);
- $(document).trigger('add.file.workflow', [data]);
- },
- removeArchive: function(data, event) {
- var self = this;
- self.archives.remove(data);
- $(document).trigger('remove.archive.workflow', [data]);
- },
- addArchive: function(data, event) {
- var self = this;
- var prop = { name: ko.observable(""), dummy: ko.observable("") };
- prop.name.subscribe(function(value) {
- self.archives.valueHasMutated();
- });
- self.archives.push(prop);
- $(document).trigger('add.archive.workflow', [data]);
- },
- removeProperty: function(data, event) {
- var self = this;
- self.job_properties.remove(data);
- $(document).trigger('remove.property.workflow', [data]);
- },
- addProperty: function(data, event) {
- var self = this;
- var prop = { name: ko.observable(""), value: ko.observable("") };
- prop.name.subscribe(function(value) {
- self.job_properties.valueHasMutated();
- });
- prop.value.subscribe(function(value) {
- self.job_properties.valueHasMutated();
- });
- self.job_properties.push(prop);
- $(document).trigger('add.property.workflow', [data]);
- },
- addParam: function(data, event) {
- var self = this;
- var prop = { value: ko.observable(""), type: ko.observable("param") };
- prop.value.subscribe(function(value) {
- self.params.valueHasMutated();
- });
- prop.type.subscribe(function(value) {
- self.params.valueHasMutated();
- });
- self.params.push(prop);
- $(document).trigger('add.param.workflow', [data]);
- },
- addArgument: function(data, event) {
- var self = this;
- var prop = { value: ko.observable(""), type: ko.observable("argument") };
- prop.value.subscribe(function(value) {
- self.params.valueHasMutated();
- });
- prop.type.subscribe(function(value) {
- self.params.valueHasMutated();
- });
- self.params.push(prop);
- $(document).trigger('add.argument.workflow', [data]);
- },
- addArg: function(data, event) {
- var self = this;
- var prop = { value: ko.observable(""), type: ko.observable("arg") };
- prop.value.subscribe(function(value) {
- self.params.valueHasMutated();
- });
- prop.type.subscribe(function(value) {
- self.params.valueHasMutated();
- });
- self.params.push(prop);
- $(document).trigger('add.arg.workflow', [data]);
- },
- addEnvVar: function(data, event) {
- var self = this;
- var prop = { value: ko.observable(""), type: ko.observable("env-var") };
- prop.value.subscribe(function(value) {
- self.params.valueHasMutated();
- });
- prop.type.subscribe(function(value) {
- self.params.valueHasMutated();
- });
- self.params.push(prop);
- $(document).trigger('add.envvar.workflow', [data]);
- },
- removeParam: function(data, event) {
- var self = this;
- self.params.remove(data);
- $(document).trigger('remove.param.workflow', [data]);
- },
- addPrepareDelete: function(data, event) {
- var self = this;
- var prop = { value: ko.observable(""), type: ko.observable("delete") };
- prop.value.subscribe(function(value) {
- self.prepares.valueHasMutated();
- });
- prop.type.subscribe(function(value) {
- self.prepares.valueHasMutated();
- });
- self.prepares.push(prop);
- $(document).trigger('add.prepare_delete.workflow', [data]);
- },
- addPrepareMkdir: function(data, event) {
- var self = this;
- var prop = { value: ko.observable(""), type: ko.observable("mkdir") };
- prop.value.subscribe(function(value) {
- self.prepares.valueHasMutated();
- });
- prop.type.subscribe(function(value) {
- self.prepares.valueHasMutated();
- });
- self.prepares.push(prop);
- $(document).trigger('add.prepare_mkdir.workflow', [data]);
- },
- removePrepare: function(data, event) {
- var self = this;
- self.prepares.remove(data);
- $(document).trigger('remove.prepare.workflow', [data]);
- },
- addDelete: function(data, event) {
- var self = this;
- var prop = { name: ko.observable("") };
- prop.name.subscribe(function(value) {
- self.deletes.valueHasMutated();
- });
- self.deletes.push(prop);
- $(document).trigger('add.delete.workflow', [data]);
- },
- removeDelete: function(data, event) {
- var self = this;
- self.deletes.remove(data);
- $(document).trigger('remove.delete.workflow', [data]);
- },
- addMkdir: function(data, event) {
- var self = this;
- var prop = { name: ko.observable("") };
- prop.name.subscribe(function(value) {
- self.mkdirs.valueHasMutated();
- });
- self.mkdirs.push(prop);
- $(document).trigger('add.mkdir.workflow', [data]);
- },
- removeMkdir: function(data, event) {
- var self = this;
- self.mkdirs.remove(data);
- $(document).trigger('remove.mkdir.workflow', [data]);
- },
- addMove: function(data, event) {
- var self = this;
- var prop = { source: ko.observable(""), destination: ko.observable("") };
- prop.source.subscribe(function(value) {
- self.moves.valueHasMutated();
- });
- prop.destination.subscribe(function(value) {
- self.moves.valueHasMutated();
- });
- self.moves.push(prop);
- $(document).trigger('add.move.workflow', [data]);
- },
- removeMove: function(data, event) {
- var self = this;
- self.moves.remove(data);
- $(document).trigger('remove.move.workflow', [data]);
- },
- addChmod: function(data, event) {
- var self = this;
- var prop = { path: ko.observable(""), permissions: ko.observable(""), recursive: ko.observable("") };
- prop.path.subscribe(function(value) {
- self.chmods.valueHasMutated();
- });
- prop.permissions.subscribe(function(value) {
- self.chmods.valueHasMutated();
- });
- prop.recursive.subscribe(function(value) {
- self.chmods.valueHasMutated();
- });
- self.chmods.push(prop);
- $(document).trigger('add.chmod.workflow', [data]);
- },
- removeChmod: function(data, event) {
- var self = this;
- self.chmods.remove(data);
- $(document).trigger('remove.chmod.workflow', [data]);
- },
- addTouchz: function(data, event) {
- var self = this;
- var prop = { name: ko.observable("") };
- prop.name.subscribe(function(value) {
- self.touchzs.valueHasMutated();
- });
- self.touchzs.push(prop);
- $(document).trigger('add.touchz.workflow', [data]);
- },
- removeTouchz: function(data, event) {
- var self = this;
- self.touchzs.remove(data);
- $(document).trigger('remove.touchz.workflow', [data]);
- }
- };
|