summaryrefslogtreecommitdiff
path: root/internal/typeutils
diff options
context:
space:
mode:
Diffstat (limited to 'internal/typeutils')
-rw-r--r--internal/typeutils/internaltofrontend.go61
1 files changed, 61 insertions, 0 deletions
diff --git a/internal/typeutils/internaltofrontend.go b/internal/typeutils/internaltofrontend.go
index 7d2889b05..a13304bd8 100644
--- a/internal/typeutils/internaltofrontend.go
+++ b/internal/typeutils/internaltofrontend.go
@@ -1739,6 +1739,67 @@ func (c *Converter) NotificationToAPINotification(
}, nil
}
+// ConversationToAPIConversation converts a conversation into its API representation.
+// The conversation status will be filtered using the notification filter context,
+// and may be nil if the status was hidden.
+func (c *Converter) ConversationToAPIConversation(
+ ctx context.Context,
+ conversation *gtsmodel.Conversation,
+ requestingAccount *gtsmodel.Account,
+ filters []*gtsmodel.Filter,
+ mutes *usermute.CompiledUserMuteList,
+) (*apimodel.Conversation, error) {
+ apiConversation := &apimodel.Conversation{
+ ID: conversation.ID,
+ Unread: !*conversation.Read,
+ }
+ for _, account := range conversation.OtherAccounts {
+ var apiAccount *apimodel.Account
+ blocked, err := c.state.DB.IsEitherBlocked(ctx, requestingAccount.ID, account.ID)
+ if err != nil {
+ return nil, gtserror.Newf(
+ "DB error checking blocks between accounts %s and %s: %w",
+ requestingAccount.ID,
+ account.ID,
+ err,
+ )
+ }
+ if blocked || account.IsSuspended() {
+ apiAccount, err = c.AccountToAPIAccountBlocked(ctx, account)
+ } else {
+ apiAccount, err = c.AccountToAPIAccountPublic(ctx, account)
+ }
+ if err != nil {
+ return nil, gtserror.Newf(
+ "error converting account %s to API representation: %w",
+ account.ID,
+ err,
+ )
+ }
+ apiConversation.Accounts = append(apiConversation.Accounts, *apiAccount)
+ }
+ if conversation.LastStatus != nil {
+ var err error
+ apiConversation.LastStatus, err = c.StatusToAPIStatus(
+ ctx,
+ conversation.LastStatus,
+ requestingAccount,
+ statusfilter.FilterContextNotifications,
+ filters,
+ mutes,
+ )
+ if err != nil && !errors.Is(err, statusfilter.ErrHideStatus) {
+ return nil, gtserror.Newf(
+ "error converting status %s to API representation: %w",
+ conversation.LastStatus.ID,
+ err,
+ )
+ }
+ }
+
+ return apiConversation, nil
+}
+
// DomainPermToAPIDomainPerm converts a gts model domin block or allow into an api domain permission.
func (c *Converter) DomainPermToAPIDomainPerm(
ctx context.Context,