Browse Source

refactor(nocodb): use extractProps for insertObj

pull/5168/head
Wing-Kam Wong 2 years ago
parent
commit
353cc8ea60
  1. 38
      packages/nocodb/src/lib/models/Audit.ts
  2. 15
      packages/nocodb/src/lib/models/BarcodeColumn.ts
  3. 77
      packages/nocodb/src/lib/models/Column.ts
  4. 43
      packages/nocodb/src/lib/models/Filter.ts
  5. 34
      packages/nocodb/src/lib/models/FormView.ts
  6. 43
      packages/nocodb/src/lib/models/FormViewColumn.ts
  7. 17
      packages/nocodb/src/lib/models/FormulaColumn.ts
  8. 32
      packages/nocodb/src/lib/models/GalleryView.ts
  9. 23
      packages/nocodb/src/lib/models/GalleryViewColumn.ts
  10. 17
      packages/nocodb/src/lib/models/GridView.ts
  11. 25
      packages/nocodb/src/lib/models/GridViewColumn.ts
  12. 64
      packages/nocodb/src/lib/models/Hook.ts
  13. 25
      packages/nocodb/src/lib/models/HookFilter.ts
  14. 21
      packages/nocodb/src/lib/models/KanbanView.ts
  15. 23
      packages/nocodb/src/lib/models/KanbanViewColumn.ts
  16. 38
      packages/nocodb/src/lib/models/LinkToAnotherRecordColumn.ts
  17. 14
      packages/nocodb/src/lib/models/LookupColumn.ts
  18. 45
      packages/nocodb/src/lib/models/Model.ts
  19. 21
      packages/nocodb/src/lib/models/ModelRoleVisibility.ts
  20. 24
      packages/nocodb/src/lib/models/Project.ts
  21. 17
      packages/nocodb/src/lib/models/ProjectUser.ts
  22. 14
      packages/nocodb/src/lib/models/QrCodeColumn.ts
  23. 14
      packages/nocodb/src/lib/models/RollupColumn.ts
  24. 15
      packages/nocodb/src/lib/models/SelectOption.ts
  25. 24
      packages/nocodb/src/lib/models/Sort.ts
  26. 15
      packages/nocodb/src/lib/models/SyncLogs.ts
  27. 18
      packages/nocodb/src/lib/models/SyncSource.ts
  28. 34
      packages/nocodb/src/lib/models/View.ts

38
packages/nocodb/src/lib/models/Audit.ts

