From 95a195d67c11c8eae3e8bdbb95c3f783d9d1ce50 Mon Sep 17 00:00:00 2001
From: ghost <localhost>
Date: Mon, 4 Dec 2023 21:09:12 +0200
Subject: [PATCH] initial commit

---
 README.md      |  14 ++++
 src/Client.php | 218 +++++++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 232 insertions(+)
 create mode 100644 src/Client.php

diff --git a/README.md b/README.md
index d05798b..af4b6f5 100644
--- a/README.md
+++ b/README.md
@@ -1,2 +1,16 @@
 # kevacoin-php
+
 kevacoin library for PHP
+
+```
+$client = new \Kevachat\Kevacoin\Client(
+    KEVA_PROTOCOL,
+    KEVA_HOST,
+    KEVA_PORT,
+    KEVA_USERNAME,
+    KEVA_PASSWORD
+);
+
+echo $client->getBlockCount();
+
+```
\ No newline at end of file
diff --git a/src/Client.php b/src/Client.php
new file mode 100644
index 0000000..429014b
--- /dev/null
+++ b/src/Client.php
@@ -0,0 +1,218 @@
+<?php
+
+namespace Kevachat\Kevacoin;
+
+class Client
+{
+    private $_id = 0;
+
+    private $_curl;
+    private $_protocol;
+    private $_host;
+    private $_port;
+
+    public function __construct(
+        string $protocol,
+        string $host,
+        int $port,
+        string $username,
+        string $password
+    )
+    {
+        $this->_protocol = $protocol;
+        $this->_host = $host;
+        $this->_port = $port;
+
+        $this->_curl = curl_init();
+
+        curl_setopt_array(
+            $this->_curl,
+            [
+                CURLOPT_RETURNTRANSFER => true,
+                CURLOPT_FOLLOWLOCATION => true,
+                CURLOPT_FRESH_CONNECT  => true,
+                CURLOPT_HTTPAUTH       => CURLAUTH_BASIC,
+                CURLOPT_USERPWD        => $username . ':' . $password,
+                CURLOPT_RETURNTRANSFER => true,
+                CURLOPT_FOLLOWLOCATION => true,
+                CURLOPT_HTTPHEADER     => [
+                    'Content-Type: application/plain',
+                ],
+            ]
+        );
+    }
+
+    public function __destruct()
+    {
+        curl_close(
+            $this->_curl
+        );
+    }
+
+    private function _prepare(
+        string $url,
+        string $method = 'POST',
+        array $data = []
+    ) {
+
+        curl_setopt(
+            $this->_curl,
+            CURLOPT_URL,
+            $this->_protocol . '://' . $this->_host . ':' . $this->_port . $url
+        );
+
+        curl_setopt(
+            $this->_curl,
+            CURLOPT_CUSTOMREQUEST,
+            $method
+        );
+
+        if ($method == 'POST' && $data)
+        {
+            curl_setopt(
+                $this->_curl,
+                CURLOPT_data,
+                json_encode(
+                    $data
+                )
+            );
+        }
+    }
+
+    private function _execute(
+        bool $json = true
+    ): ?string
+    {
+        $response = curl_exec(
+            $this->_curl
+        );
+
+        $errorNumber = curl_errno(
+            $this->_curl
+        );
+
+        $errorText = curl_error(
+            $this->_curl
+        );
+
+        if ($response)
+        {
+            return $json ? json_decode($response) : $response;
+        }
+
+        return null;
+    }
+
+    public function getBlockCount(): ?int
+    {
+        $this->_id++;
+
+        $this->_prepare(
+            '',
+            'POST',
+            [
+                'method' => 'getblockcount',
+                'params' => [],
+                'id'     => $this->_id
+            ]
+        );
+
+        $response = $this->_execute();
+
+        if (isset($response['result']) && is_int($response['result']))
+        {
+            return $response['result'];
+        }
+
+        return null;
+    }
+
+    public function getBlockHash(
+        int $block
+    ): ?string
+    {
+        $this->_id++;
+
+        $this->_prepare(
+            '',
+            'POST',
+            [
+                'method' => 'getblockhash',
+                'params' =>
+                [
+                    $block
+                ],
+                'id' => $this->_id
+            ]
+        );
+
+        $response = $this->_execute();
+
+        if (isset($response['result']) && 64 == strlen($response['result']))
+        {
+            return $response['result'];
+        }
+
+        return null;
+    }
+
+    public function getBlock(
+        string $hash
+    ): mixed
+    {
+        $this->_id++;
+
+        $this->_prepare(
+            '',
+            'POST',
+            [
+                'method' => 'getblock',
+                'params' =>
+                [
+                    $hash
+                ],
+                'id' => $this->_id
+            ]
+        );
+
+        $response = $this->_execute();
+
+        if (!empty($response['result']))
+        {
+            return $response['result'];
+        }
+
+        return null;
+    }
+
+    public function getRawTransaction(
+        string $txid,
+        bool $decode = true
+    ): mixed
+    {
+        $this->_id++;
+
+        $this->_prepare(
+            '',
+            'POST',
+            [
+                'method' => 'getrawtransaction',
+                'params' =>
+                [
+                    $txid,
+                    $decode
+                ],
+                'id' => $this->_id
+            ]
+        );
+
+        $response = $this->_execute();
+
+        if (!empty($response['result']))
+        {
+            return $response['result'];
+        }
+
+        return null;
+    }
+}