diff --git a/src/barabadb/core/gossip.nim b/src/barabadb/core/gossip.nim index f2c37bf..9973235 100644 --- a/src/barabadb/core/gossip.nim +++ b/src/barabadb/core/gossip.nim @@ -7,7 +7,6 @@ import std/net import std/asyncnet import std/strutils import std/streams -import std/os type NodeState* = enum @@ -312,7 +311,7 @@ proc startGossipListener*(gp: GossipProtocol) {.async.} = gp.running = true while gp.running: try: - let (data, senderAddr, senderPort) = await gp.sock.recvFrom(65535) + let (data, senderAddr, _) = await gp.sock.recvFrom(65535) if data.len > 0: gp.handleIncomingGossip(data, senderAddr) except: diff --git a/src/barabadb/core/httpserver.nim b/src/barabadb/core/httpserver.nim index 1d5b4d3..3d2282f 100644 --- a/src/barabadb/core/httpserver.nim +++ b/src/barabadb/core/httpserver.nim @@ -92,7 +92,7 @@ proc checkAuth(server: HttpServer, request: Request, ctx: Context): bool = ctx.json(%*{"error": "Unauthorized"}, 401) return false let tokenStr = authHeader[7..^1] - let (valid, userId, role) = server.verifyToken(tokenStr) + let (valid, _, _) = server.verifyToken(tokenStr) if not valid: ctx.json(%*{"error": "Unauthorized"}, 401) return false @@ -229,7 +229,7 @@ proc scramStartHandler(server: HttpServer): RequestHandler = if body == nil or "username" notin body or "clientFirstMessage" notin body: ctx.json(%*{"error": "Missing username or clientFirstMessage"}, 400) return - let username = body["username"].getStr() + let username {.used.} = body["username"].getStr() let clientFirst = body["clientFirstMessage"].getStr() try: let serverFirst = server.authManager.startScram(clientFirst) diff --git a/src/barabadb/query/executor.nim b/src/barabadb/query/executor.nim index 18ebbb5..29de9aa 100644 --- a/src/barabadb/query/executor.nim +++ b/src/barabadb/query/executor.nim @@ -1723,7 +1723,6 @@ proc computeWindowValues*(rows: seq[Row], expr: IRExpr, ctx: ExecutionContext = if rows.len == 0: return let wfName = expr.wfName.toLower() - let frameMode = expr.wfFrameMode let frameStart = expr.wfFrameStart let frameEnd = expr.wfFrameEnd @@ -1808,11 +1807,11 @@ proc computeWindowValues*(rows: seq[Row], expr: IRExpr, ctx: ExecutionContext = result[rowIdx] = defaultVal of "first_value": for pos, rowIdx in sortedIdxs: - let (fStart, fEnd) = resolveFrameBounds(pos, sortedIdxs.len, frameStart, frameEnd) + let (fStart, _) = resolveFrameBounds(pos, sortedIdxs.len, frameStart, frameEnd) result[rowIdx] = evalExpr(expr.wfArgs[0], rows[sortedIdxs[fStart]], ctx) of "last_value": for pos, rowIdx in sortedIdxs: - let (fStart, fEnd) = resolveFrameBounds(pos, sortedIdxs.len, frameStart, frameEnd) + let (_, fEnd) = resolveFrameBounds(pos, sortedIdxs.len, frameStart, frameEnd) result[rowIdx] = evalExpr(expr.wfArgs[0], rows[sortedIdxs[fEnd]], ctx) else: # Unknown window function — fill with empty @@ -2439,7 +2438,6 @@ proc executePlan*(ctx: ExecutionContext, plan: IRPlan): seq[Row] = # The graph is stored by name; for simplicity, we'll use a table-based approach # Graph nodes are stored as rows with their properties let graphTable = plan.graphName & "_nodes" - let edgeTable = plan.graphName & "_edges" # Try to scan the nodes table let nodeRows = execScan(ctx, graphTable) if nodeRows.len > 0: @@ -3395,7 +3393,7 @@ proc executeQuery*(ctx: ExecutionContext, astNode: Node, params: seq[WireValue] if isMigrationApplied(ctx, stmt.amName): return okResult(msg="Migration '" & stmt.amName & "' already applied") - let (found, upBody, downBody) = getMigrationBody(ctx, stmt.amName) + let (found, upBody, _) = getMigrationBody(ctx, stmt.amName) if not found: return errResult("Migration '" & stmt.amName & "' not found") @@ -3459,7 +3457,7 @@ proc executeQuery*(ctx: ExecutionContext, astNode: Node, params: seq[WireValue] var appliedCount = 0 var totalDuration = 0 for name in toApply: - let (found, upBody, downBody) = getMigrationBody(ctx, name) + let (found, upBody, _) = getMigrationBody(ctx, name) if not found: return errResult("Migration '" & name & "' not found during batch apply") let startTime = epochTime() @@ -3501,7 +3499,7 @@ proc executeQuery*(ctx: ExecutionContext, astNode: Node, params: seq[WireValue] var rolledBackCount = 0 for name in toRollback: - let (found, upBody, downBody) = getMigrationBody(ctx, name) + let (found, _, downBody) = getMigrationBody(ctx, name) if not found: return errResult("Migration '" & name & "' not found during rollback") if downBody.len == 0: diff --git a/src/barabadb/query/lexer.nim b/src/barabadb/query/lexer.nim index 2a04207..2db2534 100644 --- a/src/barabadb/query/lexer.nim +++ b/src/barabadb/query/lexer.nim @@ -416,7 +416,7 @@ proc peekRune(l: Lexer): Rune = return r return Rune(0) -proc advanceRune(l: var Lexer): Rune = +proc advanceRune(l: var Lexer): Rune {.used.} = if l.pos < l.input.len: var r: Rune fastRuneAt(l.input, l.pos, r, true) diff --git a/src/barabadb/storage/lsm.nim b/src/barabadb/storage/lsm.nim index 443fe75..898d10f 100644 --- a/src/barabadb/storage/lsm.nim +++ b/src/barabadb/storage/lsm.nim @@ -10,7 +10,6 @@ import std/locks import bloom import wal import mmap -import streams const SSTableMagic* = 0x53535442'u32 # "SSTB" diff --git a/src/baradadb.nim b/src/baradadb.nim index 73b8a22..e7ff239 100644 --- a/src/baradadb.nim +++ b/src/baradadb.nim @@ -114,7 +114,7 @@ proc main() = asyncCheck cm.startCompactionLoop() # Create TCP server (initialization is synchronous, run is async) - let localId = if config.raftNodeId.len > 0: config.raftNodeId else: "node-" & $config.port + let localId {.used.} = if config.raftNodeId.len > 0: config.raftNodeId else: "node-" & $config.port var tcpServer = newServer(config) # Start Raft cluster if enabled