Nestlé Capabilities

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

Sort

Expand

Adobe Analytics Brand Page Metrics ▼

marketing analytics adobe-analytics

Pulls page-level engagement metrics from Adobe Analytics for a Nestlé brand property, including page views, unique visitors, and average time on page.

naftiko: "0.5"
info:
  label: "Adobe Analytics Brand Page Metrics"
  description: "Pulls page-level engagement metrics from Adobe Analytics for a Nestlé brand property, including page views, unique visitors, and average time on page."
  tags:
    - marketing
    - analytics
    - adobe-analytics
capability:
  exposes:
    - type: mcp
      namespace: brand-analytics
      port: 8080
      tools:
        - name: get-page-metrics
          description: "Retrieve page-level engagement metrics from Adobe Analytics for a specified report suite and date range."
          inputParameters:
            - name: report_suite_id
              in: body
              type: string
              description: "The Adobe Analytics report suite ID for the brand property."
            - name: date_range
              in: body
              type: string
              description: "Date range in YYYY-MM-DD/YYYY-MM-DD format."
          call: "adobe.get-report"
          with:
            rsid: "{{report_suite_id}}"
            date_range: "{{date_range}}"
          outputParameters:
            - name: page_views
              type: string
              mapping: "$.rows[0].value"
            - name: unique_visitors
              type: string
              mapping: "$.rows[1].value"
            - name: avg_time_on_page
              type: string
              mapping: "$.rows[2].value"
  consumes:
    - type: http
      namespace: adobe
      baseUri: "https://analytics.adobe.io/api/nestle"
      authentication:
        type: bearer
        token: "$secrets.adobe_analytics_token"
      inputParameters:
        - name: x-api-key
          in: header
          value: "$secrets.adobe_api_key"
      resources:
        - name: reports
          path: "/reports"
          operations:
            - name: get-report
              method: POST

# ---------- 7. Datadog Factory System Health (simple) ----------

Allergen Label Compliance Checker ▼

quality food-safety sap informatica servicenow

Retrieves product recipe data from SAP, cross-references allergen declarations with the regulatory database in Informatica, and creates a ServiceNow compliance task if discrepancies are detected.

naftiko: "0.5"
info:
  label: "Allergen Label Compliance Checker"
  description: "Retrieves product recipe data from SAP, cross-references allergen declarations with the regulatory database in Informatica, and creates a ServiceNow compliance task if discrepancies are detected."
  tags:
    - quality
    - food-safety
    - sap
    - informatica
    - servicenow
capability:
  exposes:
    - type: mcp
      namespace: allergen-compliance
      port: 8080
      tools:
        - name: check-allergen-compliance
          description: "Given a material number, retrieve recipe allergens from SAP, validate against Informatica regulatory data, and flag issues in ServiceNow."
          inputParameters:
            - name: material_number
              in: body
              type: string
              description: "The SAP material number for the finished product."
            - name: target_market
              in: body
              type: string
              description: "The target market country code (ISO 3166)."
          steps:
            - name: get-recipe
              type: call
              call: "sap.get-recipe-allergens"
              with:
                material: "{{material_number}}"
            - name: get-regulations
              type: call
              call: "informatica.get-allergen-reqs"
              with:
                country: "{{target_market}}"
                allergens: "{{get-recipe.allergen_list}}"
            - name: create-compliance-task
              type: call
              call: "servicenow.create-task"
              with:
                short_description: "Allergen compliance review: {{material_number}} for {{target_market}}"
                description: "Material: {{material_number}}. Allergens declared: {{get-recipe.allergen_list}}. Target market: {{target_market}}. Regulatory requirements: {{get-regulations.required_declarations}}. Gaps: {{get-regulations.gaps}}."
                assigned_group: "Regulatory_Affairs"
                category: "allergen_compliance"
  consumes:
    - type: http
      namespace: sap
      baseUri: "https://nestle-s4.sap.com/sap/opu/odata/sap/API_RECIPE_SRV"
      authentication:
        type: basic
        username: "$secrets.sap_user"
        password: "$secrets.sap_password"
      inputParameters:
        - name: Accept
          in: header
          value: "application/json"
      resources:
        - name: recipes
          path: "/A_RecipeAllergen?$filter=Material eq '{{material}}'"
          inputParameters:
            - name: material
              in: query
          operations:
            - name: get-recipe-allergens
              method: GET
    - type: http
      namespace: informatica
      baseUri: "https://nestle.informaticacloud.com/active-bpel/rt/v1"
      authentication:
        type: bearer
        token: "$secrets.informatica_token"
      resources:
        - name: allergen-regulations
          path: "/regulatory/allergens"
          operations:
            - name: get-allergen-reqs
              method: POST
    - type: http
      namespace: servicenow
      baseUri: "https://nestle.service-now.com/api/now"
      authentication:
        type: basic
        username: "$secrets.servicenow_user"
        password: "$secrets.servicenow_password"
      resources:
        - name: tasks
          path: "/table/task"
          operations:
            - name: create-task
              method: POST

# ---------- 44. Retail Promotion Calendar Sync (orchestrated) ----------

Azure Data Factory Pipeline Monitor ▼

data monitoring azure-data-factory servicenow microsoft-teams

Checks the status of an Azure Data Factory pipeline run, and if failed, creates a ServiceNow incident and alerts the data engineering team in Microsoft Teams.

