mirror of https://github.com/hashicorp/consul
Encapsulate hcp related logic in service
parent
dcdcdbc5ea
commit
14b90314e9
|
@ -0,0 +1,37 @@
|
||||||
|
import Service, { inject as service } from '@ember/service';
|
||||||
|
import { runInDebug } from '@ember/debug';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* A service to encapsulate all logic that handles dealing with setting up consul
|
||||||
|
* core correctly when started via HCP.
|
||||||
|
*/
|
||||||
|
export default class HCPService extends Service {
|
||||||
|
@service('env') env;
|
||||||
|
@service('repository/token') tokenRepo;
|
||||||
|
@service('settings') settings;
|
||||||
|
|
||||||
|
async updateTokenIfNecessary(secret) {
|
||||||
|
if (secret) {
|
||||||
|
const existing = await this.settings.findBySlug('token');
|
||||||
|
|
||||||
|
if (secret && secret !== existing.SecretID) {
|
||||||
|
try {
|
||||||
|
const token = await this.tokenRepo.self({
|
||||||
|
secret: secret,
|
||||||
|
dc: this.env.var('CONSUL_DATACENTER_LOCAL'),
|
||||||
|
});
|
||||||
|
await this.settings.persist({
|
||||||
|
token: {
|
||||||
|
AccessorID: token.AccessorID,
|
||||||
|
SecretID: token.SecretID,
|
||||||
|
Namespace: token.Namespace,
|
||||||
|
Partition: token.Partition,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
} catch (e) {
|
||||||
|
runInDebug((_) => console.error(e));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in New Issue