Firestorage integration

firebase.json

@@ -6,10 +6,16 @@
     "ui": {
       "enabled": true
     },
-    "singleProjectMode": true
+    "singleProjectMode": true,
+    "storage": {
+      "port": 9199
+    }
   },
   "firestore": {
     "rules": "firestore.rules",
     "indexes": "firestore.indexes.json"
+  },
+  "storage": {
+    "rules": "storage.rules"
   }
 }

lib/features/posts/data/firestorage/firestorage_event.dart

@@ -0,0 +1,40 @@
+import 'package:firebase_storage/firebase_storage.dart';
+
+class FirestorageEventPaused extends FirestorageEvent {
+  const FirestorageEventPaused(super.event);
+}
+
+class FirestorageEventRunning extends FirestorageEvent {
+  const FirestorageEventRunning(super.event);
+}
+
+class FirestorageEventSuccess extends FirestorageEvent {
+  const FirestorageEventSuccess(super.event);
+  Future<String> get downloadURL => _event.ref.getDownloadURL();
+}
+
+class FirestorageEventCanceled extends FirestorageEvent {
+  const FirestorageEventCanceled(super.event);
+}
+
+class FirestorageEventError extends FirestorageEvent {
+  const FirestorageEventError(super.event);
+}
+
+sealed class FirestorageEvent {
+  const FirestorageEvent(this._event);
+  final TaskSnapshot _event;
+  int get bytesTransferred => _event.bytesTransferred;
+  int get totalBytes => _event.totalBytes;
+
+  factory FirestorageEvent.fromSnapshot(TaskSnapshot event) => switch (event) {
+        TaskSnapshot(state: TaskState.paused) => FirestorageEventPaused(event),
+        TaskSnapshot(state: TaskState.running) =>
+          FirestorageEventRunning(event),
+        TaskSnapshot(state: TaskState.success) =>
+          FirestorageEventSuccess(event),
+        TaskSnapshot(state: TaskState.canceled) =>
+          FirestorageEventCanceled(event),
+        TaskSnapshot(state: TaskState.error) => FirestorageEventError(event),
+      };
+}

lib/features/posts/data/firestorage/posts_firestorage.dart

@@ -0,0 +1,23 @@
+import 'dart:io';
+
+import 'package:firebase_storage/firebase_storage.dart';
+import 'package:instreal/features/posts/data/firestorage/firestorage_event.dart';
+
+abstract interface class PostsFirestorage {
+  Stream<FirestorageEvent> upload(File image);
+}
+
+class PostsFirestorageImpl implements PostsFirestorage {
+  PostsFirestorageImpl({FirebaseStorage? storage})
+      : storageRef = (storage ?? FirebaseStorage.instance).ref("posts");
+
+  final Reference storageRef;
+
+  @override
+  Stream<FirestorageEvent> upload(File image) {
+    final task = storageRef.child('image.jpg').putFile(image);
+    return task.snapshotEvents.map<FirestorageEvent>(
+      (event) => FirestorageEvent.fromSnapshot(event),
+    );
+  }
+}

lib/features/posts/posts_firestore.dart → lib/features/posts/data/firestore/posts_firestore.dart

@@ -1,5 +1,5 @@
 import 'package:cloud_firestore/cloud_firestore.dart';
