Drive Items API client for the Mosaia SDK

Provides CRUD operations for managing drive items (files and documents) in the Mosaia platform. Drive items are files and documents stored within drives.

This class inherits from BaseCollection and provides the following functionality:

  • Retrieve drive items with filtering and pagination
  • Create new drive items (metadata-only or with file uploads)
  • Update drive item metadata
  • Delete drive items
  • Handle file uploads
import { Mosaia } from 'mosaia-node-sdk';

const mosaia = new Mosaia({ apiKey: 'your-api-key' });
const drive = await mosaia.drives.get({}, 'drive-id');
const items = drive.items;

// Get all items in the drive
const allItems = await items.get();

// Get a specific item
const item = await items.get({}, 'item-id');

// Create a metadata-only item
const newItem = await items.create({
name: 'document.pdf',
path: '/documents',
size: 1024
});

Hierarchy

Constructors

  • Creates a new Drive Items API client instance

    Initializes the drive items client with the appropriate endpoint URI and model class for handling drive item operations.

    The constructor sets up the API endpoint to /drive/:driveId/item (or ${uri}/drive/:driveId/item if a base URI is provided), which corresponds to the Mosaia API's drive items endpoint.

    Parameters

    • uri: string = ''

      Base URI path. Typically /drive/:driveId where :driveId is the drive ID. If not provided, defaults to /drive/item.

    Returns DriveItems

    // Create with drive URI
    const items = new DriveItems('/drive/drive-id-123');

    // Create via drive model instance
    const drive = await mosaia.drives.get({}, 'drive-id');
    const items = drive.items; // Uses drive.getUri() internally

