diff --git a/packages/cli/CHANGELOG.md b/packages/cli/CHANGELOG.md index 9b2c9af55..2d473f2a4 100644 --- a/packages/cli/CHANGELOG.md +++ b/packages/cli/CHANGELOG.md @@ -1,5 +1,11 @@ # @openfn/cli +## 1.13.3 + +### Patch Changes + +- 284b889: apollo: add support for events while streaming from apollo + ## 1.13.2 ### Patch Changes diff --git a/packages/cli/package.json b/packages/cli/package.json index 16131d04c..dfadf075d 100644 --- a/packages/cli/package.json +++ b/packages/cli/package.json @@ -1,6 +1,6 @@ { "name": "@openfn/cli", - "version": "1.13.2", + "version": "1.13.3", "description": "CLI devtools for the OpenFn toolchain", "engines": { "node": ">=18", diff --git a/packages/cli/src/apollo/handler.ts b/packages/cli/src/apollo/handler.ts index 8dcbb0bee..111c9f900 100644 --- a/packages/cli/src/apollo/handler.ts +++ b/packages/cli/src/apollo/handler.ts @@ -97,6 +97,7 @@ const callApollo = async ( ) => { return new Promise((resolve) => { const apolloLogger = createLogger('APO', { level: 'debug' }); + const evtLogger = createLogger('EVT', { level: 'debug' }); const url = `${apolloBaseUrl.replace( /^http/, @@ -114,6 +115,8 @@ const callApollo = async ( resolve(evt.data); } else if (evt.event === 'log') { apolloLogger.info(evt.data); + } else if (evt.event === 'event') { + evtLogger.always(evt.type.toUpperCase(), evt.data); } });