mirror of
https://github.com/akyaiy/GoSally-mvp.git
synced 2026-01-03 20:52:25 +00:00
66 lines
1.5 KiB
Lua
66 lines
1.5 KiB
Lua
---@diagnostic disable: redefined-local
|
|
local db = require("internal.database-sqlite").connect("db/test.db", {log = true})
|
|
local log = require("internal.log")
|
|
local session = require("internal.session")
|
|
|
|
if not (session.request.params.name and session.request.params.email) then
|
|
session.response.error = {
|
|
code = -32602,
|
|
message = "Name and email are required"
|
|
}
|
|
return
|
|
end
|
|
|
|
local existing, err = db:query("SELECT 1 FROM users WHERE email = ? LIMIT 1", {
|
|
session.request.params.email
|
|
})
|
|
if err ~= nil then
|
|
session.response.error = {
|
|
code = -32603,
|
|
message = "Database check failed: "..tostring(err)
|
|
}
|
|
log.error("Email check failed: "..tostring(err))
|
|
return
|
|
end
|
|
|
|
if existing and #existing > 0 then
|
|
session.response.error = {
|
|
code = -32604,
|
|
message = "Email already exists"
|
|
}
|
|
return
|
|
end
|
|
|
|
local ctx, err = db:exec(
|
|
"INSERT INTO users (name, email) VALUES (?, ?)",
|
|
{
|
|
session.request.params.name,
|
|
session.request.params.email
|
|
}
|
|
)
|
|
if err ~= nil then
|
|
session.response.error = {
|
|
code = -32605,
|
|
message = "Insert failed: "..tostring(err)
|
|
}
|
|
log.error("Insert failed: "..tostring(err))
|
|
return
|
|
end
|
|
|
|
local res, err = ctx:wait()
|
|
if err ~= nil then
|
|
session.response.error = {
|
|
code = -32606,
|
|
message = "Insert confirmation failed: "..tostring(err)
|
|
}
|
|
log.error("Insert confirmation failed: "..tostring(err))
|
|
return
|
|
end
|
|
|
|
session.response.result = {
|
|
success = true,
|
|
rows_affected = res,
|
|
message = "User created successfully"
|
|
}
|
|
|
|
db:close() |