1030684270

Build Type

github

Committed by GitHub

Commit Message

Merge bac57351d into d1150f022

Pull Request Pull Request #47: fix: select env after merging all files together

Run Details

195 of 233 branches covered (83.69%)

Branch coverage included in aggregate %.

156 of 165 new or added lines in 4 files covered. (94.55%)

3 existing lines in 1 file now uncovered.

1099 of 1194 relevant lines covered (92.04%)

275.23 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

91.97

/lib/ConfigLocation.js

/**
 * @projectName gofigure
 * @github http://github.com/C2FO/gofigure
 * @header [../README.md]
 * @includeDoc [Change Log] ../History.md
 */

const _ = require('lodash');
const PatternEventEmitter = require('./PatternEventEmitter');
const loader = require('./loader');
const processor = require('./processor');

class ConfigLocation extends PatternEventEmitter {
  /**
   * Aggregate class for a single entry in the `locations` array.
   *
   * Locations will load all the config files specified within their list
   * and then merge them together.
   */
  constructor(locationName, opts) {
    super({});
    if (!locationName) {
      throw new Error('A locationName is required');
    }
    const options = opts || {};
    this.environment = options.environment || process.env.NODE_ENV || null;
    this.nodeType = options.nodeType || process.env.NODE_TYPE || null;
    this.environmentVariables = options.environmentVariables || process.env || {};
    this.defaultEnvironment = options.defaultEnvironment || '*';
    this.config = {};
    this.monitor = !!options.monitor;
    this.locationName = locationName;
    this.loaded = false;
  }

  /**
   * Stops monitoring confgurations for changes.
   *
   * @return {Config} this config object.
   */
  stop() {
    this.__loaders.forEach((l) => l.unWatch());
    return this;
  }

  /**
   * Asynchronously loads configs.
   *
   * @example
   * configLoader.load().then((config) => {
   *     // use the config.
   * })
   *
   * @return {Promise<any>|Promise<any[] | never>} resolves with the merged configuration from all locations.s
   */
  load() {
    if (this.__loaded) {
      return Promise.resolve(this.config);
    }
    return loader.createLoadersAsync({ locations: [this.locationName] }, { monitor: this.monitor }).then((loaders) => {
      this.__loaders = loaders;
      const loads = loaders.map((l) => l.load());
      return Promise.all(loads).then((configs) => this.__postLoad(configs));
    });
  }

  /**
   * Synchronously loads configurations.
   *
   * @example
   * const config = configLoader.loadSync()
   * //use your config.
   *
   * @return {Object} the merged configuration from all locations.
   */
  loadSync() {
    if (this.__loaded) {
      return this.config;
    }
    this.__loaders = loader.createLoadersSync({ locations: [this.locationName] }, { monitor: this.monitor });
    return this.__postLoad(this.__loaders.map((l) => l.loadSync()));
  }

  __mergeConfigs(configs) {
    return processor(_.cloneDeep(this.config), configs, {
      environment: this.environment,
      defaultEnvironment: this.defaultEnvironment,
      nodeType: this.nodeType,
      eventEmitter: this,
      environmentVariables: this.environmentVariables,
    });
  }

  /**
   *  Merges configs and starts monitoring of configs if `monitor` is true.
   * @param configs {Array<Object>} an array of configurations to merge into a single object.
   * @return {Object} the merged config
   * @private
   */
  __postLoad(configs) {
    this.config = this.__mergeConfigs(configs);
    this.__listenToChanges();
    this.__loaded = true;
    return this.config;
  }

  __listenToChanges() {
    this.__loaders.forEach((l) =>
      l.on('change', (path, config) => {
        this.emit('change', this.__mergeConfigs([config]));
      }),
    );
  }
}

module.exports = ConfigLocation;

