-
Notifications
You must be signed in to change notification settings - Fork 4
/
main.js
103 lines (77 loc) · 2.21 KB
/
main.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
//#############################################
//## WINDOW LOGIC ##
//#############################################
const {app, BrowserWindow, ipcMain} = require('electron');
const path = require('path');
const url = require('url');
let window;
function createWindow () {
window = new BrowserWindow({width: 1200, height: 720, show: false})
window.loadURL(url.format({
pathname: path.join(__dirname, '/src/index.html'),
protocol: 'file:',
slashes: true
}))
window.once('ready-to-show', function() {
getNodeInfo();
window.show();
});
window.setMenu(null);
//window.webContents.openDevTools();
window.on('closed', () => {
window = null;
})
}
app.on('ready', createWindow);
app.on('window-all-closed', () => {
if (process.platform !== 'darwin') {
app.quit();
}
})
app.on('activate', () => {
if (window === null) {
createWindow();
}
})
//#############################################
//## MAM LOGIC ##
//#############################################
const IOTA = require('iota.lib.js');
const MAM = require('mam.node.js');
iota = new IOTA({
'host': 'http://178.238.237.200',
'port': 14265
});
let root = '';
let streamIndex, data;
// Initialize MAM-state
var mamState = MAM.init(iota);
ipcMain.on('fetchRoot', (event, _root, _i) => {
root = _root;
streamIndex = _i;
execute();
})
const execute = async () => {
let resp = await MAM.fetch(root, 'public', null, logData).catch(error => {console.log('Cannot fetch stream [' + streamIndex + ']');});
if (resp == undefined) {
window.webContents.send('setRoot', streamIndex, root);
return;
}
root = resp['nextRoot'];
window.webContents.send('setRoot', streamIndex, root);
}
// Callback used to pass data out of the fetch
const logData = p => {
packet = JSON.parse(iota.utils.fromTrytes(p));
window.webContents.send('fetchPacket', packet, streamIndex);
}
//#############################################
//## API LOGIC ##
//#############################################
function getNodeInfo () {
iota.api.getNodeInfo(function(err, result) {
if (!err) {
window.webContents.send('nodeInfo', result);
}
})
}