Commit 69705109becfed7b3713e4f3da60f26ac286bed6
assume the record is json, not a string
ansuz committed on 10/31/2016, 2:56:02 PMParent: 43596ee016af3e2c1709e0734c63755a47e1f3d6
Files changed
| index.js | changed |
| index.js | ||
|---|---|---|
| @@ -2,28 +2,14 @@ | ||
| 2 | 2 … | var Client = require("ssb-client"); |
| 3 | 3 … | var Pull = require("pull-stream"); |
| 4 | 4 … | var Paramap = require("pull-paramap"); |
| 5 | 5 … | |
| 6 | - | |
| 7 | - | |
| 8 | - | |
| 9 | - | |
| 10 | - | |
| 11 | - | |
| 12 | - | |
| 13 | - | |
| 14 | 6 … | var Config; |
| 15 | 7 … | try { |
| 16 | 8 … | Config = require("./config.js"); |
| 17 | 9 … | } catch (err) { |
| 18 | 10 … | console.error("\nCouldn't find './config.js'. Using defaults"); |
| 19 | - Config = { | |
| 20 | - port: 53053, | |
| 21 | - host: '127.0.0.1', | |
| 22 | - ready: function () { | |
| 23 | - console.log('Server running at %s:%s', Config.host, Config.port); | |
| 24 | - }, | |
| 25 | - }; | |
| 11 … | + Config = require("./config.dist.js"); | |
| 26 | 12 … | } |
| 27 | 13 … | |
| 28 | 14 … | var log = { |
| 29 | 15 … | req: function (req) { |
| @@ -56,22 +42,24 @@ | ||
| 56 | 42 … | Paramap(function getAvatar(msg, cb) { |
| 57 | 43 … | cb(null, msg); |
| 58 | 44 … | }), |
| 59 | 45 … | Pull.drain(function printMessage(msg) { |
| 60 | - var text = msg.value.content.text; | |
| 46 … | + var record = msg.value.content.record; | |
| 61 | 47 … | |
| 62 | - var result; | |
| 63 | - try { | |
| 64 | - result = JSON.parse(text); | |
| 65 | - } catch (err) { | |
| 66 | - throw new Error("Invalid record!"); | |
| 67 | - } | |
| 68 | - if (name && type && result.name === name && result.type === type && result.value) { | |
| 69 | - console.log("%s (%s) => %s", name, result.type, result.value); | |
| 48 … | + if (typeof(record) !== 'object') { return; } | |
| 49 … | + | |
| 50 … | + if (name && type && | |
| 51 … | + record.name === name && | |
| 52 … | + record.type === type && | |
| 53 … | + record.value) { | |
| 54 … | + console.log("%s (%s) => %s", name, record.type, record.value); | |
| 55 … | + | |
| 56 … | + // returns the first matching record found | |
| 57 … | + // TODO support multiple returned values | |
| 70 | 58 … | res.answer.push({ |
| 71 | - name: result.name, | |
| 72 | - type: result.type, | |
| 73 | - data: result.value, | |
| 59 … | + name: record.name, | |
| 60 … | + type: record.type, | |
| 61 … | + data: record.value, | |
| 74 | 62 … | ttl: 500, |
| 75 | 63 … | }); |
| 76 | 64 … | res.end() |
| 77 | 65 … | } |
| @@ -88,9 +76,7 @@ | ||
| 88 | 76 … | if (err) { |
| 89 | 77 … | console.error(err); |
| 90 | 78 … | return void process.exit(1); |
| 91 | 79 … | } |
| 92 | - var port = 53053; | |
| 93 | - var host = '127.0.0.1'; | |
| 94 | 80 … | createServer(sbot, Config.port, Config.host, Config.ready); |
| 95 | 81 … | }); |
| 96 | 82 … | |
Built with git-ssb-web