feat : add clear() to delete all key value pairs

Author: nuzulul

README.md

@@ -77,6 +77,7 @@ void async function main() {
 	console.log(await db.list())
 	console.log(await db.delete('key'))
 	console.log(await db.has('key'))
+	console.log(await db.clear())
 }()
 ```
 
@@ -95,6 +96,7 @@ void async function main() {
 	console.log(await db.list())
 	console.log(await db.delete('key'))
 	console.log(await db.has('key'))
+	console.log(await db.clear())
 }()
 ```
 ```javascript
@@ -113,6 +115,7 @@ void async function main() {
 	console.log(await db.list())
 	console.log(await db.delete('key'))
 	console.log(await db.has('key'))
+	console.log(await db.clear())
 }()
 </script>
 ```
@@ -133,6 +136,7 @@ void async function main() {
 	console.log(await db.list())
 	console.log(await db.delete('key'))
 	console.log(await db.has('key'))
+	console.log(await db.clear())
 }()
 </script>
 ```
@@ -151,6 +155,7 @@ void async function main() {
 	console.log(await db.list())
 	console.log(await db.delete('key'))
 	console.log(await db.has('key'))
+	console.log(await db.clear())
 }()
 ```
 
@@ -173,6 +178,7 @@ export default {
 		data.push(await db.has('key'))
 		data.push(await db.list())
 		data.push(await db.delete('key'))
+		data.push(await db.clear())
 		return new Response(JSON.stringify(data, null, 2)) 
 	} 
 }
@@ -240,9 +246,16 @@ To delete a key-value pair, call the delete() method, resolve to `true` or `fals
 ```javascript
 await has(key)
 ```
-
 To check for the existence of a key, resolve to `true` or `false`
 
+### Clear storage
+
+```javascript
+await clear()
+```
+To delete all key value pairs, resolve to `true` or `false`
+
+
 ## License
 
 [MIT](https://github.com/nuzulul/kv-storage/blob/main/LICENSE)

src/kv-storage-module.ts

@@ -87,11 +87,11 @@ export class KVStorageModule{
 			const keyFilePath = this._storageDir+'/'+key
 
 				  fs.unlink(keyFilePath,(err)=>{
-            if (err) {
-              fs.stat(keyFilePath, (err)=>{
-                if (err) {resolve(true)}else{resolve(false)}
-              });
-            }else{resolve(true)}
+						if (err) {
+						  fs.stat(keyFilePath, (err)=>{
+							if (err) {resolve(true)}else{resolve(false)}
+						  });
+						}else{resolve(true)}
 				  });
 
 		})
@@ -122,4 +122,24 @@ export class KVStorageModule{
 			  });
 		})
 	}
+	
+	public async clear(){
+		return new Promise((resolve) => {
+			  fs.readdir(this._storageDir,(err,files)=>{
+				if (err) {resolve(false)}else{
+
+					let success = true
+					for (const file of files){
+						const keyFilePath = this._storageDir+'/'+file
+						fs.unlink(keyFilePath,(err)=>{
+							if (err) success = false
+						});
+					}
+					resolve(success)
+					
+				}
+			  });
+		})
+	}	
+	
 }

src/kv-storage.ts

@@ -232,6 +232,15 @@ class KVStorageCloudflare{
 			}
 			return output
 	}
+
+	public async clear(){
+			
+			const stmt = this._databaseBinding.prepare('DELETE FROM '+this._storageName);
+			const values = await stmt.run();
+			return values.success				
+		
+	}
+
 }
 
 class KVStorageBrowser{
@@ -400,4 +409,19 @@ class KVStorageBrowser{
 			}
 		})
 	}
+
+	public async clear(){
+		return new Promise((resolve) => {
+			let transaction = this._iDB.transaction(this._storageName, "readwrite")
+			let request = transaction.objectStore(this._storageName).clear()
+			request.onsuccess = function(event) {
+				resolve(true)
+			}
+			request.onerror = function() {
+				resolve(false)
+			}
+				
+		})
+	}
+
 }

test/test-unit.ts

@@ -41,6 +41,21 @@ export async function test(db:any){
 		obj={delete:await db.delete('yesyes'),expected: true}
 		if(obj.delete == obj.expected){obj.passed = true}else{obj.passed = false}				
 		data.push(obj)
+
+		//test for create new kv
+		obj={put:await db.put('yesyesyes','no'),expected: true}
+		if(obj.put == obj.expected){obj.passed = true}else{obj.passed = false}
+		data.push(obj)
+
+		//test for clear all kv
+		obj={clear:await db.clear(),expected: true}
+		if(obj.clear == obj.expected){obj.passed = true}else{obj.passed = false}
+		data.push(obj)
+
+		//test list empty storage
+		obj={list:await db.list(),expected:{keys:[],complete:true}}
+		if(JSON.stringify(obj.list) == JSON.stringify(obj.expected)){obj.passed = true}else{obj.passed = false}		
+		data.push(obj)
 
 		return JSON.stringify(data, null, 2)
 }