feat: Host conversations

migrations/20250820000000-add-conversation-visibility.ts

@@ -0,0 +1,33 @@
+'use strict';
+
+module.exports = {
+  up: async (queryInterface, DataTypes) => {
+    await queryInterface.addColumn('Conversations', 'visibility', {
+      type: DataTypes.ENUM('PUBLIC', 'ADMINS_AND_HOST'),
+      defaultValue: 'PUBLIC',
+      allowNull: false,
+    });
+
+    await queryInterface.addColumn('Conversations', 'HostCollectiveId', {
+      type: DataTypes.INTEGER,
+      references: { key: 'id', model: 'Collectives' },
+      onDelete: 'CASCADE',
+      onUpdate: 'CASCADE',
+      allowNull: true,
+    });
+
+    await queryInterface.sequelize.query(`
+      UPDATE "Conversations" SET visibility = 'PUBLIC' WHERE visibility IS NULL
+    `);
+
+    await queryInterface.changeColumn('Conversations', 'visibility', {
+      type: DataTypes.ENUM('PUBLIC', 'ADMINS_AND_HOST'),
+      allowNull: false,
+    });
+  },
+
+  down: async queryInterface => {
+    await queryInterface.removeColumn('Conversations', 'visibility');
+    await queryInterface.sequelize.query('DROP TYPE IF EXISTS "enum_Conversations_visibility"');
+  },
+};

server/graphql/common/conversations.ts

@@ -3,9 +3,9 @@ import { pick } from 'lodash';
 
 import FEATURE from '../../constants/feature';
 import { hasFeature } from '../../lib/allowed-features';
-import models from '../../models';
-import Conversation from '../../models/Conversation';
-import { FeatureNotSupportedForCollective, NotFound, Unauthorized } from '../errors';
+import models, { Collective } from '../../models';
+import Conversation, { ConversationVisibility } from '../../models/Conversation';
+import { FeatureNotSupportedForCollective, NotFound, Unauthorized, ValidationFailed } from '../errors';
 
 import { checkRemoteUserCanUseConversations } from './scope-check';
 
