// Copyright 2026 International Digital Economy Academy
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
///|
// Convert view-relative bounds to backing-string offsets before scanning.
fn find_code_unit_from_view(
target : StringView,
start : Int,
end : Int,
code : UInt16,
) -> Int {
let target_start = target.start_offset()
let found = find_code_unit_from_string(
target.data(),
target_start + start,
target_start + end,
code,
)
if found < 0 {
-1
} else {
found - target_start
}
}
///|
// Convert view-relative bounds to backing-string offsets before reverse
// scanning.
fn rev_find_code_unit_from_view(
target : StringView,
start : Int,
end : Int,
code : UInt16,
) -> Int {
let target_start = target.start_offset()
let found = rev_find_code_unit_from_string(
target.data(),
target_start + start,
target_start + end,
code,
)
if found < 0 {
-1
} else {
found - target_start
}
}
///|
// The caller must ensure `0 <= start <= end <= data.length()`.
#inline
fn find_code_unit_scalar(
data : String,
start : Int,
end : Int,
code : UInt16,
) -> Int {
for pos in start.. Int {
for pos = end - 1; pos >= start; {
if data.unsafe_get(pos) == code {
break pos
}
continue pos - 1
} nobreak {
-1
}
}
///|
#cfg(not(any(target="native", target="wasm")))
fn find_code_unit_from_string(
data : String,
start : Int,
end : Int,
code : UInt16,
) -> Int {
find_code_unit_scalar(data, start, end, code)
}
///|
#cfg(not(any(target="native", target="wasm")))
fn rev_find_code_unit_from_string(
data : String,
start : Int,
end : Int,
code : UInt16,
) -> Int {
rev_find_code_unit_scalar(data, start, end, code)
}
///|
// SIMD code-unit scanner for linear-memory backends. The vector loop scans
// eight UTF-16 code units at a time, then the scalar tail handles the remainder.
#cfg(any(target="native", target="wasm"))
fn find_code_unit_from_string(
data : String,
start : Int,
end : Int,
code : UInt16,
) -> Int {
guard start < end else { return -1 }
if data.unsafe_get(start) == code {
return start
}
let code_v = i16x8_splat(code)
let tail_start = for pos = start; pos + 8 <= end; {
let mask = i16x8_bitmask(i16x8_eq(v128_load_i16x8(data, pos), code_v))
if mask != 0 {
return pos + mask.ctz()
}
continue pos + 8
} nobreak {
pos
}
find_code_unit_scalar(data, tail_start, end, code)
}
///|
// SIMD reverse code-unit scanner for linear-memory backends. It scans
// eight-code-unit chunks from the end and returns the highest matching offset.
#cfg(any(target="native", target="wasm"))
fn rev_find_code_unit_from_string(
data : String,
start : Int,
end : Int,
code : UInt16,
) -> Int {
guard start < end else { return -1 }
if data.unsafe_get(end - 1) == code {
return end - 1
}
let code_v = i16x8_splat(code)
let head_end = for pos = end; pos - 8 >= start; {
let chunk_start = pos - 8
let mask = i16x8_bitmask(
i16x8_eq(v128_load_i16x8(data, chunk_start), code_v),
)
if mask != 0 {
return chunk_start + 31 - mask.clz()
}
continue chunk_start
} nobreak {
pos
}
rev_find_code_unit_scalar(data, start, head_end, code)
}
///|
// Finds a multi-code-unit pattern by scanning candidate positions where both
// the first and last code units match, then checking only the middle range.
// The caller must ensure `2 <= pattern.length() <= target.length()`.
fn find_by_two_anchors(target : StringView, pattern : StringView) -> Int? {
let target_len = target.length()
let pattern_len = pattern.length()
let target_start = target.start_offset()
let pattern_start = pattern.start_offset()
let last_offset = pattern_len - 1
let candidate_end = target_start + target_len - pattern_len + 1
let first = pattern.unsafe_get(0)
let last = pattern.unsafe_get(last_offset)
let middle_len = last_offset - 1
for pos = target_start, failures = 0; pos < candidate_end; {
let found = find_two_anchor_candidate_from_string(
target.data(),
pos,
candidate_end,
first,
last_offset,
last,
)
if found < 0 {
break None
}
if string_ranges_equal(
target.data(),
found + 1,
pattern.data(),
pattern_start + 1,
middle_len,
) {
break Some(found - target_start)
}
let failures = failures + 1
let scanned = found - target_start
if two_anchor_should_fallback(failures, scanned) {
break find_pattern_kmp_from(target, pattern, scanned + 1)
}
continue found + 1, failures
} nobreak {
None
}
}
///|
// Finds the last multi-code-unit pattern occurrence using the same two-anchor
// prefilter as the forward search. Candidate positions are scanned backwards.
// The caller must ensure `2 <= pattern.length() <= target.length()`.
fn rev_find_by_two_anchors(target : StringView, pattern : StringView) -> Int? {
let target_len = target.length()
let pattern_len = pattern.length()
let target_start = target.start_offset()
let pattern_start = pattern.start_offset()
let last_offset = pattern_len - 1
let first = pattern.unsafe_get(0)
let last = pattern.unsafe_get(last_offset)
let middle_len = last_offset - 1
let last_candidate = target_len - pattern_len
for candidate_end = target_start + last_candidate + 1, failures = 0; candidate_end >
target_start; {
let found = rev_find_two_anchor_candidate_from_string(
target.data(),
target_start,
candidate_end,
first,
last_offset,
last,
)
if found < 0 {
break None
}
if string_ranges_equal(
target.data(),
found + 1,
pattern.data(),
pattern_start + 1,
middle_len,
) {
break Some(found - target_start)
}
let candidate = found - target_start
let failures = failures + 1
let scanned = last_candidate - candidate
if two_anchor_should_fallback(failures, scanned) {
break rev_find_pattern_kmp_before(target, pattern, candidate)
}
continue found, failures
} nobreak {
None
}
}
///|
// Dense first/last-anchor matches make repeated SIMD candidate scans more
// expensive than direct comparison. Cut over to the guaranteed-linear KMP
// fallback either early, when failures pile up relative to progress
// (`failures > 4 + scanned / 8` — as soon as the 5th failure for
// candidates packed near the scan start), or at the hard cap
// (`failures > 64`, i.e. the 65th failed verification). Either way the
// failure count at cutover is at most 65, keeping pre-cutover
// verification work at O(pattern), so find/rev_find stay
// O(target + pattern) even on adversarial inputs.
#inline
fn two_anchor_should_fallback(failures : Int, scanned : Int) -> Bool {
failures > 64 || failures > 4 + scanned / 8
}
///|
// Longest-proper-border table for the KMP fallbacks: `table[i]` is the
// length of the longest proper prefix of `pattern[0..=i]` that is also a
// suffix of it. Only built after the two-anchor filter cuts over, so the
// O(pattern) allocation is paid exclusively on pathological inputs.
fn kmp_failure_table(pattern : StringView) -> FixedArray[Int] {
let m = pattern.length()
let table = FixedArray::make(m, 0)
let mut k = 0
for i in 1.. 0 && c != pattern.unsafe_get(k) {
k = table[k - 1]
}
if c == pattern.unsafe_get(k) {
k += 1
}
table[i] = k
}
table
}
///|
// Guaranteed-linear forward fallback used after the two-anchor filter
// encounters dense false positives: KMP over the remaining candidates, so
// the whole search stays O(target + pattern) even when both anchors and
// long pattern prefixes recur throughout the target. Returns the first
// occurrence starting at a target-relative position >= `start`.
fn find_pattern_kmp_from(
target : StringView,
pattern : StringView,
start : Int,
) -> Int? {
let n = target.length()
let m = pattern.length()
let table = kmp_failure_table(pattern)
let mut k = 0
for i in start.. 0 && c != pattern.unsafe_get(k) {
k = table[k - 1]
}
if c == pattern.unsafe_get(k) {
k += 1
}
if k == m {
return Some(i - m + 1)
}
}
None
}
///|
// Guaranteed-linear reverse fallback used after the two-anchor filter
// encounters dense false positives: forward KMP over the prefix that can
// still contain a hit, keeping the rightmost match, so the whole search
// stays O(target + pattern). Returns the last occurrence starting at a
// target-relative position strictly below `candidate_end` (exclusive).
// The caller must ensure
// `candidate_end <= target.length() - pattern.length() + 1`, so that the
// scan below stays in bounds.
fn rev_find_pattern_kmp_before(
target : StringView,
pattern : StringView,
candidate_end : Int,
) -> Int? {
guard candidate_end > 0 else { return None }
let m = pattern.length()
let table = kmp_failure_table(pattern)
// an occurrence starting at candidate_end - 1 ends at index
// candidate_end + m - 2, so that is the last index the scan must visit
let scan_end = candidate_end + m - 1
let mut k = 0
let mut best = -1
for i in 0.. 0 && c != pattern.unsafe_get(k) {
k = table[k - 1]
}
if c == pattern.unsafe_get(k) {
k += 1
}
if k == m {
best = i - m + 1
// keep scanning: a later (more rightward) overlapping match wins
k = table[k - 1]
}
}
if best >= 0 {
Some(best)
} else {
None
}
}
///|
test "kmp fallbacks handle periodic and overlapping patterns" {
// failure table borders matter for periodic patterns
let t : StringView = "aaaaaa"
assert_true(find_pattern_kmp_from(t, "aaa", 0) is Some(0))
assert_true(find_pattern_kmp_from(t, "aaa", 2) is Some(2))
assert_true(find_pattern_kmp_from(t, "aaa", 4) is None)
assert_true(rev_find_pattern_kmp_before(t, "aaa", 4) is Some(3))
assert_true(rev_find_pattern_kmp_before(t, "aaa", 1) is Some(0))
let u : StringView = "ababcababab"
assert_true(find_pattern_kmp_from(u, "abab", 0) is Some(0))
assert_true(find_pattern_kmp_from(u, "abab", 1) is Some(5))
assert_true(rev_find_pattern_kmp_before(u, "abab", 8) is Some(7))
assert_true(rev_find_pattern_kmp_before(u, "ababc", 7) is Some(0))
assert_true(find_pattern_kmp_from(u, "abcabc", 0) is None)
// start beyond any match and empty prefix bound
assert_true(rev_find_pattern_kmp_before(u, "abab", 0) is None)
}
///|
// Compares two raw UTF-16 ranges. The caller must ensure both ranges are in
// bounds; using backing strings directly also permits isolated surrogate code
// units without constructing intermediate StringViews.
#inline
fn string_ranges_equal(
left : String,
left_start : Int,
right : String,
right_start : Int,
length : Int,
) -> Bool {
for i in 0.. Int {
for pos in start.. Int {
for pos = candidate_end - 1; pos >= start; {
if data.unsafe_get(pos) == first &&
data.unsafe_get(pos + last_offset) == last {
break pos
}
continue pos - 1
} nobreak {
-1
}
}
///|
#cfg(not(any(target="native", target="wasm")))
fn find_two_anchor_candidate_from_string(
data : String,
start : Int,
candidate_end : Int,
first : UInt16,
last_offset : Int,
last : UInt16,
) -> Int {
find_two_anchor_candidate_scalar(
data, start, candidate_end, first, last_offset, last,
)
}
///|
#cfg(not(any(target="native", target="wasm")))
fn rev_find_two_anchor_candidate_from_string(
data : String,
start : Int,
candidate_end : Int,
first : UInt16,
last_offset : Int,
last : UInt16,
) -> Int {
rev_find_two_anchor_candidate_scalar(
data, start, candidate_end, first, last_offset, last,
)
}
///|
// SIMD first/last-code-unit prefilter. Eight candidate positions are checked
// per iteration and the middle range is left to the caller for verification.
#cfg(any(target="native", target="wasm"))
fn find_two_anchor_candidate_from_string(
data : String,
start : Int,
candidate_end : Int,
first : UInt16,
last_offset : Int,
last : UInt16,
) -> Int {
guard start < candidate_end else { return -1 }
if data.unsafe_get(start) == first &&
data.unsafe_get(start + last_offset) == last {
return start
}
let first_v = i16x8_splat(first)
let last_v = i16x8_splat(last)
let tail_start = for pos = start; pos + 8 <= candidate_end; {
let mask = v128_and(
i16x8_eq(v128_load_i16x8(data, pos), first_v),
i16x8_eq(v128_load_i16x8(data, pos + last_offset), last_v),
)
let bits = i16x8_bitmask(mask)
if bits != 0 {
return pos + bits.ctz()
}
continue pos + 8
} nobreak {
pos
}
find_two_anchor_candidate_scalar(
data, tail_start, candidate_end, first, last_offset, last,
)
}
///|
// SIMD reverse first/last-code-unit prefilter. It returns the highest matching
// candidate position from each eight-lane block.
#cfg(any(target="native", target="wasm"))
fn rev_find_two_anchor_candidate_from_string(
data : String,
start : Int,
candidate_end : Int,
first : UInt16,
last_offset : Int,
last : UInt16,
) -> Int {
guard start < candidate_end else { return -1 }
let final_candidate = candidate_end - 1
if data.unsafe_get(final_candidate) == first &&
data.unsafe_get(final_candidate + last_offset) == last {
return final_candidate
}
let first_v = i16x8_splat(first)
let last_v = i16x8_splat(last)
let head_end = for pos = candidate_end; pos - 8 >= start; {
let chunk_start = pos - 8
let mask = v128_and(
i16x8_eq(v128_load_i16x8(data, chunk_start), first_v),
i16x8_eq(v128_load_i16x8(data, chunk_start + last_offset), last_v),
)
let bits = i16x8_bitmask(mask)
if bits != 0 {
return chunk_start + 31 - bits.clz()
}
continue chunk_start
} nobreak {
pos
}
rev_find_two_anchor_candidate_scalar(
data, start, head_end, first, last_offset, last,
)
}