Job postings can now include desired certifications (#294)

Signed-off-by: Sergio Castaño Arteaga <[email protected]>
Signed-off-by: Cintia Sánchez García <[email protected]>
Co-authored-by: Cintia Sánchez García <[email protected]>

Author: tegioz

database/migrations/schema/0013_certifications.sql

@@ -0,0 +1,41 @@
+create table certification (
+    certification_id uuid primary key default gen_random_uuid(),
+
+    name text not null unique check (name <> ''),
+    provider text not null check (provider <> ''),
+    short_name text not null unique check (short_name <> ''),
+
+    description text check (description <> ''),
+    logo_url text check (logo_url <> ''),
+    url text check (url <> '')
+);
+
+insert into certification (name, provider, short_name, description, url, logo_url) values
+('Certified Kubernetes Administrator', 'CNCF', 'CKA', 'Performance-based exam where candidates interact with the command line to solve real-world challenges', 'https://www.cncf.io/training/certification/cka/', 'https://www.cncf.io/wp-content/uploads/2021/09/kubernetes-cka-color.svg'),
+('Certified Kubernetes Application Developer', 'CNCF', 'CKAD', 'Proves you can design, build, and manage cloud-native applications on Kubernetes', 'https://www.cncf.io/training/certification/ckad/', 'https://www.cncf.io/wp-content/uploads/2021/09/kubernetes-ckad-color.svg'),
+('Certified Kubernetes Security Specialist', 'CNCF', 'CKS', 'Covers best practices for securing container-based applications and Kubernetes platforms', 'https://www.cncf.io/training/certification/cks/', 'https://www.cncf.io/wp-content/uploads/2020/11/kubernetes-security-specialist-logo.svg'),
+('Kubernetes and Cloud Native Associate', 'CNCF', 'KCNA', 'Entry-level credential focusing on Kubernetes and broader cloud native ecosystem', 'https://www.cncf.io/training/certification/kcna/', 'https://www.cncf.io/wp-content/uploads/2021/09/kcna_color.svg'),
+('Kubernetes and Cloud Security Associate', 'CNCF', 'KCSA', 'Validates skills in evaluating Kubernetes cluster security configurations and compliance', 'https://www.cncf.io/training/certification/kcsa/', 'https://www.cncf.io/wp-content/uploads/2024/03/kubernetes-kcsa-color.svg'),
+('Prometheus Certified Associate', 'CNCF', 'PCA', 'Entry-level certification demonstrating foundational knowledge of observability and Prometheus monitoring', 'https://www.cncf.io/training/certification/pca/', 'https://www.cncf.io/wp-content/uploads/2023/11/PCA-Prometheus-Certified-Associate-logo-color.svg'),
+('Istio Certified Associate', 'CNCF', 'ICA', 'Pre-professional certification demonstrating foundational knowledge of Istio principles, terminology, and best practices', 'https://www.cncf.io/training/certification/ica/', 'https://www.cncf.io/wp-content/uploads/2024/03/ica-icon-color.svg'),
+('Cilium Certified Associate', 'CNCF', 'CCA', 'Entry-level certification designed for platform or cloud engineers interested in networking, security, and observability', 'https://www.cncf.io/training/certification/cca/', 'https://www.cncf.io/wp-content/uploads/2024/03/cca-icon-color.svg'),
+('Certified Argo Project Associate', 'CNCF', 'CAPA', 'Designed for engineers, data scientists, and others interested in demonstrating their understanding of the Argo Project ecosystem', 'https://www.cncf.io/training/certification/capa/', 'https://www.cncf.io/wp-content/uploads/2024/03/capa-icon-color.svg'),
+('GitOps Certified Associate', 'CNCF', 'CGOA', 'For DevOps engineers and team members, platform and software engineers, CI/CD practitioners interested in GitOps', 'https://www.cncf.io/training/certification/cgoa/', 'https://www.cncf.io/wp-content/uploads/2024/03/gitops_associate.svg'),
+('Certified Backstage Associate', 'CNCF', 'CBA', 'Proves you have the skills & the mindset to work with Backstage to advance your career, your team & your organization', 'https://www.cncf.io/training/certification/cba/', 'https://www.cncf.io/wp-content/uploads/2024/11/lft_badge_backstage_associate1.svg'),
+('OpenTelemetry Certified Associate', 'CNCF', 'OTCA', 'Prove your expertise in OpenTelemetry – the industry standard for tracing, metrics & logs', 'https://www.cncf.io/training/certification/otca/', 'https://www.cncf.io/wp-content/uploads/2024/11/lft_badge_opentelemetry_associate1.svg'),
+('Kyverno Certified Associate', 'CNCF', 'KCA', 'Position yourself as an expert in managing and securing Kubernetes environments. Kyverno expertise shows you understand the advanced aspects of cloud management and security', 'https://www.cncf.io/training/certification/kca/', 'https://www.cncf.io/wp-content/uploads/2024/11/lft_badge_kyverno_associate1.svg');
+
+create table job_certification (
+    job_id uuid not null references job on delete cascade,
+    certification_id uuid not null references certification on delete restrict,
+
+    primary key (job_id, certification_id)
+);
+
+create index job_certification_job_id_idx on job_certification (job_id);
+create index job_certification_certification_id_idx on job_certification (certification_id);
+
+---- create above / drop below ----
+
+drop table job_certification;
+drop table certification;

gitjobs-server/src/db/dashboard/employer.rs

@@ -17,7 +17,7 @@ use crate::{
             team::{TeamInvitation, TeamMember},
         },
         helpers::normalize_salary,
-        misc::Foundation,
+        misc::{Certification, Foundation},
     },
 };
 
