| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235 |
- // 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.
- function transform_keys(model, keys_dict) {
- $.each(keys_dict, function(key, new_key) {
- if (key in model) {
- model[new_key] = model[key];
- delete model[key];
- }
- });
- return model;
- }
- function transform_values(model, func_dict) {
- $.each(func_dict, function(key, f) {
- if (key in model) {
- model[key] = f(key, model[key]);
- }
- });
- return model;
- }
- function to_form(value) {
- return new forms.FormModel(value);
- }
- function to_forms(key, value) {
- $.each(value, function(index, form_dict) {
- value[index] = to_form(form_dict);
- });
- return value;
- }
- function to_input(value) {
- if (value.type.toLowerCase() == 'map') {
- return new forms.MapInputModel(value);
- } else {
- return new forms.InputModel(value);
- }
- }
- function to_inputs(key, value) {
- $.each(value, function(index, input_dict) {
- value[index] = to_input(input_dict);
- });
- return value;
- }
- var forms = (function($) {
- var map_form_properties = {
- 'create': function(options) {
- return new SqoopForm({modelDict: options.data});
- },
- 'update': function(options) {
- options.target.initialize({modelDict: options.data})
- return options.target;
- },
- };
- var map_input_properties = {
- 'create': function(options) {
- switch(options.data.type.toLowerCase()) {
- case 'map':
- return new SqoopMapInput({modelDict: options.data});
- default:
- return new SqoopInput({modelDict: options.data});
- }
- },
- 'update': function(options) {
- options.target.initialize({modelDict: options.data})
- return options.target;
- },
- };
- var map_properties = {
- 'connector': map_form_properties,
- 'framework': map_form_properties,
- 'con-forms': map_form_properties,
- 'job-forms': map_form_properties,
- 'inputs': map_input_properties
- };
- var FormModel = koify.Model.extend({
- 'id': -1,
- 'inputs': [],
- 'name': null,
- 'type': null,
- 'initialize': function(attrs) {
- var self = this;
- attrs = transform_values(attrs, {
- 'inputs': to_inputs
- });
- return attrs;
- }
- });
- var InputModel = koify.Model.extend({
- 'id': -1,
- 'name': null,
- 'type': null,
- 'size': -1,
- 'sensitive': false,
- 'values': null,
- 'value': "",
- 'initialize': function(attrs) {
- var self = this;
- var attrs = $.extend(true, {}, attrs);
- if ('values' in attrs && attrs['values']) {
- attrs['values'] = ($.isArray(attrs['values'])) ? attrs['values'] : attrs['values'].split(',');
- }
- if ('value' in attrs) {
- attrs.value = decodeURIComponent(attrs.value);
- }
- return attrs;
- }
- });
- var MapInputModel = InputModel.extend({
- 'value': {},
- 'initialize': function(attrs) {
- var self = this;
- if ('value' in attrs && attrs.value) {
- if (!$.isArray(attrs.value)) {
- var map = attrs['value'];
- attrs.value = [];
- $.each(map, function(key, value) {
- attrs.value.push({
- 'key': key,
- 'value': value
- });
- });
- }
- } else {
- attrs.value = [];
- }
- return attrs;
- }
- });
- // Form is reserved word
- var SqoopForm = koify.MinimalNode.extend({
- 'model_class': FormModel,
- 'map': function() {
- var self = this;
- var mapping_options = $.extend(true, {
- 'ignore': ['parent', 'initialize']
- }, map_properties);
- if ('__ko_mapping__' in self) {
- ko.mapping.fromJS(self.model, mapping_options, self);
- } else {
- var mapped = ko.mapping.fromJS(self.model, mapping_options);
- $.extend(self, mapped);
- }
- }
- });
- var SqoopInput = koify.MinimalNode.extend({
- 'model_class': InputModel,
- 'map': function() {
- var self = this;
- var mapping_options = {
- 'ignore': ['parent', 'initialize']
- };
- if ('__ko_mapping__' in self) {
- ko.mapping.fromJS(self.model, mapping_options, self);
- } else {
- var mapped = ko.mapping.fromJS(self.model, mapping_options);
- $.extend(self, mapped);
- }
- }
- });
- var SqoopMapInput = SqoopInput.extend({
- 'model_class': MapInputModel,
- 'initialize': function() {
- var self = this;
- self.parent.initialize.apply(self, arguments);
- self.addToMap = function() {
- var value = {
- 'key': ko.observable(""),
- 'value': ko.observable("")
- };
- value.key.subscribe(function() {
- self.value.valueHasMutated();
- });
- value.value.subscribe(function() {
- self.value.valueHasMutated();
- });
- self.value().push(value);
- self.value.valueHasMutated();
- };
- self.removeFromMap = function(index) {
- self.value().splice(index, 1);
- self.value.valueHasMutated();
- };
- },
- fixModel: function(model) {
- var map = {};
- $.each(model.value, function(index, obj) {
- if (obj.key) {
- map[obj.key] = obj.value;
- }
- });
- model.value = map;
- return model;
- }
- });
- return {
- 'FormModel': FormModel,
- 'InputModel': InputModel,
- 'MapInputModel': MapInputModel,
- 'Form': SqoopForm,
- 'Input': SqoopInput,
- 'MapInput': SqoopMapInput,
- 'MapProperties': map_properties
- };
- })(jQuery);
|