Paramount Capabilities

Naftiko 0.5 capability definitions for Paramount - 100 capabilities showing integration workflows and service orchestrations.

Sort

Expand

Ad Campaign Revenue Tracker ▼

advertising revenue google-ads snowflake tableau

Pulls ad impression and revenue data from Google Ads and the internal ad server, reconciles in Snowflake, and updates the advertising revenue dashboard in Tableau.

naftiko: "0.5"
info:
  label: "Ad Campaign Revenue Tracker"
  description: "Pulls ad impression and revenue data from Google Ads and the internal ad server, reconciles in Snowflake, and updates the advertising revenue dashboard in Tableau."
  tags:
    - advertising
    - revenue
    - google-ads
    - snowflake
    - tableau
capability:
  exposes:
    - type: mcp
      namespace: ad-revenue
      port: 8080
      tools:
        - name: track-ad-revenue
          description: "Track advertising revenue across platforms and update the revenue dashboard."
          inputParameters:
            - name: campaign_id
              in: body
              type: string
              description: "The advertising campaign identifier."
            - name: date
              in: body
              type: string
              description: "The reporting date in YYYY-MM-DD format."
          steps:
            - name: get-google-ads-data
              type: call
              call: "google-ads.get-campaign-revenue"
              with:
                campaign_id: "{{campaign_id}}"
                date: "{{date}}"
            - name: get-internal-ad-data
              type: call
              call: "ad-server.get-revenue"
              with:
                campaign_id: "{{campaign_id}}"
                date: "{{date}}"
            - name: reconcile-revenue
              type: call
              call: "snowflake.execute-query"
              with:
                query: "CALL reconcile_ad_revenue('{{campaign_id}}', '{{date}}')"
            - name: refresh-dashboard
              type: call
              call: "tableau.refresh-extract"
              with:
                datasource_id: "ad_revenue_ds"
  consumes:
    - type: http
      namespace: google-ads
      baseUri: "https://googleads.googleapis.com/v14"
      authentication:
        type: bearer
        token: "$secrets.google_ads_token"
      resources:
        - name: campaigns
          path: "/customers/paramount/campaigns/{{campaign_id}}/revenue"
          inputParameters:
            - name: campaign_id
              in: path
          operations:
            - name: get-campaign-revenue
              method: GET
    - type: http
      namespace: ad-server
      baseUri: "https://api.paramount.com/adserver/v1"
      authentication:
        type: bearer
        token: "$secrets.paramount_adserver_token"
      resources:
        - name: revenue
          path: "/campaigns/{{campaign_id}}/revenue"
          inputParameters:
            - name: campaign_id
              in: path
          operations:
            - name: get-revenue
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://paramount.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: tableau
      baseUri: "https://tableau.paramount.com/api/3.21"
      authentication:
        type: bearer
        token: "$secrets.tableau_token"
      resources:
        - name: datasources
          path: "/sites/paramount/datasources/{{datasource_id}}/refresh"
          inputParameters:
            - name: datasource_id
              in: path
          operations:
            - name: refresh-extract
              method: POST

Ad Inventory Availability Checker ▼

advertising inventory

Queries the ad server for available ad inventory by content category, time slot, and region. Returns available impressions and CPM rates.

naftiko: "0.5"
info:
  label: "Ad Inventory Availability Checker"
  description: "Queries the ad server for available ad inventory by content category, time slot, and region. Returns available impressions and CPM rates."
  tags:
    - advertising
    - inventory
capability:
  exposes:
    - type: mcp
      namespace: ad-inventory
      port: 8080
      tools:
        - name: check-ad-inventory
          description: "Check available advertising inventory by category and region."
          inputParameters:
            - name: content_category
              in: body
              type: string
              description: "The content category for ad placement."
            - name: region
              in: body
              type: string
              description: "The geographic region."
            - name: date_range
              in: body
              type: string
              description: "The date range for inventory check."
          call: "ad-server.get-inventory"
          with:
            category: "{{content_category}}"
            region: "{{region}}"
            range: "{{date_range}}"
          outputParameters:
            - name: available_impressions
              type: integer
              mapping: "$.data.available_impressions"
            - name: cpm_rate
              type: number
              mapping: "$.data.cpm"
            - name: fill_rate
              type: number
              mapping: "$.data.current_fill_rate"
  consumes:
    - type: http
      namespace: ad-server
      baseUri: "https://api.paramount.com/adserver/v1"
      authentication:
        type: bearer
        token: "$secrets.paramount_adserver_token"
      resources:
        - name: inventory
          path: "/inventory/check"
          operations:
            - name: get-inventory
              method: GET

Adobe Premiere Pro Project Status ▼

content post-production adobe-premiere-pro

Queries the post-production workflow system for Adobe Premiere Pro project status. Returns edit progress, review status, and estimated delivery date.

naftiko: "0.5"
info:
  label: "Adobe Premiere Pro Project Status"
  description: "Queries the post-production workflow system for Adobe Premiere Pro project status. Returns edit progress, review status, and estimated delivery date."
  tags:
    - content
    - post-production
    - adobe-premiere-pro
capability:
  exposes:
    - type: mcp
      namespace: post-production
      port: 8080
      tools:
        - name: get-edit-project-status
          description: "Look up the status of a post-production editing project."
          inputParameters:
            - name: project_id
              in: body
              type: string
              description: "The post-production project identifier."
          call: "postprod-api.get-project"
          with:
            project_id: "{{project_id}}"
          outputParameters:
            - name: edit_progress
              type: number
              mapping: "$.data.edit_progress_pct"
            - name: review_status
              type: string
              mapping: "$.data.review_status"
            - name: estimated_delivery
              type: string
              mapping: "$.data.estimated_delivery_date"
  consumes:
    - type: http
      namespace: postprod-api
      baseUri: "https://api.paramount.com/postproduction/v1"
      authentication:
        type: bearer
        token: "$secrets.paramount_postprod_token"
      resources:
        - name: projects
          path: "/projects/{{project_id}}"
          inputParameters:
            - name: project_id
              in: path
          operations:
            - name: get-project
              method: GET

Advertising Audience Segment Builder ▼

advertising streaming snowflake salesforce

Queries first-party streaming data in Snowflake to build audience segments, syncs them to the ad server for targeting, and logs the segment in Salesforce for advertiser proposals.