@ -2,6 +2,7 @@ import { AuditOperationTypes, AuditType } from 'nocodb-sdk';
import { MetaTable } from '../utils/globals'; import { MetaTable } from '../utils/globals';
import Noco from '../Noco'; import Noco from '../Noco';
import Model from './Model'; import Model from './Model';
import { extractProps } from '../meta/helpers/extractProps';
export default class Audit implements AuditType { export default class Audit implements AuditType {
id?: string; id?: string;
@ -48,27 +49,28 @@ export default class Audit implements AuditType {
return; return;
} }
const insertAudit = async () => { const insertAudit = async () => {
if (!audit.project_id && audit.fk_model_id) { const insertObj = extractProps(audit, [
audit.project_id = ( 'user',
await Model.getByIdOrName({ id: audit.fk_model_id }, ncMeta) 'ip',
'base_id',
'project_id',
'row_id',
'fk_model_id',
'op_type',
'op_sub_type',
'status',
'description',
'details',
'created_at',
'updated_at',
]);
if (!insertObj.project_id && insertObj.fk_model_id) {
insertObj.project_id = (
await Model.getByIdOrName({ id: insertObj.fk_model_id }, ncMeta)
).project_id; ).project_id;
} }
return await ncMeta.metaInsert2(null, null, MetaTable.AUDIT, { return await ncMeta.metaInsert2(null, null, MetaTable.AUDIT, insertObj);
user: audit.user,
ip: audit.ip,
base_id: audit.base_id,
project_id: audit.project_id,
row_id: audit.row_id,
fk_model_id: audit.fk_model_id,
op_type: audit.op_type,
op_sub_type: audit.op_sub_type,
status: audit.status,
description: audit.description,
details: audit.details,
created_at: audit.created_at,
updated_at: audit.updated_at,
});
}; };
if (forceAwait) { if (forceAwait) {

15
packages/nocodb/src/lib/models/BarcodeColumn.ts

@ -14,16 +14,17 @@ export default class BarcodeColumn {
} }
public static async insert( public static async insert(
data: Partial<BarcodeColumn>, barcodeColumn: Partial<BarcodeColumn>,
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
await ncMeta.metaInsert2(null, null, MetaTable.COL_BARCODE, { const insertObj = extractProps(barcodeColumn, [
fk_column_id: data.fk_column_id, 'fk_column_id',
fk_barcode_value_column_id: data.fk_barcode_value_column_id, 'fk_barcode_value_column_id',
barcode_format: data.barcode_format, 'barcode_format',
}); ]);
await ncMeta.metaInsert2(null, null, MetaTable.COL_BARCODE, insertObj);
return this.read(data.fk_column_id, ncMeta); return this.read(barcodeColumn.fk_column_id, ncMeta);
} }
public static async read(columnId: string, ncMeta = Noco.ncMeta) { public static async read(columnId: string, ncMeta = Noco.ncMeta) {
let column = let column =

77
packages/nocodb/src/lib/models/Column.ts

@ -86,41 +86,50 @@ export default class Column<T = any> implements ColumnType {
) { ) {
if (!column.fk_model_id) NcError.badRequest('Missing model id'); if (!column.fk_model_id) NcError.badRequest('Missing model id');
const insertObj: any = { // TODO: fix type
id: column?.id, const insertObj = extractProps(column as any, [
fk_model_id: column.fk_model_id, 'id',
column_name: column.column_name || column.cn, 'fk_model_id',
title: column.title || column._cn, 'column_name',
uidt: column.uidt, 'title',
dt: column.dt, 'uidt',
np: column.np, 'dt',
ns: column.ns, 'np',
clen: column.clen, 'ns',
cop: column.cop, 'clen',
pk: column.pk, 'cop',
rqd: column.rqd, 'pk',
un: column.un, 'rqd',
ct: column.ct, 'un',
ai: column.ai, 'ct',
unique: column.unique, 'ai',
cdf: column.cdf, 'unique',
cc: column.cc, 'cdf',
csn: column.csn, 'cc',
dtx: column.dtx, 'csn',
dtxp: column.dtxp, 'dtx',
dtxs: column.dtxs, 'dtxp',
au: column.au, 'dtxs',
pv: column.pv, 'au',
order: column.order, 'pv',
project_id: column.project_id, 'order',
base_id: column.base_id, 'project_id',
system: column.system, 'base_id',
meta: 'system',
column.meta && typeof column.meta === 'object' 'meta',
? JSON.stringify(column.meta) ]);
: column.meta,
}; if (!insertObj.column_name) {
insertObj.column_name = column.cn;
}
if (!insertObj.title) {
insertObj.title = column._cn;
}
if (insertObj.meta && typeof insertObj.meta === 'object') {
insertObj.meta = JSON.stringify(insertObj.meta);
}
if (column.validate) { if (column.validate) {
if (typeof column.validate === 'string') if (typeof column.validate === 'string')
insertObj.validate = column.validate; insertObj.validate = column.validate;

43
packages/nocodb/src/lib/models/Filter.ts

@ -77,29 +77,30 @@ export default class Filter {
} }
public static async insert( public static async insert(
filter: Partial<FilterType>, filter: Partial<FilterType> & { order?: number },
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
const insertObj = { const insertObj = extractProps(filter, [
id: filter.id, 'id',
fk_view_id: filter.fk_view_id, 'fk_view_id',
fk_hook_id: filter.fk_hook_id, 'fk_hook_id',
fk_column_id: filter.fk_column_id, 'fk_column_id',
comparison_op: filter.comparison_op, 'comparison_op',
value: filter.value, 'value',
fk_parent_id: filter.fk_parent_id, 'fk_parent_id',
'is_group',
is_group: filter.is_group, 'logical_op',
logical_op: filter.logical_op, 'project_id',
'base_id',
project_id: filter.project_id, 'order',
base_id: filter.base_id, ]);
order: await ncMeta.metaGetNextOrder(MetaTable.FILTER_EXP, {
[filter.fk_hook_id ? 'fk_hook_id' : 'fk_view_id']: filter.fk_hook_id insertObj.order = await ncMeta.metaGetNextOrder(MetaTable.FILTER_EXP, {
? filter.fk_hook_id [filter.fk_hook_id ? 'fk_hook_id' : 'fk_view_id']: filter.fk_hook_id
: filter.fk_view_id, ? filter.fk_hook_id
}), : filter.fk_view_id,
}; });
if (!(filter.project_id && filter.base_id)) { if (!(filter.project_id && filter.base_id)) {
let model: { project_id?: string; base_id?: string }; let model: { project_id?: string; base_id?: string };
if (filter.fk_view_id) { if (filter.fk_view_id) {

34
packages/nocodb/src/lib/models/FormView.ts

@ -54,22 +54,24 @@ export default class FormView implements FormType {
} }
static async insert(view: Partial<FormView>, ncMeta = Noco.ncMeta) { static async insert(view: Partial<FormView>, ncMeta = Noco.ncMeta) {
const insertObj = { const insertObj = extractProps(view, [
fk_view_id: view.fk_view_id, 'fk_view_id',
project_id: view.project_id, 'project_id',
base_id: view.base_id, 'base_id',
heading: view.heading, 'heading',
subheading: view.subheading, 'subheading',
success_msg: view.success_msg, 'success_msg',
redirect_url: view.redirect_url, 'redirect_url',
redirect_after_secs: view.redirect_after_secs, 'redirect_after_secs',
email: view.email, 'email',
banner_image_url: view.banner_image_url, 'banner_image_url',
logo_url: view.logo_url, 'logo_url',
submit_another_form: view.submit_another_form, 'submit_another_form',
show_blank_form: view.show_blank_form, 'show_blank_form',
meta: serializeJSON(view.meta), ]);
}; if (insertObj.meta) {
insertObj.meta = serializeJSON(insertObj.meta);
}
if (!(view.project_id && view.base_id)) { if (!(view.project_id && view.base_id)) {
const viewRef = await View.get(view.fk_view_id); const viewRef = await View.get(view.fk_view_id);
insertObj.project_id = viewRef.project_id; insertObj.project_id = viewRef.project_id;

43
packages/nocodb/src/lib/models/FormViewColumn.ts

@ -55,27 +55,32 @@ export default class FormViewColumn implements FormColumnType {
} }
static async insert(column: Partial<FormViewColumn>, ncMeta = Noco.ncMeta) { static async insert(column: Partial<FormViewColumn>, ncMeta = Noco.ncMeta) {
const insertObj: Partial<FormViewColumn> = { const insertObj = extractProps(column, [
fk_view_id: column.fk_view_id, 'fk_view_id',
fk_column_id: column.fk_column_id, 'fk_column_id',
order: await ncMeta.metaGetNextOrder(MetaTable.FORM_VIEW_COLUMNS, { 'show',
fk_view_id: column.fk_view_id, 'project_id',
}), 'base_id',
show: column.show, 'label',
project_id: column.project_id, 'help',
base_id: column.base_id, 'description',
label: column.label, 'required',
help: column.help, 'meta',
description: column.description, ]);
required: column.required,
}; insertObj.order = await ncMeta.metaGetNextOrder(
MetaTable.FORM_VIEW_COLUMNS,
if (column.meta) { {
insertObj.meta = serializeJSON(column.meta); fk_view_id: insertObj.fk_view_id,
}
);
if (insertObj.meta) {
insertObj.meta = serializeJSON(insertObj.meta);
} }
if (!(column.project_id && column.base_id)) { if (!(insertObj.project_id && insertObj.base_id)) {
const viewRef = await View.get(column.fk_view_id, ncMeta); const viewRef = await View.get(insertObj.fk_view_id, ncMeta);
insertObj.project_id = viewRef.project_id; insertObj.project_id = viewRef.project_id;
insertObj.base_id = viewRef.base_id; insertObj.base_id = viewRef.base_id;
} }

17
packages/nocodb/src/lib/models/FormulaColumn.ts

@ -14,17 +14,18 @@ export default class FormulaColumn {
} }
public static async insert( public static async insert(
data: Partial<FormulaColumn>, formulaColumn: Partial<FormulaColumn>,
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
await ncMeta.metaInsert2(null, null, MetaTable.COL_FORMULA, { const insertObj = extractProps(formulaColumn, [
fk_column_id: data.fk_column_id, 'fk_column_id',
formula_raw: data.formula_raw, 'formula_raw',
formula: data.formula, 'formula',
error: data.error, 'error',
}); ]);
await ncMeta.metaInsert2(null, null, MetaTable.COL_FORMULA, insertObj);
return this.read(data.fk_column_id, ncMeta); return this.read(formulaColumn.fk_column_id, ncMeta);
} }
public static async read(columnId: string, ncMeta = Noco.ncMeta) { public static async read(columnId: string, ncMeta = Noco.ncMeta) {
let column = let column =

32
packages/nocodb/src/lib/models/GalleryView.ts

@ -52,21 +52,23 @@ export default class GalleryView implements GalleryType {
.then((v) => v?.getModel(ncMeta)) .then((v) => v?.getModel(ncMeta))
.then((m) => m.getColumns(ncMeta)); .then((m) => m.getColumns(ncMeta));
const insertObj = { const insertObj = extractProps(view, [
project_id: view.project_id, 'project_id',
base_id: view.base_id, 'base_id',
fk_view_id: view.fk_view_id, 'fk_view_id',
fk_cover_image_col_id: 'next_enabled',
view?.fk_cover_image_col_id || 'prev_enabled',
columns?.find((c) => c.uidt === UITypes.Attachment)?.id, 'cover_image_idx',
next_enabled: view.next_enabled, 'cover_image',
prev_enabled: view.prev_enabled, 'restrict_types',
cover_image_idx: view.cover_image_idx, 'restrict_size',
cover_image: view.cover_image, 'restrict_number',
restrict_types: view.restrict_types, ]);
restrict_size: view.restrict_size,
restrict_number: view.restrict_number, insertObj.fk_cover_image_col_id =
}; view?.fk_cover_image_col_id ||
columns?.find((c) => c.uidt === UITypes.Attachment)?.id;
if (!(view.project_id && view.base_id)) { if (!(view.project_id && view.base_id)) {
const viewRef = await View.get(view.fk_view_id); const viewRef = await View.get(view.fk_view_id);
insertObj.project_id = viewRef.project_id; insertObj.project_id = viewRef.project_id;

23
packages/nocodb/src/lib/models/GalleryViewColumn.ts

@ -2,6 +2,7 @@ import Noco from '../Noco';
import { CacheGetType, CacheScope, MetaTable } from '../utils/globals'; import { CacheGetType, CacheScope, MetaTable } from '../utils/globals';
import View from './View'; import View from './View';
import NocoCache from '../cache/NocoCache'; import NocoCache from '../cache/NocoCache';
import { extractProps } from '../meta/helpers/extractProps';
export default class GalleryViewColumn { export default class GalleryViewColumn {
id: string; id: string;
@ -43,16 +44,20 @@ export default class GalleryViewColumn {
column: Partial<GalleryViewColumn>, column: Partial<GalleryViewColumn>,
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
const insertObj = { const insertObj = extractProps(column, [
fk_view_id: column.fk_view_id, 'fk_view_id',
fk_column_id: column.fk_column_id, 'fk_column_id',
order: await ncMeta.metaGetNextOrder(MetaTable.GALLERY_VIEW_COLUMNS, { 'show',
'project_id',
'base_id',
]);
insertObj.order = await ncMeta.metaGetNextOrder(
MetaTable.GALLERY_VIEW_COLUMNS,
{
fk_view_id: column.fk_view_id, fk_view_id: column.fk_view_id,
}), }
show: column.show, );
project_id: column.project_id,
base_id: column.base_id,
};
if (!(column.project_id && column.base_id)) { if (!(column.project_id && column.base_id)) {
const viewRef = await View.get(column.fk_view_id, ncMeta); const viewRef = await View.get(column.fk_view_id, ncMeta);

17
packages/nocodb/src/lib/models/GridView.ts

@ -41,14 +41,15 @@ export default class GridView {
} }
static async insert(view: Partial<GridView>, ncMeta = Noco.ncMeta) { static async insert(view: Partial<GridView>, ncMeta = Noco.ncMeta) {
const insertObj = { const insertObj = extractProps(view, [
fk_view_id: view.fk_view_id, 'fk_view_id',
project_id: view.project_id, 'project_id',
base_id: view.base_id, 'base_id',
row_height: view.row_height, 'row_height',
}; ]);
if (!(view.project_id && view.base_id)) {
const viewRef = await View.get(view.fk_view_id, ncMeta); if (!(insertObj.project_id && insertObj.base_id)) {
const viewRef = await View.get(insertObj.fk_view_id, ncMeta);
insertObj.project_id = viewRef.project_id; insertObj.project_id = viewRef.project_id;
insertObj.base_id = viewRef.base_id; insertObj.base_id = viewRef.base_id;
} }

25
packages/nocodb/src/lib/models/GridViewColumn.ts

@ -67,18 +67,19 @@ export default class GridViewColumn implements GridColumnType {
} }
static async insert(column: Partial<GridViewColumn>, ncMeta = Noco.ncMeta) { static async insert(column: Partial<GridViewColumn>, ncMeta = Noco.ncMeta) {
const insertObj = { const insertObj = extractProps(column, [
fk_view_id: column.fk_view_id, 'fk_view_id',
fk_column_id: column.fk_column_id, 'fk_column_id',
order: 'show',
column?.order ?? 'project_id',
(await ncMeta.metaGetNextOrder(MetaTable.GRID_VIEW_COLUMNS, { 'base_id',
fk_view_id: column.fk_view_id, ]);
})),
show: column.show, insertObj.order =
project_id: column.project_id, column?.order ??
base_id: column.base_id, (await ncMeta.metaGetNextOrder(MetaTable.GRID_VIEW_COLUMNS, {
}; fk_view_id: column.fk_view_id,
}));
if (!(column.project_id && column.base_id)) { if (!(column.project_id && column.base_id)) {
const viewRef = await View.get(column.fk_view_id, ncMeta); const viewRef = await View.get(column.fk_view_id, ncMeta);

64
packages/nocodb/src/lib/models/Hook.ts

@ -122,32 +122,44 @@ export default class Hook implements HookType {
>, >,
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
const insertObj = { const insertObj = extractProps(hook, [
fk_model_id: hook.fk_model_id, 'fk_model_id',
title: hook.title, 'title',
description: hook.description, 'description',
env: hook.env, 'env',
type: hook.type, 'type',
event: hook.event?.toLowerCase?.(), 'event',
operation: hook.operation?.toLowerCase?.(), 'operation',
async: hook.async, 'async',
payload: !!hook.payload, 'url',
url: hook.url, 'headers',
headers: hook.headers, 'notification',
condition: hook.condition, 'retries',
notification: 'retry_interval',
hook.notification && typeof hook.notification === 'object' 'timeout',
? JSON.stringify(hook.notification) 'active',
: hook.notification, 'project_id',
retries: hook.retries, 'base_id',
retry_interval: hook.retry_interval, 'created_at',
timeout: hook.timeout, 'updated_at',
active: hook.active, ]);
project_id: hook.project_id,
base_id: hook.base_id, if (insertObj.event) {
created_at: hook.created_at, insertObj.event = insertObj.event.toLowerCase() as 'after' | 'before';
updated_at: hook.updated_at, }
};
if (insertObj.operation) {
insertObj.operation = insertObj.operation.toLowerCase() as
| 'insert'
| 'delete'
| 'update';
}
if (insertObj.notification) {
insertObj.notification && typeof insertObj.notification === 'object'
? JSON.stringify(insertObj.notification)
: insertObj.notification;
}
if (!(hook.project_id && hook.base_id)) { if (!(hook.project_id && hook.base_id)) {
const model = await Model.getByIdOrName({ id: hook.fk_model_id }, ncMeta); const model = await Model.getByIdOrName({ id: hook.fk_model_id }, ncMeta);

25
packages/nocodb/src/lib/models/HookFilter.ts

@ -49,20 +49,19 @@ export default class Filter {
filter: Partial<FilterType>, filter: Partial<FilterType>,
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
const insertObj = { const insertObj = extractProps(filter, [
id: filter.id, 'id',
fk_view_id: filter.fk_view_id, 'fk_view_id',
fk_column_id: filter.fk_column_id, 'fk_column_id',
comparison_op: filter.comparison_op, 'comparison_op',
value: filter.value, 'value',
fk_parent_id: filter.fk_parent_id, 'fk_parent_id',
'is_group',
is_group: filter.is_group, 'logical_op',
logical_op: filter.logical_op, 'project_id',
'base_id',
]);
project_id: filter.project_id,
base_id: filter.base_id,
};
if (!(filter.project_id && filter.base_id)) { if (!(filter.project_id && filter.base_id)) {
const model = await Column.get({ colId: filter.fk_column_id }, ncMeta); const model = await Column.get({ colId: filter.fk_column_id }, ncMeta);
insertObj.project_id = model.project_id; insertObj.project_id = model.project_id;

21
packages/nocodb/src/lib/models/KanbanView.ts

@ -64,16 +64,17 @@ export default class KanbanView implements KanbanType {
.then((v) => v?.getModel(ncMeta)) .then((v) => v?.getModel(ncMeta))
.then((m) => m.getColumns(ncMeta)); .then((m) => m.getColumns(ncMeta));
const insertObj = { const insertObj = extractProps(view, [
project_id: view.project_id, 'project_id',
base_id: view.base_id, 'base_id',
fk_view_id: view.fk_view_id, 'fk_view_id',
fk_grp_col_id: view.fk_grp_col_id, 'fk_grp_col_id',
fk_cover_image_col_id: 'meta',
view?.fk_cover_image_col_id || ]);
columns?.find((c) => c.uidt === UITypes.Attachment)?.id,
meta: view.meta, insertObj.fk_cover_image_col_id =
}; view?.fk_cover_image_col_id ||
columns?.find((c) => c.uidt === UITypes.Attachment)?.id;
if (!(view.project_id && view.base_id)) { if (!(view.project_id && view.base_id)) {
const viewRef = await View.get(view.fk_view_id); const viewRef = await View.get(view.fk_view_id);

23
packages/nocodb/src/lib/models/KanbanViewColumn.ts

@ -2,6 +2,7 @@ import Noco from '../Noco';
import { CacheGetType, CacheScope, MetaTable } from '../utils/globals'; import { CacheGetType, CacheScope, MetaTable } from '../utils/globals';
import View from './View'; import View from './View';
import NocoCache from '../cache/NocoCache'; import NocoCache from '../cache/NocoCache';
import { extractProps } from '../meta/helpers/extractProps';
export default class KanbanViewColumn { export default class KanbanViewColumn {
id: string; id: string;
@ -40,16 +41,20 @@ export default class KanbanViewColumn {
return view && new KanbanViewColumn(view); return view && new KanbanViewColumn(view);
} }
static async insert(column: Partial<KanbanViewColumn>, ncMeta = Noco.ncMeta) { static async insert(column: Partial<KanbanViewColumn>, ncMeta = Noco.ncMeta) {
const insertObj = { const insertObj = extractProps(column, [
fk_view_id: column.fk_view_id, 'fk_view_id',
fk_column_id: column.fk_column_id, 'fk_column_id',
order: await ncMeta.metaGetNextOrder(MetaTable.KANBAN_VIEW_COLUMNS, { 'show',
'project_id',
'base_id',
]);
insertObj.order = await ncMeta.metaGetNextOrder(
MetaTable.KANBAN_VIEW_COLUMNS,
{
fk_view_id: column.fk_view_id, fk_view_id: column.fk_view_id,
}), }
show: column.show, );
project_id: column.project_id,
base_id: column.base_id,
};
if (!(column.project_id && column.base_id)) { if (!(column.project_id && column.base_id)) {
const viewRef = await View.get(column.fk_view_id, ncMeta); const viewRef = await View.get(column.fk_view_id, ncMeta);

38
packages/nocodb/src/lib/models/LinkToAnotherRecordColumn.ts

@ -1,9 +1,9 @@
import Noco from '../Noco'; import Noco from '../Noco';
import Column from './Column'; import Column from './Column';
import Model from './Model'; import Model from './Model';
// import NocoCache from '../cache/NocoCache';
import { CacheGetType, CacheScope, MetaTable } from '../utils/globals'; import { CacheGetType, CacheScope, MetaTable } from '../utils/globals';
import NocoCache from '../cache/NocoCache'; import NocoCache from '../cache/NocoCache';
import { extractProps } from '../meta/helpers/extractProps';
export default class LinkToAnotherRecordColumn { export default class LinkToAnotherRecordColumn {
fk_column_id?: string; fk_column_id?: string;
@ -89,27 +89,21 @@ export default class LinkToAnotherRecordColumn {
data: Partial<LinkToAnotherRecordColumn>, data: Partial<LinkToAnotherRecordColumn>,
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
await ncMeta.metaInsert2(null, null, MetaTable.COL_RELATIONS, { const insertObj = extractProps(data, [
fk_column_id: data.fk_column_id, 'fk_column_id',
'type',
// ref_db_alias 'fk_child_column_id',
type: data.type, 'fk_parent_column_id',
// db_type: 'fk_mm_model_id',
'fk_mm_child_column_id',
fk_child_column_id: data.fk_child_column_id, 'fk_mm_parent_column_id',
fk_parent_column_id: data.fk_parent_column_id, 'ur',
'dr',
fk_mm_model_id: data.fk_mm_model_id, 'fk_index_name',
fk_mm_child_column_id: data.fk_mm_child_column_id, 'fk_related_model_id',
fk_mm_parent_column_id: data.fk_mm_parent_column_id, 'virtual',
]);
ur: data.ur, await ncMeta.metaInsert2(null, null, MetaTable.COL_RELATIONS, insertObj);
dr: data.dr,
fk_index_name: data.fk_index_name,
fk_related_model_id: data.fk_related_model_id,
virtual: data.virtual,
});
return this.read(data.fk_column_id, ncMeta); return this.read(data.fk_column_id, ncMeta);
} }

14
packages/nocodb/src/lib/models/LookupColumn.ts

@ -1,8 +1,8 @@
import Noco from '../Noco'; import Noco from '../Noco';
// import NocoCache from '../cache/NocoCache';
import Column from './Column'; import Column from './Column';
import { CacheGetType, CacheScope, MetaTable } from '../utils/globals'; import { CacheGetType, CacheScope, MetaTable } from '../utils/globals';
import NocoCache from '../cache/NocoCache'; import NocoCache from '../cache/NocoCache';
import { extractProps } from '../meta/helpers/extractProps';
export default class LookupColumn { export default class LookupColumn {
fk_relation_column_id: string; fk_relation_column_id: string;
@ -29,11 +29,13 @@ export default class LookupColumn {
data: Partial<LookupColumn>, data: Partial<LookupColumn>,
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
await ncMeta.metaInsert2(null, null, MetaTable.COL_LOOKUP, { const insertObj = extractProps(data, [
fk_column_id: data.fk_column_id, 'fk_column_id',
fk_relation_column_id: data.fk_relation_column_id, 'fk_relation_column_id',
fk_lookup_column_id: data.fk_lookup_column_id, 'fk_lookup_column_id',
}); ]);
await ncMeta.metaInsert2(null, null, MetaTable.COL_LOOKUP, insertObj);
await NocoCache.appendToList( await NocoCache.appendToList(
CacheScope.COL_LOOKUP, CacheScope.COL_LOOKUP,

45
packages/nocodb/src/lib/models/Model.ts

@ -22,6 +22,7 @@ import View from './View';
import { NcError } from '../meta/helpers/catchError'; import { NcError } from '../meta/helpers/catchError';
import Audit from './Audit'; import Audit from './Audit';
import { sanitize } from '../db/sql-data-mapper/lib/sql/helpers/sanitize'; import { sanitize } from '../db/sql-data-mapper/lib/sql/helpers/sanitize';
import { extractProps } from '../meta/helpers/extractProps';
export default class Model implements TableType { export default class Model implements TableType {
copy_enabled: boolean; copy_enabled: boolean;
@ -103,25 +104,39 @@ export default class Model implements TableType {
}, },
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
const insertObj = extractProps(model, [
'table_name',
'title',
'mm',
'order',
'created_at',
'updated_at',
'id',
]);
if (insertObj.mm) {
insertObj.mm = !!insertObj.mm;
}
if (!insertObj.order) {
insertObj.order = await ncMeta.metaGetNextOrder(
MetaTable.FORM_VIEW_COLUMNS,
{
project_id: projectId,
base_id: baseId,
}
);
}
if (!insertObj.type) {
insertObj.type = ModelTypes.TABLE;
}
const { id } = await ncMeta.metaInsert2( const { id } = await ncMeta.metaInsert2(
projectId, projectId,
baseId, baseId,
MetaTable.MODELS, MetaTable.MODELS,
{ insertObj
table_name: model.table_name,
title: model.title,
mm: !!model.mm,
order:
model.order ||
(await ncMeta.metaGetNextOrder(MetaTable.FORM_VIEW_COLUMNS, {
project_id: projectId,
base_id: baseId,
})),
type: model.type || ModelTypes.TABLE,
created_at: model.created_at,
updated_at: model.updated_at,
id: model.id,
}
); );
await NocoCache.appendToList( await NocoCache.appendToList(

21
packages/nocodb/src/lib/models/ModelRoleVisibility.ts

@ -8,6 +8,7 @@ import {
} from '../utils/globals'; } from '../utils/globals';
import NocoCache from '../cache/NocoCache'; import NocoCache from '../cache/NocoCache';
import View from './View'; import View from './View';
import { extractProps } from '../meta/helpers/extractProps';
export default class ModelRoleVisibility implements ModelRoleVisibilityType { export default class ModelRoleVisibility implements ModelRoleVisibilityType {
id?: string; id?: string;
@ -134,17 +135,17 @@ export default class ModelRoleVisibility implements ModelRoleVisibilityType {
>, >,
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
const insertObj = { const insertObj = extractProps(body, [
role: body.role, 'role',
disabled: body.disabled, 'disabled',
fk_view_id: body.fk_view_id, 'fk_view_id',
project_id: body.project_id, 'project_id',
base_id: body.base_id, 'base_id',
created_at: body.created_at, 'created_at',
updated_at: body.updated_at, 'updated_at',
}; ]);
if (!(body.project_id && body.base_id)) { if (!(insertObj.project_id && insertObj.base_id)) {
const view = await View.get(body.fk_view_id, ncMeta); const view = await View.get(body.fk_view_id, ncMeta);
insertObj.project_id = view.project_id; insertObj.project_id = view.project_id;
insertObj.base_id = view.base_id; insertObj.base_id = view.base_id;

24
packages/nocodb/src/lib/models/Project.ts

@ -36,25 +36,27 @@ export default class Project implements ProjectType {
} }
public static async createProject( public static async createProject(
projectBody: ProjectType & { project: ProjectType & {
created_at?; created_at?;
updated_at?; updated_at?;
}, },
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
): Promise<Project> { ): Promise<Project> {
const insertObj = extractProps(project, [
'id',
'title',
'prefix',
'description',
'is_meta',
'created_at',
'updated_at',
]);
const { id: projectId } = await ncMeta.metaInsert2( const { id: projectId } = await ncMeta.metaInsert2(
null, null,
null, null,
MetaTable.PROJECT, MetaTable.PROJECT,
{ insertObj
id: projectBody?.id,
title: projectBody.title,
prefix: projectBody.prefix,
description: projectBody.description,
is_meta: projectBody.is_meta,
created_at: projectBody.created_at,
updated_at: projectBody.updated_at,
}
); );
await NocoCache.appendToList( await NocoCache.appendToList(
@ -63,7 +65,7 @@ export default class Project implements ProjectType {
`${CacheScope.PROJECT}:${projectId}` `${CacheScope.PROJECT}:${projectId}`
); );
for (const base of projectBody.bases) { for (const base of project.bases) {
await Base.createBase( await Base.createBase(
{ {
type: base.config?.client, type: base.config?.client,

17
packages/nocodb/src/lib/models/ProjectUser.ts

@ -8,6 +8,7 @@ import {
import Noco from '../Noco'; import Noco from '../Noco';
import NocoCache from '../cache/NocoCache'; import NocoCache from '../cache/NocoCache';
import User from './User'; import User from './User';
import { extractProps } from '../meta/helpers/extractProps';
export default class ProjectUser { export default class ProjectUser {
project_id: string; project_id: string;
@ -22,17 +23,19 @@ export default class ProjectUser {
projectUser: Partial<ProjectUser & { created_at?: any; updated_at?: any }>, projectUser: Partial<ProjectUser & { created_at?: any; updated_at?: any }>,
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
const insertObj = extractProps(projectUser, [
'fk_user_id',
'project_id',
'roles',
'created_at',
'updated_at',
]);
const { project_id, fk_user_id } = await ncMeta.metaInsert2( const { project_id, fk_user_id } = await ncMeta.metaInsert2(
null, null,
null, null,
MetaTable.PROJECT_USERS, MetaTable.PROJECT_USERS,
{ insertObj,
fk_user_id: projectUser.fk_user_id,
project_id: projectUser.project_id,
roles: projectUser.roles,
created_at: projectUser.created_at,
updated_at: projectUser.updated_at,
},
true true
); );

14
packages/nocodb/src/lib/models/QrCodeColumn.ts

@ -12,15 +12,17 @@ export default class QrCodeColumn {
} }
public static async insert( public static async insert(
data: Partial<QrCodeColumn>, qrCode: Partial<QrCodeColumn>,
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
await ncMeta.metaInsert2(null, null, MetaTable.COL_QRCODE, { const insertObj = extractProps(qrCode, [
fk_column_id: data.fk_column_id, 'fk_column_id',
fk_qr_value_column_id: data.fk_qr_value_column_id, 'fk_qr_value_column_id',
}); ]);
await ncMeta.metaInsert2(null, null, MetaTable.COL_QRCODE, insertObj);
return this.read(data.fk_column_id, ncMeta); return this.read(qrCode.fk_column_id, ncMeta);
} }
public static async read(columnId: string, ncMeta = Noco.ncMeta) { public static async read(columnId: string, ncMeta = Noco.ncMeta) {
let column = let column =

14
packages/nocodb/src/lib/models/RollupColumn.ts

@ -2,6 +2,7 @@ import Noco from '../Noco';
import Column from './Column'; import Column from './Column';
import { CacheGetType, CacheScope, MetaTable } from '../utils/globals'; import { CacheGetType, CacheScope, MetaTable } from '../utils/globals';
import NocoCache from '../cache/NocoCache'; import NocoCache from '../cache/NocoCache';
import { extractProps } from '../meta/helpers/extractProps';
export default class RollupColumn { export default class RollupColumn {
fk_column_id; fk_column_id;
@ -20,12 +21,13 @@ export default class RollupColumn {
data: Partial<RollupColumn>, data: Partial<RollupColumn>,
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
await ncMeta.metaInsert2(null, null, MetaTable.COL_ROLLUP, { const insertObj = extractProps(data, [
fk_column_id: data.fk_column_id, 'fk_column_id',
fk_relation_column_id: data.fk_relation_column_id, 'fk_relation_column_id',
fk_rollup_column_id: data.fk_rollup_column_id, 'fk_rollup_column_id',
rollup_function: data.rollup_function, 'rollup_function',
}); ]);
await ncMeta.metaInsert2(null, null, MetaTable.COL_ROLLUP, insertObj);
await NocoCache.appendToList( await NocoCache.appendToList(
CacheScope.COL_ROLLUP, CacheScope.COL_ROLLUP,

15
packages/nocodb/src/lib/models/SelectOption.ts

@ -1,6 +1,7 @@
import Noco from '../Noco'; import Noco from '../Noco';
import NocoCache from '../cache/NocoCache'; import NocoCache from '../cache/NocoCache';
import { CacheGetType, CacheScope, MetaTable } from '../utils/globals'; import { CacheGetType, CacheScope, MetaTable } from '../utils/globals';
import { extractProps } from '../meta/helpers/extractProps';
export default class SelectOption { export default class SelectOption {
title: string; title: string;
@ -16,11 +17,23 @@ export default class SelectOption {
data: Partial<SelectOption>, data: Partial<SelectOption>,
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
// title: string;
// fk_column_id: string;
// color: string;
// order: number;
const insertObj = extractProps(data, [
'title',
'fk_column_id',
'color',
'order',
]);
const { id } = await ncMeta.metaInsert2( const { id } = await ncMeta.metaInsert2(
null, null,
null, null,
MetaTable.COL_SELECT_OPTIONS, MetaTable.COL_SELECT_OPTIONS,
data insertObj
); );
await NocoCache.appendToList( await NocoCache.appendToList(

24
packages/nocodb/src/lib/models/Sort.ts

@ -9,6 +9,7 @@ import {
} from '../utils/globals'; } from '../utils/globals';
import NocoCache from '../cache/NocoCache'; import NocoCache from '../cache/NocoCache';
import { SortType } from 'nocodb-sdk'; import { SortType } from 'nocodb-sdk';
import { extractProps } from '../meta/helpers/extractProps';
export default class Sort { export default class Sort {
id: string; id: string;
@ -35,11 +36,20 @@ export default class Sort {
} }
public static async insert( public static async insert(
sortObj: Partial<Sort> & { push_to_top?: boolean }, sortObj: Partial<Sort> & { push_to_top?: boolean; order?: number },
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
const insertObj = extractProps(sortObj, [
'id',
'fk_view_id',
'fk_column_id',
'direction',
'project_id',
'base_id',
]);
// todo: implement a generic function // todo: implement a generic function
const order = sortObj.push_to_top insertObj.order = sortObj.push_to_top
? 1 ? 1
: (+( : (+(
await ncMeta await ncMeta
@ -50,16 +60,6 @@ export default class Sort {
}) })
.first() .first()
)?.order || 0) + 1; )?.order || 0) + 1;
const insertObj = {
id: sortObj.id,
fk_view_id: sortObj.fk_view_id,
fk_column_id: sortObj.fk_column_id,
direction: sortObj.direction,
project_id: sortObj.project_id,
base_id: sortObj.base_id,
order,
};
if (!(sortObj.project_id && sortObj.base_id)) { if (!(sortObj.project_id && sortObj.base_id)) {
const model = await Column.get({ colId: sortObj.fk_column_id }, ncMeta); const model = await Column.get({ colId: sortObj.fk_column_id }, ncMeta);
insertObj.project_id = model.project_id; insertObj.project_id = model.project_id;

15
packages/nocodb/src/lib/models/SyncLogs.ts

@ -1,5 +1,6 @@
import Noco from '../Noco'; import Noco from '../Noco';
import { MetaTable } from '../utils/globals'; import { MetaTable } from '../utils/globals';
import { extractProps } from '../meta/helpers/extractProps';
export default class SyncLogs { export default class SyncLogs {
id?: string; id?: string;
@ -34,13 +35,13 @@ export default class SyncLogs {
>, >,
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
const insertObj = { const insertObj = extractProps(syncLog, [
project_id: syncLog?.project_id, 'project_id',
fk_sync_source_id: syncLog?.fk_sync_source_id, 'fk_sync_source_id',
time_taken: syncLog?.time_taken, 'time_taken',
status: syncLog?.status, 'status',
status_details: syncLog?.status_details, 'status_details',
}; ]);
const { id } = await ncMeta.metaInsert2( const { id } = await ncMeta.metaInsert2(
null, null,

18
packages/nocodb/src/lib/models/SyncSource.ts

@ -73,15 +73,15 @@ export default class SyncSource {
>, >,
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
const insertObj = { const insertObj = extractProps(syncSource, [
id: syncSource?.id, 'id',
title: syncSource?.title, 'title',
type: syncSource?.type, 'type',
details: syncSource?.details, 'details',
project_id: syncSource?.project_id, 'project_id',
base_id: syncSource?.base_id, 'base_id',
fk_user_id: syncSource?.fk_user_id, 'fk_user_id',
}; ]);
if (insertObj.details && typeof insertObj.details === 'object') { if (insertObj.details && typeof insertObj.details === 'object') {
insertObj.details = JSON.stringify(insertObj.details); insertObj.details = JSON.stringify(insertObj.details);

34
packages/nocodb/src/lib/models/View.ts

@ -244,25 +244,29 @@ export default class View implements ViewType {
}, },
ncMeta = Noco.ncMeta ncMeta = Noco.ncMeta
) { ) {
const insertObj = extractProps(view, [
'id',
'title',
'is_default',
'type',
'fk_model_id',
'project_id',
'base_id',
'created_at',
'updated_at',
'meta',
]);
// get order value // get order value
const order = await ncMeta.metaGetNextOrder(MetaTable.VIEWS, { insertObj.order = await ncMeta.metaGetNextOrder(MetaTable.VIEWS, {
fk_model_id: view.fk_model_id, fk_model_id: view.fk_model_id,
}); });
const insertObj = { insertObj.show = true;
id: view.id,
title: view.title, if (!insertObj.meta) {
show: true, insertObj.meta = {};
is_default: view.is_default, }
order,
type: view.type,
fk_model_id: view.fk_model_id,
project_id: view.project_id,
base_id: view.base_id,
created_at: view.created_at,
updated_at: view.updated_at,
meta: view.meta ?? {},
};
insertObj.meta = stringifyMetaProp(insertObj); insertObj.meta = stringifyMetaProp(insertObj);

Loading…
Cancel
Save