connectors to sources

package.json

@@ -5,11 +5,11 @@
   "workspaces": [
     "packages/*",
     "packages/config/*",
-    "packages/connectors/*",
     "packages/clients/*",
     "packages/destinations/core/*",
     "packages/destinations/node/*",
     "packages/destinations/web/*",
+    "packages/sources/*",
     "packages/stacks/*"
   ],
   "scripts": {

packages/connectors/datalayer/README.md → packages/sources/datalayer/README.md

@@ -1,11 +1,11 @@
-# dataLayer connector for walkerOS
+# dataLayer source for walkerOS
 
 Made to be used with
 [walker.js](https://www.npmjs.com/package/@elbwalker/walker.js) from
 [walkerOS](https://github.com/elbwalker/walkerOS).
 
 More detailed information and examples can be found in the
-[documentation](https://www.elbwalker.com/docs/connectors/datalayer).
+[documentation](https://www.elbwalker.com/docs/sources/datalayer).
 
 ## 🤓 Usage
 

packages/connectors/datalayer/package.json → packages/sources/datalayer/package.json

@@ -1,6 +1,6 @@
 {
-  "name": "@elbwalker/connector-datalayer",
-  "description": "datalayer connector for walkerOS",
+  "name": "@elbwalker/source-datalayer",
+  "description": "datalayer source for walkerOS",
   "version": "0.0.1",
   "license": "MIT",
   "main": "dist/index.js",
@@ -28,7 +28,7 @@
   },
   "repository": {
     "url": "git+https://github.com/elbwalker/walkerOS.git",
-    "directory": "packages/connectors/datalayer"
+    "directory": "packages/sources/datalayer"
   },
   "author": "elbwalker <[email protected]>",
   "homepage": "https://github.com/elbwalker/walkerOS#readme",

packages/connectors/datalayer/src/__tests__/commands.test.ts → packages/sources/datalayer/src/__tests__/commands.test.ts

@@ -1,6 +1,6 @@
 /* eslint-disable prefer-rest-params */
 import type { DataLayer } from '../types';
-import { connectorDataLayer } from '..';
+import { sourceDataLayer } from '..';
 
 describe('commands', () => {
   const elb = jest.fn(); //.mockImplementation(console.log);
@@ -16,7 +16,7 @@ describe('commands', () => {
   });
 
   test('consent default', () => {
-    connectorDataLayer({ elb });
+    sourceDataLayer({ elb });
 
     gtag('consent', 'default', {
       ad_user_data: 'denied',
@@ -30,7 +30,7 @@ describe('commands', () => {
   });
 
   test('consent update', () => {
-    connectorDataLayer({ elb, mapping: { foo: {} } });
+    sourceDataLayer({ elb, mapping: { foo: {} } });
 
     gtag('consent', 'update', {
       ad_user_data: 'denied',
@@ -47,7 +47,7 @@ describe('commands', () => {
   });
 
   test('set', () => {
-    connectorDataLayer({
+    sourceDataLayer({
       elb,
       mapping: {
         'set campaign': {

packages/connectors/datalayer/src/__tests__/index.test.ts → packages/sources/datalayer/src/__tests__/index.test.ts

@@ -1,8 +1,8 @@
 /* eslint-disable prefer-rest-params */
 import type { DataLayer } from '../types';
-import { connectorDataLayer } from '..';
+import { sourceDataLayer } from '..';
 
-describe('connector dataLayer', () => {
+describe('source dataLayer', () => {
   const elb = jest.fn(); //.mockImplementation(console.log);
   let dataLayer: DataLayer;
 
@@ -19,11 +19,11 @@ describe('connector dataLayer', () => {
     window.dataLayer = undefined;
     expect(window.dataLayer).toBeUndefined();
 
-    connectorDataLayer();
-    connectorDataLayer({});
+    sourceDataLayer();
+    sourceDataLayer({});
     expect(window.dataLayer).toBeUndefined();
 
-    connectorDataLayer({ elb });
+    sourceDataLayer({ elb });
     expect(Array.isArray(window.dataLayer)).toBe(true);
     expect(window.dataLayer!.length).toBe(0);
   });
@@ -32,14 +32,14 @@ describe('connector dataLayer', () => {
     const originalPush = dataLayer.push;
     expect(originalPush).toBe(dataLayer.push);
 
-    connectorDataLayer({ elb });
+    sourceDataLayer({ elb });
     expect(originalPush).not.toBe(dataLayer!.push);
   });
 
   test('config dataLayer', () => {
     const dataLayer: DataLayer = [];
 
-    connectorDataLayer({ elb, dataLayer, name: 'foo' });
+    sourceDataLayer({ elb, dataLayer, name: 'foo' });
     expect(window.foo).toBeUndefined(); // Prefer dataLayer over name
     dataLayer.push({ event: 'foo' });
     expect(elb).toHaveBeenCalledTimes(1);
@@ -48,18 +48,18 @@ describe('connector dataLayer', () => {
   test('config name', () => {
     expect(window.foo).toBeUndefined();
 
-    connectorDataLayer({ elb, name: 'foo' });
+    sourceDataLayer({ elb, name: 'foo' });
     expect(Array.isArray(window.foo)).toBe(true);
   });
 
   test('original arguments', () => {
-    connectorDataLayer({ elb, name: 'foo' });
+    sourceDataLayer({ elb, name: 'foo' });
     dataLayer.push('foo');
     expect(dataLayer).toEqual(['foo']);
   });
 
   test('push', () => {
-    connectorDataLayer({ elb });
+    sourceDataLayer({ elb });
     dataLayer.push({ event: 'foo' });
     expect(elb).toHaveBeenCalledTimes(1);
     expect(elb).toHaveBeenCalledWith({
@@ -71,7 +71,7 @@ describe('connector dataLayer', () => {
   });
 
   test('prefix', () => {
-    connectorDataLayer({ elb, prefix: 'foo' });
+    sourceDataLayer({ elb, prefix: 'foo' });
     dataLayer.push({ event: 'bar baz' });
     expect(elb).toHaveBeenCalledWith(
       expect.objectContaining({
@@ -83,7 +83,7 @@ describe('connector dataLayer', () => {
   test('existing events', () => {
     dataLayer.push({ event: 'add_to_cart' });
     dataLayer.push({ event: 'purchase' });
-    connectorDataLayer({ elb });
+    sourceDataLayer({ elb });
 
     expect(elb).toHaveBeenCalledTimes(2);
   });
@@ -102,7 +102,7 @@ describe('connector dataLayer', () => {
       }),
     ];
 
-    connectorDataLayer({ elb, dataLayer });
+    sourceDataLayer({ elb, dataLayer });
 
     gtag('event', 'another_arg', {
       bar: 'baz',
@@ -147,7 +147,7 @@ describe('connector dataLayer', () => {
       args[1].push('newElement');
     });
 
-    connectorDataLayer({ elb });
+    sourceDataLayer({ elb });
     dataLayer.push(originalObj, originalArr);
     expect(dataLayer[0]).toStrictEqual({});
     expect(dataLayer[1]).toStrictEqual([]);
@@ -158,7 +158,7 @@ describe('connector dataLayer', () => {
   test('duplicate prevention', () => {
     const processedEvents = new Set<string>();
     processedEvents.add('foo');
-    connectorDataLayer({ elb, processedEvents });
+    sourceDataLayer({ elb, processedEvents });
 
     dataLayer.push({ event: 'foo', id: 'foo' });
     expect(elb).toHaveBeenCalledTimes(0);
@@ -190,7 +190,7 @@ describe('connector dataLayer', () => {
       throw new Error();
     });
 
-    connectorDataLayer(elb);
+    sourceDataLayer(elb);
     dataLayer.push('foo');
     expect(elb).toThrow();
     expect(mockOrg).toHaveBeenCalledTimes(1);

packages/connectors/datalayer/src/__tests__/mapping.test.ts → packages/sources/datalayer/src/__tests__/mapping.test.ts

@@ -1,7 +1,7 @@
 import type { WalkerOS } from '@elbwalker/types';
 import { clone } from '@elbwalker/utils';
 import { gtagToObj } from '../mapping';
-import { connectorDataLayer } from '..';
+import { sourceDataLayer } from '..';
 
 describe('mapping', () => {
   const elb = jest.fn(); //.mockImplementation(console.log);
@@ -31,7 +31,7 @@ describe('mapping', () => {
   beforeEach(() => {});
 
   test('mapping name', () => {
-    const { dataLayer } = connectorDataLayer({
+    const { dataLayer } = sourceDataLayer({
       elb,
       mapping: {
         foo: {
@@ -55,7 +55,7 @@ describe('mapping', () => {
   });
 
   test('mapping ignore', () => {
-    const { dataLayer } = connectorDataLayer({
+    const { dataLayer } = sourceDataLayer({
       elb,
       mapping: {
         foo: {
@@ -69,7 +69,7 @@ describe('mapping', () => {
   });
 
   test('mapping foo', () => {
-    const { dataLayer } = connectorDataLayer({
+    const { dataLayer } = sourceDataLayer({
       elb,
       mapping: {
         foo: {
@@ -148,7 +148,7 @@ describe('mapping', () => {
   });
 
   test('mapping add_to_cart', () => {
-    const { dataLayer } = connectorDataLayer({
+    const { dataLayer } = sourceDataLayer({
       elb,
       mapping: {
         add_to_cart: {
@@ -199,7 +199,7 @@ describe('mapping', () => {
   });
 
   test('mapping purchase', () => {
-    const { dataLayer } = connectorDataLayer({
+    const { dataLayer } = sourceDataLayer({
       elb,
       mapping: {
         purchase: {

packages/connectors/datalayer/src/index.ts → packages/sources/datalayer/src/index.ts

@@ -3,7 +3,7 @@ import { intercept, push } from './push';
 
 export * as ConnectorDataLayer from './types';
 
-export function connectorDataLayer(
+export function sourceDataLayer(
   partialConfig: Partial<Config> = {},
 ): Config | undefined {
   const { elb, prefix = 'dataLayer' } = partialConfig;
@@ -42,4 +42,4 @@ export function connectorDataLayer(
   return config;
 }
 
-export default connectorDataLayer;
+export default sourceDataLayer;

packages/connectors/gcp/README.md → packages/sources/gcp/README.md

@@ -1,10 +1,10 @@
-# GCP connector for walkerOS
+# GCP source for walkerOS
 
 Made to be used with
 [node client](https://www.npmjs.com/package/@elbwalker/client-node) from
 [walkerOS](https://github.com/elbwalker/walkerOS).
 
 More detailed information and examples can be found in the
-[documentation](https://www.elbwalker.com/docs/connectors/gcp).
+[documentation](https://www.elbwalker.com/docs/sources/gcp).
 
 ## 🤓 Usage

packages/connectors/gcp/package.json → packages/sources/gcp/package.json

@@ -1,6 +1,6 @@
 {
-  "name": "@elbwalker/connector-gcp",
-  "description": "GCP connector for walkerOS",
+  "name": "@elbwalker/source-gcp",
+  "description": "GCP source for walkerOS",
   "version": "0.0.1",
   "license": "MIT",
   "main": "dist/index.js",
@@ -29,7 +29,7 @@
   },
   "repository": {
     "url": "git+https://github.com/elbwalker/walkerOS.git",
-    "directory": "packages/connectors/gcp"
+    "directory": "packages/sources/gcp"
   },
   "author": "elbwalker <[email protected]>",
   "homepage": "https://github.com/elbwalker/walkerOS#readme",

packages/connectors/gcp/src/__tests__/index.test.ts → packages/sources/gcp/src/__tests__/index.test.ts

@@ -1,7 +1,7 @@
 import type { Request as GCPRequest } from '@google-cloud/functions-framework';
-import { connectorGCPHttpFunction } from '..';
+import { sourceGCPHttpFunction } from '..';
 
-describe('connector GCP', () => {
+describe('source GCP', () => {
   const request: GCPRequest = {
     get: (header: string) => {
       return {
@@ -21,7 +21,7 @@ describe('connector GCP', () => {
   beforeEach(() => {});
 
   test('basic', async () => {
-    expect(await connectorGCPHttpFunction(request)).toStrictEqual({
+    expect(await sourceGCPHttpFunction(request)).toStrictEqual({
       city: 'Hamburg',
       country: 'DE',
       encoding: 'gzip',
@@ -34,10 +34,10 @@ describe('connector GCP', () => {
   });
 
   test('anonymizeIp', async () => {
-    const first = await connectorGCPHttpFunction(request, {
+    const first = await sourceGCPHttpFunction(request, {
       anonymizeIp: true,
     });
-    const second = await connectorGCPHttpFunction(request, {
+    const second = await sourceGCPHttpFunction(request, {
       anonymizeIp: false,
     });
 
@@ -46,7 +46,7 @@ describe('connector GCP', () => {
   });
 
   test('mapping', async () => {
-    const context = await connectorGCPHttpFunction(request, {
+    const context = await sourceGCPHttpFunction(request, {
       mapping: {
         origin: 'foo',
         'X-Real-Ip': false,

packages/connectors/gcp/src/index.ts → packages/sources/gcp/src/index.ts

@@ -5,7 +5,7 @@ import { anonymizeIP, isDefined } from '@elbwalker/utils';
 
 export * as ConnectorGCP from './types';
 
-export async function connectorGCPHttpFunction(
+export async function sourceGCPHttpFunction(
   request: GCPRequest,
   options: HttpFunction = {},
 ): Promise<Request.Context> {