Some checks failed
AITBC CI/CD Pipeline / lint-and-test (3.11) (pull_request) Has been cancelled
AITBC CI/CD Pipeline / lint-and-test (3.12) (pull_request) Has been cancelled
AITBC CI/CD Pipeline / lint-and-test (3.13) (pull_request) Has been cancelled
Security Scanning / Bandit Security Scan (apps/coordinator-api/src) (pull_request) Has been cancelled
Security Scanning / Bandit Security Scan (cli/aitbc_cli) (pull_request) Has been cancelled
Security Scanning / Bandit Security Scan (packages/py/aitbc-core/src) (pull_request) Has been cancelled
Security Scanning / Bandit Security Scan (packages/py/aitbc-crypto/src) (pull_request) Has been cancelled
Security Scanning / Bandit Security Scan (packages/py/aitbc-sdk/src) (pull_request) Has been cancelled
Security Scanning / Bandit Security Scan (tests) (pull_request) Has been cancelled
Security Scanning / CodeQL Security Analysis (javascript) (pull_request) Has been cancelled
Security Scanning / CodeQL Security Analysis (python) (pull_request) Has been cancelled
Security Scanning / Dependency Security Scan (pull_request) Has been cancelled
Security Scanning / Container Security Scan (pull_request) Has been cancelled
Security Scanning / OSSF Scorecard (pull_request) Has been cancelled
AITBC CI/CD Pipeline / test-cli (pull_request) Has been cancelled
AITBC CI/CD Pipeline / test-services (pull_request) Has been cancelled
AITBC CI/CD Pipeline / test-production-services (pull_request) Has been cancelled
AITBC CI/CD Pipeline / security-scan (pull_request) Has been cancelled
AITBC CI/CD Pipeline / build (pull_request) Has been cancelled
AITBC CI/CD Pipeline / deploy-staging (pull_request) Has been cancelled
AITBC CI/CD Pipeline / deploy-production (pull_request) Has been cancelled
AITBC CI/CD Pipeline / performance-test (pull_request) Has been cancelled
AITBC CI/CD Pipeline / docs (pull_request) Has been cancelled
AITBC CI/CD Pipeline / release (pull_request) Has been cancelled
AITBC CI/CD Pipeline / notify (pull_request) Has been cancelled
Security Scanning / Security Summary Report (pull_request) Has been cancelled
- Add production genesis initialization scripts - Add keystore management for production - Add production node runner - Add setup production automation - Add AI memory system for development tracking - Add translation cache service - Add development heartbeat monitoring - Update blockchain RPC router - Update coordinator API main configuration - Update secure pickle service - Update claim task script - Update blockchain service configuration - Update gitignore for production files
92 lines
3.2 KiB
Python
92 lines
3.2 KiB
Python
#!/usr/bin/env python3
|
|
"""
|
|
Keystore management for AITBC production keys.
|
|
Generates a random private key and encrypts it with a password using Fernet (AES-128).
|
|
"""
|
|
|
|
from __future__ import annotations
|
|
|
|
import argparse
|
|
import base64
|
|
import hashlib
|
|
import json
|
|
import os
|
|
import secrets
|
|
from datetime import datetime
|
|
from pathlib import Path
|
|
|
|
from cryptography.fernet import Fernet
|
|
|
|
|
|
def derive_key(password: str, salt: bytes = b"") -> bytes:
|
|
"""Derive a 32-byte key from the password using SHA-256."""
|
|
if not salt:
|
|
salt = secrets.token_bytes(16)
|
|
# Simple KDF: hash(password + salt)
|
|
dk = hashlib.sha256(password.encode() + salt).digest()
|
|
return base64.urlsafe_b64encode(dk), salt
|
|
|
|
|
|
def encrypt_private_key(private_key_hex: str, password: str) -> dict:
|
|
"""Encrypt a hex-encoded private key with Fernet, returning a keystore dict."""
|
|
key, salt = derive_key(password)
|
|
f = Fernet(key)
|
|
token = f.encrypt(private_key_hex.encode())
|
|
return {
|
|
"cipher": "fernet",
|
|
"cipherparams": {"salt": base64.b64encode(salt).decode()},
|
|
"ciphertext": base64.b64encode(token).decode(),
|
|
"kdf": "sha256",
|
|
"kdfparams": {"dklen": 32, "salt": base64.b64encode(salt).decode()},
|
|
}
|
|
|
|
|
|
def main() -> None:
|
|
parser = argparse.ArgumentParser(description="Generate encrypted keystore for an account")
|
|
parser.add_argument("address", help="Account address (e.g., aitbc1treasury)")
|
|
parser.add_argument("--output-dir", type=Path, default=Path("/opt/aitbc/keystore"), help="Keystore directory")
|
|
parser.add_argument("--force", action="store_true", help="Overwrite existing keystore file")
|
|
parser.add_argument("--password", help="Encryption password (or read from KEYSTORE_PASSWORD / keystore/.password)")
|
|
args = parser.parse_args()
|
|
|
|
out_dir = args.output_dir
|
|
out_dir.mkdir(parents=True, exist_ok=True)
|
|
out_file = out_dir / f"{args.address}.json"
|
|
|
|
if out_file.exists() and not args.force:
|
|
print(f"Keystore file {out_file} exists. Use --force to overwrite.")
|
|
return
|
|
|
|
# Determine password: CLI > env var > password file
|
|
password = args.password
|
|
if not password:
|
|
password = os.getenv("KEYSTORE_PASSWORD")
|
|
if not password:
|
|
pw_file = Path("/opt/aitbc/keystore/.password")
|
|
if pw_file.exists():
|
|
password = pw_file.read_text().strip()
|
|
if not password:
|
|
print("No password provided. Set KEYSTORE_PASSWORD, pass --password, or create /opt/aitbc/keystore/.password")
|
|
sys.exit(1)
|
|
|
|
print(f"Generating keystore for {args.address}...")
|
|
private_key = secrets.token_hex(32)
|
|
print(f"Private key (hex): {private_key}")
|
|
print("** SAVE THIS KEY SECURELY ** (It cannot be recovered from the encrypted file without the password)")
|
|
|
|
encrypted = encrypt_private_key(private_key, password)
|
|
keystore = {
|
|
"address": args.address,
|
|
"crypto": encrypted,
|
|
"created_at": datetime.utcnow().isoformat() + "Z",
|
|
}
|
|
|
|
out_file.write_text(json.dumps(keystore, indent=2))
|
|
os.chmod(out_file, 0o600)
|
|
print(f"[+] Keystore written to {out_file}")
|
|
print(f"[!] Keep the password safe. Without it, the private key cannot be recovered.")
|
|
|
|
|
|
if __name__ == "__main__":
|
|
main()
|