Methods

  • Get entities with optional filtering and pagination

    This method retrieves entities from the API. When called without an ID, it returns a list of entities with optional filtering and pagination. When called with an ID, it returns a specific entity.

    Parameters

    • params: undefined | QueryParams

      Optional query parameters for filtering and pagination

      • undefined
      • QueryParams

        Query parameters interface for API requests

        Used to define common query parameters that can be passed to API endpoints for filtering, sorting, and pagination.

        • [key: string]: any

          Additional custom query parameters

        • Optionalq?: string

          Search term for text-based filtering

        • Optionallimit?: number

          Maximum number of items to return

        • Optionaloffset?: number

          Number of items to skip (for offset-based pagination)

        • Optionaltags?: string[]

          Array of tags to filter by

        • Optionalactive?: boolean

          Filter by active status

        • Optionalexternal_id?: string

          Filter by external ID

    • id: string

      Optional specific entity ID to retrieve

    Returns Promise<null | DriveItem>

    Promise resolving to: - BatchAPIResponse when getting multiple entities - M when getting a single entity by ID - null when entity is not found

    Get multiple entities with filtering:

    const result = await collection.get({
    limit: 10,
    offset: 0,
    q: 'search term',
    active: true,
    tags: ['tag1', 'tag2']
    });

    console.log('Items:', result.data);
    console.log('Total:', result.paging?.total);

    Get single entity by ID:

    const entity = await collection.get({}, 'entity-id');
    if (entity) {
    console.log('Found:', entity.id);
    } else {
    console.log('Entity not found');
    }

    When API request fails or response is invalid

  • Get entities with optional filtering and pagination

    This method retrieves entities from the API. When called without an ID, it returns a list of entities with optional filtering and pagination. When called with an ID, it returns a specific entity.

    Parameters

    • Optionalparams: QueryParams

      Optional query parameters for filtering and pagination

      Query parameters interface for API requests

      Used to define common query parameters that can be passed to API endpoints for filtering, sorting, and pagination.

      • [key: string]: any

        Additional custom query parameters

      • Optionalq?: string

        Search term for text-based filtering

      • Optionallimit?: number

        Maximum number of items to return

      • Optionaloffset?: number

        Number of items to skip (for offset-based pagination)

      • Optionaltags?: string[]

        Array of tags to filter by

      • Optionalactive?: boolean

        Filter by active status

      • Optionalexternal_id?: string

        Filter by external ID

    Returns Promise<BatchAPIResponse<DriveItem>>

    Promise resolving to: - BatchAPIResponse when getting multiple entities - M when getting a single entity by ID - null when entity is not found

    Get multiple entities with filtering:

    const result = await collection.get({
    limit: 10,
    offset: 0,
    q: 'search term',
    active: true,
    tags: ['tag1', 'tag2']
    });

    console.log('Items:', result.data);
    console.log('Total:', result.paging?.total);

    Get single entity by ID:

    const entity = await collection.get({}, 'entity-id');
    if (entity) {
    console.log('Found:', entity.id);
    } else {
    console.log('Entity not found');
    }

    When API request fails or response is invalid

  • Create a new entity

    This method creates a new entity in the system. The entity ID will be automatically generated by the server. The method returns a new model instance initialized with the created entity's data.

    Parameters

    Returns Promise<DriveItem>

    Promise resolving to a new model instance

    Create a new user:

    const newUser = await users.create({
    email: 'user@example.com',
    firstName: 'John',
    lastName: 'Doe',
    active: true
    });

    console.log('Created user:', newUser.id);

    Create with external ID:

    const newAgent = await agents.create({
    name: 'Customer Support',
    shortDescription: 'AI agent for support',
    external_id: 'agent-123',
    extensors: {
    customField: 'value'
    }
    });

    When API request fails or response is invalid

    When required fields are missing

  • Update an existing entity

    This method updates an existing entity in the system. Only the fields provided in the update data will be updated.

    Parameters

    • id: string

      The entity ID to update

    • updates: Partial<DriveItemInterface>

      Partial entity data for the update (only provided fields will be updated)

    • Optionalparams: QueryParams

      Optional query parameters for the request

    Returns Promise<DriveItem>

    Promise resolving to the updated model instance

    Update user's email:

    const updatedUser = await users.update('user-id', {
    email: 'newemail@example.com'
    });

    Update multiple fields:

    const updatedAgent = await agents.update('agent-id', {
    name: 'Updated Agent Name',
    shortDescription: 'Updated description',
    active: false
    });

    When API request fails or response is invalid

    When entity ID is not provided

  • Delete an entity

    This method permanently deletes an entity from the system. This action cannot be undone.

    Parameters

    • id: string

      The entity ID to delete

    • Optionalparams: QueryParams

      Optional query parameters object. Can include:

      • force: Force deletion even if entity has dependencies (boolean)

    Returns Promise<void>

    Promise that resolves when deletion is successful

    Basic deletion:

    await users.delete('user-id');
    

    Force delete:

    await organizations.delete('org-id', { force: true });
    

    When API request fails or entity not found

    When entity ID is not provided

  • Upload files to the drive using presigned URLs

    Uploads one or more files to the drive using presigned URLs for direct S3 uploads. Each file gets its own UploadJob for independent tracking. This method supports batch file uploads and directory uploads with structure preservation. The backend returns presigned URLs that you can use to upload files directly to S3.

    Parameters

    • files: File[]

      Array of File objects to upload (required for file uploads)

    • Optionaloptions: {
          path?: string;
          relativePaths?: string | string[];
          preserveStructure?: boolean;
          onProgress?: (uploadJob: UploadJob, progress: number) => void;
      }

      Optional upload options

      • Optionalpath?: string

        Base path where files should be uploaded (defaults to '/')

      • OptionalrelativePaths?: string | string[]

        Array of relative paths for directory structure preservation

      • OptionalpreserveStructure?: boolean

        Boolean flag to enable/disable structure preservation (default: true if relativePaths provided)

      • OptionalonProgress?: (uploadJob: UploadJob, progress: number) => void

        Optional progress callback that receives the UploadJob and progress (0-100) for each file

    Returns Promise<
        {
            message: string;
            uploadJobs: UploadJob[];
            instructions: { step1: string; step2: string; step3: string };
        },
    >

    Promise resolving to upload information with UploadJob instances

    // Single file upload
    const fileInput = document.getElementById('fileInput') as HTMLInputElement;
    const file = fileInput.files[0];

    const result = await items.uploadFiles([file], {
    path: '/documents',
    onProgress: (uploadJob, progress) => {
    console.log(`${uploadJob.filename}: ${progress}%`);
    }
    });

    // Files are automatically uploaded to S3
    console.log('Upload jobs:', result.uploadJobs);
    // Batch file upload with directory structure
    const files = Array.from(fileInput.files);
    const result = await items.uploadFiles(files, {
    path: '/uploads',
    relativePaths: ['folder1/file1.txt', 'folder2/file2.txt'],
    preserveStructure: true
    });

    // Each file can be tracked independently
    for (let i = 0; i < result.uploadJobs.length; i++) {
    const uploadJob = result.uploadJobs[i];
    const file = files[i];
    console.log(`Uploading ${uploadJob.filename}...`);
    try {
    await uploadJob.upload(file, {
    onProgress: (progress) => {
    console.log(`${uploadJob.filename}: ${progress}%`);
    }
    });
    } catch (error) {
    console.error(`Failed to upload ${uploadJob.filename}:`, error);
    await uploadJob.markFailed(error.message);
    }
    }

    When upload fails

  • Find a drive item or directory by URL path

    Resolves a URL path to a drive item by traversing the folder hierarchy. If the path resolves to a directory, returns an array of all items within that directory. If the path resolves to a file, returns a single DriveItem.

    Parameters

    • path: string

      URL path like '/documents/report.pdf' or '/folder1/subfolder/file.txt'

    • Optionaloptions: { caseSensitive?: boolean }

      Optional options for path resolution

      • OptionalcaseSensitive?: boolean

        Whether filename matching is case-sensitive (default: true)

    Returns Promise<null | DriveItem | DriveItem[]>

    Promise resolving to DriveItem for files, DriveItem[] for directories, or null if not found

    Find a file by path:

    const item = await items.findByPath('/documents/report.pdf');
    if (item) {
    console.log('Found file:', item.filename);
    }

    Find a directory (returns array):

    const items = await items.findByPath('/documents');
    if (Array.isArray(items)) {
    console.log(`Directory contains ${items.length} items`);
    items.forEach(item => console.log(item.filename));
    }

    Case-insensitive matching:

    const item = await items.findByPath('/Report.PDF', { caseSensitive: false });
    

    When path resolution fails or API error occurs