naftiko: "0.5"
info:
  label: "Azure Data Factory Pipeline Monitor"
  description: "Checks the status of an Azure Data Factory pipeline run, and if failed, creates a ServiceNow incident and alerts the data engineering team in Microsoft Teams."
  tags:
    - data
    - monitoring
    - azure-data-factory
    - servicenow
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: data-pipeline-monitor
      port: 8080
      tools:
        - name: check-pipeline-status
          description: "Given an ADF pipeline run ID, check status and escalate failures to ServiceNow and Microsoft Teams."
          inputParameters:
            - name: run_id
              in: body
              type: string
              description: "The Azure Data Factory pipeline run ID."
            - name: pipeline_name
              in: body
              type: string
              description: "The pipeline name for context."
          steps:
            - name: get-run
              type: call
              call: "adf.get-pipeline-run"
              with:
                run_id: "{{run_id}}"
            - name: create-incident
              type: call
              call: "servicenow.create-incident"
              with:
                short_description: "ADF pipeline failure: {{pipeline_name}}"
                description: "Pipeline: {{pipeline_name}}. Run ID: {{run_id}}. Status: {{get-run.status}}. Error: {{get-run.message}}. Duration: {{get-run.durationInMs}}ms."
                priority: "2"
                category: "data_pipeline"
                assigned_group: "Data_Engineering"
            - name: alert-team
              type: call
              call: "msteams.post-channel"
              with:
                team_id: "data-engineering"
                channel_id: "pipeline-alerts"
                text: "ADF Pipeline Failed: {{pipeline_name}} (run {{run_id}}). Status: {{get-run.status}}. Error: {{get-run.message}}. Incident: {{create-incident.number}}."
  consumes:
    - type: http
      namespace: adf
      baseUri: "https://management.azure.com/subscriptions/$secrets.azure_subscription_id/resourceGroups/nestle-data-rg/providers/Microsoft.DataFactory/factories/nestle-adf"
      authentication:
        type: bearer
        token: "$secrets.azure_mgmt_token"
      resources:
        - name: pipeline-runs
          path: "/pipelineruns/{{run_id}}?api-version=2018-06-01"
          inputParameters:
            - name: run_id
              in: path
          operations:
            - name: get-pipeline-run
              method: GET
    - type: http
      namespace: servicenow
      baseUri: "https://nestle.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: msteams
      baseUri: "https://graph.microsoft.com/v1.0"
      authentication:
        type: bearer
        token: "$secrets.msgraph_token"
      resources:
        - name: channel-messages
          path: "/teams/{{team_id}}/channels/{{channel_id}}/messages"
          inputParameters:
            - name: team_id
              in: path
            - name: channel_id
              in: path
          operations:
            - name: post-channel
              method: POST

# ---------- 34. Distributor Order Sync Pipeline (orchestrated) ----------

BigCommerce Product Catalog Lookup ▼

e-commerce catalog bigcommerce

Retrieves a product listing from Nestlé's BigCommerce e-commerce store by product ID, returning name, SKU, price, and inventory level.

naftiko: "0.5"
info:
  label: "BigCommerce Product Catalog Lookup"
  description: "Retrieves a product listing from Nestlé's BigCommerce e-commerce store by product ID, returning name, SKU, price, and inventory level."
  tags:
    - e-commerce
    - catalog
    - bigcommerce
capability:
  exposes:
    - type: mcp
      namespace: ecommerce-catalog
      port: 8080
      tools:
        - name: get-product
          description: "Fetch a BigCommerce product by ID. Returns name, SKU, price, and inventory."
          inputParameters:
            - name: product_id
              in: body
              type: string
              description: "The BigCommerce product ID."
          call: "bigcommerce.get-product"
          with:
            product_id: "{{product_id}}"
          outputParameters:
            - name: name
              type: string
              mapping: "$.data.name"
            - name: sku
              type: string
              mapping: "$.data.sku"
            - name: price
              type: string
              mapping: "$.data.price"
            - name: inventory_level
              type: string
              mapping: "$.data.inventory_level"
  consumes:
    - type: http
      namespace: bigcommerce
      baseUri: "https://api.bigcommerce.com/stores/nestle-store/v3"
      authentication:
        type: bearer
        token: "$secrets.bigcommerce_token"
      inputParameters:
        - name: X-Auth-Token
          in: header
          value: "$secrets.bigcommerce_access_token"
      resources:
        - name: products
          path: "/catalog/products/{{product_id}}"
          inputParameters:
            - name: product_id
              in: path
          operations:
            - name: get-product
              method: GET

# ---------- 13. Circana Market Share Report (simple) ----------

Brand Campaign Launch Orchestrator ▼

marketing campaign-management adobe-campaign google-tag-manager microsoft-teams

Initiates a new brand campaign by creating an Adobe Campaign workflow, setting up Google Tag Manager tracking, and notifying the brand team via Microsoft Teams with campaign links.

