// C o p y r i g h t © 2 0 2 2 R a n g e p r o o f P t y L t d . A l l r i g h t s r e s e r v e d .
import Foundation
import Combine
import Lucide
import GRDB
import YYImage
import DifferenceKit
import SessionUIKit
import SessionMessagingKit
import SignalUtilitiesKit
import SessionUtilitiesKit
import SessionSnodeKit
class ThreadSettingsViewModel : SessionTableViewModel , NavigatableStateHolder , ObservableTableSource {
public let dependencies : Dependencies
public let navigatableState : NavigatableState = NavigatableState ( )
public let state : TableDataState < Section , TableItem > = TableDataState ( )
public let observableState : ObservableTableSourceState < Section , TableItem > = ObservableTableSourceState ( )
private let threadId : String
private let threadVariant : SessionThread . Variant
private let didTriggerSearch : ( ) -> ( )
private var updatedName : String ?
private var updatedDescription : String ?
private var onDisplayPictureSelected : ( ( ConfirmationModal . ValueUpdate ) -> Void ) ?
private lazy var imagePickerHandler : ImagePickerHandler = ImagePickerHandler (
onTransition : { [ weak self ] in self ? . transitionToScreen ( $0 , transitionType : $1 ) } ,
onImageDataPicked : { [ weak self ] resultImageData in
self ? . onDisplayPictureSelected ? ( . image ( resultImageData ) )
}
)
// MARK: - I n i t i a l i z a t i o n
init (
threadId : String ,
threadVariant : SessionThread . Variant ,
didTriggerSearch : @ escaping ( ) -> ( ) ,
using dependencies : Dependencies
) {
self . dependencies = dependencies
self . threadId = threadId
self . threadVariant = threadVariant
self . didTriggerSearch = didTriggerSearch
}
// MARK: - C o n f i g
enum NavState {
case standard
case editing
}
enum NavItem : Equatable {
case edit
case cancel
case done
}
public enum Section : SessionTableSection {
case conversationInfo
case content
case adminActions
case destructiveActions
public var style : SessionTableSectionStyle {
switch self {
case . destructiveActions : return . padding
default : return . none
}
}
}
public enum TableItem : Differentiable {
case avatar
case displayName
case threadDescription
case sessionId
case copyThreadId
case allMedia
case searchConversation
case addToOpenGroup
case disappearingMessages
case disappearingMessagesDuration
case groupMembers
case editGroup
case promoteAdmins
case leaveGroup
case notificationMentionsOnly
case notificationMute
case blockUser
case debugDeleteBeforeNow
case debugDeleteAttachmentsBeforeNow
}
// MARK: - C o n t e n t
private struct State : Equatable {
let threadViewModel : SessionThreadViewModel ?
let disappearingMessagesConfig : DisappearingMessagesConfiguration
}
var title : String {
switch threadVariant {
case . contact : return " sessionSettings " . localized ( )
case . legacyGroup , . group , . community : return " deleteAfterGroupPR1GroupSettings " . localized ( )
}
}
lazy var observation : TargetObservation = ObservationBuilder
. databaseObservation ( self ) { [ dependencies , threadId = self . threadId ] db -> State in
let userSessionId : SessionId = dependencies [ cache : . general ] . sessionId
let threadViewModel : SessionThreadViewModel ? = try SessionThreadViewModel
. conversationSettingsQuery ( threadId : threadId , userSessionId : userSessionId )
. fetchOne ( db )
let disappearingMessagesConfig : DisappearingMessagesConfiguration = try DisappearingMessagesConfiguration
. fetchOne ( db , id : threadId )
. defaulting ( to : DisappearingMessagesConfiguration . defaultWith ( threadId ) )
return State (
threadViewModel : threadViewModel ,
disappearingMessagesConfig : disappearingMessagesConfig
)
}
. compactMapWithPrevious { [ weak self ] prev , current -> [ SectionModel ] ? in self ? . content ( prev , current ) }
private func content ( _ previous : State ? , _ current : State ) -> [ SectionModel ] {
// I f w e d o n ' t g e t a ` S e s s i o n T h r e a d V i e w M o d e l ` t h e n i t m e a n s t h e t h r e a d w a s p r o b a b l y d e l e t e d
// s o d i s m i s s t h e s c r e e n
guard let threadViewModel : SessionThreadViewModel = current . threadViewModel else {
self . dismissScreen ( type : . popToRoot )
return [ ]
}
let currentUserIsClosedGroupMember : Bool = (
(
threadViewModel . threadVariant = = . legacyGroup ||
threadViewModel . threadVariant = = . group
) &&
threadViewModel . currentUserIsClosedGroupMember = = true
)
let currentUserIsClosedGroupAdmin : Bool = (
(
threadViewModel . threadVariant = = . legacyGroup ||
threadViewModel . threadVariant = = . group
) &&
threadViewModel . currentUserIsClosedGroupAdmin = = true
)
let editIcon : UIImage ? = UIImage ( systemName : " pencil " )
let canEditDisplayName : Bool = (
threadViewModel . threadIsNoteToSelf != true && (
threadViewModel . threadVariant = = . contact ||
currentUserIsClosedGroupAdmin
)
)
let conversationInfoSection : SectionModel = SectionModel (
model : . conversationInfo ,
elements : [
SessionCell . Info (
id : . avatar ,
accessory : . profile (
id : threadViewModel . id ,
size : . hero ,
threadVariant : threadViewModel . threadVariant ,
displayPictureFilename : threadViewModel . displayPictureFilename ,
profile : threadViewModel . profile ,
profileIcon : {
guard
threadViewModel . threadVariant = = . group &&
currentUserIsClosedGroupAdmin &&
dependencies [ feature : . updatedGroupsAllowDisplayPicture ]
else { return . none }
// I f w e a l r e a d y h a v e a d i s p l a y p i c t u r e t h e n t h e m a i n p r o f i l e g e t s t h e i c o n
return ( threadViewModel . displayPictureFilename != nil ? . rightPlus : . none )
} ( ) ,
additionalProfile : threadViewModel . additionalProfile ,
additionalProfileIcon : {
guard
threadViewModel . threadVariant = = . group &&
currentUserIsClosedGroupAdmin &&
dependencies [ feature : . updatedGroupsAllowDisplayPicture ]
else { return . none }
// N o d i s p l a y p i c t u r e m e a n s t h e d u a l - p r o f i l e s o t h e a d d i t i o n a l P r o f i l e g e t s t h e i c o n
return . rightPlus
} ( ) ,
accessibility : nil
) ,
styling : SessionCell . StyleInfo (
alignment : . centerHugging ,
customPadding : SessionCell . Padding ( bottom : Values . smallSpacing ) ,
backgroundStyle : . noBackground
) ,
onTap : { [ weak self ] in
switch ( threadViewModel . threadVariant , threadViewModel . displayPictureFilename , currentUserIsClosedGroupAdmin ) {
case ( . contact , _ , _ ) : self ? . viewDisplayPicture ( threadViewModel : threadViewModel )
case ( . group , _ , true ) :
self ? . updateGroupDisplayPicture ( currentFileName : threadViewModel . displayPictureFilename )
case ( _ , . some , _ ) : self ? . viewDisplayPicture ( threadViewModel : threadViewModel )
default : break
}
}
) ,
SessionCell . Info (
id : . displayName ,
leadingAccessory : ( ! canEditDisplayName ? nil :
. icon (
editIcon ? . withRenderingMode ( . alwaysTemplate ) ,
size : . mediumAspectFill ,
customTint : . textSecondary ,
shouldFill : true
)
) ,
title : SessionCell . TextInfo (
threadViewModel . displayName ,
font : . titleLarge ,
alignment : . center
) ,
styling : SessionCell . StyleInfo (
alignment : . centerHugging ,
customPadding : SessionCell . Padding (
top : Values . smallSpacing ,
leading : ( ! canEditDisplayName ? nil :
- ( ( IconSize . medium . size + ( Values . smallSpacing * 2 ) ) / 2 )
) ,
bottom : {
guard threadViewModel . threadVariant != . contact else { return Values . smallSpacing }
guard threadViewModel . threadDescription = = nil else { return Values . smallSpacing }
return Values . largeSpacing
} ( )
) ,
backgroundStyle : . noBackground
) ,
accessibility : Accessibility (
identifier : " Username " ,
label : threadViewModel . displayName
) ,
onTap : { [ weak self ] in
guard ! threadViewModel . threadIsNoteToSelf else { return }
switch ( threadViewModel . threadVariant , currentUserIsClosedGroupAdmin ) {
case ( . contact , _ ) :
self ? . updateNickname (
current : threadViewModel . profile ? . nickname ,
displayName : (
// / * * N o t e : * * W e w a n t t o u s e t h e ` p r o f i l e ` d i r e c t l y r a t h e r t h a n ` t h r e a d V i e w M o d e l . d i s p l a y N a m e `
// / a s t h e l a t t e r w o u l d u s e t h e ` n i c k n a m e ` h e r e w h i c h i s i n c o r r e c t
threadViewModel . profile ? . displayName ( ignoringNickname : true ) ? ?
Profile . truncated ( id : threadViewModel . threadId , truncating : . middle )
)
)
case ( . group , true ) , ( . legacyGroup , true ) :
self ? . updateGroupNameAndDescription (
currentName : threadViewModel . displayName ,
currentDescription : threadViewModel . threadDescription ,
isUpdatedGroup : ( threadViewModel . threadVariant = = . group )
)
case ( . community , _ ) , ( . legacyGroup , false ) , ( . group , false ) : break
}
}
) ,
threadViewModel . threadDescription . map { threadDescription in
SessionCell . Info (
id : . threadDescription ,
subtitle : SessionCell . TextInfo (
threadDescription ,
font : . subtitle ,
alignment : . center
) ,
styling : SessionCell . StyleInfo (
tintColor : . textSecondary ,
customPadding : SessionCell . Padding (
top : 0 ,
bottom : ( threadViewModel . threadVariant != . contact ? Values . largeSpacing : nil )
) ,
backgroundStyle : . noBackground
) ,
accessibility : Accessibility (
identifier : " Description " ,
label : threadDescription
)
)
} ,
( threadViewModel . threadVariant != . contact ? nil :
SessionCell . Info (
id : . sessionId ,
subtitle : SessionCell . TextInfo (
threadViewModel . id ,
font : . monoSmall ,
alignment : . center ,
interaction : . copy
) ,
styling : SessionCell . StyleInfo (
customPadding : SessionCell . Padding (
top : Values . smallSpacing ,
bottom : Values . largeSpacing
) ,
backgroundStyle : . noBackground
) ,
accessibility : Accessibility (
identifier : " Session ID " ,
label : threadViewModel . id
)
)
)
] . compactMap { $0 }
)
let standardActionsSection : SectionModel = SectionModel (
model : . content ,
elements : [
( threadViewModel . threadVariant = = . legacyGroup || threadViewModel . threadVariant = = . group ? nil :
SessionCell . Info (
id : . copyThreadId ,
leadingAccessory : . icon (
UIImage ( named : " ic_copy " ) ?
. withRenderingMode ( . alwaysTemplate )
) ,
title : ( threadViewModel . threadVariant = = . community ?
" communityUrlCopy " . localized ( ) :
" accountIDCopy " . localized ( )
) ,
accessibility : Accessibility (
identifier : " \( ThreadSettingsViewModel . self ) .copy_thread_id " ,
label : " Copy Session ID "
) ,
onTap : { [ weak self ] in
switch threadViewModel . threadVariant {
case . contact , . legacyGroup , . group :
UIPasteboard . general . string = threadViewModel . threadId
case . community :
guard
let urlString : String = LibSession . communityUrlFor (
server : threadViewModel . openGroupServer ,
roomToken : threadViewModel . openGroupRoomToken ,
publicKey : threadViewModel . openGroupPublicKey
)
else { return }
UIPasteboard . general . string = urlString
}
self ? . showToast (
text : " copied " . localized ( ) ,
backgroundColor : . backgroundSecondary
)
}
)
) ,
SessionCell . Info (
id : . allMedia ,
leadingAccessory : . icon (
UIImage ( named : " actionsheet_camera_roll_black " ) ?
. withRenderingMode ( . alwaysTemplate )
) ,
title : " conversationsSettingsAllMedia " . localized ( ) ,
accessibility : Accessibility (
identifier : " \( ThreadSettingsViewModel . self ) .all_media " ,
label : " All media "
) ,
onTap : { [ weak self , dependencies ] in
self ? . transitionToScreen (
MediaGalleryViewModel . createAllMediaViewController (
threadId : threadViewModel . threadId ,
threadVariant : threadViewModel . threadVariant ,
focusedAttachmentId : nil ,
using : dependencies
)
)
}
) ,
SessionCell . Info (
id : . searchConversation ,
leadingAccessory : . icon (
UIImage ( named : " conversation_settings_search " ) ?
. withRenderingMode ( . alwaysTemplate )
) ,
title : " searchConversation " . localized ( ) ,
accessibility : Accessibility (
identifier : " \( ThreadSettingsViewModel . self ) .search " ,
label : " Search "
) ,
onTap : { [ weak self ] in self ? . didTriggerSearch ( ) }
) ,
( threadViewModel . threadVariant != . community ? nil :
SessionCell . Info (
id : . addToOpenGroup ,
leadingAccessory : . icon (
UIImage ( named : " ic_plus_24 " ) ?
. withRenderingMode ( . alwaysTemplate )
) ,
title : " membersInvite " . localized ( ) ,
accessibility : Accessibility (
identifier : " \( ThreadSettingsViewModel . self ) .add_to_open_group "
) ,
onTap : { [ weak self ] in self ? . inviteUsersToCommunity ( threadViewModel : threadViewModel ) }
)
) ,
( threadViewModel . threadVariant = = . community || threadViewModel . threadIsBlocked = = true ? nil :
SessionCell . Info (
id : . disappearingMessages ,
leadingAccessory : . icon (
UIImage ( systemName : " timer " ) ?
. withRenderingMode ( . alwaysTemplate )
) ,
title : " disappearingMessages " . localized ( ) ,
subtitle : {
guard current . disappearingMessagesConfig . isEnabled else {
return " off " . localized ( )
}
return ( current . disappearingMessagesConfig . type ? ? . unknown )
. localizedState (
durationString : current . disappearingMessagesConfig . durationString
)
} ( ) ,
accessibility : Accessibility (
identifier : " Disappearing messages " ,
label : " \( ThreadSettingsViewModel . self ) .disappearing_messages "
) ,
onTap : { [ weak self , dependencies ] in
self ? . transitionToScreen (
SessionTableViewController (
viewModel : ThreadDisappearingMessagesSettingsViewModel (
threadId : threadViewModel . threadId ,
threadVariant : threadViewModel . threadVariant ,
currentUserIsClosedGroupMember : threadViewModel . currentUserIsClosedGroupMember ,
currentUserIsClosedGroupAdmin : threadViewModel . currentUserIsClosedGroupAdmin ,
config : current . disappearingMessagesConfig ,
using : dependencies
)
)
)
}
)
) ,
( ! currentUserIsClosedGroupMember ? nil :
SessionCell . Info (
id : . groupMembers ,
leadingAccessory : . icon (
UIImage ( named : " icon_members " ) ?
. withRenderingMode ( . alwaysTemplate )
) ,
title : " groupMembers " . localized ( ) ,
accessibility : Accessibility (
identifier : " Group members " ,
label : " Group members "
) ,
onTap : { [ weak self ] in self ? . viewMembers ( ) }
)
) ,
( ! currentUserIsClosedGroupAdmin ? nil :
SessionCell . Info (
id : . editGroup ,
leadingAccessory : . icon (
UIImage ( named : " table_ic_group_edit " ) ?
. withRenderingMode ( . alwaysTemplate )
) ,
title : " groupEdit " . localized ( ) ,
accessibility : Accessibility (
identifier : " Edit group " ,
label : " Edit group "
) ,
onTap : { [ weak self , dependencies ] in
self ? . transitionToScreen (
SessionTableViewController (
viewModel : EditGroupViewModel (
threadId : threadViewModel . threadId ,
using : dependencies
)
)
)
}
)
) ,
( ! currentUserIsClosedGroupAdmin || ! dependencies [ feature : . updatedGroupsAllowPromotions ] ? nil :
SessionCell . Info (
id : . promoteAdmins ,
leadingAccessory : . icon (
UIImage ( named : " table_ic_group_edit " ) ?
. withRenderingMode ( . alwaysTemplate )
) ,
title : " adminPromote " . localized ( ) ,
accessibility : Accessibility (
identifier : " Promote admins " ,
label : " Promote admins "
) ,
onTap : { [ weak self ] in
self ? . promoteAdmins ( currentGroupName : threadViewModel . closedGroupName )
}
)
) ,
( ! currentUserIsClosedGroupMember ? nil :
SessionCell . Info (
id : . leaveGroup ,
leadingAccessory : . icon (
UIImage ( named : " table_ic_group_leave " ) ?
. withRenderingMode ( . alwaysTemplate )
) ,
title : " groupLeave " . localized ( ) ,
accessibility : Accessibility (
identifier : " Leave group " ,
label : " Leave group "
) ,
confirmationInfo : ConfirmationModal . Info (
title : " groupLeave " . localized ( ) ,
body : ( currentUserIsClosedGroupAdmin ?
. attributedText (
" groupLeaveDescriptionAdmin "
. put ( key : " group_name " , value : threadViewModel . displayName )
. localizedFormatted ( baseFont : . boldSystemFont ( ofSize : Values . smallFontSize ) )
) :
. attributedText (
" groupLeaveDescription "
. put ( key : " group_name " , value : threadViewModel . displayName )
. localizedFormatted ( baseFont : . boldSystemFont ( ofSize : Values . smallFontSize ) )
)
) ,
confirmTitle : " leave " . localized ( ) ,
confirmStyle : . danger ,
cancelStyle : . alert_text
) ,
onTap : { [ weak self , dependencies ] in
dependencies [ singleton : . storage ] . write { db in
try SessionThread . deleteOrLeave (
db ,
type : . leaveGroupAsync ,
threadId : threadViewModel . threadId ,
threadVariant : threadViewModel . threadVariant ,
using : dependencies
)
}
self ? . dismissScreen ( type : . popToRoot )
}
)
) ,
( threadViewModel . threadVariant = = . contact ? nil :
SessionCell . Info (
id : . notificationMentionsOnly ,
leadingAccessory : . icon (
UIImage ( named : " NotifyMentions " ) ?
. withRenderingMode ( . alwaysTemplate )
) ,
title : " deleteAfterGroupPR1MentionsOnly " . localized ( ) ,
subtitle : " deleteAfterGroupPR1MentionsOnlyDescription " . localized ( ) ,
trailingAccessory : . toggle (
threadViewModel . threadOnlyNotifyForMentions = = true ,
oldValue : ( previous ? . threadViewModel ? . threadOnlyNotifyForMentions = = true ) ,
accessibility : Accessibility (
identifier : " Notify for Mentions Only - Switch "
)
) ,
isEnabled : (
(
threadViewModel . threadVariant != . legacyGroup &&
threadViewModel . threadVariant != . group
) ||
currentUserIsClosedGroupMember
) ,
accessibility : Accessibility (
identifier : " Mentions only notification setting " ,
label : " Mentions only "
) ,
onTap : { [ dependencies ] in
let newValue : Bool = ! ( threadViewModel . threadOnlyNotifyForMentions = = true )
dependencies [ singleton : . storage ] . writeAsync { db in
try SessionThread
. filter ( id : threadViewModel . threadId )
. updateAll (
db ,
SessionThread . Columns . onlyNotifyForMentions
. set ( to : newValue )
)
}
}
)
) ,
( threadViewModel . threadIsNoteToSelf ? nil :
SessionCell . Info (
id : . notificationMute ,
leadingAccessory : . icon (
UIImage ( named : " Mute " ) ?
. withRenderingMode ( . alwaysTemplate )
) ,
title : " notificationsMute " . localized ( ) ,
trailingAccessory : . toggle (
threadViewModel . threadMutedUntilTimestamp != nil ,
oldValue : ( previous ? . threadViewModel ? . threadMutedUntilTimestamp != nil ) ,
accessibility : Accessibility (
identifier : " Mute - Switch "
)
) ,
isEnabled : (
(
threadViewModel . threadVariant != . legacyGroup &&
threadViewModel . threadVariant != . group
) ||
currentUserIsClosedGroupMember
) ,
accessibility : Accessibility (
identifier : " \( ThreadSettingsViewModel . self ) .mute " ,
label : " Mute notifications "
) ,
onTap : { [ dependencies ] in
dependencies [ singleton : . storage ] . writeAsync { db in
let currentValue : TimeInterval ? = try SessionThread
. filter ( id : threadViewModel . threadId )
. select ( . mutedUntilTimestamp )
. asRequest ( of : TimeInterval . self )
. fetchOne ( db )
try SessionThread
. filter ( id : threadViewModel . threadId )
. updateAll (
db ,
SessionThread . Columns . mutedUntilTimestamp . set (
to : ( currentValue = = nil ?
Date . distantFuture . timeIntervalSince1970 :
nil
)
)
)
}
}
)
) ,
( threadViewModel . threadIsNoteToSelf || threadViewModel . threadVariant != . contact ? nil :
SessionCell . Info (
id : . blockUser ,
leadingAccessory : . icon (
UIImage ( named : " table_ic_block " ) ?
. withRenderingMode ( . alwaysTemplate )
) ,
title : " deleteAfterGroupPR1BlockThisUser " . localized ( ) ,
trailingAccessory : . toggle (
threadViewModel . threadIsBlocked = = true ,
oldValue : ( previous ? . threadViewModel ? . threadIsBlocked = = true ) ,
accessibility : Accessibility (
identifier : " Block This User - Switch "
)
) ,
accessibility : Accessibility (
identifier : " \( ThreadSettingsViewModel . self ) .block " ,
label : " Block "
) ,
confirmationInfo : ConfirmationModal . Info (
title : {
guard threadViewModel . threadIsBlocked = = true else {
return String (
format : " block " . localized ( ) ,
threadViewModel . displayName
)
}
return String (
format : " blockUnblock " . localized ( ) ,
threadViewModel . displayName
)
} ( ) ,
body : ( threadViewModel . threadIsBlocked = = true ?
. attributedText (
" blockUnblockName "
. put ( key : " name " , value : threadViewModel . displayName )
. localizedFormatted ( baseFont : . systemFont ( ofSize : Values . smallFontSize ) )
) :
. attributedText (
" blockDescription "
. put ( key : " name " , value : threadViewModel . displayName )
. localizedFormatted ( baseFont : . systemFont ( ofSize : Values . smallFontSize ) )
)
) ,
confirmTitle : ( threadViewModel . threadIsBlocked = = true ?
" blockUnblock " . localized ( ) :
" block " . localized ( )
) ,
confirmStyle : . danger ,
cancelStyle : . alert_text
) ,
onTap : { [ weak self ] in
let isBlocked : Bool = ( threadViewModel . threadIsBlocked = = true )
self ? . updateBlockedState (
from : isBlocked ,
isBlocked : ! isBlocked ,
threadId : threadViewModel . threadId ,
displayName : threadViewModel . displayName
)
}
)
)
] . compactMap { $0 }
)
let adminActionsSection : SectionModel ? = nil
let destructiveActionsSection : SectionModel ?
if dependencies [ feature : . updatedGroupsDeleteBeforeNow ] || dependencies [ feature : . updatedGroupsDeleteAttachmentsBeforeNow ] {
destructiveActionsSection = SectionModel (
model : . destructiveActions ,
elements : [
// FIXME: [ G R O U P S R E B U I L D ] N e e d t o b u i l d t h i s p r o p e r l y i n a f u t u r e r e l e a s e
( ! dependencies [ feature : . updatedGroupsDeleteBeforeNow ] || threadViewModel . threadVariant != . group ? nil :
SessionCell . Info (
id : . debugDeleteBeforeNow ,
leadingAccessory : . icon (
Lucide . image ( icon : . trash2 , size : 24 ) ?
. withRenderingMode ( . alwaysTemplate ) ,
customTint : . danger
) ,
title : " [DEBUG] Delete all messages before now " , // s t r i n g l i n t : d i s a b l e
styling : SessionCell . StyleInfo (
tintColor : . danger
) ,
confirmationInfo : ConfirmationModal . Info (
title : " delete " . localized ( ) ,
body : . text ( " Are you sure you want to delete all messages sent before now for all group members? " ) , // s t r i n g l i n t : d i s a b l e
confirmTitle : " delete " . localized ( ) ,
confirmStyle : . danger ,
cancelStyle : . alert_text
) ,
onTap : { [ weak self ] in self ? . deleteAllMessagesBeforeNow ( ) }
)
) ,
// FIXME: [ G R O U P S R E B U I L D ] N e e d t o b u i l d t h i s p r o p e r l y i n a f u t u r e r e l e a s e
( ! dependencies [ feature : . updatedGroupsDeleteAttachmentsBeforeNow ] || threadViewModel . threadVariant != . group ? nil :
SessionCell . Info (
id : . debugDeleteAttachmentsBeforeNow ,
leadingAccessory : . icon (
Lucide . image ( icon : . trash2 , size : 24 ) ?
. withRenderingMode ( . alwaysTemplate ) ,
customTint : . danger
) ,
title : " [DEBUG] Delete all arrachments before now " , // s t r i n g l i n t : d i s a b l e
styling : SessionCell . StyleInfo (
tintColor : . danger
) ,
confirmationInfo : ConfirmationModal . Info (
title : " delete " . localized ( ) ,
body : . text ( " Are you sure you want to delete all attachments (and their associated messages) sent before now for all group members? " ) , // s t r i n g l i n t : d i s a b l e
confirmTitle : " delete " . localized ( ) ,
confirmStyle : . danger ,
cancelStyle : . alert_text
) ,
onTap : { [ weak self ] in self ? . deleteAllAttachmentsBeforeNow ( ) }
)
)
] . compactMap { $0 }
)
}
else {
destructiveActionsSection = nil
}
return [
conversationInfoSection ,
standardActionsSection ,
adminActionsSection ,
destructiveActionsSection
] . compactMap { $0 }
}
// MARK: - F u n c t i o n s
private func viewDisplayPicture ( threadViewModel : SessionThreadViewModel ) {
let displayPictureData : Data
let ownerId : DisplayPictureManager . OwnerId = {
switch threadViewModel . threadVariant {
case . contact : . user ( threadViewModel . threadId )
case . group , . legacyGroup : . group ( threadViewModel . threadId )
case . community : . community ( threadViewModel . threadId )
}
} ( )
switch threadViewModel . threadVariant {
case . legacyGroup : return // N o d i s p l a y p i c t u r e s f o r l e g a c y g r o u p s
case . contact :
guard
let profile : Profile = threadViewModel . profile ,
let imageData : Data = dependencies [ singleton : . displayPictureManager ] . displayPicture ( owner : . user ( profile ) )
else { return }
displayPictureData = imageData
default :
guard
threadViewModel . displayPictureFilename != nil ,
let imageData : Data = dependencies [ singleton : . storage ] . read ( { [ dependencies ] db in
dependencies [ singleton : . displayPictureManager ] . displayPicture ( db , id : ownerId )
} )
else { return }
displayPictureData = imageData
}
let format : ImageFormat = displayPictureData . guessedImageFormat
let navController : UINavigationController = StyledNavigationController (
rootViewController : ProfilePictureVC (
image : ( format = = . gif || format = = . webp ?
nil :
UIImage ( data : displayPictureData )
) ,
animatedImage : ( format != . gif && format != . webp ?
nil :
YYImage ( data : displayPictureData )
) ,
title : threadViewModel . displayName
)
)
navController . modalPresentationStyle = . fullScreen
self . transitionToScreen ( navController , transitionType : . present )
}
private func inviteUsersToCommunity ( threadViewModel : SessionThreadViewModel ) {
guard
let name : String = threadViewModel . openGroupName ,
let communityUrl : String = LibSession . communityUrlFor (
server : threadViewModel . openGroupServer ,
roomToken : threadViewModel . openGroupRoomToken ,
publicKey : threadViewModel . openGroupPublicKey
)
else { return }
self . transitionToScreen (
SessionTableViewController (
viewModel : UserListViewModel < Contact > (
title : " membersInvite " . localized ( ) ,
emptyState : " contactNone " . localized ( ) ,
showProfileIcons : false ,
request : Contact
. filter ( Contact . Columns . isApproved = = true )
. filter ( Contact . Columns . didApproveMe = = true )
. filter ( Contact . Columns . id != threadViewModel . currentUserSessionId ) ,
footerTitle : " membersInvite " . localized ( ) ,
footerAccessibility : Accessibility (
identifier : " Invite contacts button "
) ,
onSubmit : . publisher { [ dependencies ] _ , selectedUserInfo in
dependencies [ singleton : . storage ]
. writePublisher { db in
try selectedUserInfo . forEach { userInfo in
let sentTimestampMs : Int64 = dependencies [ cache : . snodeAPI ] . currentOffsetTimestampMs ( )
let thread : SessionThread = try SessionThread . upsert (
db ,
id : userInfo . profileId ,
variant : . contact ,
values : SessionThread . TargetValues (
creationDateTimestamp : . useExistingOrSetTo ( TimeInterval ( sentTimestampMs ) / 1000 ) ,
shouldBeVisible : . useExisting
) ,
using : dependencies
)
try LinkPreview (
url : communityUrl ,
variant : . openGroupInvitation ,
title : name ,
using : dependencies
)
. upsert ( db )
let destinationDisappearingMessagesConfiguration : DisappearingMessagesConfiguration ? = try ? DisappearingMessagesConfiguration
. filter ( id : userInfo . profileId )
. filter ( DisappearingMessagesConfiguration . Columns . isEnabled = = true )
. fetchOne ( db )
let interaction : Interaction = try Interaction (
threadId : thread . id ,
threadVariant : thread . variant ,
authorId : threadViewModel . currentUserSessionId ,
variant : . standardOutgoing ,
timestampMs : sentTimestampMs ,
expiresInSeconds : destinationDisappearingMessagesConfiguration ? . expiresInSeconds ( ) ,
expiresStartedAtMs : destinationDisappearingMessagesConfiguration ? . initialExpiresStartedAtMs (
sentTimestampMs : Double ( sentTimestampMs )
) ,
linkPreviewUrl : communityUrl ,
using : dependencies
)
. inserted ( db )
try MessageSender . send (
db ,
interaction : interaction ,
threadId : thread . id ,
threadVariant : thread . variant ,
using : dependencies
)
// T r i g g e r d i s a p p e a r a f t e r r e a d
dependencies [ singleton : . jobRunner ] . upsert (
db ,
job : DisappearingMessagesJob . updateNextRunIfNeeded (
db ,
interaction : interaction ,
startedAtMs : Double ( sentTimestampMs ) ,
using : dependencies
) ,
canStartJob : true
)
}
}
. mapError { UserListError . error ( $0 . localizedDescription ) }
. eraseToAnyPublisher ( )
} ,
using : dependencies
)
) ,
transitionType : . push
)
}
public static func createMemberListViewController (
threadId : String ,
transitionToConversation : @ escaping ( String ) -> Void ,
using dependencies : Dependencies
) -> UIViewController {
return SessionTableViewController (
viewModel : UserListViewModel (
title : " groupMembers " . localized ( ) ,
showProfileIcons : true ,
request : GroupMember
. select (
GroupMember . Columns . groupId ,
GroupMember . Columns . profileId ,
max ( GroupMember . Columns . role ) . forKey ( GroupMember . Columns . role . name ) ,
GroupMember . Columns . roleStatus ,
GroupMember . Columns . isHidden
)
. filter ( GroupMember . Columns . groupId = = threadId )
. group ( GroupMember . Columns . profileId ) ,
onTap : . callback { _ , memberInfo in
dependencies [ singleton : . storage ] . write { db in
try SessionThread . upsert (
db ,
id : memberInfo . profileId ,
variant : . contact ,
values : SessionThread . TargetValues (
creationDateTimestamp : . useExistingOrSetTo (
dependencies [ cache : . snodeAPI ] . currentOffsetTimestampMs ( ) / 1000
) ,
shouldBeVisible : . useExisting ,
isDraft : . useExistingOrSetTo ( true )
) ,
using : dependencies
)
}
transitionToConversation ( memberInfo . profileId )
} ,
using : dependencies
)
)
}
private func viewMembers ( ) {
self . transitionToScreen (
ThreadSettingsViewModel . createMemberListViewController (
threadId : threadId ,
transitionToConversation : { [ weak self , dependencies ] selectedMemberId in
self ? . transitionToScreen (
ConversationVC (
threadId : selectedMemberId ,
threadVariant : . contact ,
using : dependencies
) ,
transitionType : . push
)
} ,
using : dependencies
)
)
}
private func promoteAdmins ( currentGroupName : String ? ) {
guard dependencies [ feature : . updatedGroupsAllowPromotions ] else { return }
let groupMember : TypedTableAlias < GroupMember > = TypedTableAlias ( )
// / S u b m i t t i n g a n d r e s e n d i n g u s i n g t h e s a m e l o g i c
func send (
_ viewModel : UserListViewModel < GroupMember > ? ,
_ memberInfo : [ ( id : String , profile : Profile ? ) ] ,
isResend : Bool
) {
// / S h o w a t o a s t i m m e d i a t e l y t h a t w e a r e s e n d i n g i n v i t a t i o n s
viewModel ? . showToast (
text : " adminSendingPromotion "
. putNumber ( memberInfo . count )
. localized ( ) ,
backgroundColor : . backgroundSecondary
)
// / A c t u a l l y t r i g g e r t h e s e n d i n g p r o c e s s
MessageSender
. promoteGroupMembers (
groupSessionId : SessionId ( . group , hex : threadId ) ,
members : memberInfo ,
isResend : isResend ,
using : dependencies
)
. subscribe ( on : DispatchQueue . global ( qos : . userInitiated ) , using : dependencies )
. receive ( on : DispatchQueue . main , using : dependencies )
. sinkUntilComplete (
receiveCompletion : { [ threadId , dependencies ] result in
switch result {
case . finished : break
case . failure :
let memberIds : [ String ] = memberInfo . map ( \ . id )
// / F l a g t h e m e m b e r s a s f a i l e d
dependencies [ singleton : . storage ] . writeAsync { db in
try ? GroupMember
. filter ( GroupMember . Columns . groupId = = threadId )
. filter ( memberIds . contains ( GroupMember . Columns . profileId ) )
. updateAllAndConfig (
db ,
GroupMember . Columns . roleStatus . set ( to : GroupMember . RoleStatus . failed ) ,
using : dependencies
)
}
// / S h o w a t o a s t t h a t t h e p r o m o t i o n s f a i l e d t o s e n d
viewModel ? . showToast (
text : GroupPromoteMemberJob . failureMessage (
groupName : ( currentGroupName ? ? " groupUnknown " . localized ( ) ) ,
memberIds : memberIds ,
profileInfo : memberInfo . reduce ( into : [ : ] ) { result , next in
result [ next . id ] = next . profile
}
) ,
backgroundColor : . backgroundSecondary
)
}
}
)
}
// / S h o w t h e s e l e c t i o n l i s t
self . transitionToScreen (
SessionTableViewController (
viewModel : UserListViewModel < GroupMember > (
title : " promote " . localized ( ) ,
// FIXME: L o c a l i s e t h i s
emptyState : " There are no group members which can be promoted. " ,
showProfileIcons : true ,
request : SQLRequest ( " " "
SELECT \ ( groupMember . allColumns )
FROM \ ( groupMember )
WHERE (
\ ( groupMember [ . groupId ] ) = = \ ( threadId ) AND (
\ ( groupMember [ . role ] ) = = \ ( GroupMember . Role . admin ) OR
(
\ ( groupMember [ . role ] ) != \ ( GroupMember . Role . admin ) AND
\ ( groupMember [ . roleStatus ] ) = = \ ( GroupMember . RoleStatus . accepted )
)
)
)
GROUP BY \ ( groupMember [ . profileId ] )
" " " ),
footerTitle : " promote " . localized ( ) ,
onTap : . conditionalAction (
action : { memberInfo in
guard memberInfo . profileId != memberInfo . currentUserSessionId . hexString else {
return . none
}
switch ( memberInfo . value . role , memberInfo . value . roleStatus ) {
case ( . standard , _ ) : return . radio
default :
return . custom (
trailingAccessory : { _ in
. highlightingBackgroundLabel (
title : " resend " . localized ( )
)
} ,
onTap : { viewModel , info in
send ( viewModel , [ ( info . profileId , info . profile ) ] , isResend : true )
}
)
}
}
) ,
onSubmit : . callback { viewModel , selectedInfo in
send ( viewModel , selectedInfo . map { ( $0 . profileId , $0 . profile ) } , isResend : false )
} ,
using : dependencies
)
) ,
transitionType : . push
)
}
private func updateNickname ( current : String ? , displayName : String ) {
// / S e t ` u p d a t e d N a m e ` t o ` c u r r e n t ` s o w e c a n d i s a b l e t h e " s a v e " b u t t o n w h e n t h e r e a r e n o c h a n g e s a n d d o n ' t n e e d t o w o r r y
// / a b o u t r e t r i e v i n g t h e m i n t h e c o n f i r m a t i o n c l o s u r e
self . updatedName = current
self . transitionToScreen (
ConfirmationModal (
info : ConfirmationModal . Info (
title : " nicknameSet " . localized ( ) ,
body : . input (
explanation : " nicknameDescription "
. put ( key : " name " , value : displayName )
. localizedFormatted ( baseFont : ConfirmationModal . explanationFont ) ,
info : ConfirmationModal . Info . Body . InputInfo (
placeholder : " nicknameEnter " . localized ( ) ,
initialValue : current ,
accessibility : Accessibility (
identifier : " Username "
)
) ,
onChange : { [ weak self ] updatedName in self ? . updatedName = updatedName }
) ,
confirmTitle : " save " . localized ( ) ,
confirmEnabled : . afterChange { [ weak self ] _ in
self ? . updatedName != current &&
self ? . updatedName ? . trimmingCharacters ( in : . whitespacesAndNewlines ) . isEmpty = = false
} ,
cancelTitle : " remove " . localized ( ) ,
cancelStyle : . danger ,
cancelEnabled : . bool ( current ? . trimmingCharacters ( in : . whitespacesAndNewlines ) . isEmpty = = false ) ,
hasCloseButton : true ,
dismissOnConfirm : false ,
onConfirm : { [ weak self , dependencies , threadId ] modal in
guard
let finalNickname : String = ( self ? . updatedName ? ? " " )
. trimmingCharacters ( in : . whitespacesAndNewlines )
. nullIfEmpty
else { return }
// / C h e c k i f t h e d a t a v i o l a t e s t h e s i z e c o n s t r a i n t s
guard ! Profile . isTooLong ( profileName : finalNickname ) else {
self ? . transitionToScreen (
ConfirmationModal (
info : ConfirmationModal . Info (
title : " theError " . localized ( ) ,
body : . text ( " nicknameErrorShorter " . localized ( ) ) ,
cancelTitle : " okay " . localized ( ) ,
cancelStyle : . alert_text ,
dismissType : . single
)
) ,
transitionType : . present
)
return
}
// / U p d a t e t h e n i c k n a m e
dependencies [ singleton : . storage ] . writeAsync { db in
try Profile
. filter ( id : threadId )
. updateAllAndConfig (
db ,
Profile . Columns . nickname . set ( to : finalNickname ) ,
using : dependencies
)
}
modal . dismiss ( animated : true )
} ,
onCancel : { [ dependencies , threadId ] modal in
// / R e m o v e t h e n i c k n a m e
dependencies [ singleton : . storage ] . writeAsync { db in
try Profile
. filter ( id : threadId )
. updateAllAndConfig (
db ,
Profile . Columns . nickname . set ( to : nil ) ,
using : dependencies
)
}
modal . dismiss ( animated : true )
}
)
) ,
transitionType : . present
)
}
private func updateGroupNameAndDescription (
currentName : String ,
currentDescription : String ? ,
isUpdatedGroup : Bool
) {
// / S e t t h e ` u p d a t e d N a m e ` a n d ` u p d a t e d D e s c r i p t i o n ` v a l u e s t o t h e c u r r e n t v a l u e s s o w e c a n d i s a b l e t h e " s a v e " b u t t o n w h e n t h e r e a r e
// / n o c h a n g e s a n d d o n ' t n e e d t o w o r r y a b o u t r e t r i e v i n g t h e m i n t h e c o n f i r m a t i o n c l o s u r e
self . updatedName = currentName
self . updatedDescription = currentDescription
self . transitionToScreen (
ConfirmationModal (
info : ConfirmationModal . Info (
title : " groupInformationSet " . localized ( ) ,
body : { [ weak self , dependencies ] in
guard isUpdatedGroup && dependencies [ feature : . updatedGroupsAllowDescriptionEditing ] else {
return . input (
explanation : NSAttributedString ( string : " groupNameVisible " . localized ( ) ) ,
info : ConfirmationModal . Info . Body . InputInfo (
placeholder : " groupNameEnter " . localized ( ) ,
initialValue : currentName ,
accessibility : Accessibility (
identifier : " Group name text field "
)
) ,
onChange : { updatedName in self ? . updatedName = updatedName }
)
}
return . dualInput (
// FIXME: L o c a l i s e t h i s
explanation : NSAttributedString ( string : " Group name and description are visible to all group members. " ) ,
firstInfo : ConfirmationModal . Info . Body . InputInfo (
placeholder : " groupNameEnter " . localized ( ) ,
initialValue : currentName ,
accessibility : Accessibility (
identifier : " Group name text field "
)
) ,
secondInfo : ConfirmationModal . Info . Body . InputInfo (
placeholder : " groupDescriptionEnter " . localized ( ) ,
initialValue : currentDescription ,
accessibility : Accessibility (
identifier : " Group description text field "
)
) ,
onChange : { updatedName , updatedDescription in
self ? . updatedName = updatedName
self ? . updatedDescription = updatedDescription
}
)
} ( ) ,
confirmTitle : " save " . localized ( ) ,
confirmEnabled : . afterChange { [ weak self ] _ in
self ? . updatedName ? . trimmingCharacters ( in : . whitespacesAndNewlines ) . isEmpty = = false && (
self ? . updatedName != currentName ||
self ? . updatedDescription != currentDescription
)
} ,
cancelStyle : . danger ,
onConfirm : { [ weak self , dependencies , threadId ] modal in
guard
let finalName : String = ( self ? . updatedName ? ? " " )
. trimmingCharacters ( in : . whitespacesAndNewlines )
. nullIfEmpty
else { return }
let finalDescription : String ? = self ? . updatedDescription
. map { $0 . trimmingCharacters ( in : . whitespacesAndNewlines ) }
// / C h e c k i f t h e d a t a v i o l a t e s a n y o f t h e s i z e c o n s t r a i n t s
let maybeErrorString : String ? = {
guard ! LibSession . isTooLong ( groupName : finalName ) else {
return " groupNameEnterShorter " . localized ( )
}
guard ! LibSession . isTooLong ( groupDescription : ( finalDescription ? ? " " ) ) else {
// FIXME: L o c a l i s e t h i s
return " Please enter a shorter group description. "
}
return nil // N o e r r o r h a s o c c u r r e d
} ( )
if let errorString : String = maybeErrorString {
self ? . transitionToScreen (
ConfirmationModal (
info : ConfirmationModal . Info (
title : " theError " . localized ( ) ,
body : . text ( errorString ) ,
cancelTitle : " okay " . localized ( ) ,
cancelStyle : . alert_text ,
dismissType : . single
)
) ,
transitionType : . present
)
return
}
// / U p d a t e t h e g r o u p a p p r o p r i a t e l y
MessageSender
. updateGroup (
groupSessionId : threadId ,
name : finalName ,
groupDescription : finalDescription ,
using : dependencies
)
. subscribe ( on : DispatchQueue . global ( qos : . userInitiated ) , using : dependencies )
. receive ( on : DispatchQueue . main , using : dependencies )
. sinkUntilComplete ( )
}
)
) ,
transitionType : . present
)
}
private func updateGroupDisplayPicture ( currentFileName : String ? ) {
guard dependencies [ feature : . updatedGroupsAllowDisplayPicture ] else { return }
let existingImageData : Data ? = dependencies [ singleton : . storage ] . read { [ threadId , dependencies ] db in
dependencies [ singleton : . displayPictureManager ] . displayPicture ( db , id : . group ( threadId ) )
}
self . transitionToScreen (
ConfirmationModal (
info : ConfirmationModal . Info (
title : " groupSetDisplayPicture " . localized ( ) ,
body : . image (
placeholderData : UIImage ( named : " profile_placeholder " ) ? . pngData ( ) ,
valueData : existingImageData ,
icon : . rightPlus ,
style : . circular ,
accessibility : Accessibility (
identifier : " Image picker " ,
label : " Image picker "
) ,
onClick : { [ weak self ] onDisplayPictureSelected in
self ? . onDisplayPictureSelected = onDisplayPictureSelected
self ? . showPhotoLibraryForAvatar ( )
}
) ,
confirmTitle : " save " . localized ( ) ,
confirmEnabled : . afterChange { info in
switch info . body {
case . image ( _ , let valueData , _ , _ , _ , _ ) : return ( valueData != nil )
default : return false
}
} ,
cancelTitle : " remove " . localized ( ) ,
cancelEnabled : . bool ( existingImageData != nil ) ,
hasCloseButton : true ,
dismissOnConfirm : false ,
onConfirm : { [ weak self ] modal in
switch modal . info . body {
case . image ( _ , . some ( let valueData ) , _ , _ , _ , _ ) :
self ? . updateGroupDisplayPicture (
displayPictureUpdate : . groupUploadImageData ( valueData ) ,
onUploadComplete : { [ weak modal ] in modal ? . close ( ) }
)
default : modal . close ( )
}
} ,
onCancel : { [ weak self ] modal in
self ? . updateGroupDisplayPicture (
displayPictureUpdate : . groupRemove ,
onUploadComplete : { [ weak modal ] in modal ? . close ( ) }
)
}
)
) ,
transitionType : . present
)
}
private func showPhotoLibraryForAvatar ( ) {
Permissions . requestLibraryPermissionIfNeeded ( isSavingMedia : false , using : dependencies ) { [ weak self ] in
DispatchQueue . main . async {
let picker : UIImagePickerController = UIImagePickerController ( )
picker . sourceType = . photoLibrary
picker . mediaTypes = [ " public.image " ] // s t r i n g l i n t : d i s a b l e
picker . delegate = self ? . imagePickerHandler
self ? . transitionToScreen ( picker , transitionType : . present )
}
}
}
private func updateGroupDisplayPicture (
displayPictureUpdate : DisplayPictureManager . Update ,
onUploadComplete : @ escaping ( ) -> ( )
) {
switch displayPictureUpdate {
case . none : onUploadComplete ( )
default : break
}
Just ( displayPictureUpdate )
. setFailureType ( to : Error . self )
. flatMap { [ weak self , dependencies ] update -> AnyPublisher < DisplayPictureManager . Update , Error > in
switch displayPictureUpdate {
case . none , . currentUserRemove , . currentUserUploadImageData , . currentUserUpdateTo ,
. contactRemove , . contactUpdateTo :
return Fail ( error : AttachmentError . invalidStartState ) . eraseToAnyPublisher ( )
case . groupRemove , . groupUpdateTo :
return Just ( displayPictureUpdate )
. setFailureType ( to : Error . self )
. eraseToAnyPublisher ( )
case . groupUploadImageData ( let data ) :
// / S h o w a b l o c k i n g l o a d i n g i n d i c a t o r w h i l e u p l o a d i n g b u t n o t w h i l e u p d a t i n g o r s y n c i n g t h e g r o u p c o n f i g s
return dependencies [ singleton : . displayPictureManager ]
. prepareAndUploadDisplayPicture ( imageData : data )
. showingBlockingLoading ( in : self ? . navigatableState )
. map { url , fileName , key -> DisplayPictureManager . Update in
. groupUpdateTo ( url : url , key : key , fileName : fileName )
}
. mapError { $0 as Error }
. handleEvents (
receiveCompletion : { result in
switch result {
case . failure ( let error ) :
let message : String = {
switch ( displayPictureUpdate , error ) {
case ( . groupRemove , _ ) : return " profileDisplayPictureRemoveError " . localized ( )
case ( _ , DisplayPictureError . uploadMaxFileSizeExceeded ) :
return " profileDisplayPictureSizeError " . localized ( )
default : return " errorConnection " . localized ( )
}
} ( )
self ? . transitionToScreen (
ConfirmationModal (
info : ConfirmationModal . Info (
title : " deleteAfterLegacyGroupsGroupUpdateErrorTitle " . localized ( ) ,
body : . text ( message ) ,
cancelTitle : " okay " . localized ( ) ,
cancelStyle : . alert_text ,
dismissType : . single
)
) ,
transitionType : . present
)
case . finished : onUploadComplete ( )
}
}
)
. eraseToAnyPublisher ( )
}
}
. flatMapStorageReadPublisher ( using : dependencies ) { [ threadId ] db , displayPictureUpdate -> ( DisplayPictureManager . Update , String ? ) in
(
displayPictureUpdate ,
try ? ClosedGroup
. filter ( id : threadId )
. select ( . displayPictureFilename )
. asRequest ( of : String . self )
. fetchOne ( db )
)
}
. flatMap { [ threadId , dependencies ] displayPictureUpdate , existingFileName -> AnyPublisher < String ? , Error > in
MessageSender
. updateGroup (
groupSessionId : threadId ,
displayPictureUpdate : displayPictureUpdate ,
using : dependencies
)
. map { _ in existingFileName }
. eraseToAnyPublisher ( )
}
. handleEvents (
receiveOutput : { [ dependencies ] existingFileName in
// R e m o v e a n y c a c h e d a v a t a r i m a g e v a l u e
if let existingFileName : String = existingFileName {
dependencies . mutate ( cache : . displayPicture ) { $0 . imageData [ existingFileName ] = nil }
}
}
)
. subscribe ( on : DispatchQueue . global ( qos : . userInitiated ) , using : dependencies )
. receive ( on : DispatchQueue . main , using : dependencies )
. sinkUntilComplete ( )
}
private func updateBlockedState (
from oldBlockedState : Bool ,
isBlocked : Bool ,
threadId : String ,
displayName : String
) {
guard oldBlockedState != isBlocked else { return }
dependencies [ singleton : . storage ] . writeAsync { [ dependencies ] db in
try Contact
. filter ( id : threadId )
. updateAllAndConfig (
db ,
Contact . Columns . isBlocked . set ( to : isBlocked ) ,
using : dependencies
)
}
}
private func deleteAllMessagesBeforeNow ( ) {
guard threadVariant = = . group else { return }
dependencies [ singleton : . storage ] . writeAsync { [ threadId , dependencies ] db in
try LibSession . deleteMessagesBefore (
db ,
groupSessionId : SessionId ( . group , hex : threadId ) ,
timestamp : ( dependencies [ cache : . snodeAPI ] . currentOffsetTimestampMs ( ) / 1000 ) ,
using : dependencies
)
}
}
private func deleteAllAttachmentsBeforeNow ( ) {
guard threadVariant = = . group else { return }
dependencies [ singleton : . storage ] . writeAsync { [ threadId , dependencies ] db in
try LibSession . deleteAttachmentsBefore (
db ,
groupSessionId : SessionId ( . group , hex : threadId ) ,
timestamp : ( dependencies [ cache : . snodeAPI ] . currentOffsetTimestampMs ( ) / 1000 ) ,
using : dependencies
)
}
}
}
