fix merge

This commit is contained in:
Curtis Castrapel 2018-08-16 10:15:48 -07:00
commit be9d683e46
5 changed files with 41 additions and 7 deletions

View File

@ -0,0 +1,32 @@
"""Convert pending cert status field to text
Revision ID: 5ae0ecefb01f
Revises: 1db4f82bc780
Create Date: 2018-08-14 08:16:43.329316
"""
# revision identifiers, used by Alembic.
revision = '5ae0ecefb01f'
down_revision = '1db4f82bc780'
from alembic import op
import sqlalchemy as sa
def upgrade():
op.alter_column(
table_name='pending_certs',
column_name='status',
nullable=True,
type_=sa.TEXT()
)
def downgrade():
op.alter_column(
table_name='pending_certs',
column_name='status',
nullable=True,
type_=sa.VARCHAR(128)
)

View File

@ -107,12 +107,12 @@ def fetch_all_acme():
if pending_cert.number_attempts > 4: if pending_cert.number_attempts > 4:
error_log["message"] = "Deleting pending certificate" error_log["message"] = "Deleting pending certificate"
send_pending_failure_notification(pending_cert, notify_owner=pending_cert.notify) send_pending_failure_notification(pending_cert, notify_owner=pending_cert.notify)
pending_certificate_service.delete_by_id(pending_cert.id) pending_certificate_service.delete(pending_certificate_service.cancel(pending_cert))
else: else:
pending_certificate_service.increment_attempt(pending_cert) pending_certificate_service.increment_attempt(pending_cert)
pending_certificate_service.update( pending_certificate_service.update(
cert.get("pending_cert").id, cert.get("pending_cert").id,
status=str(cert.get("last_error"))[0:128] status=str(cert.get("last_error"))
) )
current_app.logger.error(error_log) current_app.logger.error(error_log)
log_data["message"] = "Complete" log_data["message"] = "Complete"

View File

@ -39,7 +39,7 @@ class PendingCertificate(db.Model):
date_created = Column(ArrowType, PassiveDefault(func.now()), nullable=False) date_created = Column(ArrowType, PassiveDefault(func.now()), nullable=False)
dns_provider_id = Column(Integer, ForeignKey('dns_providers.id', ondelete="CASCADE")) dns_provider_id = Column(Integer, ForeignKey('dns_providers.id', ondelete="CASCADE"))
status = Column(String(128)) status = Column(Text(), nullable=True)
rotation = Column(Boolean, default=False) rotation = Column(Boolean, default=False)
user_id = Column(Integer, ForeignKey('users.id')) user_id = Column(Integer, ForeignKey('users.id'))

View File

@ -215,7 +215,7 @@ class AcmeHandler(object):
if not dns_provider.domains: if not dns_provider.domains:
continue continue
for name in dns_provider.domains: for name in dns_provider.domains:
if domain.endswith(name): if domain.endswith("." + name):
self.dns_providers_for_domain[domain].append(dns_provider) self.dns_providers_for_domain[domain].append(dns_provider)
return self.dns_providers_for_domain return self.dns_providers_for_domain
@ -477,7 +477,8 @@ class ACMEIssuerPlugin(IssuerPlugin):
current_app.logger.debug("Using DNS provider: {0}".format(dns_provider.provider_type)) current_app.logger.debug("Using DNS provider: {0}".format(dns_provider.provider_type))
dns_provider_plugin = __import__(dns_provider.provider_type, globals(), locals(), [], 1) dns_provider_plugin = __import__(dns_provider.provider_type, globals(), locals(), [], 1)
account_number = credentials.get("account_id") account_number = credentials.get("account_id")
if dns_provider.provider_type == 'route53' and not account_number: provider_type = dns_provider.provider_type
if provider_type == "route53" and not account_number:
error = "Route53 DNS Provider {} does not have an account number configured.".format(dns_provider.name) error = "Route53 DNS Provider {} does not have an account number configured.".format(dns_provider.name)
current_app.logger.error(error) current_app.logger.error(error)
raise InvalidConfiguration(error) raise InvalidConfiguration(error)
@ -485,6 +486,7 @@ class ACMEIssuerPlugin(IssuerPlugin):
dns_provider = {} dns_provider = {}
dns_provider_options = None dns_provider_options = None
account_number = None account_number = None
provider_type = None
domains = self.acme.get_domains(issuer_options) domains = self.acme.get_domains(issuer_options)
if not create_immediately: if not create_immediately:
@ -497,7 +499,7 @@ class ACMEIssuerPlugin(IssuerPlugin):
authz_domains.append(d.value) authz_domains.append(d.value)
dns_authorization = authorization_service.create(account_number, authz_domains, dns_authorization = authorization_service.create(account_number, authz_domains,
dns_provider.get("provider_type")) provider_type)
# Return id of the DNS Authorization # Return id of the DNS Authorization
return None, None, dns_authorization.id return None, None, dns_authorization.id

View File

@ -82,7 +82,7 @@
</li> </li>
<li class="list-group-item"> <li class="list-group-item">
<strong>Latest Status</strong> <strong>Latest Status</strong>
<span class="pull-right"> <span class="center-block">
{{ pendingCertificate.status }} {{ pendingCertificate.status }}
</span> </span>
</li> </li>