node_loader.js 6.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204
  1. var util = require('./util');
  2. var region_utils = require('./region/utils');
  3. var isFipsRegion = region_utils.isFipsRegion;
  4. var getRealRegion = region_utils.getRealRegion;
  5. util.isBrowser = function() { return false; };
  6. util.isNode = function() { return true; };
  7. // node.js specific modules
  8. util.crypto.lib = require('crypto');
  9. util.Buffer = require('buffer').Buffer;
  10. util.domain = require('domain');
  11. util.stream = require('stream');
  12. util.url = require('url');
  13. util.querystring = require('querystring');
  14. util.environment = 'nodejs';
  15. util.createEventStream = util.stream.Readable ?
  16. require('./event-stream/streaming-create-event-stream').createEventStream : require('./event-stream/buffered-create-event-stream').createEventStream;
  17. util.realClock = require('./realclock/nodeClock');
  18. util.clientSideMonitoring = {
  19. Publisher: require('./publisher').Publisher,
  20. configProvider: require('./publisher/configuration'),
  21. };
  22. util.iniLoader = require('./shared-ini').iniLoader;
  23. util.getSystemErrorName = require('util').getSystemErrorName;
  24. util.loadConfig = function(options) {
  25. var envValue = options.environmentVariableSelector(process.env);
  26. if (envValue !== undefined) {
  27. return envValue;
  28. }
  29. var configFile = {};
  30. try {
  31. configFile = util.iniLoader ? util.iniLoader.loadFrom({
  32. isConfig: true,
  33. filename: process.env[util.sharedConfigFileEnv]
  34. }) : {};
  35. } catch (e) {}
  36. var sharedFileConfig = configFile[
  37. process.env.AWS_PROFILE || util.defaultProfile
  38. ] || {};
  39. var configValue = options.configFileSelector(sharedFileConfig);
  40. if (configValue !== undefined) {
  41. return configValue;
  42. }
  43. if (typeof options.default === 'function') {
  44. return options.default();
  45. }
  46. return options.default;
  47. };
  48. var AWS;
  49. /**
  50. * @api private
  51. */
  52. module.exports = AWS = require('./core');
  53. require('./credentials');
  54. require('./credentials/credential_provider_chain');
  55. require('./credentials/temporary_credentials');
  56. require('./credentials/chainable_temporary_credentials');
  57. require('./credentials/web_identity_credentials');
  58. require('./credentials/cognito_identity_credentials');
  59. require('./credentials/saml_credentials');
  60. require('./credentials/process_credentials');
  61. // Load the xml2js XML parser
  62. AWS.XML.Parser = require('./xml/node_parser');
  63. // Load Node HTTP client
  64. require('./http/node');
  65. require('./shared-ini/ini-loader');
  66. // Load custom credential providers
  67. require('./credentials/token_file_web_identity_credentials');
  68. require('./credentials/ec2_metadata_credentials');
  69. require('./credentials/remote_credentials');
  70. require('./credentials/ecs_credentials');
  71. require('./credentials/environment_credentials');
  72. require('./credentials/file_system_credentials');
  73. require('./credentials/shared_ini_file_credentials');
  74. require('./credentials/process_credentials');
  75. require('./credentials/sso_credentials');
  76. // Setup default providers for credentials chain
  77. // If this changes, please update documentation for
  78. // AWS.CredentialProviderChain.defaultProviders in
  79. // credentials/credential_provider_chain.js
  80. AWS.CredentialProviderChain.defaultProviders = [
  81. function () { return new AWS.EnvironmentCredentials('AWS'); },
  82. function () { return new AWS.EnvironmentCredentials('AMAZON'); },
  83. function () { return new AWS.SsoCredentials(); },
  84. function () { return new AWS.SharedIniFileCredentials(); },
  85. function () { return new AWS.ECSCredentials(); },
  86. function () { return new AWS.ProcessCredentials(); },
  87. function () { return new AWS.TokenFileWebIdentityCredentials(); },
  88. function () { return new AWS.EC2MetadataCredentials(); }
  89. ];
  90. // Load custom token providers
  91. require('./token');
  92. require('./token/token_provider_chain');
  93. require('./token/sso_token_provider');
  94. // Setup default providers for token chain
  95. // If this changes, please update documentation for
  96. // AWS.TokenProviderChain.defaultProviders in
  97. // token/token_provider_chain.js
  98. AWS.TokenProviderChain.defaultProviders = [
  99. function () { return new AWS.SSOTokenProvider(); },
  100. ];
  101. var getRegion = function() {
  102. var env = process.env;
  103. var region = env.AWS_REGION || env.AMAZON_REGION;
  104. if (env[AWS.util.configOptInEnv]) {
  105. var toCheck = [
  106. {filename: env[AWS.util.sharedCredentialsFileEnv]},
  107. {isConfig: true, filename: env[AWS.util.sharedConfigFileEnv]}
  108. ];
  109. var iniLoader = AWS.util.iniLoader;
  110. while (!region && toCheck.length) {
  111. var configFile = {};
  112. var fileInfo = toCheck.shift();
  113. try {
  114. configFile = iniLoader.loadFrom(fileInfo);
  115. } catch (err) {
  116. if (fileInfo.isConfig) throw err;
  117. }
  118. var profile = configFile[env.AWS_PROFILE || AWS.util.defaultProfile];
  119. region = profile && profile.region;
  120. }
  121. }
  122. return region;
  123. };
  124. var getBooleanValue = function(value) {
  125. return value === 'true' ? true: value === 'false' ? false: undefined;
  126. };
  127. var USE_FIPS_ENDPOINT_CONFIG_OPTIONS = {
  128. environmentVariableSelector: function(env) {
  129. return getBooleanValue(env['AWS_USE_FIPS_ENDPOINT']);
  130. },
  131. configFileSelector: function(profile) {
  132. return getBooleanValue(profile['use_fips_endpoint']);
  133. },
  134. default: false,
  135. };
  136. var USE_DUALSTACK_ENDPOINT_CONFIG_OPTIONS = {
  137. environmentVariableSelector: function(env) {
  138. return getBooleanValue(env['AWS_USE_DUALSTACK_ENDPOINT']);
  139. },
  140. configFileSelector: function(profile) {
  141. return getBooleanValue(profile['use_dualstack_endpoint']);
  142. },
  143. default: false,
  144. };
  145. // Update configuration keys
  146. AWS.util.update(AWS.Config.prototype.keys, {
  147. credentials: function () {
  148. var credentials = null;
  149. new AWS.CredentialProviderChain([
  150. function () { return new AWS.EnvironmentCredentials('AWS'); },
  151. function () { return new AWS.EnvironmentCredentials('AMAZON'); },
  152. function () { return new AWS.SharedIniFileCredentials({ disableAssumeRole: true }); }
  153. ]).resolve(function(err, creds) {
  154. if (!err) credentials = creds;
  155. });
  156. return credentials;
  157. },
  158. credentialProvider: function() {
  159. return new AWS.CredentialProviderChain();
  160. },
  161. logger: function () {
  162. return process.env.AWSJS_DEBUG ? console : null;
  163. },
  164. region: function() {
  165. var region = getRegion();
  166. return region ? getRealRegion(region): undefined;
  167. },
  168. tokenProvider: function() {
  169. return new AWS.TokenProviderChain();
  170. },
  171. useFipsEndpoint: function() {
  172. var region = getRegion();
  173. return isFipsRegion(region)
  174. ? true
  175. : util.loadConfig(USE_FIPS_ENDPOINT_CONFIG_OPTIONS);
  176. },
  177. useDualstackEndpoint: function() {
  178. return util.loadConfig(USE_DUALSTACK_ENDPOINT_CONFIG_OPTIONS);
  179. }
  180. });
  181. // Reset configuration
  182. AWS.config = new AWS.Config();