naftiko: "0.5"
info:
  label: "Brand Campaign Launch Orchestrator"
  description: "Initiates a new brand campaign by creating an Adobe Campaign workflow, setting up Google Tag Manager tracking, and notifying the brand team via Microsoft Teams with campaign links."
  tags:
    - marketing
    - campaign-management
    - adobe-campaign
    - google-tag-manager
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: campaign-launch
      port: 8080
      tools:
        - name: launch-campaign
          description: "Given campaign name, brand, and target URL, create an Adobe Campaign workflow, set up GTM tracking, and notify the brand team."
          inputParameters:
            - name: campaign_name
              in: body
              type: string
              description: "The campaign name."
            - name: brand
              in: body
              type: string
              description: "The Nestlé brand (e.g. Nescafé, KitKat, Purina)."
            - name: landing_url
              in: body
              type: string
              description: "The campaign landing page URL."
          steps:
            - name: create-campaign
              type: call
              call: "adobe-campaign.create-workflow"
              with:
                label: "{{campaign_name}} - {{brand}}"
                type: "campaign"
                folder_id: "brand_campaigns"
            - name: setup-tracking
              type: call
              call: "gtm.create-tag"
              with:
                account_id: "nestle-global"
                container_id: "{{brand}}-web"
                tag_name: "{{campaign_name}}_tracking"
                firing_url: "{{landing_url}}"
            - name: notify-team
              type: call
              call: "msteams.post-channel"
              with:
                team_id: "brand-marketing-{{brand}}"
                channel_id: "campaigns"
                text: "Campaign '{{campaign_name}}' launched for {{brand}}. Adobe Campaign ID: {{create-campaign.workflow_id}}. GTM tag: {{setup-tracking.tag_id}}. Landing: {{landing_url}}"
  consumes:
    - type: http
      namespace: adobe-campaign
      baseUri: "https://mc.adobe.io/nestle/campaign"
      authentication:
        type: bearer
        token: "$secrets.adobe_campaign_token"
      inputParameters:
        - name: x-api-key
          in: header
          value: "$secrets.adobe_api_key"
      resources:
        - name: workflows
          path: "/profileAndServicesExt/workflow"
          operations:
            - name: create-workflow
              method: POST
    - type: http
      namespace: gtm
      baseUri: "https://www.googleapis.com/tagmanager/v2"
      authentication:
        type: bearer
        token: "$secrets.google_tagmanager_token"
      resources:
        - name: tags
          path: "/accounts/{{account_id}}/containers/{{container_id}}/workspaces/default/tags"
          inputParameters:
            - name: account_id
              in: path
            - name: container_id
              in: path
          operations:
            - name: create-tag
              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/{{team_id}}/channels/{{channel_id}}/messages"
          inputParameters:
            - name: team_id
              in: path
            - name: channel_id
              in: path
          operations:
            - name: post-channel
              method: POST

# ---------- 21. Sustainability Metrics Reporting Pipeline (orchestrated) ----------

Canva Brand Asset Approval Workflow ▼

marketing design canva box servicenow microsoft-teams

When a marketing designer submits a Canva design for review, uploads the exported asset to Box, creates a ServiceNow approval task, and notifies the brand manager in Microsoft Teams.

naftiko: "0.5"
info:
  label: "Canva Brand Asset Approval Workflow"
  description: "When a marketing designer submits a Canva design for review, uploads the exported asset to Box, creates a ServiceNow approval task, and notifies the brand manager in Microsoft Teams."
  tags:
    - marketing
    - design
    - canva
    - box
    - servicenow
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: brand-asset-approval
      port: 8080
      tools:
        - name: submit-asset-for-approval
          description: "Given a Canva design ID and brand, export the asset, upload to Box, create an approval task, and notify the brand manager."
          inputParameters:
            - name: design_id
              in: body
              type: string
              description: "The Canva design ID."
            - name: brand
              in: body
              type: string
              description: "The Nestlé brand name."
            - name: designer_name
              in: body
              type: string
              description: "The name of the submitting designer."
          steps:
            - name: export-design
              type: call
              call: "canva.export-design"
              with:
                design_id: "{{design_id}}"
                format: "pdf"
            - name: upload-to-box
              type: call
              call: "box.upload-file"
              with:
                parent_folder_id: "brand_assets_{{brand}}"
                file_name: "{{design_id}}_review.pdf"
                file_url: "{{export-design.download_url}}"
            - name: create-approval
              type: call
              call: "servicenow.create-task"
              with:
                short_description: "Brand asset approval: {{brand}} design {{design_id}}"
                description: "Designer: {{designer_name}}. Brand: {{brand}}. Design ID: {{design_id}}. Box link: {{upload-to-box.shared_link}}. Please review for brand guidelines compliance."
                assigned_group: "Brand_Management_{{brand}}"
                category: "brand_asset_approval"
            - name: notify-manager
              type: call
              call: "msteams.post-channel"
              with:
                team_id: "brand-marketing-{{brand}}"
                channel_id: "asset-approvals"
                text: "New asset for review from {{designer_name}}: {{brand}} design {{design_id}}. Preview: {{upload-to-box.shared_link}}. Approval task: {{create-approval.number}}."
  consumes:
    - type: http
      namespace: canva
      baseUri: "https://api.canva.com/rest/v1"
      authentication:
        type: bearer
        token: "$secrets.canva_token"
      resources:
        - name: exports
          path: "/designs/{{design_id}}/export"
          inputParameters:
            - name: design_id
              in: path
          operations:
            - name: export-design
              method: POST
    - type: http
      namespace: box
      baseUri: "https://upload.box.com/api/2.0"
      authentication:
        type: bearer
        token: "$secrets.box_token"
      resources:
        - name: uploads
          path: "/files/content"
          operations:
            - name: upload-file
              method: POST
    - type: http
      namespace: servicenow
      baseUri: "https://nestle.service-now.com/api/now"
      authentication:
        type: basic
        username: "$secrets.servicenow_user"
        password: "$secrets.servicenow_password"
      resources:
        - name: tasks
          path: "/table/task"
          operations:
            - name: create-task
              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/{{team_id}}/channels/{{channel_id}}/messages"
          inputParameters:
            - name: team_id
              in: path
            - name: channel_id
              in: path
          operations:
            - name: post-channel
              method: POST

# ---------- 48. Elasticsearch Product Search Index Refresh (orchestrated) ----------

Circana Market Share Report ▼

analytics market-research circana

Pulls market share data from Circana (formerly IRI) for a specified Nestlé product category, geography, and time period. Used by brand strategy teams to benchmark competitive positioning.

naftiko: "0.5"
info:
  label: "Circana Market Share Report"
  description: "Pulls market share data from Circana (formerly IRI) for a specified Nestlé product category, geography, and time period. Used by brand strategy teams to benchmark competitive positioning."
  tags:
    - analytics
    - market-research
    - circana