naftiko: "0.5"
info:
  label: "Advertising Audience Segment Builder"
  description: "Queries first-party streaming data in Snowflake to build audience segments, syncs them to the ad server for targeting, and logs the segment in Salesforce for advertiser proposals."
  tags:
    - advertising
    - streaming
    - snowflake
    - salesforce
capability:
  exposes:
    - type: mcp
      namespace: audience-ops
      port: 8080
      tools:
        - name: build-audience-segment
          description: "Build an advertising audience segment from streaming data."
          inputParameters:
            - name: segment_name
              in: body
              type: string
              description: "Name for the new audience segment."
            - name: genre_affinity
              in: body
              type: string
              description: "Genre affinity filter."
            - name: min_watch_hours
              in: body
              type: number
              description: "Minimum watch hours threshold."
          steps:
            - name: query-audience
              type: call
              call: "snowflake.execute-query"
              with:
                query: "CALL build_audience_segment('{{segment_name}}', '{{genre_affinity}}', {{min_watch_hours}})"
            - name: sync-to-adserver
              type: call
              call: "ad-server.create-segment"
              with:
                segment_name: "{{segment_name}}"
                user_ids: "{{query-audience.user_ids}}"
            - name: log-in-salesforce
              type: call
              call: "salesforce.create-record"
              with:
                object: "Audience_Segment__c"
                data:
                  name: "{{segment_name}}"
                  size: "{{query-audience.segment_size}}"
                  ad_server_id: "{{sync-to-adserver.segment_id}}"
  consumes:
    - type: http
      namespace: snowflake
      baseUri: "https://paramount.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: ad-server
      baseUri: "https://api.paramount.com/adserver/v1"
      authentication:
        type: bearer
        token: "$secrets.paramount_adserver_token"
      resources:
        - name: segments
          path: "/segments"
          operations:
            - name: create-segment
              method: POST
    - type: http
      namespace: salesforce
      baseUri: "https://paramount.my.salesforce.com/services/data/v58.0"
      authentication:
        type: bearer
        token: "$secrets.salesforce_token"
      resources:
        - name: records
          path: "/sobjects/{{object}}"
          inputParameters:
            - name: object
              in: path
          operations:
            - name: create-record
              method: POST

Affiliate Partner Performance Report ▼

marketing advertising snowflake tableau

Pulls affiliate sign-up and conversion data from the affiliate platform, joins with subscription revenue in Snowflake, and updates the partnerships dashboard in Tableau.

naftiko: "0.5"
info:
  label: "Affiliate Partner Performance Report"
  description: "Pulls affiliate sign-up and conversion data from the affiliate platform, joins with subscription revenue in Snowflake, and updates the partnerships dashboard in Tableau."
  tags:
    - marketing
    - advertising
    - snowflake
    - tableau
capability:
  exposes:
    - type: mcp
      namespace: affiliate-ops
      port: 8080
      tools:
        - name: report-affiliate-performance
          description: "Generate an affiliate partner performance report."
          inputParameters:
            - name: partner_id
              in: body
              type: string
              description: "The affiliate partner identifier."
            - name: date_start
              in: body
              type: string
              description: "Report start date."
            - name: date_end
              in: body
              type: string
              description: "Report end date."
          steps:
            - name: get-affiliate-data
              type: call
              call: "affiliate-platform.get-partner-stats"
              with:
                partner_id: "{{partner_id}}"
                start_date: "{{date_start}}"
                end_date: "{{date_end}}"
            - name: get-revenue-data
              type: call
              call: "snowflake.execute-query"
              with:
                query: "SELECT SUM(revenue) as total_revenue FROM affiliate_subscriptions WHERE partner_id='{{partner_id}}'"
            - name: refresh-dashboard
              type: call
              call: "tableau.refresh-extract"
              with:
                datasource_id: "affiliate_performance_ds"
  consumes:
    - type: http
      namespace: affiliate-platform
      baseUri: "https://api.paramount.com/affiliates/v1"
      authentication:
        type: bearer
        token: "$secrets.paramount_affiliate_token"
      resources:
        - name: partners
          path: "/partners/{{partner_id}}/stats"
          inputParameters:
            - name: partner_id
              in: path
          operations:
            - name: get-partner-stats
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://paramount.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: tableau
      baseUri: "https://tableau.paramount.com/api/3.21"
      authentication:
        type: bearer
        token: "$secrets.tableau_token"
      resources:
        - name: datasources
          path: "/sites/paramount/datasources/{{datasource_id}}/refresh"
          inputParameters:
            - name: datasource_id
              in: path
          operations:
            - name: refresh-extract
              method: POST

Azure DevOps Pipeline Status ▼

development azure-devops

Queries Azure DevOps for the latest pipeline build status. Returns build number, result, and source branch.

naftiko: "0.5"
info:
  label: "Azure DevOps Pipeline Status"
  description: "Queries Azure DevOps for the latest pipeline build status. Returns build number, result, and source branch."
  tags:
    - development
    - azure-devops
capability:
  exposes:
    - type: mcp
      namespace: cicd-ops
      port: 8080
      tools:
        - name: get-pipeline-status
          description: "Look up the latest Azure DevOps pipeline build status."
          inputParameters:
            - name: pipeline_id
              in: body
              type: string
              description: "The pipeline definition identifier."
          call: "azdo.get-latest-build"
          with:
            pipeline_id: "{{pipeline_id}}"
          outputParameters:
            - name: build_number
              type: string
              mapping: "$.value[0].buildNumber"
            - name: result
              type: string
              mapping: "$.value[0].result"
            - name: source_branch
              type: string
              mapping: "$.value[0].sourceBranch"
  consumes:
    - type: http
      namespace: azdo
      baseUri: "https://dev.azure.com/paramount/streaming/_apis/build"
      authentication:
        type: basic
        username: ""
        password: "$secrets.azdo_pat"
      resources:
        - name: builds
          path: "/builds?definitions={{pipeline_id}}&$top=1&api-version=7.0"
          inputParameters:
            - name: pipeline_id
              in: query
          operations:
            - name: get-latest-build
              method: GET

Box File Upload and Share ▼

document-management box

Uploads a document to Box and creates a shared link for distribution.

naftiko: "0.5"
info:
  label: "Box File Upload and Share"
  description: "Uploads a document to Box and creates a shared link for distribution."
  tags:
    - document-management
    - box
