import { $APP, shadow$provide } from "./shared.js";
const shadow_esm_import = function(x) { return import(x) };
import*as esm_import$node_fs from"node:fs";import*as esm_import$node_path from"node:path";$APP.ardegazu.train.ingest={};$APP.ardegazu.train.ingest.expand_dirs=function(a){for(var b=[],c=a.length,d=0;;)if(d<c){var e=a[d],f=e.indexOf("*");if(f<0)b.push(e);else{var g=e.slice(0,f).replace(/\/[^\/]*$/,"");e=e.slice(e.indexOf("/",f)+1);try{var h=esm_import$node_fs.readdirSync(g,{withFileTypes:!0}),k=h.length;for(f=0;;)if(f<k){var l=h[f];l.isDirectory()&&b.push(esm_import$node_path.join(g,l.name,e));f+=1}else break}catch(m){}}d+=1}else break;return b};
$APP.ardegazu.train.ingest.ingest_state_path=function(a){return esm_import$node_path.join(a,"ingest-state.json")};$APP.ardegazu.train.ingest.load_ingest_state=function(a){try{return JSON.parse(esm_import$node_fs.readFileSync($APP.ardegazu.train.ingest.ingest_state_path(a),"utf8"))}catch(b){return{offsets:{}}}};$APP.ardegazu.train.ingest.save_ingest_state=function(a,b){esm_import$node_fs.mkdirSync(a,{recursive:!0});esm_import$node_fs.writeFileSync($APP.ardegazu.train.ingest.ingest_state_path(a),JSON.stringify(b))};export const expandDirs=$APP.ardegazu.train.ingest.expand_dirs;export const ingestStatePath=$APP.ardegazu.train.ingest.ingest_state_path;export const loadIngestState=$APP.ardegazu.train.ingest.load_ingest_state;export const saveIngestState=$APP.ardegazu.train.ingest.save_ingest_state;