Function syncSearchContexts

packages/backend/src/ee/syncSearchContexts.ts:16–217

(params: SyncSearchContextsParams)

}

export const syncSearchContexts = async (params: SyncSearchContextsParams) => {
    const { contexts, orgId, db } = params;

    if (!await hasEntitlement("search-contexts")) {
        if (contexts) {
            logger.warn(`Skipping search context sync. Reason: "Search contexts are not supported in your current plan. For support, contact ${SOURCEBOT_SUPPORT_EMAIL}."`);
        }
        return false;
    }

    if (contexts) {
        for (const [key, newContextConfig] of Object.entries(contexts)) {
            const allRepos = await db.repo.findMany({
                where: {
                    orgId,
                },
                select: {
                    id: true,
                    name: true,
                    metadata: true,
                }
            });

            let newReposInContext: { id: number, name: string, metadata: unknown }[] = [];
            if(newContextConfig.include) {
                newReposInContext = allRepos.filter(repo => {
                    return micromatch.isMatch(repo.name, newContextConfig.include!);
                });
            }

            if(newContextConfig.includeConnections) {
                const connections = await db.connection.findMany({
                    where: {
                        orgId,
                        name: {
                            in: newContextConfig.includeConnections,
                        }
                    },
                    include: {
                        repos: {
                            select: {
                                repo: {
                                    select: {
                                        id: true,
                                        name: true,
                                        metadata: true,
                                    }
                                }
                            }
                        }
                    }
                });

                for (const connection of connections) {
                    newReposInContext = newReposInContext.concat(connection.repos.map(repo => repo.repo));
                }
            }