feat: move files to v0.0.1, jest config in ts and validateMessage function call before sending a message

jest.config.js → jest.config.ts

@@ -1,4 +1,6 @@
-module.exports = {
+import type { Config } from "@jest/types";
+
+const config: Config.InitialOptions = {
   preset: "ts-jest",
   testEnvironment: "node",
   collectCoverage: true,
@@ -15,3 +17,4 @@ module.exports = {
   modulePaths: ["<rootDir>"],
   moduleDirectories: ["node_modules"]
 };
+export default config;

package.json

@@ -12,6 +12,7 @@
     "lint": "eslint --ignore-path .gitignore --ext .js,.ts .",
     "lint:fix": "npm run lint -- --fix",
     "prettier": "prettier --write .",
+    "test": "npm run test:all",
     "test:all": "jest --detectOpenHandles --forceExit",
     "test:unit": "jest '/tests/unit/' --coverage=false",
     "test:integration": "jest '/tests/integration/' --coverage=false --detectOpenHandles --forceExit",
@@ -32,7 +33,9 @@
   },
   "dependencies": {
     "@xmtp/xmtp-js": "^5.4.0",
-    "ethers": "^5.6.9"
+    "ethers": "^5.6.9",
+    "valid-data-url": "^4.0.1",
+    "yup": "^0.32.11"
   },
   "devDependencies": {
     "@semantic-release/changelog": "^6.0.1",

src/example/index.ts

@@ -6,7 +6,7 @@ import {
   MessageType,
   SupportedFileMimeTypes,
   ThreadObject
-} from "../util/definitions";
+} from "../util/v0.0.1/definitions";
 
 // This is just a playground for development of the SDK
 async function main() {

src/index.ts

@@ -13,13 +13,14 @@ import {
   MessageObject,
   ThreadId,
   ThreadObject
-} from "./util/definitions";
+} from "./util/v0.0.1/definitions";
 import {
   getAuthorityId,
   isValidJsonString,
   isValidMessageType,
   matchThreadIds
-} from "./util/functions";
+} from "./util/v0.0.1/functions";
+import { validateMessage } from "./util/validators";
 
 export class BosonXmtpClient extends XmtpClient {
   /**
@@ -144,6 +145,13 @@ export class BosonXmtpClient extends XmtpClient {
     recipient: string,
     fallBackDeepLink?: string
   ): Promise<MessageData> {
+    if (
+      !(await validateMessage(messageObject, {
+        throwError: true
+      }))
+    ) {
+      return;
+    }
     const jsonString: string = JSON.stringify(messageObject);
     const message: Message = await this.sendMessage(
       messageObject.contentType,

src/util/definitions.ts → src/util/v0.0.1/definitions.ts

@@ -1,3 +1,4 @@
+export const version = "0.0.1";
 export interface ThreadObject {
   threadId: ThreadId;
   counterparty: string;
@@ -21,7 +22,7 @@ export interface MessageData {
 export interface MessageObject {
   threadId: ThreadId;
   contentType: MessageType;
-  version: string;
+  version: typeof version;
   content: StringContent | FileContent | ProposalContent;
 }
 

src/util/functions.ts → src/util/v0.0.1/functions.ts

@@ -21,10 +21,7 @@ export function isValidJsonString(data: string): boolean {
  * @returns boolean
  */
 export function isValidMessageType(messageType: MessageType): boolean {
-  if (Object.values(MessageType).includes(messageType)) {
-    return true;
-  }
-  return false;
+  return Object.values(MessageType).includes(messageType);
 }
 
 /**
@@ -47,17 +44,13 @@ export function matchThreadIds(
   threadId1: ThreadId,
   threadId2: ThreadId
 ): boolean {
-  if (
+  return (
     isValidThreadId(threadId1) &&
     isValidThreadId(threadId2) &&
     threadId1.exchangeId === threadId2.exchangeId &&
     threadId1.buyerId === threadId2.buyerId &&
     threadId1.sellerId === threadId2.sellerId
-  ) {
-    return true;
-  }
-
-  return false;
+  );
 }
 
 /**