// Import classes:
import ai.pairsys.goodmem.client.ApiClient;
import ai.pairsys.goodmem.client.ApiException;
import ai.pairsys.goodmem.client.Configuration;
import ai.pairsys.goodmem.client.models.*;
import ai.pairsys.goodmem.client.api.MemoriesApi;

public class Example {
  public static void main(String[] args) {
    ApiClient defaultClient = Configuration.getDefaultApiClient();
    defaultClient.setBasePath("http://localhost");

    MemoriesApi apiInstance = new MemoriesApi(defaultClient);
    JsonBatchMemoryCreationRequest jsonBatchMemoryCreationRequest = new JsonBatchMemoryCreationRequest(); // JsonBatchMemoryCreationRequest | Batch memory creation details. For application/json requests, each item must provide exactly one of originalContent or originalContentB64. For multipart/form-data, provide a requests part and one file part per request.
    try {
      BatchMemoryResponse result = apiInstance.batchCreateMemory(jsonBatchMemoryCreationRequest);
      System.out.println(result);
    } catch (ApiException e) {
      System.err.println("Exception when calling MemoriesApi#batchCreateMemory");
      System.err.println("Status code: " + e.getCode());
      System.err.println("Reason: " + e.getResponseBody());
      System.err.println("Response headers: " + e.getResponseHeaders());
      e.printStackTrace();
    }
  }
}

// Import classes:
import ai.pairsys.goodmem.client.ApiClient;
import ai.pairsys.goodmem.client.ApiException;
import ai.pairsys.goodmem.client.Configuration;
import ai.pairsys.goodmem.client.models.*;
import ai.pairsys.goodmem.client.api.MemoriesApi;

public class Example {
  public static void main(String[] args) {
    ApiClient defaultClient = Configuration.getDefaultApiClient();
    defaultClient.setBasePath("http://localhost");

    MemoriesApi apiInstance = new MemoriesApi(defaultClient);
    BatchMemoryDeletionRequest batchMemoryDeletionRequest = new BatchMemoryDeletionRequest(); // BatchMemoryDeletionRequest | Batch memory deletion details
    try {
      BatchMemoryResponse result = apiInstance.batchDeleteMemory(batchMemoryDeletionRequest);
      System.out.println(result);
    } catch (ApiException e) {
      System.err.println("Exception when calling MemoriesApi#batchDeleteMemory");
      System.err.println("Status code: " + e.getCode());
      System.err.println("Reason: " + e.getResponseBody());
      System.err.println("Response headers: " + e.getResponseHeaders());
      e.printStackTrace();
    }
  }
}

// Import classes:
import ai.pairsys.goodmem.client.ApiClient;
import ai.pairsys.goodmem.client.ApiException;
import ai.pairsys.goodmem.client.Configuration;
import ai.pairsys.goodmem.client.models.*;
import ai.pairsys.goodmem.client.api.MemoriesApi;

public class Example {
  public static void main(String[] args) {
    ApiClient defaultClient = Configuration.getDefaultApiClient();
    defaultClient.setBasePath("http://localhost");

    MemoriesApi apiInstance = new MemoriesApi(defaultClient);
    BatchMemoryRetrievalRequest batchMemoryRetrievalRequest = new BatchMemoryRetrievalRequest(); // BatchMemoryRetrievalRequest | Batch memory retrieval details
    try {
      BatchMemoryResponse result = apiInstance.batchGetMemory(batchMemoryRetrievalRequest);
      System.out.println(result);
    } catch (ApiException e) {
      System.err.println("Exception when calling MemoriesApi#batchGetMemory");
      System.err.println("Status code: " + e.getCode());
      System.err.println("Reason: " + e.getResponseBody());
      System.err.println("Response headers: " + e.getResponseHeaders());
      e.printStackTrace();
    }
  }
}

// Import classes:
import ai.pairsys.goodmem.client.ApiClient;
import ai.pairsys.goodmem.client.ApiException;
import ai.pairsys.goodmem.client.Configuration;
import ai.pairsys.goodmem.client.models.*;
import ai.pairsys.goodmem.client.api.MemoriesApi;

