chore: extract library

Author: mdesmet

src/dbt_integration/altimateHttpClient.ts

@@ -1,7 +1,9 @@
+import { createReadStream, ReadStream } from "fs";
+
+import type { RequestInit, Response as NodeFetchResponse } from "node-fetch";
+
 import { DBTConfiguration } from "./configuration";
 import { DBTTerminal } from "./terminal";
-import type { RequestInit, Response as NodeFetchResponse } from "node-fetch";
-import { createReadStream, ReadStream } from "fs";
 
 export class NoCredentialsError extends Error {}
 

src/dbt_integration/commandProcessExecution.ts

@@ -1,6 +1,7 @@
 import { spawn } from "child_process";
-import { DBTTerminal } from "./terminal";
+
 import { EnvironmentVariables } from "./domain";
+import { DBTTerminal } from "./terminal";
 
 export class CommandProcessExecutionFactory {
   constructor(private terminal: DBTTerminal) {}

src/dbt_integration/dbtCloudIntegration.ts

@@ -1,4 +1,13 @@
-import { DBTDiagnosticData, DBTDiagnosticResult } from "./diagnostics";
+import * as crypto from "crypto";
+import { existsSync, readFileSync } from "fs";
+import { join, dirname } from "path";
+import path = require("path");
+
+import { PythonBridge } from "python-bridge";
+import semver = require("semver");
+import { parse } from "yaml";
+
+import { CommandProcessExecutionFactory } from "./commandProcessExecution";
 import {
   DBTCommand,
   DBTCommandExecutionInfrastructure,
@@ -10,14 +19,7 @@ import {
   QueryExecution,
   readAndParseProjectConfig,
 } from "./dbtIntegration";
-import { CommandProcessExecutionFactory } from "./commandProcessExecution";
-import { PythonBridge } from "python-bridge";
-import { join, dirname } from "path";
-import path = require("path");
-import { DBTTerminal } from "./terminal";
-import { RuntimePythonEnvironment } from "./pythonEnvironment";
-import { existsSync, readFileSync } from "fs";
-import semver = require("semver");
+import { DBTDiagnosticData, DBTDiagnosticResult } from "./diagnostics";
 import {
   Catalog,
   DBColumn,
@@ -26,8 +28,8 @@ import {
   DeferConfig,
   NodeMetaData,
 } from "./domain";
-import * as crypto from "crypto";
-import { parse } from "yaml";
+import { RuntimePythonEnvironment } from "./pythonEnvironment";
+import { DBTTerminal } from "./terminal";
 
 export function getDBTPath(
   pythonEnvironment: RuntimePythonEnvironment,

src/dbt_integration/dbtCoreCommandIntegration.ts

@@ -1,10 +1,10 @@
+import { getDBTPath } from "./dbtCloudIntegration";
 import {
   DBTCoreDetection,
   DBTCoreProjectDetection,
   DBTCoreProjectIntegration,
 } from "./dbtCoreIntegration";
 import { QueryExecution, DBTCommand } from "./dbtIntegration";
-import { getDBTPath } from "./dbtCloudIntegration";
 import { Catalog, DBColumn, DBTNode } from "./domain";
 
 // TODO: either fix this class or remove it

src/dbt_integration/dbtCoreIntegration.ts

@@ -1,4 +1,14 @@
-import { DBTDiagnosticData, DBTDiagnosticResult } from "./diagnostics";
+import * as crypto from "crypto";
+import { existsSync, readFileSync } from "fs";
+import * as fs from "fs";
+import * as path from "path";
+
+import { PythonBridge, PythonException } from "python-bridge";
+import { parse } from "yaml";
+
+import { NotFoundError } from "./altimateHttpClient";
+import { CommandProcessExecutionFactory } from "./commandProcessExecution";
+import { DBTConfiguration } from "./configuration";
 import {
   CompilationResult,
   DBTCommand,
@@ -12,16 +22,8 @@ import {
   ExecuteSQLError,
   DBTCommandExecutionStrategy,
 } from "./dbtIntegration";
-import { RuntimePythonEnvironment } from "./pythonEnvironment";
-import { CommandProcessExecutionFactory } from "./commandProcessExecution";
-import { PythonBridge, PythonException } from "python-bridge";
-import * as path from "path";
-import { existsSync, readFileSync } from "fs";
-import * as fs from "fs";
-import { parse } from "yaml";
-import { NotFoundError } from "./altimateHttpClient";
-import { DBTTerminal } from "./terminal";
-import { DBTConfiguration } from "./configuration";
+import { DbtIntegrationClient } from "./dbtIntegrationClient";
+import { DBTDiagnosticData, DBTDiagnosticResult } from "./diagnostics";
 import {
   Catalog,
   DBColumn,
@@ -34,8 +36,8 @@ import {
   RESOURCE_TYPE_SOURCE,
   SourceNode,
 } from "./domain";
-import * as crypto from "crypto";
-import { DbtIntegrationClient } from "./dbtIntegrationClient";
+import { RuntimePythonEnvironment } from "./pythonEnvironment";
+import { DBTTerminal } from "./terminal";
 
 const DEFAULT_QUERY_TEMPLATE = "select * from ({query}) as query limit {limit}";
 

src/dbt_integration/dbtFusionCommandIntegration.ts

@@ -1,3 +1,8 @@
+import path, { join } from "path";
+
+import { CommandProcessExecutionFactory } from "./commandProcessExecution";
+import { DBTConfiguration } from "./configuration";
+import { DBTCloudProjectIntegration, getDBTPath } from "./dbtCloudIntegration";
 import {
   QueryExecution,
   DBTCommand,
@@ -6,19 +11,15 @@ import {
   readAndParseProjectConfig,
 } from "./dbtIntegration";
 import { DBTDiagnosticData } from "./diagnostics";
-import { DBTCloudProjectIntegration, getDBTPath } from "./dbtCloudIntegration";
-import { DBTConfiguration } from "./configuration";
-import path, { join } from "path";
-import { CommandProcessExecutionFactory } from "./commandProcessExecution";
-import { RuntimePythonEnvironment } from "./pythonEnvironment";
-import { DBTTerminal } from "./terminal";
 import {
   DBT_PROJECT_FILE,
   DBColumn,
   DBTNode,
   Catalog,
   DeferConfig,
 } from "./domain";
+import { RuntimePythonEnvironment } from "./pythonEnvironment";
+import { DBTTerminal } from "./terminal";
 
 export class DBTFusionCommandDetection implements DBTDetection {
   constructor(

src/dbt_integration/dbtIntegration.ts

@@ -1,12 +1,17 @@
+import * as crypto from "crypto";
+import { existsSync, readFileSync } from "fs";
+import path from "path";
+
 import { PythonBridge, pythonBridge } from "python-bridge";
+import { parse } from "yaml";
+
 import {
   CommandProcessExecution,
   CommandProcessExecutionFactory,
   CommandProcessResult,
 } from "./commandProcessExecution";
-import { RuntimePythonEnvironment } from "./pythonEnvironment";
-import { existsSync, readFileSync } from "fs";
-import { DBTTerminal } from "./terminal";
+import { DBTConfiguration } from "./configuration";
+import { DBTDiagnosticResult } from "./diagnostics";
 import {
   Catalog,
   DBColumn,
@@ -16,11 +21,8 @@ import {
   NodeMetaData,
   RunModelParams,
 } from "./domain";
-import { DBTDiagnosticResult } from "./diagnostics";
-import { DBTConfiguration } from "./configuration";
-import path from "path";
-import { parse } from "yaml";
-import * as crypto from "crypto";
+import { RuntimePythonEnvironment } from "./pythonEnvironment";
+import { DBTTerminal } from "./terminal";
 
 function combineAbortSignals(
   ...signals: (AbortSignal | undefined)[]

src/dbt_integration/dbtIntegrationAdapter.ts

@@ -1,10 +1,20 @@
+import { EventEmitter } from "events";
+import { FSWatcher, watch, readFileSync } from "fs";
+import path from "path";
+
+import { PythonException } from "python-bridge";
+import { YAMLError } from "yaml";
+
 import { CommandProcessResult } from "./commandProcessExecution";
+import { DBTConfiguration } from "./configuration";
+import { ProjectHealthcheck } from "./dbtCoreIntegration";
+import { DBTFacade } from "./dbtFacade";
 import {
   DBTProjectIntegration,
   DBTCommandFactory,
   DBTCommand,
 } from "./dbtIntegration";
-import { ProjectHealthcheck } from "./dbtCoreIntegration";
+import { DBTDiagnosticData } from "./diagnostics";
 import {
   Catalog,
   CATALOG_FILE,
@@ -24,26 +34,17 @@ import {
   RunResultsEventData,
   Table,
 } from "./domain";
-import { DBTConfiguration } from "./configuration";
-import { DBTFacade } from "./dbtFacade";
-import { DBTDiagnosticData } from "./diagnostics";
-import { PythonException } from "python-bridge";
-import { YAMLError } from "yaml";
+import { ChildrenParentParser } from "./parsers/childrenParentParser";
 import { DocParser } from "./parsers/docParser";
+import { ExposureParser } from "./parsers/exposureParser";
 import { GraphParser } from "./parsers/graphParser";
 import { MacroParser } from "./parsers/macroParser";
+import { MetricParser } from "./parsers/metricParser";
+import { ModelDepthParser } from "./parsers/modelDepthParser";
 import { NodeParser } from "./parsers/nodeParser";
 import { SourceParser } from "./parsers/sourceParser";
 import { TestParser } from "./parsers/testParser";
-import { ExposureParser } from "./parsers/exposureParser";
-import { MetricParser } from "./parsers/metricParser";
-import { ChildrenParentParser } from "./parsers/childrenParentParser";
-import { ModelDepthParser } from "./parsers/modelDepthParser";
 import { DBTTerminal } from "./terminal";
-import path from "path";
-import { FSWatcher, watch } from "fs";
-import { EventEmitter } from "events";
-import { readFileSync } from "fs";
 
 export const debounce = (fn: (args: unknown) => void, wait: number) => {
   let timeout: NodeJS.Timeout;

src/dbt_integration/dbtIntegrationClient.ts

@@ -1,7 +1,8 @@
-import { AltimateHttpClient } from "./altimateHttpClient";
-import { join } from "path";
 import { createWriteStream, mkdirSync } from "fs";
 import * as os from "os";
+import { join } from "path";
+
+import { AltimateHttpClient } from "./altimateHttpClient";
 import { hashProjectRoot } from "./dbtIntegration";
 import { DBTTerminal } from "./terminal";