@@ -74,6 +74,9 @@ pub(crate) trait DBDashBoardEmployer {
     /// Lists all employers where the user is a team member.
     async fn list_employers(&self, user_id: &Uuid) -> Result<Vec<EmployerSummary>>;
 
+    /// Lists all available certifications.
+    async fn list_certifications(&self) -> Result<Vec<Certification>>;
+
     /// Lists all available foundations.
     async fn list_foundations(&self) -> Result<Vec<Foundation>>;
 
@@ -301,6 +304,20 @@ impl DBDashBoardEmployer for PgDB {
             }
         }
 
+        // Insert job certifications
+        if let Some(certifications) = &job.certifications {
+            for certification in certifications {
+                tx.execute(
+                    "
+                    insert into job_certification (job_id, certification_id)
+                    values ($1::uuid, $2::uuid);
+                    ",
+                    &[&job_id, &certification.certification_id],
+                )
+                .await?;
+            }
+        }
+
         // Commit transaction
         tx.commit().await?;
 
@@ -602,7 +619,22 @@ impl DBDashBoardEmployer for PgDB {
                         left join job_project jp using (project_id)
                         left join job j using (job_id)
                         where j.job_id = $1::uuid
-                    ) as projects
+                    ) as projects,
+                    (
+                        select json_agg(json_build_object(
+                            'certification_id', c.certification_id,
+                            'name', c.name,
+                            'provider', c.provider,
+                            'short_name', c.short_name,
+                            'description', c.description,
+                            'url', c.url,
+                            'logo_url', c.logo_url
+                        ))
+                        from certification c
+                        left join job_certification jc using (certification_id)
+                        left join job j using (job_id)
+                        where j.job_id = $1::uuid
+                    ) as certifications
                 from job j
                 left join location l using (location_id)
                 where job_id = $1::uuid
