always serialize RpcSecretKey as a ULID
This commit is contained in:
parent
6b6fac396f
commit
68ab9b6d1d
@ -31,6 +31,7 @@ use rdkafka::producer::{FutureProducer, FutureRecord};
|
|||||||
use rdkafka::util::Timeout as KafkaTimeout;
|
use rdkafka::util::Timeout as KafkaTimeout;
|
||||||
use redis_rate_limiter::redis::AsyncCommands;
|
use redis_rate_limiter::redis::AsyncCommands;
|
||||||
use redis_rate_limiter::RedisRateLimitResult;
|
use redis_rate_limiter::RedisRateLimitResult;
|
||||||
|
use serde::{Deserialize, Serialize};
|
||||||
use std::borrow::Cow;
|
use std::borrow::Cow;
|
||||||
use std::fmt::Display;
|
use std::fmt::Display;
|
||||||
use std::hash::{Hash, Hasher};
|
use std::hash::{Hash, Hasher};
|
||||||
@ -46,12 +47,29 @@ use ulid::Ulid;
|
|||||||
use uuid::Uuid;
|
use uuid::Uuid;
|
||||||
|
|
||||||
/// This lets us use UUID and ULID while we transition to only ULIDs
|
/// This lets us use UUID and ULID while we transition to only ULIDs
|
||||||
#[derive(Copy, Clone, Debug, Eq, PartialEq, serde::Deserialize, serde::Serialize)]
|
#[derive(Copy, Clone, Debug, Eq, PartialEq, Deserialize)]
|
||||||
pub enum RpcSecretKey {
|
pub enum RpcSecretKey {
|
||||||
Ulid(Ulid),
|
Ulid(Ulid),
|
||||||
Uuid(Uuid),
|
Uuid(Uuid),
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// always serialize as a ULID.
|
||||||
|
impl Serialize for RpcSecretKey {
|
||||||
|
fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
|
||||||
|
where
|
||||||
|
S: serde::Serializer,
|
||||||
|
{
|
||||||
|
match self {
|
||||||
|
Self::Ulid(x) => x.serialize(serializer),
|
||||||
|
Self::Uuid(x) => {
|
||||||
|
let x: Ulid = x.to_owned().into();
|
||||||
|
|
||||||
|
x.serialize(serializer)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/// TODO: should this have IpAddr and Origin or AuthorizationChecks?
|
/// TODO: should this have IpAddr and Origin or AuthorizationChecks?
|
||||||
#[derive(Debug)]
|
#[derive(Debug)]
|
||||||
pub enum RateLimitResult {
|
pub enum RateLimitResult {
|
||||||
|
Loading…
Reference in New Issue
Block a user