@servicetitan/acquisition-functions
Advanced tools
Comparing version 0.11.0 to 0.12.0
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.closeConnection = exports.openConnection = exports.setupProperties = void 0; | ||
exports.closeConnection = exports.openConnection = void 0; | ||
exports.setupProperties = setupProperties; | ||
const mongodb_1 = require("mongodb"); | ||
@@ -27,3 +28,2 @@ const mock_1 = require("./mock"); | ||
} | ||
exports.setupProperties = setupProperties; | ||
const url = `mongodb://${process.env.MONGO_HOSTNAME ?? 'localhost'}:27017`; | ||
@@ -30,0 +30,0 @@ const mongoClient = new mongodb_1.MongoClient(url, { |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.getFilterFetcherProcessor = void 0; | ||
exports.getFilterFetcherProcessor = getFilterFetcherProcessor; | ||
const calc_filter_count_1 = require("./calc-filter-count"); | ||
@@ -106,2 +106,1 @@ function getFilterFetcherProcessor(db) { | ||
} | ||
exports.getFilterFetcherProcessor = getFilterFetcherProcessor; |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.propertyUseGroupProcessorAggregate = exports.getPropertyUseGroupProcessor = void 0; | ||
exports.getPropertyUseGroupProcessor = getPropertyUseGroupProcessor; | ||
exports.propertyUseGroupProcessorAggregate = propertyUseGroupProcessorAggregate; | ||
const utils_1 = require("../utils/utils"); | ||
@@ -76,3 +77,2 @@ const getPropertiesCollection = async (db) => { | ||
} | ||
exports.getPropertyUseGroupProcessor = getPropertyUseGroupProcessor; | ||
async function propertyUseGroupProcessorAggregate(db) { | ||
@@ -106,2 +106,1 @@ const collection = await getPropertiesCollection(db); | ||
} | ||
exports.propertyUseGroupProcessorAggregate = propertyUseGroupProcessorAggregate; |
@@ -17,3 +17,3 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.configureProcessor = void 0; | ||
exports.configureProcessor = configureProcessor; | ||
const filter_fetcher_1 = require("./filter-fetcher"); | ||
@@ -29,5 +29,4 @@ const fix_property_use_1 = require("./fix-property-use"); | ||
} | ||
exports.configureProcessor = configureProcessor; | ||
__exportStar(require("./fix-property-use"), exports); | ||
__exportStar(require("./property-assessorlastsaledate-converter"), exports); | ||
__exportStar(require("./filter-fetcher"), exports); |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.propertiesAssessorLastSaleDateAggregate = exports.getAssessorLastSaleDateProcessor = void 0; | ||
exports.getAssessorLastSaleDateProcessor = getAssessorLastSaleDateProcessor; | ||
exports.propertiesAssessorLastSaleDateAggregate = propertiesAssessorLastSaleDateAggregate; | ||
const utils_1 = require("../utils/utils"); | ||
@@ -67,3 +68,2 @@ const getPropertiesCollection = async (db) => { | ||
} | ||
exports.getAssessorLastSaleDateProcessor = getAssessorLastSaleDateProcessor; | ||
async function propertiesAssessorLastSaleDateAggregate(db) { | ||
@@ -107,2 +107,1 @@ const collection = await getPropertiesCollection(db); | ||
} | ||
exports.propertiesAssessorLastSaleDateAggregate = propertiesAssessorLastSaleDateAggregate; |
import type { WithId } from 'mongodb'; | ||
export declare type Property = WithId<{ | ||
export type Property = WithId<{ | ||
attomid: number; | ||
@@ -235,3 +235,3 @@ fulladdress: string; | ||
} | ||
export declare type Filter = WithId<{ | ||
export type Filter = WithId<{ | ||
zipcode: string; | ||
@@ -238,0 +238,0 @@ propertyusegroup: Group[]; |
@@ -13,9 +13,9 @@ import { Property } from '../types'; | ||
streetname: string; | ||
streetpredirection?: string | undefined; | ||
streetpostdirection?: string | undefined; | ||
streetpredirection?: string; | ||
streetpostdirection?: string; | ||
streetsuffix: string; | ||
secondarynumber?: number | undefined; | ||
secondarynumber?: number; | ||
secondarydesignator: string; | ||
extrasecondarynumber?: number | undefined; | ||
extrasecondarydesignator?: string | undefined; | ||
extrasecondarynumber?: number; | ||
extrasecondarydesignator?: string; | ||
cityname: string; | ||
@@ -22,0 +22,0 @@ stateabbreviation: string; |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.capitalizeFirstLetter = exports.FilterNameValidator = exports.convertStringToDate = exports.convertToZipString = exports.isEmptyField = exports.UNKNOWN = exports.SEPARATOR_CHARACTER = void 0; | ||
exports.convertStringToDate = exports.convertToZipString = exports.isEmptyField = exports.UNKNOWN = exports.SEPARATOR_CHARACTER = void 0; | ||
exports.FilterNameValidator = FilterNameValidator; | ||
exports.capitalizeFirstLetter = capitalizeFirstLetter; | ||
exports.SEPARATOR_CHARACTER = '___'; | ||
@@ -32,3 +34,2 @@ exports.UNKNOWN = 'unknown'; | ||
} | ||
exports.FilterNameValidator = FilterNameValidator; | ||
function capitalizeFirstLetter(val) { | ||
@@ -40,2 +41,1 @@ if (!val) { | ||
} | ||
exports.capitalizeFirstLetter = capitalizeFirstLetter; |
@@ -7,3 +7,3 @@ export interface ResultsMeta { | ||
} | ||
declare type ProcessInput = [from: string, to: string] | string; | ||
type ProcessInput = [from: string, to: string] | string; | ||
export declare function zipProcessor(workers: number, processorFn: (zip: string, errors: Set<string>) => Promise<ResultsMeta>): { | ||
@@ -10,0 +10,0 @@ getProcessor: () => AsyncGenerator<ResultsMeta | ResultsMeta[], void, unknown> | null; |
"use strict"; | ||
/* eslint-disable no-await-in-loop, require-atomic-updates */ | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.zipProcessor = void 0; | ||
exports.zipProcessor = zipProcessor; | ||
const utils_1 = require("./utils/utils"); | ||
@@ -88,2 +88,1 @@ function zipProcessor(workers, processorFn) { | ||
} | ||
exports.zipProcessor = zipProcessor; |
{ | ||
"name": "@servicetitan/acquisition-functions", | ||
"version": "0.11.0", | ||
"version": "0.12.0", | ||
"description": "", | ||
@@ -30,3 +30,3 @@ "main": "./dist/index.js", | ||
}, | ||
"gitHead": "f9ea8fb7e8b10f8d969e7afa52ffb9bb76de07b7" | ||
"gitHead": "a80589bd64eb965e97ae60aa28232ea60b5ed19c" | ||
} |
85297
28
2361