@@ -14,7 +14,9 @@ interface CreateConversationParams {
   title: string;
   html: string;
   CollectiveId: number;
+  HostCollectiveId?: number;
   tags?: string[] | null;
+  visibility?: ConversationVisibility;
 }
 
 /**
@@ -26,7 +28,7 @@ export const createConversation = async (req: Request, params: CreateConversatio
   // For now any authenticated user can create a conversation to any collective
   checkRemoteUserCanUseConversations(req);
 
-  const { CollectiveId, title, html, tags } = params;
+  const { CollectiveId, title, html, tags, visibility } = params;
 
   // Collective must exist and be of type `COLLECTIVE`
   const collective = await req.loaders.Collective.byId.load(CollectiveId);
@@ -36,12 +38,31 @@ export const createConversation = async (req: Request, params: CreateConversatio
     throw new FeatureNotSupportedForCollective();
   }
 
-  return Conversation.createWithComment(req.remoteUser, collective, title, html, tags);
+  // Host collective must exist and be of type `HOST`
+  let host: Collective | null = null;
+  if (params.HostCollectiveId) {
+    host = await req.loaders.Collective.byId.load(params.HostCollectiveId);
+    if (!host) {
+      throw new NotFound("This Host doesn't exist or has been deleted");
+    } else if (!host.isHostAccount) {
+      throw new ValidationFailed('This Host is not a host');
+    }
+
+    // TODO
+    // else if (!req.remoteUser.isAdmin(host.id) || !(
+    //   req.remoteUser.isAdmin(collective.id) && collective.HostCollectiveId === host.id
+    // )) {
+    //   throw new Unauthorized('You are not authorized to create a conversation for this host');
+    // }
+  }
+
+  return Conversation.createWithComment(req.remoteUser, collective, title, html, tags, visibility, host);
 };
 
 interface EditConversationParams {
   id: number;
   title: string;
+  visibility?: ConversationVisibility;
 }
 
 /**
@@ -63,5 +84,5 @@ export const editConversation = async (req: Request, params: EditConversationPar
     throw new Unauthorized();
   }
 
-  return conversation.update(pick(params, ['title', 'tags']));
+  return conversation.update(pick(params, ['title', 'tags', 'visibility']));
 };

server/graphql/schemaV2.graphql

@@ -819,6 +819,26 @@
     Only return conversations matching this tag
     """
     tag: String
+
+    """
+    Only return conversations with this visibility level
+    """
+    visibility: ConversationVisibility
+
+    """
+    Only return conversations for this specific account
+    """
+    account: AccountReferenceInput
+
+    """
+    Only return conversations for this specific host
+    """
+    host: AccountReferenceInput
+
+    """
+    The order of results
+    """
+    orderBy: ChronologicalOrderInput! = { field: CREATED_AT, direction: DESC }
   ): ConversationCollection!
 
   """
@@ -3492,6 +3512,26 @@
     Only return conversations matching this tag
     """
     tag: String
+
+    """
+    Only return conversations with this visibility level
+    """
+    visibility: ConversationVisibility
+
+    """
+    Only return conversations for this specific account
+    """
+    account: AccountReferenceInput
+
+    """
+    Only return conversations for this specific host
+    """
+    host: AccountReferenceInput
+
+    """
+    The order of results
+    """
+    orderBy: ChronologicalOrderInput! = { field: CREATED_AT, direction: DESC }
   ): ConversationCollection!
 
   """
@@ -5413,6 +5453,7 @@
   updatedAt: DateTime!
   tags: [String]
   summary: String!
+  visibility: ConversationVisibility!
   account: Account
   fromAccount: Account
 
@@ -5427,6 +5468,11 @@
   comments(limit: Int! = 150, offset: Int! = 0): CommentCollection!
   followers(limit: Int! = 10, offset: Int! = 0): AccountCollection!
   stats: ConversationStats
+
+  """
+  The date of the last comment in this conversation
+  """
+  lastCommentDate: DateTime
 }
 
 """
@@ -5475,6 +5521,21 @@
   PRIVATE_NOTE
 }
 
+"""
+Conversation visibility levels
+"""
+enum ConversationVisibility {
+  """
+  Public conversation visible to everyone
+  """
+  PUBLIC
+
+  """
+  Private conversation visible only to collective admins and host admins
+  """
+  ADMINS_AND_HOST
+}
+
 type HostApplication {
   id: String!
 
@@ -9412,6 +9473,26 @@
     Only return conversations matching this tag
     """
     tag: String
+
+    """
+    Only return conversations with this visibility level
+    """
+    visibility: ConversationVisibility
+
+    """
+    Only return conversations for this specific account
+    """
+    account: AccountReferenceInput
+
+    """
+    Only return conversations for this specific host
+    """
+    host: AccountReferenceInput
+
+    """
+    The order of results
+    """
+    orderBy: ChronologicalOrderInput! = { field: CREATED_AT, direction: DESC }
   ): ConversationCollection!
 
   """
@@ -10365,6 +10446,26 @@
     Only return conversations matching this tag
     """
     tag: String
+
+    """
+    Only return conversations with this visibility level
+    """
+    visibility: ConversationVisibility
+
+    """
+    Only return conversations for this specific account
+    """
+    account: AccountReferenceInput
+
+    """
+    Only return conversations for this specific host
+    """
+    host: AccountReferenceInput
+
+    """
+    The order of results
+    """
+    orderBy: ChronologicalOrderInput! = { field: CREATED_AT, direction: DESC }
   ): ConversationCollection!
 
   """
@@ -11876,6 +11977,26 @@
     Only return conversations matching this tag
     """
     tag: String
+
+    """
+    Only return conversations with this visibility level
+    """
+    visibility: ConversationVisibility
+
+    """
+    Only return conversations for this specific account
+    """
+    account: AccountReferenceInput
+
+    """
+    Only return conversations for this specific host
+    """
+    host: AccountReferenceInput
+
+    """
+    The order of results
+    """
+    orderBy: ChronologicalOrderInput! = { field: CREATED_AT, direction: DESC }
   ): ConversationCollection!
 
   """
@@ -19238,6 +19359,26 @@
     Only return conversations matching this tag
     """
     tag: String
+
+    """
+    Only return conversations with this visibility level
+    """
+    visibility: ConversationVisibility
+
+    """
+    Only return conversations for this specific account
+    """
+    account: AccountReferenceInput
+
+    """
+    Only return conversations for this specific host
+    """
+    host: AccountReferenceInput
+
+    """
+    The order of results
+    """
+    orderBy: ChronologicalOrderInput! = { field: CREATED_AT, direction: DESC }
   ): ConversationCollection!
 
   """
@@ -20338,6 +20479,26 @@
     Only return conversations matching this tag
     """
     tag: String
+
+    """
+    Only return conversations with this visibility level
+    """
+    visibility: ConversationVisibility
+
+    """
+    Only return conversations for this specific account
+    """
+    account: AccountReferenceInput
+
+    """
+    Only return conversations for this specific host
+    """
+    host: AccountReferenceInput
+
+    """
+    The order of results
+    """
+    orderBy: ChronologicalOrderInput! = { field: CREATED_AT, direction: DESC }
   ): ConversationCollection!
 
   """

server/graphql/v2/enum/ConversationVisibility.ts

@@ -0,0 +1,18 @@
+import { GraphQLEnumType } from 'graphql';
+
+import { ConversationVisibility } from '../../../models/Conversation';
+
+export const GraphQLConversationVisibility = new GraphQLEnumType({
+  name: 'ConversationVisibility',
+  description: 'Conversation visibility levels',
+  values: {
+    PUBLIC: {
+      description: 'Public conversation visible to everyone',
+      value: ConversationVisibility.PUBLIC,
+    },
+    ADMINS_AND_HOST: {
+      description: 'Private conversation visible only to collective admins and host admins',
+      value: ConversationVisibility.ADMINS_AND_HOST,
+    },
+  },
+});