feat: retrieving profiles and updating profiles

crates/core/src/membership/join.rs

@@ -1,15 +1,21 @@
 use matrix::{
     client::membership::join::{Request, Response},
-    ruma_common::OwnedRoomOrAliasId,
+    ruma_common::OwnedRoomId,
 };
 
-use crate::{commune, error::Error};
+use crate::{commune, error::Error, util::opaque_id::OpaqueId};
 
 pub async fn service(
     access_token: impl AsRef<str>,
-    room_id: impl Into<OwnedRoomOrAliasId>,
+    space_id: impl Into<OpaqueId>,
     reason: Option<String>,
 ) -> Result<Response, Error> {
+    let server_name = &commune().config.matrix.server_name;
+
+    let space_id = space_id.into();
+    let room_id = OwnedRoomId::try_from(format!("!{space_id}:{server_name}"))
+        .expect("Parsing space identifier should never panic");
+
     let req = Request::new(room_id.into(), reason);
 
     commune()

crates/core/src/profile.rs

@@ -1,2 +1,18 @@
-pub mod avatar;
-pub mod display_name;
+pub mod avatar_url;
+pub mod displayname;
+
+use matrix::{
+    client::profile::{Request, Response},
+    ruma_common::OwnedUserId,
+};
+
+use crate::{commune, error::Error};
+
+pub async fn service(user_id: impl Into<OwnedUserId>) -> Result<Response, Error> {
+    let req = Request::new(user_id.into());
+
+    commune()
+        .send_matrix_request(req, None)
+        .await
+        .map_err(Into::into)
+}

crates/core/src/profile/avatar_url.rs

@@ -0,0 +1,27 @@
+use matrix::{
+    client::{
+        account::whoami,
+        profile::avatar_url::{Request, Response},
+    },
+    ruma_common::OwnedMxcUri,
+};
+
+use crate::{commune, error::Error};
+
+pub async fn service(
+    access_token: impl AsRef<str>,
+    avatar_url: impl Into<OwnedMxcUri>,
+) -> Result<Response, Error> {
+    let req = whoami::Request::new();
+
+    let whoami::Response { user_id, .. } = commune()
+        .send_matrix_request(req, Some(access_token.as_ref()))
+        .await?;
+
+    let req = Request::new(user_id, avatar_url.into());
+
+    commune()
+        .send_matrix_request(req, Some(access_token.as_ref()))
+        .await
+        .map_err(Into::into)
+}

crates/core/src/profile/displayname.rs

@@ -0,0 +1,24 @@
+use matrix::client::{
+    account::whoami,
+    profile::displayname::{Request, Response},
+};
+
+use crate::{commune, error::Error};
+
+pub async fn service(
+    access_token: impl AsRef<str>,
+    displayname: impl Into<String>,
+) -> Result<Response, Error> {
+    let req = whoami::Request::new();
+
+    let whoami::Response { user_id, .. } = commune()
+        .send_matrix_request(req, Some(access_token.as_ref()))
+        .await?;
+
+    let req = Request::new(user_id, displayname.into());
+
+    commune()
+        .send_matrix_request(req, Some(access_token.as_ref()))
+        .await
+        .map_err(Into::into)
+}

crates/core/src/spaces/channels/create.rs

@@ -19,9 +19,8 @@ pub async fn service(
     topic: Option<String>,
 ) -> Result<Response, Error> {
     let server_name = &commune().config.matrix.server_name;
-    // this should never panic
     let space_id = OwnedRoomId::try_from(format!("!{space_id}:{server_name}"))
-        .expect("failed to parse room ID");
+        .expect("Parsing space identifier should never panic");
 
     let req = Request::new(
         Some(RoomCreationContent {