logos-messaging/libchat
1
0
Fork 0
mirror of https://github.com/logos-messaging/libchat.git synced 2026-05-12 13:09:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Wrap constructor in result

Browse Source
This commit is contained in:
Jazz Turner-Baggs 2026-04-24 17:03:49 -07:00
parent 60e728576a
commit da7e06e495
No known key found for this signature in database
2 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
core/conversations/src/conversation/group_v1.rs
View File

@ -78,7 +78,7 @@ where
ctx: Rc<RefCell<MlsCtx>>,
ds: Rc<RefCell<DS>>,
keypkg_provider: Rc<RefCell<KP>>,
) -> Self {
) -> Result<Self, ChatError> {
let config = Self::mls_create_config();
let mls_group = {
let ctx_ref = ctx.borrow();
@ -91,7 +91,7 @@ where
.unwrap()
};
let convo_id = hex::encode(mls_group.group_id().as_slice());
Self::subscribe(&mut ds.borrow_mut(), &convo_id);
Self::subscribe(&mut ds.borrow_mut(), &convo_id)?;
println!(
"@ Create Convo: {}. {}. d:{} dc:{}",
@ -100,13 +100,13 @@ where
Self::delivery_address_from_id(&convo_id),
Self::ctrl_delivery_address_from_id(&convo_id)
);
Self {
Ok(Self {
ctx,
ds,
keypkg_provider,
mls_group,
convo_id,
}
})
}
pub fn new_from_welcome(
@ -114,7 +114,7 @@ where
ds: Rc<RefCell<DS>>,
keypkg_provider: Rc<RefCell<KP>>,
welcome: Welcome,
) -> Self {
) -> Result<Self, ChatError> {
let mls_group = {
let ctx_borrow = ctx.borrow();
let provider = ctx_borrow.provider();
@ -128,7 +128,7 @@ where
};
let convo_id = hex::encode(mls_group.group_id().as_slice());
Self::subscribe(&mut *ds.borrow_mut(), &convo_id);
Self::subscribe(&mut *ds.borrow_mut(), &convo_id)?;
println!(
"@ Welcome Convo: I:{}. {}. d:{} dc:{}",
@ -138,13 +138,13 @@ where
Self::ctrl_delivery_address_from_id(&convo_id)
);
GroupV1Convo {
Ok(Self {
ctx,
ds,
keypkg_provider,
mls_group,
convo_id,
}
})
}
pub fn load(

5
core/conversations/src/inbox_v2.rs
View File

@ -141,8 +141,7 @@ where
}
pub fn create_group_v1(&self) -> Result<GroupV1Convo<PqMlsContext, DS, RS>, ChatError> {
let convo = GroupV1Convo::new(self.ctx.clone(), self.ds.clone(), self.reg_service.clone());
Ok(convo)
GroupV1Convo::new(self.ctx.clone(), self.ds.clone(), self.reg_service.clone())
}
pub fn handle_frame(&self, payload_bytes: &[u8]) -> Result<(), ChatError> {
@ -187,7 +186,7 @@ where
self.ds.clone(),
self.reg_service.clone(),
welcome,
);
)?;
self.persist_convo(convo)
}