capability:
  exposes:
    - type: mcp
      namespace: file-sharing
      port: 8080
      tools:
        - name: upload-and-share-file
          description: "Upload a file to Box and create a shared link."
          inputParameters:
            - name: folder_id
              in: body
              type: string
              description: "The Box folder ID."
            - name: file_name
              in: body
              type: string
              description: "The file name."
          steps:
            - name: upload-file
              type: call
              call: "box.upload-file"
              with:
                folder_id: "{{folder_id}}"
                file_name: "{{file_name}}"
            - name: create-link
              type: call
              call: "box.create-shared-link"
              with:
                file_id: "{{upload-file.id}}"
  consumes:
    - type: http
      namespace: box
      baseUri: "https://api.box.com/2.0"
      authentication:
        type: bearer
        token: "$secrets.box_token"
      resources:
        - name: files
          path: "/files/content"
          operations:
            - name: upload-file
              method: POST
        - name: shared-links
          path: "/files/{{file_id}}?fields=shared_link"
          inputParameters:
            - name: file_id
              in: path
          operations:
            - name: create-shared-link
              method: PUT

Confluence Knowledge Base Search ▼

operations knowledge-management confluence

Searches Confluence for knowledge base articles matching a query string. Returns titles, URLs, and last updated dates.

naftiko: "0.5"
info:
  label: "Confluence Knowledge Base Search"
  description: "Searches Confluence for knowledge base articles matching a query string. Returns titles, URLs, and last updated dates."
  tags:
    - operations
    - knowledge-management
    - confluence
capability:
  exposes:
    - type: mcp
      namespace: knowledge-base
      port: 8080
      tools:
        - name: search-kb
          description: "Search Confluence for knowledge base articles."
          inputParameters:
            - name: query
              in: body
              type: string
              description: "The search query."
          call: "confluence.search"
          with:
            query: "{{query}}"
          outputParameters:
            - name: results
              type: array
              mapping: "$.results"
            - name: total_count
              type: integer
              mapping: "$.totalSize"
  consumes:
    - type: http
      namespace: confluence
      baseUri: "https://paramount.atlassian.net/wiki/rest/api"
      authentication:
        type: basic
        username: "$secrets.confluence_user"
        password: "$secrets.confluence_api_token"
      resources:
        - name: search
          path: "/search?cql=text~'{{query}}'"
          inputParameters:
            - name: query
              in: query
          operations:
            - name: search
              method: GET

Content Availability Window Lookup ▼

licensing content

Checks content availability windows by territory and platform. Returns start date, end date, and licensed platforms.

naftiko: "0.5"
info:
  label: "Content Availability Window Lookup"
  description: "Checks content availability windows by territory and platform. Returns start date, end date, and licensed platforms."
  tags:
    - licensing
    - content
capability:
  exposes:
    - type: mcp
      namespace: content-windows
      port: 8080
      tools:
        - name: get-availability-window
          description: "Look up content availability windows by title and territory."
          inputParameters:
            - name: title_id
              in: body
              type: string
              description: "The content title ID."
            - name: territory
              in: body
              type: string
              description: "The territory code."
          call: "cms.get-window"
          with:
            title_id: "{{title_id}}"
            territory: "{{territory}}"
          outputParameters:
            - name: start_date
              type: string
              mapping: "$.data.window_start"
            - name: end_date
              type: string
              mapping: "$.data.window_end"
            - name: platforms
              type: array
              mapping: "$.data.licensed_platforms"
  consumes:
    - type: http
      namespace: cms
      baseUri: "https://api.paramount.com/content/v2"
      authentication:
        type: bearer
        token: "$secrets.paramount_cms_token"
      resources:
        - name: windows
          path: "/titles/{{title_id}}/windows/{{territory}}"
          inputParameters:
            - name: title_id
              in: path
            - name: territory
              in: path
          operations:
            - name: get-window
              method: GET

Content Encoding Pipeline Trigger ▼

content streaming encoding

Triggers the media encoding pipeline for a new content asset, monitors progress via the encoding service, and updates the CMS with delivery URLs when complete.

naftiko: "0.5"
info:
  label: "Content Encoding Pipeline Trigger"
  description: "Triggers the media encoding pipeline for a new content asset, monitors progress via the encoding service, and updates the CMS with delivery URLs when complete."
  tags:
    - content
    - streaming
    - encoding
capability:
  exposes:
    - type: mcp
      namespace: encoding-ops
      port: 8080
      tools:
        - name: trigger-encoding
          description: "Trigger content encoding and update CMS with delivery URLs upon completion."
          inputParameters:
            - name: asset_id
              in: body
              type: string
              description: "The source media asset identifier."
            - name: output_profiles
              in: body
              type: array
              description: "List of encoding profiles (4K, HD, SD, mobile)."
          steps:
            - name: start-encoding
              type: call
              call: "encoding-service.submit-job"
              with:
                asset_id: "{{asset_id}}"
                profiles: "{{output_profiles}}"
            - name: check-status
              type: call
              call: "encoding-service.get-job-status"
              with:
                job_id: "{{start-encoding.job_id}}"
            - name: update-cms
              type: call
              call: "cms.update-delivery-urls"
              with:
                asset_id: "{{asset_id}}"
                urls: "{{check-status.output_urls}}"
  consumes:
    - type: http
      namespace: encoding-service
      baseUri: "https://api.paramount.com/encoding/v1"
      authentication:
        type: bearer
        token: "$secrets.paramount_encoding_token"
      resources:
        - name: jobs
          path: "/jobs"
          operations:
            - name: submit-job
              method: POST
        - name: job-status
          path: "/jobs/{{job_id}}"
          inputParameters:
            - name: job_id
              in: path
          operations:
            - name: get-job-status
              method: GET
    - type: http
      namespace: cms
      baseUri: "https://api.paramount.com/content/v2"
      authentication:
        type: bearer
        token: "$secrets.paramount_cms_token"
      resources:
        - name: titles
          path: "/titles/{{asset_id}}/delivery"
          inputParameters:
            - name: asset_id
              in: path
          operations:
            - name: update-delivery-urls
              method: PUT

Content Licensing Agreement Tracker ▼

licensing salesforce snowflake

Retrieves licensing deal details from Salesforce, cross-references content availability windows, and stores licensing reports in Snowflake for the business affairs team.

