feat: with loggers

.github/workflows/ci-multiplatform.yml

@@ -1,150 +0,0 @@
-name: ci-multi-platform
-on:
-  pull_request:
-  push:
-    branches:
-      - main
-  schedule:
-    - cron: '00 01 * * *'
-jobs:
-  test:
-    name: test
-    env:
-      # For some builds, we use cross to test on 32-bit and big-endian
-      # systems.
-      CARGO: cargo
-      # When CARGO is set to CROSS, this is set to `--target matrix.target`.
-      TARGET_FLAGS: ""
-      # When CARGO is set to CROSS, TARGET_DIR includes matrix.target.
-      TARGET_DIR: ./target
-      # Emit backtraces on panics.
-      RUST_BACKTRACE: 1
-    runs-on: ${{ matrix.os }}
-    strategy:
-      matrix:
-        build:
-          - pinned
-          - stable
-          - beta
-          - nightly
-          - nightly-musl
-          #- nightly-32
-          #- nightly-mips
-          #- nightly-arm
-          #- macos
-          # - win-msvc
-          #- win-gnu
-        include:
-          - build: pinned
-            os: ubuntu-22.04
-            rust: 1.65.0
-          - build: stable
-            os: ubuntu-22.04
-            rust: stable
-          - build: beta
-            os: ubuntu-22.04
-            rust: beta
-          - build: nightly
-            os: ubuntu-22.04
-            rust: nightly
-          - build: nightly-musl
-            os: ubuntu-22.04
-            rust: nightly
-            target: x86_64-unknown-linux-musl
-            #- build: nightly-32
-            #  os: ubuntu-22.04
-            #  rust: nightly
-            #  target: i686-unknown-linux-gnu
-            #- build: nightly-mips
-            #  os: ubuntu-22.04
-            #  rust: nightly
-            #  target: mips64-unknown-linux-gnuabi64
-            #- build: nightly-arm
-            #  os: ubuntu-22.04
-            #  rust: nightly
-            #  target: arm-unknown-linux-gnueabihf
-            #- build: macos
-            #  os: macos-12
-            #  rust: nightly
-            #- build: win-msvc
-            #  os: windows-2022
-            #  rust: nightly
-            #- build: win-gnu
-            #  os: windows-2022
-            #  rust: nightly-x86_64-gnu
-    steps:
-      - name: Checkout repository
-        uses: actions/checkout@v3
-      #- name: Install packages (Ubuntu)
-      #  if: matrix.os == 'ubuntu-22.04'
-      #  run: |
-      #    ci/ubuntu-install-packages
-      - name: Install packages (macOS)
-        if: matrix.os == 'macos-12'
-        run: |
-          ci/scripts/macos-install-packages
-      - name: Set up QEMU
-        uses: docker/setup-qemu-action@v2
-      - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v2.0.0
-      - name: Install Rust
-        uses: dtolnay/rust-toolchain@master
-        with:
-          toolchain: ${{ matrix.rust }}
-      - name: Use Cross
-        if: matrix.target != ''
-        run: |
-          cargo install cross
-          echo "CARGO=cross" >> $GITHUB_ENV
-          echo "TARGET_FLAGS=--target ${{ matrix.target }}" >> $GITHUB_ENV
-          echo "TARGET_DIR=./target/${{ matrix.target }}" >> $GITHUB_ENV
-      - name: Show command used for Cargo
-        run: |
-          echo "cargo command is: ${{ env.CARGO }}"
-          echo "target flag is: ${{ env.TARGET_FLAGS }}"
-      - name: Build
-        run: ${{ env.CARGO }} build --verbose --workspace ${{ env.TARGET_FLAGS }}
-      - name: Run tests (without cross)
-        if: matrix.target == ''
-        run: ${{ env.CARGO }} test --verbose --workspace ${{ env.TARGET_FLAGS }}
-        #- name: Run tests (with cross)
-        #  if: matrix.target != ''
-        #  run: ${{ env.CARGO }} test --verbose --workspace ${{ env.TARGET_FLAGS }}
-  test_multi_platform:
-    runs-on: ${{ matrix.os }}
-    strategy:
-      matrix:
-        os:
-          - macos-latest
-          - ubuntu-latest
-          #- windows-latest
-    steps:
-      - uses: actions/checkout@v3
-      - name: Install packages (macOS)
-        if: matrix.os == 'macos-latest'
-        run: |
-          ci/scripts/macos-install-packages
-      - name: Set up QEMU
-        uses: docker/setup-qemu-action@v2
-      - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v2.0.0
-      - name: Install Rust
-        uses: dtolnay/rust-toolchain@master
-        with:
-          toolchain: nightly
-      - name: Run unit tests
-        run: cargo test --locked --all-targets --workspace --all-features
-        timeout-minutes: 10
-  rustfmt:
-    name: rustfmt
-    runs-on: ubuntu-22.04
-    steps:
-      - name: Checkout repository
-        uses: actions/checkout@v3
-      - name: Install Rust
-        uses: dtolnay/rust-toolchain@master
-        with:
-          toolchain: stable
-          components: rustfmt
-      - name: Check formatting
-        run: cargo fmt --all --check

ARCHITECTURE.md

@@ -1,7 +1,7 @@
 # Architecture
 