capability:
  exposes:
    - type: mcp
      namespace: market-intelligence
      port: 8080
      tools:
        - name: get-market-share
          description: "Query Circana for market share data by category, geography, and time period."
          inputParameters:
            - name: category
              in: body
              type: string
              description: "The product category identifier."
            - name: geography
              in: body
              type: string
              description: "The geographic market code."
            - name: period
              in: body
              type: string
              description: "The time period (e.g. 4W, 12W, 52W)."
          call: "circana.get-share-data"
          with:
            category: "{{category}}"
            geography: "{{geography}}"
            period: "{{period}}"
          outputParameters:
            - name: dollar_share
              type: string
              mapping: "$.data.dollar_share"
            - name: unit_share
              type: string
              mapping: "$.data.unit_share"
            - name: share_change
              type: string
              mapping: "$.data.share_change_vs_ya"
  consumes:
    - type: http
      namespace: circana
      baseUri: "https://api.circana.com/v2"
      authentication:
        type: bearer
        token: "$secrets.circana_token"
      resources:
        - name: market-share
          path: "/market-measurement/share"
          operations:
            - name: get-share-data
              method: POST

# ---------- 14. Confluence Factory SOP Search (simple) ----------

Cold Chain Temperature Excursion Handler ▼

supply-chain quality sap servicenow microsoft-teams

When a cold chain sensor reports a temperature excursion, retrieves shipment details from SAP transportation, creates a quality hold in ServiceNow, and alerts the logistics team in Microsoft Teams.

naftiko: "0.5"
info:
  label: "Cold Chain Temperature Excursion Handler"
  description: "When a cold chain sensor reports a temperature excursion, retrieves shipment details from SAP transportation, creates a quality hold in ServiceNow, and alerts the logistics team in Microsoft Teams."
  tags:
    - supply-chain
    - quality
    - sap
    - servicenow
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: cold-chain
      port: 8080
      tools:
        - name: handle-temperature-excursion
          description: "Given a shipment number and excursion details, retrieve SAP shipment data, create a quality hold, and alert logistics."
          inputParameters:
            - name: shipment_number
              in: body
              type: string
              description: "The SAP shipment number."
            - name: max_temperature
              in: body
              type: string
              description: "The maximum recorded temperature during excursion."
            - name: excursion_duration_minutes
              in: body
              type: string
              description: "Duration of the temperature excursion in minutes."
          steps:
            - name: get-shipment
              type: call
              call: "sap.get-shipment"
              with:
                shipment_number: "{{shipment_number}}"
            - name: create-hold
              type: call
              call: "servicenow.create-task"
              with:
                short_description: "Cold chain excursion: Shipment {{shipment_number}}"
                description: "Shipment: {{shipment_number}}. Origin: {{get-shipment.origin}}. Destination: {{get-shipment.destination}}. Product: {{get-shipment.material_description}}. Max temp: {{max_temperature}}C (limit: {{get-shipment.temp_limit}}C). Duration: {{excursion_duration_minutes}} min. Quality hold required."
                priority: "1"
                assigned_group: "Quality_Cold_Chain"
                category: "temperature_excursion"
            - name: alert-logistics
              type: call
              call: "msteams.post-channel"
              with:
                team_id: "logistics-operations"
                channel_id: "cold-chain-alerts"
                text: "COLD CHAIN ALERT: Shipment {{shipment_number}} excursion detected. Product: {{get-shipment.material_description}}. Max temp: {{max_temperature}}C for {{excursion_duration_minutes}} min. Quality hold: {{create-hold.number}}. Immediate disposition required."
  consumes:
    - type: http
      namespace: sap
      baseUri: "https://nestle-s4.sap.com/sap/opu/odata/sap/API_SHIPMENT_SRV"
      authentication:
        type: basic
        username: "$secrets.sap_user"
        password: "$secrets.sap_password"
      inputParameters:
        - name: Accept
          in: header
          value: "application/json"
      resources:
        - name: shipments
          path: "/A_Shipment('{{shipment_number}}')"
          inputParameters:
            - name: shipment_number
              in: path
          operations:
            - name: get-shipment
              method: GET
    - type: http
      namespace: servicenow
      baseUri: "https://nestle.service-now.com/api/now"
      authentication:
        type: basic
        username: "$secrets.servicenow_user"
        password: "$secrets.servicenow_password"
      resources:
        - name: tasks
          path: "/table/task"
          operations:
            - name: create-task
              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/{{team_id}}/channels/{{channel_id}}/messages"
          inputParameters:
            - name: team_id
              in: path
            - name: channel_id
              in: path
          operations:
            - name: post-channel
              method: POST

# ---------- 47. Canva Brand Asset Approval Workflow (orchestrated) ----------

Confluence Factory SOP Search ▼

manufacturing knowledge-management confluence

Searches Nestlé's Confluence knowledge base for standard operating procedures relevant to a manufacturing query. Returns matching page titles, excerpts, and links.

naftiko: "0.5"
info:
  label: "Confluence Factory SOP Search"
  description: "Searches Nestlé's Confluence knowledge base for standard operating procedures relevant to a manufacturing query. Returns matching page titles, excerpts, and links."
  tags:
    - manufacturing
    - knowledge-management
    - confluence
capability:
  exposes:
    - type: mcp
      namespace: factory-knowledge
      port: 8080
      tools:
        - name: search-sops
          description: "Search Confluence for factory standard operating procedures by keyword."
          inputParameters:
            - name: query
              in: body
              type: string
              description: "The search keyword or phrase."
            - name: space_key
              in: body
              type: string
              description: "The Confluence space key for the factory SOP library."
          call: "confluence.search"
          with:
            cql: "space={{space_key}} AND type=page AND text~\"{{query}}\""
          outputParameters:
            - name: results
              type: string
              mapping: "$.results"
  consumes:
    - type: http
      namespace: confluence
      baseUri: "https://nestle.atlassian.net/wiki/rest/api"
      authentication:
        type: basic
        username: "$secrets.confluence_user"
        password: "$secrets.confluence_api_token"
      resources:
        - name: search
          path: "/search?cql={{cql}}"
          inputParameters:
            - name: cql
              in: query
          operations:
            - name: search
              method: GET

