mirror of
https://github.com/RevenueCat/purchases-ios
synced 2026-11-10 22:45:55 +05:45
66 lines
2.2 KiB
Swift
66 lines
2.2 KiB
Swift
|
//
|
||
|
|
// Copyright RevenueCat Inc. All Rights Reserved.
|
||
|
|
//
|
||
|
|
// Licensed under the MIT License (the "License");
|
||
|
|
// you may not use this file except in compliance with the License.
|
||
|
|
// You may obtain a copy of the License at
|
||
|
|
//
|
||
|
|
// https://opensource.org/licenses/MIT
|
||
|
|
//
|
||
|
|
// DefaultCheckpointWorkflowResolver+StepEvents.swift
|
||
|
|
//
|
||
|
|
// Created by Rosie Watson on 10/30/26.
|
||
|
|
|
||
|
|
import Foundation
|
||
|
|
|
||
|
|
extension DefaultCheckpointWorkflowResolver {
|
||
|
|
|
||
|
|
/// A step with no UI is the whole workflow: it starts when it is entered and completes once what it serves has
|
||
|
|
/// loaded. A step that can't be served never completes.
|
||
|
|
static func trackingStepEvents(
|
||
|
|
for step: WorkflowStep,
|
||
|
|
in workflowData: WorkflowDataResult,
|
||
|
|
traceID: String,
|
||
|
|
resolving: () async -> CheckpointResolution
|
||
|
|
) async -> (resolution: CheckpointResolution, stepEvents: [WorkflowEvent]) {
|
||
|
|
var stepEvents: [WorkflowEvent] = [.stepStarted(
|
||
|
|
.init(),
|
||
|
|
Self.stepEventData(for: step, in: workflowData, traceID: traceID, entryReason: .start)
|
||
|
|
)]
|
||
|
|
|
||
|
|
let resolution = await resolving()
|
||
|
|
|
||
|
|
switch resolution {
|
||
|
|
case .matchedOffering, .matchedAd:
|
||
|
|
stepEvents.append(.stepCompleted(
|
||
|
|
.init(),
|
||
|
|
Self.stepEventData(for: step, in: workflowData, traceID: traceID, entryReason: nil)
|
||
|
|
))
|
||
|
|
case .matchedWorkflow, .noAction:
|
||
|
|
break
|
||
|
|
}
|
||
|
|
|
||
|
|
return (resolution, stepEvents)
|
||
|
|
}
|
||
|
|
|
||
|
|
private static func stepEventData(
|
||
|
|
for step: WorkflowStep,
|
||
|
|
in workflowData: WorkflowDataResult,
|
||
|
|
traceID: String,
|
||
|
|
entryReason: WorkflowEvent.EntryReason?
|
||
|
|
) -> WorkflowEvent.Data {
|
||
|
|
return .init(
|
||
|
|
workflowId: workflowData.workflow.id,
|
||
|
|
stepId: step.id,
|
||
|
|
traceId: traceID,
|
||
|
|
stepType: step.type,
|
||
|
|
entryReason: entryReason?.rawValue,
|
||
|
|
isFirstStep: true,
|
||
|
|
isLastStep: true,
|
||
|
|
workflowBlobRef: workflowData.workflowBlobRef,
|
||
|
|
fallbackOriginalStepId: step.fallbackOriginalStepId,
|
||
|
|
experiment: step.experimentData(workflowBlobRef: workflowData.workflowBlobRef)
|
||
|
|
)
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|