Plot 2.0

packages/api-react/src/hooks/useGetTotalHarvestersSummaryQuery.ts

@@ -13,6 +13,7 @@ export default function useGetTotalHarvestersSummaryQuery() {
     let plots = new BigNumber(0);
     let plotsProcessed = new BigNumber(0);
     let totalPlotSize = new BigNumber(0);
+    let totalEffectivePlotSize = new BigNumber(0);
     let plotFilesTotal = new BigNumber(0);
     let initialized = !!data?.length;
     let initializedHarvesters = 0;
@@ -22,6 +23,7 @@ export default function useGetTotalHarvestersSummaryQuery() {
       failedToOpenFilenames = failedToOpenFilenames.plus(harvester.failedToOpenFilenames);
       noKeyFilenames = noKeyFilenames.plus(harvester.noKeyFilenames);
       totalPlotSize = totalPlotSize.plus(harvester.totalPlotSize);
+      totalEffectivePlotSize = totalEffectivePlotSize.plus(harvester.totalEffectivePlotSize);
       plots = plots.plus(harvester.plots);
 
       if (harvester.syncing) {
@@ -45,6 +47,7 @@ export default function useGetTotalHarvestersSummaryQuery() {
       plots,
       plotsProcessed,
       totalPlotSize,
+      totalEffectivePlotSize,
       plotFilesTotal,
       initialized,
       initializedHarvesters,
@@ -63,6 +66,7 @@ export default function useGetTotalHarvestersSummaryQuery() {
     harvesters: data?.length ?? 0,
     plotsProcessed: memoized.plotsProcessed,
     totalPlotSize: memoized.totalPlotSize,
+    totalEffectivePlotSize: memoized.totalEffectivePlotSize,
     plotFilesTotal: memoized.plotFilesTotal,
     initializedHarvesters: memoized.initializedHarvesters,
   };

packages/api-react/src/hooks/useService.ts

@@ -82,6 +82,8 @@ export default function useService(
       }).unwrap();
 
       refetch();
+    } catch (e) {
+      console.error(e);
     } finally {
       setIsStarting(false);
     }
@@ -99,6 +101,8 @@ export default function useService(
       }).unwrap();
 
       refetch();
+    } catch (e) {
+      console.error(e);
     } finally {
       setIsStopping(false);
     }

packages/api-react/src/services/client.ts

@@ -44,7 +44,10 @@ export const clientApi = apiWithTag.injectEndpoints({
     }),
 
     clientStartService: mutation(build, Client, 'startService'),
+
+    clientStopService: mutation(build, Client, 'stopService'),
   }),
 });
 
-export const { useCloseMutation, useGetStateQuery, useClientStartServiceMutation } = clientApi;
+export const { useCloseMutation, useGetStateQuery, useClientStartServiceMutation, useClientStopServiceMutation } =
+  clientApi;

packages/api-react/src/services/daemon.ts

