【Rust】开源Win系统自动解锁的代码，以及Winlogon认证机制的讨论

fn CreateInstance(    &self,    punkouter: Ref<'_, windows::core::IUnknown>,    riid: *const GUID,    ppv_object: *mut *mut std::ffi::c_void,) -> windows::core::Result<()> {    info!("SampleClassFactory::CreateInstance 被调用 - 开始创建凭据提供程序实例");         // 不支持聚合，若提供了外部对象则返回错误    if punkouter.is_some() {        error!("不支持聚合，返回CLASS_E_NOAGGREGATION");        return Err(CLASS_E_NOAGGREGATION.into());    }    unsafe {        // 检查输出指针是否有效        if ppv_object.is_null() {            error!("输出指针为空，返回E_INVALIDARG");            return Err(E_INVALIDARG.into());        }                 // 实例化凭据提供程序并转换为ICredentialProvider接口        let provider: ICredentialProvider = SampleProvider::new().into();        // 查询请求的接口并返回        let result = provider.query(riid, ppv_object);        if result.is_err() {            error!("接口查询失败: {:?}", result.message());            Err(E_INVALIDARG.into())        } else {            info!("凭据提供程序实例创建成功");            Ok(())        }    }}复制代码

fn Advise(&self, pcpe: windows_core::Ref<ICredentialProviderEvents>, upadvisecontext: usize) -> windows_core::Result<()> {    info!("SampleProvider::Advise - 注册事件通知，上下文ID: {}", upadvisecontext);    let mut inner = self.inner.lock().unwrap();    inner.events = pcpe.clone(); // 保存事件接口    inner.advise_context = upadvisecontext; // 保存上下文ID    // 启动管道监听，传入系统事件接口    if let Some(events) = &inner.events {        inner.listener = Some(CPipeListener::start(events.clone(), upadvisecontext, inner.shared_creds.clone()));    }    Ok(())}复制代码

let h_pipe = CreateNamedPipeW(    pipe_name,    PIPE_ACCESS_INBOUND,    PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,    PIPE_UNLIMITED_INSTANCES,    512, 512, 0,    None // 先使用默认权限，如果创建失败，则使用 create_everyone_full_access_sa);if h_pipe.is_invalid() {    error!("创建管道失败");    break;}// 使命名管道服务器进程能够等待客户端进程连接到命名管道的实例let f_connected = ConnectNamedPipe(    h_pipe,    None // 创建管道时未指定FILE_FLAG_OVERLAPPED，使用同步模式，函数会阻塞线程，直到客户端连接成功或发生错误才返回);if f_connected.is_err() {    let _ = CloseHandle(h_pipe);    error!("管道连接失败：{:?}", f_connected.err());    break;}if !running_clone.load(Ordering::SeqCst) {    // 防止在退出时误读数据    let _ = CloseHandle(h_pipe);    break;}let mut buf = [0u16; 256];let mut read = 0;// 获取 buf 的字节切片视图 (&mut [u8])// buf 的字节长度是 256 * 2 (每个 u16 占两个字节)let byte_slice = std::slice::from_raw_parts_mut(buf.as_mut_ptr() as *mut u8, buf.len() * 2);// 读取用户名if ReadFile(h_pipe, Some(byte_slice), Some(&mut read), None).is_ok() {    let user = String::from_utf16_lossy(&buf[.. (read as usize / 2)]);    let mut creds = shared_creds_clone.lock().unwrap();    creds.username = user.trim_matches('\0').to_string();}// 读取密码前重置一下缓冲区read = 0;// 读取密码if ReadFile(h_pipe, Some(byte_slice), Some(&mut read), None).is_ok() {    let pass = String::from_utf16_lossy(&buf[.. (read as usize / 2)]);    let mut creds = shared_creds_clone.lock().unwrap();    creds.password = pass.trim_matches('\0').to_string();}复制代码

// 使用系统 API 打包 Kerberos 凭据// 第一次调用获取长度let _ = CredPackAuthenticationBufferW(    CRED_PACK_FLAGS(0), // 默认传 0    pwz_username,    pwz_password,    None, // 第一次传 None    &mut auth_buffer_size);// 分配 COM 内存，系统会自动释放这块内存let out_buf = CoTaskMemAlloc(auth_buffer_size as usize) as *mut u8;// 第二次调用真正打包CredPackAuthenticationBufferW(    CRED_PACK_FLAGS(0),    pwz_username,    pwz_password,    Some(out_buf), // 传入分配好的指针    &mut auth_buffer_size)?;// 填充返回给 Windows 的结构体*pcpgsr = CPGSR_RETURN_CREDENTIAL_FINISHED;(*pcpcs).clsidCredentialProvider = CLSID_SampleProvider;(*pcpcs).cbSerialization = auth_buffer_size;(*pcpcs).rgbSerialization = out_buf;// 重点：AuthenticationPackage 需要通过 LsaLookupAuthenticationPackage 获取// 通常在 Provider 初始化时获取一次(*pcpcs).ulAuthenticationPackage = self.auth_package_id;复制代码