zeronet_nodejs/zeroproxy.js at master · zeronetscript/zeronet_nodejs · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
"use strict";

var coffeescript = require('coffee-script/register')

var ChatHelper = require("./chathelper").ChatHelper;

var request = require('request');


var chatController;

function sendResponse(user_auth_address,content){

  chatController.data.response[user_auth_address]=content;
  chatController.changed=true;
  chatController.save(false);
}

function userHandle(user_auth_address,callback){

  var inner_path= "data/users/"+user_auth_address+"/data.json";

  console.log("call fileGet:",inner_path);

  chatController.cmd("fileGet",{"inner_path":inner_path},function(user_data){
    var data=JSON.parse(user_data);

    console.log("get ",inner_path," complete" );

    if(!data.request){
      console.log("no request");
      //no request
      return;
    }

    console.log("user ",user_auth_address," request :",data.request);

    callback(data.request);

  });

}


function receiveUserCallback(inner_path){

  console.log("inner_path:",inner_path," changed");

  var user_auth_address = inner_path.match(/data\/users\/(.*)\/data.json/)[1];

  console.log("user_auth_address is ",user_auth_address);

  userHandle(user_auth_address,function(user_request){


    if (user_request==null ) {
      return;
    }
    request(user_request, function (error, response, body) {
      if (!error && response.statusCode == 200) {
        sendResponse(user_auth_address,body);
      }else{
        sendResponse(user_auth_address,"error:"+error);
      }
    });
  });
}


function collectFunc(chatController1){

  chatController=chatController1;
  chatController1.cmd("channelJoin",{"channel":"siteChanged"});

  chatController1.receiveUserCallback = receiveUserCallback;

  if(!chatController1.data.response){
    chatController1.data.response={};
  }

}

new ChatHelper(
      {
        addr:"157iuNRDp8x6ySz6fAamvxpv8zxE7RPsrS",
        host:"127.0.0.1",
        port:43110,
        proto:{
          ws:"ws",
          http:"http"
        }
      },
      ["zeroid.bit","web","telegrambot","1My4AHpEjVQB1Jvetpiuha7o2QtQgWHL5L"]
      ,true,
      collectFunc);