data_sources:
  # Existing genetics source
  genetics_23andme_path: "/path/to/23andme_raw_data.txt"

  # SelfDecode API credentials
  selfdecode:
    enabled: true
    profile_id: "your-profile-uuid"  # From URL: ?profile_id=xxx
    jwt_token: "eyJhbGciOiJSUzI1NiIs..."  # From authorization header (without "JWT " prefix)

GET https://selfdecode.com/service/health-analysis/genes/genotype/

# Set variables from profile (read from profiles/{name}.yaml)
profile_name="{profile name from profiles/{name}.yaml}"
profile_id="{from profile: selfdecode.profile_id}"
jwt_token="{from profile: selfdecode.jwt_token}"
rsid="rs429358"
cache_dir=".claude/skills/health-agent/genetics-selfdecode-lookup/.cache/${profile_name}"

# 1. Check cache first
cache_file="${cache_dir}/${rsid}.json"
if [ -f "$cache_file" ]; then
  # Check cache age (30-day TTL = 2592000 seconds)
  fetched=$(python3 -c "import json; print(json.load(open('$cache_file')).get('fetched', ''))" 2>/dev/null)
  if [ -n "$fetched" ]; then
    fetched_ts=$(date -j -f "%Y-%m-%dT%H:%M:%SZ" "$fetched" "+%s" 2>/dev/null || echo 0)
    current_ts=$(date "+%s")
    age=$((current_ts - fetched_ts))

    if [ "$age" -lt 2592000 ]; then
      echo "Using cached SelfDecode data for $rsid (age: $((age/86400)) days)"
      cat "$cache_file"
      exit 0
    fi
  fi
fi

# 2. Query SelfDecode API
response=$(curl -s "https://selfdecode.com/service/health-analysis/genes/genotype/?profile_id=${profile_id}&rsid=${rsid}" \
  -H "authorization: JWT ${jwt_token}")

# 3. Check for authentication errors (requires user intervention)
if echo "$response" | grep -qE '"detail".*([Aa]uthentication|credentials|signature)'; then
  echo "AUTH_ERROR: JWT token expired or invalid"
  echo "Response: $response"
  echo ""
  echo "ACTION REQUIRED: Prompt user to update JWT token, wait for confirmation, then retry"
  exit 2  # Exit code 2 = auth error
fi

# 4. Check for other errors
if echo "$response" | grep -q '"detail"'; then
  echo "Error: $response"
  exit 1
fi

# 5. Parse and cache response
mkdir -p "$cache_dir"
genotypes=$(echo "$response" | python3 -c "import sys, json; r=json.load(sys.stdin); print(r[0]['genotypes'][0] + r[0]['genotypes'][1] if r else '')")

cat > "$cache_file" << EOF
{
  "rsid": "$rsid",
  "fetched": "$(date -u +"%Y-%m-%dT%H:%M:%SZ")",
  "ttl_seconds": 2592000,
  "source": "selfdecode",
  "data": {
    "genotype": "$genotypes",
    "raw_response": $response
  }
}
EOF

echo "Cached SelfDecode data for $rsid: $genotypes"
cat "$cache_file"

# Batch query - up to ~50 SNPs per request
rsids="rs429358,rs7412,rs1801133"

response=$(curl -s "https://selfdecode.com/service/health-analysis/genes/genotype/?profile_id=${profile_id}&rsid=${rsids}" \
  -H "authorization: JWT ${jwt_token}")

# Returns array of results:
# [
#   {"profile_id":"...","rsid":"rs429358","variant_ids":["ref","ref"],"genotypes":["T","T"]},
#   {"profile_id":"...","rsid":"rs7412","variant_ids":["ref","ref"],"genotypes":["C","C"]},
#   ...
# ]

[{
  "profile_id": "edbd7967-4c2f-45f3-95cf-4c45879d77a4",
  "rsid": "rs429358",
  "variant_ids": ["ref", "ref"],
  "genotypes": ["T", "T"]
}]

{
  "rsid": "rs429358",
  "fetched": "2026-01-22T17:00:00Z",
  "ttl_seconds": 2592000,
  "source": "selfdecode",
  "data": {
    "genotype": "TT",
    "raw_response": [{"profile_id":"...","rsid":"rs429358","variant_ids":["ref","ref"],"genotypes":["T","T"]}]
  }
}

## SelfDecode SNP Lookup: rs429358

