NodejsL2p/l2pAuth.js at master · phikui/NodejsL2p · 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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
var request = require('request');
var clientID = '';
var obtainURL = 'https://oauth.campus.rwth-aachen.de/oauth2waitress/oauth2.svc/code';
var tokenURL = 'https://oauth.campus.rwth-aachen.de/oauth2waitress/oauth2.svc/token';
var tokenInfoURL = 'https://oauth.campus.rwth-aachen.de/oauth2waitress/oauth2.svc/tokeninfo';

function setClientID(id){
  clientID = id;
}

function obtainUserCode(callback){
request.post({url:obtainURL, form: {client_id:clientID, scope:'l2p.rwth userinfo.rwth'}},
  function(err,httpResponse,body){
    if (!err && httpResponse.statusCode == 200) {
      var parsed = JSON.parse(body);
      parsed.verification_url = parsed.verification_url + "?q=verify&d=" + parsed.user_code;
      callback(parsed);
    } else {
      console.log("error");
    }
  });
}


function getTokens(device_code, callback){
  request.post({url:tokenURL, form: {client_id:clientID, code:device_code, grant_type:'device'}},
  function(err,httpResponse,body){
    if (!err && httpResponse.statusCode == 200) {
      var parsed = JSON.parse(body);
      if(parsed.status == "error: authorization pending"){
          //User has not yet authorized
          console.log(parsed.status);
          callback(parsed);
      } else if (parsed.status == "error: slow down"){
          //To many requests
          console.log(parsed.status);
          callback(parsed);
      } else {
        callback(parsed);
      }
    } else {
      console.log("error");
    }
  });
}

function refreshToken(refreshToken, callback){
  request.post({url:tokenURL, form: {client_id:clientID, refresh_token:refreshToken, grant_type:'refresh_token'}},
    function(err,httpResponse,body){
    if (!err && httpResponse.statusCode == 200) {
      var parsed = JSON.parse(body);
      callback(parsed);
    } else {
      console.log("error");
    }
  });
}

function invalidateToken(refreshToken){
  request.post({url:tokenURL, form: {client_id:clientID, refresh_token:refreshToken, grant_type:'invalidate'}},
    function(err,httpResponse,body){
    if (!err && httpResponse.statusCode == 200) {
      //null
    } else {
      console.log("error");
    }
  });
}

function tokenValidation(accessToken, callback){
request.post({url:tokenInfoURL, form: {client_id:clientID, access_token:accessToken}},
    function(err,httpResponse,body){
    if (!err && httpResponse.statusCode == 200) {
      var parsed = JSON.parse(body);
      callback(parsed);
    } else {
      console.log("error");
    }
  });
}

function courseinfo(token,callback){
  var header = "Bearer "+token
  var options = {
  url: 'https://www2.elearning.rwth-aachen.de/api/courseinfo',
  headers: {
    "Authorization" : header
  }
  };
  request(options,callback);
}

function callAPI(token,apiurl,callback){
  var header = "Bearer "+token
  var options = {
  url: apiurl,
  headers: {
    "Authorization" : header
  }
  };
  request(options,callback);
}

exports.setClientID = setClientID;
exports.refreshToken = refreshToken;
exports.getTokens = getTokens;
exports.obtainUserCode = obtainUserCode;
exports.courseinfo = courseinfo;
exports.callAPI = callAPI;
exports.tokenValidation = tokenValidation;
exports.invalidateToken = invalidateToken;