elioria-sst-x
    Preparing search index...

    Class DrizzleOfficialCaRepository

    Implements

    • OfficialCaRepositoryPort
    Index
    constructor
    db CA_BATCH CHANGE_BATCH GEN_BATCH REP_BATCH STD_BATCH UPDATE_BATCH
    countCas createImportRun getAllCurrentStateProjections getByCaNumber getChangesByCaNumber getChangesByImportRun getCurrentStateByCaNumber getGenerationsByCaNumber getImportRunByHash getImportRunById getLatestPublishedImportRun getRecentHighAttentionChanges getReportsForGeneration getStandardsForReport persistChangeEvents publishSnapshot searchByCaNumber searchByEquipment searchByManufacturer searchPaged tryAcquireImportLock updateImportRun
    db: PostgresJsDatabase<packages/db/src/schema> & {}

    The db value.

    CA_BATCH: 500
    CHANGE_BATCH: 500
    GEN_BATCH: 200
    REP_BATCH: 500
    STD_BATCH: 2000
    UPDATE_BATCH: 1000
    • Generated

      Executes countCas.

      Returns Promise<number>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, run countCas.

      Behavior: Async; returns a value; invokes this.db .select({ count: sql<number>COUNT(*)::int }) .from.

    • Generated

      Updates data through createImportRun.

      Parameters

      • data: CreateImportRunData

        The data value.

      Returns Promise<OfficialCaImportRun>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, change data through createImportRun.

      Behavior: Async; accepts data; returns a value; invokes this.db .insert(officialCaImportRun) .values({ source: data..

    • Generated

      Returns the result of getAllCurrentStateProjections.

      Returns Promise<Map<number, OfficialCaCurrentState>>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, retrieve data through getAllCurrentStateProjections.

      Behavior: Async; returns a value; invokes this.db.select().from.

    • Generated

      Returns the result of getByCaNumber.

      Parameters

      • caNumber: number

        The caNumber value.

      Returns Promise<OfficialCa | null>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, retrieve data through getByCaNumber.

      Behavior: Async; accepts caNumber; returns a value; invokes this.db .select() .from(officialCa) .where(eq(officialCa.caN.

    • Generated

      Returns the result of getChangesByCaNumber.

      Parameters

      • caNumber: number

        The caNumber value.

      • limit: number = 50

        The limit value.

      Returns Promise<PersistedChangeEvent[]>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, retrieve data through getChangesByCaNumber.

      Behavior: Async; accepts caNumber and limit; returns a value; invokes this.db .select() .from(officialCaChange) .where(eq(official.

    • Generated

      Returns the result of getChangesByImportRun.

      Parameters

      • importRunId: string

        The importRunId value.

      Returns Promise<PersistedChangeEvent[]>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, retrieve data through getChangesByImportRun.

      Behavior: Async; accepts importRunId; returns a value; invokes this.db .select() .from(officialCaChange) .where(eq(official.

    • Generated

      Returns the result of getCurrentStateByCaNumber.

      Parameters

      • caNumber: number

        The caNumber value.

      Returns Promise<OfficialCaCurrentState | null>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, retrieve data through getCurrentStateByCaNumber.

      Behavior: Async; accepts caNumber; returns a value; invokes this.getByCaNumber.

    • Generated

      Returns the result of getGenerationsByCaNumber.

      Parameters

      • caNumber: number

        The caNumber value.

      Returns Promise<OfficialCaGeneration[]>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, retrieve data through getGenerationsByCaNumber.

      Behavior: Async; accepts caNumber; returns a value; invokes this.getByCaNumber.

    • Generated

      Returns the result of getImportRunByHash.

      Parameters

      • rawFileHash: string

        The rawFileHash value.

      Returns Promise<OfficialCaImportRun | null>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, retrieve data through getImportRunByHash.

      Behavior: Async; accepts rawFileHash; returns a value; invokes this.db .select() .from(officialCaImportRun) .where(eq(offic.

    • Generated

      Returns the result of getImportRunById.

      Parameters

      • id: string

        The id value.

      Returns Promise<OfficialCaImportRun | null>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, retrieve data through getImportRunById.

      Behavior: Async; accepts id; returns a value; invokes this.db .select() .from(officialCaImportRun) .where(eq(offic.

    • Generated

      Returns the result of getLatestPublishedImportRun.

      Returns Promise<OfficialCaImportRun | null>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, retrieve data through getLatestPublishedImportRun.

      Behavior: Async; returns a value; invokes this.db .select() .from(officialCaImportRun) .where(eq(offic.

    • Generated

      Returns the result of getRecentHighAttentionChanges.

      Parameters

      • limit: number = 50

      Returns Promise<PersistedChangeEvent[]>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, retrieve data through getRecentHighAttentionChanges.

      Behavior: Async; accepts limit; returns a value; invokes this.db .select() .from(officialCaChange) .where(sql${offic. @param limit The limit` value.

    • Generated

      Returns the result of getReportsForGeneration.

      Parameters

      • generationId: string

        The generationId value.

      Returns Promise<OfficialCaReport[]>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, retrieve data through getReportsForGeneration.

      Behavior: Async; accepts generationId; returns a value; invokes this.db .select() .from(officialCaReport) .where.

    • Generated

      Returns the result of getStandardsForReport.

      Parameters

      • reportId: string

        The reportId value.

      Returns Promise<OfficialCaStandard[]>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, retrieve data through getStandardsForReport.

      Behavior: Async; accepts reportId; returns a value; invokes this.db .select() .from(officialCaStandard) .where.

    • Generated

      Executes persistChangeEvents.

      Parameters

      • events: OfficialCaChangeEvent[]

        The events value.

      • previousImportRunId: string

        The previousImportRunId value.

      • currentImportRunId: string

        The currentImportRunId value.

      • detectedAt: Date

        The detectedAt value.

      Returns Promise<void>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, run persistChangeEvents.

      Behavior: Async; accepts events and previousImportRunId and currentImportRunId and detectedAt; returns a value; invokes events.slice.

    • Generated

      Executes publishSnapshot.

      Parameters

      • snapshot: StagedSnapshot

        The snapshot value.

      Returns Promise<void>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, run publishSnapshot.

      Behavior: Async; accepts snapshot; returns a value; invokes this.db.transaction.

    • Generated

      Executes searchByCaNumber.

      Parameters

      • caNumber: number

        The caNumber value.

      • limit: number = 20

        The limit value.

      Returns Promise<OfficialCaCurrentState[]>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, run searchByCaNumber.

      Behavior: Async; accepts caNumber and limit; returns a value; invokes String.

    • Generated

      Executes searchByEquipment.

      Parameters

      • text: string

        The text value.

      • limit: number = 20

        The limit value.

      Returns Promise<OfficialCaCurrentState[]>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, run searchByEquipment.

      Behavior: Async; accepts text and limit; returns a value; invokes text.slice.

    • Generated

      Executes searchByManufacturer.

      Parameters

      • cnpj: string

        The cnpj value.

      • limit: number = 20

        The limit value.

      Returns Promise<OfficialCaCurrentState[]>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, run searchByManufacturer.

      Behavior: Async; accepts cnpj and limit; returns a value; invokes this.db .select({ officialCaId: officialCaGeneration.officia.

    • Generated

      Executes searchPaged.

      Parameters

      • query: OfficialCaSearchQuery

        The query value.

      Returns Promise<PagedResult<OfficialCaCurrentState>>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, run searchPaged.

      Behavior: Async; accepts query; returns a value; invokes Math.max.

    • Generated

      Executes tryAcquireImportLock.

      Returns Promise<boolean>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, run tryAcquireImportLock.

      Behavior: Async; returns a value; invokes this.db.execute.

    • Generated

      Updates data through updateImportRun.

      Parameters

      • id: string

        The id value.

      • data: UpdateImportRunData

        The data value.

      Returns Promise<void>

      The function result.

      Objective: In module packages/db/src/repositories/official-ca.repository.ts, change data through updateImportRun.

      Behavior: Async; accepts id and data; returns a value; invokes Object.keys.

    Settings
    Member Visibility

    On This Page
    Constructors
    Properties
    Methods