130 lines
3.5 KiB
TypeScript
130 lines
3.5 KiB
TypeScript
import Api from '../../../server/src';
|
|
import dotenv from 'dotenv';
|
|
import path from 'path';
|
|
import actions from '../../../actions/src';
|
|
import associated from '../../../actions/src/middlewares/associated';
|
|
import { Op } from 'sequelize';
|
|
|
|
const sync = {
|
|
force: true,
|
|
alter: {
|
|
drop: true,
|
|
},
|
|
};
|
|
|
|
console.log('process.env.NOCOBASE_ENV', process.env.NOCOBASE_ENV);
|
|
|
|
dotenv.config();
|
|
|
|
const api = Api.create({
|
|
database: {
|
|
username: process.env.DB_USER,
|
|
password: process.env.DB_PASSWORD,
|
|
database: process.env.DB_DATABASE,
|
|
host: process.env.DB_HOST,
|
|
port: process.env.DB_PORT,
|
|
dialect: process.env.DB_DIALECT,
|
|
dialectOptions: {
|
|
charset: 'utf8mb4',
|
|
collate: 'utf8mb4_unicode_ci',
|
|
},
|
|
logging: false,
|
|
define: {},
|
|
sync,
|
|
},
|
|
resourcer: {
|
|
prefix: '/api',
|
|
},
|
|
});
|
|
|
|
api.resourcer.use(async (ctx: actions.Context, next) => {
|
|
const token = ctx.get('Authorization').replace(/^Bearer\s+/gi, '');
|
|
// console.log('user check', ctx.action.params.actionName);
|
|
// const { actionName } = ctx.action.params;
|
|
if (!token) {
|
|
return next();
|
|
}
|
|
const User = ctx.db.getModel('users');
|
|
const user = await User.findOne({
|
|
where: {
|
|
token,
|
|
},
|
|
});
|
|
if (!user) {
|
|
return next();
|
|
}
|
|
ctx.state.currentUser = user;
|
|
// console.log('ctx.state.currentUser', ctx.state.currentUser);
|
|
await next();
|
|
});
|
|
|
|
api.resourcer.use(async (ctx: actions.Context, next) => {
|
|
const { resourceName } = ctx.action.params;
|
|
const table = ctx.db.getTable(resourceName);
|
|
// ctx.state.developerMode = {[Op.not]: null};
|
|
ctx.state.developerMode = false;
|
|
if (table && table.hasField('developerMode') && ctx.state.developerMode === false) {
|
|
ctx.action.setParam('filter.developerMode', ctx.state.developerMode);
|
|
}
|
|
if (table) {
|
|
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);
|
|
}
|
|
}
|
|
if (except.length) {
|
|
ctx.action.setParam('fields.except', except);
|
|
}
|
|
if (appends.length) {
|
|
ctx.action.setParam('fields.appends', appends);
|
|
}
|
|
console.log(ctx.action.params.fields);
|
|
}
|
|
await next();
|
|
});
|
|
|
|
api.resourcer.use(async (ctx: actions.Context, next) => {
|
|
const { resourceName, viewName, filter } = ctx.action.params;
|
|
// TODO: 需要补充默认视图的情况
|
|
let view: any;
|
|
if (viewName) {
|
|
view = await ctx.db.getModel('views').findOne({
|
|
where: {
|
|
collection_name: 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();
|
|
});
|
|
api.resourcer.use(associated);
|
|
api.resourcer.registerActionHandlers({...actions.common, ...actions.associate});
|
|
|
|
(async () => {
|
|
await api
|
|
.plugins([
|
|
[path.resolve(__dirname, '../../../plugin-collections'), {}],
|
|
[path.resolve(__dirname, '../../../plugin-pages'), {}],
|
|
[path.resolve(__dirname, '../../../plugin-users'), {}],
|
|
// [path.resolve(__dirname, '../../../plugin-permissions'), {}],
|
|
// [path.resolve(__dirname, '../../../plugin-file-manager'), {}],
|
|
]);
|
|
|
|
// await api.database.getModel('collections').load();
|
|
|
|
api.listen(process.env.HTTP_PORT, () => {
|
|
console.log(`http://localhost:${process.env.HTTP_PORT}/`);
|
|
});
|
|
})();
|