feat: added logging of token count on push (#68)

# Pull Request Description

logging of token count on push

## Checklist

- [x] Changes are limited to a single goal (avoid scope creep)
- [x] I confirm that I have read any Contribution and Development
guidelines (CONTRIBUTING and DEVELOPMENT) and are following their
suggestions.
- [x] I confirm that I wrote and/or have the right to submit the
contents of my Pull Request, by agreeing to the _Developer Certificate
of Origin_, (adding a 'sign-off' to my commits).

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "claudesync"
-version = "0.5.7"
+version = "0.5.8"
 authors = [
     {name = "Jahziah Wagner", email = "[email protected]"},
 ]
@@ -26,7 +26,8 @@ dependencies = [
     "claudesync>=0.5.4",
     "crontab>=1.0.1",
     "python-crontab>=3.2.0",
-    "Brotli>=1.1.0"
+    "Brotli>=1.1.0",
+    "anthropic>=0.34.2"
 ]
 keywords = [
     "sync",

requirements.txt

@@ -10,4 +10,5 @@ pytest-cov>=5.0.0
 claudesync>=0.5.4
 crontab>=1.0.1
 python-crontab>=3.2.0
-Brotli>=1.1.0
+Brotli>=1.1.0
+anthropic>=0.34.2

src/claudesync/syncmanager.py

@@ -4,8 +4,8 @@
 import logging
 from datetime import datetime, timezone
 import io
+from anthropic import Anthropic
 
-import click
 from tqdm import tqdm
 
 from claudesync.utils import compute_md5_hash
@@ -54,12 +54,16 @@ def __init__(self, provider, config, local_path):
         self.max_retries = 3
         self.retry_delay = 1
         self.compression_algorithm = config.get("compression_algorithm", "none")
+        self.synced_files = {}
+        self.anthropic_client = Anthropic()
 
     def sync(self, local_files, remote_files):
+        self.synced_files = {}  # Reset synced files at the start of sync
         if self.compression_algorithm == "none":
             self._sync_without_compression(local_files, remote_files)
         else:
             self._sync_with_compression(local_files, remote_files)
+        self.log_token_count()
 
     def _sync_without_compression(self, local_files, remote_files):
         remote_files_to_delete = set(rf["file_name"] for rf in remote_files)
@@ -94,6 +98,10 @@ def _sync_without_compression(self, local_files, remote_files):
 
         self.prune_remote_files(remote_files, remote_files_to_delete)
 
+        # Count tokens for synced files
+        for local_file in synced_files:
+            self.count_tokens_for_file(local_file)
+
     def _sync_with_compression(self, local_files, remote_files):
         packed_content = self._pack_files(local_files)
         compressed_content = compress_content(
@@ -115,6 +123,10 @@ def _sync_with_compression(self, local_files, remote_files):
 
         self._cleanup_old_remote_files(remote_files)
 
+        # Count tokens for all local files (since they're all included in the compressed file)
+        for local_file in local_files:
+            self.count_tokens_for_file(local_file)
+
     def _pack_files(self, local_files):
         packed_content = io.StringIO()
         for file_path, file_hash in local_files.items():
@@ -302,7 +314,7 @@ def create_new_local_file(
 
     def prune_remote_files(self, remote_files, remote_files_to_delete):
         if not self.config.get("prune_remote_files"):
-            click.echo("Remote pruning is not enabled.")
+            logger.info("Remote pruning is not enabled.")
             return
 
         for file_to_delete in list(remote_files_to_delete):
@@ -320,3 +332,20 @@ def delete_remote_files(self, file_to_delete, remote_files):
             )
             pbar.update(1)
         time.sleep(self.upload_delay)
+
+    def count_tokens_for_file(self, file_path):
+        full_path = os.path.join(self.local_path, file_path)
+        with open(full_path, "r", encoding="utf-8", errors="ignore") as file:
+            content = file.read()
+        token_count = self.anthropic_client.count_tokens(content)
+        self.synced_files[file_path] = token_count
+
+    def get_total_token_count(self):
+        return sum(self.synced_files.values())
+
+    def get_synced_file_count(self):
+        return len(self.synced_files)
+
+    def log_token_count(self):
+        total_tokens = self.get_total_token_count()
+        logger.info(f"Total tokens in synced files: {total_tokens:,}")