From a5b5a04feb618e3dd7c136639668375bd4842292 Mon Sep 17 00:00:00 2001
From: Kylesoda <249518290+kylesoda@users.noreply.github.com>
Date: Fri, 10 Apr 2026 20:42:16 -0500
Subject: [PATCH] feat: update extractor and transformer constructors to return
 Extractor interface

---
 internal/app/etl/extractor/mssql.go    | 2 +-
 internal/app/etl/extractor/postgres.go | 2 +-
 internal/app/etl/transformer/mssql.go  | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/internal/app/etl/extractor/mssql.go b/internal/app/etl/extractor/mssql.go
index 40da1de..662171c 100644
--- a/internal/app/etl/extractor/mssql.go
+++ b/internal/app/etl/extractor/mssql.go
@@ -21,7 +21,7 @@ type MssqlExtractor struct {
 	db *sql.DB
 }
 
-func NewMssqlExtractor(db *sql.DB) *MssqlExtractor {
+func NewMssqlExtractor(db *sql.DB) Extractor {
 	return &MssqlExtractor{db: db}
 }
 
diff --git a/internal/app/etl/extractor/postgres.go b/internal/app/etl/extractor/postgres.go
index 86f0a2b..489da10 100644
--- a/internal/app/etl/extractor/postgres.go
+++ b/internal/app/etl/extractor/postgres.go
@@ -19,7 +19,7 @@ type PostgresExtractor struct {
 	db *pgxpool.Pool
 }
 
-func NewPostgresExtractor(pool *pgxpool.Pool) *PostgresExtractor {
+func NewPostgresExtractor(pool *pgxpool.Pool) Extractor {
 	return &PostgresExtractor{db: pool}
 }
 
diff --git a/internal/app/etl/transformer/mssql.go b/internal/app/etl/transformer/mssql.go
index ef6dc0a..213e6f0 100644
--- a/internal/app/etl/transformer/mssql.go
+++ b/internal/app/etl/transformer/mssql.go
@@ -12,7 +12,7 @@ import (
 
 type MssqlTransformer struct{}
 
-func NewMssqlTransformer() *MssqlTransformer {
+func NewMssqlTransformer() Transformer {
 	return &MssqlTransformer{}
 }