Memories API

import GoodMemClient from '@pairsystems/goodmem-client';

let apiInstance = new GoodMemClient.MemoriesApi();
let jsonBatchMemoryCreationRequest = new GoodMemClient.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.
apiInstance.batchCreateMemory(jsonBatchMemoryCreationRequest).then((data) => {
  console.log('API called successfully. Returned data: ' + data);
}, (error) => {
  console.error(error);
});

import GoodMemClient from '@pairsystems/goodmem-client';

let apiInstance = new GoodMemClient.MemoriesApi();
let batchMemoryDeletionRequest = new GoodMemClient.BatchMemoryDeletionRequest(); // BatchMemoryDeletionRequest | Batch memory deletion details
apiInstance.batchDeleteMemory(batchMemoryDeletionRequest).then((data) => {
  console.log('API called successfully. Returned data: ' + data);
}, (error) => {
  console.error(error);
});

import GoodMemClient from '@pairsystems/goodmem-client';

let apiInstance = new GoodMemClient.MemoriesApi();
let batchMemoryRetrievalRequest = new GoodMemClient.BatchMemoryRetrievalRequest(); // BatchMemoryRetrievalRequest | Batch memory retrieval details
apiInstance.batchGetMemory(batchMemoryRetrievalRequest).then((data) => {
  console.log('API called successfully. Returned data: ' + data);
}, (error) => {
  console.error(error);
});

import GoodMemClient from '@pairsystems/goodmem-client';

let apiInstance = new GoodMemClient.MemoriesApi();
let jsonMemoryCreationRequest = {"spaceId":"550e8400-e29b-41d4-a716-446655440000","originalContent":"This is the content to be stored and processed as a memory.","contentType":"text/plain","metadata":{"source":"document","author":"John Doe","tags":["important","research"]},"chunkingConfig":{"recursive":{"chunkSize":500,"chunkOverlap":50,"separators":["\\n\\n","\\n","."],"keepStrategy":"KEEP_END","separatorIsRegex":false,"lengthMeasurement":"CHARACTER_COUNT"}}}; // 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.
apiInstance.createMemory(jsonMemoryCreationRequest).then((data) => {
  console.log('API called successfully. Returned data: ' + data);
}, (error) => {
  console.error(error);
});

import GoodMemClient from '@pairsystems/goodmem-client';

let apiInstance = new GoodMemClient.MemoriesApi();
let id = "550e8400-e29b-41d4-a716-446655440000"; // String | The unique identifier of the memory to delete
apiInstance.deleteMemory(id).then(() => {
  console.log('API called successfully.');
}, (error) => {
  console.error(error);
});

import GoodMemClient from '@pairsystems/goodmem-client';

let apiInstance = new GoodMemClient.MemoriesApi();
let id = "550e8400-e29b-41d4-a716-446655440000"; // String | The unique identifier of the memory to retrieve
let opts = {
  'includeContent': false, // Boolean | Whether to include the original content in the response (defaults to false). The snake_case alias include_content is also accepted.
  '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.
};
apiInstance.getMemory(id, opts).then((data) => {
  console.log('API called successfully. Returned data: ' + data);
}, (error) => {
  console.error(error);
});

import GoodMemClient from '@pairsystems/goodmem-client';

let apiInstance = new GoodMemClient.MemoriesApi();
let id = "550e8400-e29b-41d4-a716-446655440000"; // String | The unique identifier of the memory to download
apiInstance.getMemoryContent(id).then((data) => {
  console.log('API called successfully. Returned data: ' + data);
}, (error) => {
  console.error(error);
});

import GoodMemClient from '@pairsystems/goodmem-client';

let apiInstance = new GoodMemClient.MemoriesApi();
let id = "550e8400-e29b-41d4-a716-446655440000"; // String | Memory UUID
let pageIndex = 0; // Number | 0-based page index
let opts = {
  'dpi': 150, // Number | Optional rendition filter. If omitted, the unique page-image rendition for the page is returned; if multiple renditions exist, specify dpi and/or contentType.
  '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.
};
apiInstance.getMemoryPageImageContent(id, pageIndex, opts).then((data) => {
  console.log('API called successfully. Returned data: ' + data);
}, (error) => {
  console.error(error);
});

import GoodMemClient from '@pairsystems/goodmem-client';

