feat: track datamode so connection; on error no loop (#41)

README.md

@@ -1,4 +1,5 @@
-# Denomailer - an SMTP client for Deno 
+# Denomailer - an SMTP client for Deno
+
 [![deno module](https://shield.deno.dev/x/denomailer)](https://deno.land/x/denomailer)
 
 > This was forked from https://github.com/manyuanrong/deno-smtp but now is much

client/basic/client.ts

@@ -72,6 +72,7 @@ export class SMTPClient {
 
   async send(config: ResolvedSendConfig) {
     await this.#ready;
+    let dataMode = false;
     try {
       await this.#que.que();
 
@@ -117,6 +118,7 @@ export class SMTPClient {
         );
       }
 
+      dataMode = true;
       await this.#connection.writeCmd("DATA");
       this.#connection.assertCode(
         await this.#connection.readCmd(),
@@ -318,9 +320,17 @@ export class SMTPClient {
         await this.#connection.readCmd(),
         CommandCode.OK,
       );
+      dataMode = false;
       await this.#cleanup();
       this.#que.next();
     } catch (ex) {
+      if (dataMode) {
+        console.error("Error while in datamode - connection not revoverable");
+        queueMicrotask(() => {
+          this.#connection.conn?.close();
+        });
+        throw ex;
+      }
       await this.#cleanup();
       this.#que.next();
       throw ex;

client/basic/connection.ts

@@ -77,8 +77,9 @@ export class SMTPConnection {
     }
 
     const nonNullResult: string[] =
-      (result.at(-1) === null ? result.slice(0, result.length - 1) : // deno-lint-ignore no-explicit-any
-        result) as any;
+      (result.at(-1) === null
+        ? result.slice(0, result.length - 1) // deno-lint-ignore no-explicit-any
+        : result) as any;
 
     if (nonNullResult.length === 0) return null;