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
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
|
#!/usr/bin/env node
var aicmd;
if(process.argv.length!=3){
console.log("Give AI command to run as command line argument.");
process.exit(1);
}
aicmd=process.argv[2];
console.log("Using AI command '"+aicmd+"'");
var app=require("express")(),
http=require("http").Server(app),
io=require("socket.io")(http),
fs=require("fs"),
spawn=require("child_process").spawn;
eval(String(fs.readFileSync("common.js")));
var HTTPPORT=8080;
var uniqid=(function(){
var id=0;
return function(){return id++;};
})();
app.get("/",function(req,res){
res.sendFile(__dirname+"/index.html");
});
["index.html","common.js"].forEach(function(fname){
app.get("/"+fname,function(req,res){
res.sendFile(__dirname+"/"+fname);
});
});
var childpids=[];
process.on("exit",function(){
console.log("Exiting:");
console.log.apply(console,arguments);
childpids.forEach(function(pid){process.kill(pid);});
process.exit();
});
process.on("SIGINT",function(){
console.log("SIGINT:");
console.log.apply(console,arguments);
childpids.forEach(function(pid){process.kill(pid);});
process.exit();
});
function stopproc(proc){
var pid=proc.pid;
console.log("Stopping proc with pid "+pid+", childpids="+JSON.stringify(childpids));
proc.stdin.write("Quit\n");
var timeout=setTimeout(function(){
console.log("Proc with pid "+pid+" didn't stop in time, killing");
proc.kill();
var idx=childpids.indexOf(pid); if(idx!=-1)childpids.splice(idx,1);
},500);
proc.on("exit",function(){
clearTimeout(timeout);
var idx=childpids.indexOf(pid); if(idx!=-1)childpids.splice(idx,1);
});
}
io.on("connection",function(conn){
var id=uniqid();
console.log("New IO connection id "+id);
var pingtimeout=null;
var bd=emptyboard();
var aiplayer=0;
conn.on("disconnect",function(){
console.log("Disconnect id "+id);
if(proc){stopproc(proc);proc=null;}
if(pingtimeout)clearTimeout(pingtimeout);
});
conn.on("ping",function(){ //only enable ping timeouting if a first ping received
if(pingtimeout)clearTimeout(pingtimeout);
pingtimeout=setTimeout(function(){
console.log("Ping timeout on id "+id+"!");
if(proc){stopproc(proc);proc=null;}
conn.disconnect(true);
},4000);
});
conn.on("usermove",function(idx){
idx=+idx;
if(idx<0||idx>=W*H){
conn.emit("alert","You sent an invalid move, index "+idx);
conn.emit("getusermove");
return;
}
var x=idx%W,y=~~(idx/W);
bd[y][x].c=1-aiplayer;
bd[y][x].n++;
bd=stabilise(bd);
if(countballs(bd)>2){
var win=checkwin(bd);
if(win!=-1){
conn.emit("win",1-aiplayer);
if(proc){stopproc(proc);proc=null;}
return;
}
}
proc.stdin.write(x+" "+y+"\n");
conn.emit("setonturn",aiplayer);
});
var proc=spawn("sh",["-c",aicmd],{
stdio:["pipe","pipe",process.stderr]
});
childpids.push(proc.pid);
var buffer="";
proc.stdout.on("data",function(data){
var idx,line,mv,win;
buffer+=data;
while((idx=buffer.indexOf("\n"))!=-1){
line=buffer.slice(0,idx);
buffer=buffer.slice(idx+1);
mv=line.split(" ").map(function(s){return parseInt(s,10);});
if(mv.length!=2||isNaN(mv[0])||isNaN(mv[1])){
console.log("Invalid move written by AI: '"+line+"'");
conn.emit("alert","Invalid move written by AI: '"+line+"'");
mv[0]=0;
mv[1]=0;
}
bd[mv[1]][mv[0]].c=aiplayer;
bd[mv[1]][mv[0]].n++;
bd=stabilise(bd);
conn.emit("applymove",{index:W*mv[1]+mv[0],player:aiplayer});
if(countballs(bd)>2){
win=checkwin(bd);
if(win!=-1){
conn.emit("win",aiplayer);
if(proc){stopproc(proc);proc=null;}
return;
}
}
conn.emit("setonturn",1-aiplayer);
conn.emit("getusermove");
}
});
proc.stdin.write("A\n-1 -1\n");
conn.emit("emptyboard");
conn.emit("setonturn",0);
});
http.listen(HTTPPORT,function(){
console.log("Listening on http://localhost:"+HTTPPORT);
});
|
