fix(core): update

This commit is contained in:
Philipp Kunz 2019-01-17 01:15:22 +01:00
parent 3151829f85
commit a33090bb5e
5 changed files with 28 additions and 17 deletions

8
package-lock.json generated
View File

@ -206,11 +206,11 @@
} }
}, },
"@pushrocks/smartlog": { "@pushrocks/smartlog": {
"version": "2.0.10", "version": "2.0.11",
"resolved": "https://verdaccio.lossless.one/@pushrocks%2fsmartlog/-/smartlog-2.0.10.tgz", "resolved": "https://verdaccio.lossless.one/@pushrocks%2fsmartlog/-/smartlog-2.0.11.tgz",
"integrity": "sha512-4Ir4/JvfL+d5VsN+O8BpFSgUc1mWgr9s6S/cwYBCAIrWdqGomUM5RsZs57RMDn9MWW0JGJjGhUA0M+A8LSSgHw==", "integrity": "sha512-V8SMzAAqDpl1+CJ9b3w5e/1ARjk4JOPZ35qZIllVBhHr8meCqnPE2immlfBYWmEp1xy3ntdAA+Lgewtu+iVk6A==",
"requires": { "requires": {
"@pushrocks/smartlog-interfaces": "^2.0.2" "@pushrocks/smartlog-interfaces": "^2.0.5"
} }
}, },
"@pushrocks/smartlog-interfaces": { "@pushrocks/smartlog-interfaces": {

View File

@ -30,7 +30,7 @@
"@pushrocks/smartdelay": "^2.0.2", "@pushrocks/smartdelay": "^2.0.2",
"@pushrocks/smartdns": "^3.0.8", "@pushrocks/smartdns": "^3.0.8",
"@pushrocks/smartexpress": "^3.0.6", "@pushrocks/smartexpress": "^3.0.6",
"@pushrocks/smartlog": "^2.0.10", "@pushrocks/smartlog": "^2.0.11",
"@pushrocks/smartpromise": "^2.0.5", "@pushrocks/smartpromise": "^2.0.5",
"@pushrocks/smartrequest": "^1.1.14", "@pushrocks/smartrequest": "^1.1.14",
"@pushrocks/smartstring": "^3.0.8", "@pushrocks/smartstring": "^3.0.8",

View File

@ -62,6 +62,7 @@ export class CertManager {
public async storeCertificate(optionsArg: interfaces.ICert) { public async storeCertificate(optionsArg: interfaces.ICert) {
const cert = new Cert(optionsArg); const cert = new Cert(optionsArg);
await cert.save(); await cert.save();
this.pendingMap.removeString(optionsArg.domainName);
} }
public async deleteCertificate(domainNameArg: string) { public async deleteCertificate(domainNameArg: string) {
@ -97,5 +98,7 @@ export class CertManager {
/** /**
* checks all certs for expiration * checks all certs for expiration
*/ */
private async checkCerts() {}; private async checkCerts() {
// TODO
};
} }

View File

@ -26,7 +26,7 @@ export class CertRemoteClient {
public async getCertificateForDomain(domainNameArg: string): Promise<interfaces.ICert> { public async getCertificateForDomain(domainNameArg: string): Promise<interfaces.ICert> {
let certificate: interfaces.ICert; let certificate: interfaces.ICert;
const doRequestCycle = async (): Promise<interfaces.ICert> => { const doRequestCycle = async (): Promise<interfaces.ICert> => {
const response: interfaces.ICertRemoteResponse = (await plugins.smartrequest.postJson( const responseBody: interfaces.ICertRemoteResponse = (await plugins.smartrequest.postJson(
this.remoteUrl, this.remoteUrl,
{ {
requestBody: <interfaces.ICertRemoteRequest>{ requestBody: <interfaces.ICertRemoteRequest>{
@ -35,13 +35,15 @@ export class CertRemoteClient {
} }
} }
)).body; )).body;
switch (response.status as interfaces.TCertStatus) { console.log(responseBody);
switch (responseBody.status as interfaces.TCertStatus) {
case 'pending': case 'pending':
await plugins.smartdelay.delayFor(5000); await plugins.smartdelay.delayFor(5000);
const finalResponse = await doRequestCycle(); const finalResponse = await doRequestCycle();
return finalResponse; return finalResponse;
case 'existing': case 'existing':
return response.certificate; this.logger.log('ok', `got certificate for ${domainNameArg}`);
return responseBody.certificate;
case 'failed': case 'failed':
default: default:
console.log(`could not retrieve certificate for ${domainNameArg}`); console.log(`could not retrieve certificate for ${domainNameArg}`);

View File

@ -16,6 +16,7 @@ export interface ISmartAcmeOptions {
setChallenge: (domainName: string, keyAuthorization: string) => Promise<any>; setChallenge: (domainName: string, keyAuthorization: string) => Promise<any>;
removeChallenge: (domainName: string) => Promise<any>; removeChallenge: (domainName: string) => Promise<any>;
environment: 'production' | 'integration'; environment: 'production' | 'integration';
logger?: plugins.smartlog.Smartlog;
} }
/** /**
@ -34,6 +35,7 @@ export class SmartAcme {
// the acme client // the acme client
private client: any; private client: any;
private smartdns = new plugins.smartdns.Smartdns(); private smartdns = new plugins.smartdns.Smartdns();
public logger: plugins.smartlog.Smartlog;
// the account private key // the account private key
private privateKey: string; private privateKey: string;
@ -49,15 +51,19 @@ export class SmartAcme {
/** /**
* the remote handler to hand the request and response to. * the remote handler to hand the request and response to.
*/ */
public certremoteHandler = async (req: plugins.smartexpress.Request, res: plugins.smartexpress.Response) => { public certremoteHandler = async (
req: plugins.smartexpress.Request,
res: plugins.smartexpress.Response
) => {
const requestBody: interfaces.ICertRemoteRequest = req.body; const requestBody: interfaces.ICertRemoteRequest = req.body;
const certDomain = this.certmatcher.getCertificateDomainNameByDomainName(requestBody.domainName); const certDomain = this.certmatcher.getCertificateDomainNameByDomainName(
let status: interfaces.TCertStatus = await this.certmanager.getCertificateStatus( requestBody.domainName
certDomain
); );
let status: interfaces.TCertStatus = await this.certmanager.getCertificateStatus(certDomain);
let response: interfaces.ICertRemoteResponse; let response: interfaces.ICertRemoteResponse;
switch (status) { switch (status) {
case 'existing': case 'existing':
this.logger.log('ok', `certificate exists for ${certDomain}. Sending certificate!`);
response = { response = {
status, status,
certificate: await (await this.certmanager.retrieveCertificate( certificate: await (await this.certmanager.retrieveCertificate(
@ -66,7 +72,7 @@ export class SmartAcme {
}; };
break; break;
default: default:
if (status === "nonexisting") { if (status === 'nonexisting') {
this.getCertificateForDomain(certDomain); this.getCertificateForDomain(certDomain);
status = 'pending'; status = 'pending';
} }
@ -82,6 +88,9 @@ export class SmartAcme {
constructor(optionsArg: ISmartAcmeOptions) { constructor(optionsArg: ISmartAcmeOptions) {
this.options = optionsArg; this.options = optionsArg;
this.options.logger
? (this.logger = optionsArg.logger)
: (this.logger = plugins.smartlog.defaultLogger);
} }
/** /**
@ -189,9 +198,6 @@ export class SmartAcme {
const cert = await this.client.getCertificate(order); const cert = await this.client.getCertificate(order);
/* Done */ /* Done */
console.log(`CSR:\n${csr.toString()}`);
console.log(`Private key:\n${key.toString()}`);
console.log(`Certificate:\n${cert.toString()}`);
await this.certmanager.storeCertificate({ await this.certmanager.storeCertificate({
id: plugins.smartunique.shortId(), id: plugins.smartunique.shortId(),