'use strict';

const BaseDriver = require('./base_driver');

/**
 * Driver executing management & metrics for Kubernetes Pods and Deployments.
 * Handles: k8s_pod, k8s_deployment.
 */
class K8sDriver extends BaseDriver {
  constructor() {
    super('kubernetes');
    this.supportedSubtypes = new Set(['k8s_pod', 'k8s_deployment']);
  }

  supports(resource) {
    if (!resource) return false;
    const subType = ((resource.metadata && resource.metadata.subType) || '').toLowerCase();
    return this.supportedSubtypes.has(subType);
  }

  async getMetrics(resource) {
    const subType = ((resource.metadata && resource.metadata.subType) || '').toLowerCase();
    if (subType === 'k8s_deployment') {
      return {
        status: 'online',
        driver: this.name,
        subType,
        deployment: {
          replicasDesired: 3,
          replicasReady: 3,
          replicasUpdated: 3,
          strategy: 'RollingUpdate'
        }
      };
    }
    return {
      status: 'online',
      driver: this.name,
      subType,
      pod: {
        phase: 'Running',
        restartCount: 0,
        podIP: '10.244.0.15',
        containers: [{ name: resource.slug, ready: true }]
      }
    };
  }

  async execAction(resource, action, params = {}) {
    const subType = ((resource.metadata && resource.metadata.subType) || '').toLowerCase();
    if (action === 'scale' && subType === 'k8s_deployment') {
      const replicas = params.replicas || 1;
      return { status: 'ok', driver: this.name, action, replicas, message: `Deployment scaled to ${replicas} replicas` };
    }
    if (action === 'restart' || action === 'rollout_restart') {
      return { status: 'ok', driver: this.name, action, message: `Rollout restart executed for ${resource.name}` };
    }
    return { status: 'error', driver: this.name, message: `Action '${action}' not supported for ${subType}` };
  }

  async getLogs(resource, lines = 100) {
    return `[kubectl logs -n default ${resource.slug} --tail=${lines}]\n` +
      `Pod ${resource.name} active. Log stream live.`;
  }
}

module.exports = K8sDriver;