1 files changed, 19 insertions, 12 deletions
diff --git a/lib/serve.js b/lib/serve.js
index 32932c5..99755c0 100644
--- a/lib/serve.js
+++ b/lib/serve.js
@@ -879,18 +879,25 @@ Serve.prototype.wrapThread = function (opts) {
 }
 
 Serve.prototype.wrapNew = function (opts) {
-  return function (read) {
-    return cat([
-      read,
-      pull.once(
-        h('tr', h('td.paginate', {colspan: 3},
-          h('a', {href: '?' + qs.stringify({
-            gt: opts.gt
-          })}, '↓ catchup')
-        )).outerHTML
-      )
-    ])
-  }
+  var self = this
+  return u.hyperwrap(function (thread, cb) {
+    self.composer({
+      channel: '',
+    }, function (err, composer) {
+      if (err) return cb(err)
+      cb(null, [
+        composer,
+        h('table.ssb-msgs',
+          thread,
+          h('tr', h('td.paginate', {colspan: 3},
+            h('a', {href: '?' + qs.stringify({
+              gt: opts.gt
+            })}, '↓ catchup')
+          ))
+        )
+      ])
+    })
+  })
 }
 
 Serve.prototype.wrapChannel = function (channel) {