**Source**: SelfDecode (imputed)
**Genotype**: T/T
**Variant IDs**: ref/ref (homozygous reference)

**Data Retrieved**: 2026-01-22 (fresh)

## SelfDecode Batch Lookup

| rsID | Genotype | Variant IDs |
|------|----------|-------------|
| rs429358 | T/T | ref/ref |
| rs7412 | C/C | ref/ref |
| rs1801133 | C/T | ref/alt |

**Data Retrieved**: 2026-01-22

profile_id="{from profile}"
jwt_token="{from profile}"
rsid="rs429358"
cache_file=".claude/skills/health-agent/genetics-selfdecode-lookup/.cache/${profile_name}/${rsid}.json"
temp_file="/tmp/claude/selfdecode_${rsid}.json"
timeout_seconds=30
max_retries=3

attempt=1
delay=2  # Start with 2 second delay (SelfDecode is slower)
while [ $attempt -le $max_retries ]; do
    # Use timeout command
    timeout_cmd="timeout"
    command -v timeout >/dev/null 2>&1 || timeout_cmd="gtimeout"

    if $timeout_cmd $timeout_seconds curl -s -f \
        "https://selfdecode.com/service/health-analysis/genes/genotype/?profile_id=${profile_id}&rsid=${rsid}" \
        -H "authorization: JWT ${jwt_token}" \
        > "$temp_file" 2>/dev/null; then

        # Check for auth error in response (still 200 status)
        if grep -qE '"detail".*[Aa]uthentication' "$temp_file"; then
            echo "AUTH_ERROR: JWT token expired" >&2
            exit 2
        fi

        # Success
        break
    fi

    exit_code=$?
    if [ $exit_code -eq 124 ]; then
        echo "Request timed out after ${timeout_seconds}s (attempt $attempt/$max_retries)" >&2
    else
        echo "Request failed with exit code $exit_code (attempt $attempt/$max_retries)" >&2
    fi

    if [ $attempt -lt $max_retries ]; then
        echo "Retrying in ${delay}s..." >&2
        sleep $delay
        delay=$((delay * 2))
    else
        echo "All attempts failed" >&2
        # Fall back to cache
        if [ -f "$cache_file" ]; then
            echo "⚠️ Using stale cache for $rsid"
            cat "$cache_file"
            exit 0
        else
            echo "❌ No cache available"
            exit 1
        fi
    fi
    attempt=$((attempt + 1))
done

validate_selfdecode_cache() {
    local file="$1"

    if [ ! -f "$file" ]; then
        return 1
    fi

    # Check file size
    local size=$(wc -c < "$file" 2>/dev/null | tr -d ' ')
    if [ -z "$size" ] || [ "$size" -lt 20 ]; then
        echo "Cache file too small ($size bytes)" >&2
        return 1
    fi

    # Validate JSON
    if ! python3 -c "import json; json.load(open('$file'))" 2>/dev/null; then
        echo "Cache file contains invalid JSON" >&2
        return 1
    fi

    # Check for expected fields
    local has_rsid=$(python3 -c "
import json
d = json.load(open('$file'))
print('yes' if d.get('rsid') and d.get('data', {}).get('genotype') else 'no')
" 2>/dev/null)

    if [ "$has_rsid" != "yes" ]; then
        echo "Cache file missing required fields" >&2
        return 1
    fi

    return 0
}

# Usage
if [ -f "$cache_file" ]; then
    if validate_selfdecode_cache "$cache_file"; then
        # Check TTL and use
        echo "Cache valid"
    else
        echo "Removing corrupted cache for $rsid"
        rm -f "$cache_file"
    fi
fi

validate_selfdecode_response() {
    local response_file="$1"

    # Expected: [{"profile_id":"...","rsid":"...","variant_ids":[...],"genotypes":[...]}]

    local validation=$(python3 -c "
import json, sys
try:
    d = json.load(open('$response_file'))

    # Empty array = SNP not found
    if isinstance(d, list) and len(d) == 0:
        print('NOT_FOUND')
        sys.exit(0)

    # Check for expected structure
    if isinstance(d, list) and len(d) > 0:
        item = d[0]
        if 'rsid' in item and 'genotypes' in item:
            print('VALID')
        elif 'detail' in item:
            print('ERROR:' + str(item.get('detail', 'Unknown')))
        else:
            print('UNKNOWN:' + ','.join(item.keys()))
    elif isinstance(d, dict):
        if 'detail' in d:
            print('ERROR:' + str(d.get('detail', 'Unknown')))
        else:
            print('UNKNOWN_DICT:' + ','.join(d.keys()))
    else:
        print('UNEXPECTED_TYPE:' + type(d).__name__)

except json.JSONDecodeError as e:
    print('JSON_ERROR:' + str(e))
except Exception as e:
    print('ERROR:' + str(e))
" 2>/dev/null)

    case "$validation" in
        VALID)
            return 0
            ;;
        NOT_FOUND)
            echo "SNP not found in SelfDecode database"
            return 2
            ;;
        ERROR:*Authentication*|ERROR:*credentials*)
            echo "Authentication error: ${validation#ERROR:}" >&2
            return 3
            ;;
        ERROR:*)
            echo "API error: ${validation#ERROR:}" >&2
            return 1
            ;;
        UNKNOWN:*|UNKNOWN_DICT:*)
            echo "⚠️ WARNING: SelfDecode API structure may have changed" >&2
            echo "Expected fields: rsid, genotypes" >&2
            echo "Found: ${validation#UNKNOWN:}" >&2
            return 4
            ;;
        JSON_ERROR:*)
            echo "Invalid JSON response: ${validation#JSON_ERROR:}" >&2
            return 1
            ;;
        *)
            echo "Unexpected validation result: $validation" >&2
            return 1
            ;;
    esac
}

