From 4f86d04add9a78d06f582d0129f07027154e1d6a Mon Sep 17 00:00:00 2001
From: cel <cel@f/6sQ6d2CMxRUhLpspgGIulDxDCwYD7DzFzPNr7u5AU=.ed25519>
Date: Fri, 27 Jul 2018 10:59:40 -1000
Subject: Publish conformant poll-position messages

---
 lib/serve.js | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

(limited to 'lib/serve.js')

diff --git a/lib/serve.js b/lib/serve.js
index b0e1267..db30896 100644
--- a/lib/serve.js
+++ b/lib/serve.js
@@ -232,10 +232,11 @@ Serve.prototype.publishPollPosition = function (cb) {
     version: 'v1',
     channel: this.data.channel || undefined,
     root: this.data.poll_root,
-    reason: this.data.poll_reason,
+    branch: this.data.branches || [],
+    reason: this.data.poll_reason || undefined,
     details: {
       type: this.data.poll_type,
-      choice: this.data.poll_choice
+      choice: Number(this.data.poll_choice)
     }
   }
   if (this.data.recps) content.recps = this.data.recps.split(',')
@@ -1100,17 +1101,19 @@ Serve.prototype.streamThreadWithComposer = function (opts) {
       )
       function gotLinks(err, links) {
         if (err) return cb(new Error(err.stack))
+        var branches = threadHeads(links, threadRootId)
         cb(null, pull(
           pull.values(sort(links)),
           self.renderThread({
             msgId: id,
+            branches: branches,
           }),
           self.wrapMessages(),
           self.wrapThread({
             recps: recps,
             root: threadRootId,
             post: id,
-            branches: threadHeads(links, threadRootId),
+            branches: branches,
             postBranches: threadRootId !== id && threadHeads(links, id),
             placeholder: opts.placeholder,
             channel: channel,
@@ -1339,6 +1342,7 @@ Serve.prototype.renderThread = function (opts) {
       filter: this.query.filter,
       limit: Number(this.query.limit),
       serve: this,
+      branches: opts && opts.branches,
     }),
     pull.map(u.toHTML)
   )
-- 
cgit v1.2.3