-
Notifications
You must be signed in to change notification settings - Fork 12
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #1895 from Inist-CNRS/add-app-file
split app and index
- Loading branch information
Showing
3 changed files
with
182 additions
and
181 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,177 @@ | ||
| import Koa from 'koa'; | ||
| import { activateBullDashboard, timeout } from '../../config.json'; | ||
| import mount from 'koa-mount'; | ||
| import route from 'koa-route'; | ||
| import cors from 'kcors'; | ||
| import koaQs from 'koa-qs'; | ||
| import { KoaAdapter } from '@bull-board/koa'; | ||
| import ezs from '@ezs/core'; | ||
|
|
||
| import controller from './controller'; | ||
| import testController from './controller/testController'; | ||
| import indexSearchableFields from './services/indexSearchableFields'; | ||
|
|
||
| import { createWorkerQueue, workerQueues } from './workers'; | ||
|
|
||
| import progress from './services/progress'; | ||
| import Meter from '@uswitch/koa-prometheus'; | ||
| import MeterConfig from '@uswitch/koa-prometheus/build/koa-prometheus.defaults.json'; | ||
| import tracer, { eventTrace, eventError } from '@uswitch/koa-tracer'; | ||
| import access, { eventAccess } from '@uswitch/koa-access'; | ||
| import getLogger from './services/logger'; | ||
| import tenant from './models/tenant'; | ||
| import mongoClient from './services/mongoClient'; | ||
| import bullBoard from './bullBoard'; | ||
| import { DEFAULT_TENANT } from '../common/tools/tenantTools'; | ||
| import { insertConfigTenant } from './services/configTenant'; | ||
|
|
||
| // set timeout as ezs server (see workers/index.js) | ||
| ezs.settings.feed.timeout = Number(timeout) || 120000; | ||
|
|
||
| // KoaQs use qs to parse query string. There is an default limit of 20 items in an array. Above this limit, qs will transform the array into an key/value object. | ||
| // We need to increase this limit to 1000 to be able to handle the facets array in the query string. | ||
| // https://github.com/ljharb/qs#parsing-arrays | ||
| const app = koaQs(new Koa(), 'extended', { arrayLimit: 1000 }); | ||
|
|
||
| app.use(cors({ credentials: true })); | ||
|
|
||
| function extractTenantFromUrl(url) { | ||
| const match = url.match(/\/instance\/([^/]+)/); | ||
| return match ? match[1].toLowerCase() : null; | ||
| } | ||
|
|
||
| const setTenant = async (ctx, next) => { | ||
| if (extractTenantFromUrl(ctx.request.url)) { | ||
| ctx.tenant = extractTenantFromUrl(ctx.request.url); | ||
| } else if (ctx.get('X-Lodex-Tenant')) { | ||
| ctx.tenant = ctx.get('X-Lodex-Tenant'); | ||
| } else { | ||
| ctx.tenant = DEFAULT_TENANT; | ||
| } | ||
|
|
||
| progress.initialize(ctx.tenant); | ||
| await next(); | ||
| }; | ||
|
|
||
| app.use(setTenant); | ||
|
|
||
| // ############################ | ||
| // # START QUEUE AND BULL BOARD | ||
| // ############################ | ||
|
|
||
| // Create an bull board instance | ||
| const serverAdapter = new KoaAdapter(); | ||
| serverAdapter.setBasePath('/bull'); | ||
| const initQueueAndBullDashboard = async () => { | ||
| bullBoard.initBullBoard(serverAdapter); | ||
| // Get current tenants | ||
| const adminDb = await mongoClient('admin'); | ||
| const tenantCollection = await tenant(adminDb); | ||
|
|
||
| const tenants = await tenantCollection.findAll(); | ||
| tenants.forEach(tenant => { | ||
| const queue = createWorkerQueue(tenant.name, 1); | ||
| bullBoard.addDashboardQueue(tenant.name, queue); | ||
| }); | ||
| // if tenant `default` is not in the database, we add it | ||
| if (!tenants.find(tenant => tenant.name === DEFAULT_TENANT)) { | ||
| await tenantCollection.create({ | ||
| name: DEFAULT_TENANT, | ||
| description: 'Instance par défaut', | ||
| author: 'Root', | ||
| username: 'admin', | ||
| password: 'secret', | ||
| createdAt: new Date(), | ||
| }); | ||
| const defaultQueue = createWorkerQueue(DEFAULT_TENANT, 1); | ||
| bullBoard.addDashboardQueue(DEFAULT_TENANT, defaultQueue); | ||
| } | ||
| insertConfigTenant(DEFAULT_TENANT); | ||
| }; | ||
|
|
||
| initQueueAndBullDashboard(); | ||
|
|
||
| // Display It only in development mode or if activateBullDashboard is true | ||
| if (process.env.NODE_ENV === 'development' || activateBullDashboard) { | ||
| app.use(serverAdapter.registerPlugin()); | ||
| } | ||
|
|
||
| // ############################ | ||
| // # END QUEUE AND BULL BOARD | ||
| // ############################ | ||
|
|
||
| if (process.env.EXPOSE_TEST_CONTROLLER) { | ||
| app.use(mount('/tests', testController)); | ||
| } | ||
|
|
||
| // worker job | ||
| app.use(async (ctx, next) => { | ||
| try { | ||
| const activeJobs = | ||
| (await workerQueues[ctx.tenant]?.getActive()) || null; | ||
|
|
||
| if (!activeJobs) { | ||
| return await next(); | ||
| } | ||
|
|
||
| const filteredActiveJobs = activeJobs.filter( | ||
| job => job.data.tenant === ctx.tenant, | ||
| ); | ||
| ctx.job = filteredActiveJobs[0]; | ||
| } catch (e) { | ||
| const logger = getLogger(ctx.tenant); | ||
| logger.error(`An error occured on loading running job`, e); | ||
| } | ||
| await next(); | ||
| }); | ||
|
|
||
| // server logs | ||
| app.use(async (ctx, next) => { | ||
| ctx.httpLog = { | ||
| method: ctx.request.method, | ||
| remoteIP: ctx.request.ip, | ||
| userAgent: ctx.request.headers['user-agent'], | ||
| }; | ||
| const authorization = ctx.get('authorization'); | ||
| if (authorization) { | ||
| ctx.httpLog.authorization = authorization; | ||
| } | ||
| await next(); | ||
| ctx.httpLog.status = ctx.status; | ||
| const logger = getLogger(ctx.tenant); | ||
| logger.info(ctx.request.url, ctx.httpLog); | ||
| }); | ||
|
|
||
| // Prometheus metrics | ||
| const meters = Meter(MeterConfig, { loadStandards: true, loadDefaults: true }); | ||
| app.use(meters.middleware); // The middleware that makes the meters available | ||
| app.use(route.get('/metrics', ctx => (ctx.body = meters.print()))); | ||
|
|
||
| app.use(tracer()); | ||
| app.use(access()); | ||
| app.on(eventAccess, ctx => { | ||
| meters.automark(ctx); | ||
| }); | ||
| app.on(eventTrace, ctx => meters.automark(ctx)); | ||
| app.on(eventError, () => meters.errorRate.mark(1)); | ||
|
|
||
| app.use(function*(next) { | ||
| try { | ||
| yield next; | ||
| } catch (err) { | ||
| this.status = err.status || 500; | ||
| this.body = err.message; | ||
| this.app.emit('error', err, this); | ||
| } | ||
| }); | ||
|
|
||
| app.use(mount('/', controller)); | ||
|
|
||
| app.use(async (ctx, next) => { | ||
| if (!module.parent) { | ||
| indexSearchableFields(ctx); | ||
| } | ||
| await next(); | ||
| }); | ||
|
|
||
| export default app; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters