Class IntegrationDataService

Constructors

constructor

new IntegrationDataService(): IntegrationDataService
Returns IntegrationDataService

Accessors

Provider

get Provider(): IMetadataProvider
Returns IMetadataProvider
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:263
set Provider(value: IMetadataProvider | null): void
Set the metadata provider this service should use. Components should call this after injection.
Parameters
- value: IMetadataProvider | null
Returns void
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:259

Methods

ApplyAll

ApplyAll(
companyIntegrationID: string,
sourceObjectNames: string[],
): Promise<ApplyAllResult>
Full automatic "Apply All" flow: pipeline + entity maps + field maps + sync
Parameters
- companyIntegrationID: string
- sourceObjectNames: string[]
Returns Promise<ApplyAllResult>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:688

ApplyAllBatch

ApplyAllBatch(
companyIntegrationID: string,
sourceObjects: SourceObjectSelectionInput[],
): Promise<ApplyAllResult>
Batch Apply All: schema + entity maps + field maps + sync via IntegrationApplyAllBatch
Parameters
- companyIntegrationID: string
- sourceObjects: SourceObjectSelectionInput[]
Returns Promise<ApplyAllResult>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:670

ApplySchemaBatch

ApplySchemaBatch(
    items: {
        CompanyIntegrationID: string;
        Objects: SchemaPreviewObjectInput[];
    }[],
): Promise<
    {
        APIRestarted?: boolean;
        GitCommitSuccess?: boolean;
        Items?: {
            CompanyIntegrationID: string;
            Message: string;
            Success: boolean;
            Warnings?: string[];
        }[];
        Message: string;
        Steps?: {
            DurationMs: number;
            Message: string;
            Name: string;
            Status: string;
        }[];
        Success: boolean;
    },
>
Batch apply schema for multiple connectors — one RSU pipeline run
Parameters
- items: { CompanyIntegrationID: string; Objects: SchemaPreviewObjectInput[] }[]
Returns Promise<
    {
        APIRestarted?: boolean;
        GitCommitSuccess?: boolean;
        Items?: {
            CompanyIntegrationID: string;
            Message: string;
            Success: boolean;
            Warnings?: string[];
        }[];
        Message: string;
        Steps?: {
            DurationMs: number;
            Message: string;
            Name: string;
            Status: string;
        }[];
        Success: boolean;
    },
>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:655

ApplySchemaForNewMaps

ApplySchemaForNewMaps(
companyIntegrationID: string,
objects: SchemaPreviewObjectInput[],
): Promise<{ Message: string; Success: boolean }>
Execute the RSU pipeline for new entity maps — introspects, generates DDL, runs full pipeline
Parameters
- companyIntegrationID: string
- objects: SchemaPreviewObjectInput[]
Returns Promise<{ Message: string; Success: boolean }>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:645

AutoMapSchema

AutoMapSchema(
    companyIntegrationID: string,
    schemaName: string,
    direction?: "Bidirectional" | "Pull" | "Push",
): Promise<
    {
        EntityMapsCreated: number;
        Errors: string[];
        FieldMapsCreated: number;
    },
>
Auto-map all entities in a given schema to a company integration. For each entity in the schema that doesn't already have an entity map, creates an entity map (ExternalObjectName = BaseTable) and 1:1 field maps for every non-system column. Returns the count of maps created.
Parameters
- companyIntegrationID: string
- schemaName: string
- direction: "Bidirectional" | "Pull" | "Push" = 'Pull'
Returns Promise<
    {
        EntityMapsCreated: number;
        Errors: string[];
        FieldMapsCreated: number;
    },
>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:881

ComputeKPIs

ComputeKPIs(summaries: IntegrationSummary[]): IntegrationKPIs
Parameters
- summaries: IntegrationSummary[]
Returns IntegrationKPIs
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:413

ComputeRelativeTime

ComputeRelativeTime(dateStr: string | null): string
Parameters
- dateStr: string | null
Returns string
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:452

