diff --git a/README.md b/README.md
index e7b3959..1b8d4f2 100644
--- a/README.md
+++ b/README.md
@@ -17,7 +17,7 @@ Then copy the contents of `./out` to your favorite static content host.
 
 ## Future Features
 
-- [ ] Two-way collaboration
+- [X] Two-way collaboration
 - [ ] File sharing
 - [ ] FAQ Page
 - [ ] Themes and Light/Dark support
diff --git a/global.d.ts b/global.d.ts
index 9252029..575a0f9 100644
--- a/global.d.ts
+++ b/global.d.ts
@@ -29,7 +29,7 @@ declare module "nostr-tools" {
         message: string
         sig: string
         tags: [[string, string]]
-      }) => Promise<void>
+      }) => void
       filter: Record<string, string[]>[]
     }) => {
       unsub: () => void
diff --git a/package.json b/package.json
index 8828564..987ff57 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "sendstr-web",
-  "version": "1.0.0",
+  "version": "1.1.0",
   "description": "",
   "main": "index.js",
   "scripts": {
diff --git a/src/lib/nostr.ts b/src/lib/nostr.ts
new file mode 100644
index 0000000..02dcd16
--- /dev/null
+++ b/src/lib/nostr.ts
@@ -0,0 +1,68 @@
+import { getRelays } from "./localStorage"
+import { NostrEventType, NostrKeysType, NostrPoolType } from "../types"
+
+export const getLatestEvent = (events: Record<string, NostrEventType>) =>
+  Object.entries(events).reduce((acc, x) => {
+    if (acc === null) return x[1]
+    if (new Date(acc.created_at) < new Date(x[1].created_at)) return x[1]
+    return acc
+  }, null as NostrEventType | null)
+
+export const getReceivePeerKey = (events: Record<string, NostrEventType>) =>
+  Object.entries(events).reduce((acc, x) => {
+    if (acc === null) return x[1]
+    if (new Date(acc.created_at) > new Date(x[1].created_at)) return x[1]
+    return acc
+  }, null as NostrEventType | null)?.pubkey
+
+export const subscribe = async (
+  keys: NostrKeysType,
+  peerKey: string,
+  cb: (event: NostrEventType) => void,
+) => {
+  const { decrypt } = await import("nostr-tools/nip04")
+  const { relayPool } = await import("nostr-tools")
+  const pool = relayPool()
+  pool.setPrivateKey(keys.priv)
+  const relays = getRelays()
+  relays.forEach((relay) => relay.enabled && pool.addRelay(relay.url, { read: true, write: true }))
+  const sub = pool.sub({
+    cb: (event: NostrEventType) => {
+      try {
+        const p = event.tags.find(([tag]) => tag === "p") || ["p", ""]
+        const pubkey = event.pubkey === keys.pub ? p[1] : event.pubkey
+        const message = decrypt(keys.priv, pubkey, event.content)
+        cb({ ...event, message })
+      } catch (e) {
+        console.warn(e)
+      }
+    },
+    filter: [{ "#p": [keys.pub, peerKey] }, { authors: [keys.pub, peerKey] }],
+  })
+  return { sub, pool }
+}
+
+type SendEncryptedMessage = {
+  pool: NostrPoolType | null
+  priv: string
+  pub: string
+  peerKey: string
+  message: string
+}
+
+export const sendEncryptedMessage = async ({
+  pool,
+  priv,
+  pub,
+  peerKey,
+  message,
+}: SendEncryptedMessage) => {
+  const { encrypt } = await import("nostr-tools/nip04")
+  return pool?.publish({
+    pubkey: pub,
+    created_at: Math.round(Date.now() / 1000),
+    kind: 4,
+    tags: [["p", peerKey]],
+    content: encrypt(priv, peerKey, message),
+  })
+}
diff --git a/src/pages/_app.tsx b/src/pages/_app.tsx
index c4af78b..bff7d05 100644
--- a/src/pages/_app.tsx
+++ b/src/pages/_app.tsx
@@ -1,70 +1,57 @@
 import "../styles/global.css"
 import { AppProps } from "next/app"
 import { useEffect, useState } from "react"
-import { getRelays } from "../lib/localStorage"
-import { NostrEventType, NostrType } from "../types"
+// import { getRelays } from "../lib/localStorage"
+// import { NostrEventType, NostrType } from "../types"
 
 export default function App({ Component, pageProps }: AppProps) {
-  const [events, setEvents] = useState<{ [k: string]: NostrEventType }>({})
-  const [nostr, setNostr] = useState<NostrType>({
-    priv: "",
-    pub: "",
-    pool: null,
-    sub: null,
-  })
+  // const [events, setEvents] = useState<{ [k: string]: NostrEventType }>({})
+  // const [nostr, setNostr] = useState<NostrType>({
+  //   priv: "",
+  //   pub: "",
+  //   pool: null,
+  //   sub: null,
+  // })
+  const [keys, setKeys] = useState<{
+    pub: string
+    priv: string
+  } | null>(null)
 
-  const updateEvents = async (pub: string, priv: string, event: NostrEventType) => {
-    const { decrypt } = await import("nostr-tools/nip04")
-    try {
-      const p = event.tags.find(([tag]) => tag === "p") || ["p", ""]
-      const pubkey = event.pubkey === pub ? p[1] : event.pubkey
-      const message = decrypt(priv, pubkey, event.content)
-      setEvents({
-        ...events,
-        ...{
-          [event.id]: {
-            ...event,
-            message,
-          },
-        },
-      })
-    } catch (e) {
-      console.warn(e)
-    }
-  }
+  // const updateEvents = async (pub: string, priv: string, event: NostrEventType) => {
+  //   const { decrypt } = await import("nostr-tools/nip04")
+  //   try {
+  //     const p = event.tags.find(([tag]) => tag === "p") || ["p", ""]
+  //     const pubkey = event.pubkey === pub ? p[1] : event.pubkey
+  //     const message = decrypt(priv, pubkey, event.content)
+  //     setEvents({
+  //       ...events,
+  //       ...{
+  //         [event.id]: {
+  //           ...event,
+  //           message,
+  //         },
+  //       },
+  //     })
+  //   } catch (e) {
+  //     console.warn(e)
+  //   }
+  // }
 
   useEffect(() => {
-    let sub: {
-      unsub: () => void
-    }
     void (async () => {
-      const { generatePrivateKey, relayPool, getPublicKey } = await import("nostr-tools")
+      const { generatePrivateKey, getPublicKey } = await import("nostr-tools")
       const priv = generatePrivateKey()
       const pub = getPublicKey(priv)
-      const pool = relayPool()
-      pool.setPrivateKey(priv)
-      const relays = getRelays()
-      relays.forEach(
-        (relay) => relay.enabled && pool.addRelay(relay.url, { read: true, write: true }),
-      )
-      sub = pool.sub({
-        cb: (event: NostrEventType) => updateEvents(pub, priv, event),
-        filter: [{ "#p": [pub] }],
-      })
-      setNostr({ priv, pub, pool, sub })
+      setKeys({ priv, pub })
     })()
-
-    return () => {
-      sub.unsub()
-    }
   }, [])
 
-  const getLatestEvent = (events: Record<string, NostrEventType>) =>
-    Object.entries(events).reduce((acc, x) => {
-      if (acc === null) return x[1]
-      if (new Date(acc.created_at) < new Date(x[1].created_at)) return x[1]
-      return acc
-    }, null as NostrEventType | null)
+  // const getLatestEvent = (events: Record<string, NostrEventType>) =>
+  //   Object.entries(events).reduce((acc, x) => {
+  //     if (acc === null) return x[1]
+  //     if (new Date(acc.created_at) < new Date(x[1].created_at)) return x[1]
+  //     return acc
+  //   }, null as NostrEventType | null)
 
-  return <Component {...{ ...pageProps, nostr, event: getLatestEvent(events) }} />
+  return <Component {...{ ...pageProps, keys }} />
 }
diff --git a/src/pages/index.tsx b/src/pages/index.tsx
index 5cacda5..ccb6eb9 100644
--- a/src/pages/index.tsx
+++ b/src/pages/index.tsx
@@ -6,14 +6,13 @@ import { Button } from "../components/button"
 import { Card } from "../components/card"
 import { SendView } from "../views/send"
 import { ReceiveView } from "../views/receive"
-import { NostrEventType, NostrType } from "../types"
+import { NostrKeysType } from "../types"
 
 type HomeProps = {
-  nostr: NostrType
-  event: NostrEventType
+  keys: NostrKeysType
 }
 
-export default function Home({ nostr, event }: HomeProps) {
+export default function Home({ keys }: HomeProps) {
   const [clientType, setClientType] = useState("")
 
   const LandingView = () => (
@@ -46,9 +45,9 @@ export default function Home({ nostr, event }: HomeProps) {
   const Page = () => {
     switch (true) {
       case clientType === "send":
-        return <SendView nostr={nostr} />
+        return <SendView keys={keys} />
       case clientType === "receive":
-        return <ReceiveView nostr={nostr} event={event} />
+        return <ReceiveView keys={keys} />
       default:
         return <LandingView />
     }
diff --git a/src/types.ts b/src/types.ts
index f2865c6..81fdf0e 100644
--- a/src/types.ts
+++ b/src/types.ts
@@ -1,4 +1,4 @@
-export type NostrSub = ({
+export type NostrSubType = ({
   cb,
   filter,
 }: {
@@ -11,13 +11,13 @@ export type NostrSub = ({
     message: string
     sig: string
     tags: [[string, string]]
-  }) => Promise<void>
+  }) => void
   filter: Record<string, string[]>[]
 }) => {
   unsub: () => void
 }
 
-export type NostrPublish = ({
+export type NostrPublishType = ({
   pubkey,
   created_at,
   kind,
@@ -31,17 +31,17 @@ export type NostrPublish = ({
   content: string
 }) => Promise<void>
 
-export type NostrPool = {
+export type NostrPoolType = {
   setPrivateKey: (priv: string) => void
   addRelay: (url: string, { read, write }: { read: boolean; write: boolean }) => void
-  sub: NostrSub
-  publish: NostrPublish
+  sub: NostrSubType
+  publish: NostrPublishType
 }
 
 export type NostrType = {
   priv: string
   pub: string
-  pool: NostrPool | null
+  pool: NostrPoolType | null
   sub: {
     unsub: () => void
   } | null
@@ -57,3 +57,8 @@ export type NostrEventType = {
   sig: string
   tags: [[string, string]]
 }
+
+export type NostrKeysType = {
+  pub: string
+  priv: string
+}
diff --git a/src/views/receive/index.tsx b/src/views/receive/index.tsx
index 80a4e7a..5e61476 100644
--- a/src/views/receive/index.tsx
+++ b/src/views/receive/index.tsx
@@ -1,32 +1,80 @@
 import { QRCodeSVG } from "qrcode.react"
+import { useEffect, useRef, useState } from "react"
 import Toastify from "toastify-js"
 import { Button } from "../../components/button"
 import { Card } from "../../components/card"
-import { NostrEventType, NostrType } from "../../types"
+import { getLatestEvent, getReceivePeerKey, sendEncryptedMessage, subscribe } from "../../lib/nostr"
+import { debounce } from "../../lib/utils"
+import { NostrEventType, NostrKeysType, NostrType } from "../../types"
 
-const Message = ({ event }: { event: NostrEventType }) => {
+type MessageProps = {
+  message: string
+  onChange: (x: string) => void
+}
+
+const Message = ({ message, onChange }: MessageProps) => {
   return (
-    <p className="bg-custom-green-dark border-2 border-custom-black rounded w-full p-3 whitespace-pre-wrap">
-      {event.message}
-    </p>
+    <section className="p-4">
+      <div className="border-0">
+        <textarea
+          className="bg-custom-green-dark border-2 border-custom-black rounded w-full min-h-[100px] max-h-[700px]"
+          value={message}
+          onChange={(e) => onChange(e.currentTarget.value || "")}
+        />
+      </div>
+    </section>
   )
 }
 
 type ReceiveViewProps = {
-  nostr: NostrType
-  event: NostrEventType
+  keys: NostrKeysType
 }
 
-export const ReceiveView = ({ nostr, event }: ReceiveViewProps) => {
+export const ReceiveView = ({ keys }: ReceiveViewProps) => {
+  const [peerKey, setPeerKey] = useState("")
+  const [message, setMessage] = useState("")
+  const events = useRef<{ [k: string]: NostrEventType } | null>(null)
+  const nostr = useRef<NostrType | null>(null)
+
+  const processEvent = (event: NostrEventType) => {
+    events.current = { ...events.current, ...{ [event.id]: event } }
+    setMessage(getLatestEvent(events?.current)?.message || "")
+    setPeerKey(getReceivePeerKey(events.current) || "")
+  }
+
+  useEffect(() => {
+    void (async () => {
+      const sub = await subscribe(keys, peerKey, processEvent)
+      nostr.current = { ...sub, ...keys }
+      return () => {
+        nostr?.current?.sub?.unsub()
+      }
+    })()
+  }, [peerKey])
+
+  const sendMessage = useRef(
+    // eslint-disable-next-line @typescript-eslint/no-misused-promises
+    debounce(async (peerKey: string, message: string) => {
+      if (nostr?.current?.pool) {
+        await sendEncryptedMessage({ ...nostr.current, peerKey, message })
+      }
+    }, 500),
+  ).current
+
+  const onMessageChange = (message: string) => {
+    setMessage(message)
+    sendMessage(peerKey, message)
+  }
+
   return (
     <div className="max-w-[64rem] m-auto">
       <Card>
         <div className="p-10">
           <div className="flex flex-col lg:flex-row">
-            {!event && (
+            {peerKey === "" && (
               <div className="overflow-visible py-5 max-w-[20rem] mx-auto lg:pr-5">
                 <QRCodeSVG
-                  value={nostr.pub}
+                  value={keys.pub}
                   level="H"
                   bgColor="transparent"
                   fgColor="#3C3744"
@@ -43,12 +91,12 @@ export const ReceiveView = ({ nostr, event }: ReceiveViewProps) => {
                   id="mypubkey"
                   className="border-2 border-custom-black rounded-md p-2 bg-custom-green-dark break-all"
                 >
-                  {nostr.pub}
+                  {keys.pub}
                 </div>
                 <div className="py-6 max-w-[20rem] m-auto">
                   <Button
                     onClick={() => {
-                      navigator.clipboard.writeText(nostr.pub).catch(console.warn)
+                      navigator.clipboard.writeText(keys.pub).catch(console.warn)
                       Toastify({
                         text: "Pubkey copied",
                         duration: 2000,
@@ -67,7 +115,7 @@ export const ReceiveView = ({ nostr, event }: ReceiveViewProps) => {
               </div>
             </div>
           </div>
-          <div>{event && <Message event={event} />}</div>
+          <div>{<Message message={message} onChange={onMessageChange} />}</div>
         </div>
       </Card>
     </div>
diff --git a/src/views/send/index.tsx b/src/views/send/index.tsx
index 8a4145b..366bc60 100644
--- a/src/views/send/index.tsx
+++ b/src/views/send/index.tsx
@@ -7,7 +7,8 @@ import { MdQrCodeScanner } from "react-icons/md"
 import { IconButton } from "../../components/icon-button"
 import { Card } from "../../components/card"
 import { debounce } from "../../lib/utils"
-import { NostrType } from "../../types"
+import { NostrEventType, NostrKeysType, NostrType } from "../../types"
+import { subscribe, sendEncryptedMessage, getLatestEvent } from "../../lib/nostr"
 
 type MessageProps = {
   message: string
@@ -55,43 +56,48 @@ const PeerInput = ({ peerKey, onChange, setShowScan }: PeerInputProps) => {
 }
 
 export type SendViewProps = {
-  nostr: NostrType
+  keys: NostrKeysType
 }
 
-export const SendView = ({ nostr }: SendViewProps) => {
+export const SendView = ({ keys }: SendViewProps) => {
   const [showScan, setShowScan] = useState(false)
   const [peerKey, setPeerKey] = useState("")
   const [message, setMessage] = useState("")
+  const events = useRef<{ [k: string]: NostrEventType } | null>(null)
+  const nostr = useRef<NostrType | null>(null)
 
   const ScanView = dynamic(async () => (await import("../scan")).ScanView)
 
+  const processEvent = (event: NostrEventType) => {
+    events.current = { ...events.current, ...{ [event.id]: event } }
+    setMessage(getLatestEvent(events?.current)?.message || "")
+  }
+
   useEffect(() => {
-    if (isMobile) {
-      setShowScan(true)
-    }
+    void (async () => {
+      if (isMobile) {
+        setShowScan(true)
+      }
+      const sub = await subscribe(keys, peerKey, processEvent)
+      nostr.current = { ...sub, ...keys }
+      return () => {
+        nostr?.current?.sub?.unsub()
+      }
+    })()
   }, [])
 
-  const sendNostrMessage = useRef(
+  const sendMessage = useRef(
     // eslint-disable-next-line @typescript-eslint/no-misused-promises
-    debounce(async (m: string, p: string, n: NostrType) => {
-      try {
-        const { encrypt } = await import("nostr-tools/nip04")
-        await n.pool?.publish({
-          pubkey: n.pub,
-          created_at: Math.round(Date.now() / 1000),
-          kind: 4,
-          tags: [["p", p]],
-          content: encrypt(n.priv, p, m),
-        })
-      } catch (e) {
-        console.warn(e)
+    debounce(async (peerKey: string, message: string) => {
+      if (nostr.current?.pool) {
+        await sendEncryptedMessage({ ...nostr.current, peerKey, message })
       }
-    }, 750),
+    }, 500),
   ).current
 
-  const sendMessage = (message: string) => {
+  const onMessageChange = (message: string) => {
     setMessage(message)
-    sendNostrMessage(message, peerKey, nostr)
+    sendMessage(peerKey, message)
   }
 
   return (
@@ -109,7 +115,7 @@ export const SendView = ({ nostr }: SendViewProps) => {
         <Card>
           <div className="p-4">
             <PeerInput peerKey={peerKey} setShowScan={setShowScan} onChange={setPeerKey} />
-            {isValidPeerKey(peerKey) && <Message message={message} onChange={sendMessage} />}
+            {isValidPeerKey(peerKey) && <Message message={message} onChange={onMessageChange} />}
           </div>
         </Card>
       </div>