feat(condo): DOMA-12905 add mutation to send voip start message to all verified residents on address + unit

apps/condo/domains/miniapp/access/SendVoIPStartMessageService.js

@@ -0,0 +1,22 @@
+const { throwAuthenticationError } = require('@open-condo/keystone/apolloErrorFormatter')
+
+const { canExecuteServiceAsB2CAppServiceUser } = require('@condo/domains/miniapp/utils/b2cAppServiceUserAccess/server.utils')
+const { SERVICE } = require('@condo/domains/user/constants/common')
+
+async function canSendVoIPStartMessage (args) {
+    const { authentication: { item: user } } = args
+
+    if (!user) return throwAuthenticationError()
+    if (user.deletedAt) return false
+    if (user.isAdmin) return true
+
+    if (user.type === SERVICE) {
+        return await canExecuteServiceAsB2CAppServiceUser(args)
+    }
+
+    return false
+}
+
+module.exports = {
+    canSendVoIPStartMessage,
+}

apps/condo/domains/miniapp/constants.js

@@ -85,6 +85,7 @@ const ACCESS_TOKEN_WRONG_RIGHT_SET_TYPE = 'ACCESS_TOKEN_WRONG_RIGHT_SET_TYPE'
 const ACCESS_TOKEN_CONTEXT_DOES_NOT_MATCH_RIGHT_SET = 'ACCESS_TOKEN_CONTEXT_DOES_NOT_MATCH_RIGHT_SET'
 const ACCESS_TOKEN_SERVICE_USER_DOES_NOT_MATCH_CONTEXT = 'ACCESS_TOKEN_SERVICE_USER_DOES_NOT_MATCH_CONTEXT'
 const ACCESS_TOKEN_NEGATIVE_TTL = 'ACCESS_TOKEN_NEGATIVE_TTL'
+const CALL_DATA_NOT_PROVIDED_ERROR = 'CALL_DATA_NOT_PROVIDED'
 
 const MAX_PERMISSION_NAME_LENGTH = 50
 const MIN_PERMISSION_NAME_LENGTH = 1