# ---------- 15. Oracle Cloud Inventory Balance (simple) ----------

Consumer Complaint Triage ▼

quality customer-service salesforce sap azure-machine-learning servicenow

Receives a consumer complaint from Salesforce Service Cloud, enriches with product batch data from SAP, classifies severity via Azure Machine Learning, and routes a ServiceNow case to the appropriate quality team.

naftiko: "0.5"
info:
  label: "Consumer Complaint Triage"
  description: "Receives a consumer complaint from Salesforce Service Cloud, enriches with product batch data from SAP, classifies severity via Azure Machine Learning, and routes a ServiceNow case to the appropriate quality team."
  tags:
    - quality
    - customer-service
    - salesforce
    - sap
    - azure-machine-learning
    - servicenow
capability:
  exposes:
    - type: mcp
      namespace: complaint-triage
      port: 8080
      tools:
        - name: triage-complaint
          description: "Given a Salesforce case ID, enrich with SAP batch data, classify severity, and route to ServiceNow."
          inputParameters:
            - name: case_id
              in: body
              type: string
              description: "The Salesforce case ID."
          steps:
            - name: get-case
              type: call
              call: "salesforce.get-case"
              with:
                case_id: "{{case_id}}"
            - name: get-batch
              type: call
              call: "sap.get-batch"
              with:
                batch_number: "{{get-case.batch_number}}"
                material_number: "{{get-case.product_code}}"
            - name: classify-severity
              type: call
              call: "azureml.classify-complaint"
              with:
                complaint_text: "{{get-case.description}}"
                product_category: "{{get-batch.material_group}}"
            - name: create-quality-case
              type: call
              call: "servicenow.create-task"
              with:
                short_description: "Consumer complaint: {{get-case.subject}} — Severity {{classify-severity.severity_level}}"
                description: "Salesforce case: {{case_id}}. Consumer: {{get-case.contact_name}}. Product: {{get-batch.material_description}} (batch {{get-case.batch_number}}). Plant: {{get-batch.plant}}. Severity: {{classify-severity.severity_level}}. Classification: {{classify-severity.category}}."
                assigned_group: "Quality_Consumer_Affairs"
                priority: "{{classify-severity.priority}}"
                category: "consumer_complaint"
  consumes:
    - type: http
      namespace: salesforce
      baseUri: "https://nestle.my.salesforce.com/services/data/v59.0"
      authentication:
        type: bearer
        token: "$secrets.salesforce_token"
      resources:
        - name: cases
          path: "/sobjects/Case/{{case_id}}"
          inputParameters:
            - name: case_id
              in: path
          operations:
            - name: get-case
              method: GET
    - type: http
      namespace: sap
      baseUri: "https://nestle-s4.sap.com/sap/opu/odata/sap/API_BATCH_SRV"
      authentication:
        type: basic
        username: "$secrets.sap_user"
        password: "$secrets.sap_password"
      inputParameters:
        - name: Accept
          in: header
          value: "application/json"
      resources:
        - name: batches
          path: "/A_Batch(Material='{{material_number}}',Batch='{{batch_number}}')"
          inputParameters:
            - name: material_number
              in: path
            - name: batch_number
              in: path
          operations:
            - name: get-batch
              method: GET
    - type: http
      namespace: azureml
      baseUri: "https://nestle-ml.westeurope.inference.ml.azure.com"
      authentication:
        type: bearer
        token: "$secrets.azureml_token"
      resources:
        - name: complaint-classifier
          path: "/score"
          operations:
            - name: classify-complaint
              method: POST
    - type: http
      namespace: servicenow
      baseUri: "https://nestle.service-now.com/api/now"
      authentication:
        type: basic
        username: "$secrets.servicenow_user"
        password: "$secrets.servicenow_password"
      resources:
        - name: tasks
          path: "/table/task"
          operations:
            - name: create-task
              method: POST

# ---------- 39. Product Launch Readiness Checker (orchestrated) ----------

Datadog Factory System Health ▼

manufacturing monitoring datadog

Queries Datadog for infrastructure host health metrics at a Nestlé manufacturing facility, returning CPU, memory, and alert counts for the last hour.

naftiko: "0.5"
info:
  label: "Datadog Factory System Health"
  description: "Queries Datadog for infrastructure host health metrics at a Nestlé manufacturing facility, returning CPU, memory, and alert counts for the last hour."
  tags:
    - manufacturing
    - monitoring
    - datadog
capability:
  exposes:
    - type: mcp
      namespace: factory-monitoring
      port: 8080
      tools:
        - name: get-host-metrics
          description: "Retrieve CPU, memory, and active alert counts for a Datadog-monitored factory host."
          inputParameters:
            - name: host_name
              in: body
              type: string
              description: "The Datadog hostname for the factory system."
          call: "datadog.get-host-totals"
          with:
            filter: "{{host_name}}"
          outputParameters:
            - name: cpu_usage
              type: string
              mapping: "$.host_list[0].metrics.cpu"
            - name: memory_usage
              type: string
              mapping: "$.host_list[0].metrics.memory"
            - name: active_alerts
              type: string
              mapping: "$.host_list[0].alerts_count"
  consumes:
    - type: http
      namespace: datadog
      baseUri: "https://api.datadoghq.com/api/v1"
      authentication:
        type: bearer
        token: "$secrets.datadog_api_key"
      inputParameters:
        - name: DD-APPLICATION-KEY
          in: header
          value: "$secrets.datadog_app_key"
      resources:
        - name: hosts
          path: "/hosts?filter={{filter}}"
          inputParameters:
            - name: filter
              in: query
          operations:
            - name: get-host-totals
              method: GET