CreateEntityMap

CreateEntityMap(
    params: {
        CompanyIntegrationID: string;
        ConflictResolution?: "Manual" | "DestWins" | "MostRecent" | "SourceWins";
        DeleteBehavior?: "DoNothing" | "HardDelete" | "SoftDelete";
        EntityID: string;
        ExternalObjectLabel?: string;
        ExternalObjectName: string;
        Priority?: number;
        SyncDirection?: "Bidirectional" | "Pull" | "Push";
    },
): Promise<MJCompanyIntegrationEntityMapEntity | null>
Parameters
- params: {
      CompanyIntegrationID: string;
      ConflictResolution?: "Manual" | "DestWins" | "MostRecent" | "SourceWins";
      DeleteBehavior?: "DoNothing" | "HardDelete" | "SoftDelete";
      EntityID: string;
      ExternalObjectLabel?: string;
      ExternalObjectName: string;
      Priority?: number;
      SyncDirection?: "Bidirectional" | "Pull" | "Push";
  }
Returns Promise<MJCompanyIntegrationEntityMapEntity | null>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:458

CreateFieldMap

CreateFieldMap(
    params: {
        DestinationFieldLabel?: string;
        DestinationFieldName: string;
        Direction?: "Both" | "DestToSource" | "SourceToDest";
        EntityMapID: string;
        IsKeyField?: boolean;
        IsRequired?: boolean;
        Priority?: number;
        SourceFieldLabel?: string;
        SourceFieldName: string;
        TransformPipeline?: string | null;
    },
): Promise<MJCompanyIntegrationFieldMapEntity | null>
Parameters
- params: {
      DestinationFieldLabel?: string;
      DestinationFieldName: string;
      Direction?: "Both" | "DestToSource" | "SourceToDest";
      EntityMapID: string;
      IsKeyField?: boolean;
      IsRequired?: boolean;
      Priority?: number;
      SourceFieldLabel?: string;
      SourceFieldName: string;
      TransformPipeline?: string | null;
  }
Returns Promise<MJCompanyIntegrationFieldMapEntity | null>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:515

DeleteEntityMap

DeleteEntityMap(entityMapID: string): Promise<boolean>
Parameters
- entityMapID: string
Returns Promise<boolean>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:490

DeleteFieldMap

DeleteFieldMap(fieldMapID: string): Promise<boolean>
Parameters
- fieldMapID: string
Returns Promise<boolean>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:550

DiscoverFields

DiscoverFields(
companyIntegrationID: string,
objectName: string,
): Promise<DiscoveryResult<DiscoveredFieldResult[]>>
Discover fields on a specific external object
Parameters
- companyIntegrationID: string
- objectName: string
Returns Promise<DiscoveryResult<DiscoveredFieldResult[]>>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:606

DiscoverObjects

DiscoverObjects(
companyIntegrationID: string,
): Promise<DiscoveryResult<DiscoveredObjectResult[]>>
Discover external objects available for a company integration
Parameters
- companyIntegrationID: string
Returns Promise<DiscoveryResult<DiscoveredObjectResult[]>>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:600

FormatDuration

FormatDuration(ms: number | null): string
Parameters
- ms: number | null
Returns string
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:440

GetDefaultConfig

GetDefaultConfig(companyIntegrationID: string): Promise<DefaultConfigResult>
Get the connector's default configuration for quick setup
Parameters
- companyIntegrationID: string
Returns Promise<DefaultConfigResult>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:703

GetDestinationRecordCount

GetDestinationRecordCount(
entityID: string,
provider?: IRunViewProvider | null,
): Promise<number>
Get a count of records in the destination MJ entity
Parameters
- entityID: string
- Optionalprovider: IRunViewProvider | null
Returns Promise<number>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:764

GetLastSyncForEntity

GetLastSyncForEntity(
    companyIntegrationID: string,
    entityID: string,
    provider?: IRunViewProvider | null,
): Promise<
    | {
        EndedAt: string
        | null;
        StartedAt: string | null;
        Status: string;
        TotalRecords: number;
    }
    | null,
