streamx / magento-connector-php
Magento connector for StreamX - a Digital Experience Data Mesh.
Installs: 0
Dependents: 0
Suggesters: 0
Security: 0
Stars: 0
Watchers: 0
Forks: 1
Open Issues: 0
Type:magento2-component
pkg:composer/streamx/magento-connector-php
Requires
- php: >=7.4
- ext-json: *
- ext-pcntl: *
- cloudevents/sdk-php: ^1.2
- magento/framework: >=101.0.0
- magento/magento-composer-installer: *
- magento/module-backend: >=100.2.0
- magento/module-catalog: >=102.0.0
- magento/module-store: >=100.2.0
- php-amqplib/rabbitmq-bundle: ^2.17
- ramsey/uuid: ^4.2
- streamx/ingestion-client-php: 2.0.3
Requires (Dev)
- ext-curl: *
- ext-mysqli: *
- ext-simplexml: *
- phpunit/phpunit: ^9.5
- dev-main
- 2.0.2
- 1.0.27
- 1.0.26
- 1.0.25
- 1.0.24
- 1.0.23
- 1.0.22
- 1.0.17
- 1.0.16
- 1.0.14
- 1.0.11
- 1.0.10
- 1.0.9
- 1.0.5
- 1.0.4
- 1.0.2
- 1.0.1
- 1.0.0
- dev-chore/dxp-2230-gh-config
- dev-SXPR-128AllowreusingofhttpclientusedforStreamXingestion
- dev-SXPR-142-fix-attributes-indexer-when-all-attributes-are-configured-as-indexable
- dev-DXP-2225-switch-tests-to-publish-data-to-main-blueprints-mesh
- dev-SXPR-116-allow-unsetting-indexed-stores-and-product-types
- dev-SXPR-116-introduce-configurable-timeouts-to-the-ingestion-endpoint
- dev-SXPR-116-remove-streamx-availability-checker
- dev-SXPR-116-use-always-up-to-date-configuration-values
- dev-SXPR-116-decouple-optimization-settings-reader-and-observer
- dev-SXPR-116-fix-test-warnings
- dev-DXP-1368-fix-bug-in-loading-store-level-base-link-urls
- dev-DXP-1826-add-github-release-action
- dev-DXP-1826-change-bump-version-commit-from-amend-to-new-commit
- dev-DXP-1910-grup-slug-generation-options-to-single-config-field
- dev-DXP-1823-don't-reindex-product-on-irrelevant-attribute-definition-change
- dev-DXP-1934-analyse-of-products-reindexing-count
- dev-DXP-1934-skip-dependent-indexer-checking-when-manually-reindexing
- dev-DXP-1826-add-fetch-depth
- dev-DXP-1910-reduce-complexity-of-executing-products-indexer-or-not
- dev-DXP-1826ImplementGitHubActionstoCommerceConnector
- dev-DXP-1910-various-minor-cleanups-in-core-module
- dev-DXP-1910-various-minor-cleanups-in-catalog-module
- dev-DXP-1910-dont-check-for-streamx-availability-when-rabbit-mq-is-used
- dev-DXP-1910MakeStreamxClientstateless
- dev-DXP-1910-reuse-streamx-publishers-also-while-checking-for-streamx-availability
- dev-DXP-1910-optimize-attributes-indexer
- dev-DXP-1910-reuse-ProductMetaData-class
- dev-DXP-1910-reduce-complexity-of-configurable-data-provider
- dev-DXP-1912-handle-remaining-test-todos
- dev-DXP-1823-group-common-indexer-dependencies-to-a-collective-service
- dev-DXP-1823-merge-processor-into-indexers
- dev-DXP-1910-unify-BasicDataLoader-contract
- dev-DXP-1910-improve-naming-of-indexed-stores-config-field
- dev-DXP-1910-remove-compilation-warnings-in-load-attributes-code
- dev-DXP-1911-rename-connector-test-tools-to-test-endpoints
- dev-DXP-1681-add-rabbitmq-ingestion-support
- dev-DXP-1823-use-built-in-methods-for-retrieving-variant-and-parent-ids
- dev-DXP-1912-remove-unnecessary-fields-also-from-nested-subcategories
- dev-DXP-1681-pre-rabbitmq-test-improvements
- dev-DXP-1825-add-test-for-publishing-all-parent-categories-chain-when-child-is-edited
- dev-DXP-1826-update-version-number
- dev-DXP-1828-use-static-field-override-feature-for-indexer-tests-configuration
- dev-DXP-1828-publish-imported-products
- dev-DXP-1827-allow-indexing-next-batches-of-data-when-error-in-data-provider
- dev-DXP-1681-test-improvements
- dev-DXP-1912-verify-publication-when-exported-product-types-are-limited
- dev-DXP-1912-improve-naming-and-configuring-indexers
- dev-DXP-1912-remove-publishing-virtual-products
- dev-DXP-1912-remove-bundle-options-provider
- dev-DXP-1912-remove-TODOs-for-grouped-products-treat-as-completed
- dev-DXP-1912-remove-custom-options
- dev-DXP-1681-more-strict-asserting-published-content
- dev-DXP-1681-perform-faster-serverside-indexer-mode-switching
- dev-DXP-1681-perform-faster-serverside-cache-cleaning
- dev-DXP-1681Usefactoriesforcreatingserviceswithinjectabledependencies
- dev-DXP-1681-split-streamx-client-and-availability-checker
- dev-DXP-1825-review-UpdateCategoryDataPlugin
- dev-DXP-1681-add-DLQ-support-MVP
- dev-DXP-1580Setidentityofthepushertocurrentuser-2
- dev-DXP-1681-minor-improvements
- dev-DXP-1825-handle-case-of-admin-adding-or-removing-products-from-edited-category
- dev-DXP-1825-cleanup-unify-code-for-get-set-delete-attributes-in-test
- dev-DXP-1824-handle-reindexing-products-that-used-a-deleted-attribute-in-on-save-mode
- dev-DXP-1824-handle-reindexing-products-that-used-a-deleted-attribute-in-mview-mode
- dev-DXP-1830-handle-quantity-reduction-publish-after-purchasing-product
- dev-DXP-1825ReviewViewPlugin
- dev-DXP-1580-add-pusher-auth
- dev-DXP-1580-autoupdate-version-fixes
- dev-DXP-1825-review-AttributeSavePlugin
- dev-DXP-1839Introduceconfigurabilityofusingpricesindex(defaulttofalse)
- dev-DXP-1719-make-non-indexed-price-have-higher-priority
- dev-spike/backup-indexer-modes-before-all-tests-and-restore-after-all-tests
- dev-DXP-1839-compute-indexed-prices
- dev-DXP-1568-validate-produced-JSONs-against-schema-required-by-Accelerator
- dev-DXP-1568ValidateproducedJSONsagainstschemarequiredbyAccelerator
- dev-DXP-1719-introduce-mechanism-to-measure-summary-coverage-of-all-integration-tests
- dev-DXP-1719Improvecoveragemeasurementonserver
- dev-DXP-1719-include-category-path-in-json
- dev-DXP-1672-remove-weak-password-warning-in-test-magento
- dev-DXP-1719Groupallshscriptsintoscriptssubdirectory
- dev-DXP-1719-load-store-level-category-names
- dev-DXP-1719Speedupintegrationtestsbyreducenumberofindexeroperations;removedependenciesfromutilityclasses
- dev-DXP-1719-transparent-cleanups-in-bundle-options-code
- dev-DXP-1719-remove-product-links-from-bundle-product-payload
- dev-DXP-1767-minor-improvements
- dev-DXP-1719-adjust-naming-of-stores-in-tests-to-improve-consistency
- dev-DXP-1767-create-categories-from-import-file
- dev-DXP-1767-create-attributes-from-import-file
- dev-DXP-1767-import-test-products-while-setting-up-local-magento-test-env
- dev-DXP-1719-verify-product-variants-publishing-and-unpublishing-in-various-eligibility-scenarios
- dev-revert-commit
- dev-DXP-1706-avoid-unpublishing-not-eligible-categories-when-category-is-modified
- dev-DXP-1719-use-store-level-attribute-labels-when-publishing-products
- dev-DXP-1719-tighten-json-based-validation-and-improve-configuring-exported-attributes-in-tests-2
- dev-DXP-1719-tighten-json-based-validation-and-improve-configuring-exported-attributes-in-tests
- dev-DXP-1706Mergecategoryselectmodifierclassestoone
- dev-DXP-1706-merge-product-select-modifier-classes-to-one
- dev-DXP-1719-poc-of-bundle-components-products-publish
- dev-DXP-1719-make-sure-edited-attr-is-outputted-to-json-of-products-that-use-it
- dev-DXP-1565-use-common-object-for-entity-ids
- dev-DXP-1713-cleanup-outdated-todos
- dev-DXP-1713-dont-publish-subcategories-and-parents-for-product-categories
- dev-DXP-1706-filter-additionally-loaded-product-ids-by-their-ingestability
- dev-DXP-1706-make-long-integration-test-faster
- dev-DXP-1706-introduce-tool-to-list-all-keys-published-and-unpublished-by-each-test
- dev-DXP-1568-simplify-entity-metadata-classes
- dev-DXP-1568Refactorattributesindexer_2
- dev-DXP-1568Publishseparatedescriptionsalsoforvariants
- dev-DXP-1719-unpublish-products-and-categories-that-were-disabled-in-stores
- dev-DXP-1568-rename-streamx-type-property
- dev-DXP-1719-load-attribute-labels-at-specific-store-levels
- dev-DXP-1706Avoidunpublishingnoteligiblecategorieswhencategoryismodified
- dev-DXP-1706-reduce-unpublishing-categories-not-available-in-current-store-or-website
- dev-DXP-1568-refactor-attributes-indexer
- dev-DXP-1568-publish-data-with-types-and-autogenerated-key-prefixes
- dev-DXP-1672-make-sure-only-variants-from-website-are-published
- dev-DXP-1672-trigger-additional-parent-variants-publishing
- dev-DXP-1568publishbasedonvisibility
- dev-DXP-1565-adjust-integration-tests-to-verify-connector-also-in-enterprise-magento
- dev-DXP-1568-remove-unnecessary-nulling-of-local-vars
- dev-DXP-1568-make-data-providers-add-data-in-place
- dev-DXP-1568-call-common-tests-wide-configuration-actions-just-once
- dev-DXP-1568-publish-swatch-as-part-of-option-value-and-remove-options-list
- dev-DXP-1655-minimize-time-consuming-magento-cache-flush-calls-in-tests
- dev-DXP-1689-use-secure-base-url-for-images
- dev-DXP-1655-speed-up-integration-tests
- dev-DXP-1568-use-object-oriented-attribute-options-handling
- dev-DXP-1672-rename-basic-data-loaders
- dev-DXP-1675-unwrap-and-decode-product-description
- dev-DXP-1568-change-format-of-publishing-attributes-and-options-values
- dev-DXP-1655-more-all-streamx-related-code-to-StreamxClient2
- dev-DXP-1633-automate-creating-stores-for-multistore-tests
- dev-DXP-1633-improve-exception-logging
- dev-DXP-1633-decomplicate-code-for-creating-streamx-client-and-improve-naming
- dev-DXP-1578-execute-mview-reindexing-less-often
- dev-DXP-1633-reduce-number-of-indexer-classes-layers-and-improve-class-naming
- dev-DXP-1568-add-troubleshooting-local-env-readme
- dev-DXP-1633-add-unit-test-for-publishing-big-batch-of-data
- dev-DXP-1633-improve-ingestion-log-messages-and-deleting-data-in-test-preconditions
- dev-DXP-1633-dont-execute-mview-based-indexers-from-cron-if-they-are-currently-in-update-on-save-mode
- dev-DXP-1633-protect-against-possible-freeze-of-streamx-client
- dev-DXP-1633-improve-multiwebsite-test
- dev-DXP-1633-enable-configuring-indexed-stores-at-website-scope
- dev-DXP-1633-add-test-for-publishing-only-categories-belonging-to-current-store
- dev-DXP-1633-make-sure-store-specific-category-data-will-be-selected-and-published
- dev-DXP-1633-make-sure-store-specific-product-data-will-be-selected-and-published
- dev-DXP-1633-skip-publishing-not-active-categories-of-a-product
- dev-DXP-1633-cleanup-code-for-select-modifiers
- dev-DXP-1633-allow-for-product-to-not-have-any-visible-category-in-the-indexed-store
- dev-DXP-1633-tidy-up-select-modifiers
- dev-DXP-1633-adjust-config-value-getters-to-use-scope-as-admin-gui-says
- dev-DXP-1633-unify-declarations-of-store-manager
- dev-DXP-1633-give-IndexableStoresProvider-name-distinct-from-magentos-StoreManager
- dev-DXP-1568-force-value-range-for-batch-indexing-size
- dev-DXP-1568-reduce-layers-while-publishing-and-stop-processing-earlier-if-streamx-not-available
- dev-DXP-1568-unify-connector-configuration-reader-classes
- dev-DXP-1568-improve-documentation-tags
- dev-DXP-1568-async-ingestion-call
- dev-DXP-1568-use-single-class-for-index-definition
- dev-DXP-1568-connector-code-cleanups
- dev-DXP-1568-review-and-remove-done-todos
- dev-DXP-1567-implement-detecting-if-only-relevant-attribute-fields-have-changed-to-republish-products-using-them
- dev-DXP-1567-trigger-publishing-products-that-use-modified-attribute-definition
- dev-DXP-1579-adjust-connector-configuration-regarding-exported-attributes
- dev-DXP-1579-improve-naming-for-main-and-child-products-cfg-classes
- dev-DXP-1577-extend-product-price-data-model
- dev-DXP-1577-publish-attribute-option-swatches
- dev-DXP-1579-make-ProductAttributesProvider-only-be-used-by-product-data-providers
- dev-DXP-1568-remove-loading-tier-prices
- dev-DXP-1580-addagithubhooktoautoupdatetheversionaftereachmergetomain
- dev-DXP-1567-skip-publishing-variants-as-separate-publishes-in-product-indexer
- dev-DXP-1568-remove-es-naming-add-todos-for-uncovered-services
- dev-DXP-1578-document-executing-streamx-indexers-as-cron-jobs
- dev-DXP-1577-shorten-code-for-processing-options-array
- dev-DXP-1567-avoid-loading-all-category-attributes-when-just-one-is-needed
- dev-DXP-1568-allow-skipping-certificate-validation
- dev-DXP-1567-publish-only-parent-product-when-variant-is-edited
- dev-DXP-1567-add-test-for-which-products-are-published-on-variant-or-parent-change
- dev-DXP-1567-avoid-loading-non-product-attributes
- dev-DXP-1568-fix-numbering-in-readme
- dev-DXP-1567-disallow-full-reindex-of-attributes-indexer
- dev-DXP-1567-a-few-small-improvements
- dev-DXP-1605-keep-tests-outside-of-connector-sources
- dev-DXP-1567-skip-sending-attributes-with-no-value
- dev-DXP-1567-make-code-to-load-attribute-definitions-common
- dev-DXP-1566-prepare-new-release
- dev-DXP-1568-exclude-test-classes-from-di-compile
- dev-DXP-1567-configure-debugging-connector-code-without-the-need-to-use-a-web-browser
- dev-DXP-1451-add-test-for-publishing-group-products
- dev-DXP-1451-add-test-for-verifying-add-swatch-setting
- dev-DXP-1451-add-test-for-publishing-bundle-products
- dev-DXP-1568-remove-unused-configuration-settings
- dev-DXP-1566-remove-extra-fields-from-publish-payload-for-configurable-products
- dev-DXP-1566-rename-configurable-child-products-to-variants-and-remove-unused-code
- dev-DXP-1566-use-common-attribute-data-provider-also-for-product-variants
- dev-DXP-1310-readme-for-using-connector-as-a-standard-composer-dependency
- dev-DXP-1568-add-instruction-how-to-debug-connector-code
- dev-DXP-1566-use-common-gallery-provider-also-for-variant-products
- dev-DXP-1566-remove-custom-code-to-load-quantity-for-variants-use-common-dataprovider-instead
- dev-DXP-1566-remove-prices-from-product-variants
- dev-DXP-1566-remove-status-and-visibility-from-required-fields-for-variants
- dev-DXP-1566-remove-datafilter
- dev-DXP-1568-add-product-label-to-published-payload
- dev-DXP-1310-fix-failing-test
- dev-DXP-1451-add-test-for-publishing-product-options
- dev-DXP-1451-a-few-small-code-improvements
- dev-DXP-1451-handle-multivalued-product-attributes
- dev-DXP-1310-improve-overriding-connector-configuration-for-integration-tests
- dev-DXP-1451-improve-indexing-all-product-attributes
- dev-DXP-1310-move-product-select-modifiers-out-of-di.xml
- dev-DXP-1310-move-category-select-modifiers-out-of-di.xml
- dev-DXP-1451-troubleshoot-internal-mview-failures-and-fix-cause
- dev-DXP-1451-stabilize-integration-test-by-adding-product-and-category-assignment-in-transaction
- dev-DXP-1310-bump-connector-version
- dev-DXP-1310-add-readme-how-to-run-streamx-indexers
- dev-DXP-1310-remove-indexers-from-di.xml
- dev-DXP-1451-remove-publishing-downloadable-products
- dev-DXP-1310-rename-setting-to-use_url_key_to_generate_slug
- dev-DXP-1310-rename-setting-to-use_url_key_and_id_to_generate_slug
- dev-DXP-1310-cleanups-in-generating-slugs-for-products-and-categories
- dev-DXP-1451-make-query-for-category-name-and-url-key-universal
- dev-DXP-1451-stabilize-integration-test-by-using-more-reliable-streamx-availability-check
- dev-DXP-1313-add-license-info-to-composer-json
- dev-DXP-1451-publish-also-images-from-attributes-with-full-urls
- dev-DXP-1451-make-product-and-category-key-prefixes-configurable
- dev-DXP-1451-simplify-indexes-configuration
- dev-DXP-1451-add-publishing-product-lang-property
- dev-DXP-1451-merge-product-attribute-provider-classes
- dev-DXP-1451-remove-datafilter-from-di.xml
- dev-DXP-1451-remove-unnecessary-fields-from-final-product-to-be-published
- dev-DXP-1310-change-ports-for-test-magentos-opensearch-and-nginx
- dev-DXP-1310-change-qty-to-quantity
- dev-DXP-1310-change-key-prefixes
- dev-DXP-1310-publish-full-urls-of-images
- dev-DXP-1310-publish-product-categories-in-SxModel
- dev-DXP-1310-group-product-prices-in-prices-array
- dev-DXP-1310-publish-also-parent-category-data-along-with-product
- dev-DXP-1310-load-both-needed-category-attributes-along-with-category
- dev-DXP-1310-remove-unnecessary-code-from-category-provider
- dev-DXP-1310-add-publishing-category-label
- dev-DXP-1655-more-all-streamx-related-code-to-StreamxClient
- dev-DXP-1310-increase-clean-up-after-test
- dev-DXP-1310-publish-isFacet-property-of-attributes
- dev-DXP-1310-avoid-running-streamx-indexers-when-connector-is-disabled
- dev-DXP-1310-convert-main-images-to-SxModel
- dev-DXP-1310-output-images-in-sxmodel
- dev-DXP-1310-remove-di-xml-interface-for-catalog-config
- dev-DXP-1310-remove-unnecessary-di-xml-interfaces
- dev-DXP-1310-remove-counts-from-category-model
- dev-DXP-1310-add-test-for-publishing-product-variants
- dev-DXP-1310-remove-unnecesary-base-product-attributes
- dev-DXP-1310-remove-ProductUrlPathGenerator
- dev-DXP-1310-send-product-attributes-along-with-available-options
- dev-DXP-1310-limit-publishing-attribute-data-to-minimum-fields
- dev-DXP-1310-send-attribute-definitions-along-with-their-values-for-products
- dev-DXP-1310-cleanups-in-code-that-generates-category-dto
- dev-DXP-1310-group-attributes-in-collection-of-product-attributes
This package is not auto-updated.
Last update: 2025-11-21 09:39:31 UTC
README
1. Install StreamX Connector in Magento
cd $MAGENTO_ROOT_DIR bin/composer require streamx/magento-connector-php
Note: if the command asks you for a github access token - just press ENTER
2. Perform steps to enable the Connector's modules in Magento
cd $MAGENTO_ROOT_DIR bin/magento module:enable StreamX_ConnectorCore bin/magento module:enable StreamX_ConnectorCatalog bin/magento cache:clean bin/magento cache:flush bin/magento setup:upgrade bin/magento setup:di:compile
3. Start your StreamX instance (or verify it's already running)
streamx run -f path-to-your-mesh-file
You can find a basic mesh file at src/catalog/test/resources/mesh.yaml
4. Enable and configure StreamX Connector via the Magento Admin page
- Click on
STORESon the left panel - Click
Configurationin theSettingsarea - Expand
STREAMXsection, click onConnectoritem, then expandGeneral Settingssection on the right - Select
Yesfor theEnable StreamX Connectorsetting and click theSave Configbutton - Switch Scope to website and select stores on the
List of stores to reindex - Expand
StreamX Ingestion Settingssection below - Edit the settings you need, or leave the default values
- Click the
Save Configbutton - You can also provide separate values for
StreamX Ingestion Settingsfor each store
5. Verify the Connector by indexing and publishing all categories to StreamX
cd $MAGENTO_ROOT_DIR bin/magento indexer:reindex streamx_category_indexer
6. Verify if the data has been published to StreamX
If you used the src/catalog/test/resources/mesh.yaml to set up your local StreamX instance,
you can verify if the categories were successfully published to StreamX.
To do so, open your StreamX instance's Web Delivery Service endpoint in a web browser and verify the JSON output at a category URL. Sample URL for Category with ID 6 is: http://localhost:8081/cat:6 Note: if you used a different Mesh Yaml file, the URL will be different.