Compare commits

...
Author SHA1 Message Date
Brandon Thomas ad7d529444 fix required rust never type behavior 2025-12-21 20:09:20 -05:00
8 changed files with 8 additions and 8 deletions
@@ -43,7 +43,7 @@ impl PremiumAvtPayload {
let expire_at= Utc::now()
.add(PremiumUserRedisKey::get_redis_ttl())
.timestamp() as usize;
redis.expire_at(self.key.as_str(), expire_at)?;
redis.expire_at::<_, ()>(self.key.as_str(), expire_at)?;
Ok(())
}
}
@@ -44,7 +44,7 @@ impl PremiumIpAddressPayload {
let expire_at= Utc::now()
.add(PremiumUserRedisKey::get_redis_ttl())
.timestamp() as usize;
redis.expire_at(self.key.as_str(), expire_at)?;
redis.expire_at::<_, ()>(self.key.as_str(), expire_at)?;
Ok(())
}
}
@@ -43,7 +43,7 @@ impl PremiumUserPayload {
let expire_at= Utc::now()
.add(PremiumUserRedisKey::get_redis_ttl())
.timestamp() as usize;
redis.expire_at(self.key.as_str(), expire_at)?;
redis.expire_at::<_, ()>(self.key.as_str(), expire_at)?;
Ok(())
}
}
@@ -16,7 +16,7 @@ pub trait HkeyStoreAdapter {
fn persist_to_redis(&self, redis_key: &str, redis: &mut PooledConnection<RedisConnectionManager>) -> AnyhowResult<()> {
let map = self.serialize_payload()?;
redis.hset_multiple(redis_key, &map)?;
redis.hset_multiple::<_, _, _, ()>(redis_key, &map)?;
Ok(())
}
@@ -130,7 +130,7 @@ pub async fn infer_w2l_handler(
let redis_count_key = RedisKeys::w2l_template_usage_count(&w2l_template_token);
redis.incr(&redis_count_key, 1)
redis.incr::<_, _, ()>(&redis_count_key, 1)
.map_err(|e| {
warn!("redis error: {:?}", e);
InferW2lError::ServerError
@@ -233,7 +233,7 @@ pub async fn enqueue_infer_w2l_with_uploads(
let redis_count_key = RedisKeys::w2l_template_usage_count(&template_token);
redis.incr(&redis_count_key, 1)
redis.incr::<_, _, ()>(&redis_count_key, 1)
.map_err(|e| {
warn!("redis error: {:?}", e);
InferW2lWithUploadError::ServerError
@@ -369,7 +369,7 @@ pub async fn enqueue_infer_tts_handler(
let redis_count_key = RedisKeys::tts_model_usage_count(&request.tts_model_token);
redis.incr(&redis_count_key, 1)
redis.incr::<_, _, ()>(&redis_count_key, 1)
.map_err(|e| {
warn!("redis error: {:?}", e);
InferTtsError::ServerError
@@ -292,7 +292,7 @@ pub async fn enqueue_voice_conversion_inference_handler(
let redis_count_key = RedisKeys::web_vc_model_usage_count(&model_token);
redis.incr(&redis_count_key, 1)
redis.incr::<_, _, ()>(&redis_count_key, 1)
.map_err(|e| {
warn!("redis error: {:?}", e);
EnqueueVoiceConversionInferenceError::ServerError