@@ -104,6 +104,7 @@ export const daemonApi = apiWithTag.injectEndpoints({
             installed,
             canInstall,
             bladebitMemoryWarning,
+            cudaSupport,
           } = plotters[plotterName] as PlotterApi;
 
           if (!plotterName.startsWith('bladebit')) {
@@ -123,24 +124,11 @@ export const daemonApi = apiWithTag.injectEndpoints({
 
           // if (plotterName.startsWith('bladebit'))
           const majorVersion = typeof version === 'string' ? +version.split('.')[0] : 0;
-          if (majorVersion > 1) {
-            const bbDisk = PlotterName.BLADEBIT_DISK;
-            availablePlotters[bbDisk] = {
-              displayName,
-              version: `${version} (Disk plot)`,
-              options: optionsForPlotter(bbDisk),
-              defaults: defaultsForPlotter(bbDisk),
-              installInfo: {
-                installed,
-                canInstall,
-                bladebitMemoryWarning,
-              },
-            };
-
+          if (majorVersion <= 1) {
             const bbRam = PlotterName.BLADEBIT_RAM;
             availablePlotters[bbRam] = {
               displayName,
-              version: `${version} (RAM plot)`,
+              version: typeof version === 'string' ? `${version} (RAM plot)` : version,
               options: optionsForPlotter(bbRam),
               defaults: defaultsForPlotter(bbRam),
               installInfo: {
@@ -149,17 +137,45 @@ export const daemonApi = apiWithTag.injectEndpoints({
                 bladebitMemoryWarning,
               },
             };
-          } else {
-            const bbRam = PlotterName.BLADEBIT_RAM;
-            availablePlotters[bbRam] = {
+            return;
+          }
+          const bbDisk = PlotterName.BLADEBIT_DISK;
+          availablePlotters[bbDisk] = {
+            displayName,
+            version: `${version} (Disk plot)`,
+            options: optionsForPlotter(bbDisk),
+            defaults: defaultsForPlotter(bbDisk),
+            installInfo: {
+              installed,
+              canInstall,
+              bladebitMemoryWarning,
+            },
+          };
+
+          const bbRam = PlotterName.BLADEBIT_RAM;
+          availablePlotters[bbRam] = {
+            displayName,
+            version: `${version} (RAM plot)`,
+            options: optionsForPlotter(bbRam),
+            defaults: defaultsForPlotter(bbRam),
+            installInfo: {
+              installed,
+              canInstall,
+              bladebitMemoryWarning,
+            },
+          };
+          if (cudaSupport) {
+            const bbCuda = PlotterName.BLADEBIT_CUDA;
+            availablePlotters[bbCuda] = {
               displayName,
-              version: `${version} (RAM plot)`,
-              options: optionsForPlotter(bbRam),
-              defaults: defaultsForPlotter(bbRam),
+              version: `${version} (CUDA plot)`,
+              options: optionsForPlotter(bbCuda),
+              defaults: defaultsForPlotter(bbCuda),
               installInfo: {
-                installed: false,
-                canInstall: false,
+                installed,
+                canInstall,
                 bladebitMemoryWarning,
+                cudaSupport,
               },
             };
           }
@@ -177,6 +193,8 @@ export const daemonApi = apiWithTag.injectEndpoints({
       transformResponse: (response) => response.version,
       providesTags: [{ type: 'RunningServices', id: 'LIST' }],
     }),
+
+    getKeysForPlotting: query(build, Daemon, 'getKeysForPlotting'),
   }),
 });
 
@@ -192,6 +210,7 @@ export const {
   useMigrateKeyringMutation,
   useUnlockKeyringMutation,
   useGetVersionQuery,
+  useGetKeysForPlottingQuery,
 
   useGetPlottersQuery,
   useStopPlottingMutation,

packages/api-react/src/services/farmer.ts

@@ -20,6 +20,9 @@ export const apiWithTag = api.enhanceEndpoints({
     'HarvestersSummary',
     'HarvesterPlotsKeysMissing',
     'HarvesterPlotsDuplicates',
+    'MissingSignagePoints',
+    'FilterChallengeStat',
+    'partialStats',
   ],
 });
 
@@ -32,7 +35,12 @@ export const farmerApi = apiWithTag.injectEndpoints({
       providesTags: [{ type: 'Harvesters', id: 'LIST' }],
       onCacheEntryAdded: onCacheEntryAddedInvalidate(baseQuery, api, [
         {
-          command: 'onHarvesterChanged',
+          command: 'onHarvesterUpdated',
+          service: Farmer,
+          endpoint: 'getHarvesters',
+        },
+        {
+          command: 'onHarvesterRemoved',
           service: Farmer,
           endpoint: 'getHarvesters',
         },
@@ -231,25 +239,75 @@ export const farmerApi = apiWithTag.injectEndpoints({
               { type: 'Pools', id: 'LIST' },
             ]
           : [{ type: 'Pools', id: 'LIST' }],
+      onCacheEntryAdded: onCacheEntryAddedInvalidate(baseQuery, api, [
+        {
+          command: 'onSubmittedPartial',
+          service: Farmer,
+          endpoint: 'getPoolState',
+        },
+        {
+          command: 'onFailedPartial',
+          service: Farmer,
+          endpoint: 'getPoolState',
+        },
+      ]),
+    }),
+
+    getPartialStatsOffset: query(build, Farmer, 'getPartialStatsOffset', {
+      providesTags: ['partialStats'],
+    }),
+
+    resetPartialStats: mutation(build, Farmer, 'resetPartialStats', {
+      invalidatesTags: ['partialStats'],
     }),
 
     setPayoutInstructions: mutation(build, Farmer, 'setPayoutInstructions', {
       invalidatesTags: (_result, _error, { launcherId }) => [{ type: 'PayoutInstructions', id: launcherId }],
     }),
 
-    getFarmingInfo: query(build, Farmer, 'getFarmingInfo', {
+    getNewFarmingInfo: query(build, Farmer, 'getNewFarmingInfo', {
+      onCacheEntryAdded: onCacheEntryAddedInvalidate(baseQuery, api, [
+        {
+          command: 'onFarmingInfoChanged',
+          service: Farmer,
+          endpoint: 'getNewFarmingInfo',
+        },
+      ]),
+    }),
+
+    getMissingSignagePoints: query(build, Farmer, 'getMissingSignagePoints', {
+      providesTags: ['MissingSignagePoints'],
+      onCacheEntryAdded: onCacheEntryAddedInvalidate(baseQuery, api, [
+        {
+          command: 'onNewSignagePoint',
+          service: Farmer,
+          endpoint: 'getMissingSignagePoints',
+        },
+      ]),
+    }),
+
+    resetMissingSignagePoints: mutation(build, Farmer, 'resetMissingSignagePoints', {
+      invalidatesTags: ['MissingSignagePoints'],
+    }),
+
+    getFilterChallengeStat: query(build, Farmer, 'getFilterChallengeStat', {
+      providesTags: ['FilterChallengeStat'],
       onCacheEntryAdded: onCacheEntryAddedInvalidate(baseQuery, api, [
         {
           command: 'onFarmingInfoChanged',
           service: Farmer,
-          endpoint: 'getFarmingInfo',
+          endpoint: 'getFilterChallengeStat',
         },
       ]),
     }),
+
+    resetFilterChallengeStat: mutation(build, Farmer, 'resetFilterChallengeStat', {
+      invalidatesTags: ['FilterChallengeStat'],
+    }),
   }),
 });
 
-// TODO add new farming info query and event for last_attepmtp_proofs
+// TODO add new farming info query and event for last_attempt_proofs
 
 export const {
   useFarmerPingQuery,
@@ -268,5 +326,11 @@ export const {
   useGetSignagePointsQuery,
   useGetPoolStateQuery,
   useSetPayoutInstructionsMutation,
-  useGetFarmingInfoQuery,
+  useGetNewFarmingInfoQuery,
+  useGetMissingSignagePointsQuery,
+  useResetMissingSignagePointsMutation,
+  useGetFilterChallengeStatQuery,
+  useResetFilterChallengeStatMutation,
+  useGetPartialStatsOffsetQuery,
+  useResetPartialStatsMutation,
 } = farmerApi;

packages/api-react/src/services/harvester.ts

@@ -1,10 +1,12 @@
 import { Harvester } from '@chia-network/api';
 
+import api, { baseQuery } from '../api';
+import onCacheEntryAddedInvalidate from '../utils/onCacheEntryAddedInvalidate';
 import { query, mutation } from '../utils/reduxToolkitEndpointAbstractions';
 import { apiWithTag } from './farmer';
 
 const apiWithTag2 = apiWithTag.enhanceEndpoints({
-  addTagTypes: ['Plots', 'PlotDirectories'],
+  addTagTypes: ['Plots', 'PlotDirectories', 'harvesterConfig'],
 });
 
 export const harvesterApi = apiWithTag2.injectEndpoints({
@@ -71,6 +73,24 @@ export const harvesterApi = apiWithTag2.injectEndpoints({
         { type: 'PlotDirectories', id: dirname },
       ],
     }),
+
+    getHarvesterConfig: query(build, Harvester, 'getHarvesterConfig', {
+      providesTags: ['harvesterConfig'],
+    }),
+
+    updateHarvesterConfig: mutation(build, Harvester, 'updateHarvesterConfig', {
+      invalidatesTags: ['harvesterConfig'],
+    }),
+
+    getFarmingInfo: query(build, Harvester, 'getFarmingInfo', {
+      onCacheEntryAdded: onCacheEntryAddedInvalidate(baseQuery, api, [
+        {
+          command: 'onFarmingInfoChanged',
+          service: Harvester,
+          endpoint: 'getFarmingInfo',
+        },
+      ]),
+    }),
   }),
 });
 
@@ -81,4 +101,7 @@ export const {
   useGetPlotDirectoriesQuery,
   useAddPlotDirectoryMutation,
   useRemovePlotDirectoryMutation,
+  useGetFarmingInfoQuery,
+  useGetHarvesterConfigQuery,
+  useUpdateHarvesterConfigMutation,
 } = harvesterApi;