index.erl 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343
  1. -module(index).
  2. -compile(export_all).
  3. -include_lib("n2o/include/wf.hrl").
  4. -include("../../server/include/requests.hrl").
  5. -include("../../server/include/settings.hrl").
  6. -include_lib("avz/include/avz.hrl").
  7. -include_lib("kvs/include/user.hrl").
  8. -define(GAMEID, 1000001).
  9. -record(okey_player,
  10. {
  11. player_id,
  12. label_id,
  13. player_info,
  14. right_pile_combo_id,
  15. right_pile = [],
  16. left_label_id
  17. }
  18. ).
  19. user() ->
  20. case wf:user() of undefined ->
  21. Imagionary = fake_users:imagionary_users(),
  22. {Id,Name,Surname} = lists:nth(crypto:rand_uniform(1,length(Imagionary)),Imagionary),
  23. X = #user{id = fake_users:fake_id(Id),
  24. names = Name,
  25. surnames = Surname},
  26. wf:user(X), X; U-> U end.
  27. color(Id,Color) -> wf:wire(wf:f("document.querySelector('#~s').style.color = \"~s\";",[Id,Color])).
  28. unselect(Id) -> color(Id,black).
  29. select(Id) -> color(Id,red).
  30. redraw_discard_combo(TilesList) ->
  31. redraw_tiles(TilesList, #dropdown{id = discard_combo, postback = combo, source = [discard_combo]}).
  32. redraw_tiles(undefined, _DropDown) -> [];
  33. redraw_tiles([] = _TilesList, DropDown = #dropdown{id = ElementId}) ->
  34. wf:update(ElementId, [DropDown#dropdown{value = [], options = []}]);
  35. redraw_tiles([{Tile, _}| _ ] = TilesList, DropDown = #dropdown{id = ElementId}) ->
  36. wf:update(ElementId, [DropDown#dropdown{value = Tile, options = [#option{label = CVBin, value = CVBin} || {CVBin, _} <- TilesList]}]).
  37. redraw_players(Players) ->
  38. User = user(),
  39. [ begin PN = player_name(PI),
  40. wf:update(LabelId, #label{ id = LabelId,
  41. style= case User#user.id == Id of
  42. true -> "font-weight: bold;";
  43. _ -> "" end, body = <<" ",PN/binary," ">>})
  44. end || #okey_player{label_id = LabelId, player_info = #'PlayerInfo'{id = Id} = PI} <- Players].
  45. update_players(UpdatedPlayer = #okey_player{label_id = LabelId}, Players) ->
  46. lists:sort(
  47. fun(#okey_player{label_id = E1}, #okey_player{label_id = E2}) -> E1 < E2 end,
  48. [UpdatedPlayer | lists:keydelete(LabelId, #okey_player.label_id, Players)]
  49. ).
  50. player_name(PI) -> auth_server:player_name(PI).
  51. main() -> #dtl{file="index", bindings=[{title,<<"N2O">>},{body,body()}]}.
  52. body() ->
  53. wf:wire(#api{name=plusLogin, tag=plus}),
  54. [ #panel{ id=history },
  55. #button{ id = plusloginbtn, body = <<"Login">>, postback=login_button},
  56. #label{ body = " Google"},#br{},#br{},
  57. #label{ id = gosterge, body="Gosterge: "}, #br{},#br{},
  58. #label{ id = player1, body = "Player 1"},
  59. #dropdown{ id = p1right_combo, options = []},#br{},
  60. #label{ id = player2, body = "Player 2"},
  61. #dropdown{ id = p2right_combo, options = []},#br{},
  62. #label{ id = player3, body = "Player 3"},
  63. #dropdown{ id = p3right_combo, options = []}, #br{},
  64. #label{ id = player4, body = "Player 4"},
  65. #dropdown{ id = p4right_combo, options = []},#br{},
  66. #br{},
  67. #button{ id = attach, body = <<"Attach">>, postback = attach},
  68. #button{ id = join, body = <<"Join">>, postback = join},
  69. #dropdown{ id= take_combo, value="0",
  70. options =
  71. [
  72. #option { label= <<"Table">>, value= <<"0">> },
  73. #option { label= <<"Left">>, value= <<"1">> }
  74. ]
  75. },
  76. #button{ id=take, body = <<"Take">>, postback = take, source=[take_combo]},
  77. #dropdown{ id=discard_combo, value="2", postback=combo, source=[discard_combo],
  78. options =
  79. [
  80. #option { label= <<"Option 1">>, value= <<"1">> },
  81. #option { label= <<"Option 2">>, value= <<"2">> },
  82. #option { label= <<"Option 3">>, value= <<"3">> }
  83. ]
  84. },
  85. #button{ id = discard, body = <<"Discard">>, postback = discard, source=[discard_combo]},
  86. #button{ id = reveal, body = <<"Reveal">>, postback = reveal, source = [discard_combo]},
  87. #button{ id = is_saw_okey, body = <<"I Saw Okey">>, postback = i_saw_okey},
  88. #button{ id = pause, body = <<"Pause">>, postback = pause},
  89. #button{ id = player_info, body = <<"PlayerInfo">>, postback = player_info}
  90. ].
  91. event(terminate) -> wf:info("terminate");
  92. event(init) -> event(attach), event(join);
  93. event(login_button) -> wf:wire(protocol:logout());
  94. event(join) -> wf:wire(protocol:join(wf:to_list(?GAMEID)));
  95. event(take) -> wf:wire(protocol:take(wf:to_list(?GAMEID), wf:q(take_combo)));
  96. event(player_info) ->
  97. User = user(),
  98. wf:wire(protocol:player_info(
  99. wf:f("'~s'",[wf:to_list(User#user.id)]),wf:f("'~s'",[game_okey])));
  100. event(attach) ->
  101. {ok,GamePid} = game_session:start_link(self()),
  102. wf:session(<<"game_pid">>,GamePid),
  103. User = user(),
  104. put(okey_im, User#user.id),
  105. wf:info("Session User: ~p",[User]),
  106. Token = auth_server:generate_token(?GAMEID,User),
  107. wf:wire(protocol:attach(wf:f("'~s'",[Token]))),
  108. ok;
  109. event(discard) ->
  110. TilesList = get(game_okey_tiles),
  111. DiscardCombo = wf:q(discard_combo),
  112. case lists:keyfind(erlang:list_to_binary(DiscardCombo), 1, TilesList) of
  113. {_, {C, V}} ->
  114. wf:wire(protocol:discard(wf:to_list(?GAMEID), wf:to_list(C), wf:to_list(V)));
  115. false -> wf:info("Discard Combo: ~p",[DiscardCombo]) end;
  116. event(reveal) ->
  117. TilesList = case get(game_okey_tiles) of undefined -> []; T -> T end,
  118. Discarded = wf:q(discard_combo),
  119. case lists:keyfind(wf:to_binary(Discarded), 1, TilesList) of
  120. {_, {CD, VD} = Key} ->
  121. Hand = [{C,V} || {_, {C, V}} <- lists:keydelete(Key, 2, TilesList) ],
  122. HandJS = "[[" ++ string:join([
  123. wf:f("tuple(atom('OkeyPiece'),~p,~p)",[C,V]) || {C,V} <- Hand],",") ++ "],[]]",
  124. RevealJS = protocol:reveal(wf:to_list(?GAMEID),wf:f("~p",[CD]),wf:f("~p",[VD]),HandJS),
  125. wf:info("RevealJS: ~p",[lists:flatten(RevealJS)]),
  126. wf:wire(RevealJS);
  127. _ ->
  128. wf:info("error discarded ~p", Discarded)
  129. end;
  130. event(i_saw_okey) ->
  131. wf:info("i_saw_okey!"),
  132. wf:wire(protocol:i_saw_okey(wf:to_list(?GAMEID)));
  133. event(pause) ->
  134. Action =
  135. case get(game_okey_pause) of
  136. X when X == resume orelse X == undefined ->
  137. put(game_okey_pause, pause),
  138. wf:update(pause, [#button{id = pause, body = "Resume", postback = pause}]),
  139. "pause";
  140. pause ->
  141. put(game_okey_pause, resume),
  142. wf:update(pause, [#button{id = pause, body = <<"Pause">>, postback = pause}]),
  143. "resume"
  144. end,
  145. wf:wire(protocol:pause(wf:to_list(?GAMEID), wf:f("~p", [Action])));
  146. %event({binary,M}) -> {ok,<<"Hello">>};
  147. event({client,Message}) ->
  148. case wf:session(<<"game_pid">>) of
  149. undefined -> skip;
  150. GamePid -> game_session:process_request(GamePid, Message) end;
  151. event({server, {game_event, _, okey_game_started, Args}}) ->
  152. {_, Tiles} = lists:keyfind(tiles, 1, Args),
  153. TilesList = [{wf:to_binary([wf:to_list(C)," ",wf:to_list(V)]), {C, V}} || {_, C, V} <- Tiles],
  154. %%wf:info("tiles ~p", [TilesList]),
  155. case lists:keyfind(gosterge, 1, Args) of
  156. {_, {_, C, V}} ->
  157. wf:update(gosterge, #label{id = gosterge, body = wf:to_binary(["Gosterge: ", wf:to_list(C), " ", wf:to_list(V)])});
  158. _ ->
  159. ok
  160. end,
  161. put(game_okey_tiles, TilesList),
  162. put(game_okey_pause, resume),
  163. redraw_discard_combo(TilesList);
  164. event({server, {game_event, _, okey_game_player_state, Args}}) ->
  165. case lists:keyfind(whos_move, 1, Args) of
  166. {_, null} ->
  167. ok;
  168. {_, WhosMove} ->
  169. Players = get(okey_players),
  170. #okey_player{label_id = X} = lists:keyfind(WhosMove, #okey_player.player_id, Players),
  171. case X of
  172. null -> skip;
  173. false -> skip;
  174. X -> select(X), put(okey_turn_mark,X) end,
  175. {_, Tiles} = lists:keyfind(tiles, 1, Args),
  176. TilesList = [{wf:to_binary([wf:to_list(C)," ",wf:to_list(V)]),{C, V}}|| {_, C, V} <- Tiles],
  177. redraw_discard_combo(TilesList),
  178. put(game_okey_tiles, TilesList),
  179. {_, Piles} = lists:keyfind(piles, 1, Args),
  180. UpdatedPlayers =
  181. [
  182. begin
  183. Player = #okey_player{right_pile_combo_id = RightPileComboId} = lists:keyfind(PlayerId, #okey_player.player_id, Players),
  184. ConvertedPile = [{wf:to_binary([wf:to_list(C), " ", wf:to_list(V)]), {C, V}} || {_, C, V} <- Pile],
  185. redraw_tiles(ConvertedPile, #dropdown{id = RightPileComboId}),
  186. Player#okey_player{right_pile = ConvertedPile}
  187. end
  188. || {PlayerId, Pile} <- Piles
  189. ],
  190. put(okey_players, lists:sort(fun(#okey_player{label_id = E1}, #okey_player{label_id = E2}) -> E1 < E2 end, UpdatedPlayers));
  191. _ ->
  192. ok
  193. end;
  194. event({server, {game_event, _, okey_tile_taken, Args}}) ->
  195. Im = get(okey_im),
  196. {_, PlayerId} = lists:keyfind(player, 1, Args),
  197. case lists:keyfind(revealed, 1, Args) of
  198. {_, {_, C, V}} ->
  199. if
  200. Im == PlayerId ->
  201. TilesList = [{wf:to_binary([wf:to_list(C), " ", wf:to_list(V)]), {C, V}} | get(game_okey_tiles)],
  202. %%wf:info("Tiles: ~p",[TilesList]),
  203. put(game_okey_tiles, TilesList),
  204. redraw_discard_combo(TilesList);
  205. true ->
  206. ok
  207. end,
  208. case lists:keyfind(pile, 1, Args) of
  209. {_, 1} -> %% have taken from left
  210. Players = get(okey_players),
  211. #okey_player{left_label_id = LeftLabelId} = lists:keyfind(PlayerId, #okey_player.player_id, Players),
  212. LeftPlayer =
  213. #okey_player{right_pile_combo_id = RightPileComboId, right_pile = RightPile} =
  214. lists:keyfind(LeftLabelId, #okey_player.label_id, Players),
  215. UpdatedRightPile = lists:keydelete({C, V}, 2, RightPile),
  216. redraw_tiles(UpdatedRightPile, #dropdown{id = RightPileComboId}),
  217. UpdatedPlayers = update_players(LeftPlayer#okey_player{right_pile = UpdatedRightPile}, Players),
  218. put(okey_players, UpdatedPlayers);
  219. _ ->
  220. ok
  221. end;
  222. _ -> ok
  223. end;
  224. event({server, {game_event, _, okey_tile_discarded, Args}}) ->
  225. Im = get(okey_im),
  226. {_, PlayerId} = lists:keyfind(player, 1, Args),
  227. {_, {_, C, V}} = lists:keyfind(tile, 1, Args),
  228. if
  229. Im == PlayerId ->
  230. TilesListOld = get(game_okey_tiles),
  231. TilesList = lists:keydelete({C, V}, 2, TilesListOld),
  232. put(game_okey_tiles, TilesList),
  233. redraw_discard_combo(TilesList);
  234. true ->
  235. ok
  236. end,
  237. Players = get(okey_players),
  238. Player =
  239. #okey_player{right_pile_combo_id = RightPileComboId, right_pile = OldRightPile} =
  240. lists:keyfind(PlayerId, #okey_player.player_id, Players),
  241. NewRightPile = [{wf:to_binary([wf:to_list(C), " ", wf:to_list(V)]), {C, V}} | OldRightPile],
  242. redraw_tiles(NewRightPile, #dropdown{id = RightPileComboId}),
  243. UpdatedPlayer = Player#okey_player{right_pile = NewRightPile},
  244. UpdatedPlayers = update_players(UpdatedPlayer, Players),
  245. put(okey_players, UpdatedPlayers);
  246. event({server,{game_event, _Game, okey_turn_timeout, Args}}) ->
  247. wf:info("okey_turn_timeout ~p", [Args]);
  248. event({server, {game_event, _, okey_game_info, Args}}) ->
  249. %% wf:info("okay_game_info ~p", [Args]),
  250. {_, PlayersInfo} = lists:keyfind(players, 1, Args),
  251. PlayersTempl =
  252. [
  253. #okey_player{label_id = player1, right_pile_combo_id = p1right_combo, left_label_id = player4},
  254. #okey_player{label_id = player2, right_pile_combo_id = p2right_combo, left_label_id = player1},
  255. #okey_player{label_id = player3, right_pile_combo_id = p3right_combo, left_label_id = player2},
  256. #okey_player{label_id = player4, right_pile_combo_id = p4right_combo, left_label_id = player3}
  257. ],
  258. Players =
  259. lists:zipwith(
  260. fun(Players, #'PlayerInfo'{id = Id} = PI) ->
  261. Players#okey_player{player_id = Id, player_info = PI} end,
  262. PlayersTempl,
  263. PlayersInfo),
  264. put(okey_players, Players),
  265. % wf:info("players ~p", [Players]),
  266. redraw_players(Players);
  267. event({server,{game_event, _, player_left, Args}}) ->
  268. {_, OldPlayerId} = lists:keyfind(player, 1, Args),
  269. {_, PI} = lists:keyfind(replacement, 1, Args),
  270. #'PlayerInfo'{id = NewPlayerId} = PI,
  271. OldPlayers = get(okey_players),
  272. OldPlayer = lists:keyfind(OldPlayerId, #okey_player.player_id, OldPlayers),
  273. NewPlayers = update_players(OldPlayer#okey_player{player_id = NewPlayerId, player_info = PI}, OldPlayers),
  274. put(okey_players, NewPlayers),
  275. redraw_players(NewPlayers),
  276. case get(okey_turn_mark) of undefined -> ok; X -> select(X) end;
  277. event({server,{game_event, _, okey_next_turn, Args}}) ->
  278. {player, PlayerId} = lists:keyfind(player, 1, Args),
  279. % wf:info("im ~p next turn players ~p ~p", [get(okey_im), PlayerId, get(okey_players)]),
  280. #okey_player{label_id = LabelId} = lists:keyfind(PlayerId, #okey_player.player_id, get(okey_players)),
  281. case get(okey_turn_mark) of
  282. undefined -> ok;
  283. OldLabelId -> unselect(OldLabelId) end,
  284. select(LabelId),
  285. put(okey_turn_mark, LabelId);
  286. event({register,User}) -> wf:info("Register: ~p",[User]), kvs:add(User), wf:user(User);
  287. event({login,User}) -> wf:info("Login: ~p",[User]), kvs:put(User), wf:user(User), event(init);
  288. event(_Event) -> wf:info("Event: ~p", [_Event]).
  289. api_event(X,Y,Z) -> avz:api_event(X,Y,Z).