Renamed identifier of pgstac source plugin.

Author: pantierra

README.md

@@ -51,7 +51,7 @@ Create a YAML configuration file to specify sources (where messages come from) a
 ```yaml
 # Sources: Define where notifications come from
 sources:
-  - type: postgres
+  - type: pgstac
     config:
       host: localhost
       port: 5432
@@ -72,7 +72,7 @@ See [examples/config.yaml](./examples/config.yaml) for a complete configuration
 ### Available Plugins
 
 #### Sources
-- `postgres`: Monitor PostgreSQL/pgSTAC database changes
+- `pgstac`: Monitor PostgreSQL/pgSTAC database changes
 
 #### Outputs
 - `mqtt`: Publish events to MQTT broker

eoapi_notifier/core/registry.py

@@ -117,7 +117,7 @@ def __init__(self) -> None:
     def _register_builtin_sources(self) -> None:
         """Register built-in source types."""
         self.register(
-            name="postgres",
+            name="pgstac",
             module_path="eoapi_notifier.sources.pgstac",
             class_name="PgSTACSource",
             config_class_name="PgSTACSourceConfig",

examples/config.yaml

@@ -4,7 +4,7 @@
 # Sources: Define where notifications come from
 sources:
   # PostgreSQL/pgSTAC source for database changes
-  - type: postgres
+  - type: pgstac
     config:
       host: localhost
       port: 5432
@@ -36,15 +36,15 @@ outputs:
 
 # Example with multiple sources and outputs
 # sources:
-#   - type: postgres
+#   - type: pgstac
 #     config:
 #       host: db1.example.com
 #       port: 5432
 #       database: stac_db
 #       username: notifier
 #       password: secret123
 #
-#   - type: postgres
+#   - type: pgstac
 #     config:
 #       host: db2.example.com
 #       port: 5432

tests/test_cli.py

@@ -103,7 +103,7 @@ def test_successful_run(
         """Test successful CLI run with valid configuration."""
         # Create test config file
         config_data = {
-            "sources": [{"type": "postgres", "config": {"host": "localhost"}}],
+            "sources": [{"type": "pgstac", "config": {"host": "localhost"}}],
             "outputs": [{"type": "mqtt", "config": {"broker_host": "localhost"}}],
         }
 

tests/test_main.py

@@ -49,7 +49,7 @@ def test_initialization(self) -> None:
     def test_load_config_valid_yaml(self) -> None:
         """Test loading valid YAML configuration."""
         config_data = {
-            "sources": [{"type": "postgres", "config": {"host": "localhost"}}],
+            "sources": [{"type": "pgstac", "config": {"host": "localhost"}}],
             "outputs": [{"type": "mqtt", "config": {"broker_host": "localhost"}}],
         }
 
@@ -124,7 +124,7 @@ def test_create_plugins_success(
         mock_create_output.return_value = mock_output
 
         config = {
-            "sources": [{"type": "postgres", "config": {"host": "localhost"}}],
+            "sources": [{"type": "pgstac", "config": {"host": "localhost"}}],
             "outputs": [{"type": "mqtt", "config": {"broker_host": "localhost"}}],
         }
 
@@ -135,7 +135,7 @@ def test_create_plugins_success(
         assert self.app.sources[0] == mock_source
         assert self.app.outputs[0] == mock_output
 
-        mock_create_source.assert_called_once_with("postgres", {"host": "localhost"})
+        mock_create_source.assert_called_once_with("pgstac", {"host": "localhost"})
         mock_create_output.assert_called_once_with("mqtt", {"broker_host": "localhost"})
 
     @patch("eoapi_notifier.core.main.create_source")
@@ -173,7 +173,7 @@ def test_create_plugins_source_creation_error(
         """Test handling of source creation errors."""
         mock_create_source.side_effect = Exception("Creation failed")
 
-        config = {"sources": [{"type": "postgres", "config": {"host": "localhost"}}]}
+        config = {"sources": [{"type": "pgstac", "config": {"host": "localhost"}}]}
 
         self.app.create_plugins(config)
 

tests/test_pgstac_source.py

@@ -142,10 +142,10 @@ def test_status_info(self) -> None:
 class TestPgSTACSourceRegistry:
     """Test pgSTAC source registry integration."""
 
-    def test_postgres_source_registered(self) -> None:
-        """Test that postgres source is registered."""
+    def test_pgstac_source_registered(self) -> None:
+        """Test that pgstac source is registered."""
         available = get_available_sources()
-        assert "postgres" in available
+        assert "pgstac" in available
 
     def test_create_source_from_registry(self) -> None:
         """Test creating pgSTAC source through registry."""
@@ -157,7 +157,7 @@ def test_create_source_from_registry(self) -> None:
             "password": "test",
         }
 
-        source = create_source("postgres", config)
+        source = create_source("pgstac", config)
 
         assert isinstance(source, PgSTACSource)
         assert isinstance(source.config, PgSTACSourceConfig)
@@ -171,7 +171,7 @@ def test_create_source_with_validation_error(self) -> None:
         }
 
         with pytest.raises(PluginError):  # Should raise validation error
-            create_source("postgres", config)
+            create_source("pgstac", config)
 
 
 class TestPgSTACSource:

tests/test_plugin_system.py

@@ -462,7 +462,7 @@ class TestRegistryIntegration:
     @pytest.mark.parametrize(
         "registry,plugin_type",
         [
-            (source_registry, "postgres"),
+            (source_registry, "pgstac"),
             (output_registry, "mqtt"),
         ],
     )

tests/test_registry.py

@@ -239,7 +239,7 @@ def test_source_registry_initialization(self) -> None:
         """Test source registry has built-in sources."""
         assert isinstance(source_registry, SourceRegistry)
         available = source_registry.list_registered()
-        assert "postgres" in available
+        assert "pgstac" in available
 
     def test_output_registry_initialization(self) -> None:
         """Test output registry has built-in outputs."""
@@ -279,7 +279,7 @@ def test_get_available_sources(self) -> None:
         """Test getting available source types."""
         sources = get_available_sources()
         assert isinstance(sources, list)
-        assert "postgres" in sources
+        assert "pgstac" in sources
 
     def test_get_available_outputs(self) -> None:
         """Test getting available output types."""