Fix: Use channel_invites collection name instead of invites.

Was conflicting with invite-only rauth registrations.
This commit is contained in:
Paul
2021-06-12 10:33:31 +01:00
parent 9be9b76035
commit 6b8158bf54
9 changed files with 15 additions and 15 deletions

View File

@@ -1,3 +1,3 @@
#!/bin/bash #!/bin/bash
export version=0.5.0-alpha.0 export version=0.5.0-alpha.0-patch.0
echo "pub const VERSION: &str = \"${version}\";" > src/version.rs echo "pub const VERSION: &str = \"${version}\";" > src/version.rs

View File

@@ -116,7 +116,7 @@ impl Channel {
let messages = get_collection("messages"); let messages = get_collection("messages");
// Delete any invites. // Delete any invites.
get_collection("invites") get_collection("channel_invites")
.delete_many( .delete_many(
doc! { doc! {
"channel": id "channel": id
@@ -126,7 +126,7 @@ impl Channel {
.await .await
.map_err(|_| Error::DatabaseError { .map_err(|_| Error::DatabaseError {
operation: "delete_many", operation: "delete_many",
with: "invites", with: "channel_invites",
})?; })?;
// Check if there are any attachments we need to delete. // Check if there are any attachments we need to delete.

View File

@@ -44,7 +44,7 @@ impl Invite {
} }
pub async fn get(code: &str) -> Result<Invite> { pub async fn get(code: &str) -> Result<Invite> {
let doc = get_collection("invites") let doc = get_collection("channel_invites")
.find_one(doc! { "_id": code }, None) .find_one(doc! { "_id": code }, None)
.await .await
.map_err(|_| Error::DatabaseError { .map_err(|_| Error::DatabaseError {
@@ -60,7 +60,7 @@ impl Invite {
} }
pub async fn save(self) -> Result<()> { pub async fn save(self) -> Result<()> {
get_collection("invites") get_collection("channel_invites")
.insert_one( .insert_one(
to_document(&self).map_err(|_| Error::DatabaseError { to_document(&self).map_err(|_| Error::DatabaseError {
operation: "to_bson", operation: "to_bson",
@@ -78,7 +78,7 @@ impl Invite {
} }
pub async fn delete(&self) -> Result<()> { pub async fn delete(&self) -> Result<()> {
get_collection("invites") get_collection("channel_invites")
.delete_one( .delete_one(
doc! { doc! {
"_id": self.code() "_id": self.code()

View File

@@ -165,7 +165,7 @@ impl Server {
})?; })?;
// Delete all channels, members, bans and invites. // Delete all channels, members, bans and invites.
for with in &["channels", "invites"] { for with in &["channels", "channel_invites"] {
get_collection(with) get_collection(with)
.delete_many( .delete_many(
doc! { doc! {

View File

@@ -59,7 +59,7 @@ impl Ref {
} }
pub async fn fetch_invite(&self) -> Result<Invite> { pub async fn fetch_invite(&self) -> Result<Invite> {
self.fetch("invites").await self.fetch("channel_invites").await
} }
pub async fn fetch_member(&self, server: &str) -> Result<Member> { pub async fn fetch_member(&self, server: &str) -> Result<Member> {

View File

@@ -37,9 +37,9 @@ pub async fn create_database() {
.await .await
.expect("Failed to create server_bans collection."); .expect("Failed to create server_bans collection.");
db.create_collection("invites", None) db.create_collection("channel_invites", None)
.await .await
.expect("Failed to create invites collection."); .expect("Failed to create channel_invites collection.");
db.create_collection("migrations", None) db.create_collection("migrations", None)
.await .await

View File

@@ -152,9 +152,9 @@ pub async fn run_migrations(revision: i32) -> i32 {
.expect("Failed to create server_bans collection."); .expect("Failed to create server_bans collection.");
get_db() get_db()
.create_collection("invites", None) .create_collection("channel_invites", None)
.await .await
.expect("Failed to create invites collection."); .expect("Failed to create channel_invites collection.");
} }
// Reminder to update LATEST_REVISION when adding new migrations. // Reminder to update LATEST_REVISION when adding new migrations.

View File

@@ -27,7 +27,7 @@ pub async fn req(user: User, target: Ref) -> Result<JsonValue> {
Err(Error::MissingPermission)? Err(Error::MissingPermission)?
} }
let mut cursor = get_collection("invites") let mut cursor = get_collection("channel_invites")
.find( .find(
doc! { doc! {
"server": target.id "server": target.id
@@ -37,7 +37,7 @@ pub async fn req(user: User, target: Ref) -> Result<JsonValue> {
.await .await
.map_err(|_| Error::DatabaseError { .map_err(|_| Error::DatabaseError {
operation: "find", operation: "find",
with: "invites", with: "channel_invites",
})?; })?;
let mut invites = vec![]; let mut invites = vec![];

View File

@@ -1 +1 @@
pub const VERSION: &str = "0.5.0-alpha.0"; pub const VERSION: &str = "0.5.0-alpha.0-patch.0";