public class Example {
  public static void main(String[] args) {
    ApiClient defaultClient = Configuration.getDefaultApiClient();
    defaultClient.setBasePath("http://localhost");

    MemoriesApi apiInstance = new MemoriesApi(defaultClient);
    JsonMemoryCreationRequest jsonMemoryCreationRequest = new JsonMemoryCreationRequest(); // JsonMemoryCreationRequest | Memory creation details. For application/json requests, provide exactly one of originalContent or originalContentB64. For multipart/form-data, provide a JSON request part plus a file part.
    try {
      Memory result = apiInstance.createMemory(jsonMemoryCreationRequest);
      System.out.println(result);
    } catch (ApiException e) {
      System.err.println("Exception when calling MemoriesApi#createMemory");
      System.err.println("Status code: " + e.getCode());
      System.err.println("Reason: " + e.getResponseBody());
      System.err.println("Response headers: " + e.getResponseHeaders());
      e.printStackTrace();
    }
  }
}

// Import classes:
import ai.pairsys.goodmem.client.ApiClient;
import ai.pairsys.goodmem.client.ApiException;
import ai.pairsys.goodmem.client.Configuration;
import ai.pairsys.goodmem.client.models.*;
import ai.pairsys.goodmem.client.api.MemoriesApi;

public class Example {
  public static void main(String[] args) {
    ApiClient defaultClient = Configuration.getDefaultApiClient();
    defaultClient.setBasePath("http://localhost");

    MemoriesApi apiInstance = new MemoriesApi(defaultClient);
    String id = "550e8400-e29b-41d4-a716-446655440000"; // String | The unique identifier of the memory to delete
    try {
      apiInstance.deleteMemory(id);
    } catch (ApiException e) {
      System.err.println("Exception when calling MemoriesApi#deleteMemory");
      System.err.println("Status code: " + e.getCode());
      System.err.println("Reason: " + e.getResponseBody());
      System.err.println("Response headers: " + e.getResponseHeaders());
      e.printStackTrace();
    }
  }
}

// Import classes:
import ai.pairsys.goodmem.client.ApiClient;
import ai.pairsys.goodmem.client.ApiException;
import ai.pairsys.goodmem.client.Configuration;
import ai.pairsys.goodmem.client.models.*;
import ai.pairsys.goodmem.client.api.MemoriesApi;

public class Example {
  public static void main(String[] args) {
    ApiClient defaultClient = Configuration.getDefaultApiClient();
    defaultClient.setBasePath("http://localhost");

    MemoriesApi apiInstance = new MemoriesApi(defaultClient);
    String id = "550e8400-e29b-41d4-a716-446655440000"; // String | The unique identifier of the memory to retrieve
    Boolean includeContent = false; // Boolean | Whether to include the original content in the response (defaults to false). The snake_case alias include_content is also accepted.
    Boolean includeProcessingHistory = false; // Boolean | Whether to include background job processing history in the response (defaults to false). The snake_case alias include_processing_history is also accepted.
    try {
      Memory result = apiInstance.getMemory(id, includeContent, includeProcessingHistory);
      System.out.println(result);
    } catch (ApiException e) {
      System.err.println("Exception when calling MemoriesApi#getMemory");
      System.err.println("Status code: " + e.getCode());
      System.err.println("Reason: " + e.getResponseBody());
      System.err.println("Response headers: " + e.getResponseHeaders());
      e.printStackTrace();
    }
  }
}

// Import classes:
import ai.pairsys.goodmem.client.ApiClient;
import ai.pairsys.goodmem.client.ApiException;
import ai.pairsys.goodmem.client.Configuration;
import ai.pairsys.goodmem.client.models.*;
import ai.pairsys.goodmem.client.api.MemoriesApi;

public class Example {
  public static void main(String[] args) {
    ApiClient defaultClient = Configuration.getDefaultApiClient();
    defaultClient.setBasePath("http://localhost");

    MemoriesApi apiInstance = new MemoriesApi(defaultClient);
    String id = "550e8400-e29b-41d4-a716-446655440000"; // String | The unique identifier of the memory to download
    try {
      File result = apiInstance.getMemoryContent(id);
      System.out.println(result);
    } catch (ApiException e) {
      System.err.println("Exception when calling MemoriesApi#getMemoryContent");
      System.err.println("Status code: " + e.getCode());
      System.err.println("Reason: " + e.getResponseBody());
      System.err.println("Response headers: " + e.getResponseHeaders());
      e.printStackTrace();
    }
  }
}

// Import classes:
import ai.pairsys.goodmem.client.ApiClient;
import ai.pairsys.goodmem.client.ApiException;
import ai.pairsys.goodmem.client.Configuration;
import ai.pairsys.goodmem.client.models.*;
import ai.pairsys.goodmem.client.api.MemoriesApi;

