+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 | 1x +1x + +2x + + | import Container from "typedi";
+import { LocationService } from "../services/locationService";
+
+export const dataSources = () => ({
+ locationService: Container.get(LocationService)
+}); |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| datasources.ts | +
+
+ |
+ 100% | +5/5 | +100% | +0/0 | +100% | +1/1 | +100% | +3/3 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| dataSources | +
+
+ |
+ 100% | +5/5 | +100% | +0/0 | +100% | +1/1 | +100% | +3/3 | +
| resolvers | +
+
+ |
+ 100% | +6/6 | +100% | +2/2 | +100% | +1/1 | +100% | +6/6 | +
| resolvers/coordinates | +
+
+ |
+ 100% | +2/2 | +100% | +0/0 | +100% | +1/1 | +100% | +2/2 | +
| schema | +
+
+ |
+ 100% | +17/17 | +100% | +4/4 | +100% | +2/2 | +100% | +17/17 | +
| services | +
+
+ |
+ 100% | +23/23 | +100% | +5/5 | +100% | +2/2 | +100% | +20/20 | +
| utils | +
+
+ |
+ 100% | +8/8 | +100% | +0/0 | +100% | +0/0 | +100% | +8/8 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| query.ts | +
+
+ |
+ 100% | +2/2 | +100% | +0/0 | +100% | +1/1 | +100% | +2/2 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 | 1x + +2x + + | export class CoordinatesQuery {
+ public async getCoordinates(parent: any, args: any, {dataSources}: any, info: any){
+ return await dataSources.locationService.getCoordinates(args.address);
+ }
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| resolvers.ts | +
+
+ |
+ 100% | +6/6 | +100% | +2/2 | +100% | +1/1 | +100% | +6/6 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 | 1x +1x + +1x + +2x + + + + + +1x + +1x + + + + + + + | import { NonEmptyString } from '../schema/customScalars';
+import { CoordinatesQuery } from './coordinates/query';
+
+const CoordinatesOrError = {
+ __resolveType(obj: any){
+ return obj.code ?
+ 'Error' :
+ 'Coordinates';
+ }
+}
+
+const Query = new CoordinatesQuery();
+
+export const resolvers = {
+ NonEmptyString: NonEmptyString,
+
+ Query,
+ CoordinatesOrError
+}
+
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 | 2x + + +2x + + + +3x +1x + +2x +1x + + +1x + + +7x +1x + +6x +1x + + +5x + + + | import { GraphQLScalarType } from "graphql";
+
+
+export const NonEmptyString = new GraphQLScalarType({
+ name: 'NonEmptyString',
+ description: 'Non empty string',
+ serialize: (value: unknown): string => {
+ if (typeof value !== 'string') {
+ throw <Error>{message: 'Wrong value type', name: 'WRONG_VALUE_TYPE'};
+ }
+ if (value === '') {
+ throw <Error>{message: `Value can't be empty`, name: 'VALUE_NOT_EMPTY'};
+ }
+
+ return value
+ },
+ parseValue: (value: unknown): string => {
+ if (typeof value !== 'string') {
+ throw <Error>{message: 'Wrong value type', name: 'WRONG_VALUE_TYPE'};
+ }
+ if (value === '') {
+ throw <Error>{message: `Value can't be empty`, name: 'VALUE_NOT_EMPTY'};
+ }
+
+ return value
+ },
+
+ }); |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| customScalars.ts | +
+
+ |
+ 100% | +12/12 | +100% | +4/4 | +100% | +2/2 | +100% | +12/12 | +
| schema.ts | +
+
+ |
+ 100% | +5/5 | +100% | +0/0 | +100% | +0/0 | +100% | +5/5 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 | 1x +1x +1x + +1x +1x + + | import path from 'path';
+import {readFileSync} from 'fs';
+import {gql} from 'apollo-server'
+
+const schema = readFileSync(path.join(__dirname, './schema.graphql'));
+export const typeDefs = gql`
+ ${schema}
+` |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| locationService.ts | +
+
+ |
+ 100% | +23/23 | +100% | +5/5 | +100% | +2/2 | +100% | +20/20 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 | 2x +2x +2x + +2x +2x + + +2x +5x +5x + + + +6x +6x +6x + + + + +6x + +6x + +6x + +6x +2x + +2x + +2x + + + + + +4x + +4x + + + + + + + + + + + | import { Logger } from "@aws-lambda-powertools/logger";
+import {Client, Status} from "@googlemaps/google-maps-services-js";
+import {DataSource} from 'apollo-datasource';
+import { responsePathAsArray } from "graphql";
+import { Service } from "typedi";
+import config from "../configs/config";
+
+@Service()
+export class LocationService extends DataSource {
+ constructor(private googleClient: Client, private logger: Logger){
+ super();
+ }
+
+ public async getCoordinates(address: string) {
+ this.logger.debug(`locationService.getCoordinates called with address: ${address}`);
+ try {
+ let params = {
+ address: address,
+ key: config.googleMapsKey!
+ };
+
+ this.logger.debug(`Sending request to googlde geocode api...`);
+
+ var repsonse = await this.googleClient.geocode({params});
+
+ this.logger.debug(`Got response from google geocode api...`);
+
+ if(repsonse.status === 200 && repsonse.data.status == Status.OK && repsonse.data.results?.length > 0){
+ const locationData = repsonse.data.results[0].geometry.location;
+
+ this.logger.info(`Valid response from google geocode service: ${JSON.stringify(locationData)}`);
+
+ return {
+ latitude: locationData.lat,
+ longitude: locationData.lng
+ }
+ }
+ else{
+ this.logger.error(`Location not found against address: ${address}`);
+
+ return {
+ code: 'LOCATION_NOT_FOUND',
+ message: 'Unable to find coordinates for given address',
+ }
+ }
+ } catch (error) {
+ /* istanbul ignore next */
+ this.logger.error(`locationService.getCoordinates ended up in exception. Error: ${error}`);
+ }
+
+ }
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 | 2x +2x + +2x +2x +2x +2x + + + +2x +2x + + + + +2x + + + + + + + + + + | import dotenv from 'dotenv';
+import path from 'path'
+
+var envPath = '';
+const env = process.env.NODE_ENV?.trimEnd();
+if(env == 'development' || env == 'test')
+ envPath = path.join(__dirname, `../../${env}.env`);
+else
+EenvPath = path.join(__dirname, `../${env}.env`);
+
+const envFound = dotenv.config({path: envPath});
+Iif (envFound.error) {
+
+ throw new Error(`⚠️ Couldn't find .env file. ⚠️ path: ${envPath} | env: ${env}`);
+}
+
+export default {
+ port: parseInt(process.env.PORT!, 10),
+
+ googleMapsKey: process.env.GOOGLE_MAPS_KEY,
+
+ logs: {
+ level: process.env.LOG_LEVEL || 'ERROR',
+ },
+
+ appName: process.env.APP_NAME || 'location-Service'
+}; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| config.ts | +
+
+ |
+ 81.81% | +9/11 | +66.66% | +6/9 | +100% | +0/0 | +81.81% | +9/11 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 | 1x +1x + +2x + + | import Container from "typedi";
+import { LocationService } from "../services/locationService";
+
+export const dataSources = () => ({
+ locationService: Container.get(LocationService)
+}); |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| datasources.ts | +
+
+ |
+ 100% | +5/5 | +100% | +0/0 | +100% | +1/1 | +100% | +3/3 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| query.ts | +
+
+ |
+ 100% | +2/2 | +100% | +0/0 | +100% | +1/1 | +100% | +2/2 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 | 1x + +2x + + | export class CoordinatesQuery {
+ public async getCoordinates(parent: any, args: any, {dataSources}: any, info: any){
+ return await dataSources.locationService.getCoordinates(args.address);
+ }
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| resolvers.ts | +
+
+ |
+ 100% | +6/6 | +100% | +2/2 | +100% | +1/1 | +100% | +6/6 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 | 1x +1x + +1x +1x + +2x + + + + +1x + + + + + | import { NonEmptyString } from '../schema/customScalars';
+import { CoordinatesQuery } from './coordinates/query';
+
+const Query = new CoordinatesQuery();
+const CoordinatesOrError = {
+ __resolveType(obj: any){
+ return obj.code ?
+ 'Error' :
+ 'Coordinates';
+ }
+}
+export const resolvers = {
+ NonEmptyString: NonEmptyString,
+
+ Query,
+ CoordinatesOrError
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 | 2x + + +2x + + + +3x +1x + +2x +1x + + +1x + + +7x +1x + +6x +1x + + +5x + + + | import { GraphQLScalarType } from "graphql";
+
+
+export const NonEmptyString = new GraphQLScalarType({
+ name: 'NonEmptyString',
+ description: 'Non empty string',
+ serialize: (value: unknown): string => {
+ if (typeof value !== 'string') {
+ throw <Error>{message: 'Wrong value type', name: 'WRONG_VALUE_TYPE'};
+ }
+ if (value === '') {
+ throw <Error>{message: `Value can't be empty`, name: 'VALUE_NOT_EMPTY'};
+ }
+
+ return value
+ },
+ parseValue: (value: unknown): string => {
+ if (typeof value !== 'string') {
+ throw <Error>{message: 'Wrong value type', name: 'WRONG_VALUE_TYPE'};
+ }
+ if (value === '') {
+ throw <Error>{message: `Value can't be empty`, name: 'VALUE_NOT_EMPTY'};
+ }
+
+ return value
+ },
+
+ }); |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| customScalars.ts | +
+
+ |
+ 100% | +12/12 | +100% | +4/4 | +100% | +2/2 | +100% | +12/12 | +
| schema.ts | +
+
+ |
+ 100% | +5/5 | +100% | +0/0 | +100% | +0/0 | +100% | +5/5 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 | 1x +1x +1x + +1x +1x + + | import path from 'path';
+import {readFileSync} from 'fs';
+import {gql} from 'apollo-server'
+
+const schema = readFileSync(path.join(__dirname, './schema.graphql'));
+export const typeDefs = gql`
+ ${schema}
+` |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| locationService.ts | +
+
+ |
+ 100% | +23/23 | +100% | +5/5 | +100% | +2/2 | +100% | +20/20 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 | 2x +2x +2x + +2x +2x + + +2x +5x +5x + + + +6x +6x +6x + + + + +6x + +6x + +6x + +6x +2x + +2x + +2x + + + + + +4x + +4x + + + + + + + + + + + | import { Logger } from "@aws-lambda-powertools/logger";
+import {Client, Status} from "@googlemaps/google-maps-services-js";
+import {DataSource} from 'apollo-datasource';
+import { responsePathAsArray } from "graphql";
+import { Service } from "typedi";
+import config from "../configs/config";
+
+@Service()
+export class LocationService extends DataSource {
+ constructor(private googleClient: Client, private logger: Logger){
+ super();
+ }
+
+ public async getCoordinates(address: string) {
+ this.logger.debug(`locationService.getCoordinates called with address: ${address}`);
+ try {
+ let params = {
+ address: address,
+ key: config.googleMapsKey!
+ };
+
+ this.logger.debug(`Sending request to googlde geocode api...`);
+
+ var repsonse = await this.googleClient.geocode({params});
+
+ this.logger.debug(`Got response from google geocode api...`);
+
+ if(repsonse.status === 200 && repsonse.data.status == Status.OK && repsonse.data.results?.length > 0){
+ const locationData = repsonse.data.results[0].geometry.location;
+
+ this.logger.info(`Valid response from google geocode service: ${JSON.stringify(locationData)}`);
+
+ return {
+ latitude: locationData.lat,
+ longitude: locationData.lng
+ }
+ }
+ else{
+ this.logger.error(`Location not found against address: ${address}`);
+
+ return {
+ code: 'LOCATION_NOT_FOUND',
+ message: 'Unable to find coordinates for given address',
+ }
+ }
+ } catch (error) {
+ /* istanbul ignore next */
+ this.logger.error(`locationService.getCoordinates ended up in exception. Error: ${error}`);
+ }
+
+ }
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 | 1x +1x + +1x +1x +1x +1x +1x + + +1x + + + + + + + + + + + + + + + + + + + + | import { Logger } from "@aws-lambda-powertools/logger";
+import { ApolloError } from "apollo-server";
+import { GraphQLError } from "graphql";
+import Container from "typedi";
+import config from "../configs/config";
+import { dataSources } from "../dataSources/datasources";
+import { resolvers } from "../resolvers/resolvers";
+import { typeDefs } from "../schema/schema";
+
+/* istanbul ignore next */
+export const buildApolloServerConfig = (): any => {
+ return {
+ typeDefs,
+ resolvers,
+ dataSources,
+ debug: config.logs.level === 'debug',
+ formatError: (err: GraphQLError) =>
+ {
+ if(err.extensions.code == 'INTERNAL_SERVER_ERROR'){
+ var logger = Container.get(Logger);
+ logger.error(`Internal error occurred. Error: ${err}`);
+
+ return new ApolloError('Unable to handle the request.', 'ERROR', {
+ token: 'INTERNAL_ERROR',
+ });
+ }
+ return err;
+ }
+ }
+
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| helpers.ts | +
+
+ |
+ 100% | +8/8 | +100% | +0/0 | +100% | +0/0 | +100% | +8/8 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 | 1x +1x +1x +1x +1x +1x + + +1x +1x + +1x | import 'reflect-metadata';
+import {ApolloServer} from 'apollo-server';
+import {buildApolloServerConfig} from '../../src/utils/helpers'
+import Container from 'typedi';
+import { Client } from '@googlemaps/google-maps-services-js';
+import { Logger } from '@aws-lambda-powertools/logger';
+
+
+Container.set({id: Logger, value: new Logger()}); //configuring empty logger
+Container.set({id: Client, value: new Client()});
+
+export const server = new ApolloServer(buildApolloServerConfig()); |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| e2eConfig.ts | +
+
+ |
+ 100% | +9/9 | +100% | +0/0 | +100% | +0/0 | +100% | +9/9 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 | 1x +1x + +1x +1x +1x +1x +1x + + +1x + + + + + + + + + + + + + + + + + + + + | import { Logger } from "@aws-lambda-powertools/logger";
+import { ApolloError } from "apollo-server";
+import { GraphQLError } from "graphql";
+import Container from "typedi";
+import config from "../configs/config";
+import { dataSources } from "../dataSources/datasources";
+import { resolvers } from "../resolvers/resolvers";
+import { typeDefs } from "../schema/schema";
+
+/* istanbul ignore next */
+export const buildApolloServerConfig = (): any => {
+ return {
+ typeDefs,
+ resolvers,
+ dataSources,
+ debug: config.logs.level === 'DEBUG',
+ formatError: (err: GraphQLError) =>
+ {
+ if(err.extensions.code == 'INTERNAL_SERVER_ERROR'){
+ var logger = Container.get(Logger);
+ logger.error(`Internal error occurred. Error: ${err}`);
+
+ return new ApolloError('Unable to handle the request.', 'ERROR', {
+ token: 'INTERNAL_ERROR',
+ });
+ }
+ return err;
+ }
+ }
+
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| helpers.ts | +
+
+ |
+ 100% | +8/8 | +100% | +0/0 | +100% | +0/0 | +100% | +8/8 | +