naftiko: "0.5"
info:
  label: "Content Licensing Agreement Tracker"
  description: "Retrieves licensing deal details from Salesforce, cross-references content availability windows, and stores licensing reports in Snowflake for the business affairs team."
  tags:
    - licensing
    - salesforce
    - snowflake
capability:
  exposes:
    - type: mcp
      namespace: licensing-ops
      port: 8080
      tools:
        - name: track-licensing-agreement
          description: "Track a content licensing agreement and generate availability reports."
          inputParameters:
            - name: deal_id
              in: body
              type: string
              description: "The Salesforce licensing deal identifier."
          steps:
            - name: get-deal
              type: call
              call: "salesforce.get-deal"
              with:
                deal_id: "{{deal_id}}"
            - name: get-content-windows
              type: call
              call: "cms.get-licensing-windows"
              with:
                deal_id: "{{deal_id}}"
            - name: store-report
              type: call
              call: "snowflake.insert-record"
              with:
                table: "licensing_reports"
                data:
                  deal_id: "{{deal_id}}"
                  partner: "{{get-deal.partner_name}}"
                  territories: "{{get-deal.territories}}"
                  window_start: "{{get-content-windows.start_date}}"
                  window_end: "{{get-content-windows.end_date}}"
  consumes:
    - type: http
      namespace: salesforce
      baseUri: "https://paramount.my.salesforce.com/services/data/v58.0"
      authentication:
        type: bearer
        token: "$secrets.salesforce_token"
      resources:
        - name: deals
          path: "/sobjects/Licensing_Deal__c/{{deal_id}}"
          inputParameters:
            - name: deal_id
              in: path
          operations:
            - name: get-deal
              method: GET
    - type: http
      namespace: cms
      baseUri: "https://api.paramount.com/content/v2"
      authentication:
        type: bearer
        token: "$secrets.paramount_cms_token"
      resources:
        - name: licensing
          path: "/deals/{{deal_id}}/windows"
          inputParameters:
            - name: deal_id
              in: path
          operations:
            - name: get-licensing-windows
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://paramount.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: insert-record
              method: POST

Content Metadata Lookup ▼

content catalog

Retrieves content metadata from the CMS by title ID. Returns title, genre, rating, runtime, and cast information.

naftiko: "0.5"
info:
  label: "Content Metadata Lookup"
  description: "Retrieves content metadata from the CMS by title ID. Returns title, genre, rating, runtime, and cast information."
  tags:
    - content
    - catalog
capability:
  exposes:
    - type: mcp
      namespace: content-catalog
      port: 8080
      tools:
        - name: get-content-metadata
          description: "Look up content metadata by title identifier."
          inputParameters:
            - name: title_id
              in: body
              type: string
              description: "The content title identifier."
          call: "cms.get-title"
          with:
            title_id: "{{title_id}}"
          outputParameters:
            - name: title
              type: string
              mapping: "$.data.title"
            - name: genre
              type: array
              mapping: "$.data.genres"
            - name: rating
              type: string
              mapping: "$.data.rating"
            - name: runtime
              type: integer
              mapping: "$.data.runtime_minutes"
  consumes:
    - type: http
      namespace: cms
      baseUri: "https://api.paramount.com/content/v2"
      authentication:
        type: bearer
        token: "$secrets.paramount_cms_token"
      resources:
        - name: titles
          path: "/titles/{{title_id}}"
          inputParameters:
            - name: title_id
              in: path
          operations:
            - name: get-title
              method: GET

Content Recommendation Engine Sync ▼

streaming content snowflake

Pulls user viewing history from the streaming platform, feeds it to the recommendation model in Snowflake, and updates personalized content rails in the CMS.

naftiko: "0.5"
info:
  label: "Content Recommendation Engine Sync"
  description: "Pulls user viewing history from the streaming platform, feeds it to the recommendation model in Snowflake, and updates personalized content rails in the CMS."
  tags:
    - streaming
    - content
    - snowflake
capability:
  exposes:
    - type: mcp
      namespace: recommendations
      port: 8080
      tools:
        - name: sync-recommendations
          description: "Update content recommendations based on viewing patterns."
          inputParameters:
            - name: user_segment
              in: body
              type: string
              description: "The user segment identifier."
            - name: model_version
              in: body
              type: string
              description: "The recommendation model version to use."
          steps:
            - name: get-viewing-data
              type: call
              call: "streaming-platform.get-viewing-history"
              with:
                segment: "{{user_segment}}"
            - name: run-model
              type: call
              call: "snowflake.execute-query"
              with:
                query: "CALL generate_recommendations('{{user_segment}}', '{{model_version}}')"
            - name: update-content-rails
              type: call
              call: "cms.update-recommendation-rails"
              with:
                segment: "{{user_segment}}"
                recommendations: "{{run-model.titles}}"
  consumes:
    - type: http
      namespace: streaming-platform
      baseUri: "https://api.paramount.com/streaming/v1"
      authentication:
        type: bearer
        token: "$secrets.paramount_streaming_token"
      resources:
        - name: viewing
          path: "/subscribers/viewing-history"
          operations:
            - name: get-viewing-history
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://paramount.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: cms
      baseUri: "https://api.paramount.com/content/v2"
      authentication:
        type: bearer
        token: "$secrets.paramount_cms_token"
      resources:
        - name: recommendations
          path: "/rails/recommendations"
          operations:
            - name: update-recommendation-rails
              method: PUT

Content Release Orchestrator ▼

content streaming microsoft-teams

When a new title is approved for release, creates the catalog entry in the content management system, schedules distribution via the streaming platform, and notifies marketing in Microsoft Teams.

