# Copyright 2012-2014 Institut National des Sciences Appliquées de Lyon (INSA-Lyon) # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. module samples.TemplatesChatWebapp import java.lang import java.io import java.net.InetSocketAddress import com.sun.net.httpserver import com.sun.net.httpserver.HttpServer local function redirect = |exchange, to| { exchange: getResponseHeaders(): set("Location", to) exchange: sendResponseHeaders(303, 0) exchange: close() } local function respond = |exchange, body| { exchange: getResponseHeaders(): set("Content-Type", "text/html") exchange: sendResponseHeaders(200, body: length()) exchange: getResponseBody(): write(body: getBytes()) exchange: close() } # This is leaky and works with just 1 POST parameter... local function extract_post = |exchange, posts| { let reader = BufferedReader(InputStreamReader(exchange: getRequestBody())) var line = reader: readLine() while line isnt null { if line: startsWith("msg=") { posts: add(java.net.URLDecoder.decode(line: substring(4), "UTF-8")) } line = reader: readLine() } reader: close() } local function index = |posts, template, exchange| { if exchange: getRequestMethod() == "POST" { extract_post(exchange, posts) redirect(exchange, "/") } else { respond(exchange, template(posts)) } } local function index_template = -> """ <%@params posts %> Golo Chat

Last posts

<% foreach post in posts { %>
<%= post %>
<% } %>
""" function main = |args| { let index_tpl = gololang.TemplateEngine(): compile(index_template()) let posts = java.util.concurrent.ConcurrentLinkedDeque() let server = HttpServer.create(InetSocketAddress("localhost", 8081), 0) server: createContext("/", ^index: bindTo(posts): bindTo(index_tpl)) server: start() println(">>> http://localhost:8081/") }