FileSpray.js 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115
  1. /*##############################################################################
  2. # HPCC SYSTEMS software Copyright (C) 2012 HPCC Systems.
  3. #
  4. # Licensed under the Apache License, Version 2.0 (the "License");
  5. # you may not use this file except in compliance with the License.
  6. # You may obtain a copy of the License at
  7. #
  8. # http://www.apache.org/licenses/LICENSE-2.0
  9. #
  10. # Unless required by applicable law or agreed to in writing, software
  11. # distributed under the License is distributed on an "AS IS" BASIS,
  12. # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13. # See the License for the specific language governing permissions and
  14. # limitations under the License.
  15. ############################################################################## */
  16. define([
  17. "dojo/_base/declare",
  18. "dojo/_base/lang",
  19. "dojo/_base/xhr",
  20. "dojo/_base/Deferred",
  21. "dojo/store/util/QueryResults",
  22. "dojo/store/JsonRest",
  23. "dojo/store/Memory",
  24. "dojo/store/Cache",
  25. "dojo/store/Observable",
  26. "dojox/xml/parser",
  27. "hpcc/ESPBase"
  28. ], function (declare, lang, xhr, Deferred, QueryResults, JsonRest, Memory, Cache, Observable,
  29. parser,
  30. ESPBase) {
  31. var GetDFUWorkunits = declare(ESPBase, {
  32. idProperty: "ID",
  33. constructor: function (options) {
  34. declare.safeMixin(this, options);
  35. },
  36. getIdentity: function (object) {
  37. return object[this.idProperty];
  38. },
  39. query: function (query, options) {
  40. var request = {};
  41. lang.mixin(request, options.query);
  42. if (options.start)
  43. request['PageStartFrom'] = options.start;
  44. if (options.count)
  45. request['PageSize'] = options.count;
  46. if (options.sort) {
  47. request['Sortby'] = options.sort[0].attribute;
  48. request['Descending'] = options.sort[0].descending;
  49. }
  50. request['rawxml_'] = "1";
  51. var results = xhr.get({
  52. url: this.getBaseURL("FileSpray") + "/GetDFUWorkunits.json",
  53. handleAs: "json",
  54. content: request
  55. });
  56. var deferredResults = new Deferred();
  57. deferredResults.total = results.then(function (response) {
  58. if (lang.exists("GetDFUWorkunitsResponse.NumWUs", response)) {
  59. return response.GetDFUWorkunitsResponse.NumWUs;
  60. }
  61. return 0;
  62. });
  63. Deferred.when(results, function (response) {
  64. var workunits = [];
  65. if (lang.exists("GetDFUWorkunitsResponse.results.DFUWorkunit", response)) {
  66. workunits = response.GetDFUWorkunitsResponse.results.DFUWorkunit;
  67. }
  68. deferredResults.resolve(workunits);
  69. });
  70. return QueryResults(deferredResults);
  71. }
  72. });
  73. return {
  74. GetDFUWorkunits: GetDFUWorkunits,
  75. WUAction: function (items, actionType, callback) {
  76. var request = {
  77. Type: actionType
  78. };
  79. for (var i = 0; i < items.length; ++i) {
  80. request["wuids_i" + i] = items[i].ID;
  81. }
  82. var espBase = new ESPBase();
  83. var context = this;
  84. xhr.post({
  85. url: espBase.getBaseURL("FileSpray") + "/DFUWorkunitsAction.json",
  86. handleAs: "json",
  87. content: request,
  88. load: function (response) {
  89. if (callback && callback.load) {
  90. callback.load(response);
  91. }
  92. },
  93. error: function () {
  94. if (callback && callback.error) {
  95. callback.error(e);
  96. }
  97. }
  98. });
  99. }
  100. };
  101. });