@ -2,53 +2,59 @@ import {Command} from 'commander';
import path from 'path' ;
import fetch from "node-fetch" ;
import fs from "fs" ;
import http from "https" ;
import http from "http" ;
import https from "https" ;
import unzipper from "unzipper" ;
import { createTechnicalFiles , defaultGitRepo } from "./generators/block/index.js" ;
import { fileURLToPath } from 'url' ;
import config from 'config' ;
const __ filename = fileURLToPath ( import . meta . url ) ;
const __ dirname = path . dirname ( __ filename ) ;
const isDev = process . env . NODE_ENV === 'development' || ( config . has ( 'isDev' ) && config . get ( 'isDev' ) ) ; // Check README file in case you get "missing files" error.
const blocksRegistry = isDev ? 'http://localhost:3020' : 'https://' ;
const blocksDirectory = isDev ? 'blocks/' : '' ;
init ( ) ;
const blockName = await init ( ) ;
console . log ( ` 🎉 Done! \n \n Check the " ${ blocksDirectory } ${ blockName } " directory. \n ` ) ;
function init ( ) {
async function init ( ) {
const program = new Command ( ) ;
program
. name ( 'create-block' )
. description ( 'AXE-WEB Platform Blocks' ) ;
const promise = new Promise ( resolve => {
program . command ( 'pull' )
. argument ( '<string>' , 'Provide a full name of required block, for example: @axe-web/hero-block' )
. action ( async ( blockName , options ) => {
console . log ( 'Block to download:' , blockName )
console . log ( '📦 Block to download:' , blockName )
await getBlockSourceFiles ( blockName ) ;
resolve ( blockName ) ;
} ) ;
} ) ;
program . parse ( ) ;
return promise ;
}
async function getBlockSourceFiles ( blockName ) {
const blocksRegistry = 'http://localhost:3020' ;
const queryString = new URLSearchParams ( ) ;
queryString . append ( 'blockName' , blockName ) ;
queryString . append ( 'includeDevConfig' , 'true' ) ;
const response = await fetch ( ` ${ blocksRegistry } ? ${ queryString . toString ( ) } ` ) ;
const responseData = await response . json ( ) ;
if ( ! responseData ) {
if ( ! responseData || ! responseData . name ) {
return ;
}
const zipFile = await downloadFile ( responseData . downloadUrl , responseData . name ) ;
const file = await fs . createReadStream ( zipFile )
. pipe ( unzipper . Extract ( { path : ` blocks/ ${ responseData . name } /src ` } ) )
const zipFile = await downloadFile ( responseData . downloadUrl , responseData . name + '.zip' ) ;
await fs . createReadStream ( zipFile )
. pipe ( unzipper . Extract ( { path : ` ${ blocksDirectory } ${ responseData . name } /src ` } ) )
. promise ( ) ;
// Remove downloaded file.
@ -59,24 +65,100 @@ async function getBlockSourceFiles(blockName) {
console . log ( e )
}
if ( responseData . statusCode && responseData . statusCode !== 200 ) {
console . log ( responseData ) ;
console . log ( "⚠️ [ERROR]" , responseData . message || "Server side error." ) ;
return ;
}
await createTechnicalFiles ( {
title : responseData . title ,
name : responseData . name ,
blockFilename : responseData . name ,
devToolSource : defaultGitRepo
blockGroupName : responseData . project ,
version : responseData . version ,
devToolSource : defaultGitRepo ,
} , __ dirname ) ;
if ( responseData . config . design_files ) {
await downloadDesignFiles ( responseData . name , responseData . config . design_files ) ;
}
await createDataFiles ( responseData . name , responseData . config . data_sources ) ;
await createConfigFile ( responseData . name , responseData . config ) ;
}
async function downloadFile ( url , blockName ) {
const file = fs . createWriteStream ( blockName + '.zip' ) ;
async function createConfigFile ( blockName , config = { } ) {
const obj = {
blockName ,
baseView : config . baseView ,
remToPx : config . remToPx ,
} ;
const cssAssets = config . assets . filter ( item => item . type === 'css' ) . map ( item => item . url ) ;
if ( cssAssets . length ) {
obj . cssUrl = cssAssets ;
}
const jsAssets = config . assets . filter ( item => item . type === 'js' ) . map ( item => item . url ) ;
if ( jsAssets . length ) {
obj . jsUrl = jsAssets ;
}
await setupPath ( ` ${ blocksDirectory } ${ blockName } /config ` ) ;
await fs . promises . writeFile ( ` ${ blocksDirectory } ${ blockName } /config/default.json ` , JSON . stringify ( obj , null , 2 ) ) ;
}
async function downloadDesignFiles ( blockName = '' , files ) {
for ( let url of files ) {
const fileName = url . split ( '/' ) . pop ( ) ;
await setupPath ( ` ${ blocksDirectory } ${ blockName } /design ` ) ;
await downloadFile ( url , ` ${ blocksDirectory } ${ blockName } /design/ ${ fileName } ` )
}
}
async function createDataFiles ( blockName , dataSources = [ ] ) {
for ( let source of dataSources ) {
await setupPath ( ` ${ blocksDirectory } ${ blockName } /data ` ) ;
await fs . promises . writeFile ( ` ${ blocksDirectory } ${ blockName } /data/ ${ source . name } .json ` , JSON . stringify ( source . data , null , 2 ) ) ;
if ( typeof source . preview_images !== 'undefined' && source . preview_images . length ) {
for ( let preview_image of source . preview_images ) {
await downloadFile ( preview_image . url , ` ${ blocksDirectory } ${ blockName } /design/ ${ source . name } - ${ preview_image . width } . ${ preview_image . extension } ` )
}
}
}
}
//
// Helpers
//
async function setupPath ( path ) {
if ( ! fs . existsSync ( path ) ) {
await fs . promises . mkdir ( path ) ;
}
}
async function downloadFile ( url , fileName ) {
const file = fs . createWriteStream ( fileName ) ;
return new Promise ( ( resolve , reject ) => {
const request = http . get ( url , function ( response ) {
const protocol = url . startsWith ( 'https://' ) ? https : http ;
protocol . get ( url , function ( response ) {
response . pipe ( file ) ;
// Loading Indicator.
const loadingInterval = setInterval ( ( ) => console . log ( '🕐 Download in progress...' ) , 3000 ) ;
// after download completed close filestream
file . on ( "finish" , ( ) => {
clearInterval ( loadingInterval ) ;
file . close ( ) ;
resolve ( ` ./ ${ blockName } .zip ` ) ;
resolve ( fileName ) ;
} ) ;
} ) ;
} )