naftiko: "0.5"
info:
  label: "Content Release Orchestrator"
  description: "When a new title is approved for release, creates the catalog entry in the content management system, schedules distribution via the streaming platform, and notifies marketing in Microsoft Teams."
  tags:
    - content
    - streaming
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: content-release
      port: 8080
      tools:
        - name: orchestrate-content-release
          description: "Orchestrate the release of a new title across content catalog, streaming platform, and marketing notification."
          inputParameters:
            - name: title_id
              in: body
              type: string
              description: "The content title identifier."
            - name: release_date
              in: body
              type: string
              description: "The planned release date in YYYY-MM-DD format."
            - name: content_type
              in: body
              type: string
              description: "Type of content (movie, series, episode, special)."
          steps:
            - name: create-catalog-entry
              type: call
              call: "cms.create-title"
              with:
                title_id: "{{title_id}}"
                release_date: "{{release_date}}"
                content_type: "{{content_type}}"
            - name: schedule-distribution
              type: call
              call: "streaming-platform.schedule-release"
              with:
                title_id: "{{title_id}}"
                release_date: "{{release_date}}"
                regions: "all"
            - name: notify-marketing
              type: call
              call: "msteams.send-message"
              with:
                channel_id: "content-releases"
                text: "New release scheduled: {{title_id}} ({{content_type}}) on {{release_date}}. Distribution: {{schedule-distribution.status}}"
  consumes:
    - type: http
      namespace: cms
      baseUri: "https://api.paramount.com/content/v2"
      authentication:
        type: bearer
        token: "$secrets.paramount_cms_token"
      resources:
        - name: titles
          path: "/titles"
          operations:
            - name: create-title
              method: POST
    - type: http
      namespace: streaming-platform
      baseUri: "https://api.paramount.com/streaming/v1"
      authentication:
        type: bearer
        token: "$secrets.paramount_streaming_token"
      resources:
        - name: releases
          path: "/releases/schedule"
          operations:
            - name: schedule-release
              method: POST
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/{{channel_id}}/channels/general/messages"
          inputParameters:
            - name: channel_id
              in: path
          operations:
            - name: send-message
              method: POST

Content Rights Expiry Monitor ▼

licensing salesforce snowflake microsoft-teams

Scans Salesforce for licensing deals with upcoming expiry dates, generates a renewal report in Snowflake, and sends alerts to business affairs via Microsoft Teams.

naftiko: "0.5"
info:
  label: "Content Rights Expiry Monitor"
  description: "Scans Salesforce for licensing deals with upcoming expiry dates, generates a renewal report in Snowflake, and sends alerts to business affairs via Microsoft Teams."
  tags:
    - licensing
    - salesforce
    - snowflake
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: rights-management
      port: 8080
      tools:
        - name: monitor-rights-expiry
          description: "Monitor content rights approaching expiry and alert business affairs."
          inputParameters:
            - name: days_ahead
              in: body
              type: integer
              description: "Number of days ahead to check for expiring rights."
          steps:
            - name: get-expiring-deals
              type: call
              call: "salesforce.query-expiring-deals"
              with:
                days_ahead: "{{days_ahead}}"
            - name: generate-report
              type: call
              call: "snowflake.execute-query"
              with:
                query: "CALL generate_expiry_report({{days_ahead}})"
            - name: notify-team
              type: call
              call: "msteams.send-message"
              with:
                channel_id: "business-affairs"
                text: "Rights expiry alert: {{get-expiring-deals.count}} deals expiring within {{days_ahead}} days. Review report in Snowflake."
  consumes:
    - type: http
      namespace: salesforce
      baseUri: "https://paramount.my.salesforce.com/services/data/v58.0"
      authentication:
        type: bearer
        token: "$secrets.salesforce_token"
      resources:
        - name: deals
          path: "/query?q=SELECT+Id,Name,Term_End_Date__c+FROM+Licensing_Deal__c+WHERE+Term_End_Date__c<=NEXT_N_DAYS:{{days_ahead}}"
          inputParameters:
            - name: days_ahead
              in: query
          operations:
            - name: query-expiring-deals
              method: GET
    - type: http
      namespace: snowflake
      baseUri: "https://paramount.snowflakecomputing.com/api/v2"
      authentication:
        type: bearer
        token: "$secrets.snowflake_token"
      resources:
        - name: statements
          path: "/statements"
          operations:
            - name: execute-query
              method: POST
    - type: http
      namespace: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/{{channel_id}}/channels/general/messages"
          inputParameters:
            - name: channel_id
              in: path
          operations:
            - name: send-message
              method: POST

Content Scheduling Calendar Sync ▼

content scheduling google-workspace microsoft-outlook

Syncs the content release calendar from the CMS to Google Calendar and Microsoft Outlook for cross-team visibility.

naftiko: "0.5"
info:
  label: "Content Scheduling Calendar Sync"
  description: "Syncs the content release calendar from the CMS to Google Calendar and Microsoft Outlook for cross-team visibility."
  tags:
    - content
    - scheduling
    - google-workspace
    - microsoft-outlook
capability:
  exposes:
    - type: mcp
      namespace: content-calendar
      port: 8080
      tools:
        - name: sync-release-calendar
          description: "Sync content release dates to Google Calendar and Outlook."
          inputParameters:
            - name: month
              in: body
              type: string
              description: "The month to sync (YYYY-MM format)."
          steps:
            - name: get-releases
              type: call
              call: "cms.get-release-calendar"
              with:
                month: "{{month}}"
            - name: sync-google-cal
              type: call
              call: "google-calendar.create-events"
              with:
                calendar_id: "content-releases"
                events: "{{get-releases.titles}}"
            - name: sync-outlook
              type: call
              call: "outlook.create-events"
              with:
                calendar_id: "content-releases"
                events: "{{get-releases.titles}}"
  consumes:
    - type: http
      namespace: cms
      baseUri: "https://api.paramount.com/content/v2"
      authentication:
        type: bearer
        token: "$secrets.paramount_cms_token"
      resources:
        - name: calendar
          path: "/releases/calendar?month={{month}}"
          inputParameters:
            - name: month
              in: query
          operations:
            - name: get-release-calendar
              method: GET
    - type: http
      namespace: google-calendar
      baseUri: "https://www.googleapis.com/calendar/v3"
      authentication:
        type: bearer
        token: "$secrets.google_calendar_token"
      resources:
        - name: events
          path: "/calendars/{{calendar_id}}/events"
          inputParameters:
            - name: calendar_id
              in: path
          operations:
            - name: create-events
              method: POST
    - type: http
      namespace: outlook
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: events
          path: "/me/calendars/{{calendar_id}}/events"
          inputParameters:
            - name: calendar_id
              in: path
          operations:
            - name: create-events
              method: POST

Datadog Streaming Infrastructure Monitor ▼

streaming operations datadog

Retrieves Datadog monitor status for streaming infrastructure. Returns monitor name, overall state, and last triggered timestamp.

