trying to fix-Init should refuse if there are existing results

src/cosmic_ray/cli.py

@@ -63,12 +63,13 @@ def new_config(config_file):
 
 
 @cli.command()
+@click.option("--force", is_flag=True, default=False, help="Force initialization")
 @click.argument("config_file")
 @click.argument(
     "session_file",
     # help="The filename for the database in which the work order will be stored."
 )
-def init(config_file, session_file):
+def init(config_file, session_file,force):
     """Initialize a mutation testing session from a configuration. This
     primarily creates a session - a database of "work to be done" -
     which describes all of the mutations and test runs that need to be
@@ -96,7 +97,13 @@ def init(config_file, session_file):
             log.info(" - %s: %s", directory, ", ".join(sorted(files)))
 
     with use_db(session_file) as database:
+
+        if database.num_results>0 or not force:
+            return
+
+
         cosmic_ray.commands.init(modules, database, operators_cfg)
+
 
     sys.exit(ExitCode.OK)
 

tests/conftest.py

@@ -2,7 +2,9 @@
 
 import pytest
 
-
+@pytest.fixture
+def force():
+    return "True"
 @pytest.fixture
 def tmpdir_path(tmpdir):
     """A temporary directory as a pathlib.Path."""

tests/unittests/test_command_line_processing.py

@@ -5,14 +5,16 @@
 import stat
 
 import pytest
+
 from exit_codes import ExitCode
 
 import cosmic_ray.cli
 import cosmic_ray.config
 import cosmic_ray.modules
 import cosmic_ray.mutating
 import cosmic_ray.plugins
-
+from cosmic_ray.work_db import WorkDB
+from cosmic_ray.work_item import WorkItem,MutationSpec
 
 @pytest.fixture
 def config_file(tmpdir):
@@ -64,6 +66,56 @@ def test_non_existent_config_file_returns_EX_NOINPUT(session, local_unittest_con
     assert cosmic_ray.cli.main(["exec", "no-such-file", str(session)]) == ExitCode.CONFIG
 
 
+
+def test_init_with_existing_results_no_force(session, local_unittest_config):
+    """Test that init exits without reinitializing when results exist and force=False"""
+    # Sample WorkItem creation
+    mutation_spec = MutationSpec(
+        module_path="src/example/test.py",
+        operator_name="delete_line",
+        occurrence=1,
+        start_pos=(10, 0),
+        end_pos=(10, 20),
+        operator_args={"comment": "Delete print statement"}
+    )
+
+    work_items = [
+        WorkItem(
+            job_id="test_job_123",
+            mutations=(mutation_spec,)
+        )
+    ]
+
+    db=WorkDB(session,1)
+    db.add_work_items(work_items)
+
+    # Verify initial database state has our test work items
+    initial_count = db.num_work_items
+    assert initial_count == len(work_items)
+
+
+
+    result = cosmic_ray.cli.main(["init", local_unittest_config, str(session)])
+    db=WorkDB(session,2)
+    final_count = db.num_results
+    assert final_count == initial_count  # Confirm work items are unchanged
+    assert result == ExitCode.OK 
+
+
+
+
+
+
+
+
+
+
+def test_init_with_existing_results_force(session, local_unittest_config,force):
+    """Test that reinitialization occurs when force=True"""
+
+    result = cosmic_ray.cli.main(["init", local_unittest_config, str(session),"--force"])
+    assert result == ExitCode.OK
+
 @pytest.mark.skip("need to sort this API out")
 def test_unreadable_file_returns_EX_PERM(tmpdir, local_unittest_config):
     p = tmpdir.ensure("bogus.session.sqlite")