forked from RedHatInsights/notifications-backend
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[RHCLOUD-29487] Record gateway certificate details on database (RedHa…
…tInsights#2366) * [RHCLOUD-29487] Record gateway certificate details on database --------- Co-authored-by: Gwenneg Lepage <[email protected]>
- Loading branch information
Showing
6 changed files
with
407 additions
and
0 deletions.
There are no files selected for viewing
66 changes: 66 additions & 0 deletions
66
...c/main/java/com/redhat/cloud/notifications/db/repositories/X509CertificateRepository.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,66 @@ | ||
| package com.redhat.cloud.notifications.db.repositories; | ||
|
|
||
| import com.redhat.cloud.notifications.models.Application; | ||
| import com.redhat.cloud.notifications.models.X509Certificate; | ||
| import jakarta.enterprise.context.ApplicationScoped; | ||
| import jakarta.inject.Inject; | ||
| import jakarta.persistence.EntityManager; | ||
| import jakarta.persistence.NoResultException; | ||
| import jakarta.transaction.Transactional; | ||
| import java.util.Optional; | ||
| import java.util.UUID; | ||
|
|
||
| @ApplicationScoped | ||
| public class X509CertificateRepository { | ||
|
|
||
| @Inject | ||
| EntityManager entityManager; | ||
|
|
||
| @Inject | ||
| ApplicationRepository applicationRepository; | ||
|
|
||
| @Transactional | ||
| public X509Certificate createCertificate(X509Certificate gatewayCertificate) { | ||
| Application application = applicationRepository.getApplication(gatewayCertificate.getBundle(), gatewayCertificate.getApplication()); | ||
| gatewayCertificate.setCertificateApplication(application); | ||
| entityManager.persist(gatewayCertificate); | ||
| return gatewayCertificate; | ||
| } | ||
|
|
||
|
|
||
| public Optional<X509Certificate> findCertificate(String bundle, String application, String subjectDn) { | ||
| final String query = "SELECT gc FROM X509Certificate gc where gc.certificateApplication.bundle.name = :bundle " + | ||
| "AND gc.certificateApplication.name = :application " + | ||
| "AND gc.subjectDn = :subjectDn"; | ||
| try { | ||
| return Optional.of(this.entityManager | ||
| .createQuery(query, X509Certificate.class) | ||
| .setParameter("bundle", bundle) | ||
| .setParameter("application", application) | ||
| .setParameter("subjectDn", subjectDn) | ||
| .getSingleResult()); | ||
| } catch (NoResultException e) { | ||
| return Optional.empty(); | ||
| } | ||
| } | ||
|
|
||
| @Transactional | ||
| public boolean updateCertificate(UUID id, X509Certificate gatewayCertificate) { | ||
| String hql = "UPDATE X509Certificate SET subjectDn = :subjectDn, sourceEnvironment = :sourceEnvironment WHERE id = :id"; | ||
| int rowCount = entityManager.createQuery(hql) | ||
| .setParameter("subjectDn", gatewayCertificate.getSubjectDn()) | ||
| .setParameter("sourceEnvironment", gatewayCertificate.getSourceEnvironment()) | ||
| .setParameter("id", id) | ||
| .executeUpdate(); | ||
| return rowCount > 0; | ||
| } | ||
|
|
||
| @Transactional | ||
| public boolean deleteCertificate(UUID id) { | ||
| String deleteHql = "DELETE FROM X509Certificate WHERE id = :id"; | ||
| int rowCount = entityManager.createQuery(deleteHql) | ||
| .setParameter("id", id) | ||
| .executeUpdate(); | ||
| return rowCount > 0; | ||
| } | ||
| } |
95 changes: 95 additions & 0 deletions
95
backend/src/main/java/com/redhat/cloud/notifications/models/X509Certificate.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,95 @@ | ||
| package com.redhat.cloud.notifications.models; | ||
|
|
||
| import com.fasterxml.jackson.annotation.JsonIgnore; | ||
| import com.fasterxml.jackson.annotation.JsonProperty; | ||
| import com.fasterxml.jackson.databind.PropertyNamingStrategies.SnakeCaseStrategy; | ||
| import com.fasterxml.jackson.databind.annotation.JsonNaming; | ||
| import jakarta.persistence.Entity; | ||
| import jakarta.persistence.FetchType; | ||
| import jakarta.persistence.GeneratedValue; | ||
| import jakarta.persistence.Id; | ||
| import jakarta.persistence.JoinColumn; | ||
| import jakarta.persistence.ManyToOne; | ||
| import jakarta.persistence.Table; | ||
| import jakarta.persistence.Transient; | ||
| import jakarta.validation.constraints.NotNull; | ||
| import java.util.UUID; | ||
|
|
||
| import static com.fasterxml.jackson.annotation.JsonProperty.Access.READ_ONLY; | ||
|
|
||
| @Entity | ||
| @Table(name = "x509_certificate") | ||
| @JsonNaming(SnakeCaseStrategy.class) | ||
| public class X509Certificate { | ||
| @Id | ||
| @GeneratedValue | ||
| @JsonProperty(access = READ_ONLY) | ||
| private UUID id; | ||
|
|
||
| @NotNull | ||
| private String subjectDn; | ||
|
|
||
| @NotNull | ||
| private String sourceEnvironment; | ||
|
|
||
| @NotNull | ||
| @Transient | ||
| private String bundle; | ||
|
|
||
| @NotNull | ||
| @Transient | ||
| private String application; | ||
|
|
||
| @ManyToOne(fetch = FetchType.LAZY, optional = false) | ||
| @JoinColumn(name = "application_id") | ||
| @JsonIgnore | ||
| private Application certificateApplication; | ||
|
|
||
| public UUID getId() { | ||
| return id; | ||
| } | ||
|
|
||
| public void setId(UUID id) { | ||
| this.id = id; | ||
| } | ||
|
|
||
| public String getSubjectDn() { | ||
| return subjectDn; | ||
| } | ||
|
|
||
| public void setSubjectDn(String subjectDn) { | ||
| this.subjectDn = subjectDn; | ||
| } | ||
|
|
||
| public String getSourceEnvironment() { | ||
| return sourceEnvironment; | ||
| } | ||
|
|
||
| public void setSourceEnvironment(String environment) { | ||
| this.sourceEnvironment = environment; | ||
| } | ||
|
|
||
| public String getBundle() { | ||
| return bundle; | ||
| } | ||
|
|
||
| public void setBundle(String bundle) { | ||
| this.bundle = bundle; | ||
| } | ||
|
|
||
| public String getApplication() { | ||
| return application; | ||
| } | ||
|
|
||
| public void setApplication(String application) { | ||
| this.application = application; | ||
| } | ||
|
|
||
| public Application getCertificateApplication() { | ||
| return certificateApplication; | ||
| } | ||
|
|
||
| public void setCertificateApplication(Application certificateApplication) { | ||
| this.certificateApplication = certificateApplication; | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
56 changes: 56 additions & 0 deletions
56
...rc/main/java/com/redhat/cloud/notifications/routers/internal/X509CertificateResource.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,56 @@ | ||
| package com.redhat.cloud.notifications.routers.internal; | ||
|
|
||
| import com.redhat.cloud.notifications.db.repositories.X509CertificateRepository; | ||
| import com.redhat.cloud.notifications.models.X509Certificate; | ||
| import jakarta.annotation.security.RolesAllowed; | ||
| import jakarta.inject.Inject; | ||
| import jakarta.validation.Valid; | ||
| import jakarta.validation.constraints.NotNull; | ||
| import jakarta.ws.rs.Consumes; | ||
| import jakarta.ws.rs.DELETE; | ||
| import jakarta.ws.rs.POST; | ||
| import jakarta.ws.rs.PUT; | ||
| import jakarta.ws.rs.Path; | ||
| import jakarta.ws.rs.Produces; | ||
| import jakarta.ws.rs.core.Response; | ||
| import org.jboss.resteasy.reactive.RestPath; | ||
| import java.util.UUID; | ||
|
|
||
| import static com.redhat.cloud.notifications.Constants.API_INTERNAL; | ||
| import static com.redhat.cloud.notifications.auth.ConsoleIdentityProvider.RBAC_INTERNAL_ADMIN; | ||
| import static jakarta.ws.rs.core.MediaType.APPLICATION_JSON; | ||
| import static jakarta.ws.rs.core.MediaType.TEXT_PLAIN; | ||
|
|
||
| @Path(API_INTERNAL + "/x509Certificates") | ||
| @RolesAllowed(RBAC_INTERNAL_ADMIN) | ||
| public class X509CertificateResource { | ||
|
|
||
| @Inject | ||
| X509CertificateRepository x509CertificateRepository; | ||
|
|
||
| @POST | ||
| @Consumes(APPLICATION_JSON) | ||
| @Produces(APPLICATION_JSON) | ||
| public X509Certificate createCertificate(@NotNull @Valid X509Certificate certificate) { | ||
| return x509CertificateRepository.createCertificate(certificate); | ||
| } | ||
|
|
||
| @PUT | ||
| @Path("/{certificateId}") | ||
| @Consumes(APPLICATION_JSON) | ||
| @Produces(TEXT_PLAIN) | ||
| public Response updateCertificate(@RestPath UUID certificateId, @NotNull X509Certificate certificate) { | ||
| boolean updated = x509CertificateRepository.updateCertificate(certificateId, certificate); | ||
| if (updated) { | ||
| return Response.ok().build(); | ||
| } else { | ||
| return Response.status(Response.Status.NOT_FOUND).build(); | ||
| } | ||
| } | ||
|
|
||
| @DELETE | ||
| @Path("/{certificateId}") | ||
| public boolean deleteCertificate(@RestPath UUID certificateId) { | ||
| return x509CertificateRepository.deleteCertificate(certificateId); | ||
| } | ||
| } |
Oops, something went wrong.