FilesExpand file tree

refs/pull/9711

/

demo_condenser.js

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

49 lines (44 loc) · 1.22 KB

refs/pull/9711

/

demo_condenser.js

Copy path

Top

File metadata and controls

• Code
• Blame

49 lines (44 loc) · 1.22 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

'use strict';

const fs = require('fs');

const path = require('path');

const zlib = require('zlib');

let once = process.argv.includes("--once");

let condense_dir = "../data/logs";

function condense(dir = condense_dir) {

fs.readdir(dir, (err, files) => {

if(err) {console.error(err); return;}

for(let file of files) {

let full = path.join(dir, file);

fs.stat(full, (err, stat) => {

if(err) {console.error(err); return;}

if(stat.isDirectory()) {

condense(full);

} else if(file == "demo.txt") {

condense_file(full);

}

});

}

});

}

function condense_file(filename) {

console.log("Compressing " + filename + "...");

let reader = fs.createReadStream(filename);

let writer = fs.createWriteStream(filename + ".gz");

let gzip = zlib.createGzip();

reader.pipe(gzip).pipe(writer).on('finish', (err) => {

if(err) {console.error(err); return;}

console.log("Compressed " + filename + "!");

// Delete it

fs.unlink(filename, (err) => {

if(err) {

console.error(filename + " failed to delete (round probably not done)");

} else {

console.error("Deleted uncompressed demo at " + filename);

}

});

});

}

condense();

if(!once) {

setInterval(condense, 60 * 60 * 1000); // condense every hour.

}