naftiko: "0.5"
info:
  label: "Datadog Streaming Infrastructure Monitor"
  description: "Retrieves Datadog monitor status for streaming infrastructure. Returns monitor name, overall state, and last triggered timestamp."
  tags:
    - streaming
    - operations
    - datadog
capability:
  exposes:
    - type: mcp
      namespace: infra-monitoring
      port: 8080
      tools:
        - name: get-monitor-status
          description: "Check Datadog monitor status for streaming infrastructure."
          inputParameters:
            - name: monitor_id
              in: body
              type: string
              description: "The Datadog monitor identifier."
          call: "datadog.get-monitor"
          with:
            monitor_id: "{{monitor_id}}"
          outputParameters:
            - name: name
              type: string
              mapping: "$.name"
            - name: status
              type: string
              mapping: "$.overall_state"
            - name: last_triggered
              type: string
              mapping: "$.state.last_triggered_ts"
  consumes:
    - type: http
      namespace: datadog
      baseUri: "https://api.datadoghq.com/api/v1"
      authentication:
        type: apiKey
        key: "$secrets.datadog_api_key"
        header: "DD-API-KEY"
      resources:
        - name: monitors
          path: "/monitor/{{monitor_id}}"
          inputParameters:
            - name: monitor_id
              in: path
          operations:
            - name: get-monitor
              method: GET

Digital Asset Retrieval ▼

content digital-assets

Retrieves a digital asset (image, video, poster) from Paramount's DAM system by asset ID. Returns the asset URL, format, resolution, and usage rights.

naftiko: "0.5"
info:
  label: "Digital Asset Retrieval"
  description: "Retrieves a digital asset (image, video, poster) from Paramount's DAM system by asset ID. Returns the asset URL, format, resolution, and usage rights."
  tags:
    - content
    - digital-assets
capability:
  exposes:
    - type: mcp
      namespace: asset-management
      port: 8080
      tools:
        - name: get-digital-asset
          description: "Retrieve a digital asset and its metadata from the DAM."
          inputParameters:
            - name: asset_id
              in: body
              type: string
              description: "The digital asset identifier."
          call: "dam.get-asset"
          with:
            asset_id: "{{asset_id}}"
          outputParameters:
            - name: url
              type: string
              mapping: "$.data.download_url"
            - name: format
              type: string
              mapping: "$.data.format"
            - name: resolution
              type: string
              mapping: "$.data.resolution"
            - name: rights
              type: object
              mapping: "$.data.usage_rights"
  consumes:
    - type: http
      namespace: dam
      baseUri: "https://api.paramount.com/dam/v1"
      authentication:
        type: bearer
        token: "$secrets.paramount_dam_token"
      resources:
        - name: assets
          path: "/assets/{{asset_id}}"
          inputParameters:
            - name: asset_id
              in: path
          operations:
            - name: get-asset
              method: GET

Employee Onboarding Orchestrator ▼

hr onboarding workday servicenow sharepoint slack

On new hire creation in Workday, opens a ServiceNow onboarding ticket, provisions a SharePoint folder, and sends a Slack welcome message.

naftiko: "0.5"
info:
  label: "Employee Onboarding Orchestrator"
  description: "On new hire creation in Workday, opens a ServiceNow onboarding ticket, provisions a SharePoint folder, and sends a Slack welcome message."
  tags:
    - hr
    - onboarding
    - workday
    - servicenow
    - sharepoint
    - slack
capability:
  exposes:
    - type: mcp
      namespace: hr-onboarding
      port: 8080
      tools:
        - name: trigger-onboarding
          description: "Orchestrate new hire onboarding across Workday, ServiceNow, SharePoint, and Slack."
          inputParameters:
            - name: workday_employee_id
              in: body
              type: string
              description: "The Workday worker ID."
            - name: start_date
              in: body
              type: string
              description: "The employee start date."
            - name: department
              in: body
              type: string
              description: "The department the new hire is joining."
          steps:
            - name: get-employee
              type: call
              call: "workday.get-worker"
              with:
                worker_id: "{{workday_employee_id}}"
            - name: open-ticket
              type: call
              call: "servicenow.create-incident"
              with:
                short_description: "New hire onboarding: {{get-employee.full_name}}"
                category: "hr_onboarding"
                description: "Onboarding for {{get-employee.full_name}} starting {{start_date}} in {{department}}."
            - name: provision-folder
              type: call
              call: "sharepoint.create-folder"
              with:
                site_id: "hr_onboarding"
                folder_path: "NewHires/{{get-employee.full_name}}_{{start_date}}"
            - name: send-welcome
              type: call
              call: "slack.post-message"
              with:
                channel: "new-hires"
                text: "Welcome to Paramount, {{get-employee.first_name}}! Onboarding ticket: {{open-ticket.number}}"
  consumes:
    - type: http
      namespace: workday
      baseUri: "https://wd2-impl-services1.workday.com/ccx/api/v1"
      authentication:
        type: bearer
        token: "$secrets.workday_token"
      resources:
        - name: workers
          path: "/workers/{{worker_id}}"
          inputParameters:
            - name: worker_id
              in: path
          operations:
            - name: get-worker
              method: GET
    - type: http
      namespace: servicenow
      baseUri: "https://paramount.service-now.com/api/now"
      authentication:
        type: basic
        username: "$secrets.servicenow_user"
        password: "$secrets.servicenow_password"
      resources:
        - name: incidents
          path: "/table/incident"
          operations:
            - name: create-incident
              method: POST
    - type: http
      namespace: sharepoint
      baseUri: "https://graph.microsoft.com/v1.0/sites"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: folders
          path: "/{{site_id}}/drive/root:/{{folder_path}}"
          inputParameters:
            - name: site_id
              in: path
            - name: folder_path
              in: path
          operations:
            - name: create-folder
              method: POST
    - type: http
      namespace: slack
      baseUri: "https://slack.com/api"
      authentication:
        type: bearer
        token: "$secrets.slack_bot_token"
      resources:
        - name: messages
          path: "/chat.postMessage"
          operations:
            - name: post-message
              method: POST

Google Ads Campaign Spend Lookup ▼

advertising google-ads

Retrieves Google Ads campaign spending data by campaign ID. Returns total spend, impressions, clicks, and CPC.

naftiko: "0.5"
info:
  label: "Google Ads Campaign Spend Lookup"
  description: "Retrieves Google Ads campaign spending data by campaign ID. Returns total spend, impressions, clicks, and CPC."
  tags:
    - advertising
    - google-ads
