diff --git a/.github/workflows/code-quality.yml b/.github/workflows/code-quality.yml index eb2a45f..0502c2f 100644 --- a/.github/workflows/code-quality.yml +++ b/.github/workflows/code-quality.yml @@ -29,30 +29,22 @@ jobs: - name: Check code formatting with Black run: | black --check --diff akavesdk/ private/ sdk/ tests/ - continue-on-error: true - name: Check import sorting with isort run: | isort --check-only --diff akavesdk/ private/ sdk/ tests/ - continue-on-error: true - name: Lint with flake8 run: | - # Stop the build if there are Python syntax errors or undefined names - flake8 akavesdk/ private/ sdk/ tests/ --count --select=E9,F63,F7,F82 --show-source --statistics - # Exit-zero treats all errors as warnings - flake8 akavesdk/ private/ sdk/ tests/ --count --exit-zero --max-complexity=10 --max-line-length=120 --statistics - continue-on-error: true + flake8 akavesdk/ private/ sdk/ tests/ --count --max-complexity=10 --max-line-length=120 --show-source --statistics - name: Lint with pylint run: | - pylint akavesdk/ private/ sdk/ --max-line-length=120 --disable=C0111,R0903,W0212,C0103 --exit-zero - continue-on-error: true + pylint akavesdk/ private/ sdk/ --max-line-length=120 --disable=C0111,R0903,W0212,C0103 - name: Type check with mypy run: | mypy akavesdk/ private/ sdk/ --ignore-missing-imports --no-strict-optional - continue-on-error: true security: runs-on: ubuntu-latest @@ -74,14 +66,12 @@ jobs: - name: Check for security vulnerabilities with Safety run: | - safety check --json || true - continue-on-error: true + safety check --json - name: Security check with Bandit run: | - bandit -r akavesdk/ private/ sdk/ -ll -f json -o bandit-report.json || true - bandit -r akavesdk/ private/ sdk/ -ll || true - continue-on-error: true + bandit -r akavesdk/ private/ sdk/ -ll -f json -o bandit-report.json + bandit -r akavesdk/ private/ sdk/ -ll - name: Upload Bandit report uses: actions/upload-artifact@v4 @@ -107,6 +97,5 @@ jobs: run: | python -m pip install --upgrade pip pip install pip-audit - pip-audit --desc || true - continue-on-error: true + pip-audit --desc diff --git a/test_ipc_upload_integration.py b/test_ipc_upload_integration.py deleted file mode 100755 index 811602d..0000000 --- a/test_ipc_upload_integration.py +++ /dev/null @@ -1,153 +0,0 @@ -#!/usr/bin/env python3 - -import os -import time -from pathlib import Path - -from akavesdk import SDK, SDKConfig - - -def main(): - NODE_ADDRESS = "connect.akave.ai:5500" - PRIVATE_KEY = "a5c223e956644f1ba11f0dcc6f3df4992184ff3c919223744d0cf1db33dab4d6" - BUCKET_NAME = "finalfr" - - script_dir = Path(__file__).parent - test_file_path = script_dir / "random_3mb_file.bin" - - if not test_file_path.exists(): - print(f"āŒ Error: Test file not found: {test_file_path}") - print(f" Please ensure random_3mb_file.bin exists in {script_dir}") - return 1 - - file_size = os.path.getsize(test_file_path) - # Use unique filename with timestamp to avoid conflicts - timestamp = int(time.time()) - file_name = f"test_{timestamp}.bin" - - print(f"\n{'='*70}") - print(f"šŸš€ Akave IPC Upload Integration Test") - print(f"{'='*70}") - print(f"šŸ“” Node Address: {NODE_ADDRESS}") - print(f"šŸ“¦ Bucket Name: {BUCKET_NAME}") - print(f"šŸ“„ File Name: {file_name}") - print(f"šŸ“‚ Source File: {test_file_path}") - print(f"šŸ“Š File Size: {file_size:,} bytes ({file_size / (1024*1024):.2f} MB)") - print(f"{'='*70}\n") - - try: - print("šŸ”§ Step 1: Initializing SDK...") - config = SDKConfig( - address=NODE_ADDRESS, - private_key=PRIVATE_KEY, - max_concurrency=5, - block_part_size=128 * 1024, - use_connection_pool=True, - chunk_buffer=10 - ) - sdk = SDK(config) - print("āœ… SDK initialized successfully\n") - - print("šŸ”§ Step 2: Creating IPC instance...") - ipc = sdk.ipc() - print("āœ… IPC instance created\n") - - print(f"šŸ”§ Step 3: Checking/Creating bucket '{BUCKET_NAME}'...") - existing_bucket = ipc.view_bucket(None, BUCKET_NAME) - - if existing_bucket is None: - print(f" Bucket doesn't exist, creating...") - result = ipc.create_bucket(None, BUCKET_NAME) - print(f"āœ… Bucket created successfully") - print(f" Bucket ID: {result.id}") - print(f" Bucket Name: {result.name}") - print(f" Created At: {result.created_at}") - time.sleep(2) - else: - print(f"āœ… Bucket already exists") - print(f" Bucket ID: {existing_bucket.id}") - print(f" Bucket Name: {existing_bucket.name}\n") - - print(f"šŸ”§ Step 4: Uploading file...") - print(f" File: {file_name}") - print(f" This may take a while for a {file_size / (1024*1024):.2f} MB file...") - print(f" Note: upload() will create file upload and handle all transactions\n") - - start_time = time.time() - - with open(test_file_path, 'rb') as f: - file_meta = ipc.upload(None, BUCKET_NAME, file_name, f) - - upload_duration = time.time() - start_time - upload_speed = (file_size / (1024*1024)) / upload_duration if upload_duration > 0 else 0 - - print(f"\nāœ… File uploaded successfully!") - print(f" Root CID: {file_meta.root_cid}") - print(f" File Name: {file_meta.name}") - print(f" File Size: {file_meta.size:,} bytes") - print(f" Encoded Size: {file_meta.encoded_size:,} bytes") - print(f" Upload Duration: {upload_duration:.2f} seconds") - print(f" Upload Speed: {upload_speed:.2f} MB/s\n") - - print(f"šŸ”§ Step 5: Verifying file metadata...") - try: - retrieved_meta = ipc.file_info(None, BUCKET_NAME, file_name) - - if retrieved_meta is None: - print(f"āš ļø Could not retrieve file metadata (but upload succeeded!)") - else: - print(f"āœ… File metadata verified") - print(f" Name: {retrieved_meta.name}") - print(f" Bucket: {retrieved_meta.bucket_name}") - print(f" Root CID: {retrieved_meta.root_cid}") - print(f" Size: {retrieved_meta.encoded_size:,} bytes\n") - except Exception as e: - print(f"āš ļø File verification skipped (upload succeeded!)") - print(f" Note: {str(e)}") - print(f" The file was successfully uploaded and committed\n") - retrieved_meta = None - - if retrieved_meta and retrieved_meta.root_cid != file_meta.root_cid: - print(f"āš ļø Warning: Root CID mismatch!") - print(f" Upload CID: {file_meta.root_cid}") - print(f" Retrieved CID: {retrieved_meta.root_cid}") - elif retrieved_meta: - print(f"āœ… Root CID matches upload!\n") - - print(f"šŸ”§ Step 6: Listing files in bucket...") - files = ipc.list_files(None, BUCKET_NAME) - print(f"āœ… Found {len(files)} file(s) in bucket '{BUCKET_NAME}'") - - uploaded_file = next((f for f in files if f.name == file_name), None) - if uploaded_file: - print(f"āœ… Uploaded file found in bucket listing") - else: - print(f"āš ļø Warning: Uploaded file not found in listing") - - print(f"\n{'='*70}") - print(f"āœ… Upload Test Completed Successfully!") - print(f"{'='*70}") - print(f"\nšŸ“‹ Summary:") - print(f" ā€¢ File: {file_name}") - print(f" ā€¢ Size: {file_size:,} bytes ({file_size / (1024*1024):.2f} MB)") - print(f" ā€¢ Root CID: {file_meta.root_cid}") - print(f" ā€¢ Bucket: {BUCKET_NAME}") - print(f" ā€¢ Upload Time: {upload_duration:.2f}s") - print(f" ā€¢ Upload Speed: {upload_speed:.2f} MB/s") - print(f"{'='*70}\n") - - sdk.close() - return 0 - - except Exception as e: - print(f"\nāŒ Error during upload test:") - print(f" {type(e).__name__}: {str(e)}") - import traceback - print(f"\nšŸ“‹ Full traceback:") - traceback.print_exc() - return 1 - - -if __name__ == "__main__": - exit_code = main() - exit(exit_code)