ephemeraHQ · humanagent · Dec 28, 2024 · Dec 23, 2024 · Dec 23, 2024 · Dec 24, 2024
diff --git a/README.md b/README.md
@@ -2,8 +2,6 @@
 
 A set of tools for AI developers to build on top of [XMTP](https://xmtp.org)
 
-## What's inside?
-
 ### MessageKit
 
 - [`message-kit`](/packages/message-kit): A kit for quickly building messaging apps

diff --git a/community/plugins.json b/community/plugins.json
@@ -90,13 +90,6 @@
     "icon": "📒",
     "author": "humanagent"
   },
-  {
-    "href": "/plugins/xmtp",
-    "title": "xmtp",
-    "description": "Use Xmtp to send E2EE messages.",
-    "icon": "💬",
-    "author": "ephemeraHQ"
-  },
   {
     "href": "/plugins/xmtp-groups",
     "title": "Xmtp Groups",

diff --git a/package.json b/package.json
@@ -32,6 +32,7 @@
     "templates": "node scripts/devTemplates.js",
     "test": "FORCE_COLOR=1 turbo run test --force --concurrency=1",
     "test:client": "cd packages/xmtp/tests && yarn test:client",
+    "test:e2e": "cd packages/xmtp/tests && yarn test:e2e",
     "test:flow": "cd packages/message-kit/tests && yarn test:flow",
     "test:intent": "cd packages/message-kit/tests && yarn test:intent",
     "test:links": "cd packages/message-kit/tests && yarn test:links",

diff --git a/packages/client/src/components/Chat.module.css b/packages/client/src/components/Chat.module.css
@@ -169,16 +169,13 @@
 }
 
 .urlContainer {
-  margin: 8px 0;
   display: flex;
   flex-direction: column;
-  gap: 8px;
+  border-radius: 8px 8px 0 0;
   max-width: 300px;
-  background: #e0e0e0;
 }
 
 .urlPreview {
-  border-radius: 8px 8px 0 0;
   overflow: hidden;
   background: #ffffff;
   border: 1px solid #b0b0b0;
@@ -231,3 +228,11 @@
   color: var(--accent);
   font-size: 0.9rem;
 }
