Skip to content

Commit 68d3acd

Browse files
author
Szymon Drosdzol
committed
Abstracted generating SAS tokens to separate function giving getToken function possibility to utiliza other sources of SAS tokens
1 parent dde4ecf commit 68d3acd

1 file changed

Lines changed: 10 additions & 6 deletions

File tree

ServiceBusJS/Scripts/servicebusjssdk-1.2.js

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -215,8 +215,12 @@ function QueueClient(config) {
215215
return uri;
216216
}
217217

218+
var getToken = function () {
219+
return generateToken(m_EntityName);
220+
};
221+
218222
// Creates shared access signature token.
219-
var getToken = function (entityPath) {
223+
var generateToken = function (entityPath) {
220224

221225
var uri = "http://" + m_ServiceNamespace + ".servicebus.windows.net/" + entityPath;
222226

@@ -285,7 +289,7 @@ function QueueClient(config) {
285289
var body = JSON.stringify(message.body);
286290
var props = message.properties;
287291

288-
var securityToken = getToken(m_EntityName);
292+
var securityToken = getToken();
289293
var sendUri = getUri(m_EntityName);
290294
var xmlHttpRequest = new XMLHttpRequest();
291295

@@ -338,7 +342,7 @@ function QueueClient(config) {
338342
/// <param name="callback" type="function">
339343
/// function to be invoked after the message has received or receiving process has failed.
340344
/// </param>
341-
var securityToken = getToken(m_EntityName);
345+
var securityToken = getToken();
342346

343347
var xmlHttpRequest = new XMLHttpRequest();
344348
var receiveUri = getUri(m_EntityName, "head");
@@ -384,7 +388,7 @@ function QueueClient(config) {
384388
/// <param name="callback" type="function">
385389
/// function to be invoked after the message has received or receiving process has failed.
386390
/// </param>
387-
var securityToken = getToken(m_EntityName);
391+
var securityToken = getToken();
388392
var uri = getUri(m_EntityName, "head");
389393

390394
var xmlHttpRequest = new XMLHttpRequest();
@@ -433,7 +437,7 @@ function QueueClient(config) {
433437
/// The URI which has been previouslly retrieved by peekLockMessage() function.
434438
/// </param>
435439
var xmlHttpRequest = new XMLHttpRequest();
436-
var securityToken = getToken(m_EntityName);
440+
var securityToken = getToken();
437441

438442
xmlHttpRequest.open("PUT", lockUri, true);
439443
xmlHttpRequest.setRequestHeader("Authorization", securityToken);
@@ -469,7 +473,7 @@ function QueueClient(config) {
469473
/// <param name="lockUri" type="function">
470474
/// The URI which has been previouslly retrieved by peekLockMessage() function.
471475
/// </param>
472-
var securityToken = getToken(m_EntityName);
476+
var securityToken = getToken();
473477
var xmlHttpRequest = new XMLHttpRequest();
474478
xmlHttpRequest.open("DELETE", lockUri, true);
475479
xmlHttpRequest.setRequestHeader("Authorization", securityToken);

0 commit comments

Comments
 (0)