1	/**	3✔
2	* @projectName gofigure	3✔
3	* @github http://github.com/C2FO/gofigure	3✔
4	* @header [../README.md]	3✔
5	* @includeDoc [Change Log] ../History.md	3✔
6	*/	3✔
7		3✔
8	const _ = require('lodash');	3✔
9	const PatternEventEmitter = require('./PatternEventEmitter');	3✔
10	const loader = require('./loader');	3✔
11	const processor = require('./processor');	3✔
12		3✔
13	class ConfigLocation extends PatternEventEmitter {	3✔
14	/**	3✔
15	* Aggregate class for a single entry in the `locations` array.	3✔
16	*	3✔
17	* Locations will load all the config files specified within their list	3✔
18	* and then merge them together.	3✔
19	*/	3✔
20	constructor(locationName, opts) {	3✔
21	super({});	213✔
22	if (!locationName) {	213!
NEW 23	throw new Error('A locationName is required');	×
NEW 24	}	×
25	const options = opts \|\| {};	213!
26	this.environment = options.environment \|\| process.env.NODE_ENV \|\| null;	213✔
27	this.nodeType = options.nodeType \|\| process.env.NODE_TYPE \|\| null;	213✔
28	this.environmentVariables = options.environmentVariables \|\| process.env \|\| {};	213!
29	this.defaultEnvironment = options.defaultEnvironment \|\| '*';	213✔
30	this.config = {};	213✔
31	this.monitor = !!options.monitor;	213✔
32	this.locationName = locationName;	213✔
33	this.loaded = false;	213✔
34	}	213✔
35		3✔
36	/**	3✔
37	* Stops monitoring confgurations for changes.	3✔
38	*	3✔
39	* @return {Config} this config object.	3✔
40	*/	3✔
41	stop() {	3✔
42	this.__loaders.forEach((l) => l.unWatch());	42✔
43	return this;	42✔
44	}	42✔
45		3✔
46	/**	3✔
47	* Asynchronously loads configs.	3✔
48	*	3✔
49	* @example	3✔
50	* configLoader.load().then((config) => {	3✔
51	* // use the config.	3✔
52	* })	3✔
53	*	3✔
54	* @return {Promise<any>\|Promise<any[] \| never>} resolves with the merged configuration from all locations.s	3✔
55	*/	3✔
56	load() {	3✔
57	if (this.__loaded) {	96!
NEW 58	return Promise.resolve(this.config);	×
NEW 59	}	×
60	return loader.createLoadersAsync({ locations: [this.locationName] }, { monitor: this.monitor }).then((loaders) => {	96✔
61	this.__loaders = loaders;	96✔
62	const loads = loaders.map((l) => l.load());	96✔
63	return Promise.all(loads).then((configs) => this.__postLoad(configs));	96✔
64	});	96✔
65	}	96✔
66		3✔
67	/**	3✔
68	* Synchronously loads configurations.	3✔
69	*	3✔
70	* @example	3✔
71	* const config = configLoader.loadSync()	3✔
72	* //use your config.	3✔
73	*	3✔
74	* @return {Object} the merged configuration from all locations.	3✔
75	*/	3✔
76	loadSync() {	3✔
77	if (this.__loaded) {	117!
NEW 78	return this.config;	×
NEW 79	}	×
80	this.__loaders = loader.createLoadersSync({ locations: [this.locationName] }, { monitor: this.monitor });	117✔
81	return this.__postLoad(this.__loaders.map((l) => l.loadSync()));	117✔
82	}	117✔
83		3✔
84	__mergeConfigs(configs) {	3✔
85	return processor(_.cloneDeep(this.config), configs, {	405✔
86	environment: this.environment,	405✔
87	defaultEnvironment: this.defaultEnvironment,	405✔
88	nodeType: this.nodeType,	405✔
89	eventEmitter: this,	405✔
90	environmentVariables: this.environmentVariables,	405✔
91	});	405✔
92	}	405✔
93		3✔
94	/**	3✔
95	* Merges configs and starts monitoring of configs if `monitor` is true.	3✔
96	* @param configs {Array<Object>} an array of configurations to merge into a single object.	3✔
97	* @return {Object} the merged config	3✔
98	* @private	3✔
99	*/	3✔
100	__postLoad(configs) {	3✔
101	this.config = this.__mergeConfigs(configs);	213✔
102	this.__listenToChanges();	213✔
103	this.__loaded = true;	213✔
104	return this.config;	213✔
105	}	213✔
106		3✔
107	__listenToChanges() {	3✔
108	this.__loaders.forEach((l) =>	213✔
109	l.on('change', (path, config) => {	357✔
110	this.emit('change', this.__mergeConfigs([config]));	192✔
111	}),	192✔
112	);	213✔
113	}	213✔
114	}	3✔
115		3✔
116	module.exports = ConfigLocation;	3✔

C2FO / gofigure / 1030684270

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous