blossom

.gitignore

@@ -30,7 +30,7 @@ migrate_working_dir/
 build/
 /coverage/*
 /lcov_badge_generator
-/.flutter-plugins
-/.flutter-plugins-dependencies
+.flutter-plugins
+.flutter-plugins-dependencies
 /packages/ndk/coverage/*
 /packages/ndk/coverage.lcov

packages/amber/pubspec.lock

@@ -469,7 +469,7 @@ packages:
       path: "../ndk"
       relative: true
     source: path
-    version: "0.2.0"
+    version: "0.2.4"
   package_config:
     dependency: transitive
     description:

packages/isar/pubspec.lock

@@ -375,7 +375,7 @@ packages:
       path: "../ndk"
       relative: true
     source: path
-    version: "0.2.0"
+    version: "0.2.4"
   node_preamble:
     dependency: transitive
     description:

packages/ndk/example/files/blossom_example_test.dart

@@ -0,0 +1,22 @@
+// ignore_for_file: avoid_print
+
+import 'package:ndk/ndk.dart';
+import 'package:test/test.dart';
+
+void main() async {
+  test('download test', () async {
+    final ndk = Ndk.defaultConfig();
+
+    final downloadResult = await ndk.blossom.getBlob(
+      sha256:
+          "b1674191a88ec5cdd733e4240a81803105dc412d6c6708d53ab94fc248f4f553",
+      serverUrls: ["https://cdn.hzrd149.com"],
+    );
+
+    print(
+      "file of type: ${downloadResult.mimeType}, size: ${downloadResult.data.length}",
+    );
+
+    expect(downloadResult.data.length, greaterThan(0));
+  });
+}

packages/ndk/example/files/files_example_test.dart

@@ -0,0 +1,31 @@
+// ignore_for_file: avoid_print
+
+import 'package:ndk/ndk.dart';
+import 'package:test/test.dart';
+
+void main() async {
+  test('download test - blossom', () async {
+    final ndk = Ndk.defaultConfig();
+
+    final downloadResult = await ndk.files.download(
+        url:
+            "https://cdn.hzrd149.com/b1674191a88ec5cdd733e4240a81803105dc412d6c6708d53ab94fc248f4f553.pdf");
+
+    print(
+        "file of type: ${downloadResult.mimeType}, size: ${downloadResult.data.length}");
+
+    expect(downloadResult.data.length, greaterThan(0));
+  });
+
+  test('download test - non blossom', () async {
+    final ndk = Ndk.defaultConfig();
+
+    final downloadResult = await ndk.files
+        .download(url: "https://camelus.app/.well-known/nostr.json");
+
+    print(
+        "file of type: ${downloadResult.mimeType}, size: ${downloadResult.data.length}");
+
+    expect(downloadResult.data.length, greaterThan(0));
+  });
+}

packages/ndk/lib/config/blossom_config.dart

@@ -0,0 +1,4 @@
+// ignore_for_file: constant_identifier_names
+
+/// how long nostr auth messages are valid for
+const Duration BLOSSOM_AUTH_EXPIRATION = Duration(minutes: 5);

packages/ndk/lib/data_layer/data_sources/http_request.dart

@@ -1,4 +1,5 @@
 import 'dart:convert';
+import 'dart:typed_data';
 
 import 'package:http/http.dart' as http;
 
@@ -21,4 +22,93 @@
     }
     return jsonDecode(response.body);
   }
+
+  Future<http.Response> put({
+    required Uri url,
+    required Uint8List body,
+    required headers,
+  }) async {
+    http.Response response = await _client.put(
+      url,
+      body: body,
+      headers: headers,
+    );
+
+    if (response.statusCode != 200) {
+      throw Exception(
+          "error fetching STATUS: ${response.statusCode}, Link: $url");
+    }
+
+    return response;
+  }
+
+  Future<http.Response> post({
+    required Uri url,
+    required Uint8List body,
+    required headers,
+  }) async {
+    http.Response response = await _client.post(
+      url,
+      body: body,
+      headers: headers,
+    );
+
+    if (response.statusCode != 200) {
+      throw Exception(
+          "error fetching STATUS: ${response.statusCode}, Link: $url");
+    }
+
+    return response;
+  }
+
+  Future<http.Response> head({
+    required Uri url,
+    headers,
+  }) async {
+    http.Response response = await _client.head(
+      url,
+      headers: headers,
+    );
+
+    if (response.statusCode != 200) {
+      throw Exception(
+          "error fetching STATUS: ${response.statusCode}, Link: $url");
+    }
+
+    return response;
+  }
+
+  Future<http.Response> get({
+    required Uri url,
+    headers,
+  }) async {
+    http.Response response = await _client.get(
+      url,
+      headers: headers,
+    );
+
+    if (response.statusCode != 200) {
+      throw Exception(
+          "error fetching STATUS: ${response.statusCode}, Link: $url");
+    }
+
+    return response;
+  }
+
+  Future<http.Response> delete({
+    required Uri url,
+    required headers,
+  }) async {
+    http.Response response = await _client.delete(
+      url,
+      headers: headers,
+    );
+
+    if (response.statusCode != 200) {
+      throw Exception(
+          "error fetching STATUS: ${response.statusCode}, Link: $url");
+    }
+
+    return response;
+  }
 }