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
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
|
local strict = require 'strict'
local m2 = require 'mongrel2'
local ui = require 'ui'
local engine = require 'engine'
local db = require 'db'
local function new_user(conn, req, user, password)
req = ui.prompt(conn, req, 'new_user')
while req.data.msg ~= password do
req = ui.prompt(conn, req, 'repeat_pass')
end
db.register_user(user, password)
ui.screen(conn, req, 'welcome_newbie')
end
local function read_long_message(conn, req, user)
local msg = {}
ui.screen(conn, req, 'leave_msg')
req = ui.ask(conn, req, 'From: ' .. user .. '\n---', '')
while req.data.msg ~= '.' and #msg < 24 do
table.insert(msg, req.data.msg)
req = ui.ask(conn, req, '', '')
end
return msg
end
local function message_iterator(db, i)
if i > 0 then
return i-1, db.message_read(i-1)
end
end
local function messages(db)
local count = assert(db.message_count())
return message_iterator, db, count
end
local function list_all_messages(conn, req)
for i, msg in messages(db) do
ui.display(conn, req, ('---- #%d -----'):format(i))
ui.display(conn, req, msg .. '\n')
if i == 0 then
ui.ask(conn, req, "No more messages; Enter for MAIN MENU.", '> ')
else
req = ui.ask(conn, req, "Enter, or Q to stop reading.", '> ')
if req.data.msg:upper() == 'Q' then
ui.display(conn, req, "Done reading.")
break
end
end
end
end
local MAINMENU = {
['1'] = function(conn, req, user)
local msg = read_long_message(conn, req, user)
db.post_message(user, msg)
ui.screen(conn, req, 'posted')
end,
['2'] = function(conn, req, user)
ui.screen(conn, req, 'read_msg')
local count = assert(db.message_count())
if count == 0 then
ui.display(conn, req, "There are no messages!")
else
list_all_messages(conn, req)
end
end,
['3'] = function (conn, req, user)
req = ui.ask(conn, req, 'Who do you want to send it to?', '> ')
local to = req.data.msg
local exists = assert(db.user_exists(to))
if exists then
local msg = read_long_message(conn, req, user)
db.send_to(to, user, msg)
ui.display(conn, req, "Message sent to " .. to)
else
ui.display(conn, req, 'Sorry, that user does not exit.')
end
end,
['4'] = function(conn, req, user)
local count = assert(db.inbox_count(user))
if count == 0 then
ui.display(conn, req, 'No messages for you. Try back later.')
return
end
while db.inbox_count(user) > 0 do
local msg = assert(db.read_inbox(user))
ui.display(conn, req, msg)
ui.ask(conn, req, "Enter to continue.", '> ')
end
end,
['Q'] = function(conn, req, user)
ui.exit(conn, req, 'bye')
end
}
local function m2bbs(conn)
local req = coroutine.yield() -- Wait for data
ui.screen(conn, req, 'welcome')
-- Have the user log in
req = ui.prompt(conn, req, 'name')
local user = req.data.msg
req = ui.prompt(conn, req, 'password')
local password = req.data.msg
print('login attempt', user, password)
local exists, error = db.user_exists(user)
if error then
print("ERROR:", error)
ui.display(conn, req, 'We had an error, sorry. Try again.')
return
elseif not exists then
new_user(conn, req, user, password)
elseif not db.auth_user(user, password) then
ui.exit(conn, req, 'bad_pass')
return
end
-- Display the MoTD and wait for the user to hit Enter.
ui.prompt(conn, req, 'motd')
repeat
req = ui.prompt(conn, req, 'menu')
local selection = MAINMENU[req.data.msg:upper()]
print("message:", req.data.msg)
if selection then
selection(conn, req, user)
else
ui.screen(conn, req, 'menu_error')
end
until req.data.msg:upper() == "Q"
end
do
-- Load configuration properties
local config = {}
setfenv(assert(loadfile('config.lua')), config)()
-- Connect to the Mongrel2 server
print("connecting", config.sender_id, config.sub_addr, config.pub_addr)
local ctx = mongrel2.new(config.io_threads)
local conn = ctx:new_connection(config.sender_id, config.sub_addr, config.pub_addr)
-- Run the BBS engine
engine.run(conn, m2bbs)
end
|
