Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions server/main.lua
Original file line number Diff line number Diff line change
Expand Up @@ -607,7 +607,7 @@ local function CreateJobAccount(job, initialBalance)
creator = nil
}

local success, errorMsg = MySQL.insert("INSERT INTO bank_accounts_new (id, amount, transactions, auth, isFrozen, creator) VALUES (?, ?, ?, ?, ?, NULL)", {
local insertId = MySQL.insert.await("INSERT INTO bank_accounts_new (id, amount, transactions, auth, isFrozen, creator) VALUES (?, ?, ?, ?, ?, NULL)", {
job.name,
cachedAccounts[job.name].amount,
json.encode(cachedAccounts[job.name].transactions), -- Convert transactions to JSON
Expand All @@ -616,9 +616,9 @@ local function CreateJobAccount(job, initialBalance)
})

-- Handle potential database errors
if not success then
if not insertId then
cachedAccounts[job.name] = nil
error(("^5[%s]^7-^1[ERROR]^7 %s"):format(currentResourceName, "Database error: " .. tostring(errorMsg)))
error(("^5[%s]^7-^1[ERROR]^7 %s"):format(currentResourceName, "Database error"))
end

return cachedAccounts[job.name]
Expand Down