# ---------- 8. SAP Purchase Order Status (simple) ----------

Demand Forecast to Production Planning ▼

supply-chain forecasting azure-databricks sap microsoft-teams

Pulls demand forecast data from Azure Databricks, converts to a planned order in SAP, and notifies the production planning team in Microsoft Teams with the scheduling details.

naftiko: "0.5"
info:
  label: "Demand Forecast to Production Planning"
  description: "Pulls demand forecast data from Azure Databricks, converts to a planned order in SAP, and notifies the production planning team in Microsoft Teams with the scheduling details."
  tags:
    - supply-chain
    - forecasting
    - azure-databricks
    - sap
    - microsoft-teams
capability:
  exposes:
    - type: mcp
      namespace: demand-planning
      port: 8080
      tools:
        - name: convert-forecast-to-plan
          description: "Given a forecast run ID and material number, retrieve the forecast from Databricks, create a planned order in SAP, and notify the planning team."
          inputParameters:
            - name: forecast_run_id
              in: body
              type: string
              description: "The Databricks forecast run identifier."
            - name: material_number
              in: body
              type: string
              description: "The SAP material number."
            - name: plant_code
              in: body
              type: string
              description: "The SAP plant code."
          steps:
            - name: get-forecast
              type: call
              call: "databricks.get-forecast"
              with:
                run_id: "{{forecast_run_id}}"
                material: "{{material_number}}"
            - name: create-planned-order
              type: call
              call: "sap.create-planned-order"
              with:
                material: "{{material_number}}"
                plant: "{{plant_code}}"
                quantity: "{{get-forecast.recommended_quantity}}"
                start_date: "{{get-forecast.production_start}}"
                end_date: "{{get-forecast.production_end}}"
            - name: notify-planners
              type: call
              call: "msteams.post-channel"
              with:
                team_id: "supply-planning"
                channel_id: "production-orders"
                text: "Planned order created from forecast: Material {{material_number}} at plant {{plant_code}}. Qty: {{get-forecast.recommended_quantity}}. Production window: {{get-forecast.production_start}} to {{get-forecast.production_end}}. SAP order: {{create-planned-order.order_number}}."
  consumes:
    - type: http
      namespace: databricks
      baseUri: "https://nestle-adb.azuredatabricks.net/api/2.0"
      authentication:
        type: bearer
        token: "$secrets.databricks_token"
      resources:
        - name: jobs
          path: "/jobs/runs/get-output?run_id={{run_id}}"
          inputParameters:
            - name: run_id
              in: query
          operations:
            - name: get-forecast
              method: GET
    - type: http
      namespace: sap
      baseUri: "https://nestle-s4.sap.com/sap/opu/odata/sap/API_PLANNED_ORDERS"
      authentication:
        type: basic
        username: "$secrets.sap_user"
        password: "$secrets.sap_password"
      inputParameters:
        - name: Accept
          in: header
          value: "application/json"
      resources:
        - name: planned-orders
          path: "/A_PlannedOrder"
          operations:
            - name: create-planned-order
              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/{{team_id}}/channels/{{channel_id}}/messages"
          inputParameters:
            - name: team_id
              in: path
            - name: channel_id
              in: path
          operations:
            - name: post-channel
              method: POST

# ---------- 25. Trade Promotion Effectiveness Analyzer (orchestrated) ----------

Distributor Order Sync Pipeline ▼

supply-chain sales oracle-e-business-suite sap salesforce

Syncs incoming distributor orders from Oracle E-Business Suite into SAP as sales orders, and updates the Salesforce opportunity stage with order confirmation details.

naftiko: "0.5"
info:
  label: "Distributor Order Sync Pipeline"
  description: "Syncs incoming distributor orders from Oracle E-Business Suite into SAP as sales orders, and updates the Salesforce opportunity stage with order confirmation details."
  tags:
    - supply-chain
    - sales
    - oracle-e-business-suite
    - sap
    - salesforce
capability:
  exposes:
    - type: mcp
      namespace: distributor-orders
      port: 8080
      tools:
        - name: sync-distributor-order
          description: "Given an Oracle EBS order number and Salesforce opportunity ID, retrieve order details, create a SAP sales order, and update Salesforce."
          inputParameters:
            - name: ebs_order_number
              in: body
              type: string
              description: "The Oracle EBS order number."
            - name: opportunity_id
              in: body
              type: string
              description: "The Salesforce opportunity ID."
          steps:
            - name: get-ebs-order
              type: call
              call: "oracle-ebs.get-order"
              with:
                order_number: "{{ebs_order_number}}"
            - name: create-sales-order
              type: call
              call: "sap.create-sales-order"
              with:
                sold_to: "{{get-ebs-order.customer_number}}"
                material: "{{get-ebs-order.item_number}}"
                quantity: "{{get-ebs-order.ordered_quantity}}"
                requested_date: "{{get-ebs-order.request_date}}"
            - name: update-opportunity
              type: call
              call: "salesforce.update-opportunity"
              with:
                opportunity_id: "{{opportunity_id}}"
                stage: "Closed Won"
                sap_order: "{{create-sales-order.sales_order_number}}"
  consumes:
    - type: http
      namespace: oracle-ebs
      baseUri: "https://nestle-ebs.oraclecloud.com/webservices/rest/order"
      authentication:
        type: basic
        username: "$secrets.oracle_ebs_user"
        password: "$secrets.oracle_ebs_password"
      resources:
        - name: orders
          path: "/{{order_number}}"
          inputParameters:
            - name: order_number
              in: path
          operations:
            - name: get-order
              method: GET
    - type: http
      namespace: sap
      baseUri: "https://nestle-s4.sap.com/sap/opu/odata/sap/API_SALES_ORDER_SRV"
      authentication:
        type: basic
        username: "$secrets.sap_user"
        password: "$secrets.sap_password"
      inputParameters:
        - name: Accept
          in: header
          value: "application/json"
      resources:
        - name: sales-orders
          path: "/A_SalesOrder"
          operations:
            - name: create-sales-order
              method: POST
    - type: http
      namespace: salesforce
      baseUri: "https://nestle.my.salesforce.com/services/data/v59.0"
      authentication:
        type: bearer
        token: "$secrets.salesforce_token"
      resources:
        - name: opportunities
          path: "/sobjects/Opportunity/{{opportunity_id}}"
          inputParameters:
            - name: opportunity_id
              in: path
          operations:
            - name: update-opportunity
              method: PATCH