capability:
  exposes:
    - type: mcp
      namespace: ad-spending
      port: 8080
      tools:
        - name: get-campaign-spend
          description: "Look up Google Ads campaign spend metrics."
          inputParameters:
            - name: campaign_id
              in: body
              type: string
              description: "The Google Ads campaign identifier."
            - name: date
              in: body
              type: string
              description: "The reporting date."
          call: "google-ads.get-spend"
          with:
            campaign_id: "{{campaign_id}}"
            date: "{{date}}"
          outputParameters:
            - name: total_spend
              type: number
              mapping: "$.data.cost_micros"
            - name: impressions
              type: integer
              mapping: "$.data.impressions"
            - name: clicks
              type: integer
              mapping: "$.data.clicks"
  consumes:
    - type: http
      namespace: google-ads
      baseUri: "https://googleads.googleapis.com/v14"
      authentication:
        type: bearer
        token: "$secrets.google_ads_token"
      resources:
        - name: campaigns
          path: "/customers/paramount/campaigns/{{campaign_id}}/metrics"
          inputParameters:
            - name: campaign_id
              in: path
          operations:
            - name: get-spend
              method: GET

Google Analytics Web Traffic Report ▼

marketing analytics google-analytics

Retrieves Paramount+ website traffic metrics from Google Analytics. Returns sessions, page views, average session duration, and top landing pages.

naftiko: "0.5"
info:
  label: "Google Analytics Web Traffic Report"
  description: "Retrieves Paramount+ website traffic metrics from Google Analytics. Returns sessions, page views, average session duration, and top landing pages."
  tags:
    - marketing
    - analytics
    - google-analytics
capability:
  exposes:
    - type: mcp
      namespace: web-analytics
      port: 8080
      tools:
        - name: get-web-traffic
          description: "Get Paramount+ web traffic metrics from Google Analytics."
          inputParameters:
            - name: start_date
              in: body
              type: string
              description: "Report start date."
            - name: end_date
              in: body
              type: string
              description: "Report end date."
          call: "google-analytics.run-report"
          with:
            start_date: "{{start_date}}"
            end_date: "{{end_date}}"
          outputParameters:
            - name: sessions
              type: integer
              mapping: "$.rows[0].metricValues[0].value"
            - name: page_views
              type: integer
              mapping: "$.rows[0].metricValues[1].value"
            - name: avg_session_duration
              type: number
              mapping: "$.rows[0].metricValues[2].value"
  consumes:
    - type: http
      namespace: google-analytics
      baseUri: "https://analyticsdata.googleapis.com/v1beta"
      authentication:
        type: bearer
        token: "$secrets.google_analytics_token"
      resources:
        - name: reports
          path: "/properties/paramount/runReport"
          operations:
            - name: run-report
              method: POST

Google Tag Manager Container Lookup ▼

marketing google-tag-manager

Retrieves tag configuration from Google Tag Manager for the Paramount+ website.

naftiko: "0.5"
info:
  label: "Google Tag Manager Container Lookup"
  description: "Retrieves tag configuration from Google Tag Manager for the Paramount+ website."
  tags:
    - marketing
    - google-tag-manager
capability:
  exposes:
    - type: mcp
      namespace: gtm-ops
      port: 8080
      tools:
        - name: get-gtm-tag
          description: "Look up a GTM tag configuration."
          inputParameters:
            - name: tag_id
              in: body
              type: string
              description: "The GTM tag ID."
          call: "gtm.get-tag"
          with:
            tag_id: "{{tag_id}}"
          outputParameters:
            - name: tag_name
              type: string
              mapping: "$.tag.name"
            - name: tag_type
              type: string
              mapping: "$.tag.type"
  consumes:
    - type: http
      namespace: gtm
      baseUri: "https://www.googleapis.com/tagmanager/v2"
      authentication:
        type: bearer
        token: "$secrets.google_tagmanager_token"
      resources:
        - name: tags
          path: "/accounts/paramount/containers/web/workspaces/default/tags/{{tag_id}}"
          inputParameters:
            - name: tag_id
              in: path
          operations:
            - name: get-tag
              method: GET

HubSpot Marketing Lead Sync ▼

marketing hubspot salesforce

Syncs marketing qualified leads from HubSpot to Salesforce for the advertising sales team.

naftiko: "0.5"
info:
  label: "HubSpot Marketing Lead Sync"
  description: "Syncs marketing qualified leads from HubSpot to Salesforce for the advertising sales team."
  tags:
    - marketing
    - hubspot
    - salesforce
capability:
  exposes:
    - type: mcp
      namespace: lead-sync
      port: 8080
      tools:
        - name: sync-hubspot-lead
          description: "Sync a HubSpot marketing lead to Salesforce."
          inputParameters:
            - name: contact_id
              in: body
              type: string
              description: "The HubSpot contact ID."
          steps:
            - name: get-contact
              type: call
              call: "hubspot.get-contact"
              with:
                contact_id: "{{contact_id}}"
            - name: create-lead
              type: call
              call: "salesforce.create-lead"
              with:
                first_name: "{{get-contact.firstname}}"
                last_name: "{{get-contact.lastname}}"
                email: "{{get-contact.email}}"
                company: "{{get-contact.company}}"
  consumes:
    - type: http
      namespace: hubspot
      baseUri: "https://api.hubapi.com/crm/v3"
      authentication:
        type: bearer
        token: "$secrets.hubspot_token"
      resources:
        - name: contacts
          path: "/objects/contacts/{{contact_id}}"
          inputParameters:
            - name: contact_id
              in: path
          operations:
            - name: get-contact
              method: GET
    - type: http
      namespace: salesforce
      baseUri: "https://paramount.my.salesforce.com/services/data/v58.0"
      authentication:
        type: bearer
        token: "$secrets.salesforce_token"
      resources:
        - name: leads
          path: "/sobjects/Lead"
          operations:
            - name: create-lead
              method: POST

Jira Production Issue Tracker ▼

content production jira confluence slack

Creates a Jira issue for production workflow blockers, links related content in Confluence, and notifies the production team via Slack.

naftiko: "0.5"
info:
  label: "Jira Production Issue Tracker"
  description: "Creates a Jira issue for production workflow blockers, links related content in Confluence, and notifies the production team via Slack."
  tags:
    - content
    - production
    - jira
    - confluence
    - slack
