Connector Architecture¶

const STATUS_MAPPING = {
    // Extern → Intern
    "busy": "unavailable",
    "in_meeting": "unavailable",
    "dnd": "urgent_only",
    "away": "async_preferred",
    "available": "all_channels",
    "focus_time": "email_only"
};

class PrivacyLayer {
    async hashSensitiveData(data) {
        // Nur Status, keine Details
        return {
            available: data.isFree,
            nextSlot: data.nextFree ? "soon" : "later",
            preferredChannel: this.mapChannel(data.context)
        };
    }

    async submitToBlockchain(hash) {
        // Zero-knowledge proof
        const proof = await zkp.generate(hash);
        return contract.updateStatus(proof);
    }
}

class CustomConnector {
    constructor(apiKey, userId) {
        this.apiKey = apiKey;
        this.userId = userId;
    }

    async getStatus() {
        // 1. Externe Daten holen
        const rawStatus = await this.fetchExternal();

        // 2. In Standard-Format transformieren
        return {
            available: rawStatus.free,
            nextSlot: rawStatus.nextFree,
            preferred: this.mapChannel(rawStatus)
        };
    }

    async fetchExternal() {
        // API-spezifische Implementierung
        const response = await fetch(
            `https://api.example.com/status/${this.userId}`,
            { headers: { 'Authorization': `Bearer ${this.apiKey}` }}
        );
        return response.json();
    }

    mapChannel(context) {
        // Kontext → Channel Mapping
        if (context.inMeeting) return "email";
        if (context.focusMode) return "async";
        return "instant";
    }

    async updateBlockchain(status) {
        // Hash sensitive data
        const hash = await crypto.subtle.digest(
            'SHA-256', 
            new TextEncoder().encode(JSON.stringify(status))
        );

        // Submit to smart contract
        return await contract.updateStatus(
            Array.from(new Uint8Array(hash))
        );
    }
}

// connector-registry.js
const registry = {
    "google-calendar": {
        name: "Google Calendar",
        version: "1.0.0",
        author: "CommunicationFinder Team",
        revenue_share: 0.3,
        endpoints: {
            status: "/api/v1/google/status",
            webhook: "/api/v1/google/webhook"
        }
    }
};

POST /api/v1/connectors/{connector_id}/status
Authorization: Bearer {api_key}
Content-Type: application/json

{
  "user_wallet": "0x1234...5678",
  "status": "unavailable",
  "next_available": 1730563200,
  "preferred_channel": "email",
  "context_hash": "a3b5c7..."
}

POST /api/v1/connectors/{connector_id}/webhooks
Authorization: Bearer {api_key}
Content-Type: application/json

{
  "url": "https://your-service.com/webhook",
  "events": ["status_change", "preference_update"],
  "secret": "webhook_secret_key"
}

const LIVE_STATUS_COSTS = {
    manual_update: 0.001,      // TOKEN pro Update
    api_update: 0.0001,        // Bulk Discount
    connector_update: 0,       // Free via offizielle Connectors

    query_costs: {
        public_profile: 0,     // Kostenlos
        live_status: 0.0001,   // Pro Query
        bulk_query: 0.00001    // Enterprise Rate
    }
};