added create room test

added send message test

src/create_room/create_room.ts

@@ -0,0 +1,22 @@
+import axios from "axios";
+const server = 'https://zeniq.chat/';
+
+/**
+ * TODO: document here
+ */
+export async function nomoCreateRoom(args: Map<string, any>, accessToken: string): Promise<string> {
+    const url = server + `_matrix/client/v3/createRoom`;
+
+    try {
+        const response = await axios.post(url, args, {
+            headers: {
+                'Authorization': `Bearer ${accessToken}`,
+                'Content-Type': 'application/json'
+            }
+        });
+        return response.data['room_id'];
+    } catch (error) {
+        console.error('Error sending message:', error);
+        return "";
+    }
+}

src/index.ts

@@ -3,6 +3,6 @@
 export {nomoRegisterOrLogin, UserMatrix, nomoLogin, nomoRegister} from "./register_login/register_login"
 export {nomoListenRoom} from "./listen_room/listen_room"
 export {nomoJoinRoom} from "./join_room/join_room"
-export {nomoSendMessage} from "./send_message/send_message"
+export {nomoSendMessage, SendMessageArgs} from "./send_message/send_message"
 export {nomoSyncUser} from "./syncing/sync_user"
 export {nomoCreateFilter} from "./syncing/create_filter"

src/send_message/send_message.ts

@@ -1,12 +1,29 @@
-
+import axios from "axios";
+const server = 'https://zeniq.chat/';
 export interface SendMessageArgs {
-    room: string;
-    content: string;
+    roomId: string;
+    content: Map<string, any>;
+    transationID: string;
+    eventType: string;
 }
 
 /**
  * TODO: document here
  */
-export async function nomoSendMessage(args: SendMessageArgs) {
-    console.log("nomoSendMessage not implemented");
+export async function nomoSendMessage(args: SendMessageArgs, accessToken: string): Promise<string> {
+    let { roomId, content, transationID, eventType } = args;
+    const url = server + `_matrix/client/v3/rooms/${roomId}/send/${eventType}/${transationID}`;
+
+    try {
+        const response = await axios.put(url, content, {
+            headers: {
+                'Authorization': `Bearer ${accessToken}`,
+                'Content-Type': 'application/json'
+            }
+        });
+        return response.data['event_id'];
+    } catch (error) {
+        console.error('Error sending message:', error);
+        return "";
+    }
 }

test/create_room_test/create_room.test.ts

@@ -0,0 +1,21 @@
+import { nomoRegisterOrLogin, UserMatrix, } from "../../src";
+import { nomoCreateRoom } from "../../src/create_room/create_room";
+import { generateRandomString } from "../test_util";
+
+test("create room", async () => {
+    const mnemonic = "diet say develop title sibling steel blast table chicken foster fuel giraffe";
+    const userMatrix: UserMatrix = await nomoRegisterOrLogin(mnemonic);
+    const args: Map<string, any> = new Map
+    {
+        [
+            ['name', generateRandomString(25)],
+            ["preset", "private_chat",],
+            ['room_alias_name', generateRandomString(10)]
+        ]
+    };
+    let roomId = await nomoCreateRoom(args, userMatrix.access_token);
+    console.log(roomId);
+    if (roomId.length == 0) {
+        fail("no roomId");
+    }
+});

test/send_message_test/send_message.test.ts

@@ -1,5 +1,38 @@
-import {nomoSendMessage} from "../../src";
+import { nomoSendMessage, nomoRegisterOrLogin, UserMatrix, SendMessageArgs } from "../../src";
+import { nomoCreateRoom } from "../../src/create_room/create_room";
+import { generateRandomString } from "../test_util";
 
 test("send message", async () => {
-    await nomoSendMessage({content: "foo", room: "bar"});
+    const mnemonic = "diet say develop title sibling steel blast table chicken foster fuel giraffe";
+    const userMatrix: UserMatrix = await nomoRegisterOrLogin(mnemonic);
+    const args: Map<string, any> = new Map
+    {
+        [
+            ['name', generateRandomString(25)],
+            ["preset", "private_chat",],
+            ['room_alias_name', generateRandomString(10)]
+        ]
+    };
+    let roomId = await nomoCreateRoom(args, userMatrix.access_token);
+    if (roomId.length == 0) {
+        fail("no roomId");
+    }
+    const contentMap: Map<string, any> = new Map
+    {
+        [
+            ['body', generateRandomString(25)],
+            ["msgtype", "m.text"],
+        ]
+    };
+    const testMessage: SendMessageArgs =
+    {
+        content: contentMap,
+        roomId: roomId,
+        transationID: generateRandomString(200),
+        eventType: "m.room.message",
+    };
+    let eventId = await nomoSendMessage(testMessage, userMatrix.access_token);
+    if (eventId.length == 0) {
+        fail("eventId empty");
+    }
 });

test/syncing/sync_user.test.ts

@@ -4,6 +4,6 @@ test("sync user", async () => {
     const mnemonic = "diet say develop title sibling steel blast table chicken foster fuel giraffe";
     const userMatrix: UserMatrix = await nomoRegisterOrLogin(mnemonic);
     // const filterID: string = await nomoCreateFilter(userMatrix.access_token, userMatrix.user_id);
-    // await nomoSyncUser(userMatrix.access_token, "", filterID, "online", false);
+    // await nomoSyncUser(userMatrix.access_token, "", '', "online", false);
     // expect(userMatrix.user_id).toBe("@0x3f0e8cF0c6eb9789348541D9D0Ce4ac847277e9B:zeniq.chat");
 }, 10000);