capability:
  exposes:
    - type: mcp
      namespace: production-tracking
      port: 8080
      tools:
        - name: create-production-issue
          description: "Create a production issue in Jira with Confluence links and Slack notification."
          inputParameters:
            - name: production_id
              in: body
              type: string
              description: "The production identifier."
            - name: issue_summary
              in: body
              type: string
              description: "Summary of the production issue."
            - name: priority
              in: body
              type: string
              description: "Issue priority (Highest, High, Medium, Low)."
          steps:
            - name: create-jira-issue
              type: call
              call: "jira.create-issue"
              with:
                project: "PROD"
                summary: "{{issue_summary}}"
                priority: "{{priority}}"
                labels: ["production-{{production_id}}"]
            - name: link-wiki
              type: call
              call: "confluence.create-page-link"
              with:
                space: "PROD"
                page_title: "Production {{production_id}} - Issues"
                link_url: "{{create-jira-issue.self}}"
            - name: notify-team
              type: call
              call: "slack.post-message"
              with:
                channel: "production-issues"
                text: "New issue for Production {{production_id}}: {{issue_summary}} ({{priority}}). Jira: {{create-jira-issue.key}}"
  consumes:
    - type: http
      namespace: jira
      baseUri: "https://paramount.atlassian.net/rest/api/3"
      authentication:
        type: basic
        username: "$secrets.jira_user"
        password: "$secrets.jira_api_token"
      resources:
        - name: issues
          path: "/issue"
          operations:
            - name: create-issue
              method: POST
    - type: http
      namespace: confluence
      baseUri: "https://paramount.atlassian.net/wiki/rest/api"
      authentication:
        type: basic
        username: "$secrets.confluence_user"
        password: "$secrets.confluence_api_token"
      resources:
        - name: pages
          path: "/content"
          operations:
            - name: create-page-link
              method: POST
    - type: http
      namespace: slack
      baseUri: "https://slack.com/api"
      authentication:
        type: bearer
        token: "$secrets.slack_bot_token"
      resources:
        - name: messages
          path: "/chat.postMessage"
          operations:
            - name: post-message
              method: POST

Jira Sprint Status Reporter ▼

development jira slack

Pulls sprint progress from Jira and posts a daily summary to the engineering Slack channel.

naftiko: "0.5"
info:
  label: "Jira Sprint Status Reporter"
  description: "Pulls sprint progress from Jira and posts a daily summary to the engineering Slack channel."
  tags:
    - development
    - jira
    - slack
capability:
  exposes:
    - type: mcp
      namespace: dev-reporting
      port: 8080
      tools:
        - name: report-sprint-status
          description: "Generate and post a Jira sprint status report to Slack."
          inputParameters:
            - name: board_id
              in: body
              type: string
              description: "The Jira board identifier."
          steps:
            - name: get-sprint
              type: call
              call: "jira.get-active-sprint"
              with:
                board_id: "{{board_id}}"
            - name: get-issues
              type: call
              call: "jira.get-sprint-issues"
              with:
                sprint_id: "{{get-sprint.id}}"
            - name: post-report
              type: call
              call: "slack.post-message"
              with:
                channel: "engineering"
                text: "Sprint {{get-sprint.name}}: {{get-issues.done_count}}/{{get-issues.total_count}} done. {{get-issues.in_progress_count}} in progress."
  consumes:
    - type: http
      namespace: jira
      baseUri: "https://paramount.atlassian.net/rest/agile/1.0"
      authentication:
        type: basic
        username: "$secrets.jira_user"
        password: "$secrets.jira_api_token"
      resources:
        - name: sprints
          path: "/board/{{board_id}}/sprint?state=active"
          inputParameters:
            - name: board_id
              in: path
          operations:
            - name: get-active-sprint
              method: GET
        - name: sprint-issues
          path: "/sprint/{{sprint_id}}/issue"
          inputParameters:
            - name: sprint_id
              in: path
          operations:
            - name: get-sprint-issues
              method: GET
    - type: http
      namespace: slack
      baseUri: "https://slack.com/api"
      authentication:
        type: bearer
        token: "$secrets.slack_bot_token"
      resources:
        - name: messages
          path: "/chat.postMessage"
          operations:
            - name: post-message
              method: POST

MailChimp Newsletter Subscriber Sync ▼

marketing mailchimp salesforce-marketing-cloud

Retrieves newsletter subscribers from MailChimp and syncs to Salesforce Marketing Cloud for unified audience management.

naftiko: "0.5"
info:
  label: "MailChimp Newsletter Subscriber Sync"
  description: "Retrieves newsletter subscribers from MailChimp and syncs to Salesforce Marketing Cloud for unified audience management."
  tags:
    - marketing
    - mailchimp
    - salesforce-marketing-cloud
capability:
  exposes:
    - type: mcp
      namespace: subscriber-sync
      port: 8080
      tools:
        - name: sync-mailchimp-subscribers
          description: "Sync MailChimp subscribers to SFMC."
          inputParameters:
            - name: list_id
              in: body
              type: string
              description: "The MailChimp list identifier."
          steps:
            - name: get-subscribers
              type: call
              call: "mailchimp.get-members"
              with:
                list_id: "{{list_id}}"
            - name: sync-to-sfmc
              type: call
              call: "sfmc.upsert-data-extension"
              with:
                data_extension: "mailchimp_subscribers"
                rows: "{{get-subscribers.members}}"
  consumes:
    - type: http
      namespace: mailchimp
      baseUri: "https://us1.api.mailchimp.com/3.0"
      authentication:
        type: basic
        username: "anystring"
        password: "$secrets.mailchimp_api_key"
      resources:
        - name: lists
          path: "/lists/{{list_id}}/members"
          inputParameters:
            - name: list_id
              in: path
          operations:
            - name: get-members
              method: GET
    - type: http
      namespace: sfmc
      baseUri: "https://paramount.rest.marketingcloudapis.com/data/v1"
      authentication:
        type: bearer
        token: "$secrets.sfmc_token"
      resources:
        - name: data-extensions
          path: "/customobjectdata/key/{{data_extension}}/rowset"
          inputParameters:
            - name: data_extension
              in: path
          operations:
            - name: upsert-data-extension
              method: POST

Paramount Workflow 1 ▼

media operations salesforce