log

1 files changed, 8 insertions, 5 deletions

diff --git a/bucky/app/federate.js b/bucky/app/federate.js
index f4490c6..6741a21 100644
--- a/bucky/app/federate.js
+++ b/bucky/app/federate.js
@@ -4,16 +4,17 @@ var db = require('../db')
 module.exports = {
 
   route: (app) => {
-    app.put('/raw/import/thread/',  importRaw(db.Thread),  (req, res) => res.send({ status: 'ok' }))
-    app.put('/raw/import/keyword/', importRaw(db.Keyword), (req, res) => res.send({ status: 'ok' }))
-    app.put('/raw/import/file/',    importRaw(db.File),    (req, res) => res.send({ status: 'ok' }))
-    app.put('/raw/import/comment/', importRaw(db.Comment), (req, res) => res.send({ status: 'ok' }))
+    app.put('/raw/import/thread/',  importRaw('thread', db.Thread),  (req, res) => res.send({ status: 'ok' }))
+    app.put('/raw/import/keyword/', importRaw('keyword', db.Keyword), (req, res) => res.send({ status: 'ok' }))
+    app.put('/raw/import/file/',    importRaw('file', db.File),    (req, res) => res.send({ status: 'ok' }))
+    app.put('/raw/import/comment/', importRaw('comment', db.Comment), (req, res) => res.send({ status: 'ok' }))
 
     app.get('/raw/export/thread/:id',  exportThread,  (req, res) => res.send({ status: 'ok' }))
     app.get('/raw/export/keyword/:id', exportKeyword, (req, res) => res.send({ status: 'ok' }))
 
-    function importRaw (model) {
+    function importRaw (type, model) {
       return (req, res, next) => {
+        console.log('importing', type, req.body.id)
         new model(req.body).save().then((el) => {
           res.el = el;
           next()
@@ -21,6 +22,7 @@ module.exports = {
       }
     }
     function exportKeyword (req, res, next) {
+      console.log('export keyword', req.params.keyword)
       db.getKeyword(req.params.keyword).then(keyword => {
         send("keyword", keyword)
         return db.getThreadsForKeyword(keyword)
@@ -50,6 +52,7 @@ module.exports = {
       })
     }
     function send(type, data){
+      console.log('sending', type, data.get('id'))
       var json = data.toJSON()
       fetch("https://bucky.asdf.us/raw/import/" + type, {
         method: 'PUT',