gatekeeper/net
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix: Convert scripts to ES modules for Directus v11

Browse Source
This commit is contained in:
cawcenter
2025-12-12 07:28:30 -05:00
parent 483cfa3239
commit b5e5a5b011
2 changed files with 139 additions and 105 deletions
Download Patch File Download Diff File Expand all files Collapse all files

97
directus/scripts/import_template.js
View File

@@ -7,30 +7,98 @@
* Usage: node scripts/import_template.js
*/
require('dotenv').config();
const { createDirectus, rest, staticToken, schemaApply, createCollection, createField, createRelation } = require('@directus/sdk');
const collections = require('../template/src/collections.json');
const fields = require('../template/src/fields.json');
const relations = require('../template/src/relations.json');
import { createDirectus, rest, staticToken } from '@directus/sdk';
import { readFileSync } from 'fs';
import { fileURLToPath } from 'url';
import { dirname, join } from 'path';
const DIRECTUS_URL = process.env.DIRECTUS_URL || 'http://localhost:8055';
const DIRECTUS_TOKEN = process.env.DIRECTUS_ADMIN_TOKEN;
const __filename = fileURLToPath(import.meta.url);
const __dirname = dirname(__filename);
const DIRECTUS_URL = process.env.PUBLIC_URL || process.env.DIRECTUS_URL || 'http://localhost:8055';
const DIRECTUS_TOKEN = process.env.ADMIN_TOKEN || process.env.DIRECTUS_ADMIN_TOKEN;
if (!DIRECTUS_TOKEN) {
console.error('❌ DIRECTUS_ADMIN_TOKEN is required');
console.error('❌ ADMIN_TOKEN or DIRECTUS_ADMIN_TOKEN is required');
console.log('Set it in your environment or run: export ADMIN_TOKEN=your-token');
process.exit(1);
}
// Load schema files
const collectionsPath = join(__dirname, '../template/src/collections.json');
const fieldsPath = join(__dirname, '../template/src/fields.json');
const relationsPath = join(__dirname, '../template/src/relations.json');
let collections, fields, relations;
try {
collections = JSON.parse(readFileSync(collectionsPath, 'utf8'));
fields = JSON.parse(readFileSync(fieldsPath, 'utf8'));
relations = JSON.parse(readFileSync(relationsPath, 'utf8'));
} catch (err) {
console.error('❌ Failed to load schema files:', err.message);
process.exit(1);
}
const directus = createDirectus(DIRECTUS_URL).with(rest()).with(staticToken(DIRECTUS_TOKEN));
async function createCollection(collection) {
const response = await fetch(`${DIRECTUS_URL}/collections`, {
method: 'POST',
headers: {
'Authorization': `Bearer ${DIRECTUS_TOKEN}`,
'Content-Type': 'application/json'
},
body: JSON.stringify(collection)
});
if (!response.ok) {
const error = await response.json();
throw new Error(error.errors?.[0]?.message || response.statusText);
}
return response.json();
}
async function createField(collectionName, field) {
const response = await fetch(`${DIRECTUS_URL}/fields/${collectionName}`, {
method: 'POST',
headers: {
'Authorization': `Bearer ${DIRECTUS_TOKEN}`,
'Content-Type': 'application/json'
},
body: JSON.stringify(field)
});
if (!response.ok) {
const error = await response.json();
throw new Error(error.errors?.[0]?.message || response.statusText);
}
return response.json();
}
async function createRelation(relation) {
const response = await fetch(`${DIRECTUS_URL}/relations`, {
method: 'POST',
headers: {
'Authorization': `Bearer ${DIRECTUS_TOKEN}`,
'Content-Type': 'application/json'
},
body: JSON.stringify(relation)
});
if (!response.ok) {
const error = await response.json();
throw new Error(error.errors?.[0]?.message || response.statusText);
}
return response.json();
}
async function importSchema() {
console.log('🚀 Starting Spark Platform schema import...\n');
console.log('🚀 Starting Spark Platform schema import...');
console.log(` Directus URL: ${DIRECTUS_URL}\n`);
// Create collections
console.log('📦 Creating collections...');
for (const collection of collections) {
try {
await directus.request(createCollection(collection));
await createCollection(collection);
console.log(` ✅ ${collection.collection}`);
} catch (err) {
if (err.message?.includes('already exists')) {
@@ -46,7 +114,7 @@ async function importSchema() {
for (const [collectionName, collectionFields] of Object.entries(fields)) {
for (const field of collectionFields) {
try {
await directus.request(createField(collectionName, field));
await createField(collectionName, field);
console.log(` ✅ ${collectionName}.${field.field}`);
} catch (err) {
if (err.message?.includes('already exists')) {
@@ -62,7 +130,7 @@ async function importSchema() {
console.log('\n🔗 Creating relations...');
for (const relation of relations) {
try {
await directus.request(createRelation(relation));
await createRelation(relation);
console.log(` ✅ ${relation.collection}.${relation.field} → ${relation.related_collection}`);
} catch (err) {
if (err.message?.includes('already exists')) {
@@ -76,4 +144,7 @@ async function importSchema() {
console.log('\n✨ Schema import complete!');
}
importSchema().catch(console.error);
importSchema().catch((err) => {
console.error('❌ Import failed:', err);
process.exit(1);
});