Compare commits
No commits in common. "a117fcbba669b4a1eea6dbb4af34e1cd8c51efa5" and "31477b6bebaa00755f38b1147c7e4373b0a573cc" have entirely different histories.
a117fcbba6
...
31477b6beb
|
@ -22,12 +22,10 @@ repos:
|
||||||
- id: fmt
|
- id: fmt
|
||||||
name: fmt
|
name: fmt
|
||||||
description: Format files with cargo fmt.
|
description: Format files with cargo fmt.
|
||||||
entry: cargo +nightly fmt
|
entry: cargo fmt
|
||||||
language: system
|
language: system
|
||||||
types: [rust]
|
types: [rust]
|
||||||
args: ["--", "--check"]
|
args: ["--", "--check"]
|
||||||
# For some reason some formatting is different depending on how you invoke?
|
|
||||||
pass_filenames: false
|
|
||||||
|
|
||||||
- id: clippy
|
- id: clippy
|
||||||
name: clippy
|
name: clippy
|
||||||
|
|
|
@ -1,2 +0,0 @@
|
||||||
imports_granularity = "Module"
|
|
||||||
group_imports = "StdExternalCrate"
|
|
|
@ -1,7 +1,7 @@
|
||||||
[package]
|
[package]
|
||||||
name = "lldap-controller"
|
name = "lldap-controller"
|
||||||
version = "0.1.0"
|
version = "0.1.0"
|
||||||
edition = "2024"
|
edition = "2021"
|
||||||
default-run = "lldap-controller"
|
default-run = "lldap-controller"
|
||||||
|
|
||||||
[workspace]
|
[workspace]
|
||||||
|
|
|
@ -88,9 +88,9 @@ pub struct GetGroups {
|
||||||
|
|
||||||
#[cfg(test)]
|
#[cfg(test)]
|
||||||
mod tests {
|
mod tests {
|
||||||
use cynic::{MutationBuilder, QueryBuilder};
|
|
||||||
|
|
||||||
use super::*;
|
use super::*;
|
||||||
|
use cynic::MutationBuilder;
|
||||||
|
use cynic::QueryBuilder;
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn delete_user_gql_output() {
|
fn delete_user_gql_output() {
|
||||||
|
|
|
@ -1,7 +1,9 @@
|
||||||
use async_trait::async_trait;
|
use async_trait::async_trait;
|
||||||
use k8s_openapi::api::core::v1::Secret;
|
use k8s_openapi::api::core::v1::Secret;
|
||||||
use kube::runtime::events::{Event, EventType, Recorder, Reporter};
|
use kube::{
|
||||||
use kube::{Resource, ResourceExt};
|
runtime::events::{Event, EventType, Recorder, Reporter},
|
||||||
|
Resource, ResourceExt,
|
||||||
|
};
|
||||||
|
|
||||||
use crate::lldap::LldapConfig;
|
use crate::lldap::LldapConfig;
|
||||||
|
|
||||||
|
|
14
src/lldap.rs
14
src/lldap.rs
|
@ -1,19 +1,19 @@
|
||||||
use std::time::Duration;
|
|
||||||
|
|
||||||
use anyhow::Context;
|
use anyhow::Context;
|
||||||
use cynic::http::{CynicReqwestError, ReqwestExt};
|
|
||||||
use cynic::{GraphQlError, GraphQlResponse, MutationBuilder, QueryBuilder};
|
|
||||||
use lldap_auth::login::{ClientSimpleLoginRequest, ServerLoginResponse};
|
|
||||||
use lldap_auth::opaque::AuthenticationError;
|
use lldap_auth::opaque::AuthenticationError;
|
||||||
use lldap_auth::registration::ServerRegistrationStartResponse;
|
use lldap_auth::registration::ServerRegistrationStartResponse;
|
||||||
use lldap_auth::{opaque, registration};
|
use lldap_auth::{opaque, registration};
|
||||||
|
use reqwest::header::{HeaderMap, HeaderValue, AUTHORIZATION};
|
||||||
|
use std::time::Duration;
|
||||||
|
use tracing::{debug, trace};
|
||||||
|
|
||||||
|
use cynic::http::{CynicReqwestError, ReqwestExt};
|
||||||
|
use cynic::{GraphQlError, GraphQlResponse, MutationBuilder, QueryBuilder};
|
||||||
|
use lldap_auth::login::{ClientSimpleLoginRequest, ServerLoginResponse};
|
||||||
use queries::{
|
use queries::{
|
||||||
AddUserToGroup, AddUserToGroupVariables, CreateUser, CreateUserVariables, DeleteUser,
|
AddUserToGroup, AddUserToGroupVariables, CreateUser, CreateUserVariables, DeleteUser,
|
||||||
DeleteUserVariables, GetGroups, GetUser, GetUserVariables, Group, RemoveUserFromGroup,
|
DeleteUserVariables, GetGroups, GetUser, GetUserVariables, Group, RemoveUserFromGroup,
|
||||||
RemoveUserFromGroupVariables, User,
|
RemoveUserFromGroupVariables, User,
|
||||||
};
|
};
|
||||||
use reqwest::header::{AUTHORIZATION, HeaderMap, HeaderValue};
|
|
||||||
use tracing::{debug, trace};
|
|
||||||
|
|
||||||
#[derive(thiserror::Error, Debug)]
|
#[derive(thiserror::Error, Debug)]
|
||||||
pub enum Error {
|
pub enum Error {
|
||||||
|
|
22
src/main.rs
22
src/main.rs
|
@ -1,18 +1,18 @@
|
||||||
use std::sync::Arc;
|
use std::{sync::Arc, time::Duration};
|
||||||
use std::time::Duration;
|
|
||||||
|
|
||||||
use futures::StreamExt;
|
use futures::StreamExt;
|
||||||
use k8s_openapi::api::core::v1::Secret;
|
use k8s_openapi::api::core::v1::Secret;
|
||||||
use kube::runtime::Controller;
|
use kube::{
|
||||||
use kube::runtime::controller::Action;
|
runtime::{controller::Action, Controller},
|
||||||
use kube::{Api, Client as KubeClient};
|
Api, Client as KubeClient,
|
||||||
use lldap_controller::context::Context;
|
};
|
||||||
use lldap_controller::lldap::LldapConfig;
|
use lldap_controller::{
|
||||||
use lldap_controller::resources::{self, ServiceUser, reconcile};
|
context::Context,
|
||||||
|
lldap::LldapConfig,
|
||||||
|
resources::{self, reconcile, ServiceUser},
|
||||||
|
};
|
||||||
use tracing::{debug, info, warn};
|
use tracing::{debug, info, warn};
|
||||||
use tracing_subscriber::layer::SubscriberExt;
|
use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt, EnvFilter, Registry};
|
||||||
use tracing_subscriber::util::SubscriberInitExt;
|
|
||||||
use tracing_subscriber::{EnvFilter, Registry};
|
|
||||||
|
|
||||||
fn error_policy(_obj: Arc<ServiceUser>, err: &resources::Error, _ctx: Arc<Context>) -> Action {
|
fn error_policy(_obj: Arc<ServiceUser>, err: &resources::Error, _ctx: Arc<Context>) -> Action {
|
||||||
warn!("error: {}", err);
|
warn!("error: {}", err);
|
||||||
|
|
|
@ -8,14 +8,15 @@ use k8s_openapi::NamespaceResourceScope;
|
||||||
use kube::runtime::controller::Action;
|
use kube::runtime::controller::Action;
|
||||||
use kube::runtime::finalizer;
|
use kube::runtime::finalizer;
|
||||||
use kube::{Api, Resource, ResourceExt};
|
use kube::{Api, Resource, ResourceExt};
|
||||||
use serde::Serialize;
|
|
||||||
use serde::de::DeserializeOwned;
|
use serde::de::DeserializeOwned;
|
||||||
|
use serde::Serialize;
|
||||||
use tracing::{debug, instrument};
|
use tracing::{debug, instrument};
|
||||||
|
|
||||||
pub use self::service_user::ServiceUser;
|
|
||||||
use crate::context::Context;
|
use crate::context::Context;
|
||||||
use crate::lldap;
|
use crate::lldap;
|
||||||
|
|
||||||
|
pub use service_user::ServiceUser;
|
||||||
|
|
||||||
#[derive(thiserror::Error, Debug)]
|
#[derive(thiserror::Error, Debug)]
|
||||||
pub enum Error {
|
pub enum Error {
|
||||||
#[error("Failed to commit: {0}")]
|
#[error("Failed to commit: {0}")]
|
||||||
|
|
|
@ -229,9 +229,8 @@ impl Reconcile for ServiceUser {
|
||||||
|
|
||||||
#[cfg(test)]
|
#[cfg(test)]
|
||||||
mod tests {
|
mod tests {
|
||||||
use kube::CustomResourceExt;
|
|
||||||
|
|
||||||
use super::*;
|
use super::*;
|
||||||
|
use kube::CustomResourceExt;
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn service_user_crd_output() {
|
fn service_user_crd_output() {
|
||||||
|
|
Loading…
Reference in New Issue
Block a user