fix: use StorageManager for upload (#262)

* use StorageManager for upload

* mock StorageManager.upload

* fix: use existing context

* deps: update synapse-sdk

---------

Co-authored-by: Russell Dempsey <1173416+SgtPooki@users.noreply.github.com>

Author: wjmelements

package.json

@@ -103,7 +103,8 @@
   "homepage": "https://github.com/filecoin-project/filecoin-pin#readme",
   "dependencies": {
     "@clack/prompts": "^0.11.0",
-    "@filoz/synapse-sdk": "^0.35.3",
+    "@filoz/synapse-core": "^0.1.3",
+    "@filoz/synapse-sdk": "^0.36.0",
     "@helia/unixfs": "^6.0.1",
     "@ipld/car": "^5.4.2",
     "commander": "^14.0.1",

src/core/data-set/get-data-set-pieces.ts

@@ -6,8 +6,8 @@
  * @module core/data-set/get-data-set-pieces
  */
 
+import { getSizeFromPieceCID } from '@filoz/synapse-core/piece'
 import { METADATA_KEYS, type StorageContext, type Synapse, WarmStorageService } from '@filoz/synapse-sdk'
-import { getSizeFromPieceCID } from '@filoz/synapse-sdk/piece'
 import { isStorageContextWithDataSetId } from './type-guards.js'
 import type {
   DataSetPiecesResult,

src/core/upload/synapse.ts

@@ -4,7 +4,7 @@
  * This module provides a reusable upload pattern for CAR files to Filecoin
  * via Synapse SDK, used by both the import command and pinning server.
  */
-import type { PieceCID, UploadOptions } from '@filoz/synapse-sdk'
+import type { PieceCID } from '@filoz/synapse-sdk'
 import { METADATA_KEYS, type ProviderInfo, type UploadCallbacks } from '@filoz/synapse-sdk'
 import type { CID } from 'multiformats/cid'
 import type { Logger } from 'pino'
@@ -129,15 +129,16 @@ export async function uploadToSynapse(
   }
 
   // Upload using Synapse with IPFS root CID metadata
-  const uploadOptions: UploadOptions = {
+  const uploadOptions: Parameters<typeof synapseService.synapse.storage.upload>[1] = {
     ...uploadCallbacks,
     metadata: {
       ...(options.pieceMetadata ?? {}),
       [METADATA_KEYS.IPFS_ROOT_CID]: rootCid.toString(), // Associate piece with IPFS root CID
     },
+    context: synapseService.storage,
   }
 
-  const synapseResult = await synapseService.storage.upload(carData, uploadOptions)
+  const synapseResult = await synapseService.synapse.storage.upload(carData, uploadOptions)
 
   // Log success
   logger.info(

src/test/mocks/synapse-mocks.ts

@@ -98,6 +98,7 @@ export class MockSynapse extends EventEmitter {
   // Storage namespace matches SDK structure
   public readonly storage = {
     createContext: this.createStorageContext.bind(this),
+    upload: (data: any, options: any) => this._storageContext?.upload(data, options),
   }
 
   /**

src/test/unit/core-data-set.test.ts

@@ -85,7 +85,7 @@ vi.mock('@filoz/synapse-sdk', async () => {
 })
 
 // Mock piece size calculation
-vi.mock('@filoz/synapse-sdk/piece', () => ({
+vi.mock('@filoz/synapse-core/piece', () => ({
   getSizeFromPieceCID: vi.fn((cid: { toString: () => string } | string) => {
     // Map specific CIDs to sizes for testing
     const cidString = typeof cid === 'string' ? cid : cid.toString()
@@ -97,11 +97,11 @@ vi.mock('@filoz/synapse-sdk/piece', () => ({
 }))
 vi.mock('@filoz/synapse-sdk/sp-registry', () => {
   return {
-    SPRegistryService: vi.fn().mockImplementation(function () {
-      return {
-        getProviders: mockGetProviders,
+    SPRegistryService: class {
+      async getProviders(providerIds: number[]) {
+        return mockGetProviders(providerIds)
       }
-    }),
+    },
   }
 })
 

src/test/unit/data-set.test.ts

@@ -160,7 +160,7 @@ vi.mock('@filoz/synapse-sdk', async () => {
 })
 
 // Mock piece size calculation
-vi.mock('@filoz/synapse-sdk/piece', () => ({
+vi.mock('@filoz/synapse-core/piece', () => ({
   getSizeFromPieceCID: vi.fn(() => {
     // Return a realistic piece size (1 MiB = 1048576 bytes)
     return 1048576