>
Get the most recent run that touched a given entity
Parameters
- companyIntegrationID: string
- entityID: string
- Optionalprovider: IRunViewProvider | null
Returns Promise<
    | {
        EndedAt: string
        | null;
        StartedAt: string | null;
        Status: string;
        TotalRecords: number;
    }
    | null,
>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:783

ListSourceObjects

ListSourceObjects(
companyIntegrationID: string,
): Promise<DiscoveryResult<SourceObjectListItem[]>>
Lists every source object the external system exposes — thin catalog for the picker. No per-object describe; that runs later in ApplyAllBatch.
Parameters
- companyIntegrationID: string
Returns Promise<DiscoveryResult<SourceObjectListItem[]>>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:682

LoadDailyRecordCounts

LoadDailyRecordCounts(
days?: number,
provider?: IRunViewProvider | null,
): Promise<DailyRecordCount[]>
Parameters
- days: number = 7
- Optionalprovider: IRunViewProvider | null
Returns Promise<DailyRecordCount[]>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:395

LoadEntityFields

LoadEntityFields(
    entityID: string,
    _provider?: IRunViewProvider | null,
): Promise<
    { ID: string; IsRequired: boolean; Name: string; Type: string }[],
>
Load entity fields for a given entity (for field mapping destination picker)
Parameters
- entityID: string
- Optional_provider: IRunViewProvider | null
Returns Promise<{ ID: string; IsRequired: boolean; Name: string; Type: string }[]>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:588

LoadEntityMapCounts

LoadEntityMapCounts(
_provider?: IRunViewProvider | null,
): Promise<Map<string, number>>
Load entity map count per company integration (used by Overview cards)
Parameters
- Optional_provider: IRunViewProvider | null
Returns Promise<Map<string, number>>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:972

LoadMJEntities

LoadMJEntities(
_provider?: IRunViewProvider | null,
): Promise<{ ID: string; Name: string }[]>
Load available MJ entities for mapping target selection
Parameters
- Optional_provider: IRunViewProvider | null
Returns Promise<{ ID: string; Name: string }[]>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:580

LoadRecentRuns

LoadRecentRuns(
limit?: number,
provider?: IRunViewProvider | null,
): Promise<ActivityFeedItem[]>
Parameters
- limit: number = 20
- Optionalprovider: IRunViewProvider | null
Returns Promise<ActivityFeedItem[]>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:381

LoadRunDetails

LoadRunDetails(
runID: string,
provider?: IRunViewProvider | null,
): Promise<RunDetailRow[]>
Parameters
- runID: string
- Optionalprovider: IRunViewProvider | null
Returns Promise<RunDetailRow[]>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:316

LoadRunHistory

LoadRunHistory(
    companyIntegrationID: string,
    limit?: number,
    provider?: IRunViewProvider | null,
): Promise<IntegrationRunRow[]>
Parameters
- companyIntegrationID: string
- limit: number = 10
- Optionalprovider: IRunViewProvider | null
Returns Promise<IntegrationRunRow[]>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:302

LoadSchedules

LoadSchedules(
_provider?: IRunViewProvider | null,
): Promise<MJCompanyIntegrationEntity[]>
Load schedule data for all company integrations (includes new scheduling fields)
Parameters
- Optional_provider: IRunViewProvider | null
Returns Promise<MJCompanyIntegrationEntity[]>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:860

LoadSchemas

LoadSchemas(): string[]
Load available schemas (for auto-map schema picker)

Returns string[]
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:962

LoadSourceTypes

LoadSourceTypes(
_provider?: IRunViewProvider | null,
): Promise<MJIntegrationSourceTypeEntity[]>
Parameters
- Optional_provider: IRunViewProvider | null
Returns Promise<MJIntegrationSourceTypeEntity[]>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:376

LoadWatermarks

