Skip to content

Commit

Permalink
Add WS provider for Deployment Add.
Browse files Browse the repository at this point in the history
  • Loading branch information
@mtho11
mtho11 committed Aug 26, 2015
1 parent d86e812 commit 46e1589
Show file tree
Hide file tree
Showing 4 changed files with 288 additions and 19 deletions.
78 changes: 77 additions & 1 deletion dist/hawkular-ui-service.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -175,6 +175,81 @@ var hawkularRest;
});
})(hawkularRest || (hawkularRest = {}));

var hawkularRest;
(function (hawkularRest) {
hawkularRest._module.provider('HawkularAddDeploymentOps', function () {
this.setHost = function (host) {
this.host = host;
return this;
};
this.setPort = function (port) {
this.port = port;
return this;
};
this.$get = ['$location', '$http', function ($location) {
this.setHost(this.host || $location.host() || 'localhost');
this.setPort(this.port || $location.port() || 8080);
var prefix = 'ws://' + this.host + ':' + this.port;
var opsUrlPart = '/hawkular/feed-comm/ui/ws';
var url = prefix + opsUrlPart;
var factory = {};
var NotificationService;
var ws = new WebSocket(url);
var responseHandlers = [{
prefix: 'GenericSuccessResponse=',
handle: function (operationResponse) {
console.log('Operation Deployment Request : ', operationResponse.message);
NotificationService.info('Operation Deployment Request : ' + operationResponse.message);
}
}, {
prefix: 'DeploymentOperationResponse=',
handle: function (deploymentResponse) {
console.warn("Hey New Add Deployment works!!!");
if (deploymentResponse.status === "OK") {
NotificationService.success('Deployment "' + deploymentResponse.destinationFileName + '" on resource "' + deploymentResponse.resourcePath + '" succeeded.');
}
else if (deploymentResponse.status === "ERROR") {
NotificationService.error('Deployment File: "' + deploymentResponse.destinationFileName + '" on resource "' + deploymentResponse.resourcePath + '" failed: ' + deploymentResponse.message);
}
else {
console.log('Unexpected deploymentOperationResponse: ', deploymentResponse);
}
}
}, {
prefix: 'GenericErrorResponse=',
handle: function (operationResponse) {
NotificationService.error('Operation Deployment Add failed: ' + operationResponse.message);
}
}];
ws.onopen = function () {
console.log('Socket has been opened!');
};
ws.onmessage = function (message) {
console.log('WebSocket received:', message);
var data = message.data;
for (var i = 0; i < responseHandlers.length; i++) {
var h = responseHandlers[i];
if (data.indexOf(h.prefix) === 0) {
var opResult = JSON.parse(data.substring(h.prefix.length));
h.handle(opResult);
return;
}
}
console.log('Unexpected WebSocket message: ', message);
};
factory.init = function (ns) {
NotificationService = ns;
};
factory.performOperation = function (resourcePath, destinationFileName) {
var json = 'DeployApplicationRequest={\"resourcePath\": \"' + resourcePath + '\", \"destinationFileName\":\"' + destinationFileName + '\" }';
console.log('DeployApplicationRequest: ' + json);
ws.send(json);
};
return factory;
}];
});
})(hawkularRest || (hawkularRest = {}));

var hawkularRest;
(function (hawkularRest) {
hawkularRest._module.constant("inventoryInterceptURLS", [new RegExp('.+/inventory/.+/resources/.+%2F.+')]);
Expand Down Expand Up @@ -552,6 +627,7 @@ var hawkularRest;
prefix: 'GenericSuccessResponse=',
handle: function (operationResponse) {
console.log('Operation request delivery: ', operationResponse.message);
NotificationService.info('Operation request delivery: ' + operationResponse.message);
}
}, {
prefix: 'ExecuteOperationResponse=',
Expand All @@ -576,7 +652,7 @@ var hawkularRest;
console.log('Socket has been opened!');
};
ws.onmessage = function (message) {
console.log('WebSocket recevied:', message);
console.log('WebSocket received:', message);
var data = message.data;
for (var i = 0; i < responseHandlers.length; i++) {
var h = responseHandlers[i];
Expand Down
78 changes: 77 additions & 1 deletion dist/hawkular-ui-service.min.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -175,6 +175,81 @@ var hawkularRest;
});
})(hawkularRest || (hawkularRest = {}));