-- `crates/dagger-bootstrap` Root project mainly used for generating the CLI,
+- `.` Root project mainly used for generating the CLI, which in turn is used to
-  which in turn is used to bootstrap the code generation from `dagger`
+  bootstrap the code generation from `dagger`
 - `crates/dagger-core` Contains all base types used during actual usage. This is
   where the primary logic lives in which the user interacts (\*disclaimer: most
   stuff haven't moved in here yet.)

Cargo.lock

@@ -24,14 +24,16 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "eab1c04a571841102f5345a8fc0f6bb3d31c315dec879b5c6e42e40ce7ffa34e"
 
 [[package]]
-name = "async-trait"
+name = "async-compression"
-version = "0.1.67"
+version = "0.3.15"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "86ea188f25f0255d8f92797797c97ebf5631fa88178beb1a46fdf5622c9a00e4"
+checksum = "942c7cd7ae39e91bde4820d74132e9862e62c2f386c3aa90ccf55949f5bad63a"
 dependencies = [
- "proc-macro2",
+ "flate2",
- "quote",
+ "futures-core",
- "syn 2.0.11",
+ "memchr",
+ "pin-project-lite",
+ "tokio",
 ]
 
 [[package]]
@@ -67,12 +69,6 @@ version = "1.3.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "bef38d45163c2f1dde094a7dfd33ccf595c92905c8f8f4fdc18d06fb1037718a"
 
-[[package]]
-name = "bitflags"
-version = "2.0.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d5dd14596c0e5b954530d0e6f1fd99b89c03e313aa2086e8da4303701a09e1cf"
-
 [[package]]
 name = "block-buffer"
 version = "0.10.4"
@@ -125,11 +121,11 @@ dependencies = [
 
 [[package]]
 name = "clap"
-version = "4.1.11"
+version = "4.1.8"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "42dfd32784433290c51d92c438bb72ea5063797fc3cc9a21a8c4346bebbb2098"
+checksum = "c3d7ae14b20b94cb02149ed21a86c423859cbe18dc7ed69845cace50e52b40a5"
 dependencies = [
- "bitflags 2.0.1",
+ "bitflags",
  "clap_lex",
  "is-terminal",
  "strsim",
@@ -138,9 +134,9 @@ dependencies = [
 
 [[package]]
 name = "clap_lex"
-version = "0.3.3"
+version = "0.3.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "033f6b7a4acb1f358c742aaca805c939ee73b4c6209ae4318ec7aca81c42e646"
+checksum = "350b9cf31731f9957399229e9b2adc51eeabdfbe9d71d9a0552275fd12710d09"
 dependencies = [
  "os_str_bytes",
 ]
@@ -194,6 +190,22 @@ dependencies = [
  "unicode-segmentation",
 ]
 
+[[package]]
+name = "core-foundation"
+version = "0.9.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "194a7a9e6de53fa55116934067c844d9d749312f75c6f6d0980e8c252f8c2146"
+dependencies = [
+ "core-foundation-sys",
+ "libc",
+]
+
+[[package]]
+name = "core-foundation-sys"
+version = "0.8.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5827cebf4670468b8772dd191856768aedcb1b0278a04f989f7766351917b9dc"
+
 [[package]]
 name = "cpufeatures"
 version = "0.2.5"
@@ -229,21 +241,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "6d2301688392eb071b0bf1a37be05c469d3cc4dbbd95df672fe28ab021e6a096"
 dependencies = [
  "quote",
- "syn 1.0.109",
+ "syn",
-]
-
-[[package]]
-name = "dagger-bootstrap"
-version = "0.2.10"
-dependencies = [
- "clap",
- "color-eyre",
- "dagger-codegen",
- "dagger-core",
- "eyre",
- "serde",
- "serde_json",
- "tokio",
 ]
 
 [[package]]
@@ -264,11 +262,10 @@ dependencies = [
 name = "dagger-core"
 version = "0.2.8"
 dependencies = [
- "async-trait",
- "base64",
  "dirs",
  "eyre",
  "flate2",
+ "graphql-introspection-query",
  "graphql_client",
  "hex",
  "hex-literal",
@@ -284,15 +281,42 @@ dependencies = [
  "tracing-subscriber",
 ]
 
+[[package]]
+name = "dagger-rs"
+version = "0.2.10"
+dependencies = [
+ "clap",
+ "color-eyre",
+ "dagger-codegen",
+ "dagger-core",
+ "dirs",
+ "eyre",
+ "flate2",
+ "graphql-introspection-query",
+ "graphql_client",
+ "hex",
+ "hex-literal",
+ "platform-info",
+ "reqwest",
+ "serde",
+ "serde_json",
+ "sha2",
+ "tar",
+ "tempfile",
+ "tokio",
+]
+
 [[package]]
 name = "dagger-sdk"
 version = "0.2.19"
 dependencies = [
+ "base64",
  "dagger-core",
  "derive_builder",
  "eyre",
  "futures",
  "genco",
+ "gql_client",
  "pretty_assertions",
  "rand",
  "serde",
@@ -324,7 +348,7 @@ dependencies = [
  "proc-macro2",
  "quote",
  "strsim",
- "syn 1.0.109",
+ "syn",
 ]
 
 [[package]]
@@ -335,7 +359,7 @@ checksum = "a4aab4dbc9f7611d8b55048a3a16d2d010c2c8334e46304b40ac1cc14bf3b48e"
 dependencies = [
  "darling_core",
  "quote",
- "syn 1.0.109",
+ "syn",
 ]
 
 [[package]]
@@ -356,7 +380,7 @@ dependencies = [
  "darling",
  "proc-macro2",
  "quote",
- "syn 1.0.109",
+ "syn",
 ]
 
 [[package]]
@@ -366,7 +390,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "ebcda35c7a396850a55ffeac740804b40ffec779b98fffbb1738f4033f0ee79e"
 dependencies = [
  "derive_builder_core",
- "syn 1.0.109",
+ "syn",
 ]
 
 [[package]]
@@ -479,6 +503,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "a8a2db397cb1c8772f31494cb8917e48cd1e64f0fa7efac59fbd741a0a8ce841"
 dependencies = [
  "crc32fast",
+ "libz-sys",
  "miniz_oxide",
 ]
 
@@ -488,6 +513,21 @@ version = "1.0.7"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "3f9eec918d3f24069decb9af1554cad7c880e2da24a9afd88aca000531ab82c1"
 
+[[package]]
+name = "foreign-types"
+version = "0.3.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f6f339eb8adc052cd2ca78910fda869aefa38d22d5cb648e6485e4d3fc06f3b1"
+dependencies = [
+ "foreign-types-shared",
+]
+
+[[package]]
+name = "foreign-types-shared"
+version = "0.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "00b0228411908ca8685dba7fc2cdd70ec9990a6e753e89b6ac91a84c40fbaf4b"
+
 [[package]]
 name = "form_urlencoded"
 version = "1.1.0"
@@ -499,9 +539,9 @@ dependencies = [
 
 [[package]]
 name = "futures"
-version = "0.3.28"
+version = "0.3.27"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "23342abe12aba583913b2e62f22225ff9c950774065e4bfb61a19cd9770fec40"
+checksum = "531ac96c6ff5fd7c62263c5e3c67a603af4fcaee2e1a0ae5565ba3a11e69e549"
 dependencies = [
  "futures-channel",
  "futures-core",
@@ -514,9 +554,9 @@ dependencies = [
 
 [[package]]
 name = "futures-channel"
-version = "0.3.28"
+version = "0.3.27"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "955518d47e09b25bbebc7a18df10b81f0c766eaf4c4f1cccef2fca5f2a4fb5f2"
+checksum = "164713a5a0dcc3e7b4b1ed7d3b433cabc18025386f9339346e8daf15963cf7ac"
 dependencies = [
  "futures-core",
  "futures-sink",
@@ -524,15 +564,15 @@ dependencies = [
 
 [[package]]
 name = "futures-core"
-version = "0.3.28"
+version = "0.3.27"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "4bca583b7e26f571124fe5b7561d49cb2868d79116cfa0eefce955557c6fee8c"
+checksum = "86d7a0c1aa76363dac491de0ee99faf6941128376f1cf96f07db7603b7de69dd"
 
 [[package]]
 name = "futures-executor"
-version = "0.3.28"
+version = "0.3.27"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "ccecee823288125bd88b4d7f565c9e58e41858e47ab72e8ea2d64e93624386e0"
+checksum = "1997dd9df74cdac935c76252744c1ed5794fac083242ea4fe77ef3ed60ba0f83"
 dependencies = [
  "futures-core",
  "futures-task",
@@ -541,38 +581,38 @@ dependencies = [
 
 [[package]]
 name = "futures-io"
-version = "0.3.28"
+version = "0.3.27"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "4fff74096e71ed47f8e023204cfd0aa1289cd54ae5430a9523be060cdb849964"
+checksum = "89d422fa3cbe3b40dca574ab087abb5bc98258ea57eea3fd6f1fa7162c778b91"
 
 [[package]]
 name = "futures-macro"
-version = "0.3.28"
+version = "0.3.27"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "89ca545a94061b6365f2c7355b4b32bd20df3ff95f02da9329b34ccc3bd6ee72"
+checksum = "3eb14ed937631bd8b8b8977f2c198443447a8355b6e3ca599f38c975e5a963b6"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.11",
+ "syn",
 ]
 
 [[package]]
 name = "futures-sink"
-version = "0.3.28"
+version = "0.3.27"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f43be4fe21a13b9781a69afa4985b0f6ee0e1afab2c6f454a8cf30e2b2237b6e"
+checksum = "ec93083a4aecafb2a80a885c9de1f0ccae9dbd32c2bb54b0c3a65690e0b8d2f2"
 
 [[package]]
 name = "futures-task"
-version = "0.3.28"
+version = "0.3.27"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "76d3d132be6c0e6aa1534069c705a74a5997a356c0dc2f86a47765e5617c5b65"
+checksum = "fd65540d33b37b16542a0438c12e6aeead10d4ac5d05bd3f805b8f35ab592879"
 
 [[package]]
 name = "futures-util"
-version = "0.3.28"
+version = "0.3.27"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "26b01e40b772d54cf6c6d721c1d1abd0647a0106a12ecaa1c186273392a69533"
+checksum = "3ef6b17e481503ec85211fed8f39d1970f128935ca1f814cd32ac4a6842e84ab"
 dependencies = [
  "futures-channel",
  "futures-core",
@@ -605,7 +645,7 @@ checksum = "c85fd34848b1f708e6344a4af6f7bfc05172ae20ce4b35c8e417efffb4f306aa"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 1.0.109",
+ "syn",
 ]
 
 [[package]]
@@ -635,6 +675,18 @@ version = "0.27.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "ad0a93d233ebf96623465aad4046a8d3aa4da22d4f4beba5388838c8a434bbb4"
 
+[[package]]
+name = "gql_client"
+version = "1.0.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e57f4862d3e5cd4ffe8df03fa2137e620e33578bbc1895e6f8f569630e17b1db"
+dependencies = [
+ "log",
+ "reqwest",
+ "serde",
+ "serde_json",
+]
+
 [[package]]
 name = "graphql-introspection-query"
 version = "0.2.0"
@@ -680,7 +732,7 @@ dependencies = [
  "quote",
  "serde",
  "serde_json",
- "syn 1.0.109",
+ "syn",
 ]
 
 [[package]]
@@ -691,7 +743,7 @@ checksum = "d52fc9cde811f44b15ec0692b31e56a3067f6f431c5ace712f286e47c1dacc98"
 dependencies = [
  "graphql_client_codegen",
  "proc-macro2",
- "syn 1.0.109",
+ "syn",
 ]
 
 [[package]]
@@ -811,16 +863,16 @@ dependencies = [
 ]
 
 [[package]]
-name = "hyper-rustls"
+name = "hyper-tls"
-version = "0.23.2"
+version = "0.5.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "1788965e61b367cd03a62950836d5cd41560c3577d90e40e0819373194d1661c"
+checksum = "d6183ddfa99b85da61a140bea0efc93fdf56ceaa041b37d553518030827f9905"
 dependencies = [
- "http",
+ "bytes",
  "hyper",
- "rustls",
+ "native-tls",
  "tokio",
- "tokio-rustls",
+ "tokio-native-tls",
 ]
 
 [[package]]
@@ -866,11 +918,10 @@ dependencies = [
 
 [[package]]
 name = "io-lifetimes"
-version = "1.0.8"
+version = "1.0.6"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0dd6da19f25979c7270e70fa95ab371ec3b701cd0eefc47667a09785b3c59155"
+checksum = "cfa919a82ea574332e2de6e74b4c36e74d41982b335080fa59d4ef31be20fdf3"
 dependencies = [
- "hermit-abi 0.3.1",
  "libc",
  "windows-sys 0.45.0",
 ]
@@ -883,9 +934,9 @@ checksum = "30e22bd8629359895450b59ea7a776c850561b96a3b1d31321c1949d9e6c9146"
 
 [[package]]
 name = "is-terminal"
-version = "0.4.5"
+version = "0.4.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "8687c819457e979cc940d09cb16e42a1bf70aa6b60a549de6d3a62a0ee90c69e"
+checksum = "21b6b32576413a8e69b90e952e4a026476040d81017b80445deda5f2d3921857"
 dependencies = [
  "hermit-abi 0.3.1",
  "io-lifetimes",
@@ -929,6 +980,17 @@ version = "0.2.140"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "99227334921fae1a979cf0bfdfcc6b3e5ce376ef57e16fb6fb3ea2ed6095f80c"
 
+[[package]]
+name = "libz-sys"
+version = "1.1.8"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9702761c3935f8cc2f101793272e202c72b99da8f4224a19ddcf1279a6450bbf"
+dependencies = [
+ "cc",
+ "pkg-config",
+ "vcpkg",
+]
+
 [[package]]
 name = "linux-raw-sys"
 version = "0.1.4"
@@ -996,6 +1058,24 @@ dependencies = [
  "windows-sys 0.45.0",
 ]
 
+[[package]]
+name = "native-tls"
+version = "0.2.11"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "07226173c32f2926027b63cce4bcd8076c3552846cbe7925f3aaffeac0a3b92e"
+dependencies = [
+ "lazy_static",
+ "libc",
+ "log",
+ "openssl",
+ "openssl-probe",
+ "openssl-sys",
+ "schannel",
+ "security-framework",
+ "security-framework-sys",
+ "tempfile",
+]
+
 [[package]]
 name = "nu-ansi-term"
 version = "0.46.0"
@@ -1031,6 +1111,51 @@ version = "1.17.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "b7e5500299e16ebb147ae15a00a942af264cf3688f47923b8fc2cd5858f23ad3"
 
+[[package]]
+name = "openssl"
+version = "0.10.45"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b102428fd03bc5edf97f62620f7298614c45cedf287c271e7ed450bbaf83f2e1"
+dependencies = [
+ "bitflags",
+ "cfg-if",
+ "foreign-types",
+ "libc",
+ "once_cell",
+ "openssl-macros",
+ "openssl-sys",
+]
+
+[[package]]
+name = "openssl-macros"
+version = "0.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b501e44f11665960c7e7fcf062c7d96a14ade4aa98116c004b2e37b5be7d736c"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "openssl-probe"
+version = "0.1.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ff011a302c396a5197692431fc1948019154afc178baf7d8e37367442a4601cf"
+
+[[package]]
+name = "openssl-sys"
+version = "0.9.80"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "23bbbf7854cd45b83958ebe919f0e8e516793727652e27fda10a8384cfc790b7"
+dependencies = [
+ "autocfg",
+ "cc",
+ "libc",
+ "pkg-config",
+ "vcpkg",
+]
+
 [[package]]
 name = "os_str_bytes"
 version = "6.4.1"
@@ -1099,6 +1224,12 @@ version = "0.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "8b870d8c151b6f2fb93e84a13146138f05d02ed11c7e7c54f8826aaaf7c9f184"
 
+[[package]]
+name = "pkg-config"
+version = "0.3.26"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6ac9a59f73473f1b8d852421e59e64809f025994837ef743615c6d0c5b305160"
+
 [[package]]
 name = "platform-info"
 version = "1.0.2"
@@ -1181,7 +1312,7 @@ version = "0.2.16"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "fb5a58c1855b4b6819d59012155603f0b22ad30cad752600aadfcb695265519a"
 dependencies = [
- "bitflags 1.3.2",
+ "bitflags",
 ]
 
 [[package]]
@@ -1231,6 +1362,7 @@ version = "0.11.14"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "21eed90ec8570952d53b772ecf8f206aa1ec9a3d76b2521c56c42973f2d91ee9"
 dependencies = [
+ "async-compression",
  "base64",
  "bytes",
  "encoding_rs",
@@ -1240,21 +1372,20 @@ dependencies = [
  "http",
  "http-body",
  "hyper",
- "hyper-rustls",
+ "hyper-tls",
  "ipnet",
  "js-sys",
  "log",
  "mime",
+ "native-tls",
  "once_cell",
  "percent-encoding",
  "pin-project-lite",
- "rustls",
- "rustls-pemfile",
  "serde",
  "serde_json",
  "serde_urlencoded",
  "tokio",
- "tokio-rustls",
+ "tokio-native-tls",
  "tokio-util",
  "tower-service",
  "url",
@@ -1262,25 +1393,9 @@ dependencies = [
  "wasm-bindgen-futures",
  "wasm-streams",
  "web-sys",
- "webpki-roots",
  "winreg",
 ]
 
-[[package]]
-name = "ring"
-version = "0.16.20"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "3053cf52e236a3ed746dfc745aa9cacf1b791d846bdaf412f60a8d7d6e17c8fc"
-dependencies = [
- "cc",
- "libc",
- "once_cell",
- "spin",
- "untrusted",
- "web-sys",
- "winapi",
-]
-
 [[package]]
 name = "rustc-demangle"
 version = "0.1.21"
@@ -1289,11 +1404,11 @@ checksum = "7ef03e0a2b150c7a90d01faf6254c9c48a41e95fb2a8c2ac1c6f0d2b9aefc342"
 
 [[package]]
 name = "rustix"
-version = "0.36.10"
+version = "0.36.9"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "2fe885c3a125aa45213b68cc1472a49880cb5923dc23f522ad2791b882228778"
+checksum = "fd5c6ff11fecd55b40746d1995a02f2eb375bf8c00d192d521ee09f42bef37bc"
 dependencies = [
- "bitflags 1.3.2",
+ "bitflags",
  "errno",
  "io-lifetimes",
  "libc",
@@ -1301,33 +1416,21 @@ dependencies = [
  "windows-sys 0.45.0",
 ]
 
-[[package]]
-name = "rustls"
-version = "0.20.8"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "fff78fc74d175294f4e83b28343315ffcfb114b156f0185e9741cb5570f50e2f"
-dependencies = [
- "log",
- "ring",
- "sct",
- "webpki",
-]
-
-[[package]]
-name = "rustls-pemfile"
-version = "1.0.2"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d194b56d58803a43635bdc398cd17e383d6f71f9182b9a192c127ca42494a59b"
-dependencies = [
- "base64",
-]
-
 [[package]]
 name = "ryu"
 version = "1.0.13"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "f91339c0467de62360649f8d3e185ca8de4224ff281f66000de5eb2a77a79041"
 
+[[package]]
+name = "schannel"
+version = "0.1.21"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "713cfb06c7059f3588fb8044c0fad1d09e3c01d225e25b9220dbfdcf16dbb1b3"
+dependencies = [
+ "windows-sys 0.42.0",
+]
+
 [[package]]
 name = "scopeguard"
 version = "1.1.0"
@@ -1335,33 +1438,46 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "d29ab0c6d3fc0ee92fe66e2d99f700eab17a8d57d1c1d3b748380fb20baa78cd"
 
 [[package]]
-name = "sct"
+name = "security-framework"
-version = "0.7.0"
+version = "2.8.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d53dcdb7c9f8158937a7981b48accfd39a43af418591a5d008c7b22b5e1b7ca4"
+checksum = "a332be01508d814fed64bf28f798a146d73792121129962fdf335bb3c49a4254"
 dependencies = [
- "ring",
+ "bitflags",
- "untrusted",
+ "core-foundation",
+ "core-foundation-sys",
+ "libc",
+ "security-framework-sys",
+]
+
+[[package]]
+name = "security-framework-sys"
+version = "2.8.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "31c9bb296072e961fcbd8853511dd39c2d8be2deb1e17c6860b1d30732b323b4"
+dependencies = [
+ "core-foundation-sys",
+ "libc",
 ]
 
 [[package]]
 name = "serde"
-version = "1.0.157"
+version = "1.0.156"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "707de5fcf5df2b5788fca98dd7eab490bc2fd9b7ef1404defc462833b83f25ca"
+checksum = "314b5b092c0ade17c00142951e50ced110ec27cea304b1037c6969246c2469a4"
 dependencies = [
  "serde_derive",
 ]
 
 [[package]]
 name = "serde_derive"
-version = "1.0.157"
+version = "1.0.156"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "78997f4555c22a7971214540c4a661291970619afd56de19f77e0de86296e1e5"
+checksum = "d7e29c4601e36bcec74a223228dce795f4cd3616341a4af93520ca1a837c087d"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.11",
+ "syn",
 ]
 
 [[package]]
@@ -1441,12 +1557,6 @@ dependencies = [
  "winapi",
 ]
 
-[[package]]
-name = "spin"
-version = "0.5.2"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "6e63cff320ae2c57904679ba7cb63280a3dc4613885beafb148ee7bf9aa9042d"
-
 [[package]]
 name = "strsim"
 version = "0.10.0"
@@ -1464,17 +1574,6 @@ dependencies = [
  "unicode-ident",
 ]
 
-[[package]]
-name = "syn"
-version = "2.0.11"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "21e3787bb71465627110e7d87ed4faaa36c1f61042ee67badb9e2ef173accc40"
-dependencies = [
- "proc-macro2",
- "quote",
- "unicode-ident",
-]
-
 [[package]]
 name = "tar"
 version = "0.4.38"
@@ -1510,22 +1609,22 @@ dependencies = [
 
 [[package]]
 name = "thiserror"
-version = "1.0.40"
+version = "1.0.39"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "978c9a314bd8dc99be594bc3c175faaa9794be04a5a5e153caba6915336cebac"
+checksum = "a5ab016db510546d856297882807df8da66a16fb8c4101cb8b30054b0d5b2d9c"
 dependencies = [
  "thiserror-impl",
 ]
 
 [[package]]
 name = "thiserror-impl"
-version = "1.0.40"
+version = "1.0.39"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f9456a42c5b0d803c8cd86e73dd7cc9edd429499f37a3550d286d5e86720569f"
+checksum = "5420d42e90af0c38c3290abcca25b9b3bdf379fc9f55c528f53a269d9c9a267e"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 2.0.11",
+ "syn",
 ]
 
 [[package]]
@@ -1581,18 +1680,17 @@ checksum = "d266c00fde287f55d3f1c3e96c500c362a2b8c695076ec180f27918820bc6df8"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 1.0.109",
+ "syn",
 ]
 
 [[package]]
-name = "tokio-rustls"
+name = "tokio-native-tls"
-version = "0.23.4"
+version = "0.3.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "c43ee83903113e03984cb9e5cebe6c04a5116269e900e3ddba8f068a62adda59"
+checksum = "bbae76ab933c85776efabc971569dd6119c580d8f5d448769dec1764bf796ef2"
 dependencies = [
- "rustls",
+ "native-tls",
  "tokio",
- "webpki",
 ]
 
 [[package]]
@@ -1636,7 +1734,7 @@ checksum = "4017f8f45139870ca7e672686113917c71c7a6e02d4924eda67186083c03081a"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 1.0.109",
+ "syn",
 ]
 
 [[package]]
@@ -1708,7 +1806,7 @@ checksum = "258bc1c4f8e2e73a977812ab339d503e6feeb92700f6d07a6de4d321522d5c08"
 dependencies = [
  "lazy_static",
  "quote",
- "syn 1.0.109",
+ "syn",
 ]
 
 [[package]]
@@ -1725,9 +1823,9 @@ checksum = "497961ef93d974e23eb6f433eb5fe1b7930b659f06d12dec6fc44a8f554c0bba"
 
 [[package]]
 name = "unicode-bidi"
-version = "0.3.12"
+version = "0.3.11"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "7d502c968c6a838ead8e69b2ee18ec708802f99db92a0d156705ec9ef801993b"
+checksum = "524b68aca1d05e03fdf03fcdce2c6c94b6daf6d16861ddaa7e4f2b6638a9052c"
 
 [[package]]
 name = "unicode-ident"
@@ -1759,12 +1857,6 @@ dependencies = [
  "void",
 ]
 
-[[package]]
-name = "untrusted"
-version = "0.7.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "a156c684c91ea7d62626509bce3cb4e1d9ed5c4d978f7b4352658f96a4c26b4a"
-
 [[package]]
 name = "url"
 version = "2.3.1"
@@ -1782,6 +1874,12 @@ version = "0.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "830b7e5d4d90034032940e4ace0d9a9a057e7a45cd94e6c007832e39edb82f6d"
 
+[[package]]
+name = "vcpkg"
+version = "0.2.15"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "accd4ea62f7bb7a82fe23066fb0957d48ef677f6eeb8215f372f52e48bb32426"
+
 [[package]]
 name = "version_check"
 version = "0.9.4"
@@ -1831,7 +1929,7 @@ dependencies = [
  "once_cell",
  "proc-macro2",
  "quote",
- "syn 1.0.109",
+ "syn",
  "wasm-bindgen-shared",
 ]
 
@@ -1865,7 +1963,7 @@ checksum = "2aff81306fcac3c7515ad4e177f521b5c9a15f2b08f4e32d823066102f35a5f6"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn 1.0.109",
+ "syn",
  "wasm-bindgen-backend",
  "wasm-bindgen-shared",
 ]
@@ -1899,25 +1997,6 @@ dependencies = [
  "wasm-bindgen",
 ]
 
-[[package]]
-name = "webpki"
-version = "0.22.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f095d78192e208183081cc07bc5515ef55216397af48b873e5edcd72637fa1bd"
-dependencies = [
- "ring",
- "untrusted",
-]
-
-[[package]]
-name = "webpki-roots"
-version = "0.22.6"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "b6c71e40d7d2c34a5106301fb632274ca37242cd0c9d3e64dbece371a40a2d87"
-dependencies = [
- "webpki",
-]
-
 [[package]]
 name = "winapi"
 version = "0.3.9"

Cargo.toml

@@ -3,14 +3,14 @@ members = [
   "crates/dagger-codegen",
   "crates/dagger-sdk",
   "crates/dagger-core",
-  "crates/dagger-bootstrap",
+  "crates/dagger-rs",
   "ci",
 ]
 
 [workspace.dependencies]
 dagger-codegen = { path = "crates/dagger-codegen", version = "^0.2.5" }
 dagger-core = { path = "crates/dagger-core", version = "^0.2.8" }
-dagger-bootstrap = { path = "crates/dagger-bootstrap", version = "^0.2.10" }
+dagger-rs = { path = "crates/dagger-rs", version = "^0.2.10" }
 dagger-sdk = { path = "crates/dagger-sdk", version = "^0.2.19" }
 
 eyre = "0.6.8"

Cross.toml

@@ -1,2 +0,0 @@
-[target.x86_64-unknown-linux-musl]
-image = "messense/rust-musl-cross:x86_64-musl"

Makefile.toml

@@ -8,7 +8,7 @@ command = "cargo"
 args = [
   "run",
   "-p",
-  "dagger-bootstrap",
+  "dagger-rs",
   "--",
   "generate",
   "--output",

ci/scripts/macos-install-packages

@@ -1,4 +0,0 @@
-#!/bin/sh
-
-brew install docker
-colima start

ci/src/main.rs

@@ -48,8 +48,6 @@ async fn run_codegen(client: Arc<Query>, _subm: &ArgMatches) -> eyre::Result<()>
         .with_exec(vec![
             "cargo",
             "run",
-            "-p",
-            "dagger-bootstrap",
             "--",
             "generate",
             "--output",
@@ -92,7 +90,7 @@ async fn release(client: Arc<Query>, _subm: &clap::ArgMatches) -> Result<(), col
             "--execute",
             "--allow-fully-generated-changelogs",
             "--no-changelog-preview",
-            "dagger-sdk",
+            "dagger-rs",
             "dagger-sdk",
         ]);
     let exit = container.exit_code().await?;

crates/dagger-codegen/Cargo.toml

@@ -5,7 +5,7 @@ edition = "2021"
 readme = "README.md"
 license-file = "LICENSE.MIT"
 description = "dagger sdk codegen library"
-repository = "https://github.com/kjuulh/dagger-sdk"
+repository = "https://github.com/kjuulh/dagger-rs"
 publish = true
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 

crates/dagger-codegen/src/rust/functions.rs

@@ -247,7 +247,7 @@ fn render_execution(funcs: &CommonFunctions, field: &FullTypeFields) -> rust::To
             return $(output_type) {
                 proc: self.proc.clone(),
                 selection: query,
-                graphql_client: self.graphql_client.clone(),
+                conn: self.conn.clone(),
             }
         };
     }
@@ -273,13 +273,15 @@ fn render_execution(funcs: &CommonFunctions, field: &FullTypeFields) -> rust::To
             return vec![$(output_type) {
                 proc: self.proc.clone(),
                 selection: query,
-                graphql_client: self.graphql_client.clone(),
+                conn: self.conn.clone(),
             }]
         };
     }
 
+    let graphql_client = rust::import("crate::client", "graphql_client");
+
     quote! {
-        query.execute(self.graphql_client.clone()).await
+        query.execute(&$graphql_client(&self.conn)).await
     }
 }
 

crates/dagger-codegen/src/rust/templates/object_tmpl.rs

@@ -12,15 +12,15 @@ use crate::utility::OptionExt;
 pub fn render_object(funcs: &CommonFunctions, t: &FullType) -> eyre::Result<rust::Tokens> {
     let selection = rust::import("crate::querybuilder", "Selection");
     let child = rust::import("tokio::process", "Child");
-    let graphql_client = rust::import("dagger_core::graphql_client", "DynGraphQLClient");
+    let conn = rust::import("dagger_core::connect_params", "ConnectParams");
     let arc = rust::import("std::sync", "Arc");
 
     Ok(quote! {
-        #[derive(Clone)]
+        #[derive(Debug, Clone)]
         pub struct $(t.name.pipe(|s| format_name(s))) {
             pub proc: $arc<$child>,
             pub selection: $selection,
-            pub graphql_client: $graphql_client
+            pub conn: $conn,
         }
 
         $(t.fields.pipe(|f| render_optional_args(funcs, f)))

crates/dagger-core/Cargo.toml

@@ -5,7 +5,7 @@ edition = "2021"
 readme = "README.md"
 license-file = "LICENSE.MIT"
 description = "dagger sdk core library"
-repository = "https://github.com/kjuulh/dagger-sdk"
+repository = "https://github.com/kjuulh/dagger-rs"
 publish = true
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
@@ -17,22 +17,14 @@ tokio = { workspace = true }
 tracing = { workspace = true }
 tracing-subscriber = { workspace = true }
 
-base64 = "0.21.0"
 dirs = "4.0.0"
-flate2 = { version = "1.0.25", features = ["rust_backend"] }
+flate2 = { version = "1.0.25", features = ["zlib"] }
-graphql_client = { version = "0.12.0", features = [
+graphql-introspection-query = "0.2.0"
-  "reqwest-rustls",
+graphql_client = { version = "0.12.0", features = ["reqwest"] }
-  "graphql_query_derive",
-], default-features = false }
 hex = "0.4.3"
 hex-literal = "0.3.4"
 platform-info = "1.0.2"
-reqwest = { version = "0.11.14", features = [
+reqwest = { version = "0.11.14", features = ["stream", "deflate"] }
-  "stream",
-  "rustls-tls",
-], default-features = false }
-
 sha2 = "0.10.6"
 tar = "0.4.38"
 tempfile = "3.3.0"
-async-trait = "0.1.67"

crates/dagger-core/src/gql_client.rs

@@ -1,375 +0,0 @@
-use reqwest::Error;
-use reqwest::{Client, Url};
-use serde::{Deserialize, Serialize};
-use std::collections::HashMap;
-use std::fmt::{self, Formatter};
-use std::str::FromStr;
-
-#[derive(Clone)]
-pub struct GraphQLError {
-    message: String,
-    json: Option<Vec<GraphQLErrorMessage>>,
-}
-
-// https://spec.graphql.org/June2018/#sec-Errors
-#[derive(Deserialize, Debug, Clone)]
-#[allow(dead_code)]
-pub struct GraphQLErrorMessage {
-    message: String,
-    locations: Option<Vec<GraphQLErrorLocation>>,
-    extensions: Option<HashMap<String, String>>,
-    path: Option<Vec<GraphQLErrorPathParam>>,
-}
-
-#[derive(Deserialize, Debug, Clone)]
-#[allow(dead_code)]
-pub struct GraphQLErrorLocation {
-    line: u32,
-    column: u32,
-}
-
-#[derive(Deserialize, Debug, Clone)]
-#[serde(untagged)]
-pub enum GraphQLErrorPathParam {
-    String(String),
-    Number(u32),
-}
-
-impl GraphQLError {
-    pub fn with_text(message: impl AsRef<str>) -> Self {
-        Self {
-            message: message.as_ref().to_string(),
-            json: None,
-        }
-    }
-
-    pub fn with_message_and_json(message: impl AsRef<str>, json: Vec<GraphQLErrorMessage>) -> Self {
-        Self {
-            message: message.as_ref().to_string(),
-            json: Some(json),
-        }
-    }
-
-    pub fn with_json(json: Vec<GraphQLErrorMessage>) -> Self {
-        Self::with_message_and_json("Look at json field for more details", json)
-    }
-
-    pub fn message(&self) -> &str {
-        &self.message
-    }
-
-    pub fn json(&self) -> Option<Vec<GraphQLErrorMessage>> {
-        self.json.clone()
-    }
-}
-
-fn format(err: &GraphQLError, f: &mut Formatter<'_>) -> fmt::Result {
-    // Print the main error message
-    writeln!(f, "\nGQLClient Error: {}", err.message)?;
-
-    // Check if query errors have been received
-    if err.json.is_none() {
-        return Ok(());
-    }
-
-    let errors = err.json.as_ref();
-
-    for err in errors.unwrap() {
-        writeln!(f, "Message: {}", err.message)?;
-    }
-
-    Ok(())
-}
-
-impl fmt::Display for GraphQLError {
-    fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result {
-        format(self, f)
-    }
-}
-
-impl fmt::Debug for GraphQLError {
-    #[allow(clippy::needless_borrow)]
-    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
-        format(&self, f)
-    }
-}
-
-impl From<Error> for GraphQLError {
-    fn from(error: Error) -> Self {
-        Self {
-            message: error.to_string(),
-            json: None,
-        }
-    }
-}
-
-/// GQL client config
-#[derive(Clone, Debug, Deserialize, Serialize)]
-pub struct ClientConfig {
-    /// the endpoint about graphql server
-    pub endpoint: String,
-    /// gql query timeout, unit: seconds
-    pub timeout: Option<u64>,
-    /// additional request header
-    pub headers: Option<HashMap<String, String>>,
-    /// request proxy
-    pub proxy: Option<GQLProxy>,
-}
-
-/// proxy type
-#[derive(Clone, Debug, Deserialize, Serialize)]
-pub enum ProxyType {
-    Http,
-    Https,
-    All,
-}
-
-/// proxy auth, basic_auth
-#[derive(Clone, Debug, Deserialize, Serialize)]
-pub struct ProxyAuth {
-    pub username: String,
-    pub password: String,
-}
-
-/// request proxy
-#[derive(Clone, Debug, Deserialize, Serialize)]
-pub struct GQLProxy {
-    /// schema, proxy url
-    pub schema: String,
-    /// proxy type
-    pub type_: ProxyType,
-    /// auth
-    pub auth: Option<ProxyAuth>,
-}
-
-#[cfg(not(target_arch = "wasm32"))]
-impl TryFrom<GQLProxy> for reqwest::Proxy {
-    type Error = GraphQLError;
-
-    fn try_from(gql_proxy: GQLProxy) -> Result<Self, Self::Error> {
-        let proxy = match gql_proxy.type_ {
-            ProxyType::Http => reqwest::Proxy::http(gql_proxy.schema),
-            ProxyType::Https => reqwest::Proxy::https(gql_proxy.schema),
-            ProxyType::All => reqwest::Proxy::all(gql_proxy.schema),
-        }
-        .map_err(|e| Self::Error::with_text(format!("{:?}", e)))?;
-        Ok(proxy)
-    }
-}
-
-#[derive(Clone, Debug)]
-pub struct GQLClient {
-    config: ClientConfig,
-}
-
-#[derive(Serialize)]
-struct RequestBody<T: Serialize> {
-    query: String,
-    variables: T,
-}
-
-#[derive(Deserialize, Debug)]
-struct GraphQLResponse<T> {
-    data: Option<T>,
-    errors: Option<Vec<GraphQLErrorMessage>>,
-}
-
-impl GQLClient {
-    fn client(&self) -> Result<Client, GraphQLError> {
-        let mut builder = Client::builder().timeout(std::time::Duration::from_secs(
-            self.config.timeout.unwrap_or(5),
-        ));
-        if let Some(proxy) = &self.config.proxy {
-            builder = builder.proxy(proxy.clone().try_into()?);
-        }
-        builder
-            .build()
-            .map_err(|e| GraphQLError::with_text(format!("Can not create client: {:?}", e)))
-    }
-}
-
-impl GQLClient {
-    pub fn new(endpoint: impl AsRef<str>) -> Self {
-        Self {
-            config: ClientConfig {
-                endpoint: endpoint.as_ref().to_string(),
-                timeout: None,
-                headers: Default::default(),
-                proxy: None,
-            },
-        }
-    }
-
-    pub fn new_with_headers(
-        endpoint: impl AsRef<str>,
-        headers: HashMap<impl ToString, impl ToString>,
-    ) -> Self {
-        let _headers: HashMap<String, String> = headers
-            .iter()
-            .map(|(name, value)| (name.to_string(), value.to_string()))
-            .into_iter()
-            .collect();
-        Self {
-            config: ClientConfig {
-                endpoint: endpoint.as_ref().to_string(),
-                timeout: None,
-                headers: Some(_headers),
-                proxy: None,
-            },
-        }
-    }
-
-    pub fn new_with_config(config: ClientConfig) -> Self {
-        Self { config }
-    }
-}
-
-impl GQLClient {
-    pub async fn query<K>(&self, query: &str) -> Result<Option<K>, GraphQLError>
-    where
-        K: for<'de> Deserialize<'de>,
-    {
-        self.query_with_vars::<K, ()>(query, ()).await
-    }
-
-    pub async fn query_unwrap<K>(&self, query: &str) -> Result<K, GraphQLError>
-    where
-        K: for<'de> Deserialize<'de>,
-    {
-        self.query_with_vars_unwrap::<K, ()>(query, ()).await
-    }
-
-    pub async fn query_with_vars_unwrap<K, T: Serialize>(
-        &self,
-        query: &str,
-        variables: T,
-    ) -> Result<K, GraphQLError>
-    where
-        K: for<'de> Deserialize<'de>,
-    {
-        match self.query_with_vars(query, variables).await? {
-            Some(v) => Ok(v),
-            None => Err(GraphQLError::with_text(format!(
-                "No data from graphql server({}) for this query",
-                self.config.endpoint
-            ))),
-        }
-    }
-
-    pub async fn query_with_vars<K, T: Serialize>(
-        &self,
-        query: &str,
-        variables: T,
-    ) -> Result<Option<K>, GraphQLError>
-    where
-        K: for<'de> Deserialize<'de>,
-    {
-        self.query_with_vars_by_endpoint(&self.config.endpoint, query, variables)
-            .await
-    }
-
-    async fn query_with_vars_by_endpoint<K, T: Serialize>(
-        &self,
-        endpoint: impl AsRef<str>,
-        query: &str,
-        variables: T,
-    ) -> Result<Option<K>, GraphQLError>
-    where
-        K: for<'de> Deserialize<'de>,
-    {
-        let mut times = 1;
-        let mut endpoint = endpoint.as_ref().to_string();
-        let endpoint_url = Url::from_str(&endpoint).map_err(|e| {
-            GraphQLError::with_text(format!("Wrong endpoint: {}. {:?}", endpoint, e))
-        })?;
-        let schema = endpoint_url.scheme();
-        let host = endpoint_url
-            .host()
-            .ok_or_else(|| GraphQLError::with_text(format!("Wrong endpoint: {}", endpoint)))?;
-
-        let client: Client = self.client()?;
-        let body = RequestBody {
-            query: query.to_string(),
-            variables,
-        };
-
-        loop {
-            if times > 10 {
-                return Err(GraphQLError::with_text(format!(
-                    "Many redirect location: {}",
-                    endpoint
-                )));
-            }
-
-            let mut request = client.post(&endpoint).json(&body);
-            if let Some(headers) = &self.config.headers {
-                if !headers.is_empty() {
-                    for (name, value) in headers {
-                        request = request.header(name, value);
-                    }
-                }
-            }
-
-            let raw_response = request.send().await?;
-            if let Some(location) = raw_response.headers().get(reqwest::header::LOCATION) {
-                let redirect_url = location.to_str().map_err(|e| {
-                    GraphQLError::with_text(format!(
-                        "Failed to parse response header: Location. {:?}",
-                        e
-                    ))
-                })?;
-
-                // if the response location start with http:// or https://
-                if redirect_url.starts_with("http://") || redirect_url.starts_with("https://") {
-                    times += 1;
-                    endpoint = redirect_url.to_string();
-                    continue;
-                }
-
-                // without schema
-                endpoint = if redirect_url.starts_with('/') {
-                    format!("{}://{}{}", schema, host, redirect_url)
-                } else {
-                    format!("{}://{}/{}", schema, host, redirect_url)
-                };
-                times += 1;
-                continue;
-            }
-
-            let status = raw_response.status();
-            let response_body_text = raw_response
-                .text()
-                .await
-                .map_err(|e| GraphQLError::with_text(format!("Can not get response: {:?}", e)))?;
-
-            let json: GraphQLResponse<K> =
-                serde_json::from_str(&response_body_text).map_err(|e| {
-                    GraphQLError::with_text(format!(
-                        "Failed to parse response: {:?}. The response body is: {}",
-                        e, response_body_text
-                    ))
-                })?;
-
-            if !status.is_success() {
-                return Err(GraphQLError::with_message_and_json(
-                    format!("The response is [{}]", status.as_u16()),
-                    json.errors.unwrap_or_default(),
-                ));
-            }
-
-            // Check if error messages have been received
-            if json.errors.is_some() {
-                return Err(GraphQLError::with_json(json.errors.unwrap_or_default()));
-            }
-            if json.data.is_none() {
-                tracing::warn!(
-                    target = "gql-client",
-                    response_text = response_body_text,
-                    "The deserialized data is none, the response",
-                );
-            }
-
-            return Ok(json.data);
-        }
-    }
-}

crates/dagger-core/src/graphql_client.rs

@@ -1,52 +0,0 @@
-use std::collections::HashMap;
-use std::sync::Arc;
-
-use async_trait::async_trait;
-use base64::engine::general_purpose;
-use base64::Engine;
-
-use crate::connect_params::ConnectParams;
-use crate::gql_client::{ClientConfig, GQLClient};
-
-#[async_trait]
-pub trait GraphQLClient {
-    async fn query(&self, query: &str) -> eyre::Result<Option<serde_json::Value>>;
-}
-
-pub type DynGraphQLClient = Arc<dyn GraphQLClient + Send + Sync>;
-
-#[derive(Debug)]
-pub struct DefaultGraphQLClient {
-    client: GQLClient,
-}
-
-impl DefaultGraphQLClient {
-    pub fn new(conn: &ConnectParams) -> Self {
-        let token = general_purpose::URL_SAFE.encode(format!("{}:", conn.session_token));
-
-        let mut headers = HashMap::new();
-        headers.insert("Authorization".to_string(), format!("Basic {}", token));
-
-        Self {
-            client: GQLClient::new_with_config(ClientConfig {
-                endpoint: conn.url(),
-                timeout: Some(1000),
-                headers: Some(headers),
-                proxy: None,
-            }),
-        }
-    }
-}
-
-#[async_trait]
-impl GraphQLClient for DefaultGraphQLClient {
-    async fn query(&self, query: &str) -> eyre::Result<Option<serde_json::Value>> {
-        let res: Option<serde_json::Value> = self
-            .client
-            .query(&query)
-            .await
-            .map_err(|r| eyre::anyhow!(r.to_string()))?;
-
-        return Ok(res);
-    }
-}

crates/dagger-core/src/lib.rs

@@ -1,14 +1,12 @@
 #![deny(warnings)]
 
-pub const DAGGER_ENGINE_VERSION: &'static str = "0.4.2";
+pub const DAGGER_ENGINE_VERSION: &'static str = "0.4.0";
 
 pub mod cli_session;
 pub mod config;
 pub mod connect_params;
 pub mod downloader;
 pub mod engine;
-pub mod gql_client;
-pub mod graphql_client;
 pub mod introspection;
 pub mod logger;
 pub mod schema;

crates/dagger-rs/Cargo.toml

@@ -1,11 +1,11 @@
 [package]
-name = "dagger-bootstrap"
+name = "dagger-rs"
 version = "0.2.10"
 edition = "2021"
 readme = "README.md"
 license-file = "LICENSE.MIT"
 description = "A dagger sdk for rust, written in rust"
-repository = "https://github.com/kjuulh/dagger-sdk"
+repository = "https://github.com/kjuulh/dagger-rs"
 publish = true
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
@@ -21,3 +21,14 @@ serde_json = { workspace = true }
 tokio = { workspace = true }
 
 clap = "4.1.6"
+dirs = "4.0.0"
+flate2 = { version = "1.0.25", features = ["zlib"] }
+graphql-introspection-query = "0.2.0"
+graphql_client = { version = "0.12.0", features = ["reqwest"] }
+hex = "0.4.3"
+hex-literal = "0.3.4"
+platform-info = "1.0.2"
+reqwest = { version = "0.11.14", features = ["stream", "deflate"] }
+sha2 = "0.10.6"
+tar = "0.4.38"
+tempfile = "3.3.0"

crates/dagger-sdk/Cargo.toml

@@ -5,7 +5,7 @@ edition = "2021"
 readme = "README.md"
 license-file = "LICENSE.MIT"
 description = "A dagger sdk for rust, written in rust"
-repository = "https://github.com/kjuulh/dagger-sdk"
+repository = "https://github.com/kjuulh/dagger-rs"
 publish = true
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
@@ -20,7 +20,9 @@ serde_json = { workspace = true }
 tracing.workspace = true
 tracing-subscriber.workspace = true
 
-futures = "0.3.28"
+base64 = "0.21.0"
+futures = "0.3.27"
+gql_client = "1.0.7"
 derive_builder = "0.12.0"
 
 [dev-dependencies]

crates/dagger-sdk/examples/caching/main.rs

@@ -35,7 +35,7 @@ async fn main() -> eyre::Result<()> {
         .container()
         .from("nginx")
         .with_directory("/usr/share/nginx/html", build_dir.id().await?)
-        .publish(format!("ttl.sh/hello-dagger-sdk-{}:1h", rng.gen::<u64>()))
+        .publish(format!("ttl.sh/hello-dagger-rs-{}:1h", rng.gen::<u64>()))
         .await?;
 
     println!("published image to: {}", ref_);

crates/dagger-sdk/examples/existing-dockerfile/main.rs

@@ -13,7 +13,7 @@ async fn main() -> eyre::Result<()> {
     let ref_ = client
         .container()
         .build(context_dir.id().await?)
-        .publish(format!("ttl.sh/hello-dagger-sdk-{}:1h", rng.gen::<u64>()))
+        .publish(format!("ttl.sh/hello-dagger-rs-{}:1h", rng.gen::<u64>()))
         .await?;
 
     println!("published image to: {}", ref_);

crates/dagger-sdk/examples/multi-stage-build/main.rs

@@ -34,7 +34,7 @@ async fn main() -> eyre::Result<()> {
         .container()
         .from("nginx")
         .with_directory("/usr/share/nginx/html", build_dir.id().await?)
-        .publish(format!("ttl.sh/hello-dagger-sdk-{}:1h", rng.gen::<u64>()))
+        .publish(format!("ttl.sh/hello-dagger-rs-{}:1h", rng.gen::<u64>()))
         .await?;
 
     println!("published image to: {}", ref_);

crates/dagger-sdk/examples/publish-the-application/main.rs

@@ -39,7 +39,7 @@ async fn main() -> eyre::Result<()> {
             "/usr/share/nginx/html",
             client.host().directory(output).id().await?,
         )
-        .publish(format!("ttl.sh/hello-dagger-sdk-{}:1h", rng.gen::<u64>()))
+        .publish(format!("ttl.sh/hello-dagger-rs-{}:1h", rng.gen::<u64>()))
         .await?;
 
     println!("published image to: {}", ref_);

crates/dagger-sdk/src/client.rs

@@ -1,8 +1,12 @@
+use std::collections::HashMap;
 use std::sync::Arc;
 
-use dagger_core::graphql_client::DefaultGraphQLClient;
+use base64::engine::general_purpose;
+use base64::Engine;
+use gql_client::ClientConfig;
 
 use dagger_core::config::Config;
+use dagger_core::connect_params::ConnectParams;
 use dagger_core::engine::Engine as DaggerEngine;
 
 use crate::gen::Query;
@@ -21,12 +25,26 @@ pub async fn connect_opts(cfg: Config) -> eyre::Result<DaggerConn> {
     let (conn, proc) = DaggerEngine::new().start(&cfg).await?;
 
     Ok(Arc::new(Query {
+        conn,
         proc: Arc::new(proc),
         selection: query(),
-        graphql_client: Arc::new(DefaultGraphQLClient::new(&conn)),
     }))
 }
 
+pub fn graphql_client(conn: &ConnectParams) -> gql_client::Client {
+    let token = general_purpose::URL_SAFE.encode(format!("{}:", conn.session_token));
+
+    let mut headers = HashMap::new();
+    headers.insert("Authorization".to_string(), format!("Basic {}", token));
+
+    gql_client::Client::new_with_config(ClientConfig {
+        endpoint: conn.url(),
+        timeout: Some(1000),
+        headers: Some(headers),
+        proxy: None,
+    })
+}
+
 // Conn will automatically close on drop of proc
 
 #[cfg(test)]

crates/dagger-sdk/src/querybuilder.rs

@@ -1,6 +1,5 @@
 use std::{collections::HashMap, ops::Add, sync::Arc};
 
-use dagger_core::graphql_client::DynGraphQLClient;
 use eyre::Context;
 use serde::{Deserialize, Serialize};
 
@@ -117,7 +116,7 @@ impl Selection {
         Ok(fields.join("{") + &"}".repeat(fields.len() - 1))
     }
 
-    pub async fn execute<D>(&self, gql_client: DynGraphQLClient) -> eyre::Result<D>
+    pub async fn execute<D>(&self, gql_client: &gql_client::Client) -> eyre::Result<D>
     where
         D: for<'de> Deserialize<'de>,
     {