Mercurial Hosting > chat
comparison src/chat.luan @ 59:8270106644db
add chat.luan
| author | Franklin Schmidt <fschmidt@gmail.com> |
|---|---|
| date | Tue, 04 Mar 2025 08:22:45 -0700 |
| parents | |
| children | a47036fd0158 |
comparison
equal
deleted
inserted
replaced
| 58:7b6691bd65c3 | 59:8270106644db |
|---|---|
| 1 local Luan = require "luan:Luan.luan" | |
| 2 local error = Luan.error | |
| 3 local pairs = Luan.pairs or error() | |
| 4 local Table = require "luan:Table.luan" | |
| 5 local concat = Table.concat or error() | |
| 6 local is_empty = Table.is_empty or error() | |
| 7 local Http = require "luan:http/Http.luan" | |
| 8 local Shared = require "site:/lib/Shared.luan" | |
| 9 local http_push_to_users = Shared.http_push_to_users or error() | |
| 10 local User = require "site:/lib/User.luan" | |
| 11 local current_user = User.current or error() | |
| 12 local get_user_by_email = User.get_by_email or error() | |
| 13 local Utils = require "site:/lib/Utils.luan" | |
| 14 local to_set = Utils.to_set or error() | |
| 15 local Db = require "site:/lib/Db.luan" | |
| 16 local run_in_transaction = Db.run_in_transaction or error() | |
| 17 local Chat = require "site:/lib/Chat.luan" | |
| 18 local get_chat_by_user_ids = Chat.get_by_user_ids or error() | |
| 19 | |
| 20 | |
| 21 return function() | |
| 22 local with = Http.request.parameters.with | |
| 23 local user = current_user() | |
| 24 with = to_set(with) | |
| 25 if user == nil then | |
| 26 local url = "/login.html" | |
| 27 if not is_empty(with) then | |
| 28 local t = {} | |
| 29 for email in pairs(with) do | |
| 30 t[#t+1] = "with="..email | |
| 31 end | |
| 32 url = url.."?"..concat(t,"&") | |
| 33 end | |
| 34 Http.response.send_redirect(url) | |
| 35 return | |
| 36 end | |
| 37 if is_empty(with) then | |
| 38 Http.response.send_redirect("/") | |
| 39 return | |
| 40 end | |
| 41 with[user.email] = true | |
| 42 local ids = {} | |
| 43 for email in pairs(with) do | |
| 44 local with_user = get_user_by_email(email) or error() | |
| 45 local id = with_user.id | |
| 46 ids[#ids+1] = id | |
| 47 end | |
| 48 local need_push = false | |
| 49 local chat = run_in_transaction( function() | |
| 50 local chat = get_chat_by_user_ids(ids) | |
| 51 if chat == nil then | |
| 52 chat = Chat.new{ | |
| 53 user_ids = ids | |
| 54 } | |
| 55 chat.save() | |
| 56 need_push = true | |
| 57 end | |
| 58 return chat | |
| 59 end ) | |
| 60 if need_push then | |
| 61 local js = "getChats('"..chat.id.."')" | |
| 62 http_push_to_users( chat.user_ids, js ) | |
| 63 end | |
| 64 Http.response.send_redirect("/?chat="..chat.id) | |
| 65 end |