Skip to content

Commit

Permalink
Update type def.
Browse files Browse the repository at this point in the history
  • Loading branch information
kj415j45 committed Aug 9, 2023
1 parent 571d129 commit eea27a3
Show file tree
Hide file tree
Showing 6 changed files with 17 additions and 17 deletions.
6 changes: 3 additions & 3 deletions src/Mongodb/Mongodb.ts
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ export class MongoDB extends TestDatabase {
}

// Chunked insert to avoid OOM
async create(data: TestData[]): Promise<void> {
async create(data: Array<TestData>): Promise<void> {
const chunkSize = 100000;
const docs = data.map(transformTestData);
let index = 0;
Expand Down Expand Up @@ -73,7 +73,7 @@ export class MongoDB extends TestDatabase {
lng: Longitude,
lat: Latitude,
maxDistance: number
): Promise<TestData[]> {
): Promise<Array<TestData>> {
const locations = await LocationModel.find(
{
location: {
Expand All @@ -98,7 +98,7 @@ export class MongoDB extends TestDatabase {
lng: Longitude,
lat: Latitude,
maxDistance: number
): Promise<TestData[]> {
): Promise<Array<TestData>> {
const locations = await LocationModel.find(
{
location: {
Expand Down
2 changes: 1 addition & 1 deletion src/Mongodb/Transformer.ts
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ export function transformTestData(data: TestData): Location {
id: data.id,
location: {
type: "Point",
coordinates: [data.lng, data.lat],
coordinates: [+data.lng, +data.lat],
},
};
}
Expand Down
14 changes: 7 additions & 7 deletions src/Redis/Redis.ts
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ import { TestDatabase } from "../TestDatabase";
import { transformLocation, transformTestData } from "./Transformer";
import { Latitude, Longitude } from "../utils";
import { Repository } from "redis-om";
import { locationSchema } from "./Locations";
import { locationSchema, Location } from "./Locations";

export class Redis extends TestDatabase {
redis: any;
Expand Down Expand Up @@ -35,7 +35,7 @@ export class Redis extends TestDatabase {
await this.redis.flushAll();
}

async create(data: TestData[]): Promise<void> {
async create(data: Array<TestData>): Promise<void> {
const docs = data.map(transformTestData);
let index = 0;
while (index < docs.length) {
Expand All @@ -62,7 +62,7 @@ export class Redis extends TestDatabase {
)
.return.first();
return transformLocation(
(location! as any) ?? {
(location! as unknown as Location) ?? {
id: `Out_Of_Range(${closestLimit}km)`,
location: {
longitude: 0,
Expand All @@ -76,29 +76,29 @@ export class Redis extends TestDatabase {
lng: Longitude,
lat: Latitude,
maxDistance: number
): Promise<TestData[]> {
): Promise<Array<TestData>> {
const locations = await this.repository!.search()
.where("location")
.inRadius(
(circle) =>
circle.longitude(lng).latitude(lat).radius(maxDistance).kilometers
)
.return.first();
return (locations as any).map(transformLocation);
return (locations as unknown as Array<Location>).map(transformLocation);
}

async queryC(
lng: Longitude,
lat: Latitude,
maxDistance: number
): Promise<TestData[]> {
): Promise<Array<TestData>> {
const locations = await this.repository!.search()
.where("location")
.inRadius(
(circle) =>
circle.longitude(lng).latitude(lat).radius(maxDistance).kilometers
)
.return.first();
return (locations as any).map(transformLocation);
return (locations as unknown as Array<Location>).map(transformLocation);
}
}
4 changes: 2 additions & 2 deletions src/Redis/Transformer.ts
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ export function transformTestData(data: TestData): Location {
export function transformLocation(location: Location): TestData {
return {
id: location.id,
lng: location.location["longitude"],
lat: location.location["latitude"],
lng: location.location.longitude,
lat: location.location.latitude,
};
}
6 changes: 3 additions & 3 deletions src/StubDatabase.ts
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ export class StubDatabase extends TestDatabase {
async connect(uri?: string | undefined): Promise<void> {}
async disconnect(): Promise<void> {}
async cleanup(): Promise<void> {}
async create(data: TestData[]): Promise<void> {}
async create(data: Array<TestData>): Promise<void> {}
async prepare(): Promise<void> {}
async usageReport(): Promise<object> {
return {};
Expand All @@ -27,7 +27,7 @@ export class StubDatabase extends TestDatabase {
lng: number,
lat: number,
maxDistance: number
): Promise<TestData[]> {
): Promise<Array<TestData>> {
return [
{
id: "stub",
Expand All @@ -41,7 +41,7 @@ export class StubDatabase extends TestDatabase {
lng: number,
lat: number,
maxDistance: number
): Promise<TestData[]> {
): Promise<Array<TestData>> {
return [
{
id: "stub",
Expand Down
2 changes: 1 addition & 1 deletion src/TestDatabase.ts
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ export abstract class TestDatabase {
* Initialize DB with data
* @param data
*/
abstract create(data: TestData[]): Promise<void>;
abstract create(data: Array<TestData>): Promise<void>;

/**
* Prepare DB for query
Expand Down

0 comments on commit eea27a3

Please sign in to comment.