@@ -621,6 +653,9 @@ impl DBDashBoardEmployer for PgDB {
             apply_instructions: row.get("apply_instructions"),
             apply_url: row.get("apply_url"),
             benefits: row.get("benefits"),
+            certifications: row
+                .get::<_, Option<serde_json::Value>>("certifications")
+                .map(|v| serde_json::from_value(v).expect("certifications should be valid json")),
             job_id: row.get("job_id"),
             location: row
                 .get::<_, Option<serde_json::Value>>("location")
@@ -786,6 +821,43 @@ impl DBDashBoardEmployer for PgDB {
         Ok(employers)
     }
 
+    #[instrument(skip(self), err)]
+    async fn list_certifications(&self) -> Result<Vec<Certification>> {
+        trace!("db: list certifications");
+
+        let db = self.pool.get().await?;
+        let certifications = db
+            .query(
+                "
+                select
+                    certification_id,
+                    name,
+                    provider,
+                    short_name,
+                    description,
+                    logo_url,
+                    url
+                from certification
+                order by name asc;
+                ",
+                &[],
+            )
+            .await?
+            .into_iter()
+            .map(|row| Certification {
+                certification_id: row.get("certification_id"),
+                name: row.get("name"),
+                provider: row.get("provider"),
+                short_name: row.get("short_name"),
+                description: row.get("description"),
+                logo_url: row.get("logo_url"),
+                url: row.get("url"),
+            })
+            .collect();
+
+        Ok(certifications)
+    }
+
     #[instrument(skip(self), err)]
     async fn list_foundations(&self) -> Result<Vec<Foundation>> {
         trace!("db: list foundations");
@@ -1060,8 +1132,8 @@ impl DBDashBoardEmployer for PgDB {
             )
             .await?;
 
-        // Update job projects
         if rows_updated == 1 {
+            // Update job projects
             tx.execute("delete from job_project where job_id = $1::uuid;", &[&job_id])
                 .await?;
             if let Some(projects) = &job.projects {
@@ -1076,6 +1148,25 @@ impl DBDashBoardEmployer for PgDB {
                     .await?;
                 }
             }
+
+            // Update job certifications
+            tx.execute(
+                "delete from job_certification where job_id = $1::uuid;",
+                &[&job_id],
+            )
+            .await?;
+            if let Some(certifications) = &job.certifications {
+                for certification in certifications {
+                    tx.execute(
+                        "
+                        insert into job_certification (job_id, certification_id)
+                        values ($1::uuid, $2::uuid);
+                        ",
+                        &[&job_id, &certification.certification_id],
+                    )
+                    .await?;
+                }
+            }
         }
 
         // Commit transaction

gitjobs-server/src/db/jobboard.rs

@@ -138,7 +138,22 @@ impl DBJobBoard for PgDB {
                         left join job_project jp using (project_id)
                         left join job j using (job_id)
                         where j.job_id = $1::uuid
-                    ) as projects
+                    ) as projects,
+                    (
+                        select json_agg(json_build_object(
+                            'certification_id', c.certification_id,
+                            'name', c.name,
+                            'provider', c.provider,
+                            'short_name', c.short_name,
+                            'description', c.description,
+                            'logo_url', c.logo_url,
+                            'url', c.url
+                        ))
+                        from certification c
+                        left join job_certification jc using (certification_id)
+                        left join job j using (job_id)
+                        where j.job_id = $1::uuid
+                    ) as certifications
                 from job j
                 join employer e on j.employer_id = e.employer_id
                 left join location l on j.location_id = l.location_id
@@ -162,6 +177,9 @@ impl DBJobBoard for PgDB {
                 apply_instructions: row.get("apply_instructions"),
                 apply_url: row.get("apply_url"),
                 benefits: row.get("benefits"),
+                certifications: row
+                    .get::<_, Option<serde_json::Value>>("certifications")
+                    .map(|v| serde_json::from_value(v).expect("certifications should be valid json")),
                 location: row
                     .get::<_, Option<serde_json::Value>>("location")
                     .map(|v| serde_json::from_value(v).expect("location should be valid json")),

gitjobs-server/src/handlers/dashboard/employer/jobs.rs

@@ -26,8 +26,11 @@ use crate::{
 /// Renders the page to add a new job for an employer.
 #[instrument(skip_all, err)]
 pub(crate) async fn add_page(State(db): State<DynDB>) -> Result<impl IntoResponse, HandlerError> {
-    let foundations = db.list_foundations().await?;
-    let template = jobs::AddPage { foundations };
+    let (certifications, foundations) = tokio::try_join!(db.list_certifications(), db.list_foundations())?;
+    let template = jobs::AddPage {
+        certifications,
+        foundations,
+    };
 
     Ok(Html(template.render()?))
 }
@@ -87,9 +90,16 @@ pub(crate) async fn update_page(
     State(db): State<DynDB>,
     Path(job_id): Path<Uuid>,
 ) -> Result<impl IntoResponse, HandlerError> {
-    let foundations = db.list_foundations().await?;
-    let job = db.get_job_dashboard(&job_id).await?;
-    let template = jobs::UpdatePage { foundations, job };
+    let (certifications, foundations, job) = tokio::try_join!(
+        db.list_certifications(),
+        db.list_foundations(),
+        db.get_job_dashboard(&job_id)
+    )?;
+    let template = jobs::UpdatePage {
+        certifications,
+        foundations,
+        job,
+    };
 
     Ok(Html(template.render()?).into_response())
 }

gitjobs-server/src/templates/dashboard/employer/jobs.rs

@@ -11,7 +11,7 @@ use crate::templates::{
     filters,
     helpers::{DATE_FORMAT, build_dashboard_image_url, format_location, normalize, normalize_salary},
     jobboard::jobs::Seniority,
-    misc::{Foundation, Location, Project},
+    misc::{Certification, Foundation, Location, Project},
 };
 
 // Pages templates.
@@ -20,6 +20,8 @@ use crate::templates::{
 #[derive(Debug, Clone, Template, Serialize, Deserialize)]
 #[template(path = "dashboard/employer/jobs/add.html")]
 pub(crate) struct AddPage {
+    /// List of available certifications for job requirements.
+    pub certifications: Vec<Certification>,
     /// List of available foundations for job association.
     pub foundations: Vec<Foundation>,
 }
@@ -46,6 +48,8 @@ pub(crate) struct PreviewPage {
 #[derive(Debug, Clone, Template, Serialize, Deserialize)]
 #[template(path = "dashboard/employer/jobs/update.html")]
 pub(crate) struct UpdatePage {
+    /// List of available certifications for job requirements.
+    pub certifications: Vec<Certification>,
     /// List of available foundations for job association.
     pub foundations: Vec<Foundation>,
     /// Job details to update.
@@ -102,6 +106,8 @@ pub(crate) struct Job {
     pub apply_url: Option<String>,
     /// List of job benefits, if any.
     pub benefits: Option<Vec<String>>,
+    /// Desired certifications, if any.
+    pub certifications: Option<Vec<Certification>>,
     /// Unique identifier for the job, if available.
     pub job_id: Option<Uuid>,
     /// Location details for the job, if specified.

gitjobs-server/src/templates/jobboard/jobs.rs

@@ -12,7 +12,7 @@ use crate::templates::{
     dashboard::employer::jobs::{JobKind, SalaryKind, Workplace},
     filters,
     helpers::{DATE_FORMAT, DATE_FORMAT_3, build_jobboard_image_url, option_is_none_or_default},
-    misc::{Foundation, Location, Member, Project},
+    misc::{Certification, Foundation, Location, Member, Project},
     pagination::{NavigationLinks, Pagination},
 };
 
@@ -310,6 +310,8 @@ pub(crate) struct Job {
     pub apply_url: Option<String>,
     /// List of benefits, if any.
     pub benefits: Option<Vec<String>>,
+    /// Desired certifications, if any.
+    pub certifications: Option<Vec<Certification>>,
     /// Location of the job, if specified.
     pub location: Option<Location>,
     /// Open source status, if specified.

gitjobs-server/src/templates/misc.rs

@@ -36,6 +36,26 @@ pub(crate) struct UserMenuSection {
 
 // Types.
 
+/// Information about a certification.
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
+pub(crate) struct Certification {
+    /// Unique identifier for the certification.
+    pub certification_id: Uuid,
+    /// Full name of the certification.
+    pub name: String,
+    /// Provider of the certification.
+    pub provider: String,
+    /// Short name or abbreviation.
+    pub short_name: String,
+
+    /// Description of the certification.
+    pub description: Option<String>,
+    /// Logo URL for the certification.
+    pub logo_url: Option<String>,
+    /// URL to certification information.
+    pub url: Option<String>,
+}
+
 /// Information about a foundation.
 #[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
 pub(crate) struct Foundation {

gitjobs-server/src/templates/notifications.rs

@@ -80,6 +80,7 @@ mod tests {
             apply_instructions: None,
             apply_url: None,
             benefits: None,
+            certifications: None,
             projects: None,
             published_at: None,
             qualifications: None,