--- /dev/null
+/*
+ *
+ * Copyright 2016 RIFT.IO Inc
+ *
+ * Licensed 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.
+ *
+ */
+import AccountActions from './accountActions.js';
+import AccountSource from './accountSource.js';
+
+
+var rw = require('utils/rw.js');
+var altImage = rw.getSearchParams(window.location).alt_image;
+
+let Params = {
+ //Config Agent
+ ConfigAgent: {
+
+ }
+}
+
+
+
+let AccountMeta = {
+ 'config-agent': {
+
+ defaultType: 'juju',
+ params: {
+ "juju": [{
+ label: "IP Address",
+ ref: 'ip-address'
+ }, {
+ label: "Port",
+ ref: 'port',
+ optional: true
+ }, {
+ label: "Username",
+ ref: 'user',
+ optional: true
+ }, {
+ label: "Secret",
+ ref: 'secret',
+ optional: true
+ }]
+ },
+ types: [{
+ "name": "JUJU",
+ "account-type": "juju",
+ }]
+ },
+ 'sdn': {
+ defaultType: 'odl',
+ params: {
+ "odl": [{
+ label: "Username",
+ ref: 'username'
+ }, {
+ label: "Password",
+ ref: 'password'
+ }, {
+ label: "URL",
+ ref: 'url'
+ }]
+ },
+ types: [{
+ "name": "ODL",
+ "account-type": "odl",
+ }]
+ },
+ 'cloud': {
+ defaultType: 'openstack',
+ params: {
+ "aws": [{
+ label: "Key",
+ ref: 'key'
+ }, {
+ label: "Secret",
+ ref: 'secret'
+ }, {
+ label: "Availability Zone",
+ ref: 'availability-zone'
+ }, {
+ label: "Default Subnet ID",
+ ref: 'default-subnet-id'
+ }, {
+ label: "Region",
+ ref: 'region'
+ }, {
+ label: "VPC ID",
+ ref: 'vpcid'
+ }, {
+ label: "SSH Key",
+ ref: 'ssh-key'
+ }],
+ "cloudsim_proxy": [{
+ label: "Host",
+ ref: "host"
+ }],
+ "openstack": [{
+ label: "Key",
+ ref: 'key'
+ }, {
+ label: "Secret",
+ ref: 'secret'
+ }, {
+ label: "Authentication URL",
+ ref: 'auth_url'
+ }, {
+ label: "Tenant",
+ ref: 'tenant'
+ }, {
+ label: 'Management Network',
+ ref: 'mgmt-network'
+ }, {
+ label: 'Floating IP Pool',
+ ref: 'floating-ip-pool',
+ optional: true
+ }],
+ "openmano": [{
+ label: "Host",
+ ref: 'host'
+ }, {
+ label: "Port",
+ ref: 'port'
+ }, {
+ label: "Tenant ID",
+ ref: 'tenant-id'
+ }],
+ "openvim": [{
+ label: "Host",
+ ref: 'host'
+ }, {
+ label: "Tenant Name",
+ ref: 'tenant-name'
+ }, {
+ label: 'Management Network',
+ ref: 'mgmt-network'
+ }, {
+ label: "Port",
+ ref: 'port',
+ optional: true
+ }]
+ },
+ nestedParams: {
+ "openvim": {
+ "container-name": "image-management",
+ "label": "Image Management",
+ "params": [{
+ label: "Username",
+ ref: 'username'
+ }, {
+ label: "Password",
+ ref: 'password'
+ }, {
+ label: 'Image Directory Path',
+ ref: 'image-directory-path',
+ optional: true
+ }]
+ }
+ },
+ types: [{
+ "name": "OpenStack",
+ "account-type": "openstack"
+ }, {
+ "name": "Cloudsim",
+ "account-type": "cloudsim_proxy"
+ }, {
+ "name": "Open Mano",
+ "account-type": "openmano"
+ }, {
+ "name": "AWS",
+ "account-type": "aws"
+ }, {
+ "name": "Open VIM",
+ "account-type": "openvim"
+ }]
+ },
+ resources: {
+ },
+ image: {
+ "aws": require("../../images/aws.png"),
+ "openmano": altImage || require("../../images/openmano.png"),
+ "openvim": require("../../images/openmano.png"),
+ "openstack": require("../../images/openstack.png"),
+ "cloudsim_proxy": require("../../images/riftio.png"),
+ "odl": require("../../images/OpenDaylight_logo.png"),
+ "juju": require("../../images/juju.svg")
+
+ },
+ labelByType: {
+ "aws": "AWS",
+ "openmano": "OpenStack",
+ "openvim": "Open VIM",
+ "openstack": "OpenStack",
+ "cloudsim_proxy": "Cloudsim"
+ }
+}
+
+export default class AccountStore {
+ constructor() {
+ this.cloud = [];
+ this['config-agent'] = [];
+ this.sdn = [];
+ this.account = null;
+ this.types = [];
+ this.refreshingAll = false;
+ this.sdnOptions = [];
+ this.AccountMeta = AccountMeta;
+ this.bindActions(AccountActions(this.alt));
+ this.registerAsync(AccountSource);
+ this.exportPublicMethods({
+ closeSocket:this.closeSocket,
+ setAccountTemplate: this.setAccountTemplate,
+ handleParamChange: this.handleParamChange,
+ handleNameChange: this.handleNameChange,
+ handleAccountTypeChange: this.handleAccountTypeChange,
+ updateAccount: this.updateAccount,
+ viewAccount: this.viewAccount,
+ handleNestedParamChange: this.handleNestedParamChange,
+ getImage: this.getImage
+ })
+ }
+ refreshAllAccountsSuccess = () => {
+ this.setState({
+ refreshingAll: false
+ });
+ }
+ refreshAllAccountsLoading = () => {
+ this.setState({
+ refreshingAll: true
+ });
+ }
+ refreshAllAccountsError = () => {
+
+ }
+ refreshCloudAccountFail = () => {
+ console.log(this);
+ }
+ refreshCloudAccountSuccess = () => {
+
+ }
+ deleteAccountSuccess = (response) => {
+ this.setState({
+ currentAccount: false,
+ account: {}
+ });
+ }
+ openAccountSocketSuccess = (connection) => {
+ let self = this;
+ let ws = window.multiplexer.channel(connection);
+
+ if (!connection) return;
+ this.setState({
+ socket: ws.ws,
+ channelId: connection
+ });
+ ws.onmessage = (socket) => {
+ try {
+ var data = JSON.parse(socket.data);
+ let SdnOptions = [{
+ label: 'Select an SDN Account',
+ value: false
+ }];
+ SdnOptions = SdnOptions.concat(this.generateOptionsByName(data.sdn.data))
+ var newState = {
+ cloud: data.cloud.data,
+ 'config-agent': data['config-agent'].data,
+ sdn: data.sdn.data,
+ sdnOptions: SdnOptions
+ };
+
+ //If account is selected, updated connection status only
+ if(self.currentAccount) {
+ let Account = self.getAccountFromStream(data[self.currentAccount.type].data, self.currentAccount.name);
+ newState.account = self.account;
+ newState.account['connection-status'] = Account['connection-status']
+ }
+ self.setState(newState)
+ } catch(error) {
+ console.log('Hit at exception in openAccountSocketSuccess', error)
+ }
+
+ }
+ ws.onclose = () => {
+ self.closeSocket();
+ }
+ }
+ closeSocket = () => {
+ if (this.socket) {
+ window.multiplexer.channel(this.channelId).close();
+ }
+ this.setState({
+ socket: null
+ })
+ }
+ setAccountTemplate = (AccountType, type) => {
+ let account = {
+ name: '',
+ 'account-type': type || AccountMeta[AccountType].defaultType,
+ params: AccountMeta[AccountType].params[AccountMeta[AccountType].defaultType],
+ nestedParams: AccountMeta[AccountType].nestedParams ? AccountMeta[AccountType].nestedParams[AccountMeta[AccountType].defaultType]:null,
+ 'connection-status': {
+ status: ''
+ }
+ };
+
+ account[type || AccountMeta[AccountType].defaultType] = {}
+ this.setState({
+ account: account,
+ accountType: AccountType,
+ types: AccountMeta[AccountType].types,
+ currentAccount: null
+ })
+ }
+ getAccountFromStream(data, name) {
+ let result = null;
+ data.map(function(a) {
+ if(a.name == name) {
+ result = a;
+ }
+ });
+ return result;
+ }
+ viewAccount = ({type, name}) => {
+ var data = null;
+ var accounts = null;
+ if(this && this[type].length) {
+ accounts = this[type];
+ data = this.getAccountFromStream(accounts, name);
+ if(data) {
+ let accountParams = {
+ params: AccountMeta[type].params[data['account-type']]
+ };
+
+ let accountNestedParams = {
+ nestedParams: AccountMeta[type].nestedParams?AccountMeta[type].nestedParams[data['account-type']]:null
+ };
+
+ this.setState({
+ currentAccount: {type, name},
+ account: Object.assign(data, accountParams, accountNestedParams),
+ accountType: type
+ })
+ }
+ }
+ }
+ generateOptionsByName(data) {
+ let results = [];
+ if (data.constructor.name == "Array") {
+ data.map(function(d) {
+ results.push({
+ label: d.name,
+ value: d.name
+ })
+ });
+ }
+ return results;
+ }
+ updateAccount = (account) => {
+ this.setState({account:account})
+ }
+ handleNameChange = (event) => {
+ var account = this.account;
+ account.name = event.target.value;
+ this.setState(
+ {
+ account:account
+ }
+ );
+ }
+ handleAccountTypeChange = (node, event) => {
+ var temp = {};
+ temp.name = this.account.name;
+ temp['account-type'] = event.target.value;
+ temp.params= AccountMeta[this.accountType].params[event.target.value];
+ temp.nestedParams = AccountMeta[this.accountType]?AccountMeta[this.accountType].nestedParams[event.target.value]:null;
+ temp[event.target.value] = {};
+ this.setState({
+ account: temp
+ });
+ }
+ handleParamChange(node, event) {
+ return function(event) {
+ var account = this.state.account;
+ account[account['account-type']][node.ref] = event.target.value;
+ account.params[node.ref] = event.target.value;
+ this.updateAccount(account);
+ }.bind(this);
+ }
+ handleNestedParamChange(containerName, node, event) {
+ return function(event) {
+ var account = this.state.account;
+ account[account['account-type']][containerName] = account[account['account-type']][containerName] || {};
+ account[account['account-type']][containerName][node.ref] = event.target.value;
+ account[containerName] = account[containerName] || {};
+ account[containerName].params = account[containerName].params || {};
+ account[containerName].params[node.ref] = event.target.value;
+ this.updateAccount(account);
+ }.bind(this);
+ }
+ getImage = (type) => {
+ return AccountMeta.image[type];
+ }
+}
+
+
+/**
+ *Cloud
+ *
+ * {"name":"eng2","account-type":"openstack","openstack":{"key":"lmaultsb","secret":"mypasswd","auth_url":"http://engstack.eng.riftio.com:5000/v3/","tenant":"lmaultsb","mgmt-network":"private"}}
+Name
+Path
+
+
+SDN
+
+
+ *
+ *
+ */
projects / osm / UI.git / blobdiff