Merge branch 'createwarnings' into 'master'
fix: correct create event warnings See merge request famedly/conduit!161
This commit is contained in:
		
						commit
						72dd95f500
					
				
					 4 changed files with 22 additions and 5 deletions
				
			
		|  | @ -822,7 +822,10 @@ pub async fn invite_helper<'a>( | ||||||
|                     serde_json::from_value::<Raw<CreateEventContent>>(create_event.content.clone()) |                     serde_json::from_value::<Raw<CreateEventContent>>(create_event.content.clone()) | ||||||
|                         .expect("Raw::from_value always works.") |                         .expect("Raw::from_value always works.") | ||||||
|                         .deserialize() |                         .deserialize() | ||||||
|                         .map_err(|_| Error::bad_database("Invalid PowerLevels event in db.")) |                         .map_err(|e| { | ||||||
|  |                             warn!("Invalid create event: {}", e); | ||||||
|  |                             Error::bad_database("Invalid create event in db.") | ||||||
|  |                         }) | ||||||
|                 }) |                 }) | ||||||
|                 .transpose()?; |                 .transpose()?; | ||||||
| 
 | 
 | ||||||
|  |  | ||||||
|  | @ -423,6 +423,8 @@ pub async fn upgrade_room_route( | ||||||
| 
 | 
 | ||||||
|     // Create a replacement room
 |     // Create a replacement room
 | ||||||
|     let replacement_room = RoomId::new(db.globals.server_name()); |     let replacement_room = RoomId::new(db.globals.server_name()); | ||||||
|  |     db.rooms | ||||||
|  |         .get_or_create_shortroomid(&replacement_room, &db.globals)?; | ||||||
| 
 | 
 | ||||||
|     let mutex_state = Arc::clone( |     let mutex_state = Arc::clone( | ||||||
|         db.globals |         db.globals | ||||||
|  |  | ||||||
|  | @ -1780,7 +1780,10 @@ impl Rooms { | ||||||
|                 serde_json::from_value::<Raw<CreateEventContent>>(create_event.content.clone()) |                 serde_json::from_value::<Raw<CreateEventContent>>(create_event.content.clone()) | ||||||
|                     .expect("Raw::from_value always works.") |                     .expect("Raw::from_value always works.") | ||||||
|                     .deserialize() |                     .deserialize() | ||||||
|                     .map_err(|_| Error::bad_database("Invalid PowerLevels event in db.")) |                     .map_err(|e| { | ||||||
|  |                         warn!("Invalid create event: {}", e); | ||||||
|  |                         Error::bad_database("Invalid create event in db.") | ||||||
|  |                     }) | ||||||
|             }) |             }) | ||||||
|             .transpose()?; |             .transpose()?; | ||||||
| 
 | 
 | ||||||
|  |  | ||||||
|  | @ -1036,7 +1036,10 @@ fn handle_outlier_pdu<'a>( | ||||||
|             serde_json::from_value::<Raw<CreateEventContent>>(create_event.content.clone()) |             serde_json::from_value::<Raw<CreateEventContent>>(create_event.content.clone()) | ||||||
|                 .expect("Raw::from_value always works.") |                 .expect("Raw::from_value always works.") | ||||||
|                 .deserialize() |                 .deserialize() | ||||||
|                 .map_err(|_| "Invalid PowerLevels event in db.".to_owned())?; |                 .map_err(|e| { | ||||||
|  |                     warn!("Invalid create event: {}", e); | ||||||
|  |                     "Invalid create event in db.".to_owned() | ||||||
|  |                 })?; | ||||||
| 
 | 
 | ||||||
|         let room_version_id = &create_event_content.room_version; |         let room_version_id = &create_event_content.room_version; | ||||||
|         let room_version = RoomVersion::new(room_version_id).expect("room version is supported"); |         let room_version = RoomVersion::new(room_version_id).expect("room version is supported"); | ||||||
|  | @ -1323,7 +1326,10 @@ async fn upgrade_outlier_to_timeline_pdu( | ||||||
|         serde_json::from_value::<Raw<CreateEventContent>>(create_event.content.clone()) |         serde_json::from_value::<Raw<CreateEventContent>>(create_event.content.clone()) | ||||||
|             .expect("Raw::from_value always works.") |             .expect("Raw::from_value always works.") | ||||||
|             .deserialize() |             .deserialize() | ||||||
|             .map_err(|_| "Invalid PowerLevels event in db.".to_owned())?; |             .map_err(|e| { | ||||||
|  |                 warn!("Invalid create event: {}", e); | ||||||
|  |                 "Invalid create event in db.".to_owned() | ||||||
|  |             })?; | ||||||
| 
 | 
 | ||||||
|     let room_version_id = &create_event_content.room_version; |     let room_version_id = &create_event_content.room_version; | ||||||
|     let room_version = RoomVersion::new(room_version_id).expect("room version is supported"); |     let room_version = RoomVersion::new(room_version_id).expect("room version is supported"); | ||||||
|  | @ -2210,7 +2216,10 @@ pub fn create_join_event_template_route( | ||||||
|             serde_json::from_value::<Raw<CreateEventContent>>(create_event.content.clone()) |             serde_json::from_value::<Raw<CreateEventContent>>(create_event.content.clone()) | ||||||
|                 .expect("Raw::from_value always works.") |                 .expect("Raw::from_value always works.") | ||||||
|                 .deserialize() |                 .deserialize() | ||||||
|                 .map_err(|_| Error::bad_database("Invalid PowerLevels event in db.")) |                 .map_err(|e| { | ||||||
|  |                     warn!("Invalid create event: {}", e); | ||||||
|  |                     Error::bad_database("Invalid create event in db.") | ||||||
|  |                 }) | ||||||
|         }) |         }) | ||||||
|         .transpose()?; |         .transpose()?; | ||||||
| 
 | 
 | ||||||
|  |  | ||||||
		Loading…
	
		Reference in a new issue