feat: renterd multipart upload hooks

.changeset/two-ducks-act.md

@@ -0,0 +1,5 @@
+---
+'@siafoundation/react-renterd': minor
+---
+
+Add useMultipartUploadCreate, useMultipartUploadComplete, useMultipartUploadAbort, useMultipartUploadAddPart, useMultipartUploadChunk, useMultipartUploadListUploads, useMultipartUploadListParts.

libs/react-renterd/src/bus.ts

@@ -29,7 +29,9 @@ import {
   Host,
   HostSettings,
   Obj,
+  PartialSlab,
   SiacoinElement,
+  SlabSlice,
   WalletTransaction,
 } from './siaTypes'
 
@@ -838,3 +840,158 @@ export function useMetricsWallet(
 //   hostKey: string
 //   origin: string
 // }
+
+// multipart
+
+export type MultipartUploadCreatePayload = {
+  path: string
+  bucket: string
+  key?: string /// defaults to key:0000000000000000000000000000000000000000000000000000000000000000
+}
+
+export function useMultipartUploadCreate(
+  args?: HookArgsCallback<
+    void,
+    MultipartUploadCreatePayload,
+    { uploadID: string }
+  >
+) {
+  return usePostFunc(
+    { ...args, route: '/bus/multipart/create' },
+    async (mutate) => {
+      mutate((key) => {
+        return key.startsWith('/bus/multipart')
+      })
+    }
+  )
+}
+
+export type MultipartUploadCompletePart = {
+  partNumber: number
+  eTag: string
+}
+
+export type MultipartUploadCompletePayload = {
+  path: string
+  bucket: string
+  uploadID: string
+  parts: MultipartUploadCompletePart[]
+}
+
+export function useMultipartUploadComplete(
+  args?: HookArgsCallback<void, MultipartUploadCompletePayload, void>
+) {
+  return usePostFunc(
+    { ...args, route: '/bus/multipart/complete' },
+    async (mutate) => {
+      mutate((key) => {
+        return key.startsWith('/bus/multipart')
+      })
+    }
+  )
+}
+
+export type MultipartUploadAbortPayload = {
+  path: string
+  bucket: string
+  uploadID: string
+}
+
+export function useMultipartUploadAbort(
+  args?: HookArgsCallback<void, MultipartUploadAbortPayload, void>
+) {
+  return usePostFunc(
+    { ...args, route: '/bus/multipart/abort' },
+    async (mutate) => {
+      mutate((key) => {
+        return key.startsWith('/bus/multipart')
+      })
+    }
+  )
+}
+
+export type MultipartUploadListPartsPayload = {
+  bucket: string
+  path: string
+  uploadID: string
+  partNumberMarker: number
+  limit: number
+}
+
+export type MultipartUploadListPartsResponse = {
+  hasMore: boolean
+  nextMarker?: number
+  parts: {
+    partNumber: number
+    lastModified: string
+    eTag: string
+    size: number
+  }[]
+}
+
+export function useMultipartUploadListParts(
+  args?: HookArgsWithPayloadSwr<
+    void,
+    MultipartUploadListPartsPayload,
+    MultipartUploadListPartsResponse
+  >
+) {
+  return usePostSwr({
+    ...args,
+    route: '/bus/multipart/listparts',
+  })
+}
+
+export type MultipartUploadListUploadsPayload = {
+  bucket: string
+  prefix: string
+  pathMarker?: string
+  uploadIDMarker?: string
+  limit: number
+}
+
+export type MultipartUploadListUploadsResponse = {
+  uploads: {
+    path: string
+    uploadID: string
+    createdAt: string
+  }[]
+}
+
+export function useMultipartUploadListUploads(
+  args?: HookArgsWithPayloadSwr<
+    void,
+    MultipartUploadListUploadsPayload,
+    MultipartUploadListUploadsResponse
+  >
+) {
+  return usePostSwr({
+    ...args,
+    route: '/bus/multipart/listuploads',
+  })
+}
+
+export type MultipartUploadAddPartPayload = {
+  path: string
+  bucket: string
+  uploadID: string
+  eTag: string
+  partNumber: number
+  contractSet?: string
+  partialSlabs?: PartialSlab[]
+  slices?: SlabSlice[]
+  usedContracts?: Contract[]
+}
+
+export function useMultipartUploadAddPart(
+  args?: HookArgsCallback<void, MultipartUploadAddPartPayload, void>
+) {
+  return usePostFunc(
+    { ...args, route: '/bus/multipart/part' },
+    async (mutate) => {
+      mutate((key) => {
+        return key.startsWith('/bus/multipart/listparts')
+      })
+    }
+  )
+}

libs/react-renterd/src/siaTypes.ts

@@ -87,6 +87,12 @@ export type Sector = {
   root: string
 }
 
+export type PartialSlab = {
+  key: EncryptionKey
+  offset: number
+  length: number
+}
+
 export type Slab = {
   health: number
   key: EncryptionKey

libs/react-renterd/src/worker.ts

@@ -55,6 +55,36 @@ export function useObjectUpload(
   )
 }
 
+export type MultipartUploadChunkParams = {
+  key: string
+  bucket?: string
+  contractset?: string
+  uploadid: string
+  partnumber: number
+  minshards?: number
+  totalshards?: number
+  offset?: number
+  disablepreshardingencryption?: boolean
+}
+
+export function useMultipartUploadChunk(
+  args?: HookArgsCallback<MultipartUploadChunkParams, Blob, void>
+) {
+  return usePutFunc({
+    ...args,
+    config: {
+      ...args?.config,
+      axios: {
+        ...args?.config?.axios,
+        headers: {
+          'Content-Type': 'multipart/form-data',
+        },
+      },
+    },
+    route: '/worker/multipart/:key',
+  })
+}
+
 export type RhpScanRequest = {
   hostKey: string
   hostIP: string