public class Example {
  public static void main(String[] args) {
    ApiClient defaultClient = Configuration.getDefaultApiClient();
    defaultClient.setBasePath("http://localhost");

    MemoriesApi apiInstance = new MemoriesApi(defaultClient);
    String id = "550e8400-e29b-41d4-a716-446655440000"; // String | Memory UUID
    Integer pageIndex = 0; // Integer | 0-based page index
    Integer dpi = 150; // Integer | Optional rendition filter. If omitted, the unique page-image rendition for the page is returned; if multiple renditions exist, specify dpi and/or contentType.
    String contentType = "image/png"; // String | Optional rendition filter. MIME type of the desired page image, such as image/png. The snake_case alias content_type is also accepted.
    try {
      File result = apiInstance.getMemoryPageImageContent(id, pageIndex, dpi, contentType);
      System.out.println(result);
    } catch (ApiException e) {
      System.err.println("Exception when calling MemoriesApi#getMemoryPageImageContent");
      System.err.println("Status code: " + e.getCode());
      System.err.println("Reason: " + e.getResponseBody());
      System.err.println("Response headers: " + e.getResponseHeaders());
      e.printStackTrace();
    }
  }
}

// Import classes:
import ai.pairsys.goodmem.client.ApiClient;
import ai.pairsys.goodmem.client.ApiException;
import ai.pairsys.goodmem.client.Configuration;
import ai.pairsys.goodmem.client.models.*;
import ai.pairsys.goodmem.client.api.MemoriesApi;

public class Example {
  public static void main(String[] args) {
    ApiClient defaultClient = Configuration.getDefaultApiClient();
    defaultClient.setBasePath("http://localhost");

    MemoriesApi apiInstance = new MemoriesApi(defaultClient);
    String spaceId = "550e8400-e29b-41d4-a716-446655440000"; // String | The unique identifier of the space containing the memories
    Boolean includeContent = false; // Boolean | Whether to include the original content in the response (defaults to false). The snake_case alias include_content is also accepted.
    Boolean includeProcessingHistory = false; // Boolean | Whether to include background job processing history in the response (defaults to false). The snake_case alias include_processing_history is also accepted.
    String statusFilter = "PENDING"; // String | Filter memories by processing status (PENDING, PROCESSING, COMPLETED, FAILED). The snake_case alias status_filter is also accepted.
    String filter = "val('$.source') = 'email'"; // String | Optional metadata filter expression for list results
    Integer maxResults = 50; // Integer | Maximum number of results per page (defaults to 50, clamped to [1, 500]). The snake_case alias max_results is also accepted.
    String nextToken = "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9..."; // String | Opaque pagination token for the next page. URL-safe Base64 without padding; do not parse or construct it. The snake_case alias next_token is also accepted.
    String sortBy = "created_at"; // String | Field to sort by (e.g., 'created_at'). The snake_case alias sort_by is also accepted.
    String sortOrder = "DESCENDING"; // String | Sort direction (ASCENDING or DESCENDING). The snake_case alias sort_order is also accepted.
    try {
      MemoryListResponse result = apiInstance.listMemories(spaceId, includeContent, includeProcessingHistory, statusFilter, filter, maxResults, nextToken, sortBy, sortOrder);
      System.out.println(result);
    } catch (ApiException e) {
      System.err.println("Exception when calling MemoriesApi#listMemories");
      System.err.println("Status code: " + e.getCode());
      System.err.println("Reason: " + e.getResponseBody());
      System.err.println("Response headers: " + e.getResponseHeaders());
      e.printStackTrace();
    }
  }
}

// Import classes:
import ai.pairsys.goodmem.client.ApiClient;
import ai.pairsys.goodmem.client.ApiException;
import ai.pairsys.goodmem.client.Configuration;
import ai.pairsys.goodmem.client.models.*;
import ai.pairsys.goodmem.client.api.MemoriesApi;

