Merge pull request #51 from internxt/feature/get-download-links

[_]: feature/get-download-links

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@internxt/inxt-js",
-  "version": "1.4.0",
+  "version": "1.5.0",
   "description": "",
   "main": "build/index.js",
   "types": "build/index.d.ts",

src/cli/Commands.ts

@@ -3,6 +3,7 @@ import { buildCommand } from './CommandInterface';
 import { createBucket } from './create-bucket';
 import { deleteBucket } from './delete-bucket';
 import { downloadFile } from './download-file';
+import { getDownloadLinks } from './get-download-links';
 import { getFileInfo } from './get-filo-info';
 import { renameFile } from './rename-file';
 import { uploadFileOneShard, uploadFileMultipleShards } from './upload-file';
@@ -18,19 +19,19 @@ export const uploadFileCommand = buildCommand({
   version: '0.0.1',
   command: 'upload-file <path>',
   description: 'Upload a file',
-  options: [{
-    flags: '-s, --shards [one|multiple]',
-    required: true
-  }],
+  options: [
+    {
+      flags: '-s, --shards [one|multiple]',
+      required: true,
+    },
+  ],
 }).action((path, opts) => {
   if (opts.shards === 'multiple') {
-    return uploadFileMultipleShards(path, 1)
-      .finally(notifyProgramFinished('upload-file'));
-  } 
+    return uploadFileMultipleShards(path, 1).finally(notifyProgramFinished('upload-file'));
+  }
   if (opts.shards === 'one') {
-    return uploadFileOneShard(path)
-      .finally(notifyProgramFinished('upload-file'));
-  }  
+    return uploadFileOneShard(path).finally(notifyProgramFinished('upload-file'));
+  }
 });
 
 export const uploadFileCommandParallel = buildCommand({
@@ -91,7 +92,7 @@ export const createBucketCommand = buildCommand({
   version: '0.0.1',
   command: 'create-bucket <bucketName>',
   description: 'Creates a bucket with the given name',
-  options: []
+  options: [],
 }).action((bucketName: string) => {
   createBucket(bucketName).finally(notifyProgramFinished('create-bucket'));
 });
@@ -100,11 +101,20 @@ export const deleteBucketCommand = buildCommand({
   version: '0.0.1',
   command: 'delete-bucket <bucketId>',
   description: 'Deletes a bucket given its id',
-  options: []
+  options: [],
 }).action((bucketId: string) => {
   deleteBucket(bucketId).finally(notifyProgramFinished('delete-bucket'));
 });
 
+export const getDownloadLinksCommand = buildCommand({
+  version: '0.0.1',
+  command: 'get-download-links <bucketId> <fileIdsSeparatedByCommas>',
+  description: 'Gets download links of file ids',
+  options: [],
+}).action((bucketId: string, fileIdsSeparatedByCommas: string) => {
+  getDownloadLinks(bucketId, fileIdsSeparatedByCommas.split(',')).finally(notifyProgramFinished('get-download-links'));
+});
+
 // export const downloadFolderZippedCommand = buildCommand({
 //   version: '0.0.1',
 //   name: 'download-folder-zip',

src/cli/get-download-links.ts

@@ -0,0 +1,13 @@
+import { logger } from '../lib/utils/logger';
+import { getEnvironment } from './CommandInterface';
+
+export async function getDownloadLinks(bucketId: string, fileIds: string[]): Promise<void> {
+  const network = getEnvironment();
+
+  try {
+    const response = await network.getDownloadLinks(bucketId, fileIds);
+    logger.info(`getDownloadLinks response: ${JSON.stringify(response, null, 2)}`);
+  } catch (err) {
+    logger.error(`Something went wrong while getting download links ${err.message}`);
+  }
+}

src/cli/index.ts

@@ -15,6 +15,7 @@ program.addCommand(commands.renameFileCommand);
 program.addCommand(commands.getFileInfoCommand);
 program.addCommand(commands.createBucketCommand);
 program.addCommand(commands.deleteBucketCommand);
+program.addCommand(commands.getDownloadLinksCommand);
 // program.addCommand(commands.downloadFolderZippedCommand);
 
 program.parse(process.argv);

src/index.ts

@@ -26,7 +26,7 @@ import { ActionState, ActionTypes, Bucket, EnvironmentConfig } from './api';
 import { logger, Logger } from './lib/utils/logger';
 
 import { FileInfo, GetFileInfo } from './api/fileinfo';
-import { Bridge, CreateFileTokenResponse } from './services/api';
+import { Bridge, CreateFileTokenResponse, GetDownloadLinksResponse } from './services/api';
 import { HashStream } from './lib/utils/streams';
 
 type GetBucketsCallback = (err: Error | null, result: any) => void;
@@ -273,4 +273,8 @@ export class Environment {
       return new Bridge(this.config).renameFile(bucketId, fileId, newEncryptedName).start();
     });
   }
+
+  getDownloadLinks(bucketId: string, fileIds: string[]) {
+    return new Bridge(this.config).getDownloadLinks(bucketId, fileIds).start<GetDownloadLinksResponse>();
+  }
 }

src/services/api.ts

@@ -104,6 +104,7 @@ export interface CreateFileTokenResponse {
   size: number;
   token: string;
 }
+export type GetDownloadLinksResponse = { fileId: string; link: string; index: string }[];
 
 export interface InxtApiI {
   getBucketById(bucketId: string, params?: AxiosRequestConfig): INXTRequest;
@@ -289,12 +290,18 @@ export class Bridge extends InxtApi {
   createBucket(bucketName: string) {
     const targetUrl = `${this.config.bridgeUrl}/buckets`;
 
-    return new INXTRequest(this.config, Methods.Post, targetUrl, { data: { name: bucketName }});
-  };
+    return new INXTRequest(this.config, Methods.Post, targetUrl, { data: { name: bucketName } });
+  }
 
   deleteBucket(bucketId: string) {
     const targetUrl = `${this.config.bridgeUrl}/buckets/${bucketId}`;
 
     return new INXTRequest(this.config, Methods.Delete, targetUrl, {});
   }
+
+  getDownloadLinks(bucketId: string, fileIds: string[]) {
+    const targetUrl = `${this.config.bridgeUrl}/buckets/${bucketId}/bulk-files?fileIds=${fileIds.join(',')}`;
+
+    return new INXTRequest(this.config, Methods.Get, targetUrl, {});
+  }
 }