override fun afterCreate()

in src/main/kotlin/org/jetbrains/teamcity/github/SetupFromUrlGitHubWebhooksExtension.kt [28:81]
45 lines of code
8 McCabe index (conditional complexity)

    override fun afterCreate(buildType: SBuildType, user: SUser) {
        val gitRoots = HashSet<SVcsRoot>()
        Util.findSuitableRoots(listOf(buildType)) {
            gitRoots.add(it)
        }
        if (gitRoots.isEmpty()) return
        val split = GitHubWebHookSuggestion.splitRoots(gitRoots)

        val filtered = split.entrySet()
                .filterKnownServers(myOAuthConnectionsManager)
                .filter {
                    TeamCityProperties.getBoolean("teamcity.commitHooks.github.autoInstall") || !it.key.server.equals("github.com", true)
                }
                .map { it.key to it.value }.toMap()

        if (filtered.isEmpty()) return

        val affectedRootsCount = filtered.values.sumOf { it.size }
        LOG.info("Will try to install GitHub webhooks to ${filtered.size} ${filtered.size.pluralize("repository")} (used in $affectedRootsCount vcs ${affectedRootsCount.pluralize("root")})")

        val infos = filtered.keys

        val project = buildType.project

        // Load webhooks for repository and install new one if there's no good webhooks there
        infos@for (info in infos) {
            val connections = myTokensHelper.getConnections(project, info.server)
                    .plus(myWebHooksManager.authDataStorage.findAllForRepository(info).mapNotNull { getConnection(it) })
                    // Like #toSet with custom #equals:
                    .map { (it.project to it.id) to it }.toMap().values
            val connectionToTokensMap = myTokensHelper.getExistingTokens(project, connections, user)
            if (connectionToTokensMap.isEmpty()) {
                LOG.warn("Could not install GitHub webhook for '$info' repository: no tokens for user '${user.describe(false)}")
            }
            for ((connection, tokens) in connectionToTokensMap) {
                val ghc: GitHubClientEx = GitHubClientFactory.createGitHubClient(connection.parameters[GitHubConstants.GITHUB_URL_PARAM]!!)
                for (token in tokens) {
                    ghc.setOAuth2Token(token.accessToken)
                    LOG.debug("Trying to install GitHub webhook with token from the GitHub user '${token.oauthLogin}', OAuth connection is ${connection.id}")
                    try {
                        val result = myWebHooksManager.doInstallWebHook(info, ghc, user, connection)
                        when (result.first) {
                            HookAddOperationResult.Created -> LOG.info("Successfully installed GitHub webhook for '$info'")
                            HookAddOperationResult.AlreadyExists -> LOG.info("Skipped installation of the GitHub webhook for '$info' because it was already there")
                        }
                        // TODO: Show message in UI once webhook successfully installed
                        continue@infos
                    } catch(e: Exception) {
                        LOG.warnAndDebugDetails("Failed to install GitHub webhook for the repository '$info' using token of the GitHub user '${token.oauthLogin}'", e)
                    }
                }
            }
        }
    }