public class Example {
  public static void main(String[] args) {
    ApiClient defaultClient = Configuration.getDefaultApiClient();
    defaultClient.setBasePath("http://localhost");

    MemoriesApi apiInstance = new MemoriesApi(defaultClient);
    String id = "550e8400-e29b-41d4-a716-446655440000"; // String | Memory UUID
    Integer startPageIndex = 0; // Integer | Optional lower bound for returned page indices, inclusive. The snake_case alias start_page_index is also accepted.
    Integer endPageIndex = 10; // Integer | Optional upper bound for returned page indices, inclusive. The snake_case alias end_page_index is also accepted.
    Integer dpi = 150; // Integer | Optional rendition filter for page-image DPI.
    String contentType = "image/png"; // String | Optional rendition filter for page-image MIME type, such as image/png. The snake_case alias content_type is also accepted.
    Integer maxResults = 50; // Integer | Maximum number of results per page. The snake_case alias max_results is also accepted.
    String nextToken = "eyJzdGFydCI6NTAsIm1lbW9yeUlkIjoiLi4uIn0"; // String | Opaque pagination token for the next page. The snake_case alias next_token is also accepted. Do not parse or construct it.
    try {
      ListMemoryPageImagesResponse result = apiInstance.listMemoryPageImages(id, startPageIndex, endPageIndex, dpi, contentType, maxResults, nextToken);
      System.out.println(result);
    } catch (ApiException e) {
      System.err.println("Exception when calling MemoriesApi#listMemoryPageImages");
      System.err.println("Status code: " + e.getCode());
      System.err.println("Reason: " + e.getResponseBody());
      System.err.println("Response headers: " + e.getResponseHeaders());
      e.printStackTrace();
    }
  }
}

import ai.pairsys.goodmem.client.ApiClient;
import ai.pairsys.goodmem.client.StreamingClient;
import ai.pairsys.goodmem.client.StreamingClient.*;

import java.util.List;
import java.util.stream.Stream;

public class BasicStreamingExample {
    public static void main(String[] args) throws StreamError {
        // Configure client
        ApiClient apiClient = new ApiClient();
        apiClient.setBasePath("http://localhost:8080");
        apiClient.setApiKey("your-api-key");

        // Create streaming client
        StreamingClient streamingClient = new StreamingClient(apiClient);

        // Stream memory retrieval results with ChatPostProcessor
        Stream<MemoryStreamResponse> stream = streamingClient.retrieveMemoryStreamChat(
            "your search query",                              // message
            List.of("550e8400-e29b-41d4-a716-446655440000"),  // space IDs
            10,                                                // requested size
            true,                                              // fetch memory
            false,                                             // fetch memory content
            "550e8400-e29b-41d4-a716-446655440001",           // LLM ID
            "550e8400-e29b-41d4-a716-446655440000",           // reranker ID
            0.5,                                               // relevance threshold
            0.3,                                               // LLM temperature
            10,                                                // max results
            true                                               // chronological resort
        );

        // Process streaming events
        stream.forEach(event -> {
            if (event.getAbstractReply() != null) {
                System.out.println("Abstract: " + event.getAbstractReply().getText());
            } else if (event.getRetrievedItem() != null
                    && event.getRetrievedItem().getMemory() != null) {
                System.out.println("Memory: " + event.getRetrievedItem().getMemory());
            }
        });
    }
}

import ai.pairsys.goodmem.client.ApiClient;
import ai.pairsys.goodmem.client.StreamingClient;
import ai.pairsys.goodmem.client.StreamingClient.*;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Stream;

public class AdvancedStreamingExample {
    public static void main(String[] args) throws StreamError {
        // Configure client
        ApiClient apiClient = new ApiClient();
        apiClient.setBasePath("http://localhost:8080");
        apiClient.setApiKey("your-api-key");

        // Create streaming client
        StreamingClient streamingClient = new StreamingClient(apiClient);

        // Create advanced request with custom post-processor
        AdvancedMemoryStreamRequest request = new AdvancedMemoryStreamRequest(
            "your search query",
            List.of("550e8400-e29b-41d4-a716-446655440000")
        );
        request.setRequestedSize(10);
        request.setFetchMemory(true);
        request.setFetchMemoryContent(false);

        // Configure custom post-processor
        request.setPostProcessorName("com.goodmem.retrieval.postprocess.ChatPostProcessorFactory");

        Map<String, Object> postProcessorConfig = new HashMap<>();
        postProcessorConfig.put("llm_id", "550e8400-e29b-41d4-a716-446655440001");
        postProcessorConfig.put("reranker_id", "550e8400-e29b-41d4-a716-446655440000");
        postProcessorConfig.put("relevance_threshold", 0.5);
        postProcessorConfig.put("llm_temp", 0.3);
        postProcessorConfig.put("max_results", 10);
        postProcessorConfig.put("chronological_resort", true);
        request.setPostProcessorConfig(postProcessorConfig);

        // Execute advanced streaming
        Stream<MemoryStreamResponse> stream = streamingClient.retrieveMemoryStreamAdvanced(request);

        // Process streaming events
        stream.forEach(event -> {
            if (event.getAbstractReply() != null) {
                System.out.println("Abstract: " + event.getAbstractReply().getText());
            } else if (event.getRetrievedItem() != null) {
                System.out.println("Retrieved item: " + event.getRetrievedItem());
            }
        });
    }
}