@@ -85,65 +85,67 @@ public void downloadUrl(final String javascriptStorageBucket,
85
85
final StorageReference fileRef = storageRef .child (path );
86
86
87
87
Task <Uri > downloadTask = fileRef .getDownloadUrl ();
88
- downloadTask .addOnSuccessListener (new OnSuccessListener <Uri >() {
89
- @ Override
90
- public void onSuccess (Uri uri ) {
91
- final WritableMap res = Arguments .createMap ();
92
-
93
- res .putString ("status" , "success" );
94
- res .putString ("bucket" , storageRef .getBucket ());
95
- res .putString ("fullPath" , uri .toString ());
96
- res .putString ("path" , uri .getPath ());
97
- res .putString ("url" , uri .toString ());
98
-
99
- fileRef .getMetadata ()
100
- .addOnSuccessListener (new OnSuccessListener <StorageMetadata >() {
101
- @ Override
102
- public void onSuccess (final StorageMetadata storageMetadata ) {
103
- Log .d (TAG , "getMetadata success " + storageMetadata );
104
- res .putString ("name" , storageMetadata .getName ());
105
-
106
- WritableMap metadata = Arguments .createMap ();
107
- metadata .putString ("getBucket" , storageMetadata .getBucket ());
108
- metadata .putString ("getName" , storageMetadata .getName ());
109
- metadata .putDouble ("sizeBytes" , storageMetadata .getSizeBytes ());
110
- metadata .putDouble ("created_at" , storageMetadata .getCreationTimeMillis ());
111
- metadata .putDouble ("updated_at" , storageMetadata .getUpdatedTimeMillis ());
112
- metadata .putString ("md5hash" , storageMetadata .getMd5Hash ());
113
- metadata .putString ("encoding" , storageMetadata .getContentEncoding ());
114
- res .putString ("url" , storageMetadata .getDownloadUrl ().toString ());
115
-
116
- res .putMap ("metadata" , metadata );
117
- callback .invoke (null , res );
118
- }
119
- }).addOnFailureListener (new OnFailureListener () {
88
+ downloadTask
89
+ .addOnSuccessListener (new OnSuccessListener <Uri >() {
120
90
@ Override
121
- public void onFailure (@ NonNull Exception exception ) {
122
- Log .e (TAG , "Failure in download " + exception );
123
- callback .invoke (makeErrorPayload (1 , exception ));
124
- }
125
- });
91
+ public void onSuccess (Uri uri ) {
92
+ final WritableMap res = Arguments .createMap ();
93
+
94
+ res .putString ("status" , "success" );
95
+ res .putString ("bucket" , storageRef .getBucket ());
96
+ res .putString ("fullPath" , uri .toString ());
97
+ res .putString ("path" , uri .getPath ());
98
+ res .putString ("url" , uri .toString ());
99
+
100
+ fileRef .getMetadata ()
101
+ .addOnSuccessListener (new OnSuccessListener <StorageMetadata >() {
102
+ @ Override
103
+ public void onSuccess (final StorageMetadata storageMetadata ) {
104
+ Log .d (TAG , "getMetadata success " + storageMetadata );
105
+ res .putString ("name" , storageMetadata .getName ());
106
+
107
+ WritableMap metadata = Arguments .createMap ();
108
+ metadata .putString ("getBucket" , storageMetadata .getBucket ());
109
+ metadata .putString ("getName" , storageMetadata .getName ());
110
+ metadata .putDouble ("sizeBytes" , storageMetadata .getSizeBytes ());
111
+ metadata .putDouble ("created_at" , storageMetadata .getCreationTimeMillis ());
112
+ metadata .putDouble ("updated_at" , storageMetadata .getUpdatedTimeMillis ());
113
+ metadata .putString ("md5hash" , storageMetadata .getMd5Hash ());
114
+ metadata .putString ("encoding" , storageMetadata .getContentEncoding ());
115
+ res .putString ("url" , storageMetadata .getDownloadUrl ().toString ());
116
+
117
+ res .putMap ("metadata" , metadata );
118
+ callback .invoke (null , res );
119
+ }
120
+ })
121
+ .addOnFailureListener (new OnFailureListener () {
122
+ @ Override
123
+ public void onFailure (@ NonNull Exception exception ) {
124
+ Log .e (TAG , "Failure in download " + exception );
125
+ callback .invoke (makeErrorPayload (1 , exception ));
126
+ }
127
+ });
126
128
127
- }
128
- }).addOnFailureListener (new OnFailureListener () {
129
- @ Override
130
- public void onFailure (@ NonNull Exception exception ) {
131
- Log .e (TAG , "Failed to download file " + exception .getMessage ());
129
+ }
130
+ })
131
+ .addOnFailureListener (new OnFailureListener () {
132
+ @ Override
133
+ public void onFailure (@ NonNull Exception exception ) {
134
+ Log .e (TAG , "Failed to download file " + exception .getMessage ());
132
135
133
- WritableMap err = Arguments .createMap ();
134
- err .putString ("status" , "error" );
135
- err .putString ("description" , exception .getLocalizedMessage ());
136
+ WritableMap err = Arguments .createMap ();
137
+ err .putString ("status" , "error" );
138
+ err .putString ("description" , exception .getLocalizedMessage ());
136
139
137
- callback .invoke (err );
138
- }
139
- });
140
+ callback .invoke (err );
141
+ }
142
+ });
140
143
}
141
144
142
145
// STORAGE
143
146
@ ReactMethod
144
147
public void uploadFile (final String urlStr , final String name , final String filepath , final ReadableMap metadata , final Callback callback ) {
145
148
FirebaseStorage storage = FirebaseStorage .getInstance ();
146
-
147
149
StorageReference storageRef = storage .getReferenceFromUrl (urlStr );
148
150
StorageReference fileRef = storageRef .child (name );
149
151
@@ -161,29 +163,30 @@ public void uploadFile(final String urlStr, final String name, final String file
161
163
162
164
StorageMetadata md = metadataBuilder .build ();
163
165
UploadTask uploadTask = fileRef .putFile (file , md );
164
- // uploadTask uploadTask = fileRef.putStream(stream, md);
165
166
166
167
// Register observers to listen for when the download is done or if it fails
167
- uploadTask .addOnFailureListener (new OnFailureListener () {
168
- @ Override
169
- public void onFailure (@ NonNull Exception exception ) {
170
- // Handle unsuccessful uploads
171
- Log .e (TAG , "Failed to upload file " + exception .getMessage ());
172
-
173
- WritableMap err = Arguments .createMap ();
174
- err .putString ("description" , exception .getLocalizedMessage ());
175
-
176
- callback .invoke (err );
177
- }
178
- }).addOnSuccessListener (new OnSuccessListener <UploadTask .TaskSnapshot >() {
179
- @ Override
180
- public void onSuccess (UploadTask .TaskSnapshot taskSnapshot ) {
181
- Log .d (TAG , "Successfully uploaded file " + taskSnapshot );
182
- // taskSnapshot.getMetadata() contains file metadata such as size, content-type, and download URL.
183
- WritableMap resp = getDownloadData (taskSnapshot );
184
- callback .invoke (null , resp );
185
- }
186
- })
168
+ uploadTask
169
+ .addOnFailureListener (new OnFailureListener () {
170
+ @ Override
171
+ public void onFailure (@ NonNull Exception exception ) {
172
+ // Handle unsuccessful uploads
173
+ Log .e (TAG , "Failed to upload file " + exception .getMessage ());
174
+
175
+ WritableMap err = Arguments .createMap ();
176
+ err .putString ("description" , exception .getLocalizedMessage ());
177
+
178
+ callback .invoke (err );
179
+ }
180
+ })
181
+ .addOnSuccessListener (new OnSuccessListener <UploadTask .TaskSnapshot >() {
182
+ @ Override
183
+ public void onSuccess (UploadTask .TaskSnapshot taskSnapshot ) {
184
+ Log .d (TAG , "Successfully uploaded file " + taskSnapshot );
185
+ // taskSnapshot.getMetadata() contains file metadata such as size, content-type, and download URL.
186
+ WritableMap resp = getDownloadData (taskSnapshot );
187
+ callback .invoke (null , resp );
188
+ }
189
+ })
187
190
.addOnProgressListener (new OnProgressListener <UploadTask .TaskSnapshot >() {
188
191
@ Override
189
192
public void onProgress (UploadTask .TaskSnapshot taskSnapshot ) {
@@ -200,18 +203,19 @@ public void onProgress(UploadTask.TaskSnapshot taskSnapshot) {
200
203
FirestackUtils .sendEvent (mReactContext , "upload_progress" , data );
201
204
}
202
205
}
203
- }).addOnPausedListener (new OnPausedListener <UploadTask .TaskSnapshot >() {
204
- @ Override
205
- public void onPaused (UploadTask .TaskSnapshot taskSnapshot ) {
206
- System .out .println ("Upload is paused" );
207
- StorageMetadata d = taskSnapshot .getMetadata ();
208
- String bucket = d .getBucket ();
209
- WritableMap data = Arguments .createMap ();
210
- data .putString ("eventName" , "upload_paused" );
211
- data .putString ("ref" , bucket );
212
- FirestackUtils .sendEvent (mReactContext , "upload_paused" , data );
213
- }
214
- });
206
+ })
207
+ .addOnPausedListener (new OnPausedListener <UploadTask .TaskSnapshot >() {
208
+ @ Override
209
+ public void onPaused (UploadTask .TaskSnapshot taskSnapshot ) {
210
+ System .out .println ("Upload is paused" );
211
+ StorageMetadata d = taskSnapshot .getMetadata ();
212
+ String bucket = d .getBucket ();
213
+ WritableMap data = Arguments .createMap ();
214
+ data .putString ("eventName" , "upload_paused" );
215
+ data .putString ("ref" , bucket );
216
+ FirestackUtils .sendEvent (mReactContext , "upload_paused" , data );
217
+ }
218
+ });
215
219
} catch (Exception ex ) {
216
220
callback .invoke (makeErrorPayload (2 , ex ));
217
221
}
0 commit comments