mirror of
https://github.com/sourcebot-dev/sourcebot.git
synced 2025-12-18 23:35:25 +00:00
22d548e171
## Problem If a repository is added **after** a search context (e.g., a new repository is synced from the code host), then it will never be added to the context even if it should be included. The workaround is to restart the instance. ## Solution This PR adds a call to re-sync all search contexts whenever a connection is successfully synced. This PR adds the `@sourcebot/shared` package that contains `syncSearchContexts.ts` (previously in web) and it's dependencies (namely the entitlements system). ## Why another package? Because the `syncSearchContexts` call is now called from: 1. `initialize.ts` in **web** - handles syncing search contexts on startup and whenever the config is modified in watch mode. This is the same as before. 2. `connectionManager.ts` in **backend** - syncs the search contexts whenever a connection is successfully synced. ## Follow-up devex work Two things: 1. We have several very thin shared packages (i.e., `crypto`, `error`, and `logger`) that we can probably fold into this "general" shared package. `schemas` and `db` _feels_ like they should remain separate (mostly because they are "code-gen" packages). 2. When running `yarn dev`, any changes made to the shared package will only get picked if you `ctrl+c` and restart the instance. Would be nice if we have watch mode work across package dependencies in the monorepo.
76 lines
1.8 KiB
TypeScript
76 lines
1.8 KiB
TypeScript
import "./instrument.js";
|
|
|
|
import * as Sentry from "@sentry/node";
|
|
import { existsSync } from 'fs';
|
|
import { mkdir } from 'fs/promises';
|
|
import path from 'path';
|
|
import { AppContext } from "./types.js";
|
|
import { main } from "./main.js"
|
|
import { PrismaClient } from "@sourcebot/db";
|
|
import { env } from "./env.js";
|
|
import { createLogger } from "@sourcebot/logger";
|
|
|
|
const logger = createLogger('backend-entrypoint');
|
|
|
|
|
|
// Register handler for normal exit
|
|
process.on('exit', (code) => {
|
|
logger.info(`Process is exiting with code: ${code}`);
|
|
});
|
|
|
|
// Register handlers for abnormal terminations
|
|
process.on('SIGINT', () => {
|
|
logger.info('Process interrupted (SIGINT)');
|
|
process.exit(0);
|
|
});
|
|
|
|
process.on('SIGTERM', () => {
|
|
logger.info('Process terminated (SIGTERM)');
|
|
process.exit(0);
|
|
});
|
|
|
|
// Register handlers for uncaught exceptions and unhandled rejections
|
|
process.on('uncaughtException', (err) => {
|
|
logger.error(`Uncaught exception: ${err.message}`);
|
|
process.exit(1);
|
|
});
|
|
|
|
process.on('unhandledRejection', (reason, promise) => {
|
|
logger.error(`Unhandled rejection at: ${promise}, reason: ${reason}`);
|
|
process.exit(1);
|
|
});
|
|
|
|
const cacheDir = env.DATA_CACHE_DIR;
|
|
const reposPath = path.join(cacheDir, 'repos');
|
|
const indexPath = path.join(cacheDir, 'index');
|
|
|
|
if (!existsSync(reposPath)) {
|
|
await mkdir(reposPath, { recursive: true });
|
|
}
|
|
if (!existsSync(indexPath)) {
|
|
await mkdir(indexPath, { recursive: true });
|
|
}
|
|
|
|
const context: AppContext = {
|
|
indexPath,
|
|
reposPath,
|
|
cachePath: cacheDir,
|
|
}
|
|
|
|
const prisma = new PrismaClient();
|
|
|
|
main(prisma, context)
|
|
.then(async () => {
|
|
await prisma.$disconnect();
|
|
})
|
|
.catch(async (e) => {
|
|
logger.error(e);
|
|
Sentry.captureException(e);
|
|
|
|
await prisma.$disconnect();
|
|
process.exit(1);
|
|
})
|
|
.finally(() => {
|
|
logger.info("Shutting down...");
|
|
});
|
|
|