AI Slop Code Risk Monitor

seaweedfs/seaweedfs

SlopCodeMonitor badge for seaweedfs/seaweedfs Adjusted legacy signal; badge bands: 25 / 50 / 75 (different from dashboard bands).

SeaweedFS is a distributed storage system for object storage (S3), file systems, and Iceberg tables, designed to handle billions of files with O(1) disk access and effortless horizontal scaling.

2.1 Low pattern signal View on GitHub

Open-Source Code Quality, Security and Technical Debt Review

This report summarizes scanner evidence for seaweedfs/seaweedfs, a Go project with 35,840 GitHub stars. SynthScan examined 1,214,456 lines of code across 4155 source files, recording 1690 pattern matches distributed across 22 syntactic categories. The legacy adjusted pattern signal is 2.1 (Low pattern signal); it is not an authorship estimate.

Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.

2.1
Adjusted Signal
2.1
Raw Pattern Score
100%
Time Factor
2026-10-31
Last Push
35.8K
Stars
Go
Language
1.2M
Lines of Code
4.2K
Files
1.7K
Pattern Hits
2026-10-31
Scan Date
0.01
HC Hit Rate

Risk Review · Payload v1

Use each vector to guide manual verification of the underlying findings.

Payload schema: 1.0.0 · Engine: 2.0.0 · Scoring: heuristic-density-v1 · Scan date: 2026-10-31.

Cognitive Ownership Risk 7.7/100 · LOW

Can maintainers explain intent, assumptions, and trade-offs? 1447 finding(s).

Hallucinated Dependency & Supply Chain Risk 0.7/100 · LOW

Are imports declared and package/API names verified? 62 finding(s).

Agent Over-Engineering Ratio 2.0/100 · LOW

Are wrappers, guards, and repeated structures necessary? 231 finding(s).

PR Review Velocity Impact 8.5/100 · LOW

Which changes need focused human review? 1690 finding(s).

What These Metrics Mean

Adjusted Signal
Legacy pattern score normalized per 1,000 scanned lines and multiplied by the repository-level time factor. It is not an estimate of AI authorship.
Raw Pattern Score
Sum of severity- and context-weighted pattern findings before applying the time factor.
Time Factor
A coarse multiplier based on repository last-push metadata. It does not identify when individual code was written.
Pattern Hits
Count of configured pattern findings. Review each location and surrounding code before acting.
HC Hit Rate
High- and critical-severity findings per scanned file. Severity is a configured detector weight, not proof of a vulnerability or authorship.
Lines / Files
Scan coverage denominators used by the legacy normalized score.

Pattern-Signal History

This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.

Severity Breakdown

Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.

CRITICAL 6HIGH 22MEDIUM 147LOW 1515

Directory Score Breakdown

This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.

Pattern Findings

The scanner identified 1690 distinct pattern matches across 22 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.

