Page MenuHomePhorge
Files F32164228

D13409.1765047110.diff
No OneTemporary
Actions

Size
3 KB
Referenced Files
None
Subscribers
None

D13409.1765047110.diff
View Options

diff --git a/lib/actions/holder-actions.js b/lib/actions/holder-actions.js
--- a/lib/actions/holder-actions.js
+++ b/lib/actions/holder-actions.js
@@ -1,6 +1,11 @@
// @flow
+import blobService from '../facts/blob-service.js';
+import type { AuthMetadata } from '../shared/identity-client-context.js';
import type { BlobHashAndHolder } from '../types/holder-types.js';
+import { toBase64URL } from '../utils/base64.js';
+import { makeBlobServiceEndpointURL } from '../utils/blob-service.js';
+import { createDefaultHTTPRequestHeaders } from '../utils/services-utils.js';
type MultipleBlobHolders = $ReadOnlyArray<BlobHashAndHolder>;
export const storeEstablishedHolderActionType = 'STORE_ESTABLISHED_HOLDER';
@@ -21,3 +26,87 @@
notAdded: MultipleBlobHolders,
notRemoved: MultipleBlobHolders,
};
+
+// This function can be simplified when batch holders operations
+// are implemented on Blob Service
+async function performBlobServiceHolderActions(
+ action: 'establish' | 'remove',
+ inputs: MultipleBlobHolders,
+ authMetadata: AuthMetadata,
+): Promise<{
+ succeeded: MultipleBlobHolders,
+ failed: MultipleBlobHolders,
+}> {
+ if (inputs.length === 0) {
+ return { succeeded: [], failed: [] };
+ }
+
+ const assignHolderEndpoint =
+ action === 'establish'
+ ? blobService.httpEndpoints.ASSIGN_HOLDER
+ : blobService.httpEndpoints.DELETE_BLOB;
+ const endpointURL = makeBlobServiceEndpointURL(assignHolderEndpoint);
+ const defaultHeaders = createDefaultHTTPRequestHeaders(authMetadata);
+
+ const promises = inputs.map(async input => {
+ const blobHash = toBase64URL(input.blobHash);
+ try {
+ const response = await fetch(endpointURL, {
+ method: assignHolderEndpoint.method,
+ body: JSON.stringify({
+ holder: input.holder,
+ blob_hash: blobHash,
+ }),
+ headers: {
+ ...defaultHeaders,
+ 'content-type': 'application/json',
+ },
+ });
+ const holderAlreadyEstablishedResponse =
+ action === 'establish' && response.status === 409;
+ if (response.ok || holderAlreadyEstablishedResponse) {
+ return { ...input, success: true };
+ }
+ return { ...input, success: false };
+ } catch (e) {
+ return { ...input, success: false };
+ }
+ });
+
+ const results = await Promise.all(promises);
+ const succeeded = results
+ .filter(it => it.success)
+ .map(({ success, ...rest }) => rest);
+ const failed = results
+ .filter(it => !it.success)
+ .map(({ success, ...rest }) => rest);
+
+ return {
+ succeeded,
+ failed,
+ };
+}
+
+async function processHoldersAction(
+ input: ProcessHoldersStartedPayload,
+ authMetadata: AuthMetadata,
+): Promise<ProcessHoldersFinishedPayload> {
+ const [
+ { succeeded: added, failed: notAdded },
+ { succeeded: removed, failed: notRemoved },
+ ] = await Promise.all([
+ performBlobServiceHolderActions(
+ 'establish',
+ input.holdersToAdd,
+ authMetadata,
+ ),
+ performBlobServiceHolderActions(
+ 'remove',
+ input.holdersToRemove,
+ authMetadata,
+ ),
+ ]);
+ return { added, notAdded, removed, notRemoved };
+}
+
+export { processHoldersAction };

File Metadata

Mime Type
text/plain
Expires
Sat, Dec 6, 6:51 PM (16 h, 55 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5840264
Default Alt Text
D13409.1765047110.diff (3 KB)

Event Timeline