-
Notifications
You must be signed in to change notification settings - Fork 0
/
StudIPInterface.js
139 lines (101 loc) · 3.94 KB
/
StudIPInterface.js
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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
const fetch = require('node-fetch');
const fs = require('fs');
class StudIPInterface {
constructor(apiURL, userData = {name, password}) {
this.url = apiURL;
this.userData = userData;
this.foundFiles = null;
this.hashFile = 'hashFile.json';
this.downloadPrefix = 'files/';
if (!fs.existsSync(this.downloadPrefix)) {
fs.mkdirSync(this.downloadPrefix);
}
}
async downloadFoundFiles() {
if (!this.foundFiles) return;
const newFiles = this.testForNewFiles(this.foundFiles);
console.info('Downloading ' + newFiles.length + ' new files.')
const paths = [];
for (const file of newFiles) {
if (!fs.existsSync(this.downloadPrefix + file.folder_id)) {
fs.mkdirSync(this.downloadPrefix + file.folder_id);
}
const data = await this.apiRequest('/file/' + file.id + '/download', 'file');
let buffer = Buffer.from(data);
const path = this.downloadPrefix + file.folder_id + '/' + file.name
fs.writeFile(path, buffer, "binary", () => {});
paths.push(path)
}
this.foundFiles = null;
return paths;
}
testForNewFiles(fileList) {
try {
const info = fs.statSync(this.hashFile)
console.log('hashfile exists')
} catch {
console.log('hashfile does not exists')
return [];
}
const hashFile = JSON.parse(fs.readFileSync(this.hashFile));
fileList = fileList.filter((file) => !hashFile.hashes.find((val) => val == getHash(file)));
fileList.map((file) => {hashFile.hashes.push(getHash(file))});
hashFile.lastModified = Date.now();
fs.writeFileSync(this.hashFile, JSON.stringify(hashFile, false, 2))
return fileList;
function getHash(file) {
return file.file_id + file.chdate + file.name
}
}
async findFilesInCourse(fileName, courseId) {
const res = await this.apiRequest('course/' + courseId + '/top_folder');
let allFiles = await this.getAllFilesInFolder(res.id, true);
let re = new RegExp(fileName, '');
this.foundFiles = allFiles.filter((file) => {
return re.test(file.name);
})
return allFiles;
}
async getAllFilesInFolder(folderId, recursive = false) {
const files = await this.apiRequest('folder/' + folderId + '/files');
const allFiles = [];
if(!files) return allFiles;
for (const file in files.collection)
allFiles.push(files.collection[file]);
console.info('Found ' + allFiles.length + ' file/s!')
if (recursive) {
const res = await this.getAllFoldersInFolder(folderId);
for (const folder in res.collection) {
const recursiveFiles = await this.getAllFilesInFolder(res.collection[folder].id, true);
allFiles.push(...recursiveFiles);
}
}
return allFiles;
}
async getAllFoldersInFolder(folderId) {
const res = await this.apiRequest('folder/' + folderId + '/subfolders');
return res;
}
async apiRequest(path, type) {
let response = await fetch(this.url + path, {
method:'GET',
headers: {
'Authorization': 'Basic ' + Buffer.from(this.userData.name + ":" + this.userData.password).toString('base64')
},
})
if (!response.ok)
return ;
switch(type) {
case 'text':
response = await response.text();
break;
case 'file':
response = await response.arrayBuffer();
break;
default:
response = await response.json();
}
return response;
}
}
module.exports = StudIPInterface;