|
| 1 | +#!/usr/bin/env bash |
| 2 | +# Oracle Parity Test: crsql_get_seq() function |
| 3 | +# |
| 4 | +# Tests the crsql_get_seq() function which returns the current seq value |
| 5 | +# without incrementing it. This is a read-only version of crsql_increment_and_get_seq(). |
| 6 | +# |
| 7 | +# Used by sync clients to observe the current seq without side effects. |
| 8 | +set -euo pipefail |
| 9 | + |
| 10 | +SCRIPT_DIR="$(cd "$(dirname "$0")" && pwd)" |
| 11 | +REPO_ROOT="$(cd "$SCRIPT_DIR/../.." && pwd)" |
| 12 | +ZIG_DIR="$(cd "$SCRIPT_DIR/.." && pwd)" |
| 13 | + |
| 14 | +echo "━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━" |
| 15 | +echo "Oracle Parity Test: crsql_get_seq() function" |
| 16 | +echo "━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━" |
| 17 | +echo "" |
| 18 | + |
| 19 | +# Determine extension paths based on platform |
| 20 | +if [[ "$(uname)" == "Darwin" ]]; then |
| 21 | + ARCH=$(uname -m) |
| 22 | + if [[ "$ARCH" == "arm64" ]]; then |
| 23 | + RUST_EXT="$REPO_ROOT/lib/crsqlite-darwin-aarch64.dylib" |
| 24 | + else |
| 25 | + RUST_EXT="$REPO_ROOT/lib/crsqlite-darwin-x86_64.dylib" |
| 26 | + fi |
| 27 | + ZIG_EXT="$ZIG_DIR/zig-out/lib/libcrsqlite.dylib" |
| 28 | +else |
| 29 | + ARCH=$(uname -m) |
| 30 | + if [[ "$ARCH" == "aarch64" ]]; then |
| 31 | + RUST_EXT="$REPO_ROOT/lib/crsqlite-linux-aarch64.so" |
| 32 | + else |
| 33 | + RUST_EXT="$REPO_ROOT/lib/crsqlite-linux-x86_64.so" |
| 34 | + fi |
| 35 | + ZIG_EXT="$ZIG_DIR/zig-out/lib/libcrsqlite.so" |
| 36 | +fi |
| 37 | + |
| 38 | +# Check for Rust/C oracle |
| 39 | +HAVE_ORACLE=true |
| 40 | +if [[ ! -f "$RUST_EXT" ]]; then |
| 41 | + echo "NOTE: Rust/C oracle not found at $RUST_EXT" |
| 42 | + echo " Oracle parity tests will be skipped" |
| 43 | + HAVE_ORACLE=false |
| 44 | +fi |
| 45 | + |
| 46 | +# Check for Zig extension |
| 47 | +if [[ ! -f "$ZIG_EXT" ]]; then |
| 48 | + echo "Zig extension not found at $ZIG_EXT" |
| 49 | + echo "Building Zig extension..." |
| 50 | + cd "$ZIG_DIR" |
| 51 | + if ! nix run nixpkgs#zig -- build 2>&1; then |
| 52 | + echo "FAIL: Zig build failed" |
| 53 | + exit 1 |
| 54 | + fi |
| 55 | +fi |
| 56 | + |
| 57 | +SQLITE="nix run nixpkgs#sqlite --" |
| 58 | + |
| 59 | +echo "Zig extension: $ZIG_EXT" |
| 60 | +if [[ "$HAVE_ORACLE" == "true" ]]; then |
| 61 | + echo "Rust/C oracle: $RUST_EXT" |
| 62 | +fi |
| 63 | +echo "" |
| 64 | + |
| 65 | +# Temp files for output |
| 66 | +TMPDIR="${REPO_ROOT}/.tmp" |
| 67 | +mkdir -p "$TMPDIR" |
| 68 | +RUST_OUT=$(mktemp "$TMPDIR/get-seq-rust.XXXXXX") |
| 69 | +ZIG_OUT=$(mktemp "$TMPDIR/get-seq-zig.XXXXXX") |
| 70 | +ERRFILE=$(mktemp "$TMPDIR/get-seq-err.XXXXXX") |
| 71 | +trap "rm -f $RUST_OUT $ZIG_OUT $ERRFILE" EXIT |
| 72 | + |
| 73 | +PASS=0 |
| 74 | +FAIL=0 |
| 75 | +SKIP=0 |
| 76 | + |
| 77 | +# Helper to run SQL |
| 78 | +run_zig() { |
| 79 | + local sql="$1" |
| 80 | + $SQLITE :memory: -cmd ".load $ZIG_EXT" "$sql" 2>"$ERRFILE" |
| 81 | +} |
| 82 | + |
| 83 | +run_rust() { |
| 84 | + local sql="$1" |
| 85 | + $SQLITE :memory: -cmd ".load $RUST_EXT sqlite3_crsqlite_init" "$sql" 2>"$ERRFILE" |
| 86 | +} |
| 87 | + |
| 88 | +# ═══════════════════════════════════════════════════════════════════════════ |
| 89 | +# Test 1: crsql_get_seq() exists and returns 0 initially |
| 90 | +# ═══════════════════════════════════════════════════════════════════════════ |
| 91 | +echo "Test 1: crsql_get_seq() exists and returns 0 initially" |
| 92 | +result=$(run_zig "SELECT crsql_get_seq();" 2>&1) || true |
| 93 | +if grep -q "no such function" "$ERRFILE" 2>/dev/null; then |
| 94 | + echo " FAIL: crsql_get_seq() function not found in Zig extension" |
| 95 | + FAIL=$((FAIL + 1)) |
| 96 | +elif [[ "$result" == "0" ]]; then |
| 97 | + echo " PASS: crsql_get_seq() returns 0 initially" |
| 98 | + PASS=$((PASS + 1)) |
| 99 | +else |
| 100 | + echo " FAIL: Expected 0, got: $result" |
| 101 | + FAIL=$((FAIL + 1)) |
| 102 | +fi |
| 103 | +echo "" |
| 104 | + |
| 105 | +# ═══════════════════════════════════════════════════════════════════════════ |
| 106 | +# Test 2: Multiple calls return same value (no increment) |
| 107 | +# ═══════════════════════════════════════════════════════════════════════════ |
| 108 | +echo "Test 2: Multiple calls return same value (no increment)" |
| 109 | +result=$(run_zig "SELECT crsql_get_seq(); SELECT crsql_get_seq(); SELECT crsql_get_seq();") || true |
| 110 | +# All three should be 0 |
| 111 | +count_zeros=$(echo "$result" | grep -c "^0$" || echo "0") |
| 112 | +if [[ "$count_zeros" == "3" ]]; then |
| 113 | + echo " PASS: crsql_get_seq() returns 0 three times without incrementing" |
| 114 | + PASS=$((PASS + 1)) |
| 115 | +else |
| 116 | + echo " FAIL: Expected three 0s, got: $result" |
| 117 | + FAIL=$((FAIL + 1)) |
| 118 | +fi |
| 119 | +echo "" |
| 120 | + |
| 121 | +# ═══════════════════════════════════════════════════════════════════════════ |
| 122 | +# Test 3: crsql_get_seq() matches crsql_increment_and_get_seq() before increment |
| 123 | +# ═══════════════════════════════════════════════════════════════════════════ |
| 124 | +echo "Test 3: crsql_get_seq() matches crsql_increment_and_get_seq() before increment" |
| 125 | +result=$(run_zig " |
| 126 | +SELECT 'BEFORE=' || (crsql_get_seq() = 0); |
| 127 | +SELECT 'INCR=' || crsql_increment_and_get_seq(); |
| 128 | +SELECT 'AFTER=' || (crsql_get_seq() = 1); |
| 129 | +SELECT 'INCR2=' || crsql_increment_and_get_seq(); |
| 130 | +SELECT 'AFTER2=' || (crsql_get_seq() = 2); |
| 131 | +") || true |
| 132 | + |
| 133 | +before=$(echo "$result" | grep "BEFORE=" | cut -d= -f2) |
| 134 | +after=$(echo "$result" | grep "^AFTER=" | cut -d= -f2) |
| 135 | +after2=$(echo "$result" | grep "AFTER2=" | cut -d= -f2) |
| 136 | + |
| 137 | +if [[ "$before" == "1" && "$after" == "1" && "$after2" == "1" ]]; then |
| 138 | + echo " PASS: crsql_get_seq() correctly reflects seq after increment_and_get_seq()" |
| 139 | + PASS=$((PASS + 1)) |
| 140 | +else |
| 141 | + echo " FAIL: Expected all 1s (true), got: before=$before after=$after after2=$after2" |
| 142 | + echo " Full result: $result" |
| 143 | + FAIL=$((FAIL + 1)) |
| 144 | +fi |
| 145 | +echo "" |
| 146 | + |
| 147 | +# ═══════════════════════════════════════════════════════════════════════════ |
| 148 | +# Test 4: crsql_get_seq() takes no arguments |
| 149 | +# ═══════════════════════════════════════════════════════════════════════════ |
| 150 | +echo "Test 4: crsql_get_seq() takes no arguments" |
| 151 | +result=$(run_zig "SELECT crsql_get_seq(1);" 2>&1) || true |
| 152 | +# SQLite itself may reject the wrong number of arguments before our function runs |
| 153 | +if grep -qi "wrong number of arguments\|takes no arguments" "$ERRFILE" 2>/dev/null; then |
| 154 | + echo " PASS: crsql_get_seq() correctly rejects arguments" |
| 155 | + PASS=$((PASS + 1)) |
| 156 | +else |
| 157 | + echo " FAIL: Expected error about wrong number of arguments, got: $result" |
| 158 | + cat "$ERRFILE" 2>/dev/null || true |
| 159 | + FAIL=$((FAIL + 1)) |
| 160 | +fi |
| 161 | +echo "" |
| 162 | + |
| 163 | +# ═══════════════════════════════════════════════════════════════════════════ |
| 164 | +# Test 5: Oracle parity (if available) |
| 165 | +# ═══════════════════════════════════════════════════════════════════════════ |
| 166 | +echo "Test 5: Oracle parity" |
| 167 | +if [[ "$HAVE_ORACLE" == "true" ]]; then |
| 168 | + zig_result=$(run_zig "SELECT crsql_get_seq();") || true |
| 169 | + rust_result=$(run_rust "SELECT crsql_get_seq();") || true |
| 170 | + |
| 171 | + if grep -q "no such function" "$ERRFILE" 2>/dev/null; then |
| 172 | + echo " SKIP: crsql_get_seq() not available in Rust/C oracle" |
| 173 | + SKIP=$((SKIP + 1)) |
| 174 | + elif [[ "$zig_result" == "$rust_result" ]]; then |
| 175 | + echo " PASS: Zig ($zig_result) matches Rust/C oracle ($rust_result)" |
| 176 | + PASS=$((PASS + 1)) |
| 177 | + else |
| 178 | + echo " FAIL: Zig ($zig_result) != Rust/C oracle ($rust_result)" |
| 179 | + FAIL=$((FAIL + 1)) |
| 180 | + fi |
| 181 | +else |
| 182 | + echo " SKIP: Rust/C oracle not available" |
| 183 | + SKIP=$((SKIP + 1)) |
| 184 | +fi |
| 185 | +echo "" |
| 186 | + |
| 187 | +# ═══════════════════════════════════════════════════════════════════════════ |
| 188 | +# Test 6: Oracle parity - seq after operations |
| 189 | +# ═══════════════════════════════════════════════════════════════════════════ |
| 190 | +echo "Test 6: Oracle parity - seq behavior after operations" |
| 191 | +if [[ "$HAVE_ORACLE" == "true" ]]; then |
| 192 | + SQL=" |
| 193 | +SELECT 'GET1=' || crsql_get_seq(); |
| 194 | +SELECT 'INCR1=' || crsql_increment_and_get_seq(); |
| 195 | +SELECT 'GET2=' || crsql_get_seq(); |
| 196 | +SELECT 'INCR2=' || crsql_increment_and_get_seq(); |
| 197 | +SELECT 'GET3=' || crsql_get_seq(); |
| 198 | +" |
| 199 | + zig_result=$(run_zig "$SQL") || true |
| 200 | + rust_result=$(run_rust "$SQL" 2>/dev/null) || true |
| 201 | + |
| 202 | + if grep -q "no such function" "$ERRFILE" 2>/dev/null; then |
| 203 | + echo " SKIP: crsql_get_seq() not available in Rust/C oracle" |
| 204 | + SKIP=$((SKIP + 1)) |
| 205 | + elif [[ "$zig_result" == "$rust_result" ]]; then |
| 206 | + echo " PASS: Zig matches Rust/C oracle for seq operations" |
| 207 | + echo " Zig: $(echo "$zig_result" | tr '\n' ' ')" |
| 208 | + echo " Rust: $(echo "$rust_result" | tr '\n' ' ')" |
| 209 | + PASS=$((PASS + 1)) |
| 210 | + else |
| 211 | + echo " FAIL: Zig != Rust/C oracle" |
| 212 | + echo " Zig: $(echo "$zig_result" | tr '\n' ' ')" |
| 213 | + echo " Rust: $(echo "$rust_result" | tr '\n' ' ')" |
| 214 | + FAIL=$((FAIL + 1)) |
| 215 | + fi |
| 216 | +else |
| 217 | + echo " SKIP: Rust/C oracle not available" |
| 218 | + SKIP=$((SKIP + 1)) |
| 219 | +fi |
| 220 | +echo "" |
| 221 | + |
| 222 | +# ═══════════════════════════════════════════════════════════════════════════ |
| 223 | +# Summary |
| 224 | +# ═══════════════════════════════════════════════════════════════════════════ |
| 225 | +echo "━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━" |
| 226 | +echo "crsql_get_seq() Test Summary" |
| 227 | +echo "━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━" |
| 228 | +printf " PASSED: %d\n" "$PASS" |
| 229 | +printf " FAILED: %d\n" "$FAIL" |
| 230 | +printf " SKIPPED: %d\n" "$SKIP" |
| 231 | +echo "━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━" |
| 232 | +echo "" |
| 233 | + |
| 234 | +if [[ $FAIL -gt 0 ]]; then |
| 235 | + echo "FAIL: Some crsql_get_seq() tests failed" |
| 236 | + exit 1 |
| 237 | +elif [[ $PASS -gt 0 ]]; then |
| 238 | + echo "SUCCESS: All crsql_get_seq() tests passed" |
| 239 | + exit 0 |
| 240 | +else |
| 241 | + echo "No tests ran successfully" |
| 242 | + exit 2 |
| 243 | +fi |
0 commit comments