feat(condo): DOMA-13296 add webhook transport (#7750)

* feat(condo): DOMA-13296 add messanger transport

* feat(condo): DOMA-13299 add template and fix api

* feat(condo): DOMA-13296 add webhook transport

* feat(condo): DOMA-13296 add webhook transport

* feat(condo): DOMA-13296 fix bot name

* feat(condo): DOMA-13296 undo delete telegram

* feat(condo): DOMA-13296 fix naming

* feat(condo): DOMA-13296 review fixes

* feat(condo): DOMA-13296 review fixes

* feat(condo): DOMA-13296 review fixes

* feat(condo): DOMA-13296 fix work with webhook render

* feat(condo): DOMA-13296 review fix

* feat(condo): DOMA-13296 update submodules

* feat(condo): DOMA-13296 review fix

* feat(condo): DOMA-13296 fix build

* feat(condo): DOMA-13296 review fix

* feat(condo): DOMA-13296 fix translations

* feat(condo): DOMA-13296 update submodules

* feat(condo): DOMA-13296 undo changes

* feat(condo): DOMA-13296 undo changes

* feat(condo): DOMA-13296 update submodules

* feat(condo): DOMA-13296 update submodules

* feat(condo): DOMA-13296 fix conflict

* feat(condo): DOMA-13296 fix build

* feat(condo): DOMA-13296 add nosemgrep

---------

Co-authored-by: Profitro1ka <189228262+Alexander-Turkin@users.noreply.github.com>

Author: Alexander-Turkin

.helm

@@ -14,7 +14,6 @@ const {
     SMS_TRANSPORT,
     EMAIL_TRANSPORT,
     PUSH_TRANSPORT,
-    TELEGRAM_TRANSPORT,
     MESSAGE_SENDING_STATUS,
     MESSAGE_RESENDING_STATUS,
     MESSAGE_PROCESSING_STATUS,
@@ -24,6 +23,7 @@ const {
     MESSAGE_DISABLED_BY_USER_STATUS,
     MESSAGE_DELIVERY_STRATEGY_AT_LEAST_ONE_TRANSPORT,
     MESSAGE_THROTTLED_STATUS,
+    TELEGRAM_TRANSPORT,
 } = require('@condo/domains/notification/constants/constants')
 const { ONE_MESSAGE_PER_THROTTLING_PERIOD_FOR_USER } = require('@condo/domains/notification/constants/errors')
 const emailAdapter = require('@condo/domains/notification/transports/email')

apps/condo/domains/notification/tasks/deliverMessage.js

@@ -209,7 +209,7 @@ function normalizeSMSText (text) {
 function substituteTranslations (item, locale) {
     if (isArray(item)) return item.map(itemValue => substituteTranslations(itemValue, locale))
     if (isObject(item)) return translateObjectItems(item, locale)
-    
+
     return getLocalized(locale, item)
 }
 
@@ -316,16 +316,16 @@ function emailRenderer ({ message, env }) {
 function pushRenderer ({ message, env, additionalParams }) {
     const { lang: locale, type } = message
     const messageTranslated = substituteTranslations(message, locale)
-    
+
     const appId = additionalParams?.appId
     const overridesForAppId = PUSH_MESSAGE_OVERRIDES?.[appId]
 
     const titleKey = translationStringKeyForPushTitle(type)
     const bodyKey = translationStringKeyForPushBody(type)
-    
+
     let renderedTitle
     let renderedBody
-    
+
     if (appId && overridesForAppId) {
         const overrides = overridesForAppId[locale]
         const titleTemplate = overrides?.[titleKey]

apps/condo/domains/notification/templates.js

@@ -45,6 +45,7 @@ const logger = getLogger()
 
 /** @type {PushAdapterSettings} */
 const PUSH_ADAPTER_SETTINGS = JSON.parse(conf.PUSH_ADAPTER_SETTINGS || '{}')
+const DISABLED_TYPES_EXCEPTIONS_BY_APP_ID = JSON.parse(conf.DISABLED_TYPES_EXCEPTIONS_BY_APP_ID || '[]')
 
 const PUSH_DATA_VALIDATORS_BY_APP_ID = Object.fromEntries(
     Object.entries(PUSH_ADAPTER_SETTINGS.pushDataValidatorsByAppId || {})
@@ -323,11 +324,23 @@ async function send ({ notification, message, data, user, remoteClient } = {}, i
     const userId = get(user, 'id')
     const remoteClientId = get(remoteClient, 'id')
 
-    if (TEMPORARY_DISABLED_TYPES_FOR_PUSH_NOTIFICATIONS.includes(get(message, 'type'))) {
-        return [false, { error: 'Disabled type for push transport' }]
+    let pushTokens = await getTokens(userId, remoteClientId, isVoIP, PUSH_ADAPTER_SETTINGS.transportPriorityByAppId)
+
+    const messageType = get(message, 'type')
+    if (TEMPORARY_DISABLED_TYPES_FOR_PUSH_NOTIFICATIONS.includes(messageType)) {
+        const allowedAppIds = DISABLED_TYPES_EXCEPTIONS_BY_APP_ID?.[messageType] || []
+
+        if (allowedAppIds.length > 0) {
+            pushTokens = pushTokens.filter(token => allowedAppIds.includes(token.appId))
+
+            if (pushTokens.length === 0) {
+                return [false, { error: 'Disabled type for push transport (no allowed appIds found)' }]
+            }
+        } else {
+            return [false, { error: 'Disabled type for push transport' }]
+        }
     }
 
-    let pushTokens = await getTokens(userId, remoteClientId, isVoIP, PUSH_ADAPTER_SETTINGS.transportPriorityByAppId)
     // NOTE: For some message types with push transport, you need to override the push type for all push tokens.
     // If the message has a preferred push type, it takes priority over the value from the remote client.
     const preferredPushTypeForMessage = getPreferredPushTypeByMessageType(get(message, 'type'))

apps/condo/domains/notification/transports/push.js

@@ -1080,18 +1080,20 @@ __metadata:
     "@employee-bot/domains": "link:./domains"
     "@graphql-tools/graphql-file-loader": "npm:^7.5.17"
     "@graphql-tools/load": "npm:^8.1.0"
+    "@maxhub/max-bot-api": "npm:^0.2.2"
     "@open-condo/cli": "workspace:^"
     "@open-condo/codegen": "workspace:^"
     "@open-condo/config": "workspace:^"
+    "@open-condo/featureflags": "workspace:^"
     "@open-condo/keystone": "workspace:^"
     "@types/node": "npm:^24"
-    axios: "npm:^1.15.0"
     commander: "npm:14.0.1"
     express: "npm:^4.17.1"
     graphql: "npm:^16.10.0"
     https-proxy-agent: "npm:^7.0.1"
     jest: "npm:^29.7.0"
     jest-jasmine2: "npm:^29.7.0"
+    jsonwebtoken: "npm:^9.0.0"
     lodash: "npm:^4.17.21"
     node-telegram-bot-api: "npm:^0.66.0"
     openid-client: "npm:5.7.1"