use crate::function::{OptionalArg, PyFuncArgs};
use crate::obj::objbytes::{PyBytes, PyBytesRef};
use crate::obj::objstr::PyStringRef;
use crate::obj::objtype::PyClassRef;
use crate::pyobject::{PyClassImpl, PyObjectRef, PyResult, PyValue};
use crate::vm::VirtualMachine;
use std::cell::RefCell;
use std::fmt;
use blake2::{Blake2b, Blake2s};
use digest::DynDigest;
use md5::Md5;
use sha1::Sha1;
use sha2::{Sha224, Sha256, Sha384, Sha512};
use sha3::{Sha3_224, Sha3_256, Sha3_384, Sha3_512};
#[pyclass(name = "hasher")]
struct PyHasher {
name: String,
buffer: RefCell<HashWrapper>,
}
impl fmt::Debug for PyHasher {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
write!(f, "hasher {}", self.name)
}
}
impl PyValue for PyHasher {
fn class(vm: &VirtualMachine) -> PyClassRef {
vm.class("hashlib", "hasher")
}
}
#[pyimpl]
impl PyHasher {
fn new(name: &str, d: HashWrapper) -> Self {
PyHasher {
name: name.to_owned(),
buffer: RefCell::new(d),
}
}
#[pyslot]
fn tp_new(_cls: PyClassRef, _args: PyFuncArgs, vm: &VirtualMachine) -> PyResult {
Ok(PyHasher::new("md5", HashWrapper::md5())
.into_ref(vm)
.into_object())
}
#[pyproperty(name = "name")]
fn name(&self) -> String {
self.name.clone()
}
#[pyproperty(name = "digest_size")]
fn digest_size(&self, vm: &VirtualMachine) -> PyResult {
Ok(vm.ctx.new_int(self.buffer.borrow().digest_size()))
}
#[pymethod(name = "update")]
fn update(&self, data: PyBytesRef, vm: &VirtualMachine) -> PyResult {
self.buffer.borrow_mut().input(data.get_value());
Ok(vm.get_none())
}
#[pymethod(name = "digest")]
fn digest(&self) -> PyBytes {
let result = self.get_digest();
PyBytes::new(result)
}
#[pymethod(name = "hexdigest")]
fn hexdigest(&self) -> String {
let result = self.get_digest();
hex::encode(result)
}
fn get_digest(&self) -> Vec<u8> {
self.buffer.borrow().get_digest()
}
}
fn hashlib_new(
name: PyStringRef,
data: OptionalArg<PyBytesRef>,
vm: &VirtualMachine,
) -> PyResult<PyHasher> {
match name.as_str() {
"md5" => md5(data, vm),
"sha1" => sha1(data, vm),
"sha224" => sha224(data, vm),
"sha256" => sha256(data, vm),
"sha384" => sha384(data, vm),
"sha512" => sha512(data, vm),
"sha3_224" => sha3_224(data, vm),
"sha3_256" => sha3_256(data, vm),
"sha3_384" => sha3_384(data, vm),
"sha3_512" => sha3_512(data, vm),
"blake2b" => blake2b(data, vm),
"blake2s" => blake2s(data, vm),
other => Err(vm.new_value_error(format!("Unknown hashing algorithm: {}", other))),
}
}
fn init(
hasher: PyHasher,
data: OptionalArg<PyBytesRef>,
vm: &VirtualMachine,
) -> PyResult<PyHasher> {
if let OptionalArg::Present(data) = data {
hasher.update(data, vm)?;
}
Ok(hasher)
}
fn md5(data: OptionalArg<PyBytesRef>, vm: &VirtualMachine) -> PyResult<PyHasher> {
init(PyHasher::new("md5", HashWrapper::md5()), data, vm)
}
fn sha1(data: OptionalArg<PyBytesRef>, vm: &VirtualMachine) -> PyResult<PyHasher> {
init(PyHasher::new("sha1", HashWrapper::sha1()), data, vm)
}
fn sha224(data: OptionalArg<PyBytesRef>, vm: &VirtualMachine) -> PyResult<PyHasher> {
init(PyHasher::new("sha224", HashWrapper::sha224()), data, vm)
}
fn sha256(data: OptionalArg<PyBytesRef>, vm: &VirtualMachine) -> PyResult<PyHasher> {
init(PyHasher::new("sha256", HashWrapper::sha256()), data, vm)
}
fn sha384(data: OptionalArg<PyBytesRef>, vm: &VirtualMachine) -> PyResult<PyHasher> {
init(PyHasher::new("sha384", HashWrapper::sha384()), data, vm)
}
fn sha512(data: OptionalArg<PyBytesRef>, vm: &VirtualMachine) -> PyResult<PyHasher> {
init(PyHasher::new("sha512", HashWrapper::sha512()), data, vm)
}
fn sha3_224(data: OptionalArg<PyBytesRef>, vm: &VirtualMachine) -> PyResult<PyHasher> {
init(PyHasher::new("sha3_224", HashWrapper::sha3_224()), data, vm)
}
fn sha3_256(data: OptionalArg<PyBytesRef>, vm: &VirtualMachine) -> PyResult<PyHasher> {
init(PyHasher::new("sha3_256", HashWrapper::sha3_256()), data, vm)
}
fn sha3_384(data: OptionalArg<PyBytesRef>, vm: &VirtualMachine) -> PyResult<PyHasher> {
init(PyHasher::new("sha3_384", HashWrapper::sha3_384()), data, vm)
}
fn sha3_512(data: OptionalArg<PyBytesRef>, vm: &VirtualMachine) -> PyResult<PyHasher> {
init(PyHasher::new("sha3_512", HashWrapper::sha3_512()), data, vm)
}
fn shake128(_data: OptionalArg<PyBytesRef>, vm: &VirtualMachine) -> PyResult<PyHasher> {
Err(vm.new_not_implemented_error("shake256".to_owned()))
}
fn shake256(_data: OptionalArg<PyBytesRef>, vm: &VirtualMachine) -> PyResult<PyHasher> {
Err(vm.new_not_implemented_error("shake256".to_owned()))
}
fn blake2b(data: OptionalArg<PyBytesRef>, vm: &VirtualMachine) -> PyResult<PyHasher> {
init(PyHasher::new("blake2b", HashWrapper::blake2b()), data, vm)
}
fn blake2s(data: OptionalArg<PyBytesRef>, vm: &VirtualMachine) -> PyResult<PyHasher> {
init(PyHasher::new("blake2s", HashWrapper::blake2s()), data, vm)
}
pub fn make_module(vm: &VirtualMachine) -> PyObjectRef {
let ctx = &vm.ctx;
let hasher_type = PyHasher::make_class(ctx);
py_module!(vm, "hashlib", {
"new" => ctx.new_function(hashlib_new),
"md5" => ctx.new_function(md5),
"sha1" => ctx.new_function(sha1),
"sha224" => ctx.new_function(sha224),
"sha256" => ctx.new_function(sha256),
"sha384" => ctx.new_function(sha384),
"sha512" => ctx.new_function(sha512),
"sha3_224" => ctx.new_function(sha3_224),
"sha3_256" => ctx.new_function(sha3_256),
"sha3_384" => ctx.new_function(sha3_384),
"sha3_512" => ctx.new_function(sha3_512),
"shake128" => ctx.new_function(shake128),
"shake256" => ctx.new_function(shake256),
"blake2b" => ctx.new_function(blake2b),
"blake2s" => ctx.new_function(blake2s),
"hasher" => hasher_type,
})
}
struct HashWrapper {
inner: Box<dyn DynDigest>,
}
impl HashWrapper {
fn new<D: 'static>(d: D) -> Self
where
D: DynDigest + Sized,
{
HashWrapper { inner: Box::new(d) }
}
fn md5() -> Self {
Self::new(Md5::default())
}
fn sha1() -> Self {
Self::new(Sha1::default())
}
fn sha224() -> Self {
Self::new(Sha224::default())
}
fn sha256() -> Self {
Self::new(Sha256::default())
}
fn sha384() -> Self {
Self::new(Sha384::default())
}
fn sha512() -> Self {
Self::new(Sha512::default())
}
fn sha3_224() -> Self {
Self::new(Sha3_224::default())
}
fn sha3_256() -> Self {
Self::new(Sha3_256::default())
}
fn sha3_384() -> Self {
Self::new(Sha3_384::default())
}
fn sha3_512() -> Self {
Self::new(Sha3_512::default())
}
fn blake2b() -> Self {
Self::new(Blake2b::default())
}
fn blake2s() -> Self {
Self::new(Blake2s::default())
}
fn input(&mut self, data: &[u8]) {
self.inner.input(data);
}
fn digest_size(&self) -> usize {
self.inner.output_size()
}
fn get_digest(&self) -> Vec<u8> {
let cloned = self.inner.clone();
cloned.result().to_vec()
}
}