# ---------- 35. LinkedIn Brand Recruitment Campaign (orchestrated) ----------

E-Commerce Order Fulfillment Tracker ▼

e-commerce supply-chain bigcommerce sap salesforce

Retrieves a BigCommerce order, checks shipment status via SAP delivery tracking, and updates the Salesforce opportunity with fulfillment data for B2B e-commerce orders.

naftiko: "0.5"
info:
  label: "E-Commerce Order Fulfillment Tracker"
  description: "Retrieves a BigCommerce order, checks shipment status via SAP delivery tracking, and updates the Salesforce opportunity with fulfillment data for B2B e-commerce orders."
  tags:
    - e-commerce
    - supply-chain
    - bigcommerce
    - sap
    - salesforce
capability:
  exposes:
    - type: mcp
      namespace: ecommerce-fulfillment
      port: 8080
      tools:
        - name: track-order-fulfillment
          description: "Given a BigCommerce order ID and Salesforce opportunity ID, fetch order details, check SAP shipment status, and update the Salesforce opportunity."
          inputParameters:
            - name: order_id
              in: body
              type: string
              description: "The BigCommerce order ID."
            - name: opportunity_id
              in: body
              type: string
              description: "The Salesforce opportunity ID linked to this order."
          steps:
            - name: get-order
              type: call
              call: "bigcommerce.get-order"
              with:
                order_id: "{{order_id}}"
            - name: get-delivery
              type: call
              call: "sap.get-delivery"
              with:
                sales_order: "{{get-order.staff_notes}}"
            - name: update-opportunity
              type: call
              call: "salesforce.update-opportunity"
              with:
                opportunity_id: "{{opportunity_id}}"
                shipment_status: "{{get-delivery.overall_status}}"
                tracking_number: "{{get-delivery.tracking_number}}"
                estimated_delivery: "{{get-delivery.planned_delivery_date}}"
  consumes:
    - type: http
      namespace: bigcommerce
      baseUri: "https://api.bigcommerce.com/stores/nestle-store/v2"
      authentication:
        type: bearer
        token: "$secrets.bigcommerce_token"
      inputParameters:
        - name: X-Auth-Token
          in: header
          value: "$secrets.bigcommerce_access_token"
      resources:
        - name: orders
          path: "/orders/{{order_id}}"
          inputParameters:
            - name: order_id
              in: path
          operations:
            - name: get-order
              method: GET
    - type: http
      namespace: sap
      baseUri: "https://nestle-s4.sap.com/sap/opu/odata/sap/API_OUTBOUND_DELIVERY_SRV"
      authentication:
        type: basic
        username: "$secrets.sap_user"
        password: "$secrets.sap_password"
      inputParameters:
        - name: Accept
          in: header
          value: "application/json"
      resources:
        - name: deliveries
          path: "/A_OutbDeliveryHeader?$filter=SalesOrder eq '{{sales_order}}'"
          inputParameters:
            - name: sales_order
              in: query
          operations:
            - name: get-delivery
              method: GET
    - type: http
      namespace: salesforce
      baseUri: "https://nestle.my.salesforce.com/services/data/v59.0"
      authentication:
        type: bearer
        token: "$secrets.salesforce_token"
      resources:
        - name: opportunities
          path: "/sobjects/Opportunity/{{opportunity_id}}"
          inputParameters:
            - name: opportunity_id
              in: path
          operations:
            - name: update-opportunity
              method: PATCH

# ---------- 19. Manufacturing Line Downtime Alerter (orchestrated) ----------

Elasticsearch Product Search Index Refresh ▼

e-commerce search sap elasticsearch google-sheets

Retrieves updated product catalog data from SAP, pushes it to an Elasticsearch index for the e-commerce search engine, and logs the refresh status to a Google Sheets audit trail.

naftiko: "0.5"
info:
  label: "Elasticsearch Product Search Index Refresh"
  description: "Retrieves updated product catalog data from SAP, pushes it to an Elasticsearch index for the e-commerce search engine, and logs the refresh status to a Google Sheets audit trail."
  tags:
    - e-commerce
    - search
    - sap
    - elasticsearch
    - google-sheets