# Usage
case $(validate_selfdecode_response "$temp_file"; echo $?) in
    0)
        echo "Valid response, proceeding to cache"
        ;;
    2)
        echo "SNP not in database"
        exit 0
        ;;
    3)
        echo "AUTH_ERROR - prompt user to refresh token"
        exit 2
        ;;
    4)
        echo "API changed - attempting fallback parsing"
        # Try to extract genotype from any structure
        genotype=$(python3 -c "
import json
d = json.load(open('$temp_file'))
# Recursively search for anything that looks like a genotype
def find_genotype(obj, depth=0):
    if depth > 5: return None
    if isinstance(obj, list) and len(obj) == 2 and all(isinstance(x, str) and len(x) == 1 for x in obj):
        return ''.join(obj)
    if isinstance(obj, dict):
        for k, v in obj.items():
            if k in ('genotype', 'genotypes', 'alleles'):
                if isinstance(v, str): return v
                if isinstance(v, list): return find_genotype(v)
            result = find_genotype(v, depth+1)
            if result: return result
    if isinstance(obj, list):
        for item in obj:
            result = find_genotype(item, depth+1)
            if result: return result
    return None
print(find_genotype(d) or 'NOT_FOUND')
" 2>/dev/null)
        if [ "$genotype" != "NOT_FOUND" ] && [ -n "$genotype" ]; then
            echo "Fallback parsing found genotype: $genotype"
        fi
        ;;
    *)
        echo "Request failed"
        exit 1
        ;;
esac

{"detail":"Incorrect authentication credentials."}
{"detail":"Authentication credentials were not provided."}
{"detail":"Error decoding signature."}

## SelfDecode Authentication Error

Your JWT token has expired or is invalid. To continue:

1. Log in to SelfDecode in your browser
2. Open Developer Tools (F12) → Network tab
3. Navigate to any SNP page (e.g., https://selfdecode.com/app/snp/rs429358)
4. Find request to `/service/health-analysis/genes/genotype/`
5. From Request Headers, copy the `authorization` value (just the `eyJ...` part)
6. Update your profile YAML with the new token:
   ```yaml
   data_sources:
     selfdecode:
       jwt_token: "eyJ..."  # Paste new token here

**3. Wait for user confirmation** - Do not proceed until user confirms token update

**4. Re-read the profile** to get the new token:
```bash
# Re-read profile YAML to get updated jwt_token
cat profiles/{profile_name}.yaml | grep -A5 "selfdecode:"

# After curl request, check for auth errors
if echo "$response" | grep -qE '"detail".*([Aa]uthentication|credentials|signature)'; then
  echo "AUTH_ERROR: JWT token expired or invalid"
  echo "Prompt user to update token and wait for confirmation before retrying"
  exit 2  # Exit code 2 = auth error (distinct from other errors)
fi

## SNP Comparison: rs429358

| Source | Genotype | Notes |
|--------|----------|-------|
| 23andMe (raw) | T;T | Directly genotyped |
| SelfDecode (imputed) | T;T | Matches raw data |

**Concordance**: Sources agree. High confidence.