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
|
// A bot which responds to `jarvis` with a box
const Space = require('../space');
const Socket = require('../socket');
const tilekeys = require('../utils/tilekeys');
const ms = require('../utils/measurespace');
const vec = require('../utils/vec');
const comb = require('../utils/comb');
const Search = require('../tools/search');
const Queue = require('../tools/queue');
const ri = require('../utils/rectintersect');
var main = new Socket();
function equals(arg1,arg2){ // Just takes the specific case argument of each being an int pair
return arg1[0] == arg2[0] && arg1[1] == arg2[1]
}
main.on('open', ()=>{ // Tries to identify itself with a cursor movement
console.log('socket opened');
let coords = [Math.floor(Math.random()*100000+16),Math.floor(Math.random()*100000+16)];
main.cursor(coords);
main.on('cursor',detect);
function detect(pos, send){
if (equals(pos[0],coords)){
main.off('cursor', detect);
identity(send);
}
}
})
var sender; // Global variable that holds identity()'s `send` for tileHandler
function identity(send){
sender = send;
console.log('identity activated');
init();
main.on('tileUpdate', tileHandler);
}
function init(){
writes.enqueue(...notif.towrite()); // A non-conservative write because I don't want to write the fetch request (also, faster in many cases because the notif is <200 chars)
}
function tileHandler(send, source, tiles){
if (send == sender) return;
let locs = tilekeys(tiles);
let tilespaces = {};
for (let i=0; i<locs.length; i++){
let loc = locs[i];
tilespaces[loc] = new Space();
tilespaces[loc].fromfetch(tiles, [loc, loc], conform=false);
}
[protectArea, detectPrompt].forEach(func => {
func(send, tilespaces, locs);
});
}
var notif = new Space();
notifsrc = '\
\n\
For a node.js YWOT api: \n\
& http://github.com/feynmansfedora/ywot-clean \n\
& Try `jarvis` today. Uptime: UPTIME \n\
'
var hrsUp = 0;
function notifRefresh(){
notif.adhoc(notifsrc.replace('UPTIME', hrsUp + 'hrs'));
setTimeout(notifRefresh, 3600*1000);
hrsUp += 1;
}
notifRefresh();
notif.loc = [-6, 20];
var ctrl = ms(notif);
function protectArea(send, tiles, locs){
let tilesize = [8, 16]; // This may be exportable to an external util/tool
for (loc of locs){
let tile = tiles[loc];
let origloc = loc;
loc = vec.tileToChar(loc);
if (ri(ctrl, [loc, vec.add(loc, tilesize)])){
// Write diffs from the tile
let inter = notif.copy(); // Acts as a window for tile (only see relevant data)
inter.comb(tile, comb.unmask);
let diff = notif.copy(); // Actually diffs notify with the errant text
diff.comb(inter, comb.sub);
writes.enqueue(...diff.towrite())
// Mask the tile
let newtile = notif.copy();
newtile.comb(tile, comb.mask);
tiles[origloc] = newtile;
}
}
}
var search = new Space();
search.adhoc('jarvis'); // The search space is the word jarvis, so whenever that's caught, a relevant function can be called.
var read = new Search(search);
var expire = {};
function detectPrompt(send, tiles, locs){ // tries to detect the prompt ('jarvis') and calls respond if found.
for (let i=0; i<locs.length; i++){
let loc = locs[i];
if (read.has(loc)){
clearTimeout(expire[loc]);
delete expire[loc];
read.del(loc);
}
let results = read.add(loc, tiles[loc]);
if (results.length > 0) respond(results);
expire[loc] = setTimeout(() => {read.del(loc)}, 30000);
}
}
let response = new Space();
response.adhoc('yes, my liege');
let writes = new Queue(1000, 200, (elems) => main.write(elems));
function respond(coord){
console.log('called at', coord);
response.loc = coord;
writes.enqueue(...response.towrite());
}
|