let apiInstance = new GoodMemClient.MemoriesApi();
let spaceId = "550e8400-e29b-41d4-a716-446655440000"; // String | The unique identifier of the space containing the memories
let opts = {
  'includeContent': false, // Boolean | Whether to include the original content in the response (defaults to false). The snake_case alias include_content is also accepted.
  '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.
  'statusFilter': "COMPLETED", // String | Filter memories by processing status (PENDING, PROCESSING, COMPLETED, FAILED). The snake_case alias status_filter is also accepted.
  'filter': "val('$.source') = 'email'", // String | Optional metadata filter expression for list results
  'maxResults': 100, // Number | Maximum number of results per page (defaults to 50, clamped to [1, 500]). The snake_case alias max_results is also accepted.
  '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.
  'sortBy': "created_at", // String | Field to sort by (e.g., 'created_at'). The snake_case alias sort_by is also accepted.
  'sortOrder': "DESCENDING" // String | Sort direction (ASCENDING or DESCENDING). The snake_case alias sort_order is also accepted.
};
apiInstance.listMemories(spaceId, opts).then((data) => {
  console.log('API called successfully. Returned data: ' + data);
}, (error) => {
  console.error(error);
});

import GoodMemClient from '@pairsystems/goodmem-client';

let apiInstance = new GoodMemClient.MemoriesApi();
let id = "550e8400-e29b-41d4-a716-446655440000"; // String | Memory UUID
let opts = {
  'startPageIndex': 0, // Number | Optional lower bound for returned page indices, inclusive. The snake_case alias start_page_index is also accepted.
  'endPageIndex': 10, // Number | Optional upper bound for returned page indices, inclusive. The snake_case alias end_page_index is also accepted.
  'dpi': 150, // Number | Optional rendition filter for page-image DPI.
  '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.
  'maxResults': 50, // Number | Maximum number of results per page. The snake_case alias max_results is also accepted.
  '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.
};
apiInstance.listMemoryPageImages(id, opts).then((data) => {
  console.log('API called successfully. Returned data: ' + data);
}, (error) => {
  console.error(error);
});

const GoodMemClient = require('@pairsystems/goodmem-client');
const { StreamingClient } = GoodMemClient;

// Configure client
const defaultClient = GoodMemClient.ApiClient.instance;
defaultClient.basePath = 'http://localhost:8080';
defaultClient.defaultHeaders = {
    'X-API-Key': 'your-api-key'
};

// Create streaming client
const streamingClient = new StreamingClient(defaultClient);

// Create abort controller for cancellation
const controller = new AbortController();

// Stream with ChatPostProcessor
streamingClient.retrieveMemoryStreamChat(
    controller.signal,
    'your search query',                          // message
    ['550e8400-e29b-41d4-a716-446655440000'],     // space IDs
    10,                                            // requested size
    true,                                          // fetch memory
    false,                                         // fetch memory content
    'ndjson',                                      // format (ndjson or sse)
    '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
).then(async (stream) => {
    for await (const event of stream) {
        if (event.abstractReply) {
            console.log('Abstract:', event.abstractReply.text);
        } else if (event.retrievedItem && event.retrievedItem.memory) {
            console.log('Memory:', event.retrievedItem.memory);
        }
    }
}).catch(error => {
    console.error('Streaming error:', error);
});

const GoodMemClient = require('@pairsystems/goodmem-client');
const { StreamingClient } = GoodMemClient;

// Configure client
const defaultClient = GoodMemClient.ApiClient.instance;
defaultClient.basePath = 'http://localhost:8080';
defaultClient.defaultHeaders = {
    'X-API-Key': 'your-api-key'
};

// Create streaming client
const streamingClient = new StreamingClient(defaultClient);

// Create abort controller
const controller = new AbortController();

// Create advanced request with custom post-processor
const request = {
    message: 'your search query',
    spaceIds: ['550e8400-e29b-41d4-a716-446655440000'],
    requestedSize: 10,
    fetchMemory: true,
    fetchMemoryContent: false,
    format: 'ndjson',  // or 'sse'
    postProcessorName: 'com.goodmem.retrieval.postprocess.ChatPostProcessorFactory',
    postProcessorConfig: {
        llm_id: '550e8400-e29b-41d4-a716-446655440001',
        reranker_id: '550e8400-e29b-41d4-a716-446655440000',
        relevance_threshold: 0.5,
        llm_temp: 0.3,
        max_results: 10,
        chronological_resort: true
    }
};

// Execute advanced streaming
streamingClient.retrieveMemoryStreamAdvanced(controller.signal, request)
    .then(async (stream) => {
        for await (const event of stream) {
            if (event.abstractReply) {
                console.log('Abstract:', event.abstractReply.text);
            } else if (event.retrievedItem) {
                console.log('Retrieved item:', event.retrievedItem);
            }
        }
    }).catch(error => {
        console.error('Streaming error:', error);
    });