جولة متكاملة من البداية إلى النهاية

#!/usr/bin/env bash
set -euo pipefail
BASE="https://app.sahlfinancial.com/api"
REF="client-0001"

read_doc() { # file, mime, doc_type
  curl -sS --fail-with-body -X POST "$BASE/v1/kyc/extract" \
    -H "Authorization: Bearer $SAHL_API_KEY" \
    -F "files=@$1;type=$2" -F "doc_type=$3" -F "reference=$REF" \
    -F "environment=sandbox" -F "subject=Test Client" -F "kind=individual"
}

# 1 and 2. Read the payslip and the CIN.
read_doc payslip-test.pdf application/pdf payslip > payslip.json
read_doc cin-test.jpg image/jpeg national_id > cin.json
jq -r '"payslip fields: " + (.fields | keys | join(", "))' payslip.json
jq -r '"ID checks: " + ([.checks[] | "\(.id)=\(.passed)"] | join(" "))' cin.json

# 3. Build the request body. Income and answers come from your own form.
jq -n --slurpfile pass cin.json --slurpfile slip payslip.json '
  ($slip[0].fields + $pass[0].fields) as $r | {
    reference: "client-0001", environment: "sandbox", subject: "Test Client", kind: "individual",
    values: {
      first_name: $r.first_name, last_name: $r.last_name, date_of_birth: $r.date_of_birth,
      citizenship: $r.citizenship, country: "MA", id_type: $r.id_type, id_number: $r.id_number,
      id_expiry: $r.id_expiry, occupation: $r.occupation, employer_name: $r.employer_name,
      annual_income: "84000", net_liquid_assets: "20000", total_net_worth: "60000",
      objective: "Balanced", horizon: "5-10 years",
      investment_knowledge: "Good", investment_experience: "< 5 years"
    },
    documents: ($pass[0].documents + $slip[0].documents)
  }' > assess-body.json

# 4. Assess.
curl -sS --fail-with-body -X POST "$BASE/v1/kyc/assess" \
  -H "Authorization: Bearer $SAHL_API_KEY" -H "Content-Type: application/json" \
  -d @assess-body.json > assess.json

jq -r '"passed: \(.verification.passed)",
       "flags: \([.verification.flags[].id] | join(", "))",
       "risk profile: \(.assessment.risk_profile.score) \(.assessment.risk_profile.band)",
       "capacity: \(.assessment.capacity.score) \(.assessment.capacity.band)",
       "compliance risk: \(.assessment.compliance_risk.level) (\(.assessment.compliance_risk.score) points)",
       "suitability: \(.assessment.suitability)",
       "case: \(.case_id)"' assess.json

import { readFile } from "node:fs/promises";

const BASE = "https://app.sahlfinancial.com/api";
const KEY = process.env.SAHL_API_KEY;
const REFERENCE = "client-0001";

async function call(path, init) {
  const res = await fetch(`${BASE}${path}`, {
    ...init,
    headers: { Authorization: `Bearer ${KEY}`, ...init.headers },
  });
  const text = await res.text();
  if (!res.ok) throw new Error(`${path} -> ${res.status} ${text}`);
  return JSON.parse(text);
}

async function extract(file, mime, docType) {
  const form = new FormData();
  form.append("files", new Blob([await readFile(file)], { type: mime }), file);
  form.append("doc_type", docType);
  form.append("reference", REFERENCE);
  form.append("environment", "sandbox");
  form.append("subject", "Test Client");
  form.append("kind", "individual");
  return call("/v1/kyc/extract", { method: "POST", body: form });
}

// 1 and 2. Read the payslip and the CIN.
const payslip = await extract("payslip-test.pdf", "application/pdf", "payslip");
const cin = await extract("cin-test.jpg", "image/jpeg", "national_id");
console.log("payslip fields:", Object.keys(payslip.fields).join(", "));
console.log("ID checks:", cin.checks.map((c) => `${c.id}=${c.passed}`).join(" "));
if (payslip.reader_unavailable || cin.reader_unavailable) throw new Error("a file was not read, retry later");

