added cleanSession option, defaults to false, set clientId to fromId

package.json

 {
   "name": "usp-js",
-  "version": "0.4.7",
+  "version": "0.4.8",
   "description": "Library for easy usp(TR-369) communication using mqtt or ws.",
   "main": "node/index.js",
   "browser": "web/index.js",

src/configurations/mqtt.ts

@@ -16,8 +16,15 @@ import { jsonRoots } from "./util";
 export const isURL = (opts: ConnectionOptions): opts is URLConnectionOptions =>
   "url" in opts;
 
-export const connectClient: ConnectClientFn = async (opts) =>
-  isURL(opts)
+const correctOptions = (opts: ConnectionOptions): ConnectionOptions => ({
+  ...opts,
+  clientId: opts.clientId || opts.fromId,
+  clean: opts.cleanSession ?? false,
+});
+
+export const connectClient: ConnectClientFn = async (initialOpts) => {
+  const opts = correctOptions(initialOpts);
+  return isURL(opts)
     ? (mqttAsync.connectAsync(
         opts.url,
         opts as any
@@ -31,6 +38,7 @@ export const connectClient: ConnectClientFn = async (opts) =>
           : {}),
       } as any) as unknown as ConnectionClient)
     : (mqttAsync.connectAsync(opts) as unknown as ConnectionClient);
+};
 
 export const loadProtobuf = async (version: USPVersion): Promise<Proto> => {
   const [rootRecordJson, rootMsgJson] = jsonRoots[version];

src/types.ts

@@ -765,6 +765,10 @@ export interface MainConnectionOptions {
    */
   connectTimeout?: number;
   clientId?: string;
+  /**
+   * Defaults to false
+   */
+  cleanSession?: boolean;
   /**
    * Allows passing additional options to the underlying connection library
    */