suspend fun startSync()

in space-slack-sync/src/main/kotlin/org/jetbrains/spaceSlackSync/homepage/StartSyncService.kt [10:85]
68 lines of code
3 McCabe index (conditional complexity)

    suspend fun startSync(spaceChannelId: String, slackTeamId: String, slackChannelId: String): StartSyncResponse {
        db.syncedChannels.addIfAbsent(
            spaceTokenInfo.spaceAppInstance.clientId,
            spaceChannelId,
            slackTeamId,
            slackChannelId
        )

        appSpaceClient.applications.authorizations.authorizedRights.requestRights(
            application = ApplicationIdentifier.Me,
            contextIdentifier = ChannelPermissionContextIdentifier(spaceChannelId),
            rightCodes = listOf(
                PermissionIdentifier.ViewChannelInfo,
                PermissionIdentifier.ViewMessages,
                PermissionIdentifier.ImportMessages,
            )
        )

        val webhooks = appSpaceClient.applications.webhooks.getAllWebhooks(
            application = ApplicationIdentifier.Me,
        ) {
            webhook {
                id()
                subscriptions {
                    subscription {
                        filters()
                    }
                }
            }
        }

        webhooks.data
            .map { it.webhook }
            .forEach { webhook ->
                val isForThisChannel = webhook.subscriptions
                    .map { it.subscription.filters }
                    .any { filters ->
                        filters.any { filter ->
                            filter is ChatChannelSubscriptionFilter && filter.channel == spaceChannelId
                        }
                    }

                if (isForThisChannel) {
                    // webhook will be re-created
                    appSpaceClient.applications.webhooks.deleteWebhook(
                        application = ApplicationIdentifier.Me,
                        webhookId = webhook.id
                    )
                }
            }

        val webhookId = appSpaceClient.applications.webhooks.createWebhook(
            application = ApplicationIdentifier.Me,
            name = "Channel Messages",
            acceptedHttpResponseCodes = emptyList(),
        ).id

        appSpaceClient.applications.webhooks.subscriptions.createSubscription(
            application = ApplicationIdentifier.Me,
            webhookId = webhookId,
            name = "Channel Messages",
            subscription = CustomGenericSubscriptionIn(
                subjectCode = "Chat.Message",
                filters = listOf(
                    ChatChannelSubscriptionFilterIn(spaceChannelId)
                ),
                eventTypeCodes = listOf(
                    "Chat.Message.Created",
                    "Chat.Message.Deleted",
                    "Chat.Message.Updated",
                )
            ),
        )

        return StartSyncResponse(true)
    }