Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
// 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.
//
// Module dependencies.
var url = require('url');
var WrapTokenManager = require('./wraptokenmanager');
var Constants = require('azure-common').Constants;
var HeaderConstants = Constants.HeaderConstants;
var ServiceBusConstants = Constants.ServiceBusConstants;
/**
* Creates a new Wrap object.
*
* @param {string} acsHost The access control host.
* @param {string} issuer The service bus issuer.
* @param {string} accessKey The service bus issuer password.
*/
function Wrap(acsHost, issuer, accessKey) {
this.acsHost = acsHost;
this.issuer = issuer;
this.accessKey = accessKey;
this.wrapTokenManager = new WrapTokenManager(acsHost, issuer, accessKey);
}
/**
// 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.
//
// Module dependencies.
var WrapService = require('../wrapservice');
var Constants = require('azure-common').Constants;
var ServiceBusConstants = Constants.ServiceBusConstants;
var ONE_SECOND_MS = 1000;
/**
* Creates a new Wrap object.
*
* @param {string} acsHost The access control host.
* @param {string} issuer The service bus issuer.
* @param {string} accessKey The service bus issuer password.
*/
function WrapTokenManager(acsHost, issuer, accessKey) {
this.activeTokens = { };
this.wrapService = new WrapService(acsHost, issuer, accessKey);
}
// 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.
//
var queryString = require('querystring');
// Module dependencies.
var Constants = require('azure-common').Constants;
var ServiceBusConstants = Constants.ServiceBusConstants;
// Expose 'AcsTokenResult'.
exports = module.exports;
exports.parse = function (acsTokenQueryString) {
var acsTokenResult = {};
var parsedQueryString = queryString.parse(acsTokenQueryString);
acsTokenResult[ServiceBusConstants.WRAP_ACCESS_TOKEN] = parsedQueryString[ServiceBusConstants.WRAP_ACCESS_TOKEN];
acsTokenResult[ServiceBusConstants.WRAP_ACCESS_TOKEN_EXPIRES_IN] = parsedQueryString[ServiceBusConstants.WRAP_ACCESS_TOKEN_EXPIRES_IN];
return acsTokenResult;
};
// 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.
//
var resourceResult = require('./resourceresult');
var Constants = require('azure-common').Constants;
var ServiceBusConstants = Constants.ServiceBusConstants;
exports.serialize = function (resource) {
var properties = [
ServiceBusConstants.LOCK_DURATION,
ServiceBusConstants.MAX_SIZE_IN_MEGABYTES,
ServiceBusConstants.REQUIRES_DUPLICATE_DETECTION,
ServiceBusConstants.REQUIRES_SESSION,
ServiceBusConstants.DEFAULT_MESSAGE_TIME_TO_LIVE,
ServiceBusConstants.DEAD_LETTERING_ON_MESSAGE_EXPIRATION,
ServiceBusConstants.DUPLICATE_DETECTION_HISTORY_TIME_WINDOW,
ServiceBusConstants.MAX_DELIVERY_COUNT,
ServiceBusConstants.ENABLE_BATCHED_OPERATIONS,
ServiceBusConstants.SIZE_IN_BYTES,
ServiceBusConstants.MESSAGE_COUNT,
ServiceBusConstants.ENABLE_PARTITIONING
];