LoadWatermarks(
companyIntegrationID: string,
_provider?: IRunViewProvider | null,
): Promise<MJCompanyIntegrationSyncWatermarkEntity[]>
Load sync watermarks for a specific company integration's entity maps
Parameters
- companyIntegrationID: string
- Optional_provider: IRunViewProvider | null
Returns Promise<MJCompanyIntegrationSyncWatermarkEntity[]>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:866

PreviewDestinationData

PreviewDestinationData(
    entityID: string,
    limit?: number,
    provider?: IRunViewProvider | null,
): Promise<Record<string, string | number | boolean | null>[]>
Preview destination data by loading a few records from the target entity
Parameters
- entityID: string
- limit: number = 5
- Optionalprovider: IRunViewProvider | null
Returns Promise<Record<string, string | number | boolean | null>[]>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:736

PreviewSourceData

PreviewSourceData(
    companyIntegrationID: string,
    objectName: string,
    limit?: number,
): Promise<Record<string, string | number | boolean | null>[]>
Preview source data from the external system via connector's FetchChanges
Parameters
- companyIntegrationID: string
- objectName: string
- limit: number = 5
Returns Promise<Record<string, string | number | boolean | null>[]>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:715

RunSchemaPipeline

RunSchemaPipeline(
companyIntegrationID: string,
entityMap: EntityMapRow,
): Promise<{ Message?: string; Success: boolean }>
Execute the full RSU pipeline for an integration entity map
Parameters
- companyIntegrationID: string
- entityMap: EntityMapRow
Returns Promise<{ Message?: string; Success: boolean }>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:622

RunSync

RunSync(
companyIntegrationID: string,
fullSync?: boolean,
): Promise<{ Message: string; Success: boolean }>
Run an integration sync via the "Run Integration Sync" action
Parameters
- companyIntegrationID: string
- fullSync: boolean = false
Returns Promise<{ Message: string; Success: boolean }>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:840

SchemaPreview

SchemaPreview(
    companyIntegrationID: string,
    objects: SchemaPreviewObjectInput[],
    platform?: string,
): Promise<SchemaPreviewResult>
Generate DDL preview for creating tables from discovered objects
Parameters
- companyIntegrationID: string
- objects: SchemaPreviewObjectInput[]
- platform: string = 'sqlserver'
Returns Promise<SchemaPreviewResult>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:612

StartSync

StartSync(
companyIntegrationID: string,
): Promise<{ Message: string; RunID?: string; Success: boolean }>
Start a sync for a company integration
Parameters
- companyIntegrationID: string
Returns Promise<{ Message: string; RunID?: string; Success: boolean }>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:697

StartSyncWithDirection

StartSyncWithDirection(
    companyIntegrationID: string,
    fullSync: boolean,
    syncDirection: "Bidirectional" | "Pull" | "Push",
): Promise<{ Message: string; Success: boolean }>
Run a directional sync directly via the GraphQL StartSync mutation.
Parameters
- companyIntegrationID: string
- fullSync: boolean
- syncDirection: "Bidirectional" | "Pull" | "Push"
Returns Promise<{ Message: string; Success: boolean }>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:829

TestConnection

TestConnection(
companyIntegrationID: string,
): Promise<ConnectionTestGraphQLResult>
Test connection to the external system
Parameters
- companyIntegrationID: string
Returns Promise<ConnectionTestGraphQLResult>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:709

ToggleEntityMapEnabled

ToggleEntityMapEnabled(entityMapID: string, enabled: boolean): Promise<boolean>
Parameters
- entityMapID: string
- enabled: boolean
Returns Promise<boolean>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:497

UpdateFieldMap

UpdateFieldMap(
    fieldMapID: string,
    updates: {
        DestinationFieldName?: string;
        Direction?: "Both" | "DestToSource" | "SourceToDest";
        IsKeyField?: boolean;
        IsRequired?: boolean;
        SourceFieldName?: string;
        Status?: "Active" | "Inactive";
        TransformPipeline?: string | null;
    },
): Promise<boolean>
Parameters
- fieldMapID: string
- updates: {
      DestinationFieldName?: string;
      Direction?: "Both" | "DestToSource" | "SourceToDest";
      IsKeyField?: boolean;
      IsRequired?: boolean;
      SourceFieldName?: string;
      Status?: "Active" | "Inactive";
      TransformPipeline?: string | null;
  }
