client.js 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142
  1. const logger = require('./logger');
  2. const restler = require('@jc21/restler');
  3. const BackendApi = function(config, token) {
  4. this.config = config;
  5. this.token = token;
  6. };
  7. /**
  8. * @param {string} token
  9. */
  10. BackendApi.prototype.setToken = function(token) {
  11. this.token = token;
  12. };
  13. /**
  14. * @param {string} path
  15. * @param {bool} [returnOnError]
  16. * @returns {Promise<object>}
  17. */
  18. BackendApi.prototype.get = function(path, returnOnError) {
  19. return new Promise((resolve, reject) => {
  20. let headers = {
  21. Accept: 'application/json'
  22. };
  23. if (this.token) {
  24. headers.Authorization = 'Bearer ' + this.token;
  25. }
  26. logger('GET ', this.config.baseUrl + path);
  27. restler
  28. .get(this.config.baseUrl + path, {
  29. headers: headers,
  30. })
  31. .on('complete', function(data, response) {
  32. logger('Response data:', data);
  33. if (!returnOnError && data instanceof Error) {
  34. reject(data);
  35. } else if (!returnOnError && response.statusCode != 200) {
  36. if (typeof data === 'object' && typeof data.error === 'object' && typeof data.error.message !== 'undefined') {
  37. reject(new Error(data.error.code + ': ' + data.error.message));
  38. } else {
  39. reject(new Error('Error ' + response.statusCode));
  40. }
  41. } else {
  42. resolve(data);
  43. }
  44. });
  45. });
  46. };
  47. /**
  48. * @param {string} path
  49. * @param {bool} [returnOnError]
  50. * @returns {Promise<object>}
  51. */
  52. BackendApi.prototype.delete = function(path, returnOnError) {
  53. return new Promise((resolve, reject) => {
  54. let headers = {
  55. Accept: 'application/json'
  56. };
  57. if (this.token) {
  58. headers.Authorization = 'Bearer ' + this.token;
  59. }
  60. logger('DELETE ', this.config.baseUrl + path);
  61. restler
  62. .del(this.config.baseUrl + path, {
  63. headers: headers,
  64. })
  65. .on('complete', function(data, response) {
  66. logger('Response data:', data);
  67. if (!returnOnError && data instanceof Error) {
  68. reject(data);
  69. } else if (!returnOnError && response.statusCode != 200) {
  70. if (typeof data === 'object' && typeof data.error === 'object' && typeof data.error.message !== 'undefined') {
  71. reject(new Error(data.error.code + ': ' + data.error.message));
  72. } else {
  73. reject(new Error('Error ' + response.statusCode));
  74. }
  75. } else {
  76. resolve(data);
  77. }
  78. });
  79. });
  80. };
  81. /**
  82. * @param {string} path
  83. * @param {object} data
  84. * @param {bool} [returnOnError]
  85. * @returns {Promise<object>}
  86. */
  87. BackendApi.prototype.postJson = function(path, data, returnOnError) {
  88. logger('POST ', this.config.baseUrl + path);
  89. return this._putPostJson('postJson', path, data, returnOnError);
  90. };
  91. /**
  92. * @param {string} path
  93. * @param {object} data
  94. * @param {bool} [returnOnError]
  95. * @returns {Promise<object>}
  96. */
  97. BackendApi.prototype.putJson = function(path, data, returnOnError) {
  98. logger('PUT ', this.config.baseUrl + path);
  99. return this._putPostJson('putJson', path, data, returnOnError);
  100. };
  101. /**
  102. * @param {string} path
  103. * @param {object} data
  104. * @param {bool} [returnOnError]
  105. * @returns {Promise<object>}
  106. */
  107. BackendApi.prototype._putPostJson = function(fn, path, data, returnOnError) {
  108. return new Promise((resolve, reject) => {
  109. restler[fn](this.config.baseUrl + path, data, {
  110. headers: {
  111. Accept: 'application/json',
  112. Authorization: 'Bearer ' + this.token,
  113. },
  114. }).on('complete', function(data, response) {
  115. logger('Response data:', data);
  116. if (!returnOnError && data instanceof Error) {
  117. reject(data);
  118. } else if (!returnOnError && (response.statusCode < 200 || response.statusCode >= 300)) {
  119. if (typeof data === 'object' && typeof data.error === 'object' && typeof data.error.message !== 'undefined') {
  120. reject(new Error(data.error.code + ': ' + data.error.message));
  121. } else {
  122. reject(new Error('Error ' + response.statusCode));
  123. }
  124. } else {
  125. resolve(data);
  126. }
  127. });
  128. });
  129. };
  130. module.exports = BackendApi;