source-appsflyer: new connector

.github/workflows/python.yaml

@@ -64,6 +64,7 @@ on:
       - "source-gong/**"
       - "source-greenhouse-native/**"
       - "source-calendly/**"
+      - "source-appsflyer/**"
 
   pull_request:
     branches: [main]
@@ -129,6 +130,7 @@ on:
       - "source-gong/**"
       - "source-greenhouse-native/**"
       - "source-calendly/**"
+      - "source-appsflyer/**"
 
 concurrency:
   group: ${{ github.workflow }}-${{ github.ref }}
@@ -380,6 +382,10 @@ jobs:
             type: capture
             version: v1
             usage_rate: "1.0"
+          - name: source-appsflyer
+            type: capture
+            version: v1
+            usage_rate: "1.0"
 
     steps:
       - uses: actions/checkout@v4

source-appsflyer/Dockerfile

@@ -0,0 +1 @@
+../estuary-cdk/webhook-capture.Dockerfile

source-appsflyer/VERSION

@@ -0,0 +1 @@
+v1

source-appsflyer/acmeCo/daily_geo_aggregate_report.schema.yaml

@@ -0,0 +1,49 @@
+$defs:
+  Meta:
+    properties:
+      op:
+        default: u
+        description: 'Operation type (c: Create, u: Update, d: Delete)'
+        enum:
+        - c
+        - u
+        - d
+        title: Op
+        type: string
+      row_id:
+        default: -1
+        description: Row ID of the Document, counting up from zero, or -1 if not known
+        title: Row Id
+        type: integer
+      app_id:
+        default: ''
+        description: AppsFlyer App ID this row was fetched for
+        title: App Id
+        type: string
+    title: Meta
+    type: object
+additionalProperties: true
+properties:
+  _meta:
+    $ref: '#/$defs/Meta'
+    description: Document metadata
+  Date:
+    title: Date
+    type: string
+  Country:
+    title: Country
+    type: string
+  Media Source (pid):
+    title: Media Source (Pid)
+    type: string
+  Campaign (c):
+    title: Campaign (C)
+    type: string
+required:
+- Date
+- Country
+- Media Source (pid)
+- Campaign (c)
+title: AggGeoDailyReport
+type: object
+x-infer-schema: true

source-appsflyer/acmeCo/flow.yaml

@@ -0,0 +1,65 @@
+collections:
+  acmeCo/daily_geo_aggregate_report:
+    schema: daily_geo_aggregate_report.schema.yaml
+    key:
+    - /_meta/app_id
+    - /Date
+    - /Country
+    - /Media Source (pid)
+    - /Campaign (c)
+  acmeCo/in-app-event:
+    schema: in-app-event.schema.yaml
+    key:
+    - /_meta/estuary_id
+  acmeCo/install:
+    schema: install.schema.yaml
+    key:
+    - /_meta/estuary_id
+  acmeCo/install-in-app-event:
+    schema: install-in-app-event.schema.yaml
+    key:
+    - /_meta/estuary_id
+  acmeCo/organic-install:
+    schema: organic-install.schema.yaml
+    key:
+    - /_meta/estuary_id
+  acmeCo/organic-install-in-app-event:
+    schema: organic-install-in-app-event.schema.yaml
+    key:
+    - /_meta/estuary_id
+  acmeCo/organic-reinstall:
+    schema: organic-reinstall.schema.yaml
+    key:
+    - /_meta/estuary_id
+  acmeCo/postback:
+    schema: postback.schema.yaml
+    key:
+    - /_meta/estuary_id
+  acmeCo/postbacks-copy:
+    schema: postbacks-copy.schema.yaml
+    key:
+    - /_meta/estuary_id
+  acmeCo/re-attribution:
+    schema: re-attribution.schema.yaml
+    key:
+    - /_meta/estuary_id
+  acmeCo/re-attribution-in-app-event:
+    schema: re-attribution-in-app-event.schema.yaml
+    key:
+    - /_meta/estuary_id
+  acmeCo/re-download:
+    schema: re-download.schema.yaml
+    key:
+    - /_meta/estuary_id
+  acmeCo/re-engagement:
+    schema: re-engagement.schema.yaml
+    key:
+    - /_meta/estuary_id
+  acmeCo/re-engagement-in-app-event:
+    schema: re-engagement-in-app-event.schema.yaml
+    key:
+    - /_meta/estuary_id
+  acmeCo/reinstall:
+    schema: reinstall.schema.yaml
+    key:
+    - /_meta/estuary_id