capability:
  exposes:
    - type: mcp
      namespace: search-index
      port: 8080
      tools:
        - name: refresh-product-index
          description: "Given a material group, pull updated products from SAP, index in Elasticsearch, and log to audit sheet."
          inputParameters:
            - name: material_group
              in: body
              type: string
              description: "The SAP material group to refresh."
            - name: audit_spreadsheet_id
              in: body
              type: string
              description: "The Google Sheets ID for index refresh audit."
          steps:
            - name: get-products
              type: call
              call: "sap.get-products-by-group"
              with:
                material_group: "{{material_group}}"
            - name: bulk-index
              type: call
              call: "elasticsearch.bulk-index"
              with:
                index: "nestle-product-catalog"
                documents: "{{get-products.results}}"
            - name: log-refresh
              type: call
              call: "gsheets.append-row"
              with:
                spreadsheet_id: "{{audit_spreadsheet_id}}"
                range: "IndexRefresh!A:E"
                values: "{{material_group}},{{get-products.count}},{{bulk-index.indexed_count}},{{bulk-index.error_count}},{{bulk-index.timestamp}}"
  consumes:
    - type: http
      namespace: sap
      baseUri: "https://nestle-s4.sap.com/sap/opu/odata/sap/API_PRODUCT_SRV"
      authentication:
        type: basic
        username: "$secrets.sap_user"
        password: "$secrets.sap_password"
      inputParameters:
        - name: Accept
          in: header
          value: "application/json"
      resources:
        - name: products
          path: "/A_Product?$filter=MaterialGroup eq '{{material_group}}'"
          inputParameters:
            - name: material_group
              in: query
          operations:
            - name: get-products-by-group
              method: GET
    - type: http
      namespace: elasticsearch
      baseUri: "https://nestle-es.westeurope.azure.elastic-cloud.com"
      authentication:
        type: basic
        username: "$secrets.elasticsearch_user"
        password: "$secrets.elasticsearch_password"
      resources:
        - name: bulk
          path: "/{{index}}/_bulk"
          inputParameters:
            - name: index
              in: path
          operations:
            - name: bulk-index
              method: POST
    - type: http
      namespace: gsheets
      baseUri: "https://sheets.googleapis.com/v4"
      authentication:
        type: bearer
        token: "$secrets.google_sheets_token"
      resources:
        - name: values
          path: "/spreadsheets/{{spreadsheet_id}}/values/{{range}}:append"
          inputParameters:
            - name: spreadsheet_id
              in: path
            - name: range
              in: path
          operations:
            - name: append-row
              method: POST

# ---------- 49. NiFi Data Pipeline Failure Escalation (orchestrated) ----------

Factory Quality Inspection Results Sync ▼

quality manufacturing sap google-sheets servicenow

Retrieves quality inspection results from SAP QM, logs findings to a Google Sheets tracker, and creates a ServiceNow follow-up task if any results are out of specification.

naftiko: "0.5"
info:
  label: "Factory Quality Inspection Results Sync"
  description: "Retrieves quality inspection results from SAP QM, logs findings to a Google Sheets tracker, and creates a ServiceNow follow-up task if any results are out of specification."
  tags:
    - quality
    - manufacturing
    - sap
    - google-sheets
    - servicenow
capability:
  exposes:
    - type: mcp
      namespace: quality-inspection
      port: 8080
      tools:
        - name: sync-inspection-results
          description: "Given an SAP inspection lot number, retrieve results, log to Google Sheets, and create a ServiceNow task if out-of-spec."
          inputParameters:
            - name: inspection_lot
              in: body
              type: string
              description: "The SAP inspection lot number."
            - name: spreadsheet_id
              in: body
              type: string
              description: "The Google Sheets ID for the quality tracker."
          steps:
            - name: get-results
              type: call
              call: "sap.get-inspection-results"
              with:
                inspection_lot: "{{inspection_lot}}"
            - name: log-results
              type: call
              call: "gsheets.append-row"
              with:
                spreadsheet_id: "{{spreadsheet_id}}"
                range: "InspectionLog!A:G"
                values: "{{inspection_lot}},{{get-results.material}},{{get-results.plant}},{{get-results.inspection_date}},{{get-results.overall_result}},{{get-results.defect_count}},{{get-results.inspector}}"
            - name: create-followup
              type: call
              call: "servicenow.create-task"
              with:
                short_description: "QC follow-up: Inspection lot {{inspection_lot}} — {{get-results.overall_result}}"
                description: "Material: {{get-results.material}}. Plant: {{get-results.plant}}. Result: {{get-results.overall_result}}. Defects: {{get-results.defect_count}}. Inspector: {{get-results.inspector}}."
                assigned_group: "Quality_Operations"
                category: "quality_inspection"
  consumes:
    - type: http
      namespace: sap
      baseUri: "https://nestle-s4.sap.com/sap/opu/odata/sap/API_INSPECTIONLOT_SRV"
      authentication:
        type: basic
        username: "$secrets.sap_user"
        password: "$secrets.sap_password"
      inputParameters:
        - name: Accept
          in: header
          value: "application/json"
      resources:
        - name: inspection-lots
          path: "/A_InspectionLot('{{inspection_lot}}')/to_InspectionResult"
          inputParameters:
            - name: inspection_lot
              in: path
          operations:
            - name: get-inspection-results
              method: GET
    - type: http
      namespace: gsheets
      baseUri: "https://sheets.googleapis.com/v4"
      authentication:
        type: bearer
        token: "$secrets.google_sheets_token"
      resources:
        - name: values
          path: "/spreadsheets/{{spreadsheet_id}}/values/{{range}}:append"
          inputParameters:
            - name: spreadsheet_id
              in: path
            - name: range
              in: path
          operations:
            - name: append-row
              method: POST
    - type: http
      namespace: servicenow
      baseUri: "https://nestle.service-now.com/api/now"
      authentication:
        type: basic
        username: "$secrets.servicenow_user"
        password: "$secrets.servicenow_password"
      resources:
        - name: tasks
          path: "/table/task"
          operations:
            - name: create-task
              method: POST

# ---------- 32. Vendor Invoice Reconciliation (orchestrated) ----------

Nestle Workflow 1 ▼

food-manufacturing operations salesforce