var hawkularRest;
(function (hawkularRest) {
hawkularRest._module.provider('HawkularAddDeploymentOps', function () {
this.setHost = function (host) {
this.host = host;
return this;
};
this.setPort = function (port) {
this.port = port;
return this;
};
this.$get = ['$location', '$http', function ($location) {
this.setHost(this.host || $location.host() || 'localhost');
this.setPort(this.port || $location.port() || 8080);
var prefix = 'ws://' + this.host + ':' + this.port;
var opsUrlPart = '/hawkular/feed-comm/ui/ws';
var url = prefix + opsUrlPart;
var factory = {};
var NotificationService;
var ws = new WebSocket(url);
var responseHandlers = [{
prefix: 'GenericSuccessResponse=',
handle: function (operationResponse) {
console.log('Operation Deployment Request : ', operationResponse.message);
NotificationService.info('Operation Deployment Request : ' + operationResponse.message);
}
}, {
prefix: 'DeploymentOperationResponse=',
handle: function (deploymentResponse) {
console.warn("Hey New Add Deployment works!!!");
if (deploymentResponse.status === "OK") {
NotificationService.success('Deployment "' + deploymentResponse.destinationFileName + '" on resource "' + deploymentResponse.resourcePath + '" succeeded.');
}
else if (deploymentResponse.status === "ERROR") {
NotificationService.error('Deployment File: "' + deploymentResponse.destinationFileName + '" on resource "' + deploymentResponse.resourcePath + '" failed: ' + deploymentResponse.message);
}
else {
console.log('Unexpected deploymentOperationResponse: ', deploymentResponse);
}
}
}, {
prefix: 'GenericErrorResponse=',
handle: function (operationResponse) {
NotificationService.error('Operation Deployment Add failed: ' + operationResponse.message);
}
}];
ws.onopen = function () {
console.log('Socket has been opened!');
};
ws.onmessage = function (message) {
console.log('WebSocket received:', message);
var data = message.data;
for (var i = 0; i < responseHandlers.length; i++) {
var h = responseHandlers[i];
if (data.indexOf(h.prefix) === 0) {
var opResult = JSON.parse(data.substring(h.prefix.length));
h.handle(opResult);
return;
}
}
console.log('Unexpected WebSocket message: ', message);
};
factory.init = function (ns) {
NotificationService = ns;
};
factory.performOperation = function (resourcePath, destinationFileName) {
var json = 'DeployApplicationRequest={\"resourcePath\": \"' + resourcePath + '\", \"destinationFileName\":\"' + destinationFileName + '\" }';
console.log('DeployApplicationRequest: ' + json);
ws.send(json);
};
return factory;
}];
});
})(hawkularRest || (hawkularRest = {}));

var hawkularRest;
(function (hawkularRest) {
hawkularRest._module.constant("inventoryInterceptURLS", [new RegExp('.+/inventory/.+/resources/.+%2F.+')]);
Expand Down Expand Up @@ -552,6 +627,7 @@ var hawkularRest;
prefix: 'GenericSuccessResponse=',
handle: function (operationResponse) {
console.log('Operation request delivery: ', operationResponse.message);
NotificationService.info('Operation request delivery: ' + operationResponse.message);
}
}, {
prefix: 'ExecuteOperationResponse=',
Expand All @@ -576,7 +652,7 @@ var hawkularRest;
console.log('Socket has been opened!');
};
ws.onmessage = function (message) {
console.log('WebSocket recevied:', message);
console.log('WebSocket received:', message);
var data = message.data;
for (var i = 0; i < responseHandlers.length; i++) {
var h = responseHandlers[i];
Expand Down
116 changes: 116 additions & 0 deletions src/rest/hawkRest-deploy-add-factory.ts
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,116 @@
/// Copyright 2014-2015 Red Hat, Inc. and/or its affiliates
/// and other contributors as indicated by the @author tags.
///
/// 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.

/**
* @ngdoc provider
* @name hawkular.rest.HawkularAddDeploymentOps
* @description
* # HawkularOps
* Asynchronous Deployment Add operations
*/

module hawkularRest {

_module.provider('HawkularAddDeploymentOps', function () {

this.setHost = function (host) {
this.host = host;
return this;
};

this.setPort = function (port) {
this.port = port;
return this;
};

this.$get = ['$location', '$http', function ($location) {
// If available, used pre-configured values, otherwise use values from current browser location of fallback to
// defaults
this.setHost(this.host || $location.host() || 'localhost');
this.setPort(this.port || $location.port() || 8080);

var prefix = 'ws://' + this.host + ':' + this.port;
var opsUrlPart = '/hawkular/feed-comm/ui/ws';
var url = prefix + opsUrlPart;
var factory:any = {};
var NotificationService:any;

var ws = new WebSocket(url);

var responseHandlers = [{
prefix: 'GenericSuccessResponse=',
handle: function (operationResponse) {
console.log('Operation Deployment Request : ', operationResponse.message);
// Probably makes no sense to show this in the UI
NotificationService.info('Operation Deployment Request : ' + operationResponse.message);
}
}, {
prefix: 'DeploymentOperationResponse=',
handle: function (deploymentResponse) {

console.warn("Hey New Add Deployment works!!!");

if (deploymentResponse.status === "OK") {
NotificationService.success('Deployment "' + deploymentResponse.destinationFileName + '" on resource "'
+ deploymentResponse.resourcePath + '" succeeded.');
} else if (deploymentResponse.status === "ERROR") {
NotificationService.error('Deployment File: "' + deploymentResponse.destinationFileName + '" on resource "'
+ deploymentResponse.resourcePath + '" failed: ' + deploymentResponse.message);
} else {
console.log('Unexpected deploymentOperationResponse: ', deploymentResponse);
}
}
}, {
prefix: 'GenericErrorResponse=',
handle: function (operationResponse) {
NotificationService.error('Operation Deployment Add failed: ' + operationResponse.message);
}
}];

ws.onopen = function () {
console.log('Socket has been opened!');
};

ws.onmessage = function (message) {
console.log('WebSocket received:', message);
var data = message.data;
for (var i = 0; i < responseHandlers.length; i++) {
var h = responseHandlers[i];
if (data.indexOf(h.prefix) === 0) {
var opResult = JSON.parse(data.substring(h.prefix.length));
h.handle(opResult);
return;
}
}
console.log('Unexpected WebSocket message: ', message);
};

factory.init = function (ns) {
NotificationService = ns;
};

factory.performOperation = function (resourcePath, destinationFileName) {
var json = 'DeployApplicationRequest={\"resourcePath\": \"'+resourcePath+'\", \"destinationFileName\":\"'+destinationFileName+'\" }';
console.log('DeployApplicationRequest: ' + json);
ws.send(json);

};


return factory;
}];

});
}

0 comments on commit 46e1589

Please sign in to comment.