-import 'package:instreal/features/posts/post_firestore_model.dart';
+import 'package:instreal/features/posts/data/firestore/post_firestore_model.dart';
 
 abstract interface class PostsFirestore {
   Future<List<PostFirestoreModel>> get posts;

lib/features/posts/post_entity.dart

@@ -1,16 +1,41 @@
+import 'dart:io';
+
 import 'package:flutter/material.dart';
 
 @immutable
-class Post {
+class Post extends PostEntity {
   final String id;
-  final String title;
-  final String author;
   final String imageUrl;
 
   const Post({
     required this.id,
-    required this.title,
-    required this.author,
+    required super.title,
+    required super.author,
     required this.imageUrl,
   });
 }
+
+@immutable
+class PostDraft extends PostEntity {
+  final File imageFile;
+
+  const PostDraft({
+    required super.title,
+    required super.author,
+    required this.imageFile,
+  });
+
+  Post toPost(String imageUrl) => Post(
+        id: "",
+        title: title,
+        author: author,
+        imageUrl: imageUrl,
+      );
+}
+
+@immutable
+sealed class PostEntity {
+  final String title;
+  final String author;
+  const PostEntity({required this.title, required this.author});
+}

lib/features/posts/posts_repository.dart

@@ -1,16 +1,18 @@
+import 'package:instreal/features/posts/data/firestorage/posts_firestorage.dart';
+import 'package:instreal/features/posts/data/firestore/post_firestore_model.dart';
+import 'package:instreal/features/posts/data/firestore/posts_firestore.dart';
 import 'package:instreal/features/posts/post_entity.dart';
-import 'package:instreal/features/posts/post_firestore_model.dart';
-import 'package:instreal/features/posts/posts_firestore.dart';
 
 abstract interface class PostsRepository {
   Future<List<Post>> get posts;
   Future<String> add(Post posting);
 }
 
 class PostsRepositoryImpl implements PostsRepository {
-  PostsRepositoryImpl({required this.firestore});
+  PostsRepositoryImpl({required this.firestore, required this.firestorage});
 
   final PostsFirestore firestore;
+  final PostsFirestorage firestorage;
 
   @override
   Future<List<Post>> get posts async =>

lib/main.dart

@@ -1,5 +1,6 @@
 import 'package:cloud_firestore/cloud_firestore.dart';
 import 'package:firebase_core/firebase_core.dart';
+import 'package:firebase_storage/firebase_storage.dart';
 import 'package:flutter/foundation.dart';
 import 'package:flutter/material.dart';
 import 'package:google_fonts/google_fonts.dart';
@@ -16,12 +17,11 @@ void main() async {
 
   if (kDebugMode) {
     try {
-      FirebaseFirestore.instance.useFirestoreEmulator(
-        defaultTargetPlatform == TargetPlatform.android
-            ? "10.0.2.2"
-            : "localhost",
-        8080,
-      );
+      final emulatorHost = defaultTargetPlatform == TargetPlatform.android
+          ? "10.0.2.2"
+          : "localhost";
+      FirebaseStorage.instance.useStorageEmulator(emulatorHost, 9199);
+      FirebaseFirestore.instance.useFirestoreEmulator(emulatorHost, 8080);
     } catch (e) {
       // ignore: avoid_print
       print(e);

lib/presentation/screens/home/home.dart

@@ -1,7 +1,10 @@
+import 'dart:io';
+
 import 'package:flutter/material.dart';
 import 'package:google_fonts/google_fonts.dart';
+import 'package:instreal/features/posts/data/firestorage/posts_firestorage.dart';
 import 'package:instreal/features/posts/post_entity.dart';
-import 'package:instreal/features/posts/posts_firestore.dart';
+import 'package:instreal/features/posts/data/firestore/posts_firestore.dart';
 import 'package:instreal/features/posts/posts_repository.dart';
 import 'package:instreal/l10n/index.dart';
 import 'package:instreal/presentation/components/index.dart';
@@ -14,7 +17,10 @@ class MyHomePage extends StatefulWidget {
 }
 
 class _MyHomePageState extends State<MyHomePage> {
-  final postingsRepo = PostsRepositoryImpl(firestore: PostFirestoreImpl());
+  final postingsRepo = PostsRepositoryImpl(
+    firestore: PostFirestoreImpl(),
+    firestorage: PostsFirestorageImpl(),
+  );
 
   @override
   Widget build(BuildContext context) {
@@ -68,13 +74,13 @@ class _MyHomePageState extends State<MyHomePage> {
       floatingActionButton: FloatingActionButton(
         onPressed: () async {
           await postingsRepo.add(
-            const Post(
-              id: "",
+            PostDraft(
               title: 'title',
               author: 'author',
-              imageUrl:
-                  'https://i1.wp.com/www.suitcasescholar.com/wp-content/uploads/2012/08/DSC_2583.jpg',
-            ),
+              imageFile: File(
+                'https://i1.wp.com/www.suitcasescholar.com/wp-content/uploads/2012/08/DSC_2583.jpg',
+              ),
+            ).toPost('imageUrl'),
           );
           setState(() {});
         },

macos/Flutter/GeneratedPluginRegistrant.swift

@@ -7,10 +7,12 @@ import Foundation
 
 import cloud_firestore
 import firebase_core
+import firebase_storage
 import path_provider_foundation
 
 func RegisterGeneratedPlugins(registry: FlutterPluginRegistry) {
   FLTFirebaseFirestorePlugin.register(with: registry.registrar(forPlugin: "FLTFirebaseFirestorePlugin"))
   FLTFirebaseCorePlugin.register(with: registry.registrar(forPlugin: "FLTFirebaseCorePlugin"))
+  FLTFirebaseStoragePlugin.register(with: registry.registrar(forPlugin: "FLTFirebaseStoragePlugin"))
   PathProviderPlugin.register(with: registry.registrar(forPlugin: "PathProviderPlugin"))
 }

pubspec.lock

@@ -137,6 +137,30 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "2.6.0"
+  firebase_storage:
+    dependency: "direct main"
+    description:
+      name: firebase_storage
+      sha256: "195ae2b623ba054b9be3934c79bf6282831ca15a81cfd392841feea930e50253"
+      url: "https://pub.dev"
+    source: hosted
+    version: "11.2.4"
+  firebase_storage_platform_interface:
+    dependency: transitive
+    description:
+      name: firebase_storage_platform_interface
+      sha256: be0f4254cae3ccaefd5d1435b82c1fa3bda33187387b241c55b27d7516ea9b93
+      url: "https://pub.dev"
+    source: hosted
+    version: "4.4.3"
+  firebase_storage_web:
+    dependency: transitive
+    description:
+      name: firebase_storage_web
+      sha256: f02c63c871deb36180b39a5fab1ee5b2677a01fa0fb642746ca62ae7f9d1a482
+      url: "https://pub.dev"
+    source: hosted
+    version: "3.6.4"
   flutter:
     dependency: "direct main"
     description: flutter

pubspec.yaml

@@ -16,6 +16,7 @@ dependencies:
   google_fonts: ^5.0.0
   cloud_firestore: ^4.8.1
   firebase_core: ^2.14.0
+  firebase_storage: ^11.2.4
 
 dev_dependencies:
   flutter_test:

storage.rules

@@ -0,0 +1,12 @@
+rules_version = '2';
+
+// Craft rules based on data in your Firestore database
+// allow write: if firestore.get(
+//    /databases/(default)/documents/users/$(request.auth.uid)).data.isAdmin;
+service firebase.storage {
+  match /b/{bucket}/o {
+    match /{allPaths=**} {
+      allow read, write: if false;
+    }
+  }
+}

test/features/postings/post_firestore_model_test.dart → test/features/posts/data/firestore/post_firestore_model_test.dart

@@ -1,5 +1,5 @@
 import 'package:flutter_test/flutter_test.dart';
-import 'package:instreal/features/posts/post_firestore_model.dart';
+import 'package:instreal/features/posts/data/firestore/post_firestore_model.dart';
 
 void main() {
   test('convert json to model', () async {

test/features/postings/posts_repository_test.dart → test/features/posts/posts_repository_test.dart

@@ -1,6 +1,10 @@
+import 'dart:io';
+
 import 'package:flutter_test/flutter_test.dart';
-import 'package:instreal/features/posts/post_firestore_model.dart';
-import 'package:instreal/features/posts/posts_firestore.dart';
+import 'package:instreal/features/posts/data/firestorage/firestorage_event.dart';
+import 'package:instreal/features/posts/data/firestorage/posts_firestorage.dart';
+import 'package:instreal/features/posts/data/firestore/post_firestore_model.dart';
+import 'package:instreal/features/posts/data/firestore/posts_firestore.dart';
 import 'package:instreal/features/posts/posts_repository.dart';
 
 class MockFirestore implements PostsFirestore {
@@ -26,16 +30,27 @@ class MockFirestore implements PostsFirestore {
   }
 }
 
+class MockFireStorage implements PostsFirestorage {
+  @override
+  Stream<FirestorageEvent> upload(File image) {
+    throw UnimplementedError();
+  }
+}
+
 void main() {
   test('convert model to entity', () async {
     final mockStore = MockFirestore();
+    final mockStorage = MockFireStorage();
     final mockModelData = PostFirestoreModel.fromDocument({
       'title': 'title',
       'author': 'author',
       'imageUrl': 'imageUrl',
     }, 'id');
     mockStore.add(mockModelData);
-    final repo = PostsRepositoryImpl(firestore: mockStore);
+    final repo = PostsRepositoryImpl(
+      firestore: mockStore,
+      firestorage: mockStorage,
+    );
     final posts = await repo.posts;
     expect(posts.length, 1);
     expect(posts[0].id, 'id');