Returns Promise<boolean>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:557

UpdateSyncDirection

UpdateSyncDirection(
entityMapID: string,
direction: "Bidirectional" | "Pull" | "Push",
): Promise<boolean>
Parameters
- entityMapID: string
- direction: "Bidirectional" | "Pull" | "Push"
Returns Promise<boolean>
- Defined in Angular/Explorer/dashboards/src/Integration/services/integration-data.service.ts:505

Class IntegrationDataService

Index

Constructors

Accessors

Methods

Constructors

constructor

Returns IntegrationDataService

Accessors

Provider

Returns IMetadataProvider

Parameters

Returns void

Methods

ApplyAll

Parameters

Returns Promise<ApplyAllResult>

ApplyAllBatch

Parameters

Returns Promise<ApplyAllResult>

ApplySchemaBatch

Parameters

Returns Promise< { APIRestarted?: boolean; GitCommitSuccess?: boolean; Items?: { CompanyIntegrationID: string; Message: string; Success: boolean; Warnings?: string[]; }[]; Message: string; Steps?: { DurationMs: number; Message: string; Name: string; Status: string; }[]; Success: boolean; },>

ApplySchemaForNewMaps

Parameters

Returns Promise<{ Message: string; Success: boolean }>

AutoMapSchema

Parameters

Returns Promise< { EntityMapsCreated: number; Errors: string[]; FieldMapsCreated: number; },>

ComputeKPIs

Parameters

Returns IntegrationKPIs

ComputeRelativeTime

Parameters

Returns string

CreateEntityMap

Parameters

Returns Promise<MJCompanyIntegrationEntityMapEntity | null>

CreateFieldMap

Parameters

Returns Promise<MJCompanyIntegrationFieldMapEntity | null>

DeleteEntityMap

Parameters

Returns Promise<boolean>

DeleteFieldMap

Parameters

Returns Promise<boolean>

DiscoverFields

Parameters

Returns Promise<DiscoveryResult<DiscoveredFieldResult[]>>

DiscoverObjects

Parameters

Returns Promise<DiscoveryResult<DiscoveredObjectResult[]>>

FormatDuration

Parameters

Returns string

GetDefaultConfig

Parameters

Returns Promise<DefaultConfigResult>

GetDestinationRecordCount

Parameters

Returns Promise<number>

GetLastSyncForEntity

Parameters

Returns Promise< | { EndedAt: string | null; StartedAt: string | null; Status: string; TotalRecords: number; } | null,>

ListSourceObjects

Parameters

Returns Promise<DiscoveryResult<SourceObjectListItem[]>>

LoadDailyRecordCounts

Parameters

Returns Promise<DailyRecordCount[]>

LoadEntityFields

Parameters

Returns Promise<{ ID: string; IsRequired: boolean; Name: string; Type: string }[]>

LoadEntityMapCounts

Parameters

Returns Promise<Map<string, number>>

LoadEntityMaps

Parameters

Returns Promise<MJCompanyIntegrationEntityMapEntity[]>

Returns Promise<
{
APIRestarted?: boolean;
GitCommitSuccess?: boolean;
Items?: {
CompanyIntegrationID: string;
Message: string;
Success: boolean;
Warnings?: string[];
}[];
Message: string;
Steps?: {
DurationMs: number;
Message: string;
Name: string;
Status: string;
}[];
Success: boolean;
},
>

Returns Promise<
{
EntityMapsCreated: number;
Errors: string[];
FieldMapsCreated: number;
},
>

Returns Promise<
| {
EndedAt: string
| null;
StartedAt: string | null;
Status: string;
TotalRecords: number;
}
| null,
>