Duplicate V2

__mocks__/dd-trace.js

@@ -0,0 +1 @@
+// No-op: make sure we never load dd-trace in tests, as we run into memory issues.

src/lib/cache.ts

@@ -3,8 +3,8 @@ import { isArray } from "lodash"
 import config from "config"
 import { error, verbose } from "./loggers"
 import Memcached from "memcached"
-import { cacheTracer } from "./tracer"
-import { statsClient } from "./stats"
+import { createCacheTracer } from "./tracer"
+import { createStatsClient } from "./stats"
 
 const {
   NODE_ENV,
@@ -80,6 +80,12 @@ function createMemcachedClient() {
 
 export const client = isTest ? createMockClient() : createMemcachedClient()
 
+const cacheTracer: ReturnType<typeof createCacheTracer> = isTest
+  ? { get: x => x, set: x => x, delete: x => x }
+  : createCacheTracer()
+
+const statsClient = isTest ? null : createStatsClient()
+
 function _get<T>(key) {
   return new Promise<T>((resolve, reject) => {
     let timeoutId: NodeJS.Timer | null = setTimeout(() => {

src/lib/stats.js

@@ -4,88 +4,92 @@ import StatsD from "hot-shots"
 import config from "config"
 import { error } from "./loggers"
 
-const {
-  NODE_ENV,
-  ENABLE_METRICS,
-  STATSD_HOST,
-  STATSD_PORT,
-  DD_TRACER_SERVICE_NAME,
-} = config
+export function createStatsClient() {
+  const {
+    NODE_ENV,
+    ENABLE_METRICS,
+    STATSD_HOST,
+    STATSD_PORT,
+    DD_TRACER_SERVICE_NAME,
+  } = config
 
-const isProd = NODE_ENV === "production"
-const enableMetrics = ENABLE_METRICS === "true"
-const appMetricsDisable = [
-  "http",
-  "http-outbound",
-  "mongo",
-  "socketio",
-  "mqlight",
-  "postgresql",
-  "mqtt",
-  "mysql",
-  "redis",
-  "riak",
-  "memcached",
-  "oracledb",
-  "oracle",
-  "strong-oracle",
-]
+  const isProd = NODE_ENV === "production"
+  const enableMetrics = ENABLE_METRICS === "true"
+  const appMetricsDisable = [
+    "http",
+    "http-outbound",
+    "mongo",
+    "socketio",
+    "mqlight",
+    "postgresql",
+    "mqtt",
+    "mysql",
+    "redis",
+    "riak",
+    "memcached",
+    "oracledb",
+    "oracle",
+    "strong-oracle",
+  ]
 
-export const statsClient = new StatsD({
-  host: STATSD_HOST,
-  port: STATSD_PORT,
-  globalTags: { service: DD_TRACER_SERVICE_NAME, pod_name: os.hostname() },
-  mock: !isProd,
-  errorHandler: function(err) {
-    error(`Statsd client error ${err}`)
-  },
-})
-
-if (enableMetrics && isProd) {
-  const appmetrics = require("appmetrics")
-  appmetrics.configure({
-    mqtt: "off",
-  })
-  const monitoring = appmetrics.monitor()
-  _.forEach(appMetricsDisable, (val, idx) => {
-    appmetrics.disable(val)
+  const statsClient = new StatsD({
+    host: STATSD_HOST,
+    port: STATSD_PORT,
+    globalTags: { service: DD_TRACER_SERVICE_NAME, pod_name: os.hostname() },
+    mock: !isProd,
+    errorHandler: function(err) {
+      error(`Statsd client error ${err}`)
+    },
   })
 
-  monitoring.on("loop", loopMetrics => {
-    statsClient.timing("loop.count_per_five_seconds", loopMetrics.count)
-    statsClient.timing("loop.minimum_loop_duration", loopMetrics.minimum)
-    statsClient.timing("loop.maximum_loop_duration", loopMetrics.maximum)
-    statsClient.timing("loop.cpu_usage_in_userland", loopMetrics.cpu_user)
-    statsClient.timing("loop.cpu_usage_in_system", loopMetrics.cpu_system)
-  })
+  if (enableMetrics && isProd) {
+    const appmetrics = require("appmetrics")
+    appmetrics.configure({
+      mqtt: "off",
+    })
+    const monitoring = appmetrics.monitor()
+    _.forEach(appMetricsDisable, (val, idx) => {
+      appmetrics.disable(val)
+    })
 
-  monitoring.on("eventloop", eventloopMetrics => {
-    statsClient.timing("eventloop.latency.min", eventloopMetrics.latency.min)
-    statsClient.timing("eventloop.latency.max", eventloopMetrics.latency.max)
-    statsClient.timing("eventloop.latency.avg", eventloopMetrics.latency.avg)
-  })
+    monitoring.on("loop", loopMetrics => {
+      statsClient.timing("loop.count_per_five_seconds", loopMetrics.count)
+      statsClient.timing("loop.minimum_loop_duration", loopMetrics.minimum)
+      statsClient.timing("loop.maximum_loop_duration", loopMetrics.maximum)
+      statsClient.timing("loop.cpu_usage_in_userland", loopMetrics.cpu_user)
+      statsClient.timing("loop.cpu_usage_in_system", loopMetrics.cpu_system)
+    })
 
-  monitoring.on("memory", memoryMetrics => {
-    statsClient.gauge("memory.physical", memoryMetrics.physical)
-    statsClient.gauge("memory.virtual", memoryMetrics.virtual)
-  })
+    monitoring.on("eventloop", eventloopMetrics => {
+      statsClient.timing("eventloop.latency.min", eventloopMetrics.latency.min)
+      statsClient.timing("eventloop.latency.max", eventloopMetrics.latency.max)
+      statsClient.timing("eventloop.latency.avg", eventloopMetrics.latency.avg)
+    })
 
-  monitoring.on("gc", gcMetrics => {
-    statsClient.gauge("gc.heap_size", gcMetrics.size)
-    statsClient.gauge("gc.heap_used", gcMetrics.used)
-    statsClient.timing("gc.sweep_duration", gcMetrics.duration, {
-      sweep_type: gcMetrics.type,
+    monitoring.on("memory", memoryMetrics => {
+      statsClient.gauge("memory.physical", memoryMetrics.physical)
+      statsClient.gauge("memory.virtual", memoryMetrics.virtual)
     })
-  })
 
-  setInterval(() => {
-    statsClient.gauge(
-      "process.active_handles",
-      process._getActiveHandles().length
-    )
-    statsClient.gauge(
-      "process.active_requests",
-      process._getActiveRequests().length
-    )
-  }, 5000)
+    monitoring.on("gc", gcMetrics => {
+      statsClient.gauge("gc.heap_size", gcMetrics.size)
+      statsClient.gauge("gc.heap_used", gcMetrics.used)
+      statsClient.timing("gc.sweep_duration", gcMetrics.duration, {
+        sweep_type: gcMetrics.type,
+      })
+    })
+
+    setInterval(() => {
+      statsClient.gauge(
+        "process.active_handles",
+        process._getActiveHandles().length
+      )
+      statsClient.gauge(
+        "process.active_requests",
+        process._getActiveRequests().length
+      )
+    }, 5000)
+  }
+
+  return statsClient
 }

src/lib/stitching/convection/__tests__/stitching.test.ts

@@ -2,9 +2,10 @@ import { incrementalMergeSchemas } from "../../mergeSchemas"
 import { graphql } from "graphql"
 import gql from "lib/gql"
 import { addMockFunctionsToSchema } from "graphql-tools"
+import schema from "schema/v1/schema"
 
 it("resolves an Artist on a Consignment Submission", async () => {
-  const allMergedSchemas = await incrementalMergeSchemas({
+  const allMergedSchemas = await incrementalMergeSchemas(schema, {
     ENABLE_CONSIGNMENTS_STITCHING: true,
   })
 

src/lib/stitching/mergeSchemas.ts

@@ -10,7 +10,6 @@ import { executableKawsSchema } from "lib/stitching/kaws/schema"
 import { kawsStitchingEnvironment } from "lib/stitching/kaws/stitching"
 import config from "config"
 
-import localSchema from "schema/v1/schema"
 import { GraphQLSchema } from "graphql"
 import { exchangeStitchingEnvironment } from "./exchange/stitching"
 import { executableVortexSchema } from "lib/stitching/vortex/schema"
@@ -19,7 +18,7 @@ import { vortexStitchingEnvironment } from "./vortex/stitching"
 /**
  * Incrementally merges in schemas according to `process.env`
  */
-export const incrementalMergeSchemas = (testConfig?: any) => {
+export const incrementalMergeSchemas = (localSchema, testConfig?: any) => {
   const environment = testConfig || config
 
   const {

src/lib/tracer.ts

@@ -66,8 +66,10 @@ const createCommand = (command: string) => <T>(
   )
 }
 
-export const cacheTracer = {
-  get: createCommand("get"),
-  set: createCommand("set"),
-  delete: createCommand("delete"),
+export function createCacheTracer() {
+  return {
+    get: createCommand("get"),
+    set: createCommand("set"),
+    delete: createCommand("delete"),
+  }
 }

src/schema/v1/__tests__/article.test.js

@@ -1,5 +1,5 @@
 /* eslint-disable promise/always-return */
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 
 describe("Article type", () => {
   let article = null

src/schema/v1/__tests__/articles.test.js

@@ -1,5 +1,5 @@
 /* eslint-disable promise/always-return */
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 
 describe("Articles type", () => {
   let context = null

src/schema/v1/__tests__/artists.test.js

@@ -1,4 +1,4 @@
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 import gql from "lib/gql"
 import { find } from "lodash"
 

src/schema/v1/__tests__/artworkAttributionClasses.test.ts

@@ -1,5 +1,5 @@
 /* eslint-disable promise/always-return */
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 
 describe("ArtworkAttributionClasses type", () => {
   it("fetches artworkAttributionClasses", () => {

src/schema/v1/__tests__/auction_results.test.js

@@ -1,5 +1,5 @@
 /* eslint-disable promise/always-return */
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 
 const artist = {
   id: "percy-z",

src/schema/v1/__tests__/causality_jwt.test.js

@@ -1,7 +1,7 @@
 /* eslint-disable promise/always-return */
 import jwt from "jwt-simple"
 import { omit } from "lodash"
-import { runQuery, runAuthenticatedQuery } from "test/utils"
+import { runQuery, runAuthenticatedQuery } from "schema/v1/test/utils"
 import config from "config"
 
 const { HMAC_SECRET } = config

src/schema/v1/__tests__/city.test.ts

@@ -26,7 +26,7 @@ jest.mock("../city/cityDataSortedByDisplayPreference.json", () => mockCities)
 jest.mock("lib/all.ts")
 jest.mock("lib/sponsoredContent/data.json", () => mockSponsoredContent)
 
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 import gql from "lib/gql"
 import { MAX_GRAPHQL_INT, allViaLoader as _allViaLoader } from "lib/all"
 

src/schema/v1/__tests__/collection.test.js

@@ -1,6 +1,6 @@
 import { resolve } from "path"
 import { readFileSync } from "fs"
-import { runAuthenticatedQuery } from "test/utils"
+import { runAuthenticatedQuery } from "schema/v1/test/utils"
 import gql from "lib/gql"
 import { isEqual } from "lodash"
 

src/schema/v1/__tests__/credit_card.test.ts

@@ -1,5 +1,5 @@
 /* eslint-disable promise/always-return */
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 
 describe("CreditCard type", () => {
   let creditCard: any

src/schema/v1/__tests__/ecommerce/add_initial_offer_to_order_mutation.test.ts

@@ -1,5 +1,5 @@
 /* eslint-disable promise/always-return */
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 import { mockxchange } from "test/fixtures/exchange/mockxchange"
 import { sampleOrder } from "test/fixtures/results/sample_order"
 import exchangeOrderJSON from "test/fixtures/exchange/offer_order.json"

src/schema/v1/__tests__/ecommerce/approve_order_mutation.test.ts

@@ -1,5 +1,5 @@
 /* eslint-disable promise/always-return */
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 import { sampleOrder } from "test/fixtures/results/sample_order"
 import exchangeOrderJSON from "test/fixtures/exchange/buy_order.json"
 import { mockxchange } from "test/fixtures/exchange/mockxchange"

src/schema/v1/__tests__/ecommerce/buyer_accept_offer_mutation.test.ts

@@ -1,4 +1,4 @@
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 import { sampleOrder } from "test/fixtures/results/sample_order"
 import gql from "lib/gql"
 import { mockxchange } from "test/fixtures/exchange/mockxchange"

src/schema/v1/__tests__/ecommerce/buyer_counter_offer_mutation.test.ts

@@ -1,4 +1,4 @@
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 import { sampleOrder } from "test/fixtures/results/sample_order"
 import gql from "lib/gql"
 import { mockxchange } from "test/fixtures/exchange/mockxchange"

src/schema/v1/__tests__/ecommerce/buyer_reject_offer_mutation.test.ts

@@ -2,7 +2,7 @@ import gql from "lib/gql"
 import { OrderBuyerFields } from "./order_fields"
 import exchangeOrderJSON from "test/fixtures/exchange/buy_order.json"
 import { mockxchange } from "test/fixtures/exchange/mockxchange"
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 import { sampleOrder } from "test/fixtures/results/sample_order"
 
 let context

src/schema/v1/__tests__/ecommerce/confirm_pickup_mutation.test.ts

@@ -1,5 +1,5 @@
 /* eslint-disable promise/always-return */
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 import { sampleOrder } from "test/fixtures/results/sample_order"
 import exchangeOrderJSON from "test/fixtures/exchange/buy_order.json"
 import { mockxchange } from "test/fixtures/exchange/mockxchange"

src/schema/v1/__tests__/ecommerce/create_offer_order_with_artwork_mutation.test.ts

@@ -1,5 +1,5 @@
 /* eslint-disable promise/always-return */
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 import { mockxchange } from "test/fixtures/exchange/mockxchange"
 import { sampleOrder } from "test/fixtures/results/sample_order"
 import exchangeOrderJSON from "test/fixtures/exchange/buy_order.json"

src/schema/v1/__tests__/ecommerce/create_order_with_artwork_mutation.test.ts

@@ -1,5 +1,5 @@
 /* eslint-disable promise/always-return */
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 import { mockxchange } from "test/fixtures/exchange/mockxchange"
 import { sampleOrder } from "test/fixtures/results/sample_order"
 import exchangeOrderJSON from "test/fixtures/exchange/buy_order.json"

src/schema/v1/__tests__/ecommerce/fix_failed_payment.test.ts

@@ -1,4 +1,4 @@
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 import { sampleOrder } from "test/fixtures/results/sample_order"
 import gql from "lib/gql"
 import { mockxchange } from "test/fixtures/exchange/mockxchange"

src/schema/v1/__tests__/ecommerce/fulfill_order_at_once_mutation.test.ts

@@ -1,5 +1,5 @@
 /* eslint-disable promise/always-return */
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 import { mockxchange } from "test/fixtures/exchange/mockxchange"
 import { sampleOrder } from "test/fixtures/results/sample_order"
 import exchangeOrderJSON from "test/fixtures/exchange/buy_order.json"

src/schema/v1/__tests__/ecommerce/order.test.ts

@@ -1,6 +1,6 @@
 /* eslint-disable promise/always-return */
 
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 import { mockxchange } from "test/fixtures/exchange/mockxchange"
 import { sampleOrder } from "test/fixtures/results/sample_order"
 import exchangeOrderJSON from "test/fixtures/exchange/buy_order.json"

src/schema/v1/__tests__/ecommerce/orders.test.ts

@@ -1,6 +1,6 @@
 /* eslint-disable promise/always-return */
 
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 import { mockxchange } from "test/fixtures/exchange/mockxchange"
 import { sampleOrder } from "test/fixtures/results/sample_order"
 import exchangeOrdersJSON from "test/fixtures/exchange/orders.json"

src/schema/v1/__tests__/ecommerce/reject_order_mutation.test.ts

@@ -1,5 +1,5 @@
 /* eslint-disable promise/always-return */
-import { runQuery } from "test/utils"
+import { runQuery } from "schema/v1/test/utils"
 import { mockxchange } from "test/fixtures/exchange/mockxchange"
 import { sampleOrder } from "test/fixtures/results/sample_order"
 import exchangeOrderJSON from "test/fixtures/exchange/buy_order.json"