diff --git a/src/hub.js b/src/hub.js
index 93b345b77fb5c0cadee34160233906fa41f82987..666f471dd83f7d663db8ac89dab1e486551d5178 100644
--- a/src/hub.js
+++ b/src/hub.js
@@ -63,6 +63,7 @@ import ReactDOM from "react-dom";
 import React from "react";
 import UIRoot from "./react-components/ui-root";
 import HubChannel from "./utils/hub-channel";
+import XferChannel from "./utils/xfer-channel";
 import { connectToPhoenix } from "./utils/phoenix-utils";
 
 import "./systems/personal-space-bubble";
@@ -164,6 +165,7 @@ function mountUI(scene, props = {}) {
 const onReady = async () => {
   const scene = document.querySelector("a-scene");
   const hubChannel = new HubChannel(store);
+  const xferChannel = new XferChannel(store);
 
   document.querySelector("a-scene canvas").classList.add("blurred");
   window.APP.scene = scene;
@@ -381,30 +383,10 @@ const onReady = async () => {
       console.error(res);
     });
 
-  //const xferCode = Math.floor(Math.random() * 9999)
-  //  .toString()
-  //  .padStart(4, "0");
-  const xferCode = "1234";
-
-  const xferChannel = socket.channel(`xfer:${xferCode}`, { timeout: 10000 });
-
-  xferChannel.onClose(() => console.log("closed"));
-  xferChannel.on("expired", () => console.log("expired"));
-
-  xferChannel.on("presence_state", state => {
-    console.log(state);
-  });
-
-  xferChannel
-    .join()
-    .receive("ok", data => {
-      console.log(data);
-      console.log("OK");
-    })
-    .receive("error", res => {
-      console.log("ERR");
-      console.log(res);
-    });
+  xferChannel.setSocket(socket);
+  const code = await xferChannel.generateCode();
+  code.onFinished.then(reason => console.log(reason));
+  console.log(code);
 };
 
 document.addEventListener("DOMContentLoaded", onReady);
diff --git a/src/utils/xfer-channel.js b/src/utils/xfer-channel.js
new file mode 100644
index 0000000000000000000000000000000000000000..5c05514e0005fe6a91ef45ff9b408ad0c6661883
--- /dev/null
+++ b/src/utils/xfer-channel.js
@@ -0,0 +1,70 @@
+export default class XferChannel {
+  constructor(store) {
+    this.store = store;
+  }
+
+  setSocket = socket => {
+    this.socket = socket;
+  };
+
+  // Returns a promise that, when resolved, will forward an object with three keys:
+  //
+  // code: The code that was made available to use for xfer.
+  //
+  // cancel: A function that the caller can call to cancel the use of the code.
+  //
+  // onFinished: A promise that, when resolved, indicates the code was used or expired.
+  // If expired, the string "expired" will be passed forward.
+  generateCode = () => {
+    return new Promise(resolve => {
+      const onFinished = new Promise(finished => {
+        const step = () => {
+          const code = Math.floor(Math.random() * 9999)
+            .toString()
+            .padStart(4, "0");
+
+          // Only respond to one xfer_request in this channel.
+          let readyToSend = false;
+
+          const channel = this.socket.channel(`xfer:${code}`, { timeout: 10000 });
+          const cancel = () => channel.leave();
+
+          channel.on("expired", () => finished("expired"));
+
+          channel.on("presence_state", state => {
+            if (Object.keys(state).length > 0) {
+              // Code is in use by someone else, try a new one
+              step();
+            } else {
+              readyToSend = true;
+              resolve({ code, cancel, onFinished });
+            }
+          });
+
+          channel.on("xfer_request", () => {
+            if (readyToSend) {
+              const payload = {
+                location: [location.protocol, "//", location.host, location.pathname].join("")
+              };
+
+              // Copy profile data to xfer'ed device, and apply it on the other side
+              // if hasChangedName is false.
+              if (this.store.state.activity.hasChangedName) {
+                payload.profile = { ...this.store.state.profile };
+              }
+
+              channel.push("xfer_response", payload);
+              channel.leave();
+              finished("used");
+              readyToSend = false;
+            }
+          });
+
+          channel.join();
+        };
+
+        step();
+      });
+    });
+  };
+}