[Http] Add Http adapter functions

Author: stloyd

bin/docs.php

@@ -37,11 +37,14 @@ public function execute(InputInterface $input, OutputInterface $output) : int
 
         $paths = [
             __DIR__ . '/../src/core/etl/src/Flow/ETL/DSL/functions.php',
+            __DIR__ . '/../src/adapter/etl-adapter-avro/src/Flow/ETL/Adapter/Avro/functions.php',
             __DIR__ . '/../src/adapter/etl-adapter-chartjs/src/Flow/ETL/Adapter/ChartJS/functions.php',
             __DIR__ . '/../src/adapter/etl-adapter-csv/src/Flow/ETL/Adapter/CSV/functions.php',
             __DIR__ . '/../src/adapter/etl-adapter-doctrine/src/Flow/ETL/Adapter/Doctrine/functions.php',
+            __DIR__ . '/../src/adapter/etl-adapter-excel/src/Flow/ETL/Adapter/Excel/DSL/functions.php',
             __DIR__ . '/../src/adapter/etl-adapter-elasticsearch/src/Flow/ETL/Adapter/Elasticsearch/functions.php',
             __DIR__ . '/../src/adapter/etl-adapter-google-sheet/src/Flow/ETL/Adapter/GoogleSheet/functions.php',
+            __DIR__ . '/../src/adapter/etl-adapter-http/src/Flow/ETL/Adapter/Http/DSL/functions.php',
             __DIR__ . '/../src/adapter/etl-adapter-json/src/Flow/ETL/Adapter/JSON/functions.php',
             __DIR__ . '/../src/adapter/etl-adapter-meilisearch/src/Flow/ETL/Adapter/Meilisearch/functions.php',
             __DIR__ . '/../src/adapter/etl-adapter-parquet/src/Flow/ETL/Adapter/Parquet/functions.php',

composer.json

@@ -146,6 +146,7 @@
             "src/adapter/etl-adapter-elasticsearch/src/Flow/ETL/Adapter/Elasticsearch/functions.php",
             "src/adapter/etl-adapter-excel/src/Flow/ETL/Adapter/Excel/DSL/functions.php",
             "src/adapter/etl-adapter-google-sheet/src/Flow/ETL/Adapter/GoogleSheet/functions.php",
+            "src/adapter/etl-adapter-http/src/Flow/ETL/Adapter/Http/DSL/functions.php",
             "src/adapter/etl-adapter-json/src/Flow/ETL/Adapter/JSON/functions.php",
             "src/adapter/etl-adapter-meilisearch/src/Flow/ETL/Adapter/Meilisearch/functions.php",
             "src/adapter/etl-adapter-parquet/src/Flow/ETL/Adapter/Parquet/functions.php",

src/adapter/etl-adapter-http/composer.json

@@ -29,7 +29,10 @@
             "Flow\\": [
                 "src/Flow"
             ]
-        }
+        },
+        "files": [
+          "src/Flow/ETL/Adapter/Http/DSL/functions.php"
+        ]
     },
     "autoload-dev": {
         "psr-4": {

src/adapter/etl-adapter-http/src/Flow/ETL/Adapter/Http/DSL/functions.php

@@ -0,0 +1,37 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Flow\ETL\Adapter\Http;
+
+use Flow\ETL\{Adapter\Http\DynamicExtractor\NextRequestFactory,
+    Attribute\DocumentationDSL,
+    Attribute\Module,
+    Attribute\Type};
+use Psr\Http\Client\ClientInterface;
+use Psr\Http\Message\RequestInterface;
+
+#[DocumentationDSL(module: Module::HTTP, type: Type::EXTRACTOR)]
+function from_dynamic_http_client(
+    ClientInterface $client,
+    NextRequestFactory $requestFactory,
+) : PsrHttpClientDynamicExtractor {
+    return new PsrHttpClientDynamicExtractor(
+        $client,
+        $requestFactory,
+    );
+}
+
+/**
+ * @param iterable<RequestInterface> $requests
+ */
+#[DocumentationDSL(module: Module::HTTP, type: Type::EXTRACTOR)]
+function from_static_http_client(
+    ClientInterface $client,
+    iterable $requests,
+) : PsrHttpClientStaticExtractor {
+    return new PsrHttpClientStaticExtractor(
+        $client,
+        $requests,
+    );
+}

src/core/etl/src/Flow/ETL/Attribute/Module.php

@@ -11,13 +11,13 @@ enum Module : string
     case CHART_JS = 'CHART_JS';
     case CORE = 'CORE';
     case CSV = 'CSV';
-
     case DEPRECATED = 'DEPRECATED';
     case DOCTRINE = 'DOCTRINE';
     case ELASTIC_SEARCH = 'ELASTIC_SEARCH';
     case EXCEL = 'EXCEL';
     case FILESYSTEM = 'FILESYSTEM';
     case GOOGLE_SHEET = 'GOOGLE_SHEET';
+    case HTTP = 'HTTP';
     case JSON = 'JSON';
     case MEILI_SEARCH = 'MEILI_SEARCH';
     case PARQUET = 'PARQUET';