Feature/output_in_initializeCompute (#2056)

* remove initializeComputeV1

* add output option for InitializeCompute

Author: alexcos20

src/services/Provider.ts

@@ -443,78 +443,6 @@ export class Provider {
     throw new Error(JSON.stringify(resolvedResponse))
   }
 
-  /** Initializes the provider for a compute request.
-   * @param {ComputeAsset[]} assets The datasets array to initialize compute request.
-   * @param {ComputeAlgorithmber} algorithm The algorithm to use.
-   * @param {string} computeEnv The compute environment.
-   * @param {string} providerUri The provider URI.
-   * @param {string} accountId caller address
-   * @param {string} chainId The chain Id to start compute on
-   * @param {string} token The token to use for the compute payment
-   * @param {number} maxJobDuration The maximum duration the job can take
-   * @param {AbortSignal} signal abort signal
-   * @return {Promise<ProviderComputeInitialize>} ProviderComputeInitialize data
-   */
-  public async initializeComputeV1(
-    assets: ComputeAsset[],
-    algorithm: ComputeAlgorithm,
-    computeEnv: string,
-    providerUri: string,
-    accountId: string,
-    chainId: number,
-    token: string,
-    maxJobDuration: number,
-    signal?: AbortSignal
-  ): Promise<ProviderComputeInitializeResults> {
-    const providerEndpoints = await this.getEndpoints(providerUri)
-    const serviceEndpoints = await this.getServiceEndpoints(
-      providerUri,
-      providerEndpoints
-    )
-    const payment: ComputePayment = {
-      chainId,
-      token,
-      maxJobDuration
-    }
-    const payload: Object = {
-      datasets: assets,
-      algorithm,
-      payment,
-      consumerAddress: accountId,
-      environment: computeEnv
-    }
-    const initializeUrl = this.getEndpointURL(serviceEndpoints, 'initializeCompute')
-      ? this.getEndpointURL(serviceEndpoints, 'initializeCompute').urlPath
-      : null
-    if (!initializeUrl) return null
-    let response
-    try {
-      response = await fetch(initializeUrl, {
-        method: 'POST',
-        body: JSON.stringify(payload),
-        headers: { 'Content-Type': 'application/json' },
-        signal
-      })
-    } catch (e) {
-      LoggerInstance.error('Initialize compute failed: ')
-      LoggerInstance.error(e)
-      throw new Error('ComputeJob cannot be initialized')
-    }
-    if (response?.ok) {
-      const params = await response.json()
-      return params
-    }
-    const resolvedResponse = await response.json()
-    LoggerInstance.error(
-      'Initialize compute failed: ',
-      response.status,
-      response.statusText,
-      resolvedResponse
-    )
-    LoggerInstance.error('Payload was:', JSON.stringify(payload))
-    throw new Error(JSON.stringify(resolvedResponse))
-  }
-
   /** Initializes the provider for a compute request.
    * @param {ComputeAsset[]} assets The datasets array to initialize compute request.
    * @param {ComputeAlgorithmber} algorithm The algorithm to use.
@@ -527,6 +455,7 @@ export class Provider {
    * @param {number} chainId The chain used to do payments
    * @param {any} policyServer Policy server data.
    * @param {AbortSignal} signal abort signal
+   * @param {ComputeOutput} output The compute job output settings.
    * @param {dockerRegistryAuth} dockerRegistryAuth Docker registry authentication data.
    * @return {Promise<ProviderComputeInitialize>} ProviderComputeInitialize data
    */
@@ -542,6 +471,7 @@ export class Provider {
     chainId: number,
     policyServer?: any,
     signal?: AbortSignal,
+    output?: ComputeOutput,
     dockerRegistryAuth?: dockerRegistryAuth
   ): Promise<ProviderComputeInitializeResults> {
     const providerEndpoints = await this.getEndpoints(providerUri)
@@ -601,7 +531,12 @@ export class Provider {
     }
 
     if (policyServer) providerData.policyServer = policyServer
-
+    if (output) {
+      const nodeKey = await this.getNodePublicKey(providerUri)
+      if (nodeKey) {
+        providerData.output = eciesencrypt(nodeKey, JSON.stringify(output))
+      }
+    }
     let response
     try {
       console.log('Initialize compute url:', initializeUrl)