451aed8983
* feat(db): add support for multiple users and organizations * feat: backfill entities with new organization id * refactor: filter all backend queries to surface only organization specific entities * refactor: each org has its own restic password * test: ensure organization is created * chore: pr feedbacks * refactor: filter by org id in all places * refactor: download restic password from stored db password * refactor(navigation): use volume id in urls instead of name * feat: disable registrations * refactor(auth): bubble up auth error to hono * refactor: use async local storage for cleaner context sharing * refactor: enable user registration vs disabling it * test: multi-org isolation * chore: final cleanup
29 lines
1,011 B
TypeScript
29 lines
1,011 B
TypeScript
import { Job } from "../core/scheduler";
|
|
import { repositoriesService } from "../modules/repositories/repositories.service";
|
|
import { logger } from "../utils/logger";
|
|
import { db } from "../db/db";
|
|
import { eq, or } from "drizzle-orm";
|
|
import { repositoriesTable } from "../db/schema";
|
|
import { withContext } from "../core/request-context";
|
|
|
|
export class RepositoryHealthCheckJob extends Job {
|
|
async run() {
|
|
logger.debug("Running health check for all repositories...");
|
|
|
|
const repositories = await db.query.repositoriesTable.findMany({
|
|
where: or(eq(repositoriesTable.status, "healthy"), eq(repositoriesTable.status, "error")),
|
|
});
|
|
|
|
for (const repository of repositories) {
|
|
try {
|
|
await withContext({ organizationId: repository.organizationId }, async () => {
|
|
await repositoriesService.checkHealth(repository.id);
|
|
});
|
|
} catch (error) {
|
|
logger.error(`Health check failed for repository ${repository.name}:`, error);
|
|
}
|
|
}
|
|
|
|
return { done: true, timestamp: new Date() };
|
|
}
|
|
}
|