introspectGel() — drizzle-orm Function Reference

Source Code

drizzle-kit/src/cli/commands/introspect.ts lines 181–305

export const introspectGel = async (
	casing: Casing,
	out: string,
	breakpoints: boolean,
	credentials: GelCredentials | undefined,
	tablesFilter: string[],
	schemasFilter: string[],
	prefix: Prefix,
	entities: Entities,
) => {
	const { prepareGelDB } = await import('../connections');
	const db = await prepareGelDB(credentials);

	const matchers = tablesFilter.map((it) => {
		return new Minimatch(it);
	});

	const filter = (tableName: string) => {
		if (matchers.length === 0) return true;

		let flags: boolean[] = [];

		for (let matcher of matchers) {
			if (matcher.negate) {
				if (!matcher.match(tableName)) {
					flags.push(false);
				}
			}

			if (matcher.match(tableName)) {
				flags.push(true);
			}
		}

		if (flags.length > 0) {
			return flags.every(Boolean);
		}
		return false;
	};

	const progress = new IntrospectProgress(true);

	const res = await renderWithTask(
		progress,
		fromGelDatabase(
			db,
			filter,
			schemasFilter,
			entities,
			(stage, count, status) => {
				progress.update(stage, count, status);
			},
		),
	);

	const schema = { id: originUUID, prevId: '', ...res } as GelSchema;
	const ts = gelSchemaToTypeScript(schema, casing);
	const relationsTs = relationsToTypeScript(schema, casing);
	const { internal, ...schemaWithoutInternals } = schema;

	const schemaFile = join(out, 'schema.ts');
	writeFileSync(schemaFile, ts.file);
	const relationsFile = join(out, 'relations.ts');
	writeFileSync(relationsFile, relationsTs.file);
	console.log();

	// const { snapshots, journal } = prepareOutFolder(out, 'gel');

	// if (snapshots.length === 0) {
	// 	const { sqlStatements, _meta } = await applyGelSnapshotsDiff(
	// 		squashGelScheme(dryGel),
	// 		squashGelScheme(schema),
	// 		schemasResolver,
	// 		enumsResolver,
	// 		sequencesResolver,
	// 		policyResolver,
	// 		indPolicyResolver,
	// 		roleResolver,
	// 		tablesResolver,
	// 		columnsResolver,
	// 		viewsResolver,