ref: 28cacde37de17e1f471b215e55d644b53881a24b
dir: /bts.c/
#include <u.h>
#include <libc.h>
#include <bio.h>
#include <thread.h>
#include <draw.h>
#include <mouse.h>
#include <cursor.h>
#include <keyboard.h>
#include <geometry.h>
#include "dat.h"
#include "fns.h"
#include "mixer.h"
enum {
PCBlack,
PCWhite,
PCRed,
PCGreen,
PCShip,
PCYellow,
PCBlue,
PCWater,
PCWaves,
PCBrown,
PCShadow,
NCOLORS
};
enum {
CMid,
CMqueued,
CMlayout,
CMoid,
CMwait,
CMplay,
CMwehit,
CMwemiss,
CMtheyhit,
CMtheymiss,
CMmatches, /* list opening */
CMmatch, /* list entry */
CMendmatches, /* list closure */
CMwatching,
CMwin,
CMlose,
CMplayeroutlay,
CMplayerhit,
CMplayermiss,
CMplayerplays,
CMplayerwon,
CMstats,
};
Cmdtab svcmd[] = {
CMid, "id", 1,
CMqueued, "queued", 1,
CMlayout, "layout", 1,
CMoid, "oid", 2,
CMwait, "wait", 1,
CMplay, "play", 1,
CMwehit, "hit", 1,
CMwemiss, "miss", 1,
CMtheyhit, "hit", 2,
CMtheymiss, "miss", 2,
CMmatches, "matches", 1,
CMmatch, "m", 4,
CMendmatches, "endmatches", 1,
CMwatching, "watching", 4,
CMwin, "win", 1,
CMlose, "lose", 1,
CMplayeroutlay, "outlayed", 3,
CMplayerhit, "hit", 3,
CMplayermiss, "miss", 3,
CMplayerplays, "plays", 2,
CMplayerwon, "won", 2,
CMstats, "stats", 2,
};
int debug;
int silent;
Cursor patrolcursor = {
{0, 0},
{ 0x00, 0x00, 0x01, 0x00, 0x03, 0x00, 0x03, 0x80,
0x06, 0x80, 0x06, 0xc0, 0x0e, 0xe0, 0x1e, 0xf0,
0x1f, 0xf8, 0x3f, 0x00, 0x01, 0x00, 0x41, 0x02,
0x7f, 0xfe, 0x7f, 0xfc, 0x3f, 0xf8, 0x00, 0x00,
},
{ 0x03, 0x80, 0x06, 0x80, 0x04, 0xc0, 0x0c, 0x40,
0x09, 0x60, 0x19, 0x30, 0x31, 0x18, 0x21, 0x0c,
0x60, 0x04, 0x40, 0xfc, 0xfe, 0x87, 0xbe, 0xfd,
0x80, 0x01, 0x80, 0x03, 0xc0, 0x06, 0x7f, 0xfc,
},
};
Cursor waitcursor = {
{0, 0},
{ 0x01, 0x80, 0x03, 0xc0, 0x07, 0xe0, 0x07, 0xe0,
0x07, 0xe0, 0x07, 0xe0, 0x03, 0xc0, 0x0f, 0xf0,
0x1f, 0xf8, 0x1f, 0xf8, 0x1f, 0xf8, 0x1f, 0xf8,
0x0f, 0xf0, 0x1f, 0xf8, 0x3f, 0xfc, 0x3f, 0xfc,
},
{ 0x01, 0x80, 0x03, 0xc0, 0x07, 0xe0, 0x04, 0x20,
0x04, 0x20, 0x06, 0x60, 0x02, 0x40, 0x0c, 0x30,
0x10, 0x08, 0x14, 0x08, 0x14, 0x28, 0x12, 0x28,
0x0a, 0x50, 0x16, 0x68, 0x20, 0x04, 0x3f, 0xfc,
}
};
Cursor boxcursor = {
{-7, -7},
{ 0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff,
0xff, 0xff, 0xf8, 0x1f, 0xf8, 0x1f, 0xf8, 0x1f,
0xf8, 0x1f, 0xf8, 0x1f, 0xf8, 0x1f, 0xff, 0xff,
0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff
},
{ 0x00, 0x00, 0x7f, 0xfe, 0x7f, 0xfe, 0x7f, 0xfe,
0x70, 0x0e, 0x70, 0x0e, 0x70, 0x0e, 0x70, 0x0e,
0x70, 0x0e, 0x70, 0x0e, 0x70, 0x0e, 0x70, 0x0e,
0x7f, 0xfe, 0x7f, 0xfe, 0x7f, 0xfe, 0x00, 0x00
}
};
Cursor aimcursor = {
{-7, -7},
{ 0x1f, 0xf8, 0x3f, 0xfc, 0x7f, 0xfe, 0xfb, 0xdf,
0xf3, 0xcf, 0xe3, 0xc7, 0xff, 0xff, 0xff, 0xff,
0xff, 0xff, 0xff, 0xff, 0xe3, 0xc7, 0xf3, 0xcf,
0x7b, 0xdf, 0x7f, 0xfe, 0x3f, 0xfc, 0x1f, 0xf8,
},
{ 0x00, 0x00, 0x0f, 0xf0, 0x31, 0x8c, 0x21, 0x84,
0x41, 0x82, 0x41, 0x82, 0x41, 0x82, 0x7f, 0xfe,
0x7f, 0xfe, 0x41, 0x82, 0x41, 0x82, 0x41, 0x82,
0x21, 0x84, 0x31, 0x8c, 0x0f, 0xf0, 0x00, 0x00,
}
};
char deffont[] = "/lib/font/bit/pelm/unicode.9.font";
char assetdir[] = "/sys/games/lib/battleship";
//char assetdir[] = "assets";
char titlefontpath[] = "font/gunmetal/gunmetal.48.font";
Font *titlefont;
char winspec[32];
char uid[8+1], oid[8+1];
Image *coverimg;
Sprite *spritetab[NVFX];
Vfx vfxqueue;
Channel *drawchan;
Channel *reconnc;
Channel *ingress, *egress;
Mousectl *mctl; /* only used to update the cursor */
Keyboardctl *kctl; /* only used to ignore key presses during specific interactions */
RFrame worldrf;
Image *pal[NCOLORS];
Image *screenb;
Image *tiletab[NTILES];
AudioSource *playlist[NSOUNDS];
Board alienboard;
Board localboard;
Ship armada[NSHIPS];
Ship *curship;
int layoutdone;
Point2 lastshot;
Menulist *matches;
MatchInfo match; /* of which we are an spectator */
int nplayers;
struct {
Image *c; /* color */
char *s; /* banner text */
AudioSource *snd; /* victory or defeat bg sfx */
} conclusion;
int gamestate;
static void
PvP_handler(Button *)
{
if(gamestate != Waiting0)
return;
chanprint(egress, "play %d\n", GMPvP);
}
static void
PvAI_handler(Button *)
{
if(gamestate != Waiting0)
return;
chanprint(egress, "play %d\n", GMPvAI);
}
Button mainbtns[] = {
{ .label = "PvP", .handler = PvP_handler },
{ .label = "PvAI", .handler = PvAI_handler },
};
Point
fromworld(Point2 p)
{
p = invrframexform(p, worldrf);
return Pt(p.x,p.y);
}
Point2
toworld(Point p)
{
return rframexform(Pt2(p.x,p.y,1), worldrf);
}
Point
fromboard(Board *b, Point2 p)
{
p = invrframexform(invrframexform(p, *b), worldrf);
return Pt(p.x,p.y);
}
Point2
toboard(Board *b, Point p)
{
Point2 np;
np = rframexform(rframexform(Pt2(p.x,p.y,1), worldrf), *b);
np.x = floor(np.x);
np.y = floor(np.y);
return np;
}
int
rectXarmada(Rectangle r)
{
int i;
for(i = 0; i < nelem(armada); i++)
if(curship != &armada[i] && rectXrect(r, armada[i].bbox))
return 1;
return 0;
}
Rectangle
mkshipbbox(Point2 p, int o, int ncells)
{
Point2 sv;
assert(o == OH || o == OV);
sv = o == OH? Vec2(1,0): Vec2(0,1);
return Rpt(
fromboard(&localboard, p),
fromboard(&localboard, addpt2(addpt2(p, mulpt2(sv, ncells)), Vec2(sv.y,sv.x)))
);
}
void
csetcursor(Mousectl *mc, Cursor *c)
{
static Cursor *oc;
if(c == oc)
return;
setcursor(mc, c);
oc = c;
}
void
playvfx(int idx, Point p, int times)
{
if(idx < 0 || idx > NVFX)
return;
addvfx(&vfxqueue, newvfx(spritetab[idx]->clone(spritetab[idx]), p, times));
}
void
resetgame(void)
{
int i;
memset(localboard.map, Twater, MAPW*MAPH);
memset(alienboard.map, Twater, MAPW*MAPH);
for(i = 0; i < nelem(armada); i++){
armada[i].bbox = ZR;
memset(armada[i].hit, 0, armada[i].ncells*sizeof(int));
}
curship = nil;
layoutdone = 0;
oid[0] = 0;
gamestate = Waiting0;
conclusion.s = nil;
csetcursor(mctl, nil);
if(!silent){
stopaudio(conclusion.snd);
conclusion.snd = nil;
playaudio(playlist[SBG0]);
}
}
Point
vstring(Image *dst, Point p, Image *src, Point sp, Font *f, char *s)
{
while(*s){
stringn(dst, p, src, sp, f, s++, 1);
p.y += font->height;
}
return p;
}
Image *
gettileimage(int type)
{
if(type < 0 || type > nelem(tiletab))
return nil;
return tiletab[type];
}
void
drawtile(Image *dst, Board *b, Point2 cell, int type)
{
Point p;
Image *ti;
p = fromboard(b, cell);
ti = gettileimage(type);
if(ti == nil)
return;
draw(dst, Rpt(p, addpt(p, Pt(TW,TH))), ti, nil, ZP);
}
void
drawship(Image *dst, Ship *s)
{
Point2 p, sv;
int i;
if(!rectinrect(s->bbox, localboard.bbox))
return;
p = s->p;
assert(s->orient == OH || s->orient == OV);
sv = s->orient == OH? Vec2(1,0): Vec2(0,1);
for(i = 0; i < s->ncells; i++){
drawtile(dst, &localboard, p, s->hit[i]? Thit: Tship);
p = addpt2(p, sv);
}
}
void
drawarmada(Image *dst)
{
int i;
for(i = 0; i < nelem(armada); i++)
drawship(dst, &armada[i]);
}
void
drawboard(Image *dst, Board *b)
{
int i, j;
border(dst, b->bbox, -Borderwidth, pal[PCBrown], ZP);
for(i = 0; i < MAPW; i++)
for(j = 0; j < MAPH; j++)
drawtile(dst, b, Pt2(i,j,1), b->map[i][j]);
}
void
drawtitle(Image *dst)
{
static char s[] = "BATTLESHIP";
string(dst, Pt(SCRW/2 - stringwidth(titlefont, s)/2, 0), pal[PCWhite], ZP, titlefont, s);
draw(dst, rectaddpt(coverimg->r, subpt(dst->r.max, subpt(coverimg->r.max, coverimg->r.min))), coverimg, nil, ZP);
}
void
drawgameoptions(Image *dst)
{
Button *b;
for(b = mainbtns; b < mainbtns+nelem(mainbtns); b++){
draw(dst, b->r, pal[b->status? PCBlack: PCWhite], nil, ZP);
border(dst, b->r, Btnborder, pal[PCWater], ZP);
string(dst, addpt(b->r.min, Pt(Dx(b->r)/2 - stringwidth(font, b->label)/2, Btnpadding + Btnborder)), pal[b->status? PCWhite: PCBlack], ZP, font, b->label);
}
}
void
drawgamestats(Image *dst)
{
Point p, dim;
char buf[32];
if(nplayers < 1)
return;
snprint(buf, sizeof buf, "%d player%s connected", nplayers, nplayers == 1? "": "s");
dim = stringsize(font, buf);
p = Pt(matches->r.min.x + Dx(matches->r)/2, matches->r.max.y + font->height);
p.x -= dim.x/2;
string(dst, p, pal[PCWater], ZP, font, buf);
}
void
drawinfo(Image *dst)
{
Point p;
char *s, buf[32];
int i;
s = "";
switch(gamestate){
case Watching:
snprint(buf, sizeof buf, "watching %s vs. %s", match.pl[0].uid, match.pl[1].uid);
s = buf;
break;
case Ready: s = "looking for players"; break;
case Outlaying: s = "place the fleet"; break;
case Waiting: s = "wait for your turn"; break;
case Playing: s = "your turn"; break;
}
p = Pt(SCRW/2 - stringwidth(font, s)/2, 0);
string(dst, p, pal[PCWhite], ZP, font, s);
s = gamestate == Watching? "PLAYER 1": "TARGET";
p = subpt(alienboard.bbox.min, Pt(font->width+2+Borderwidth,0));
vstring(dst, p, pal[PCWhite], ZP, font, s);
s = gamestate == Watching? "PLAYER 2": "LOCAL";
p = Pt(localboard.bbox.max.x+2+Borderwidth, localboard.bbox.min.y);
vstring(dst, p, pal[PCWhite], ZP, font, s);
p = Pt(alienboard.bbox.max.x+2+Borderwidth, alienboard.bbox.min.y);
vstring(dst, p, pal[PCWhite], ZP, font, gamestate == Watching? match.pl[1].uid: oid);
p = subpt(localboard.bbox.min, Pt(font->width+2+Borderwidth,0));
vstring(dst, p, pal[PCWhite], ZP, font, gamestate == Watching? match.pl[0].uid: uid);
switch(gamestate){
case Outlaying:
if(curship != nil){
snprint(buf, sizeof buf, "%s (%d)", shipname(curship-armada), curship->ncells);
p = Pt(SCRW/2 - stringwidth(font, buf)/2, SCRH-Boardmargin);
string(dst, p, pal[PCYellow], ZP, font, buf);
s = "MMB to rotate the ship";
p = Pt(SCRW/2 - stringwidth(font, s)/2, SCRH-Boardmargin+font->height);
string(dst, p, pal[PCYellow], ZP, font, s);
}else{
s = "done with the layout?";
p = Pt(SCRW/2 - stringwidth(font, s)/2, SCRH-Boardmargin);
string(dst, p, pal[PCYellow], ZP, font, s);
s = "LMB/MMB = No, RMB = Yes";
p = Pt(SCRW/2 - stringwidth(font, s)/2, SCRH-Boardmargin+font->height);
string(dst, p, pal[PCYellow], ZP, font, s);
}
break;
case Watching:
for(i = 0; i < nelem(match.pl); i++)
if(match.pl[i].state == Playing){
snprint(buf, sizeof buf, "it's %s's turn", match.pl[i].uid);
p = Pt(SCRW/2 - stringwidth(font, buf)/2, SCRH-Boardmargin);
string(dst, p, pal[PCBlue], ZP, font, buf);
return;
}
s = "waiting for players to";
p = Pt(SCRW/2 - stringwidth(font, s)/2, SCRH-Boardmargin);
string(dst, p, pal[PCBlue], ZP, font, s);
s = "lay out their fleet";
p = Pt(SCRW/2 - stringwidth(font, s)/2, SCRH-Boardmargin+font->height);
string(dst, p, pal[PCBlue], ZP, font, s);
break;
}
}
void
drawconclusion(Image *dst)
{
static char s[] = "press any key to continue";
if(conclusion.s == nil)
return;
draw(dst, dst->r, pal[PCShadow], nil, ZP);
string(dst, Pt(SCRW/2 - stringwidth(font, conclusion.s)/2, font->height+5), conclusion.c, ZP, font, conclusion.s);
string(dst, Pt(SCRW/2 - stringwidth(font, s)/2, 10*font->height+5), pal[PCWhite], ZP, font, s);
}
void
redraw(void)
{
Vfx *vfx;
lockdisplay(display);
draw(screenb, screenb->r, pal[PCBlack], nil, ZP);
switch(gamestate){
case Waiting0:
drawtitle(screenb);
drawgameoptions(screenb);
matches->draw(matches, screenb);
drawgamestats(screenb);
break;
default:
drawboard(screenb, &alienboard);
drawboard(screenb, &localboard);
drawarmada(screenb);
drawinfo(screenb);
break;
}
for(vfx = vfxqueue.next; vfx != &vfxqueue; vfx = vfx->next)
vfx->draw(vfx, screenb);
drawconclusion(screenb);
draw(screen, screen->r, screenb, nil, ZP);
flushimage(display, 1);
unlockdisplay(display);
}
void
resize(void)
{
int fd;
lockdisplay(display);
if(getwindow(display, Refnone) < 0)
sysfatal("resize failed");
unlockdisplay(display);
if(Dx(screen->r) != SCRW || Dy(screen->r) != SCRH){
fd = open("/dev/wctl", OWRITE);
if(fd >= 0){
fprint(fd, "resize %s", winspec);
close(fd);
}
}
nbsend(drawchan, nil);
}
void
initpalette(void)
{
pal[PCBlack] = display->black;
pal[PCWhite] = display->white;
pal[PCRed] = eallocimage(display, Rect(0,0,1,1), screen->chan, 1, DRed);
pal[PCGreen] = eallocimage(display, Rect(0,0,1,1), screen->chan, 1, DGreen);
pal[PCShip] = eallocimage(display, Rect(0,0,1,1), screen->chan, 1, 0xAAAAAAFF);
pal[PCYellow] = eallocimage(display, Rect(0,0,1,1), screen->chan, 1, DDarkyellow);
pal[PCWater] = eallocimage(display, Rect(0,0,1,1), screen->chan, 1, DPalegreyblue);
pal[PCWaves] = eallocimage(display, Rect(0,0,1,1), screen->chan, 1, DPalebluegreen);
pal[PCBlue] = pal[PCWaves];
pal[PCBrown] = eallocimage(display, Rect(0,0,1,1), screen->chan, 1, 0x806000FF);
pal[PCShadow] = eallocimage(display, Rect(0,0,1,1), RGBA32, 1, 0x0000007f);
}
void
inittiles(void)
{
int i, x, y;
Point pts[2];
for(i = 0; i < nelem(tiletab); i++){
tiletab[i] = eallocimage(display, Rect(0,0,TW,TH), screen->chan, 0, DNofill);
switch(i){
case Twater:
draw(tiletab[i], tiletab[i]->r, pal[PCWater], nil, ZP);
for(pts[0] = ZP, x = 0; x < TW; x++){
y = sin(x)*TH/2;
pts[1] = Pt(x,y+TH/2);
line(tiletab[i], pts[0], pts[1], Endsquare, Endsquare, 0, pal[PCWaves], ZP);
pts[0] = pts[1];
}
break;
case Tship:
draw(tiletab[i], tiletab[i]->r, pal[PCShip], nil, ZP);
fillellipse(tiletab[i], Pt(TW/2,TH/2), 2, 2, pal[PCBlack], ZP);
break;
case Thit:
draw(tiletab[i], tiletab[i]->r, pal[PCRed], nil, ZP);
pts[0] = Pt(TW/2-TW/4,TH/2-TH/4);
pts[1] = Pt(TW/2+TW/4,TH/2+TH/4);
line(tiletab[i], pts[0], pts[1], Endsquare, Endsquare, 1, pal[PCBlack], ZP);
pts[0].y += TH/2;
pts[1].y -= TH/2;
line(tiletab[i], pts[0], pts[1], Endsquare, Endsquare, 1, pal[PCBlack], ZP);
break;
case Tmiss:
draw(tiletab[i], tiletab[i]->r, tiletab[Twater], nil, ZP);
ellipse(tiletab[i], Pt(TW/2,TH/2), 6, 6, 1, pal[PCWhite], ZP);
break;
}
}
}
void
initmainbtns(void)
{
Button *b;
Point btnsize;
btnsize.x = Btnborder + Btnpadding + 100 + Btnpadding + Btnborder;
btnsize.y = Btnborder + Btnpadding + font->height + Btnpadding + Btnborder;
for(b = mainbtns; b < mainbtns+nelem(mainbtns); b++){
b->status = BRest;
if(b == mainbtns)
b->r.min = Pt(SCRW/2 - Btnpadding - 100/2, 8*font->height);
else
b->r.min = addpt(b[-1].r.min, Pt(0, btnsize.y+4));
b->r.max = addpt(b->r.min, btnsize);
}
}
void
initboards(void)
{
memset(alienboard.map, Twater, MAPW*MAPH);
alienboard.p = Pt2(Boardmargin+Borderwidth,Boardmargin+Borderwidth,1);
alienboard.bx = Vec2(TW,0);
alienboard.by = Vec2(0,TH);
alienboard.bbox = Rpt(fromworld(alienboard.p), fromworld(addpt2(alienboard.p, Pt2(TW*MAPW,TH*MAPH,1))));
memset(localboard.map, Twater, MAPW*MAPH);
localboard.p = addpt2(alienboard.p, Vec2(0,MAPH*TH+Borderwidth+TH+Borderwidth));
localboard.bx = Vec2(TW,0);
localboard.by = Vec2(0,TH);
localboard.bbox = Rpt(fromworld(localboard.p), fromworld(addpt2(localboard.p, Pt2(TW*MAPW,TH*MAPH,1))));
}
void
initarmada(void)
{
Ship *s;
int i;
for(i = 0; i < nelem(armada); i++){
s = &armada[i];
s->ncells = shiplen(i);
s->orient = OV;
s->hit = emalloc(s->ncells*sizeof(int));
memset(s->hit, 0, s->ncells*sizeof(int));
}
}
void
initvfx(void)
{
char aux[64];
snprint(aux, sizeof aux, "%s/%s", assetdir, "vfx/battleship.png");
coverimg = readpngimage(aux);
snprint(aux, sizeof aux, "%s/%s", assetdir, "vfx/hit.png");
spritetab[VFXHit] = readpngsprite(aux, ZP, Rect(0, 0, 32, 32), 12, 100);
snprint(aux, sizeof aux, "%s/%s", assetdir, "vfx/miss.png");
spritetab[VFXMiss] = readpngsprite(aux, ZP, Rect(0, 0, 32, 32), 7, 150);
snprint(aux, sizeof aux, "%s/%s", assetdir, "vfx/shining.png");
spritetab[VFXShine] = readpngsprite(aux, ZP, Rect(0, 0, 50, 50), 11, 100);
initvfxq(&vfxqueue);
}
void
initsfx(void)
{
struct {
char *path;
double gain;
int loops;
} sndtab[NSOUNDS] = {
[SBG0] {"sfx/bg0.mp3", 1.0, 1},
[SBG1] {"sfx/bg1.mp3", 1.0, 1},
[SBG2] {"sfx/bg2.mp3", 1.0, 1},
[SCANNON] {"sfx/cannon.mp3", 5.0, 0},
[SWATER] {"sfx/water.mp3", 3.0, 0},
[SVICTORY] {"sfx/victory.mp3", 1.0, 1},
[SDEFEAT] {"sfx/defeat.mp3", 1.0, 1},
};
int i;
char aux[64];
initaudio(44100);
audio_set_master_gain(0.5);
for(i = 0; i < NSOUNDS; i++){
snprint(aux, sizeof aux, "%s/%s", assetdir, sndtab[i].path);
playlist[i] = loadaudiosource(aux);
if(playlist[i] == nil)
sysfatal("loadaudiosource: %r");
audio_set_gain(playlist[i], sndtab[i].gain);
audio_set_loop(playlist[i], sndtab[i].loops);
}
playaudio(playlist[SBG0]);
}
int
confirmdone(Mousectl *mc)
{
Cursor anchor = {
{0, 0},
{ 0x00, 0x00, 0x00, 0x1e, 0x01, 0x92, 0x30, 0xd2,
0x70, 0x7e, 0x60, 0x70, 0x40, 0xf8, 0x41, 0xcc,
0x43, 0x84, 0x47, 0x00, 0x4e, 0x00, 0x5c, 0x00,
0x78, 0x18, 0x70, 0x38, 0x7f, 0xf0, 0x00, 0x00,
},
{ 0x00, 0x3f, 0x03, 0xe1, 0x7a, 0x6d, 0xcb, 0x2d,
0x89, 0x81, 0x99, 0x8f, 0xb3, 0x07, 0xa6, 0x33,
0xac, 0x7a, 0xb8, 0xce, 0xb1, 0x80, 0xa3, 0x3c,
0x86, 0x64, 0x8f, 0xc4, 0x80, 0x0c, 0xff, 0xf8,
},
};
csetcursor(mc, &anchor);
while(mc->buttons != 0) /* ignore any buttons already pressed */
readmouse(mc);
while(mc->buttons == 0) /* wait for a button press */
readmouse(mc);
if(mc->buttons != 4){
while(nbrecv(kctl->c, nil)) /* flush key presses */
csetcursor(mc, nil);
return 0;
}
while(mc->buttons){ /* commit action on button release */
if(mc->buttons != 4){
while(nbrecv(kctl->c, nil));
csetcursor(mc, nil);
return 0;
}
readmouse(mc);
}
while(nbrecv(kctl->c, nil));
csetcursor(mc, nil);
return 1;
}
void
sendlayout(void)
{
char buf[NSHIPS*(1+3+1)+1];
int i, n;
n = 0;
for(i = 0; i < nelem(armada); i++){
assert(sizeof(buf) - n > 1+3+1);
if(i != 0)
buf[n++] = ',';
n += cell2coords(buf+n, sizeof(buf) - n, armada[i].p);
buf[n++] = armada[i].orient == OH? 'h': 'v';
}
buf[n] = 0;
chanprint(egress, "layout %s\n", buf);
layoutdone++;
}
void
lmb(Mousectl *mc)
{
Point2 cell;
Button *b;
char buf[3+1];
if(conclusion.s != nil)
return;
switch(gamestate){
case Waiting0:
for(b = mainbtns; b < mainbtns+nelem(mainbtns); b++)
if(ptinrect(mc->xy, b->r)){
b->handler(b);
break;
}
break;
case Outlaying:
if(!ptinrect(mc->xy, localboard.bbox))
break;
if(curship != nil && rectinrect(curship->bbox, localboard.bbox)){
if(++curship >= armada+nelem(armada)){
curship = nil;
redraw();
if(confirmdone(mc))
sendlayout();
else
curship = &armada[0];
}else if(curship != &armada[0])
curship->orient = (curship-1)->orient;
nbsend(drawchan, nil);
}
break;
case Playing:
if(!ptinrect(mc->xy, alienboard.bbox))
break;
if(!silent)
playaudio(playlist[SCANNON]);
cell = toboard(&alienboard, mc->xy);
cell2coords(buf, sizeof buf, cell);
if(gettile(&alienboard, cell) == Twater){
chanprint(egress, "shoot %s\n", buf);
lastshot = cell;
}
break;
}
}
void
mmb(Mousectl *mc)
{
if(gamestate != Outlaying)
return;
if(curship != nil){
curship->orient = curship->orient == OH? OV: OH;
curship->bbox = mkshipbbox(curship->p, curship->orient, curship->ncells);
if(debug)
fprint(2, "curship orient %c\n", curship->orient == OH? 'h': 'v');
/* steer it, captain! don't let it go off-board! */
if(!rectinrect(curship->bbox, localboard.bbox)){
switch(curship->orient){
case OH:
curship->bbox.min.x -= curship->bbox.max.x - localboard.bbox.max.x;
curship->bbox.max.x = localboard.bbox.max.x;
break;
case OV:
curship->bbox.min.y -= curship->bbox.max.y - localboard.bbox.max.y;
curship->bbox.max.y = localboard.bbox.max.y;
break;
}
curship->p = toboard(&localboard, curship->bbox.min);
moveto(mc, addpt(screen->r.min, curship->bbox.min));
readmouse(mc); /* ignore mmb click triggered by moveto */
}
/* …nor ram allied ships! */
if(rectXarmada(curship->bbox))
curship->bbox = ZR;
nbsend(drawchan, nil);
}
}
void
mouse(Mousectl *mc)
{
static Mouse oldm;
Rectangle newbbox;
Button *b;
int selmatch;
mc->xy = subpt(mc->xy, screen->r.min);
if(gamestate == Waiting0){
for(b = mainbtns; b < mainbtns+nelem(mainbtns); b++){
if(ptinrect(mc->xy, b->r)){
if(b->status == BRest)
playvfx(VFXShine, addpt(b->r.min, Pt(Btnborder, Btnborder)), 1);
b->status = BHover;
}else
b->status = BRest;
}
nbsend(drawchan, nil);
if((selmatch = matches->update(matches, mc, drawchan)) >= 0){
if(debug) fprint(2, "selected match id %d title %s\n",
matches->entries[selmatch].id,
matches->entries[selmatch].title);
chanprint(egress, "watch %d\n", matches->entries[selmatch].id);
}
}
if(gamestate == Outlaying && curship != nil){
newbbox = mkshipbbox(toboard(&localboard, mc->xy), curship->orient, curship->ncells);
if(ptinrect(mc->xy, localboard.bbox))
csetcursor(mctl, &boxcursor);
else
csetcursor(mctl, nil);
if(rectinrect(newbbox, localboard.bbox) && !rectXarmada(newbbox)){
curship->p = toboard(&localboard, mc->xy);
curship->bbox = newbbox;
nbsend(drawchan, nil);
}
}
if(gamestate == Playing && conclusion.s == nil)
if(ptinrect(mc->xy, alienboard.bbox))
csetcursor(mctl, &aimcursor);
else
csetcursor(mctl, nil);
if(oldm.buttons != mc->buttons)
switch(mc->buttons){
case 1:
lmb(mc);
break;
case 2:
mmb(mc);
break;
}
oldm = mc->Mouse;
}
void
key(Rune r)
{
if(conclusion.s != nil){
resetgame();
nbsend(drawchan, nil);
return;
}
switch(r){
case Kdel:
threadexitsall(nil);
case Kesc:
case 'q':
if(gamestate == Waiting0)
threadexitsall(nil);
nbsend(reconnc, nil);
break;
}
}
void
celebrate(void)
{
static char s[] = "YOU WON!";
conclusion.c = pal[PCGreen];
conclusion.s = s;
if(!silent){
conclusion.snd = playlist[SVICTORY];
stopaudio(playlist[SBG2]);
playaudio(conclusion.snd);
}
}
void
keelhaul(void)
{
static char s[] = "...YOU LOST";
conclusion.c = pal[PCRed];
conclusion.s = s;
if(!silent){
conclusion.snd = playlist[SDEFEAT];
stopaudio(playlist[SBG2]);
playaudio(conclusion.snd);
}
}
void
announcewinner(char *winner)
{
static char s[16];
if(winner == nil)
return;
snprint(s, sizeof s, "%s WON", winner);
conclusion.c = pal[PCGreen];
conclusion.s = s;
if(!silent){
conclusion.snd = playlist[SVICTORY];
stopaudio(playlist[SBG2]);
playaudio(conclusion.snd);
}
}
void
processcmd(char *cmd)
{
Cmdbuf *cb;
Cmdtab *ct;
Point2 cell;
uchar buf[BY2MAP];
int i, idx;
struct {
int high, off;
} menuparams;
if(debug)
fprint(2, "rcvd '%s'\n", cmd);
cb = parsecmd(cmd, strlen(cmd));
ct = lookupcmd(cb, svcmd, nelem(svcmd));
if(ct == nil){
free(cb);
return;
}
switch(ct->index){
case CMwin:
celebrate();
break;
case CMlose:
keelhaul();
break;
}
switch(gamestate){
case Waiting0:
switch(ct->index){
case CMid:
chanprint(egress, "id %s\n", uid);
break;
case CMqueued:
gamestate = Ready;
csetcursor(mctl, &patrolcursor);
break;
case CMmatches:
if(!matches->filling){
menuparams.high = matches->high;
menuparams.off = matches->off;
matches->clear(matches);
matches->filling = 1;
}
break;
case CMmatch:
if(matches->filling)
matches->add(matches, strtoul(cb->f[1], nil, 10),
smprint("%s vs %s", cb->f[2], cb->f[3]));
break;
case CMendmatches:
if(matches->filling){
matches->high = min(menuparams.high, matches->nentries-1);
matches->off = menuparams.off > matches->nentries - matches->maxvis?
0: menuparams.off;
matches->filling = 0;
}
break;
case CMwatching:
match.id = strtoul(cb->f[1], nil, 10);
snprint(match.pl[0].uid, sizeof match.pl[0].uid, "%s", cb->f[2]);
snprint(match.pl[1].uid, sizeof match.pl[1].uid, "%s", cb->f[3]);
match.pl[0].state = Outlaying;
match.pl[1].state = Outlaying;
match.bl[0] = &localboard;
match.bl[1] = &alienboard;
gamestate = Watching;
if(!silent){
stopaudio(playlist[SBG0]);
playaudio(playlist[SBG2]);
}
break;
case CMstats:
nplayers = strtoul(cb->f[1], nil, 10);
break;
}
break;
case Ready:
switch(ct->index){
case CMlayout:
gamestate = Outlaying;
curship = &armada[0];
if(!silent){
stopaudio(playlist[SBG0]);
playaudio(playlist[SBG2]);
}
break;
case CMoid:
snprint(oid, sizeof oid, "%s", cb->f[1]);
break;
}
break;
case Watching:
switch(ct->index){
case CMplayeroutlay:
idx = strtoul(cb->f[1], nil, 10);
if(dec64(buf, sizeof buf, cb->f[2], strlen(cb->f[2])) < 0)
sysfatal("dec64 failed");
bitunpackmap(match.bl[idx], buf, sizeof buf);
match.pl[idx].state = Waiting;
break;
case CMplayerhit:
idx = strtoul(cb->f[1], nil, 10);
cell = coords2cell(cb->f[2]);
settile(match.bl[idx^1], cell, Thit);
playvfx(VFXHit, addpt(fromboard(match.bl[idx^1], cell), Pt(TW/2, TH/2)), 1);
break;
case CMplayermiss:
idx = strtoul(cb->f[1], nil, 10);
cell = coords2cell(cb->f[2]);
settile(match.bl[idx^1], cell, Tmiss);
playvfx(VFXMiss, addpt(fromboard(match.bl[idx^1], cell), Pt(TW/2, TH/2)), 1);
break;
case CMplayerplays:
idx = strtoul(cb->f[1], nil, 10);
match.pl[idx].state = Playing;
match.pl[idx^1].state = Waiting;
break;
case CMplayerwon:
idx = strtoul(cb->f[1], nil, 10);
announcewinner(match.pl[idx].uid);
break;
}
break;
case Outlaying:
switch(ct->index){
case CMwait:
gamestate = Waiting;
csetcursor(mctl, &waitcursor);
break;
case CMplay:
gamestate = Playing;
break;
}
break;
case Playing:
switch(ct->index){
case CMwait:
gamestate = Waiting;
csetcursor(mctl, &waitcursor);
break;
case CMwehit:
settile(&alienboard, lastshot, Thit);
playvfx(VFXHit, addpt(fromboard(&alienboard, lastshot), Pt(TW/2, TH/2)), 1);
break;
case CMwemiss:
if(!silent)
playaudio(playlist[SWATER]);
settile(&alienboard, lastshot, Tmiss);
playvfx(VFXMiss, addpt(fromboard(&alienboard, lastshot), Pt(TW/2, TH/2)), 1);
break;
}
break;
case Waiting:
switch(ct->index){
case CMplay:
gamestate = Playing;
csetcursor(mctl, nil);
break;
case CMtheyhit:
cell = coords2cell(cb->f[1]);
for(i = 0; i < nelem(armada); i++)
if(ptinrect(fromboard(&localboard, cell), armada[i].bbox)){
playvfx(VFXHit, addpt(fromboard(&localboard, cell), Pt(TW/2, TH/2)), 1);
cell = subpt2(cell, armada[i].p);
armada[i].hit[(int)vec2len(cell)] = 1;
break;
}
break;
case CMtheymiss:
cell = coords2cell(cb->f[1]);
settile(&localboard, cell, Tmiss);
playvfx(VFXMiss, addpt(fromboard(&localboard, cell), Pt(TW/2, TH/2)), 1);
break;
}
break;
}
free(cb);
nbsend(drawchan, nil);
}
void
soundproc(void *)
{
Biobuf *aout;
uchar buf[1024];
threadsetname("soundproc");
aout = Bopen("/dev/audio", OWRITE);
if(aout == nil)
sysfatal("Bopen: %r");
for(;;){
processaudio((void*)buf, sizeof(buf)/2);
Bwrite(aout, buf, sizeof buf);
}
}
void
timerproc(void *)
{
Vfx *vfx;
uvlong t0, Δt, φt, acc;
int refresh;
threadsetname("timer");
t0 = nsec();
acc = 0;
for(;;){
Δt = nsec() - t0;
φt = Δt/1000000ULL;
acc += Δt;
refresh = 0;
for(vfx = vfxqueue.next; vfx != &vfxqueue; vfx = vfx->next){
vfx->step(vfx, φt);
refresh = 1;
}
if(refresh)
nbsend(drawchan, nil);
if(gamestate == Waiting0 && acc >= 5*SEC){
chanprint(egress, "watch\n");
chanprint(egress, "stats\n");
acc = 0;
}
t0 += Δt;
sleep(HZ2MS(20));
}
}
void
netrecvthread(void *arg)
{
Ioproc *io;
char buf[256], *e;
int n, tot, fd;
fd = *(int*)arg;
io = ioproc();
tot = 0;
while((n = ioread(io, fd, buf+tot, sizeof(buf)-1-tot)) > 0){
tot += n;
buf[tot] = 0;
while((e = strchr(buf, '\n')) != nil){
*e++ = 0;
processcmd(buf);
tot -= e-buf;
memmove(buf, e, tot);
}
if(tot >= sizeof(buf)-1)
tot = 0;
}
closeioproc(io);
threadexits(nil);
}
void
netsendthread(void *arg)
{
char *s;
int fd;
fd = *(int*)arg;
while(recv(egress, &s) > 0){
if(write(fd, s, strlen(s)) != strlen(s))
break;
if(debug)
fprint(2, "sent '%s'\n", s);
free(s);
}
threadexits(nil);
}
void
usage(void)
{
fprint(2, "usage: %s [-ds] addr\n", argv0);
threadexitsall("usage");
}
void
threadmain(int argc, char *argv[])
{
char aux[64];
char *addr;
char *user;
int fd, cfd;
Mousectl *mc;
Keyboardctl *kc;
Rune r;
GEOMfmtinstall();
ARGBEGIN{
case 'd':
debug++;
break;
case 's':
silent++;
break;
default: usage();
}ARGEND
if(argc != 1)
usage();
snprint(winspec, sizeof winspec, "-dx %d -dy %d", SCRW, SCRH);
if(debug && newwindow(winspec) < 0)
sysfatal("newwindow: %r");
if(initdraw(nil, deffont, "bts") < 0)
sysfatal("initdraw: %r");
if((mc = initmouse(nil, screen)) == nil)
sysfatal("initmouse: %r");
if((kc = initkeyboard(nil)) == nil)
sysfatal("initkeyboard: %r");
display->locking = 1;
unlockdisplay(display);
resize();
mctl = mc;
kctl = kc;
if((user = getenv("user")) == nil)
user = getuser();
snprint(uid, sizeof uid, "%s", user);
screenb = eallocimage(display, Rect(0,0,SCRW,SCRH), screen->chan, 0, DNofill);
worldrf.p = Pt2(0,0,1);
worldrf.bx = Vec2(1,0);
worldrf.by = Vec2(0,1);
snprint(aux, sizeof aux, "%s/%s", assetdir, titlefontpath);
titlefont = openfont(display, aux);
if(titlefont == nil)
sysfatal("openfont: %r");
initpalette();
inittiles();
initmainbtns();
initboards();
initarmada();
initvfx();
matches = newmenulist(14*font->height, "ongoing matches");
gamestate = Waiting0;
if(!silent){
initsfx();
proccreate(soundproc, nil, mainstacksize);
}
addr = netmkaddr(argv[0], "tcp", "3047");
if(debug)
fprint(2, "connecting to %s\n", addr);
fd = dial(addr, nil, nil, &cfd);
if(fd < 0)
sysfatal("dial: %r");
else if(debug)
fprint(2, "line established\n");
drawchan = chancreate(sizeof(void*), 1);
reconnc = chancreate(sizeof(void*), 1);
ingress = chancreate(sizeof(char*), 8);
egress = chancreate(sizeof(char*), 8);
threadcreate(netrecvthread, &fd, mainstacksize);
threadcreate(netsendthread, &fd, mainstacksize);
nbsend(drawchan, nil);
proccreate(timerproc, nil, mainstacksize);
enum { MOUSE, RESIZE, KEYS, DRAW, RECONN, NONE };
Alt a[] = {
[MOUSE] {mc->c, &mc->Mouse, CHANRCV},
[RESIZE] {mc->resizec, nil, CHANRCV},
[KEYS] {kc->c, &r, CHANRCV},
[DRAW] {drawchan, nil, CHANRCV},
[RECONN] {reconnc, nil, CHANRCV},
[NONE] {nil, nil, CHANEND}
};
for(;;)
switch(alt(a)){
case MOUSE:
mouse(mc);
break;
case RESIZE:
resize();
break;
case KEYS:
key(r);
break;
case DRAW:
redraw();
break;
case RECONN:
if(debug)
fprint(2, "reconnecting to %s\n", addr);
write(cfd, "close", 5);
close(cfd);
close(fd);
fd = dial(addr, nil, nil, &cfd);
if(fd < 0)
sysfatal("dial: %r");
else if(debug)
fprint(2, "line established\n");
threadcreate(netrecvthread, &fd, mainstacksize);
threadcreate(netsendthread, &fd, mainstacksize);
resetgame();
nbsend(drawchan, nil);
break;
default:
sysfatal("input thread interrupted");
}
}