Over-Commented Block843 hits · 816 pts
SeverityFileLineSnippetContext
LOWinstall.sh1#!/bin/bashCOMMENT
LOWS3_LIFECYCLE_REDESIGN.md381COMMENT
LOWS3_LIFECYCLE_REDESIGN.md581// One probe per task entry: which per-filer log shards exist, what's the earliestCOMMENT
LOWS3_LIFECYCLE_REDESIGN.md601// reseeding via lazy-seeding when F reappears. Safe to delete cursor[F].COMMENT
LOWS3_LIFECYCLE_REDESIGN.md621// 2. Surface `lifecycle_lost_log_total{filer_id}` andCOMMENT
LOWS3_LIFECYCLE_REDESIGN.md1521// RetryTarget carries the routing/identification fields needed to (a) write aCOMMENT
LOWterraform/test/local/run_local_cluster.sh1#!/usr/bin/env bashCOMMENT
LOWterraform/modules/core/variables.tf1# =============================================================================COMMENT
LOWweed/operation/assign_file_id.go81 // ResourceExhausted: the master is shedding because volume growthCOMMENT
LOWweed/s3api/auth_security_test.go381 assert.NotEqual(t, s3err.ErrNone, errCode, "Expected signature verification to fail")COMMENT
LOWweed/s3api/s3api_bucket_config.go1041// (e.g., simultaneous tag and CORS updates), the last write may overwrite previous changes.COMMENT
LOWweed/s3api/chunked_reader_v4.go301 } else if cr.chunkSignature != "" {COMMENT
LOWweed/s3api/chunked_reader_v4.go381 // Update bytes to be read of the current chunk before verifying chunk's signature.COMMENT
LOWweed/s3api/auth_credentials.go201 if claimed, taken := emailAccount[account.EmailAddress]; taken && claimed.Id != account.Id {COMMENT
LOWweed/s3api/auth_credentials.go681 }COMMENT
LOWweed/s3api/auth_credentials.go1421 }COMMENT
LOWweed/s3api/auth_credentials.go2001COMMENT
LOWweed/s3api/auth_credentials.go2601// SetIAMIntegration sets the IAM integration for advanced authentication and authorization.COMMENT
LOWweed/s3api/auth_credentials.go3061// authorizeObjectKeyAction authorizes action on bucket/objectKey for anCOMMENT
LOWweed/s3api/s3api_object_handlers_rename.go21COMMENT
LOWweed/s3api/s3api_object_handlers_rename.go201// pickRenameSource resolves which reading of the source header the bucketCOMMENT
LOWweed/s3api/s3api_versioning_heal_log_test.go21 // public functions don't panic and that the format strings work.COMMENT
LOWweed/s3api/s3api_versioning_heal_log_test.go101COMMENT
LOWweed/s3api/s3api_object_handlers_put.go1201// Unresolvable lookups fail the same way; only a proven-absent entry withCOMMENT
LOWweed/s3api/s3api_object_handlers_put.go1581// parseRequestQuery returns the parsed query for a request, or nil if thereCOMMENT
LOWweed/s3api/s3api_object_handlers_put.go1781 return s3err.ErrServiceUnavailableCOMMENT
LOWweed/s3api/s3api_object_handlers_put.go1861 entry.Extended = make(map[string][]byte)COMMENT
LOWweed/s3api/s3api_object_handlers_put.go1941 glog.V(2).Infof("putSuspendedVersioningObject: applied bucket default retention mode: %s", string(modeBytes))COMMENT
LOWweed/s3api/s3api_object_handlers_put.go2061 // Stamp the demoted version BEFORE the .versions/ pointerCOMMENT
LOWweed/s3api/s3api_object_handlers_put.go2221 // This version is born noncurrent: stamp it so the lifecycle engineCOMMENT
LOWweed/s3api/s3api_object_handlers_put.go2941 }COMMENT
LOWweed/s3api/s3api_internal_lifecycle.go401 }COMMENT
LOWweed/s3api/sts_params_test.go141 // The Router does not match "/" for STS because Action is not in query.COMMENT
LOWweed/s3api/s3api_object_handlers_list.go1061 // glog.V(4).Infof("doListFilerEntries dir: %s, prefix: %s, marker %s, maxKeys: %d, prefixEndsOnDelimiter: %+v", dir, pCOMMENT
LOWweed/s3api/s3api_object_handlers_list.go1421 hiddenProbeBudget = 10000COMMENT
LOWweed/s3api/s3api_tables.go661// and in the X-Amz-Credential query parameter for presigned requests.COMMENT
LOWweed/s3api/s3api_handlers.go41 client := filer_pb.NewSeaweedFilerClient(grpcConnection)COMMENT
LOWweed/s3api/s3_validation_utils.go41COMMENT
LOWweed/s3api/s3_action_resolver.go21// - bucket: Bucket name from the request pathCOMMENT
LOW…ed/s3api/s3api_object_handlers_copy_collection_test.go41 // collection, so the entry write is unaffected either way.COMMENT
LOWweed/s3api/s3_iam_middleware.go401}COMMENT
LOWweed/s3api/s3_iam_middleware.go521COMMENT
LOWweed/s3api/auth_signature_v4.go1/*COMMENT
LOWweed/s3api/auth_signature_v4.go1301 'a' <= s && s <= 'z' ||COMMENT
LOWweed/s3api/s3api_object_versioning.go41 delete(extended, s3_constants.ExtLatestVersionOwnerKey)COMMENT
LOWweed/s3api/s3api_object_versioning.go621 // A sibling directory that is a prefix of the marker up to a byte below '0'COMMENT
LOWweed/s3api/s3api_object_versioning.go1361// repointLatestBeforeDeletion is the "option 1" pre-step for deleting aCOMMENT
LOWweed/s3api/s3api_object_versioning.go1561//COMMENT
LOWweed/s3api/s3api_object_versioning.go1641//COMMENT
LOWweed/s3api/s3api_object_versioning.go1761 })COMMENT
LOWweed/s3api/s3api_object_versioning.go1801 }COMMENT
LOWweed/s3api/s3api_object_versioning.go1821// caller. If they have changed, abort.COMMENT
LOWweed/s3api/s3api_object_versioning.go2221// points to a version file that no longer exists. It paginates the directory,COMMENT
LOWweed/s3api/s3api_object_versioning.go2241 //COMMENT
LOWweed/s3api/s3api_object_versioning.go2261 } else {COMMENT
LOWweed/s3api/s3api_object_versioning.go2321 versioningHealInfof("healed", "bucket=%s key=%s mode=pointer_repaired new_version=%s file=%s delete_marker=%v", bucketCOMMENT
LOWweed/s3api/s3api_object_versioning.go2561 return trueCOMMENT
LOWweed/s3api/s3api_bucket_policy_engine.go101// EvaluatePolicy evaluates whether an action is allowed by bucket policyCOMMENT
LOWweed/s3api/s3api_object_versioned_finalize.go101COMMENT
LOWweed/s3api/s3api_object_versioned_finalize.go281}COMMENT
783 more matches not shown…
Structural Annotation Overuse219 hits · 406 pts
SeverityFileLineSnippetContext
LOW⚡weed/s3api/auth_security_test.go356 // Step 1: Sign a request targeting the client-facing URL using real AWS SDK signerCOMMENT
LOW⚡weed/s3api/auth_security_test.go364 // Step 2: Create a separate request as the proxy would deliver itCOMMENT
LOW⚡weed/s3api/auth_security_test.go374 // Step 3: VerifyCOMMENT
LOW⚡weed/s3api/auth_security_test.go516 // Step 1: Sign a request using the real AWS SDK v2 signer.COMMENT
LOW⚡weed/s3api/auth_security_test.go525 // Step 2: Build the request as the proxy would deliver it to SeaweedFS.COMMENT
LOW⚡weed/s3api/auth_security_test.go545 // Step 3: Verify extractHostHeader returns the expected value.COMMENT
LOW⚡weed/s3api/auth_security_test.go552 // Step 4: Verify the full signature matches.COMMENT
LOWweed/s3api/s3api_object_handlers_put.go750 // Step 3: Calculate MD5 hash and add SSE metadata to chunksCOMMENT
LOWweed/s3api/s3api_object_handlers_put.go849 // Step 4: Create metadata entryCOMMENT
LOWweed/s3api/s3api_object_handlers_put.go991 // Step 4: Save metadata to filer via gRPCCOMMENT
LOWweed/s3api/s3api_object_handlers_copy.go2746 // Step 1: Decrypt source dataCOMMENT
LOWweed/s3api/s3api_object_handlers_copy.go2843 // Step 2: Re-encrypt with destination encryption (if any)COMMENT
LOWweed/s3api/s3_sse_s3_integration_test.go47 // Step 1: Encrypt (simulates what happens during PUT)COMMENT
LOWweed/s3api/s3_sse_s3_integration_test.go72 // Step 2: Simulate storage (inline file - no chunks)COMMENT
LOWweed/s3api/s3_sse_s3_integration_test.go83 // Step 3: Decrypt (simulates what happens during GET)COMMENT
LOW⚡weed/s3api/s3api_object_retention.go528 // Step 1: Check if governance bypass was requested via headerCOMMENT
LOW⚡weed/s3api/s3api_object_retention.go535 // Step 2: Validate user has permission to bypass governance retentionCOMMENT
LOW⚡weed/s3api/s3_list_parts_action_test.go200 // Step 1: Initiate multipart upload (POST with uploads query)COMMENT
LOW⚡weed/s3api/s3_list_parts_action_test.go210 // Step 2: List existing parts (GET with uploadId query) - THIS WAS THE MISSING MAPPINGCOMMENT
LOW⚡weed/s3api/s3_list_parts_action_test.go220 // Step 3: Upload a part (PUT with uploadId and partNumber)COMMENT
LOWweed/s3api/s3_list_parts_action_test.go231 // Step 4: Complete multipart upload (POST with uploadId)COMMENT
LOWweed/util/chunk_cache/chunk_cache.go226 // Step 1: Read and validate header (volume ID + cookie)COMMENT
LOWweed/util/chunk_cache/chunk_cache.go252 // Step 2: Read actual data from the offset position (after header)COMMENT
LOWweed/shell/command_remote_cache.go109 // Step 1: Collect all remote filesCOMMENT
LOWweed/shell/command_remote_cache.go123 // Step 2: Collect all local files (only if we need to delete local extra files)COMMENT
LOWweed/shell/command_remote_cache.go141 // Step 3: Determine actions neededCOMMENT
LOWweed/shell/command_remote_cache.go223 // Step 4: Execute actionsCOMMENT
LOW⚡weed/shell/command_s3_user_provision.go114 // Step 0: Check if user already existsCOMMENT
LOW⚡weed/shell/command_s3_user_provision.go123 // Step 1: Create policyCOMMENT
LOWweed/shell/command_s3_user_provision.go157 // Step 2: Create new user with credentialsCOMMENT
LOWweed/shell/command_remote_copy_local.go113 // Step 1: Collect all local files that are part of the remote mountCOMMENT
LOWweed/shell/command_remote_copy_local.go129 // Step 2: Check which files exist on remote storageCOMMENT
LOWweed/shell/command_remote_copy_local.go143 // Step 3: Determine files to copy and files to deleteCOMMENT
LOWweed/shell/command_remote_copy_local.go174 // Step 4: Copy files to remote storageCOMMENT
LOWweed/shell/command_remote_copy_local.go225 // Step 5: Delete extraneous files from remote storageCOMMENT
LOWweed/admin/topology/storage_slot_test.go555 // Step 1: Add pending task (should reserve capacity via StorageSlotChange)COMMENT
LOWweed/admin/topology/storage_slot_test.go579 // Step 2: Assign task (capacity already reserved by pending task)COMMENT
LOW⚡weed/admin/topology/storage_slot_test.go592 // Step 3: Complete task (should release reserved capacity)COMMENT
LOW⚡weed/admin/topology/storage_slot_test.go601 // Step 4: Apply actual storage change (simulates master topology update)COMMENT
LOWweed/storage/volume_replica/replica_sync.go115 // Step 1: Find the largest replica (highest file count) that's not excluded.COMMENT
LOWweed/storage/volume_replica/replica_sync.go136 // Step 2: Read index database from the best replicaCOMMENT
LOWweed/storage/volume_replica/replica_sync.go147 // Step 3: For each other replica (including excluded), find entries missing from best and copy themCOMMENT
LOWweed/iam/integration/iam_integration_test.go64 // Step 1: Attempt role assumptionCOMMENT
LOWweed/iam/integration/iam_integration_test.go84 // Step 2: Test policy enforcement with assumed credentialsCOMMENT
LOWweed/iam/integration/iam_integration_test.go138 // Step 1: Attempt role assumption with LDAP credentialsCOMMENT
LOWweed/iam/integration/iam_integration_test.go158 // Step 2: Test policy enforcementCOMMENT
LOW⚡weed/iam/policy/policy_engine.go1235 // Step 1: Substitute policy variables (e.g., ${aws:username}, ${saml:username})COMMENT
LOW⚡weed/iam/policy/policy_engine.go1238 // Step 2: Handle special patternsCOMMENT
LOW⚡weed/iam/policy/policy_engine.go1255 // Step 3: Case-insensitive exact matchCOMMENT
LOW⚡weed/iam/policy/policy_engine.go1260 // Step 4: Handle AWS-style wildcards (case-insensitive)COMMENT
LOWweed/mount/meta_cache/meta_cache_deadlock_test.go104 // Step 1: the "flush handler" takes the fh exclusive lockCOMMENT
LOWweed/mount/meta_cache/meta_cache_deadlock_test.go116 // Step 2: a subscriber event arrives; the apply loop will runCOMMENT
LOWweed/mount/meta_cache/meta_cache_deadlock_test.go131 // Step 3: still holding the fh lock, the flush handler applies its localCOMMENT
LOWweed/mq/topic/local_partition.go136 // Step 2: Enter the main loop - read from in-memory buffer, occasionally checking diskCOMMENT
LOWweed/mq/kafka/protocol/offset_fetch_pattern_test.go45 // Step 1: Fetch batch of messages starting from nextOffsetCOMMENT
LOW⚡weed/mq/kafka/protocol/offset_fetch_pattern_test.go64 // Step 2: Commit the last offset in this batchCOMMENT
LOW⚡weed/mq/kafka/protocol/offset_fetch_pattern_test.go70 // Step 3: Verify offset is correctly storedCOMMENT
LOW⚡weed/mq/kafka/protocol/offset_fetch_pattern_test.go76 // Step 4: Next fetch should start from lastConsumedOffset + 1COMMENT
LOW⚡weed/mq/kafka/protocol/batch_crc_compat_test.go262 // Step 1: Read the batch header to get the CRCCOMMENT
LOW⚡weed/mq/kafka/protocol/batch_crc_compat_test.go270 // Step 2: Calculate CRC over the data (from byte 21 onwards)COMMENT
159 more matches not shown…
Verbosity Indicators217 hits · 403 pts
SeverityFileLineSnippetContext
LOW⚡weed/s3api/auth_security_test.go356 // Step 1: Sign a request targeting the client-facing URL using real AWS SDK signerCOMMENT
LOW⚡weed/s3api/auth_security_test.go364 // Step 2: Create a separate request as the proxy would deliver itCOMMENT
LOW⚡weed/s3api/auth_security_test.go374 // Step 3: VerifyCOMMENT
LOW⚡weed/s3api/auth_security_test.go516 // Step 1: Sign a request using the real AWS SDK v2 signer.COMMENT
LOW⚡weed/s3api/auth_security_test.go525 // Step 2: Build the request as the proxy would deliver it to SeaweedFS.COMMENT
LOW⚡weed/s3api/auth_security_test.go545 // Step 3: Verify extractHostHeader returns the expected value.COMMENT
LOW⚡weed/s3api/auth_security_test.go552 // Step 4: Verify the full signature matches.COMMENT
LOWweed/s3api/s3api_object_handlers_put.go750 // Step 3: Calculate MD5 hash and add SSE metadata to chunksCOMMENT
LOWweed/s3api/s3api_object_handlers_put.go849 // Step 4: Create metadata entryCOMMENT
LOWweed/s3api/s3api_object_handlers_put.go991 // Step 4: Save metadata to filer via gRPCCOMMENT
LOWweed/s3api/s3api_object_handlers_copy.go2746 // Step 1: Decrypt source dataCOMMENT
LOWweed/s3api/s3api_object_handlers_copy.go2843 // Step 2: Re-encrypt with destination encryption (if any)COMMENT
LOWweed/s3api/s3_sse_s3_integration_test.go47 // Step 1: Encrypt (simulates what happens during PUT)COMMENT
LOWweed/s3api/s3_sse_s3_integration_test.go72 // Step 2: Simulate storage (inline file - no chunks)COMMENT
LOWweed/s3api/s3_sse_s3_integration_test.go83 // Step 3: Decrypt (simulates what happens during GET)COMMENT
LOW⚡weed/s3api/s3api_object_retention.go528 // Step 1: Check if governance bypass was requested via headerCOMMENT
LOW⚡weed/s3api/s3api_object_retention.go535 // Step 2: Validate user has permission to bypass governance retentionCOMMENT
LOW⚡weed/s3api/s3_list_parts_action_test.go200 // Step 1: Initiate multipart upload (POST with uploads query)COMMENT
LOW⚡weed/s3api/s3_list_parts_action_test.go210 // Step 2: List existing parts (GET with uploadId query) - THIS WAS THE MISSING MAPPINGCOMMENT
LOW⚡weed/s3api/s3_list_parts_action_test.go220 // Step 3: Upload a part (PUT with uploadId and partNumber)COMMENT
LOWweed/s3api/s3_list_parts_action_test.go231 // Step 4: Complete multipart upload (POST with uploadId)COMMENT
LOWweed/util/chunk_cache/chunk_cache.go226 // Step 1: Read and validate header (volume ID + cookie)COMMENT
LOWweed/util/chunk_cache/chunk_cache.go252 // Step 2: Read actual data from the offset position (after header)COMMENT
LOWweed/shell/command_remote_cache.go109 // Step 1: Collect all remote filesCOMMENT
LOWweed/shell/command_remote_cache.go123 // Step 2: Collect all local files (only if we need to delete local extra files)COMMENT
LOWweed/shell/command_remote_cache.go141 // Step 3: Determine actions neededCOMMENT
LOWweed/shell/command_remote_cache.go181 // For caching, we need to check if the local file exists and needs cachingCOMMENT
LOWweed/shell/command_remote_cache.go223 // Step 4: Execute actionsCOMMENT
LOW⚡weed/shell/command_s3_user_provision.go114 // Step 0: Check if user already existsCOMMENT
LOW⚡weed/shell/command_s3_user_provision.go123 // Step 1: Create policyCOMMENT
LOWweed/shell/command_s3_user_provision.go157 // Step 2: Create new user with credentialsCOMMENT
LOWweed/shell/command_remote_copy_local.go113 // Step 1: Collect all local files that are part of the remote mountCOMMENT
LOWweed/shell/command_remote_copy_local.go129 // Step 2: Check which files exist on remote storageCOMMENT
LOWweed/shell/command_remote_copy_local.go143 // Step 3: Determine files to copy and files to deleteCOMMENT
LOWweed/shell/command_remote_copy_local.go174 // Step 4: Copy files to remote storageCOMMENT
LOWweed/shell/command_remote_copy_local.go225 // Step 5: Delete extraneous files from remote storageCOMMENT
LOWweed/admin/topology/storage_slot_test.go555 // Step 1: Add pending task (should reserve capacity via StorageSlotChange)COMMENT
LOWweed/admin/topology/storage_slot_test.go579 // Step 2: Assign task (capacity already reserved by pending task)COMMENT
LOW⚡weed/admin/topology/storage_slot_test.go592 // Step 3: Complete task (should release reserved capacity)COMMENT
LOW⚡weed/admin/topology/storage_slot_test.go601 // Step 4: Apply actual storage change (simulates master topology update)COMMENT
LOWweed/storage/volume_replica/replica_sync.go115 // Step 1: Find the largest replica (highest file count) that's not excluded.COMMENT
LOWweed/storage/volume_replica/replica_sync.go136 // Step 2: Read index database from the best replicaCOMMENT
LOWweed/storage/volume_replica/replica_sync.go147 // Step 3: For each other replica (including excluded), find entries missing from best and copy themCOMMENT
LOWweed/iam/integration/iam_integration_test.go64 // Step 1: Attempt role assumptionCOMMENT
LOWweed/iam/integration/iam_integration_test.go84 // Step 2: Test policy enforcement with assumed credentialsCOMMENT
LOWweed/iam/integration/iam_integration_test.go138 // Step 1: Attempt role assumption with LDAP credentialsCOMMENT
LOWweed/iam/integration/iam_integration_test.go158 // Step 2: Test policy enforcementCOMMENT
LOW⚡weed/iam/policy/policy_engine.go1235 // Step 1: Substitute policy variables (e.g., ${aws:username}, ${saml:username})COMMENT
LOW⚡weed/iam/policy/policy_engine.go1238 // Step 2: Handle special patternsCOMMENT
LOW⚡weed/iam/policy/policy_engine.go1255 // Step 3: Case-insensitive exact matchCOMMENT
LOW⚡weed/iam/policy/policy_engine.go1260 // Step 4: Handle AWS-style wildcards (case-insensitive)COMMENT
LOWweed/mount/meta_cache/meta_cache_deadlock_test.go104 // Step 1: the "flush handler" takes the fh exclusive lockCOMMENT
LOWweed/mount/meta_cache/meta_cache_deadlock_test.go116 // Step 2: a subscriber event arrives; the apply loop will runCOMMENT
LOWweed/mount/meta_cache/meta_cache_deadlock_test.go131 // Step 3: still holding the fh lock, the flush handler applies its localCOMMENT
LOWweed/mq/topic/local_partition.go136 // Step 2: Enter the main loop - read from in-memory buffer, occasionally checking diskCOMMENT
LOWweed/mq/kafka/protocol/offset_fetch_pattern_test.go45 // Step 1: Fetch batch of messages starting from nextOffsetCOMMENT
LOW⚡weed/mq/kafka/protocol/offset_fetch_pattern_test.go64 // Step 2: Commit the last offset in this batchCOMMENT
LOW⚡weed/mq/kafka/protocol/offset_fetch_pattern_test.go70 // Step 3: Verify offset is correctly storedCOMMENT
LOW⚡weed/mq/kafka/protocol/offset_fetch_pattern_test.go76 // Step 4: Next fetch should start from lastConsumedOffset + 1COMMENT
LOWweed/mq/kafka/protocol/fetch.go1011 // We need to check if this looks like a real RecordValue or just random bytesCOMMENT
157 more matches not shown…
Decorative Section Separators87 hits · 284 pts
SeverityFileLineSnippetContext
MEDIUM⚡terraform/test/local-secure/main.tf1# =============================================================================COMMENT
MEDIUM⚡terraform/test/local-secure/main.tf6# =============================================================================COMMENT
MEDIUM⚡terraform/test/local/main.tf1# =============================================================================COMMENT
MEDIUM⚡terraform/test/local/main.tf8# =============================================================================COMMENT
MEDIUMterraform/modules/core/main.tf1# =============================================================================COMMENT
MEDIUMterraform/modules/core/main.tf6# =============================================================================COMMENT
MEDIUMterraform/modules/core/main.tf78 # ===========================================================================COMMENT
MEDIUMterraform/modules/core/main.tf80 # ===========================================================================COMMENT
MEDIUMterraform/modules/core/main.tf123 # ===========================================================================COMMENT
MEDIUMterraform/modules/core/main.tf125 # ===========================================================================COMMENT
MEDIUMterraform/modules/core/main.tf170 # ===========================================================================COMMENT
MEDIUMterraform/modules/core/main.tf172 # ===========================================================================COMMENT
MEDIUMterraform/modules/core/main.tf221 # ===========================================================================COMMENT
MEDIUMterraform/modules/core/main.tf223 # ===========================================================================COMMENT
MEDIUMterraform/modules/core/main.tf264 # ===========================================================================COMMENT
MEDIUMterraform/modules/core/main.tf266 # ===========================================================================COMMENT
MEDIUMterraform/modules/core/main.tf314 # ===========================================================================COMMENT
MEDIUMterraform/modules/core/main.tf316 # ===========================================================================COMMENT
MEDIUM⚡terraform/modules/core/variables.tf1# =============================================================================COMMENT
MEDIUM⚡terraform/modules/core/variables.tf13# =============================================================================COMMENT
MEDIUMterraform/modules/core/variables.tf51# ----------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/variables.tf54# ----------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/variables.tf106# ----------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/variables.tf108# ----------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/variables.tf145# ----------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/variables.tf147# ----------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/variables.tf191# ----------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/variables.tf193# ----------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/variables.tf236# ----------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/variables.tf239# ----------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/variables.tf267# ----------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/variables.tf270# ----------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/variables.tf283# ----------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/variables.tf285# ----------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/tests/render.tftest.hcl8# ---------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/tests/render.tftest.hcl32# ---------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/tests/render.tftest.hcl54# ---------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/tests/render.tftest.hcl72# ---------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/tests/render.tftest.hcl100# ---------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/tests/render.tftest.hcl132# ---------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/core/tests/render.tftest.hcl155# ---------------------------------------------------------------------------COMMENT
MEDIUMterraform/modules/security/variables.tf1# =============================================================================COMMENT
MEDIUMterraform/modules/security/variables.tf9# =============================================================================COMMENT
MEDIUMterraform/modules/aws/security.tf1# =============================================================================COMMENT
MEDIUMterraform/modules/aws/security.tf10# =============================================================================COMMENT
MEDIUMterraform/modules/aws/variables.tf1# =============================================================================COMMENT
MEDIUMterraform/modules/aws/variables.tf8# =============================================================================COMMENT
MEDIUMweed/shell/command_fs_distribute_chunks_test.go39// ── shortName ────────────────────────────────────────────────────────────────COMMENT
MEDIUMweed/shell/command_fs_distribute_chunks_test.go56// ── relevantNodes ────────────────────────────────────────────────────────────COMMENT
MEDIUMweed/shell/command_fs_distribute_chunks_test.go70// ── computeOwnerTarget ───────────────────────────────────────────────────────COMMENT
MEDIUMweed/shell/command_fs_distribute_chunks_test.go110// ── buildDistributionCounts ──────────────────────────────────────────────────COMMENT
MEDIUMweed/shell/command_fs_distribute_chunks_test.go156// ── selectActiveNodes ────────────────────────────────────────────────────────COMMENT
MEDIUMweed/shell/command_fs_distribute_chunks_test.go181// ── planOwnerMoves ───────────────────────────────────────────────────────────COMMENT
MEDIUMweed/shell/command_fs_distribute_chunks_test.go223// ── planDistribution: primary ─────────────────────────────────────────────────COMMENT
MEDIUMweed/shell/command_fs_distribute_chunks_test.go287// ── planDistribution: round-robin ─────────────────────────────────────────────COMMENT
MEDIUMweed/shell/command_fs_distribute_chunks_test.go361// ── planDistribution: replica ─────────────────────────────────────────────────COMMENT
MEDIUMweed/shell/command_fs_distribute_chunks_test.go410// ── printRedistributionPlan ──────────────────────────────────────────────────COMMENT
MEDIUMweed/ec/ec_lifecycle_model_test.go115// ── invariants ──────────────────────────────────────────────────────────────COMMENT
MEDIUMweed/ec/ec_lifecycle_model_test.go159// ── operations as step lists ────────────────────────────────────────────────COMMENT
MEDIUMweed/ec/ec_lifecycle_model_test.go327// ── recovery convergence ────────────────────────────────────────────────────COMMENT
27 more matches not shown…
Excessive Try-Catch Wrapping84 hits · 100 pts
SeverityFileLineSnippetContext
LOWdocker/test.py91 except Exception as e:CODE
MEDIUMdocker/test.py92 print(f"Error listing files: {e}")CODE
MEDIUMtest/s3/compatibility/fix_s3_tests_bucket_conflicts.py35 print(f"Error: File {file_path} not found")CODE
LOWtest/s3/error_compat/s3_error_compat_test.py112 except Exception as e:CODE
MEDIUMtest/s3/error_compat/s3_error_compat_test.py100def cleanup():CODE
LOW⚡test/s3/parquet/test_cross_filesystem_compatibility.py151 except Exception:CODE
LOW⚡test/s3/parquet/test_cross_filesystem_compatibility.py161 except Exception:CODE
LOW⚡test/s3/parquet/test_cross_filesystem_compatibility.py171 except Exception:CODE
LOW⚡test/s3/parquet/test_cross_filesystem_compatibility.py183 except Exception as e: # noqa: BLE001 - Intentionally broad for compatibility testingCODE
LOW⚡test/s3/parquet/test_cross_filesystem_compatibility.py192 except Exception as e: # noqa: BLE001 - Intentionally broad for compatibility testingCODE
LOW⚡test/s3/parquet/test_cross_filesystem_compatibility.py201 except Exception as e: # noqa: BLE001 - Intentionally broad for compatibility testingCODE
LOW⚡test/s3/parquet/test_cross_filesystem_compatibility.py216 except Exception as e: # noqa: BLE001 - Intentionally broad for compatibility testingCODE
LOW⚡test/s3/parquet/test_cross_filesystem_compatibility.py225 except Exception as e: # noqa: BLE001 - Intentionally broad for compatibility testingCODE
LOW⚡test/s3/parquet/test_cross_filesystem_compatibility.py234 except Exception as e: # noqa: BLE001 - Intentionally broad for compatibility testingCODE
LOWtest/s3/parquet/test_cross_filesystem_compatibility.py94 except Exception:CODE
LOWtest/s3/parquet/test_cross_filesystem_compatibility.py132 except Exception:CODE
LOWtest/s3/parquet/test_cross_filesystem_compatibility.py302 except Exception as e: # noqa: BLE001 - Top-level exception handler for test orchestrationCODE
LOWtest/s3/parquet/test_cross_filesystem_compatibility.py339 except Exception as e: # noqa: BLE001 - Top-level exception handler for test orchestrationCODE
LOWtest/s3/parquet/test_cross_filesystem_compatibility.py352 except Exception:CODE
LOWtest/s3/parquet/s3_parquet_test.py118 except Exception:CODE
LOWtest/s3/parquet/s3_parquet_test.py132 except Exception:CODE
LOWtest/s3/parquet/s3_parquet_test.py144 except Exception as e:CODE
LOWtest/s3/parquet/s3_parquet_test.py159 except Exception as e:CODE
LOWtest/s3/parquet/s3_parquet_test.py199 except Exception as e:CODE
LOWtest/s3/parquet/s3_parquet_test.py225 except Exception as e:CODE
LOW⚡test/s3/parquet/s3_parquet_test.py253 except Exception as e:CODE
LOW⚡test/s3/parquet/s3_parquet_test.py266 except Exception as e:CODE
LOWtest/s3/parquet/s3_parquet_test.py278 except Exception as e:CODE
LOWtest/s3/parquet/s3_parquet_test.py319 except Exception as e:CODE
LOWtest/s3/parquet/s3_parquet_test.py342 except Exception as e:CODE
MEDIUMtest/s3/parquet/s3_parquet_test.py410 print(f"Error details logged to: {ERROR_LOG_FILE}")CODE
LOWtest/s3/parquet/debug_write_dataset.py55 except Exception as e:CODE
LOW⚡test/s3/parquet/debug_write_dataset.py69 except Exception as e:CODE
LOW⚡test/s3/parquet/debug_write_dataset.py79 except Exception as e:CODE
LOW⚡test/s3/parquet/debug_write_dataset.py82except Exception as e:CODE
MEDIUMtest/s3/parquet/debug_write_dataset.py38def list_recursive(path, indent=0):CODE
LOWtest/s3/parquet/test_implicit_directory_fix.py132 except Exception as e:CODE
LOWtest/s3/parquet/test_implicit_directory_fix.py155 except Exception as e:CODE
LOW⚡test/s3/parquet/test_implicit_directory_fix.py174 except Exception as e:CODE
LOW⚡test/s3/parquet/test_implicit_directory_fix.py195 except Exception as e:CODE
LOW⚡test/s3/parquet/test_implicit_directory_fix.py226 except Exception as e:CODE
LOWtest/s3/parquet/test_implicit_directory_fix.py245 except Exception as e:CODE
LOWtest/s3/parquet/test_pyarrow_native_s3.py111 except Exception:CODE
LOWtest/s3/parquet/test_pyarrow_native_s3.py148 except Exception:CODE
LOWtest/s3/parquet/test_pyarrow_native_s3.py170 except Exception as e:CODE
LOWtest/s3/parquet/test_pyarrow_native_s3.py179 except Exception:CODE
LOW⚡test/s3/parquet/test_pyarrow_native_s3.py266 except Exception as exc:CODE
LOWtest/s3/parquet/test_pyarrow_native_s3.py302 except Exception:CODE
LOWtest/s3/parquet/test_sse_s3_compatibility.py98 except Exception:CODE
LOWtest/s3/parquet/test_sse_s3_compatibility.py134 except Exception:CODE
LOWtest/s3/parquet/test_sse_s3_compatibility.py165 except Exception as e:CODE
LOWtest/s3/spark/issue_8234_repro_test.go47except Exception as err:CODE
LOWtest/s3tables/catalog/test_rest_catalog_auth.py141 except Exception as e:CODE
LOWtest/s3tables/catalog/test_rest_catalog_auth.py183 except Exception as e:CODE
LOWtest/s3tables/catalog/test_rest_catalog_auth.py213 except Exception as e:CODE
LOWtest/s3tables/catalog/test_rest_catalog.py146 except Exception as e:CODE
LOWtest/s3tables/catalog/test_rest_catalog.py172 except Exception as e:CODE
LOWtest/s3tables/catalog/test_rest_catalog.py210 except Exception as e:CODE
LOWtest/s3tables/catalog/test_rest_catalog.py241 except Exception as e:CODE
LOWtest/s3tables/catalog_spark/spark_operations_test.go210 except Exception as e:STRING
24 more matches not shown…
AI Slop Vocabulary31 hits · 96 pts
SeverityFileLineSnippetContext
MEDIUM⚡terraform/test/local-secure/main.tf2# Local mTLS test harness: generate the CA + component certs + JWT keys with theCOMMENT
MEDIUMterraform/test/local-secure/main.tf39 # non-secure harness.COMMENT
MEDIUM⚡terraform/test/local/main.tf2# Local test harness: render a small SeaweedFS cluster with the core moduleCOMMENT
MEDIUMterraform/test/local/main.tf33 # High port range so the harness does not collide with a SeaweedFS clusterCOMMENT
MEDIUM⚡terraform/modules/core/variables.tf7# infra wrappers (consume cloud_init/systemd_unit) and the local test harnessCOMMENT
MEDIUMcmd/weed-sql/sqlcmd.go185 // Split file content into individual queries (robust approach).COMMENT
MEDIUMweed/s3api/s3api_sts.go305 // Use typed errors for robust error checkingCOMMENT
MEDIUMweed/s3api/s3_iam_middleware.go106 // Determine token type by issuer claim (more robust than checking role claim)COMMENT
MEDIUMweed/kms/gcp/gcp_kms.go300// This is a simplified implementation - in production, you might want a more robust serializationCOMMENT
MEDIUMweed/util/sqlutil/splitter.go8// This robust implementation handles SQL comments, quoted strings, and escaped characters.COMMENT
MEDIUMweed/shell/command_remote_cache.go37 # comprehensive sync and cache: update metadata, cache content, and remove deleted filesCOMMENT
MEDIUMweed/ec/ec_decode.go141 // Keep this robust against wording tweaks while still being specific.COMMENT
MEDIUMweed/server/postgres/protocol.go41 // Use typed errors for robust error mappingCOMMENT
MEDIUMweed/storage/disk_location_ec.go590// checkDatFileExists checks if a .dat file with actual data exists with robustCOMMENT
MEDIUMweed/iam/providers/errors.go6// These enable robust error checking with errors.Is() throughout the stackCOMMENT
MEDIUMweed/iam/oidc/oidc_provider.go701 // Use JWT library's typed errors for robust error checkingCOMMENT
MEDIUMweed/iam/utils/arn_utils_test.go13// format to ensure robust handling of both legacy and modern AWS ARN formats.COMMENT
MEDIUMweed/iam/sts/sts_service.go1031 // Map provider errors to STS errors using errors.Is() for robust error checkingCOMMENT
MEDIUMweed/iam/sts/session_claims.go139// This enables seamless integration with existing code expecting SessionInfoCOMMENT
MEDIUMweed/iam/sts/constants.go90// Typed errors for robust error checking with errors.Is()COMMENT
MEDIUMweed/filer/filer_deletion.go507// TODO: Consider these improvements for more robust error handling:COMMENT
MEDIUMweed/query/engine/hybrid_message_scanner.go239// Uses SeaweedFS MQ's GenMergedReadFunc for seamless integrationCOMMENT
MEDIUMtest/benchmark/fuse_db/bin/lib.sh2# IMPORTANT: this harness manages ONLY its own processes via pidfiles and its ownCOMMENT
MEDIUMtest/s3/remote_cache/command_edge_cases_test.go102 // This is a simplified check; a more robust test would check if the file is *actually* gone from local cacheCOMMENT
MEDIUMtest/s3/remote_cache/command_edge_cases_test.go105 // The instruction implies just adding the test, not necessarily making it fully robust for all pattern scenarios.COMMENT
MEDIUMtest/s3/iam/s3_iam_distributed_test.go114 // Test concurrent operations across distributed instances with robust retry mechanismsCOMMENT
MEDIUMtest/s3tables/catalog/test_lance_namespace.py61 # what the namespace vends is correct for its own host, and a test harnessCOMMENT
MEDIUMtest/samba/smb_tests.sh5# harness (run_inside_container.sh).COMMENT
MEDIUMtest/kafka/kafka-client-loadtest/docker-compose.yml65 # Enable comprehensive Kafka client DEBUG logging to trace offset managementCOMMENT
MEDIUMtest/kafka/kafka-client-loadtest/config/loadtest.yaml4test_mode: "comprehensive" # producer, consumer, comprehensiveCODE
MEDIUM…st/kafka/kafka-client-loadtest/scripts/run-loadtest.sh81 # Run comprehensive test for 5 minutesCOMMENT
Cross-Language Confusion10 hits · 70 pts
SeverityFileLineSnippetContext
HIGH⚡test/s3/parquet/test_cross_filesystem_compatibility.py249 if not read.schema.equals(original.schema):CODE
HIGH⚡test/s3/parquet/test_cross_filesystem_compatibility.py257 if not read_sorted.equals(original_sorted):CODE
HIGH⚡test/s3/parquet/test_cross_filesystem_compatibility.py263 if not col_original.equals(col_read):CODE
HIGH⚡test/s3/parquet/test_pyarrow_native_s3.py208 if not table_read.schema.equals(table.schema):CODE
HIGH⚡test/s3/parquet/test_pyarrow_native_s3.py215 if not table_read_sorted.equals(table_sorted):CODE
HIGH⚡test/s3/parquet/test_pyarrow_native_s3.py221 if not col_original.equals(col_read):CODE
HIGHtest/s3/parquet/test_pyarrow_native_s3.py235 if not table_dataset_sorted.equals(table_sorted):CODE
HIGHtest/s3/parquet/test_pyarrow_native_s3.py240 if not col_original.equals(col_read):CODE
HIGH⚡test/s3/parquet/test_pyarrow_native_s3.py254 if not table_pads_sorted.equals(table_sorted):CODE
HIGH⚡test/s3/parquet/test_pyarrow_native_s3.py259 if not col_original.equals(col_read):CODE
Redundant / Tautological Comments45 hits · 70 pts
SeverityFileLineSnippetContext
LOWdocker/admin_integration/check_volumes.sh7# Check if master is runningCOMMENT
LOWdocker/admin_integration/demo_vacuum_testing.sh7# Check if SeaweedFS is runningCOMMENT
LOWtest/kms/setup_openbao.sh25# Check if we can connectCOMMENT
LOWtest/s3/iam/setup_keycloak.sh145 # Check if it exists now (might have been created by another process)COMMENT
LOWtest/s3/iam/setup_keycloak.sh215 # Check if role already assignedCOMMENT
LOWtest/s3/iam/setup_keycloak.sh236 # Check if a realm roles mapper already exists for this clientCOMMENT
LOWtest/s3/iam/setup_keycloak.sh277 # Check if an audience mapper already exists for this clientCOMMENT
LOWtest/s3/iam/setup_all_tests.sh57 # Check if LDAP container is already runningCOMMENT
LOWtest/s3/iam/setup_all_tests.sh176 # Check if Keycloak is respondingCOMMENT
LOWtest/s3/parquet/test_pyarrow_native_s3.py133 # Check if bucket existsCOMMENT
LOWtest/s3/parquet/test_pyarrow_native_s3.py156 # Check if bucket exists by trying to list itCOMMENT
LOWtest/java/spark/run-tests.sh8# Check if SeaweedFS is runningCOMMENT
LOWtest/java/spark/quick-start.sh8# Check if SeaweedFS is runningCOMMENT
LOW⚡test/java/spark/quick-start.sh92 # Check if Docker is availableCOMMENT
LOW⚡test/java/spark/quick-start.sh98 # Check if Maven is availableCOMMENT
LOW⚡test/java/spark/quick-start.sh104 # Check if SeaweedFS is running, if not start itCOMMENT
LOWtest/postgres/validate-setup.sh27# Check if running from correct directoryCOMMENT
LOWtest/postgres/validate-setup.sh65# Check if services are runningCOMMENT
LOWtest/kafka/test-schema-bypass.sh11# Check if Kafka gateway is runningCOMMENT
LOWtest/kafka/loadtest/run_million_record_test.sh25# Check if SeaweedFS infrastructure is runningCOMMENT
LOWtest/kafka/scripts/test_schema_registry.sh10# Check if we have a real schema registry URLCOMMENT
LOWtest/kafka/scripts/test_schema_registry.sh46# Check if services are runningCOMMENT
LOW…fka/kafka-client-loadtest/scripts/wait-for-services.sh39# Check if a service is reachableCOMMENT
LOW…fka/kafka-client-loadtest/scripts/wait-for-services.sh71 # Check if we have at least one volume serverCOMMENT
LOW…fka/kafka-client-loadtest/scripts/wait-for-services.sh96 # Check if Schema Registry container is running firstCOMMENT
LOW…fka/kafka-client-loadtest/scripts/wait-for-services.sh185 # Check if it's still starting up (healthcheck start_period)COMMENT
LOW…st/kafka/kafka-client-loadtest/scripts/run-loadtest.sh181# Check if Docker and Docker Compose are availableCOMMENT
LOW…afka/kafka-client-loadtest/scripts/register-schemas.sh95 # Check if it's a consumer lag timeout (error_code 50002)COMMENT
LOW.github/workflows/s3-keycloak-tests.yml66 # Set WEED_BINARY to use the installed versionCOMMENT
LOW.github/workflows/deploy_telemetry.yml147 # Check if service exists and deploy accordinglyCOMMENT
LOW.github/workflows/s3-policy-tests.yml118 # Set WEED_BINARY to use the installed versionCOMMENT
LOW.github/workflows/s3-policy-tests.yml433 # Set WEED_BINARY to use the installed version (though test uses 'weed' command)COMMENT
LOW.github/workflows/s3-proxy-signature-tests.yml67 # Check if containers are runningCOMMENT
LOW.github/workflows/s3-iam-tests.yml120 # Set WEED_BINARY to use the installed versionCOMMENT
LOW.github/workflows/s3tests.yml918 # Check if server process is still alive before waitingCOMMENT
LOW.github/workflows/s3tests.yml934 # Check if server process is still aliveCOMMENT
LOW.github/workflows/kafka-tests.yml255 # Check if broker is properly registered by querying cluster nodesCOMMENT
LOW.github/workflows/kafka-tests.yml272 # Check if broker failed to start and show logsCOMMENT
LOW.github/workflows/kafka-tests.yml434 # Check if broker is properly registered by querying cluster nodesCOMMENT
LOW.github/workflows/kafka-tests.yml451 # Check if broker failed to start and show logsCOMMENT
LOW.github/workflows/kafka-tests.yml595 # Check if broker is properly registered by querying cluster nodesCOMMENT
LOW.github/workflows/kafka-tests.yml612 # Check if broker failed to start and show logsCOMMENT
LOW.github/workflows/kafka-tests.yml753 # Check if broker is properly registered by querying cluster nodesCOMMENT
LOW.github/workflows/kafka-tests.yml770 # Check if broker failed to start and show logsCOMMENT
LOW.github/workflows/posix-compliance.yml295 # Check if this is actually a FUSE mount — the plain directory createdCOMMENT
Hallucination Indicators6 hits · 60 pts
SeverityFileLineSnippetContext
CRITICALweed/static/javascript/jquery-3.6.0.min.js2!function(e,t){"use strict";"object"==typeof module&&"object"==typeof module.exports?module.exports=e.document?t(e,!0):fCODE
CRITICAL…a/spark/src/test/java/seaweed/spark/SparkTestBase.java108 org.apache.hadoop.fs.FileSystem fs = org.apache.hadoop.fs.FileSystem.get(CODE
CRITICAL…java/seaweed/spark/ParquetOperationComparisonTest.java308 try (ParquetWriter<Group> writer = org.apache.parquet.hadoop.example.ExampleParquetWriter.builder(path)CODE
CRITICAL…java/seaweed/spark/ParquetOperationComparisonTest.java347 try (ParquetWriter<Group> writer = org.apache.parquet.hadoop.example.ExampleParquetWriter.builder(path)CODE
CRITICAL…est/java/seaweed/spark/SparkReadDirectParquetTest.java157 try (ParquetWriter<Group> writer = org.apache.parquet.hadoop.example.ExampleParquetWriter.builder(path)CODE
CRITICAL…k/src/test/java/seaweed/spark/SimpleOneColumnTest.java27 org.apache.hadoop.fs.FileSystem fs = org.apache.hadoop.fs.FileSystem.get(CODE
Hyper-Verbose Identifiers50 hits · 57 pts
SeverityFileLineSnippetContext
LOWweed/admin/static/js/policy_editor.js118 function policyEditorOffersNotPrincipal(which) {CODE
LOWweed/admin/static/js/policy_editor.js504 function commitPolicyEditorToTextarea(which) {CODE
LOWweed/admin/static/js/policy_editor.js514 function commitPolicyTextareaToEditor(which) {CODE
LOWweed/admin/static/js/policy_editor.js558 function loadPolicyTextareaIntoEditor(which) {CODE
LOWweed/admin/static/js/policy_editor.js680 function policyTextDisallowedNegationError(which) {CODE
LOWweed/admin/static/js/policy_editor.js704 function confirmPolicyFieldDiscard(which) {CODE
LOWweed/admin/static/js/policy_editor.js911 function renderPolicyDatalistOptions(datalist, values) {CODE
LOWweed/admin/static/js/policy_editor.js917 function updatePolicyResourceSuggestions(which, inputEl) {CODE
LOWweed/admin/static/js/policy_editor.js962 function loadPolicyPrincipalSuggestions() {CODE
LOWweed/admin/static/js/policy_editor.js972 function updatePolicyPrincipalSuggestions(which) {CODE
LOWweed/admin/static/js/s3tables.js443async function loadIcebergNamespaceTables(node, bucketArn, catalogName) {CODE
LOWweed/admin/static/js/admin.js969function updateDeleteSelectedButton() {CODE
LOWweed/admin/static/js/admin.js1421function setupFileManagerEventHandlers() {CODE
LOWweed/admin/view/app/s3_buckets_templ.go883 templ_7745c5c3_Err = templruntime.WriteString(templ_7745c5c3_Buffer, 100, "<!-- Bucket Policy Modal --><div class=\"moCODE
LOWweed/admin/view/app/service_accounts_templ.go272 templ_7745c5c3_Err = templruntime.WriteString(templ_7745c5c3_Buffer, 26, "</select> <small class=\"form-text text-muteCODE
LOWweed/admin/view/app/file_browser_templ.go868 templ_7745c5c3_Err = templruntime.WriteString(templ_7745c5c3_Buffer, 94, "\"><!-- File List Preview --><div id=\"fileLCODE
LOWweed/admin/view/app/object_store_users_templ.go240 templ_7745c5c3_Err = templruntime.WriteString(templ_7745c5c3_Buffer, 24, "</div><div class=\"mb-3\"><label for=\"emailCODE
LOWweed/admin/view/app/plugin_templ.go112 templ_7745c5c3_Err = templruntime.WriteString(templ_7745c5c3_Buffer, 7, "<div class=\"plugin-section plugin-section-ovCODE
LOWweed/admin/view/app/topic_details_templ.go998 templ_7745c5c3_Err = templruntime.WriteString(templ_7745c5c3_Buffer, 117, "</div></div></div></div></div></div></div><CODE
LOWtest/s3/compatibility/fix_s3_tests_bucket_conflicts.py185def _sw_get_new_bucket_resource(name=None):CODE
LOW⚡test/s3/parquet/s3_parquet_test.py259def read_with_parquet_dataset(path: str, fs: s3fs.S3FileSystem) -> Tuple[bool, str, int]:CODE
LOWtest/s3/parquet/test_implicit_directory_fix.py69def test_implicit_directory_head_behavior(fs, s3_client):CODE
LOWtest/s3/parquet/test_implicit_directory_fix.py159def test_pyarrow_dataset_read(fs):CODE
LOW⚡test/s3/parquet/test_implicit_directory_fix.py179def test_explicit_directory_marker(fs, s3_client):CODE
LOW⚡test/s3/parquet/test_implicit_directory_fix.py210def test_empty_file_not_directory(fs, s3_client):CODE
LOWtest/s3tables/catalog/test_rest_catalog_auth.py41def test_namespace_operations(catalog, prefix):CODE
LOWtest/s3tables/catalog/test_rest_catalog.py41def test_namespace_operations(catalog, prefix):CODE
LOWtest/s3vectors/s3vectors_test.py72def test_vector_bucket_policy(vectors):CODE
LOWtest/s3vectors/s3vectors_test.py141def test_upsert_and_invalid_batch(vectors, index):CODE
LOWtest/s3vectors/s3vectors_test.py169def test_list_pagination_and_segments(vectors, index):CODE
LOWtest/s3vectors/s3vectors_test.py219def test_delete_bucket_conflict(vectors, index):CODE
LOWtest/s3vectors/s3vectors_test.py224def test_vector_policy_permissions(vectors, vector_clients, index):CODE
LOWtest/s3vectors/s3vectors_test.py267def test_vector_bucket_encryption(vectors):CODE
LOWtest/s3vectors/s3vectors_test.py309def test_delete_and_recreate_index(vectors, index):CODE
LOWtest/s3vectors/s3vectors_test.py324def test_index_arn_validation(vectors, index):CODE
LOWtest/s3vectors/s3vectors_test.py367def test_query_without_writer(vectors, index, cluster):CODE
LOW…thub/actions/cleanup-stale-fuse-mounts/test_cleanup.py29 def test_only_fuse_integration_test_mounts_are_candidates(self):CODE
LOW…thub/actions/cleanup-stale-fuse-mounts/test_cleanup.py38 def test_all_test_mount_layouts_are_candidates(self):CODE
LOW…thub/actions/cleanup-stale-fuse-mounts/test_cleanup.py55 def test_mountinfo_paths_are_unescaped_once(self):CODE
LOW⚡…thub/actions/cleanup-stale-fuse-mounts/test_cleanup.py67 def test_healthy_mount_is_untouched(self):CODE
LOW⚡…thub/actions/cleanup-stale-fuse-mounts/test_cleanup.py72 def test_other_probe_errors_are_untouched(self):CODE
LOW⚡…thub/actions/cleanup-stale-fuse-mounts/test_cleanup.py79 def test_probe_timeout_does_not_detach_a_possibly_live_mount(self):CODE
LOW⚡…thub/actions/cleanup-stale-fuse-mounts/test_cleanup.py84 def test_disconnected_mount_is_lazily_unmounted(self):CODE
LOW⚡…thub/actions/cleanup-stale-fuse-mounts/test_cleanup.py91 def test_replaced_or_removed_mount_is_untouched(self):CODE
LOW⚡…thub/actions/cleanup-stale-fuse-mounts/test_cleanup.py96 def test_mount_identity_is_checked_without_stat(self):CODE
LOW⚡…thub/actions/cleanup-stale-fuse-mounts/test_cleanup.py101 def test_missing_or_timed_out_helper_uses_fallback(self):CODE
LOW⚡…thub/actions/cleanup-stale-fuse-mounts/test_cleanup.py109 def test_failed_helpers_fall_back_to_sudo(self):CODE
LOW⚡…thub/actions/cleanup-stale-fuse-mounts/test_cleanup.py116 def test_cleanup_fails_when_stale_mount_remains(self):CODE
LOW⚡…thub/actions/cleanup-stale-fuse-mounts/test_cleanup.py123 def test_unmounted_test_dir_is_reclaimed(self):CODE
LOW⚡…thub/actions/cleanup-stale-fuse-mounts/test_cleanup.py129 def test_probe_process_reports_errno(self):CODE
Self-Referential Comments15 hits · 48 pts
SeverityFileLineSnippetContext
MEDIUM⚡terraform/modules/core/variables.tf4# This module is a PURE RENDERER. It creates zero cloud resources. It takes aCOMMENT
MEDIUMweed/command/mini.go1349 sb.WriteString("# This file is loaded on startup if it exists\n")CODE
MEDIUMtest/kms/setup_openbao.sh60 # Create the encryption keyCOMMENT
MEDIUMtest/s3/parquet/debug_write_dataset.py9# Create a simple test tableCOMMENT
MEDIUMtest/s3/parquet/test_implicit_directory_fix.py83 # Create a dataset using PyArrow (creates implicit directory)COMMENT
MEDIUM⚡test/s3/parquet/test_implicit_directory_fix.py185 # Create an explicit directory markerCOMMENT
MEDIUM⚡test/s3/parquet/test_implicit_directory_fix.py216 # Create an empty file with text/plain mime typeCOMMENT
MEDIUMtest/s3tables/catalog/test_rest_catalog_auth.py83 # Define a simple schemaCOMMENT
MEDIUMtest/s3tables/catalog/test_rest_catalog.py83 # Define a simple schemaCOMMENT
MEDIUM…afka/kafka-client-loadtest/scripts/register-schemas.sh66 # Create the schema registration payloadCOMMENT
MEDIUM…afka/kafka-client-loadtest/scripts/register-schemas.sh181 # Define the Avro schema for load test messagesCOMMENT
MEDIUM…afka/kafka-client-loadtest/scripts/register-schemas.sh197 # Define the JSON schema for load test messagesCOMMENT
MEDIUM…afka/kafka-client-loadtest/scripts/register-schemas.sh217 # Define the Protobuf schema for load test messagesCOMMENT
MEDIUM…afka/kafka-client-loadtest/scripts/register-schemas.sh232 # Define the key schema (simple string)COMMENT
MEDIUMtest/foundationdb/test_fdb_s3.sh114# Create a directoryCOMMENT
Fake / Example Data37 hits · 38 pts
SeverityFileLineSnippetContext
LOWweed/s3api/auth_credentials.go167 EmailAddress: "admin@example.com",CODE
LOWweed/s3api/auth_sts_identity_test.go334 "email": "user@example.com",CODE
LOWweed/s3api/auth_sts_identity_test.go353 assert.Equal(t, "user@example.com", sessionInfo.RequestContext["email"])CODE
LOWweed/s3api/auth_sts_identity_test.go363 assert.Equal(t, "user@example.com", identity.Claims["email"], "email should be in Claims")CODE
LOWweed/kms/config.go471 req := &DescribeKeyRequest{KeyID: "health-check-dummy-key"}CODE
LOWweed/admin/config/schema.go59 Placeholder string `json:"placeholder"`CODE
LOWweed/iam/oidc/oidc_provider_test.go128 "email": "user@example.com",CODE
LOWweed/iam/oidc/oidc_provider_test.go140 assert.Equal(t, "user@example.com", email)CODE
LOWweed/iam/oidc/oidc_provider_test.go365 "email": "user@example.com",CODE
LOWweed/iam/oidc/oidc_provider_test.go374 assert.Equal(t, "user@example.com", identity.Email)CODE
LOWweed/iam/oidc/oidc_provider_test.go388 "email": "user@example.com",CODE
LOWweed/iam/oidc/oidc_provider_test.go466 "email": "user@example.com",CODE
LOWweed/iam/oidc/oidc_provider_test.go498 assert.Equal(t, "user@example.com", identity.Email)CODE
LOWweed/iam/oidc/oidc_provider_test.go550 assert.Equal(t, "user@example.com", identity.Email)CODE
LOWweed/iam/oidc/oidc_provider_test.go658 "email": "user@example.com",CODE
LOWweed/mq/kafka/schema/reconstruction_test.go64 "name": "John Doe",CODE
LOWweed/mq/kafka/schema/reconstruction_test.go111 if finalDecodedMsg.RecordValue.Fields["name"].GetStringValue() != "John Doe" {CODE
LOWweed/mq/kafka/schema/reconstruction_test.go112 t.Errorf("Expected name='John Doe', got %v", finalDecodedMsg.RecordValue.Fields["name"].GetStringValue())CODE
LOWweed/mq/kafka/schema/reconstruction_test.go314 "name": "John Doe",CODE
LOWweed/mq/kafka/schema/manager_test.go64 "name": "John Doe",CODE
LOWweed/mq/kafka/schema/manager_test.go106 if nameValue == nil || nameValue.GetStringValue() != "John Doe" {CODE
LOWweed/mq/kafka/schema/manager_test.go107 t.Errorf("Expected name='John Doe', got %v", nameValue)CODE
LOWweed/mq/kafka/schema/decode_encode_test.go50 "name": "John Doe",CODE
LOWweed/mq/kafka/schema/decode_encode_test.go212 "street": "123 Main St",CODE
LOWweed/mq/kafka/schema/json_schema_decoder_test.go106 "name": "John Doe",CODE
LOW⚡weed/mq/kafka/schema/json_schema_decoder_test.go132 "name": "John Doe"CODE
LOW⚡weed/mq/kafka/schema/json_schema_decoder_test.go140 "name": "John Doe",CODE
LOW⚡weed/mq/kafka/schema/json_schema_decoder_test.go149 "name": "John Doe",CODE
LOWweed/mq/kafka/schema/json_schema_decoder_test.go519 jsonData := []byte(`{"id": 123, "name": "John Doe"}`)CODE
LOWweed/mq/kafka/schema/json_schema_decoder_test.go538 jsonData := []byte(`{"id": 123, "name": "John Doe"}`)CODE
LOWweed/mq/kafka/schema/integration_test.go454 "email": map[string]interface{}{"string": "user@example.com"},CODE
LOWweed/mq/kafka/schema/avro_decoder_test.go87 "name": "John Doe",CODE
LOWweed/mq/kafka/schema/avro_decoder_test.go110 if result["name"] != "John Doe" {CODE
LOWweed/mq/kafka/schema/avro_decoder_test.go111 t.Errorf("Expected name='John Doe', got %v", result["name"])CODE
LOWweed/mq/kafka/schema/avro_decoder_test.go519 "name": "John Doe",CODE
LOWweed/query/engine/test_sample_data_test.go125 "data": {Kind: &schema_pb.Value_StringValue{StringValue: `{"field": "email", "new_value": "user@example.com"}CODE
LOWtest/s3/iam/s3_iam_framework.go338 return []byte("dummy-key"), nilCODE
Empty Error Handlers6 hits · 30 pts
SeverityFileLineSnippetContext
HIGHtest/benchmark/fuse_db/bin/fsbench.py52except OSError: passCODE
HIGHtest/benchmark/fuse_db/bin/sqlite_bench.py16except OSError: passCODE
HIGHtest/s3/parquet/test_implicit_directory_fix.py80except:CODE
HIGHtest/s3tables/lifecycle/iceberg_lifecycle.py157except NoSuchTableError:CODE
HIGHtest/s3tables/lifecycle/iceberg_lifecycle.py139except NamespaceAlreadyExistsError:CODE
HIGHtest/s3vectors/conftest.py42except (OSError, urllib.error.URLError):CODE
Example Usage Blocks10 hits · 15 pts
SeverityFileLineSnippetContext
LOWinstall.sh6# Usage:COMMENT
LOWweed/filer/filer.go957// Example usage:COMMENT
LOWweed/wdclient/vidmap_client.go141// Example usage:COMMENT
LOWweed/worker/tasks/base/volume_utils.go14// Example usage:COMMENT
LOWdocker/compose/test-git-on-mount.sh14# Usage:COMMENT
LOWtest/s3/proxy_signature/test.sh5# Usage:COMMENT
LOWtest/s3tables/catalog/docker-compose.test.yaml6# Usage:COMMENT
LOWtest/samba/run.sh17# Usage:COMMENT
LOWtest/pjdfstest/run.sh13# Usage:COMMENT
LOWk8s/charts/seaweedfs/openshift-values.yaml20# Usage:COMMENT
Modern AI Meta-Vocabulary6 hits · 15 pts
SeverityFileLineSnippetContext
MEDIUMterraform/examples/aws-ha-distributed/main.tf7# This is a scaffold: it provisions instances, protected EBS data disks, and theCOMMENT
MEDIUMweed/notification/webhook/webhook_queue_test.go795// the scaffold ships exactly that combination, and a named target must notCOMMENT
MEDIUMtest/s3/parquet/test_cross_filesystem_compatibility.py302 except Exception as e: # noqa: BLE001 - Top-level exception handler for test orchestrationCODE
MEDIUMtest/s3/parquet/test_cross_filesystem_compatibility.py339 except Exception as e: # noqa: BLE001 - Top-level exception handler for test orchestrationCODE
MEDIUMtest/volume_server/DEV_PLAN.md413### Phase 0: Harness and scaffoldingCOMMENT
MEDIUMtest/postgres/SETUP_OVERVIEW.md11├── docker-compose.yml # Multi-service orchestrationCODE
Synthetic Comment Markers2 hits · 15 pts
SeverityFileLineSnippetContext
HIGHweed/server/volume_grpc_tier_upload.go68 // check whether the existing backend storage is the same as requestedCOMMENT
HIGH.github/pull_request_template.md17# Checks for AI generated PRsCOMMENT
Cross-File Repetition3 hits · 15 pts
SeverityFileLineSnippetContext
HIGHtest/s3tables/catalog_clickhouse/append_rows.py0append rows to an existing iceberg table via the seaweedfs rest catalog. used by the doris integration test to materialiSTRING
HIGHtest/s3tables/catalog_dremio/append_rows.py0append rows to an existing iceberg table via the seaweedfs rest catalog. used by the doris integration test to materialiSTRING
HIGHtest/s3tables/catalog_doris/append_rows.py0append rows to an existing iceberg table via the seaweedfs rest catalog. used by the doris integration test to materialiSTRING
Unused Imports9 hits · 8 pts
SeverityFileLineSnippetContext
LOWtest/s3/error_compat/s3_error_compat_test.py14CODE
LOWtest/s3/error_compat/s3_error_compat_test.py14CODE
LOWtest/s3/parquet/test_cross_filesystem_compatibility.py49CODE
LOWtest/s3/parquet/test_cross_filesystem_compatibility.py50CODE
LOWtest/s3/parquet/debug_write_dataset.py36CODE
LOWtest/s3/parquet/test_implicit_directory_fix.py13CODE
LOWtest/s3/parquet/test_implicit_directory_fix.py21CODE
LOWtest/s3/parquet/example_pyarrow_native.py33CODE
LOWtest/s3tables/unity_catalog/delta_rs_writer.py25CODE
Deep Nesting7 hits · 7 pts
SeverityFileLineSnippetContext
LOWtest/s3/parquet/debug_write_dataset.py38CODE
LOWtest/s3/parquet/test_pyarrow_native_s3.py184CODE
LOWtest/s3/parquet/test_pyarrow_native_s3.py271CODE
LOW.github/scripts/helm_jwt_keys.py144CODE
LOWpostgres-examples/test_client.py103CODE
LOWpostgres-examples/test_client.py145CODE
LOWpostgres-examples/test_client.py242CODE
Docstring Block Structure1 hit · 5 pts
SeverityFileLineSnippetContext
HIGHtest/s3/parquet/s3_parquet_test.py168 Helper to discover all parquet files for a given path. Args: path: S3 path (file or directory) STRING
Slop Phrases1 hit · 3 pts
SeverityFileLineSnippetContext
MEDIUMk8s/charts/seaweedfs/values.yaml429 # If these don't meet your needs, you can use "custom" here along with extraVolumes and extraVolumeMountsCOMMENT
Modern Structural Boilerplate1 hit · 1 pts
SeverityFileLineSnippetContext
LOWtest/s3/parquet/test_implicit_directory_fix.py31logger = logging.getLogger(__name__)CODE