captaincore-manager/app/Remote/Kinsta.php

<?php 

namespace CaptainCore\Remote;

class Kinsta {

    private static $api_key;

    public static function setApiKey( $key ) {
        self::$api_key = $key;
    }

    private static function getApiKey() {
        // Fallback to the default provider key if not set dynamically
        return self::$api_key ?? \CaptainCore\Providers\Kinsta::credentials("api");
    }

    public static function showApiKey() {
        return self::getApiKey();
    }

    public static function get( $endpoint, $parameters = [] ) {
        $api_key = self::getApiKey();
        $data    = [
            'timeout' => 45,
            'headers' => [
                'Content-Type'  => 'application/json',
                'Authorization' => "Bearer $api_key",
            ],
        ];
        if ( ! empty( $parameters ) ) {
            $data['body'] = json_encode( $parameters );
        }

        // Kinsta's API rate-limits aggressively (e.g. ssh/password endpoints
        // start returning 429 after just 2 requests in the same second). Retry
        // with backoff so a small burst of internal calls survives.
        $max_attempts = 5;
        $attempt      = 0;
        while ( true ) {
            $response = wp_remote_get( "https://api.kinsta.com/v2/$endpoint", $data );
            if ( is_wp_error( $response ) ) {
                return false;
            }
            $code = wp_remote_retrieve_response_code( $response );
            if ( $code !== 429 || $attempt >= $max_attempts - 1 ) {
                break;
            }
            $retry_after = (int) wp_remote_retrieve_header( $response, 'retry-after' );
            $sleep_us    = $retry_after > 0
                ? $retry_after * 1000000
                : (int) ( pow( 2, $attempt ) * 500000 );
            usleep( $sleep_us );
            $attempt++;
        }

        $response = json_decode( $response['body'] );
        return $response;
    }

    public static function post( $endpoint, $parameters = [] ) {
        $api_key = self::getApiKey();
        $data    = [
            'timeout' => 45,
            'headers' => [
                'Content-Type'  => 'application/json',
                'Authorization' => "Bearer $api_key",
            ],
        ];
        if ( ! empty( $parameters ) ) {
            $data['body'] = json_encode( $parameters );
        }
        $response = wp_remote_post( "https://api.kinsta.com/v2/$endpoint", $data );
        if ( is_wp_error( $response ) ) {
            return false;
        }
        $response = json_decode( $response['body'] );
        return $response;
    }

    public static function put( $endpoint, $parameters = [] ) {
        $api_key = self::getApiKey();
        $data    = [
            'timeout' => 45,
            'headers' => [
                'Content-Type'  => 'application/json',
                'Authorization' => "Bearer $api_key",
            ],
            'method'  => 'PUT',
        ];
        if ( ! empty( $parameters ) ) {
            $data['body'] = json_encode( $parameters );
        }
        $response = wp_remote_post( "https://api.kinsta.com/v2/$endpoint", $data );
        if ( is_wp_error( $response ) ) {
            return false;
        }
        $response = json_decode( $response['body'] );
        return $response;
    }

    public static function delete( $endpoint, $parameters = [] ) {
        $api_key = self::getApiKey();
        $data    = [
            'timeout' => 45,
            'headers' => [
                'Content-Type'  => 'application/json',
                'Authorization' => "Bearer $api_key",
            ],
            'method'  => 'DELETE',
        ];
        if ( ! empty( $parameters ) ) {
            $data['body'] = json_encode( $parameters );
        }
        $response = wp_remote_request( "https://api.kinsta.com/v2/$endpoint", $data );
        if ( is_wp_error( $response ) ) {
            return false;
        }
        $response = json_decode( $response['body'] );
        return $response;
    }

}