303 lines
11 KiB
JavaScript
303 lines
11 KiB
JavaScript
'use strict';
|
|
|
|
var drizzleOrm = require('drizzle-orm');
|
|
var zod = require('zod');
|
|
|
|
const CONSTANTS = {
|
|
INT8_MIN: -128,
|
|
INT8_MAX: 127,
|
|
INT8_UNSIGNED_MAX: 255,
|
|
INT16_MIN: -32768,
|
|
INT16_MAX: 32767,
|
|
INT16_UNSIGNED_MAX: 65535,
|
|
INT24_MIN: -8388608,
|
|
INT24_MAX: 8388607,
|
|
INT24_UNSIGNED_MAX: 16777215,
|
|
INT32_MIN: -2147483648,
|
|
INT32_MAX: 2147483647,
|
|
INT32_UNSIGNED_MAX: 4294967295,
|
|
INT48_MIN: -140737488355328,
|
|
INT48_MAX: 140737488355327,
|
|
INT48_UNSIGNED_MAX: 281474976710655,
|
|
INT64_MIN: -9223372036854775808n,
|
|
INT64_MAX: 9223372036854775807n,
|
|
INT64_UNSIGNED_MAX: 18446744073709551615n,
|
|
};
|
|
|
|
function isColumnType(column, columnTypes) {
|
|
return columnTypes.includes(column.columnType);
|
|
}
|
|
function isWithEnum(column) {
|
|
return 'enumValues' in column && Array.isArray(column.enumValues) && column.enumValues.length > 0;
|
|
}
|
|
const isPgEnum = isWithEnum;
|
|
|
|
const literalSchema = zod.z.union([zod.z.string(), zod.z.number(), zod.z.boolean(), zod.z.null()]);
|
|
const jsonSchema = zod.z.lazy(() => zod.z.union([literalSchema, zod.z.array(jsonSchema), zod.z.record(jsonSchema)]));
|
|
const bufferSchema = zod.z.custom((v) => v instanceof Buffer); // eslint-disable-line no-instanceof/no-instanceof
|
|
/** @internal */
|
|
function columnToSchema(column, z) {
|
|
let schema;
|
|
if (isWithEnum(column)) {
|
|
schema = column.enumValues.length ? z.enum(column.enumValues) : z.string();
|
|
}
|
|
if (!schema) {
|
|
// Handle specific types
|
|
if (isColumnType(column, ['PgGeometry', 'PgPointTuple'])) {
|
|
schema = z.tuple([z.number(), z.number()]);
|
|
}
|
|
else if (isColumnType(column, ['PgGeometryObject', 'PgPointObject'])) {
|
|
schema = z.object({ x: z.number(), y: z.number() });
|
|
}
|
|
else if (isColumnType(column, ['PgHalfVector', 'PgVector'])) {
|
|
schema = z.array(z.number());
|
|
schema = column.dimensions ? schema.length(column.dimensions) : schema;
|
|
}
|
|
else if (isColumnType(column, ['PgLine'])) {
|
|
schema = z.tuple([z.number(), z.number(), z.number()]);
|
|
}
|
|
else if (isColumnType(column, ['PgLineABC'])) {
|
|
schema = z.object({
|
|
a: z.number(),
|
|
b: z.number(),
|
|
c: z.number(),
|
|
});
|
|
} // Handle other types
|
|
else if (isColumnType(column, ['PgArray'])) {
|
|
schema = z.array(columnToSchema(column.baseColumn, z));
|
|
schema = column.size ? schema.length(column.size) : schema;
|
|
}
|
|
else if (column.dataType === 'array') {
|
|
schema = z.array(z.any());
|
|
}
|
|
else if (column.dataType === 'number') {
|
|
schema = numberColumnToSchema(column, z);
|
|
}
|
|
else if (column.dataType === 'bigint') {
|
|
schema = bigintColumnToSchema(column, z);
|
|
}
|
|
else if (column.dataType === 'boolean') {
|
|
schema = z.boolean();
|
|
}
|
|
else if (column.dataType === 'date') {
|
|
schema = z.date();
|
|
}
|
|
else if (column.dataType === 'string') {
|
|
schema = stringColumnToSchema(column, z);
|
|
}
|
|
else if (column.dataType === 'json') {
|
|
schema = jsonSchema;
|
|
}
|
|
else if (column.dataType === 'custom') {
|
|
schema = z.any();
|
|
}
|
|
else if (column.dataType === 'buffer') {
|
|
schema = bufferSchema;
|
|
}
|
|
}
|
|
if (!schema) {
|
|
schema = z.any();
|
|
}
|
|
return schema;
|
|
}
|
|
function numberColumnToSchema(column, z) {
|
|
let unsigned = column.getSQLType().includes('unsigned');
|
|
let min;
|
|
let max;
|
|
let integer = false;
|
|
if (isColumnType(column, ['MySqlTinyInt'])) {
|
|
min = unsigned ? 0 : CONSTANTS.INT8_MIN;
|
|
max = unsigned ? CONSTANTS.INT8_UNSIGNED_MAX : CONSTANTS.INT8_MAX;
|
|
integer = true;
|
|
}
|
|
else if (isColumnType(column, [
|
|
'PgSmallInt',
|
|
'PgSmallSerial',
|
|
'MySqlSmallInt',
|
|
])) {
|
|
min = unsigned ? 0 : CONSTANTS.INT16_MIN;
|
|
max = unsigned ? CONSTANTS.INT16_UNSIGNED_MAX : CONSTANTS.INT16_MAX;
|
|
integer = true;
|
|
}
|
|
else if (isColumnType(column, [
|
|
'PgReal',
|
|
'MySqlFloat',
|
|
'MySqlMediumInt',
|
|
])) {
|
|
min = unsigned ? 0 : CONSTANTS.INT24_MIN;
|
|
max = unsigned ? CONSTANTS.INT24_UNSIGNED_MAX : CONSTANTS.INT24_MAX;
|
|
integer = isColumnType(column, ['MySqlMediumInt']);
|
|
}
|
|
else if (isColumnType(column, ['PgInteger', 'PgSerial', 'MySqlInt'])) {
|
|
min = unsigned ? 0 : CONSTANTS.INT32_MIN;
|
|
max = unsigned ? CONSTANTS.INT32_UNSIGNED_MAX : CONSTANTS.INT32_MAX;
|
|
integer = true;
|
|
}
|
|
else if (isColumnType(column, [
|
|
'PgDoublePrecision',
|
|
'MySqlReal',
|
|
'MySqlDouble',
|
|
'SQLiteReal',
|
|
])) {
|
|
min = unsigned ? 0 : CONSTANTS.INT48_MIN;
|
|
max = unsigned ? CONSTANTS.INT48_UNSIGNED_MAX : CONSTANTS.INT48_MAX;
|
|
}
|
|
else if (isColumnType(column, ['PgBigInt53', 'PgBigSerial53', 'MySqlBigInt53', 'MySqlSerial', 'SQLiteInteger'])) {
|
|
unsigned = unsigned || isColumnType(column, ['MySqlSerial']);
|
|
min = unsigned ? 0 : Number.MIN_SAFE_INTEGER;
|
|
max = Number.MAX_SAFE_INTEGER;
|
|
integer = true;
|
|
}
|
|
else if (isColumnType(column, ['MySqlYear'])) {
|
|
min = 1901;
|
|
max = 2155;
|
|
integer = true;
|
|
}
|
|
else {
|
|
min = Number.MIN_SAFE_INTEGER;
|
|
max = Number.MAX_SAFE_INTEGER;
|
|
}
|
|
const schema = z.number().min(min).max(max);
|
|
return integer ? schema.int() : schema;
|
|
}
|
|
function bigintColumnToSchema(column, z) {
|
|
const unsigned = column.getSQLType().includes('unsigned');
|
|
const min = unsigned ? 0n : CONSTANTS.INT64_MIN;
|
|
const max = unsigned ? CONSTANTS.INT64_UNSIGNED_MAX : CONSTANTS.INT64_MAX;
|
|
return z.bigint().min(min).max(max);
|
|
}
|
|
function stringColumnToSchema(column, z) {
|
|
if (isColumnType(column, ['PgUUID'])) {
|
|
return z.string().uuid();
|
|
}
|
|
let max;
|
|
let regex;
|
|
let fixed = false;
|
|
if (isColumnType(column, ['PgVarchar', 'SQLiteText'])) {
|
|
max = column.length;
|
|
}
|
|
else if (isColumnType(column, ['MySqlVarChar'])) {
|
|
max = column.length ?? CONSTANTS.INT16_UNSIGNED_MAX;
|
|
}
|
|
else if (isColumnType(column, ['MySqlText'])) {
|
|
if (column.textType === 'longtext') {
|
|
max = CONSTANTS.INT32_UNSIGNED_MAX;
|
|
}
|
|
else if (column.textType === 'mediumtext') {
|
|
max = CONSTANTS.INT24_UNSIGNED_MAX;
|
|
}
|
|
else if (column.textType === 'text') {
|
|
max = CONSTANTS.INT16_UNSIGNED_MAX;
|
|
}
|
|
else {
|
|
max = CONSTANTS.INT8_UNSIGNED_MAX;
|
|
}
|
|
}
|
|
if (isColumnType(column, ['PgChar', 'MySqlChar'])) {
|
|
max = column.length;
|
|
fixed = true;
|
|
}
|
|
if (isColumnType(column, ['PgBinaryVector'])) {
|
|
regex = /^[01]+$/;
|
|
max = column.dimensions;
|
|
}
|
|
let schema = z.string();
|
|
schema = regex ? schema.regex(regex) : schema;
|
|
return max && fixed ? schema.length(max) : max ? schema.max(max) : schema;
|
|
}
|
|
|
|
function getColumns(tableLike) {
|
|
return drizzleOrm.isTable(tableLike) ? drizzleOrm.getTableColumns(tableLike) : drizzleOrm.getViewSelectedFields(tableLike);
|
|
}
|
|
function handleColumns(columns, refinements, conditions, factory) {
|
|
const columnSchemas = {};
|
|
for (const [key, selected] of Object.entries(columns)) {
|
|
if (!drizzleOrm.is(selected, drizzleOrm.Column) && !drizzleOrm.is(selected, drizzleOrm.SQL) && !drizzleOrm.is(selected, drizzleOrm.SQL.Aliased) && typeof selected === 'object') {
|
|
const columns = drizzleOrm.isTable(selected) || drizzleOrm.isView(selected) ? getColumns(selected) : selected;
|
|
columnSchemas[key] = handleColumns(columns, refinements[key] ?? {}, conditions, factory);
|
|
continue;
|
|
}
|
|
const refinement = refinements[key];
|
|
if (refinement !== undefined && typeof refinement !== 'function') {
|
|
columnSchemas[key] = refinement;
|
|
continue;
|
|
}
|
|
const column = drizzleOrm.is(selected, drizzleOrm.Column) ? selected : undefined;
|
|
const schema = column ? columnToSchema(column, factory?.zodInstance ?? zod.z) : zod.z.any();
|
|
const refined = typeof refinement === 'function' ? refinement(schema) : schema;
|
|
if (conditions.never(column)) {
|
|
continue;
|
|
}
|
|
else {
|
|
columnSchemas[key] = refined;
|
|
}
|
|
if (column) {
|
|
if (conditions.nullable(column)) {
|
|
columnSchemas[key] = columnSchemas[key].nullable();
|
|
}
|
|
if (conditions.optional(column)) {
|
|
columnSchemas[key] = columnSchemas[key].optional();
|
|
}
|
|
}
|
|
}
|
|
return zod.z.object(columnSchemas);
|
|
}
|
|
function handleEnum(enum_, factory) {
|
|
const zod$1 = factory?.zodInstance ?? zod.z;
|
|
return zod$1.enum(enum_.enumValues);
|
|
}
|
|
const selectConditions = {
|
|
never: () => false,
|
|
optional: () => false,
|
|
nullable: (column) => !column.notNull,
|
|
};
|
|
const insertConditions = {
|
|
never: (column) => column?.generated?.type === 'always' || column?.generatedIdentity?.type === 'always',
|
|
optional: (column) => !column.notNull || (column.notNull && column.hasDefault),
|
|
nullable: (column) => !column.notNull,
|
|
};
|
|
const updateConditions = {
|
|
never: (column) => column?.generated?.type === 'always' || column?.generatedIdentity?.type === 'always',
|
|
optional: () => true,
|
|
nullable: (column) => !column.notNull,
|
|
};
|
|
const createSelectSchema = (entity, refine) => {
|
|
if (isPgEnum(entity)) {
|
|
return handleEnum(entity);
|
|
}
|
|
const columns = getColumns(entity);
|
|
return handleColumns(columns, refine ?? {}, selectConditions);
|
|
};
|
|
const createInsertSchema = (entity, refine) => {
|
|
const columns = getColumns(entity);
|
|
return handleColumns(columns, refine ?? {}, insertConditions);
|
|
};
|
|
const createUpdateSchema = (entity, refine) => {
|
|
const columns = getColumns(entity);
|
|
return handleColumns(columns, refine ?? {}, updateConditions);
|
|
};
|
|
function createSchemaFactory(options) {
|
|
const createSelectSchema = (entity, refine) => {
|
|
if (isPgEnum(entity)) {
|
|
return handleEnum(entity, options);
|
|
}
|
|
const columns = getColumns(entity);
|
|
return handleColumns(columns, refine ?? {}, selectConditions, options);
|
|
};
|
|
const createInsertSchema = (entity, refine) => {
|
|
const columns = getColumns(entity);
|
|
return handleColumns(columns, refine ?? {}, insertConditions, options);
|
|
};
|
|
const createUpdateSchema = (entity, refine) => {
|
|
const columns = getColumns(entity);
|
|
return handleColumns(columns, refine ?? {}, updateConditions, options);
|
|
};
|
|
return { createSelectSchema, createInsertSchema, createUpdateSchema };
|
|
}
|
|
|
|
exports.createInsertSchema = createInsertSchema;
|
|
exports.createSchemaFactory = createSchemaFactory;
|
|
exports.createSelectSchema = createSelectSchema;
|
|
exports.createUpdateSchema = createUpdateSchema;
|
|
//# sourceMappingURL=index.cjs.map
|