SourceSync.ai MCP Server

Instructions

Implementation Reference

• src/sourcesync.ts:543-557 (handler)

  Core implementation of resyncDocuments in SourceSyncApiClient: sends POST request to /v1/documents/resync with filterConfig to queue documents for reprocessing.

  public async resyncDocuments({
    filterConfig,
  }: Omit<
    SourceSyncResyncDocumentsRequest,
    'namespaceId'
  >): Promise<SourceSyncResyncDocumentsResponse> {
    return this.client
      .url(`/v1/documents/resync`)
      .json({
        namespaceId: this.namespaceId,
        filterConfig,
      } satisfies SourceSyncResyncDocumentsRequest)
      .post()
      .json<SourceSyncResyncDocumentsResponse>()
  }

• src/index.ts:528-567 (handler)

  MCP tool handler for resyncDocuments: destructures params, creates API client, merges documentIds into filterConfig, converts string enums to typed enums, calls underlying client.resyncDocuments, wrapped in safeApiCall.

  async (params: any) => {
    return safeApiCall(async () => {
      const { namespaceId, documentIds, tenantId, filterConfig } = params
  
      // Create a client with the provided parameters
      const client = createClient({ namespaceId, tenantId })
  
      // Add documentIds to filter if provided and not already in filter
      if (documentIds && documentIds.length > 0 && !filterConfig.documentIds) {
        filterConfig.documentIds = documentIds
      }
  
      // Call the resyncDocuments method with properly structured parameters
      return await client.resyncDocuments({
        filterConfig: {
          ...filterConfig,
          // Convert string enum values to their SourceSync enum equivalents
          documentTypes: filterConfig.documentTypes?.map(
            (type: string) =>
              SourceSyncDocumentType[
                type as keyof typeof SourceSyncDocumentType
              ],
          ),
          documentIngestionSources: filterConfig.documentIngestionSources?.map(
            (source: string) =>
              SourceSyncIngestionSource[
                source as keyof typeof SourceSyncIngestionSource
              ],
          ),
          documentIngestionStatuses:
            filterConfig.documentIngestionStatuses?.map(
              (status: string) =>
                SourceSyncIngestionStatus[
                  status as keyof typeof SourceSyncIngestionStatus
                ],
            ),
        },
      })
    })
  },

• src/schemas.ts:413-418 (schema)

  Zod schema defining input parameters for resyncDocuments tool: optional namespaceId, documentIds array, tenantId, and filterConfig.

  export const ResyncDocumentsSchema = z.object({
    namespaceId: namespaceIdSchema.optional(),
    documentIds: z.array(z.string()).optional(),
    tenantId: tenantIdSchema,
    filterConfig: FilterConfigSchema,
  })

• src/index.ts:524-568 (registration)

  MCP server.tool registration for 'resyncDocuments' tool, specifying name, description, input schema, and handler function.

  server.tool(
    'resyncDocuments',
    'Reprocesses documents that match the specified filter criteria. Useful for updating after schema changes.',
    ResyncDocumentsSchema.shape,
    async (params: any) => {
      return safeApiCall(async () => {
        const { namespaceId, documentIds, tenantId, filterConfig } = params
  
        // Create a client with the provided parameters
        const client = createClient({ namespaceId, tenantId })
  
        // Add documentIds to filter if provided and not already in filter
        if (documentIds && documentIds.length > 0 && !filterConfig.documentIds) {
          filterConfig.documentIds = documentIds
        }
  
        // Call the resyncDocuments method with properly structured parameters
        return await client.resyncDocuments({
          filterConfig: {
            ...filterConfig,
            // Convert string enum values to their SourceSync enum equivalents
            documentTypes: filterConfig.documentTypes?.map(
              (type: string) =>
                SourceSyncDocumentType[
                  type as keyof typeof SourceSyncDocumentType
                ],
            ),
            documentIngestionSources: filterConfig.documentIngestionSources?.map(
              (source: string) =>
                SourceSyncIngestionSource[
                  source as keyof typeof SourceSyncIngestionSource
                ],
            ),
            documentIngestionStatuses:
              filterConfig.documentIngestionStatuses?.map(
                (status: string) =>
                  SourceSyncIngestionStatus[
                    status as keyof typeof SourceSyncIngestionStatus
                  ],
              ),
          },
        })
      })
    },
  )

• src/sourcesync.types.ts:649-654 (schema)

  TypeScript type definitions for SourceSyncResyncDocumentsRequest and Response used by the API client.

  export type SourceSyncResyncDocumentsRequest = {
    namespaceId: string
    filterConfig: SourceSyncDocumentFilterConfig
  }
  
  export type SourceSyncResyncDocumentsResponse = SourceSyncApiResponse<{