// 3. Build the profile. Read values come from /extract. Income and answers come from your own form.
const read = { ...payslip.fields, ...cin.fields };
const values = {
  first_name: read.first_name,
  last_name: read.last_name,
  date_of_birth: read.date_of_birth,
  citizenship: read.citizenship,
  country: "MA",
  id_type: read.id_type,
  id_number: read.id_number,
  id_expiry: read.id_expiry,
  occupation: read.occupation,
  employer_name: read.employer_name,
  annual_income: "84000", // declared by the client: the payslip did not state it
  net_liquid_assets: "20000",
  total_net_worth: "60000",
  objective: "Balanced",
  horizon: "5-10 years",
  investment_knowledge: "Good",
  investment_experience: "< 5 years",
};

// 4. Assess: verification plus the risk assessment.
const result = await call("/v1/kyc/assess", {
  method: "POST",
  headers: { "Content-Type": "application/json" },
  body: JSON.stringify({
    reference: REFERENCE,
    environment: "sandbox",
    subject: "Test Client",
    kind: "individual",
    values,
    documents: [...cin.documents, ...payslip.documents], // unchanged, strongest ID first
  }),
});

const { verification, assessment } = result;
console.log("passed:", verification.passed);
console.log("flags:", verification.flags.map((f) => f.id).join(", ") || "none");
console.log("risk profile:", assessment.risk_profile.score, assessment.risk_profile.band);
console.log("capacity:", assessment.capacity.score, assessment.capacity.band);
console.log("compliance risk:", assessment.compliance_risk.level, `(${assessment.compliance_risk.score} points)`);
console.log("suitability:", assessment.suitability);
console.log("case:", result.case_id);

import os
import requests

BASE = "https://app.sahlfinancial.com/api"
HEADERS = {"Authorization": f"Bearer {os.environ['SAHL_API_KEY']}"}
REFERENCE = "client-0001"


def extract(path, mime, doc_type):
    with open(path, "rb") as f:
        res = requests.post(
            f"{BASE}/v1/kyc/extract",
            headers=HEADERS,
            files=[("files", (path, f, mime))],
            data={
                "doc_type": doc_type,
                "reference": REFERENCE,
                "environment": "sandbox",
                "subject": "Test Client",
                "kind": "individual",
            },
            timeout=120,
        )
    res.raise_for_status()
    return res.json()


# 1 and 2. Read the payslip and the CIN.
payslip = extract("payslip-test.pdf", "application/pdf", "payslip")
cin = extract("cin-test.jpg", "image/jpeg", "national_id")
print("payslip fields:", ", ".join(payslip["fields"]))
print("ID checks:", " ".join(f"{c['id']}={c['passed']}" for c in cin["checks"]))
if payslip["reader_unavailable"] or cin["reader_unavailable"]:
    raise SystemExit("a file was not read, retry later")

# 3. Build the profile. Read values come from /extract. Income and answers come from your own form.
read = {**payslip["fields"], **cin["fields"]}
values = {
    "first_name": read["first_name"],
    "last_name": read["last_name"],
    "date_of_birth": read["date_of_birth"],
    "citizenship": read["citizenship"],
    "country": "MA",
    "id_type": read["id_type"],
    "id_number": read["id_number"],
    "id_expiry": read["id_expiry"],
    "occupation": read["occupation"],
    "employer_name": read["employer_name"],
    "annual_income": "84000",  # declared by the client: the payslip did not state it
    "net_liquid_assets": "20000",
    "total_net_worth": "60000",
    "objective": "Balanced",
    "horizon": "5-10 years",
    "investment_knowledge": "Good",
    "investment_experience": "< 5 years",
}

# 4. Assess: verification plus the risk assessment.
res = requests.post(
    f"{BASE}/v1/kyc/assess",
    headers=HEADERS,
    json={
        "reference": REFERENCE,
        "environment": "sandbox",
        "subject": "Test Client",
        "kind": "individual",
        "values": values,
        "documents": cin["documents"] + payslip["documents"],  # unchanged, strongest ID first
    },
    timeout=60,
)
res.raise_for_status()
result = res.json()

verification, assessment = result["verification"], result["assessment"]
print("passed:", verification["passed"])
print("flags:", ", ".join(f["id"] for f in verification["flags"]) or "none")
print("risk profile:", assessment["risk_profile"]["score"], assessment["risk_profile"]["band"])
print("capacity:", assessment["capacity"]["score"], assessment["capacity"]["band"])
print("compliance risk:", assessment["compliance_risk"]["level"], f"({assessment['compliance_risk']['score']} points)")
print("suitability:", assessment["suitability"])
print("case:", result["case_id"])