Yazam API Reference

using (MultipartFormDataContent job = new MultipartFormDataContent
{
    { new StringContent("<POLICY_NAME>"), "policy" },
    { new StringContent("<CLIENT>"),      "client" },
    { new StringContent("modified"),      "return" }
})
{
    job.Add(new StreamContent(File.OpenRead("<PATH_TO_FILE1>")), "file", "<FILE1_NAME>");
    job.Add(new StreamContent(File.OpenRead("<PATH_TO_FILE2>")), "file", "<FILE2_NAME>");

    using (HttpClient hc = new HttpClient(new HttpClientHandler(), true)
    { BaseAddress = new Uri(@"https://<HOST>/composite/"), Timeout = Timeout.InfiniteTimeSpan })

    using (HttpResponseMessage response = await hc.SendAsync(
        new HttpRequestMessage(HttpMethod.Post, "") { Content = job },
        HttpCompletionOption.ResponseHeadersRead).ConfigureAwait(false))
    {
        response.EnsureSuccessStatusCode();

        MultipartMemoryStreamProvider result = await response.Content
            .ReadAsMultipartAsync(new MultipartMemoryStreamProvider()).ConfigureAwait(false);
        foreach (HttpContent part in result.Contents)
        {
            if (part.Headers.ContentDisposition.Name == "summary")
                Console.WriteLine("Summary: \n" + part.ReadAsStringAsync().ConfigureAwait(false));
            else if (part.Headers.ContentDisposition.Name == "file")
                using (Stream file = await part.ReadAsStreamAsync().ConfigureAwait(false))
                {
                    Console.WriteLine("Modified file: " + part.Headers.ContentDisposition.FileNameStar + ", size: " + file.Length);
                    // process file ...
                }
        }
    }
}

import os, requests
from requests_toolbelt.multipart import decoder
import pyrfc6266

path1 = r"<PATH_TO_FILE1>"
path2 = r"<PATH_TO_FILE2>"
fn1 = os.path.basename(path1)
fn2 = os.path.basename(path2)

with open(path1, "rb") as f1, open(path2, "rb") as f2:
    r = requests.post(
        "https://<HOST>/composite/",
        data=[
            ("policy", "<POLICY_NAME>"),
            ("client", "<CLIENT>"),
            ("return", "modified"),
            ("return", "json"),
        ],
        files=[
            ("file", (fn1, f1, "application/octet-stream")),
            ("file", (fn2, f2, "application/octet-stream")),
        ],
        # Add authentication here if required
    )

multipart_data = decoder.MultipartDecoder.from_response(r)
for part in multipart_data.parts:
    cd = part.headers.get(b"Content-Disposition", b"").decode("ascii", "ignore")
    disp, params = pyrfc6266.parse(cd)
    name = next(p for p in params if p.name == "name").value
    if name == "summary":
        print(part.text)
    elif name == "file":
        print(next(p for p in params if p.name == "filename*").value)

import os
from urllib.parse import quote
import requests

base_url = "http://127.0.0.1:8008/native"

def filter_file(session, file_path, policy, client="", return_format="JSON"):
    file_name = os.path.basename(file_path)
    encoded_name = quote(file_name)

    # Submit the file
    with open(file_path, "rb") as file:
        response = session.post(
            base_url,
            data=file,
            headers={"Content-Name": encoded_name}
        )
        response.raise_for_status()

    # Filter the file
    data = {
        "policy": policy,
        "client": client,
        "return": return_format
    }

    response = session.put(base_url, json=data)
    response.raise_for_status()
    print(response.text)

    # Retrieve filtered file
    altered_file_path = f"altered_{file_name}"
    response = session.get(f"{base_url}?name={encoded_name}")
    response.raise_for_status()

    with open(altered_file_path, "wb") as file:
        file.write(response.content)

    return altered_file_path

file_paths = [
    r"C:\path\to\file1.jpg",
    r"C:\path\to\file2.xml"
]

session = requests.Session()
# Optional: add authentication to the session if required
# (for example Basic auth, Bearer token, or client certificate).

try:
    for file_path in file_paths:
        altered_file_path = filter_file(session, file_path, "full")
        print(f"Altered file saved as: {altered_file_path}")
finally:
    response = session.delete(base_url)
    response.raise_for_status()

base_url      →  https://<YOUR_HOST>
policy        →  <POLICY_NAME>
client        →  postman-test
bearer_token  →  (auto-populated by logon request)

const token = pm.response.text();
if (token) pm.environment.set("bearer_token", token.trim());