+.encryptionInfo {
+  text-align: center !important;
+  width: 100%;
+  font-size: 0.7rem;
+  padding: 0rem;
+  padding-top: 0.4rem;
+  display: block !important;
+}
diff --git a/packages/client/src/components/Chat.tsx b/packages/client/src/components/Chat.tsx
@@ -37,8 +37,6 @@ function Chat({ user }: { user: UserInfo }) {
   const [processedMessageIds] = useState(new Set<string>());
 
   useEffect(() => {
-    console.log("useEffect triggered with user:", user);
-
     const init = async () => {
       try {
         setRecipientInfo(user);
@@ -64,7 +62,6 @@ function Chat({ user }: { user: UserInfo }) {
 
   const onMessage = async (message: Message | undefined) => {
     if (message) {
-      console.log("onMessage", message);
       setMessages((prevMessages) => [...prevMessages, message]);
     }
   };
@@ -88,7 +85,6 @@ function Chat({ user }: { user: UserInfo }) {
         receivers: [recipientInfo.address],
         originalMessage: undefined,
       })) as Message;
-      console.log("message", message);
 
       setMessages((prevMessages) => [...prevMessages, message]);
       setNewMessage("");
@@ -144,17 +140,19 @@ function Chat({ user }: { user: UserInfo }) {
       if (urlRegex.test(part)) {
         try {
           const urlType = getUrlType(part);
-          const isMessageKitUrl = part.includes("message-kit.org");
-
+          const isMessageKitUrl =
+            part.includes("message-kit.org") ||
+            part.includes("baselinks.vercel.app");
+          const isMobile = window.innerWidth < 768;
           return (
             <div key={index} className={styles.urlContainer}>
-              {isMessageKitUrl && <UrlPreview url={part} urlType={urlType} />}
+              {isMessageKitUrl && <UrlPreview url={part} />}
               <div className={styles.buttonContainer}>
                 {urlType === "payment" && (
                   <button
                     onClick={() => {
                       const ethUrl = ethereumURL(part);
-                      openUrl(ethUrl);
+                      isMobile ? openUrl(ethUrl) : alert("Not on mobile");
                     }}
                     className={styles.urlButton}>
                     Pay in USDC
@@ -248,6 +246,9 @@ function Chat({ user }: { user: UserInfo }) {
             Send
           </button>
         </div>
+        <div className={styles.encryptionInfo}>
+          End-to-end encrypted powered by XMTP
+        </div>
       </form>
     </div>
   );

diff --git a/packages/client/src/components/UrlPreview.tsx b/packages/client/src/components/UrlPreview.tsx
@@ -8,13 +8,7 @@ interface OgData {
   url?: string;
 }
 
-export const UrlPreview = ({
-  url,
-  urlType,
-}: {
-  url: string;
-  urlType?: string;
-}) => {
+export const UrlPreview = ({ url }: { url: string; urlType?: string }) => {
   const [ogData, setOgData] = useState<OgData | null>(null);
   const [loading, setLoading] = useState(true);
 

diff --git a/packages/create-message-kit/package.json b/packages/create-message-kit/package.json
@@ -36,4 +36,4 @@
     "access": "public",
     "registry": "https://registry.npmjs.org/"
   }
-}
+}
diff --git a/packages/docs/pages/concepts/xmtp.mdx b/packages/docs/pages/concepts/xmtp.mdx
@@ -2,7 +2,7 @@
 
 [XMTP](https://xmtp.org/) is the protocol that MessageKit uses to send and receive messages.
 
-> Check out the [XMTP AI](/plugins/xmtp) plugins for more information.
+> Check out the [xmtp e2ee](https://docs-xmtp-org-git-agents-ephemerahq.vercel.app/agents/pluginxmtp) plugins for more information.
 
 ## Context
 

diff --git a/packages/docs/pages/plugins/xmtp.mdx b/packages/docs/pages/plugins/xmtp.mdx
diff --git a/packages/xmtp-e2ee/README.md b/packages/xmtp-e2ee/README.md
@@ -1,6 +1,6 @@
 # XMTP
 
-> See [XMTP AI](https://message-kit.org/plugins/xmtp) plugin
+> See [xmtp e2ee](https://docs-xmtp-org-git-agents-ephemerahq.vercel.app/agents/plugins) plugins
 
 ### Installation
 

diff --git a/packages/xmtp-e2ee/package.json b/packages/xmtp-e2ee/package.json
@@ -1,6 +1,6 @@
 {
   "name": "xmtp-e2ee",
-  "version": "0.0.8",
+  "version": "0.0.9",
   "license": "MIT",
   "type": "module",
   "exports": {
@@ -61,4 +61,4 @@
     "access": "public",
     "registry": "https://registry.npmjs.org/"
   }
-}
+}
diff --git a/packages/xmtp-e2ee/src/lib/xmtp.ts b/packages/xmtp-e2ee/src/lib/xmtp.ts
@@ -237,7 +237,8 @@ async function streamMessages(
   while (true) {
     try {
       const stream = await client.conversations.streamAllMessages();
-      console.log(`Stream started`);
+      console.log(`XMTP: [v2] Stream started`);
+
       for await (const message of stream) {
         if (message) {
           try {

diff --git a/packages/xmtp/README.md b/packages/xmtp/README.md
@@ -1,6 +1,6 @@
 # XMTP
 
-> See [XMTP AI](https://message-kit.org/plugins/xmtp) plugin
+> See [xmtp e2ee](https://docs-xmtp-org-git-agents-ephemerahq.vercel.app/agents/plugins) plugin
 
 ### Installation
 

diff --git a/packages/xmtp/package.json b/packages/xmtp/package.json
@@ -1,6 +1,6 @@
 {
   "name": "xmtp",
-  "version": "0.0.8",
+  "version": "0.0.9",
   "license": "MIT",
   "type": "module",
   "exports": {
@@ -22,7 +22,8 @@
     "clean": "rm -rf .turbo && rm -rf node_modules && rm -rf dist",
     "publish": "npm publish",
     "test": "yarn build && vitest",
-    "test:client": "vitest run tests/client"
+    "test:client": "vitest run tests/client",
+    "test:e2e": "vitest run tests/encryption"
   },
   "dependencies": {
     "@changesets/changelog-git": "^0.2.0",
@@ -59,4 +60,4 @@
     "access": "public",
     "registry": "https://registry.npmjs.org/"
   }
-}
+}
diff --git a/packages/message-kit/src/lib/skills.ts b/packages/message-kit/src/lib/skills.ts
 export function findSkill(text: string, skills: Skill[][]): Skill | undefined {
  const trigger = text.split(" ")[0].toLowerCase();

  const handler = skills.flat().find((skill) => {
    return (
      "/" + skill.skill?.replace("/", "").split(" ")[0].toLowerCase() ===
      trigger
diff --git a/packages/message-kit/tests/Intent.test.ts b/packages/message-kit/tests/Intent.test.ts

 describe("Flow Tests", async () => {
  afterEach(() => {
    console.log("chatMemory", chatMemory.getHistory(memoryKey).length);
  });
  afterAll(() => {
    console.log("chatMemory", chatMemory.getHistory(memoryKey));
    // @ts-ignore
    const { reply } = await agentReply(mockReply);
    chatMemory.addEntry(mockReply.getMemoryKey(), reply, "assistant");
    expect(reply).toContain("/info vitalik.eth");
  });

  const prompts = [
        // @ts-ignore
        const { reply } = await agentReply(mockReply);
        chatMemory.addEntry(mockReply.getMemoryKey(), reply, "assistant");
        expect(reply).toContain("/tip vitalik.eth");
      },
    );
  }
-Original file line number
+Diff line change
@@ @@ -36,4 +36,4 @@ @@
         "access": "public",
         "registry": "https://registry.npmjs.org/"
       }
-    }
+    }
	export function findSkill(text: string, skills: Skill[][]): Skill \| undefined {
	const trigger = text.split(" ")[0].toLowerCase();

	const handler = skills.flat().find((skill) => {
Check failure on line 11 in packages/message-kit/src/lib/skills.ts GitHub Actions / test tests/Parsing.test.ts > Parsing tests > Compare extracted values from skill: /check vitalik.eth `TypeError: Cannot read properties of undefined (reading 'flat') ❯ Module.findSkill src/lib/skills.ts:11:26 ❯ tests/Parsing.test.ts:53:27` Check failure on line 11 in packages/message-kit/src/lib/skills.ts GitHub Actions / test tests/Parsing.test.ts > Parsing tests > Compare extracted values from skill: /register vitalik.eth `TypeError: Cannot read properties of undefined (reading 'flat') ❯ Module.findSkill src/lib/skills.ts:11:26 ❯ tests/Parsing.test.ts:53:27` Check failure on line 11 in packages/message-kit/src/lib/skills.ts GitHub Actions / test tests/Parsing.test.ts > Parsing tests > Compare extracted values from skill: /cool vitalik.eth `TypeError: Cannot read properties of undefined (reading 'flat') ❯ Module.findSkill src/lib/skills.ts:11:26 ❯ tests/Parsing.test.ts:53:27` Check failure on line 11 in packages/message-kit/src/lib/skills.ts GitHub Actions / test tests/Parsing.test.ts > Parsing tests > Compare extracted values from skill: /renew vitalik.eth `TypeError: Cannot read properties of undefined (reading 'flat') ❯ Module.findSkill src/lib/skills.ts:11:26 ❯ tests/Parsing.test.ts:53:27` Check failure on line 11 in packages/message-kit/src/lib/skills.ts GitHub Actions / test tests/Parsing.test.ts > Parsing tests > Compare extracted values from skill: /info vitalik.eth `TypeError: Cannot read properties of undefined (reading 'flat') ❯ Module.findSkill src/lib/skills.ts:11:26 ❯ tests/Parsing.test.ts:53:27` Check failure on line 11 in packages/message-kit/src/lib/skills.ts GitHub Actions / test tests/Parsing.test.ts > Parsing tests > Compare extracted values from skill: /pay vitalik.eth `TypeError: Cannot read properties of undefined (reading 'flat') ❯ Module.findSkill src/lib/skills.ts:11:26 ❯ tests/Parsing.test.ts:53:27`
	return (
	"/" + skill.skill?.replace("/", "").split(" ")[0].toLowerCase() ===
	trigger

	describe("Flow Tests", async () => {
	afterEach(() => {
	console.log("chatMemory", chatMemory.getHistory(memoryKey).length);
Check failure on line 18 in packages/message-kit/tests/Intent.test.ts GitHub Actions / test tests/Intent.test.ts > Flow Tests > Ask who holds vitalik.eth `TypeError: Cannot read properties of undefined (reading 'length') ❯ tests/Intent.test.ts:18:62` Check failure on line 18 in packages/message-kit/tests/Intent.test.ts GitHub Actions / test tests/Intent.test.ts > Flow Tests > Step 1: Tip vitalik.eth `TypeError: Cannot read properties of undefined (reading 'length') ❯ tests/Intent.test.ts:18:62` Check failure on line 18 in packages/message-kit/tests/Intent.test.ts GitHub Actions / test tests/Intent.test.ts > Flow Tests > Step 2: again `TypeError: Cannot read properties of undefined (reading 'length') ❯ tests/Intent.test.ts:18:62` Check failure on line 18 in packages/message-kit/tests/Intent.test.ts GitHub Actions / test tests/Intent.test.ts > Flow Tests > Step 3: Tip vitalik.eth again `TypeError: Cannot read properties of undefined (reading 'length') ❯ tests/Intent.test.ts:18:62` Check failure on line 18 in packages/message-kit/tests/Intent.test.ts GitHub Actions / test tests/Intent.test.ts > Flow Tests > Step 4: Tip it again `TypeError: Cannot read properties of undefined (reading 'length') ❯ tests/Intent.test.ts:18:62`
	});
	afterAll(() => {
	console.log("chatMemory", chatMemory.getHistory(memoryKey));
	// @ts-ignore
	const { reply } = await agentReply(mockReply);
	chatMemory.addEntry(mockReply.getMemoryKey(), reply, "assistant");
	expect(reply).toContain("/info vitalik.eth");
Check failure on line 29 in packages/message-kit/tests/Intent.test.ts GitHub Actions / test tests/Intent.test.ts > Flow Tests > Ask who holds vitalik.eth `AssertionError: expected 'An error occurred while processing yo…' to contain '/info vitalik.eth' Expected: "/info vitalik.eth" Received: "An error occurred while processing your request." ❯ tests/Intent.test.ts:29:19`
	});

	const prompts = [
	// @ts-ignore
	const { reply } = await agentReply(mockReply);
	chatMemory.addEntry(mockReply.getMemoryKey(), reply, "assistant");
	expect(reply).toContain("/tip vitalik.eth");
Check failure on line 53 in packages/message-kit/tests/Intent.test.ts GitHub Actions / test tests/Intent.test.ts > Flow Tests > Step 1: Tip vitalik.eth `AssertionError: expected 'An error occurred while processing yo…' to contain '/tip vitalik.eth' Expected: "/tip vitalik.eth" Expected: "/tip vitalik.eth" Expected: "/tip vitalik.eth" Expected: "/tip vitalik.eth"
	},
	);
	}