source-appsflyer/acmeCo/in-app-event.schema.yaml

@@ -0,0 +1,90 @@
+$defs:
+  JsonValue: {}
+  Meta:
+    properties:
+      op:
+        default: u
+        description: 'Operation type (c: Create, u: Update, d: Delete)'
+        enum:
+        - c
+        - u
+        - d
+        title: Op
+        type: string
+      row_id:
+        default: -1
+        description: Row ID of the Document, counting up from zero, or -1 if not known
+        title: Row Id
+        type: integer
+      webhookId:
+        title: Webhookid
+        type: string
+      receivedAt:
+        title: Receivedat
+        type: string
+      headers:
+        additionalProperties:
+          $ref: '#/$defs/JsonValue'
+        title: Headers
+        type: object
+      reqPath:
+        title: Reqpath
+        type: string
+      pathParams:
+        anyOf:
+        - additionalProperties:
+            type: string
+          type: object
+        - type: 'null'
+        default: null
+        title: Pathparams
+      queryParams:
+        anyOf:
+        - additionalProperties:
+            type: string
+          type: object
+        - type: 'null'
+        default: null
+        title: Queryparams
+      estuary_id:
+        default: ''
+        description: The surrogate key generated from characteristic fields
+        title: Estuary Id
+        type: string
+    required:
+    - headers
+    - reqPath
+    title: Meta
+    type: object
+properties:
+  _meta:
+    $ref: '#/$defs/Meta'
+    description: Document metadata
+  app_id:
+    title: App Id
+    type: string
+  appsflyer_id:
+    title: Appsflyer Id
+    type: string
+  event_name:
+    title: Event Name
+    type: string
+  event_time:
+    title: Event Time
+    type: string
+  event_value:
+    title: Event Value
+    type: string
+  api_version:
+    title: Api Version
+    type: string
+required:
+- app_id
+- appsflyer_id
+- event_name
+- event_time
+- event_value
+- api_version
+title: AppsFlyerWebhookDocument
+type: object
+x-infer-schema: true

source-appsflyer/acmeCo/install-in-app-event.schema.yaml

@@ -0,0 +1,90 @@
+$defs:
+  JsonValue: {}
+  Meta:
+    properties:
+      op:
+        default: u
+        description: 'Operation type (c: Create, u: Update, d: Delete)'
+        enum:
+        - c
+        - u
+        - d
+        title: Op
+        type: string
+      row_id:
+        default: -1
+        description: Row ID of the Document, counting up from zero, or -1 if not known
+        title: Row Id
+        type: integer
+      webhookId:
+        title: Webhookid
+        type: string
+      receivedAt:
+        title: Receivedat
+        type: string
+      headers:
+        additionalProperties:
+          $ref: '#/$defs/JsonValue'
+        title: Headers
+        type: object
+      reqPath:
+        title: Reqpath
+        type: string
+      pathParams:
+        anyOf:
+        - additionalProperties:
+            type: string
+          type: object
+        - type: 'null'
+        default: null
+        title: Pathparams
+      queryParams:
+        anyOf:
+        - additionalProperties:
+            type: string
+          type: object
+        - type: 'null'
+        default: null
+        title: Queryparams
+      estuary_id:
+        default: ''
+        description: The surrogate key generated from characteristic fields
+        title: Estuary Id
+        type: string
+    required:
+    - headers
+    - reqPath
+    title: Meta
+    type: object
+properties:
+  _meta:
+    $ref: '#/$defs/Meta'
+    description: Document metadata
+  app_id:
+    title: App Id
+    type: string
+  appsflyer_id:
+    title: Appsflyer Id
+    type: string
+  event_name:
+    title: Event Name
+    type: string
+  event_time:
+    title: Event Time
+    type: string
+  event_value:
+    title: Event Value
+    type: string
+  api_version:
+    title: Api Version
+    type: string
+required:
+- app_id
+- appsflyer_id
+- event_name
+- event_time
+- event_value
+- api_version
+title: AppsFlyerWebhookDocument
+type: object
+x-infer-schema: true