fix(dir methods): rm

README.md

@@ -41,7 +41,6 @@ Require in the same format as Node.js `fs`, specifying an S3 Bucket:
 - [ ] fs.rmdir(path, callback)
 - [ ] fs.rm(path, callback)
 - [ ] fs.unlink(path, callback)
-- [ ] fs.lstat(path, callback)
 - [ ] fs.createReadStream(path, [options])
 - [ ] fs.createWriteStream(path, [options])
 

src/CyclicS3FSPromises.js

@@ -4,7 +4,8 @@ const {
  PutObjectCommand,
  HeadObjectCommand,
  ListObjectsCommand,
- ListObjectsV2Command
+ ListObjectsV2Command,
+ DeleteObjectCommand
 } = require("@aws-sdk/client-s3");
 const _path = require('path')
 const {Stats} = require('fs')
@@ -68,9 +69,10 @@ class CyclicS3FSPromises{
  }
 
  async stat(fileName, data, options={}){
+ fileName = util.normalize_path(fileName)
  const cmd = new HeadObjectCommand({
  Bucket: this.bucket,
- Key: util.normalize_path(fileName)
+ Key: fileName
  })
  let result;
  try{
@@ -121,7 +123,7 @@ class CyclicS3FSPromises{
 
  async readdir(path){
  path = util.normalize_dir(path)
- const cmd = new ListObjectsCommand({
+ const cmd = new ListObjectsV2Command({
  Bucket: this.bucket,
  // StartAfter: path,
  Prefix: path,
@@ -153,6 +155,36 @@ class CyclicS3FSPromises{
  return result
  }
 
+ async rm(path){
+ try{
+ let f = await this.stat(path)
+ }catch(e){
+ throw e
+ }
+ path = util.normalize_path(path)
+ const cmd = new DeleteObjectCommand({
+ Bucket: this.bucket,
+ Key: path
+ })
+ try{
+ await this.s3.send(cmd)
+ }catch(e){
+ console.error(e)
+ }
+
+ }
+
+
+// async rmdir(path){
+// path = util.normalize_dir(path)
+// try{
+// let await readdir(path)
+// // await this.s3.send(cmd)
+// }catch(e){
+// throw e
+// }
+// }
+
 }
 
 

src/index.js

@@ -98,6 +98,18 @@ class CyclicS3FS extends CyclicS3FSPromises {
  })
  }
 
+ rm(path, callback) {
+ callback = makeCallback(arguments[arguments.length - 1]);
+ new Promise(async (resolve,reject)=>{
+ try{
+ let res = await super.rm(...arguments)
+ return resolve(callback(null,res))
+ }catch(e){
+ return resolve(callback(e))
+ }
+ })
+ }
+
 
  readFileSync(fileName) {
  return sync_interface.runSync(this,'readFile',[fileName])
@@ -130,6 +142,10 @@ class CyclicS3FS extends CyclicS3FSPromises {
  return sync_interface.runSync(this,'mkdir',[path])
  }
 
+ rmSync(path) {
+ return sync_interface.runSync(this,'rm',[path])
+ }
+
 }