88 lines
2.8 KiB
TypeScript
88 lines
2.8 KiB
TypeScript
import api from './app';
|
|
import actions from '../../actions/src';
|
|
|
|
api.resourcer.use(async (ctx: actions.Context, next) => {
|
|
const { actionName, resourceField, resourceName, fields = {} } = ctx.action.params;
|
|
const table = ctx.db.getTable(resourceField ? resourceField.options.target : resourceName);
|
|
// ctx.state.developerMode = {[Op.not]: null};
|
|
ctx.state.developerMode = false;
|
|
if (table && table.hasField('developerMode') && ctx.state.developerMode === false) {
|
|
ctx.action.mergeParams({ filter: { "developerMode.$isFalsy": true } }, { filter: 'and' });
|
|
}
|
|
if (table && ['get', 'list'].includes(actionName)) {
|
|
const except = [];
|
|
const appends = [];
|
|
for (const [name, field] of table.getFields()) {
|
|
if (field.options.hidden) {
|
|
except.push(field.options.name);
|
|
}
|
|
// if (field.options.appends) {
|
|
// appends.push(field.options.name);
|
|
// }
|
|
}
|
|
ctx.action.mergeParams({ fields: {
|
|
except,
|
|
appends
|
|
} }, { fields: 'append' });
|
|
// console.log('ctx.action.params.fields', ctx.action.params.fields, except, appends);
|
|
}
|
|
await next();
|
|
});
|
|
|
|
// api.resourcer.use(async (ctx: actions.Context, next) => {
|
|
// const { resourceField, resourceName, viewName, filter } = ctx.action.params;
|
|
// // TODO: 需要补充默认视图的情况
|
|
// let view: any;
|
|
// if (viewName) {
|
|
// view = await ctx.db.getModel('views').findOne({
|
|
// where: {
|
|
// collection_name: resourceField ? resourceField.options.target : resourceName,
|
|
// name: viewName,
|
|
// }
|
|
// });
|
|
// const viewFilter = view.get('filter');
|
|
// if (viewFilter) {
|
|
// const args = [viewFilter, filter].filter(Boolean);
|
|
// ctx.action.setParam('filter', {and: args});
|
|
// console.log(ctx.action.params.filter);
|
|
// }
|
|
// }
|
|
// await next();
|
|
// });
|
|
|
|
(async () => {
|
|
await api.loadPlugins();
|
|
|
|
api.database.getModel('users').addHook('beforeUpdate', function (model) {
|
|
console.log('users.beforeUpdate', model.get(), model.changed('password' as any));
|
|
});
|
|
|
|
api.resourcer.use(async (ctx, next) => {
|
|
if (process.env.NOCOBASE_ENV !== 'demo') {
|
|
return next();
|
|
}
|
|
const currentUser = ctx.state.currentUser;
|
|
if (currentUser && currentUser.username === 'admin') {
|
|
return next();
|
|
}
|
|
const { actionName } = ctx.action.params;
|
|
if (['create', 'update', 'destroy', 'sort', 'upload'].includes(actionName)) {
|
|
ctx.body = {
|
|
data: {},
|
|
meta: {},
|
|
};
|
|
return;
|
|
}
|
|
await next();
|
|
});
|
|
|
|
await api.database.getModel('collections').load({skipExisting: true});
|
|
await api.database.getModel('collections').load({where: {
|
|
name: 'users',
|
|
}});
|
|
await api.database.getModel('automations').load();
|
|
api.listen(process.env.API_PORT, () => {
|
|
console.log(`http://localhost:${process.env.API_PORT}/`);
|
|
});
|
|
})();
|