@@ -132,6 +133,9 @@ const ACCESS_TOKEN_SESSION_ID_PREFIX = `${Buffer.from('b2bAccessToken').toString
 
 const ACCESS_TOKEN_UPDATE_MANY_CHUNK_SIZE = 500
 
+const NATIVE_VOIP_TYPE = 'sip'
+const B2C_APP_VOIP_TYPE = 'b2cApp'
+
 module.exports = {
     ALL_APPS_CATEGORY,
     CONNECTED_APPS_CATEGORY,
@@ -207,4 +211,9 @@ module.exports = {
 
     DEFAULT_NOTIFICATION_WINDOW_MAX_COUNT,
     DEFAULT_NOTIFICATION_WINDOW_DURATION_IN_SECONDS,
+
+    CALL_DATA_NOT_PROVIDED_ERROR,
+
+    NATIVE_VOIP_TYPE,
+    B2C_APP_VOIP_TYPE,
 }

apps/condo/domains/miniapp/gql.js

@@ -29,6 +29,12 @@ const SEND_B2C_APP_PUSH_MESSAGE_MUTATION = gql`
     }
 `
 
+const SEND_VOIP_START_MESSAGE_MUTATION = gql`
+    mutation sendVoIPStartMessage ($data: SendVoIPStartMessageInput!) {
+        result: sendVoIPStartMessage(data: $data) { verifiedContactsCount createdMessagesCount erroredMessagesCount }
+    }
+`
+
 const B2B_APP_NEWS_SHARING_CONFIG_FIELDS = `{ publishUrl previewUrl pushNotificationSettings customFormUrl getRecipientsUrl getRecipientsCountersUrl icon { publicUrl } previewPicture { publicUrl } name ${COMMON_FIELDS} }`
 const B2BAppNewsSharingConfig = generateGqlQueries('B2BAppNewsSharingConfig', B2B_APP_NEWS_SHARING_CONFIG_FIELDS)
 
@@ -135,5 +141,6 @@ module.exports = {
     B2BAppRoleWithoutEmployeeRole,
     B2BAppPosIntegrationConfig,
     B2CAppAccessRightSet,
+    SEND_VOIP_START_MESSAGE_MUTATION,
 /* AUTOGENERATE MARKER <EXPORTS> */
 }

apps/condo/domains/miniapp/schema/B2CAppAccessRightSet.test.js

@@ -4,20 +4,22 @@
 
 const { faker } = require('@faker-js/faker')
 
-const { makeLoggedInAdminClient, makeClient, UUID_RE } = require('@open-condo/keystone/test.utils')
+const { makeLoggedInAdminClient, makeClient, UUID_RE, expectToThrowAccessDeniedErrorToResult } = require('@open-condo/keystone/test.utils')
 const {
     expectToThrowAuthenticationErrorToObj, expectToThrowAuthenticationErrorToObjects,
     expectToThrowAccessDeniedErrorToObj, expectToThrowAccessDeniedErrorToObjects,
 } = require('@open-condo/keystone/test.utils')
 
 
 
-const { B2CAppAccessRightSet, createTestB2CAppAccessRightSet, updateTestB2CAppAccessRightSet, createTestB2CAppProperty, updateTestB2CAppProperty, B2CAppProperty } = require('@condo/domains/miniapp/utils/testSchema')
+const { B2CAppAccessRightSet, createTestB2CAppAccessRightSet, updateTestB2CAppAccessRightSet, createTestB2CAppProperty, updateTestB2CAppProperty, B2CAppProperty, sendVoIPStartMessageByTestClient, updateTestB2CAppAccessRight } = require('@condo/domains/miniapp/utils/testSchema')
 const { createTestB2CApp, createTestB2CAppAccessRight } = require('@condo/domains/miniapp/utils/testSchema')
+const { FLAT_UNIT_TYPE } = require('@condo/domains/property/constants/common')
 const { buildFakeAddressAndMeta } = require('@condo/domains/property/utils/testSchema/factories')
 const { makeClientWithNewRegisteredAndLoggedInUser, makeClientWithSupportUser } = require('@condo/domains/user/utils/testSchema')
 const { makeClientWithServiceUser } = require('@condo/domains/user/utils/testSchema')
 
+
 describe('B2CAppAccessRightSet', () => {
     let admin
 
@@ -304,13 +306,14 @@ describe('B2CAppAccessRightSet', () => {
         let user
         let b2cApp
         let serviceUser
+        let b2cAccessRight
 
         beforeEach(async () => {
             support = await makeClientWithSupportUser()
             user = await makeClientWithNewRegisteredAndLoggedInUser()
             serviceUser = await makeClientWithServiceUser();
-            [b2cApp] = await createTestB2CApp(admin)
-            await createTestB2CAppAccessRight(admin, serviceUser.user, b2cApp)
+            [b2cApp] = await createTestB2CApp(admin);
+            [b2cAccessRight] = await createTestB2CAppAccessRight(admin, serviceUser.user, b2cApp)
         })
 
         test('B2CAppAccessRightSet', async () => {
@@ -418,6 +421,57 @@ describe('B2CAppAccessRightSet', () => {
             expect(foundB2CAppProperty.id).toEqual(createdB2CAppProperty.id)
 
         })
+
+        test('SendVoIPStartMessageService', async () => {
+            const args = {
+                app: { id: b2cApp.id },
+                addressKey: faker.datatype.uuid(),
+                unitName: faker.random.alphaNumeric(8),
+                unitType: FLAT_UNIT_TYPE,
+                callData: { 
+                    callId: faker.random.alphaNumeric(8),
+                    b2cAppCallData: {
+                        B2CAppContext: faker.random.alphaNumeric(8),
+                    },
+                },
+            }
+
+            // Can't without access right set
+            await expectToThrowAccessDeniedErrorToResult(async () => {
+                await sendVoIPStartMessageByTestClient(serviceUser, args)
+            })
+
+            // Can't with access right set and without b2c app property
+            const [rightSet] = await createTestB2CAppAccessRightSet(support, b2cApp, { canExecuteSendVoIPStartMessage: true })
+            await updateTestB2CAppAccessRight(support, b2cAccessRight.id, { accessRightSet: { connect: { id: rightSet.id } } })
+            await expectToThrowAccessDeniedErrorToResult(async () => {
+                await sendVoIPStartMessageByTestClient(serviceUser, args)
+            })
+
+            // Can with access right set and b2c app property
+            const [b2cAppProperty] = await createTestB2CAppProperty(serviceUser, b2cApp)
+            args.addressKey = b2cAppProperty.addressKey
+            const [result] = await sendVoIPStartMessageByTestClient(serviceUser, args)
+            expect(result).toEqual(expect.objectContaining({
+                verifiedContactsCount: expect.any(Number),
+                createdMessagesCount: expect.any(Number),
+                erroredMessagesCount: expect.any(Number),
+            }))
+
+            // Can't with access right and another b2c app proeprty
+            const [anotherB2CApp] = await createTestB2CApp(admin)
+            const [anotherB2CAppProperty] = await createTestB2CAppProperty(admin, anotherB2CApp)
+            args.addressKey = anotherB2CAppProperty.addressKey
+            await expectToThrowAccessDeniedErrorToResult(async () => {
+                await sendVoIPStartMessageByTestClient(serviceUser, args)
+            })
+
+            // Can't for another app
+            args.app.id = anotherB2CApp.id
+            await expectToThrowAccessDeniedErrorToResult(async () => {
+                await sendVoIPStartMessageByTestClient(serviceUser, args)
+            })
+        })
     })
 
 })