fix

Author: Wentao-Kuang

packages/cli-vector/src/cli/cli.join.ts

@@ -20,7 +20,7 @@ async function download(filePaths: URL[], outputPath: string, logger: LogType):
     } else {
       const fileName = basename(file.pathname);
       if (fileName == null) throw new Error(`Unsupported source pathname ${file.pathname}`);
-      const localFile = fsa.toUrl(`${outputPath}/${fileName}`);
+      const localFile = fsa.toUrl(`${outputPath}/downloads/${fileName}`);
       if (await fsa.exists(localFile)) {
         logger.info({ file: file, localFile, fileName }, 'Download:FileExists');
       } else {
@@ -52,7 +52,7 @@ async function upload(file: URL, bucketPath: URL, logger: LogType): Promise<URL>
   }
 
   // Upload to s3 or copy to local
-  let path = new URL(`topographic/${CliId}/`, bucketPath);
+  let path = new URL(`topographic/${CliId}/${filename}`, bucketPath);
   logger.info({ file: file, path: path }, 'Load:Path');
   if (path.protocol === 'file:') mkdirSync(path, { recursive: true });
   if (filename.endsWith('catalog.json')) path = new URL(filename, bucketPath); // Upload catalog to root directory
@@ -89,6 +89,13 @@ export const JoinArgs = {
     defaultValue: () => 'Topographic',
     defaultValueIsSerializable: true,
   }),
+  output: option({
+    type: string,
+    long: 'output',
+    description: 'Output path for the processing files, default is /tmp/join/',
+    defaultValue: () => '/tmp/join/',
+    defaultValueIsSerializable: true,
+  }),
   target: option({
     type: Url,
     long: 'target',
@@ -103,7 +110,7 @@ export const JoinCommand = command({
   args: JoinArgs,
   async handler(args) {
     const logger = getLogger(this, args, 'cli-vector');
-    const outputPath = `/tmp/join/`;
+    const outputPath = args.output;
     const tileMatrix = TileMatrixSets.find(args.tileMatrix);
     if (tileMatrix == null) throw new Error(`Tile matrix ${args.tileMatrix} is not supported`);
     const bucketPath = new URL(`vector/${tileMatrix.projection.code}/`, args.target);