--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/pumpio.coffee	Thu Jun 05 10:35:15 2014 +0200
@@ -0,0 +1,153 @@
+# Copyright (C) 2014 by Intevation GmbH
+# Author: Mathias Gebbe <mgebbe@intevation.de>
+#
+# This file is Free Software under the Apache License, Version 2.0
+# (the "License"); and comes with ABSOLUTELY NO WARRANTY!
+# You may not use this file except in compliance with the License.
+# See LICENSE for details.
+
+https = require("https")
+async = require("async")
+_ = require("underscore")
+Routes = require("./routes")
+querystring = require("querystring")
+EdgeControl = require("./edgecontrol")
+Edge = require("./edge")
+Host = require("../node_modules/pump.io-client-app/lib/models/host")
+OAuth = require('oauth')
+Usermap = require("./usermap")
+
+
+#######################################
+##### get user info pumpio        #####
+#######################################
+getUser = (user) ->
+  id = user.user_ESN.substr(0,user.user_ESN.indexOf('@'))
+  server = user.user_ESN.substr(user.user_ESN.indexOf('@')+1,user.user_ESN.length)
+  token = user.oauth_token.substr(0,user.oauth_token.indexOf(';'))
+  secret = user.oauth_token.substr(user.oauth_token.indexOf(';')+1,user.oauth_token.length)
+  # get tokens and ask pump.io api for userinformation then update userdb
+  async.waterfall [
+   (callback) ->
+     Host.search {hostname: server}, callback
+   (host,callback)  ->
+     # get host from db
+     host = JSON.stringify(host)
+     host = JSON.parse(host)
+     oauth = new OAuth.OAuth(host[0].request_token_endpoint, host[0].access_token_endpoint, host[0].client_id, host[0].client_secret, "1.0A", null, "HMAC-SHA1")
+     oauth.get "https://" + server + "/api/user/"+id, token, secret, callback
+  ], (err,result) ->
+    #console.log 'PUMP BODY:' + result
+    result = JSON.parse(result)
+    id = result.profile.id.substr(result.profile.id.indexOf(':')+1,result.profile.id.length)
+    Routes.updateUserDB(id,result.profile.preferredUsername,result.profile.displayName,result.profile.url,result.profile.image.url)
+  return
+
+postUser = (bridgeid, to, text, callback) ->
+
+  bridgename = bridgeid.substr(0,bridgeid.indexOf('@'))
+  server = bridgeid.substr(bridgeid.indexOf('@')+1,bridgeid.length)
+  token=undefined
+  secret=undefined
+
+  async.waterfall [
+   (callback) ->
+     Usermap.search {id: bridgeid+'_to_'+bridgeid}, callback
+   (bridgeuser, callback) ->
+     token = bridgeuser[0].oauth_token.substr(0,bridgeuser[0].oauth_token.indexOf(';'))
+     secret = bridgeuser[0].oauth_token.substr(bridgeuser[0].oauth_token.indexOf(';')+1,bridgeuser[0].oauth_token.length)
+     Host.search {hostname: server}, callback
+   (host,callback)  ->
+     # get host from db
+     host = JSON.stringify(host)
+     host = JSON.parse(host)
+     activity =
+       verb: "post"
+       #cc: [
+       #  id: "http://activityschema.org/collection/public"
+       #  objectType: "collection"
+       #]
+       to: [
+         id: "acct:" + to
+         objectType: "person"
+       ]
+       object:
+         objectType: "note"
+         content: text
+     oauth = new OAuth.OAuth(host[0].request_token_endpoint, host[0].access_token_endpoint, host[0].client_id, host[0].client_secret, "1.0A", null, "HMAC-SHA1")
+     oauth.post "https://" + server + "/api/user/" + bridgename + "/feed", token, secret, JSON.stringify(activity), 'application/json', callback
+  ], (err,result) ->
+    #console.log 'PUMP BODY:' + result
+    callback null, result
+
+  return
+
+#######################################
+##### get user pumpio feed        #####
+#######################################
+getUserFeed = (user, callback) ->
+  id = user.user_ESN.substr(0,user.user_ESN.indexOf('@'))
+  server = user.user_ESN.substr(user.user_ESN.indexOf('@')+1,user.user_ESN.length)
+  token = user.oauth_token.substr(0,user.oauth_token.indexOf(';'))
+  secret = user.oauth_token.substr(user.oauth_token.indexOf(';')+1,user.oauth_token.length)
+  # get tokens and ask pump.io api for userinformation then update userdb
+  async.waterfall [
+   (callback) ->
+     Host.search {hostname: server}, callback
+   (host,callback)  ->
+     # get host from db
+     host = JSON.stringify(host)
+     host = JSON.parse(host)
+     oauth = new OAuth.OAuth(host[0].request_token_endpoint, host[0].access_token_endpoint, host[0].client_id, host[0].client_secret, "1.0A", null, "HMAC-SHA1")
+     oauth.get "https://" + server + "/api/user/"+id+"/feed", token, secret, callback
+  ], (err,result) ->
+    #console.log 'PUMP BODY:' + result
+    result = JSON.parse(result)
+    callback null, result
+  return
+
+#######################################
+##### get user pumpio note        #####
+#######################################
+getNote = (user, noteurl, callback) ->
+  id = user.user_ESN.substr(0,user.user_ESN.indexOf('@'))
+  server = user.user_ESN.substr(user.user_ESN.indexOf('@')+1,user.user_ESN.length)
+  token = user.oauth_token.substr(0,user.oauth_token.indexOf(';'))
+  secret = user.oauth_token.substr(user.oauth_token.indexOf(';')+1,user.oauth_token.length)
+
+  # get tokens and ask pump.io api for userinformation then update userdb
+  async.waterfall [
+   (callback) ->
+     Host.search {hostname: server}, callback
+   (host,callback)  ->
+     # get host from db
+     host = JSON.stringify(host)
+     host = JSON.parse(host)
+     oauth = new OAuth.OAuth(host[0].request_token_endpoint, host[0].access_token_endpoint, host[0].client_id, host[0].client_secret, "1.0A", null, "HMAC-SHA1")
+     oauth.get noteurl, token, secret, callback
+  ], (err,result) ->
+    #console.log 'PUMP BODY:' + result
+    result = JSON.parse(result)
+    callback null, result
+  return
+
+isPublicActivity = (act) ->
+  recip = []
+  _.each [
+    "to"
+    "cc"
+    "bto"
+    "bcc"
+  ], (prop) ->
+    recip = recip.concat(act[prop])  if _.isArray(act[prop])
+    return
+
+  _.some recip, (rec) ->
+    rec.objectType is "collection" and rec.id is "http://activityschema.org/collection/public"
+
+
+exports.isPublicActivity = isPublicActivity
+exports.getUserFeed = getUserFeed
+exports.getUser = getUser
+exports.getNote = getNote
+exports.postUser = postUser