-
Notifications
You must be signed in to change notification settings - Fork 6
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
chore: Remove self user creator [WPB-11559] (#3118)
* chore: Remove self user creator [WPB-11559] * Cleanup field from db
- Loading branch information
1 parent
b391c81
commit ee39af7
Showing
14 changed files
with
127 additions
and
46 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,127 @@ | ||
| DROP VIEW IF EXISTS ConversationDetails; | ||
|
|
||
| CREATE VIEW IF NOT EXISTS ConversationDetails AS | ||
| SELECT | ||
| Conversation.qualified_id AS qualifiedId, | ||
| CASE (Conversation.type) | ||
| WHEN 'ONE_ON_ONE' THEN User.name | ||
| WHEN 'CONNECTION_PENDING' THEN connection_user.name | ||
| ELSE Conversation.name | ||
| END AS name, | ||
| Conversation.type, | ||
| Call.status AS callStatus, | ||
| CASE (Conversation.type) | ||
| WHEN 'ONE_ON_ONE' THEN User.preview_asset_id | ||
| WHEN 'CONNECTION_PENDING' THEN connection_user.preview_asset_id | ||
| END AS previewAssetId, | ||
| Conversation.muted_status AS mutedStatus, | ||
| CASE (Conversation.type) | ||
| WHEN 'ONE_ON_ONE' THEN User.team | ||
| ELSE Conversation.team_id | ||
| END AS teamId, | ||
| CASE (Conversation.type) | ||
| WHEN 'CONNECTION_PENDING' THEN Connection.last_update_date | ||
| ELSE Conversation.last_modified_date | ||
| END AS lastModifiedDate, | ||
| Conversation.last_read_date AS lastReadDate, | ||
| CASE (Conversation.type) | ||
| WHEN 'ONE_ON_ONE' THEN User.user_availability_status | ||
| WHEN 'CONNECTION_PENDING' THEN connection_user.user_availability_status | ||
| END AS userAvailabilityStatus, | ||
| CASE (Conversation.type) | ||
| WHEN 'ONE_ON_ONE' THEN User.user_type | ||
| WHEN 'CONNECTION_PENDING' THEN connection_user.user_type | ||
| END AS userType, | ||
| CASE (Conversation.type) | ||
| WHEN 'ONE_ON_ONE' THEN User.bot_service | ||
| WHEN 'CONNECTION_PENDING' THEN connection_user.bot_service | ||
| END AS botService, | ||
| CASE (Conversation.type) | ||
| WHEN 'ONE_ON_ONE' THEN User.deleted | ||
| WHEN 'CONNECTION_PENDING' THEN connection_user.deleted | ||
| END AS userDeleted, | ||
| CASE (Conversation.type) | ||
| WHEN 'ONE_ON_ONE' THEN User.defederated | ||
| WHEN 'CONNECTION_PENDING' THEN connection_user.defederated | ||
| END AS userDefederated, | ||
| CASE (Conversation.type) | ||
| WHEN 'ONE_ON_ONE' THEN User.supported_protocols | ||
| WHEN 'CONNECTION_PENDING' THEN connection_user.supported_protocols | ||
| END AS userSupportedProtocols, | ||
| CASE (Conversation.type) | ||
| WHEN 'ONE_ON_ONE' THEN User.connection_status | ||
| WHEN 'CONNECTION_PENDING' THEN connection_user.connection_status | ||
| END AS connectionStatus, | ||
| CASE (Conversation.type) | ||
| WHEN 'ONE_ON_ONE' THEN User.qualified_id | ||
| WHEN 'CONNECTION_PENDING' THEN connection_user.qualified_id | ||
| END AS otherUserId, | ||
| CASE (Conversation.type) | ||
| WHEN 'ONE_ON_ONE' THEN User.active_one_on_one_conversation_id | ||
| WHEN 'CONNECTION_PENDING' THEN connection_user.active_one_on_one_conversation_id | ||
| END AS otherUserActiveConversationId, | ||
| CASE (Conversation.type) | ||
| WHEN 'ONE_ON_ONE' THEN coalesce(User.active_one_on_one_conversation_id = Conversation.qualified_id, 0) | ||
| ELSE 1 | ||
| END AS isActive, | ||
| CASE (Conversation.type) | ||
| WHEN 'ONE_ON_ONE' THEN User.accent_id | ||
| ELSE 0 | ||
| END AS accentId, | ||
| Conversation.last_notified_date AS lastNotifiedMessageDate, | ||
| memberRole. role AS selfRole, | ||
| Conversation.protocol, | ||
| Conversation.mls_cipher_suite, | ||
| Conversation.mls_epoch, | ||
| Conversation.mls_group_id, | ||
| Conversation.mls_last_keying_material_update_date, | ||
| Conversation.mls_group_state, | ||
| Conversation.access_list, | ||
| Conversation.access_role_list, | ||
| Conversation.mls_proposal_timer, | ||
| Conversation.muted_time, | ||
| Conversation.creator_id, | ||
| Conversation.receipt_mode, | ||
| Conversation.message_timer, | ||
| Conversation.user_message_timer, | ||
| Conversation.incomplete_metadata, | ||
| Conversation.archived, | ||
| Conversation.archived_date_time, | ||
| Conversation.verification_status AS mls_verification_status, | ||
| Conversation.proteus_verification_status, | ||
| Conversation.legal_hold_status, | ||
| SelfUser.id AS selfUserId, | ||
| CASE | ||
| WHEN Conversation.type = 'GROUP' THEN | ||
| CASE | ||
| WHEN memberRole.role IS NOT NULL THEN 1 | ||
| ELSE 0 | ||
| END | ||
| WHEN Conversation.type = 'ONE_ON_ONE' THEN | ||
| CASE | ||
| WHEN User.defederated = 1 THEN 0 | ||
| WHEN User.deleted = 1 THEN 0 | ||
| WHEN User.connection_status = 'BLOCKED' THEN 0 | ||
| WHEN Conversation.legal_hold_status = 'DEGRADED' THEN 0 | ||
| ELSE 1 | ||
| END | ||
| ELSE 0 | ||
| END AS interactionEnabled, | ||
| LabeledConversation.folder_id IS NOT NULL AS isFavorite | ||
| FROM Conversation | ||
| LEFT JOIN SelfUser | ||
| LEFT JOIN Member ON Conversation.qualified_id = Member.conversation | ||
| AND Conversation.type IS 'ONE_ON_ONE' | ||
| AND Member.user IS NOT SelfUser.id | ||
| LEFT JOIN Member AS memberRole ON Conversation.qualified_id = memberRole.conversation | ||
| AND memberRole.user IS SelfUser.id | ||
| LEFT JOIN User ON User.qualified_id = Member.user | ||
| LEFT JOIN Connection ON Connection.qualified_conversation = Conversation.qualified_id | ||
| AND (Connection.status = 'SENT' | ||
| OR Connection.status = 'PENDING' | ||
| OR Connection.status = 'NOT_CONNECTED' | ||
| AND Conversation.type IS 'CONNECTION_PENDING') | ||
| LEFT JOIN User AS connection_user ON Connection.qualified_to = connection_user.qualified_id | ||
| LEFT JOIN Call ON Call.id IS (SELECT id FROM Call WHERE Call.conversation_id = Conversation.qualified_id AND Call.status IS 'STILL_ONGOING' ORDER BY created_at DESC LIMIT 1) | ||
| LEFT JOIN ConversationFolder AS FavoriteFolder ON FavoriteFolder.folder_type = 'FAVORITE' | ||
| LEFT JOIN LabeledConversation ON LabeledConversation.conversation_id = Conversation.qualified_id AND LabeledConversation.folder_id = FavoriteFolder.id; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters