feat: implement upload history

package.json

@@ -67,6 +67,7 @@
     "cafe-utility": "^33.3.1",
     "chalk": "^2.4.2",
     "cli-progress": "^3.11.2",
+    "cli-table3": "^0.6.5",
     "ethers": "^5.7.2",
     "furious-commander": "^1.7.1",
     "inquirer": "^8.2.5",

src/command/feed/feed-command.ts

@@ -73,7 +73,11 @@ export class FeedCommand extends RootCommand {
       this.console.error('The provided identity does not exist. Please select one that exists.')
     }
 
-    return identities[this.identity] || identities[await pickIdentity(this.commandConfig, this.console)]
+    if (!identities[this.identity]) {
+      this.identity = await pickIdentity(this.commandConfig, this.console)
+    }
+
+    return identities[this.identity]
   }
 
   private async writeFeed(stamp: string, wallet: Wallet, topic: Topic, chunkReference: Reference): Promise<FeedInfo> {

src/command/feed/upload.ts

@@ -4,6 +4,7 @@ import { pickStamp } from '../../service/stamp'
 import { stampProperties } from '../../utils/option'
 import { Upload as FileUpload } from '../upload'
 import { FeedCommand } from './feed-command'
+import { History } from '../../service/history'
 
 export class Upload extends FeedCommand implements LeafCommand {
   public readonly name = 'upload'
@@ -34,6 +35,16 @@ export class Upload extends FeedCommand implements LeafCommand {
 
     const reference = await this.runUpload()
     this.feedManifest = await this.updateFeedAndPrint(this.stamp, reference)
+    const history = new History(this.commandConfig.configFolderPath, this.console)
+    history.addItem({
+      timestamp: Date.now(),
+      reference: reference.toHex(),
+      stamp: this.stamp,
+      path: this.fileUpload.path,
+      uploadType: 'folder',
+      feedIdentity: this.identity,
+      feedAddress: this.feedManifest.toHex(),
+    })
     this.console.dim('Successfully uploaded to feed.')
   }
 

src/command/history/history-command.ts

@@ -0,0 +1,3 @@
+import { RootCommand } from '../root-command'
+
+export class HistoryCommand extends RootCommand {}

src/command/history/index.ts

@@ -0,0 +1,11 @@
+import { GroupCommand } from 'furious-commander'
+import { List } from './list'
+import { Show } from './show'
+
+export class History implements GroupCommand {
+  public readonly name = 'history'
+
+  public readonly description = 'Get upload history'
+
+  public subCommandClasses = [List, Show]
+}

src/command/history/list.ts

@@ -0,0 +1,40 @@
+import { HistoryCommand } from './history-command'
+import { History } from '../../service/history'
+import Table from 'cli-table3'
+import { LeafCommand } from 'furious-commander'
+import { ellipsis } from '../../utils/text'
+import { HistoryItem } from '../../service/history/types/historyItem'
+
+export class List extends HistoryCommand implements LeafCommand {
+  public readonly name = 'list'
+
+  public readonly alias = 'ls'
+
+  public readonly description = 'Get upload history list'
+
+  public run() {
+    super.init()
+    const table = new Table({
+      head: ['Index', 'Timestamp', 'Reference', 'Postage stamp batch ID', 'File path', 'Upload type'],
+      style: {
+        head: ['green', 'bold'],
+      },
+      wordWrap: true,
+    })
+
+    const history = new History(this.commandConfig.configFolderPath, this.console)
+    table.push(
+      ...history
+        .getItems()
+        .map((h: HistoryItem) => [
+          h.index,
+          new Date(h.timestamp).toLocaleString(),
+          h.reference.slice(0, 12),
+          ellipsis(h.stamp, 6, -6),
+          h.path,
+          h.uploadType,
+        ]),
+    )
+    this.console.log(table.toString())
+  }
+}

src/command/history/show.ts

@@ -0,0 +1,46 @@
+import { HistoryCommand } from './history-command'
+import { Argument, LeafCommand } from 'furious-commander'
+import { createKeyValue } from '../../utils/text'
+import { exit } from 'process'
+import { History } from '../../service/history'
+
+export class Show extends HistoryCommand implements LeafCommand {
+  public readonly name = 'show'
+
+  public readonly description = 'Get upload history item'
+
+  @Argument({
+    key: 'index',
+    description: 'Index of the history item',
+    required: true,
+    type: 'number',
+  })
+  public index!: number
+
+  public run() {
+    super.init()
+    const history = new History(this.commandConfig.configFolderPath, this.console)
+    const historyItem = history.getItemByIndex(this.index)
+
+    if (historyItem === undefined) {
+      this.console.error(`Cound not find history item with index '${this.index}'`)
+      exit(1)
+    }
+    this.console.log(createKeyValue('Timestamp', new Date(historyItem.timestamp).toUTCString()))
+    this.console.log(createKeyValue('Swarm hash', historyItem.reference))
+    this.console.log(createKeyValue('Stamp ID', historyItem.stamp))
+    this.console.log(createKeyValue('Upload type', historyItem.uploadType))
+
+    if (historyItem.path) {
+      this.console.log(createKeyValue('Path', historyItem.path))
+    }
+
+    if (historyItem.feedAddress) {
+      this.console.log(createKeyValue('Feed address', historyItem.feedAddress))
+    }
+
+    if (historyItem.feedIdentity) {
+      this.console.log(createKeyValue('Feed identity', historyItem.feedIdentity))
+    }
+  }
+}

src/command/upload.ts

@@ -15,6 +15,7 @@ import { createSpinner } from '../utils/spinner'
 import { createKeyValue, warningSymbol, warningText } from '../utils/text'
 import { RootCommand } from './root-command'
 import { VerbosityLevel } from './root-command/command-log'
+import { History } from '../service/history'
 
 export class Upload extends RootCommand implements LeafCommand {
   public readonly name = 'upload'
@@ -166,7 +167,8 @@ export class Upload extends RootCommand implements LeafCommand {
     const url = await this.uploadAnyWithSpinner(tag, uploadingFolder)
 
     this.console.dim('Data has been sent to the Bee node successfully!')
-    this.console.log(createKeyValue('Swarm hash', this.result.getOrThrow().toHex()))
+    const swarmHash = this.result.getOrThrow().toHex()
+    this.console.log(createKeyValue('Swarm hash', swarmHash))
 
     if (this.act) {
       this.console.log(createKeyValue('Swarm history address', this.historyAddress.getOrThrow().toHex()))
@@ -180,6 +182,18 @@ export class Upload extends RootCommand implements LeafCommand {
     this.console.dim('Uploading was successful!')
     this.console.log(createKeyValue('URL', url))
 
+    const history = new History(this.commandConfig.configFolderPath, this.console)
+
+    if (!usedFromOtherCommand) {
+      history.addItem({
+        timestamp: Date.now(),
+        reference: swarmHash,
+        stamp: this.stamp,
+        path: this.path,
+        uploadType: this.path ? 'file' : 'stdin',
+      })
+    }
+
     if (!usedFromOtherCommand) {
       this.console.quiet(this.result.getOrThrow().toHex())
 

src/config.ts

@@ -17,6 +17,7 @@ import { Status } from './command/status'
 import { Upload } from './command/upload'
 import { Utility } from './command/utility'
 import { Wallet } from './command/wallet'
+import { History } from './command/history'
 
 export const beeApiUrl: IOption<string> = {
   key: 'bee-api-url',
@@ -133,4 +134,5 @@ export const rootCommandClasses = [
   Utility,
   Grantee,
   Quickstart,
+  History,
 ]

src/service/history/index.ts

@@ -0,0 +1,48 @@
+import { existsSync, readFileSync, writeFileSync } from 'fs'
+import { join } from 'path'
+import { HistoryItem } from './types/historyItem'
+import { exit } from 'process'
+import { CommandLog } from '../../command/root-command/command-log'
+
+export class History {
+  public configFolderPath: string
+  private console: CommandLog
+
+  constructor(configFolderPath: string, console: CommandLog) {
+    this.configFolderPath = configFolderPath
+    this.console = console
+  }
+
+  public getItems(): HistoryItem[] {
+    const historyFilePath = this.getHistoryFilePath()
+
+    if (!existsSync(historyFilePath)) {
+      return []
+    }
+    const historyData = readFileSync(historyFilePath)
+    try {
+      const historyList = JSON.parse(historyData.toString()) as HistoryItem[]
+
+      return historyList
+    } catch (err) {
+      this.console.error(`There has been an error parsing history JSON from path: '${historyFilePath}'`)
+
+      exit(1)
+    }
+  }
+
+  public getItemByIndex(index: number): HistoryItem | undefined {
+    return this.getItems().find((item: HistoryItem) => item.index === index)
+  }
+
+  public addItem(item: HistoryItem) {
+    const history = this.getItems()
+    item.index = history.length + 1
+    history.push(item)
+    writeFileSync(this.getHistoryFilePath(), JSON.stringify(history))
+  }
+
+  public getHistoryFilePath(): string {
+    return join(this.configFolderPath, 'upload-history.json')
+  }
+}