wit apis

.gitignore

@@ -10,8 +10,6 @@ wit/
 *.swo
 *.zip
 /home
-packages/**/pkg/*.wasm
-packages/**/wit
 */**/node_modules
 .env
 kinode/src/bootstrapped_processes.rs

kinode/Cargo.toml

@@ -14,7 +14,7 @@ path = "src/main.rs"
 
 [build-dependencies]
 anyhow = "1.0.71"
-kit = { git = "https://github.com/kinode-dao/kit", rev = "25b474a" }
+kit = { git = "https://github.com/kinode-dao/kit", rev = "9ad80d2" }
 rayon = "1.8.1"
 sha2 = "0.10"
 tokio = "1.28"

kinode/build.rs

@@ -59,7 +59,7 @@ fn build_and_zip_package(
 ) -> anyhow::Result<(String, String, Vec<u8>)> {
     let rt = tokio::runtime::Runtime::new().unwrap();
     rt.block_on(async {
-        kit::build::execute(&entry_path, true, false, true, features)
+        kit::build::execute(&entry_path, true, false, true, features, None, None) // TODO
             .await
             .map_err(|e| anyhow::anyhow!("{:?}", e))?;
 

kinode/packages/app_store/app_store/src/api.rs

@@ -17,6 +17,14 @@ pub enum RemoteRequest {
         package_id: PackageId,
         desired_version_hash: Option<String>,
     },
+    /// Request a package API from another node who we expect to
+    /// be mirroring it. If the remote node is mirroring the package,
+    /// they must respond with RemoteResponse::DownloadApproved,
+    /// at which point requester can expect an FTWorkerRequest::Receive.
+    DownloadApi {
+        package_id: PackageId,
+        desired_version_hash: String,
+    },
 }
 
 /// The response expected from sending a [`RemoteRequest`].
@@ -45,6 +53,7 @@ pub enum LocalRequest {
     /// This is used for locally installing a package.
     NewPackage {
         package: PackageId,
+        metadata: kernel_types::Erc721Metadata,
         /// Sets whether we will mirror this package for others
         mirror: bool,
     },
@@ -93,6 +102,10 @@ pub enum LocalRequest {
     /// This is an expensive operation! Throw away our state and rebuild from scratch.
     /// Re-index the locally downloaded/installed packages AND the onchain data.
     RebuildIndex,
+    /// List all apps we have APIs for.
+    ListApis,
+    /// Return the given API, if we have it.
+    GetApi(PackageId),
 }
 
 /// Local responses take this form.
@@ -107,6 +120,8 @@ pub enum LocalResponse {
     MirrorResponse(MirrorResponse),
     AutoUpdateResponse(AutoUpdateResponse),
     RebuiltIndex,
+    ListApisResponse { apis: Vec<PackageId> },
+    GetApiResponse(GetApiResponse), // API in blob (or None)
 }
 
 // TODO for all: expand these to elucidate why something failed
@@ -147,3 +162,9 @@ pub enum AutoUpdateResponse {
     Success,
     Failure,
 }
+
+#[derive(Debug, Serialize, Deserialize)]
+pub enum GetApiResponse {
+    Success,
+    Failure,
+}

kinode/packages/app_store/app_store/src/http_api.rs

@@ -30,10 +30,18 @@ pub fn handle_http_request(
     our: &Address,
     state: &mut State,
     eth_provider: &eth::Provider,
+    requested_apis: &mut HashMap<PackageId, RequestedPackage>,
     requested_packages: &mut HashMap<PackageId, RequestedPackage>,
     req: &IncomingHttpRequest,
 ) -> anyhow::Result<()> {
-    match serve_paths(our, state, eth_provider, requested_packages, req) {
+    match serve_paths(
+        our,
+        state,
+        eth_provider,
+        requested_apis,
+        requested_packages,
+        req,
+    ) {
         Ok((status_code, _headers, body)) => send_response(
             status_code,
             Some(HashMap::from([(
@@ -102,6 +110,7 @@ fn serve_paths(
     our: &Address,
     state: &mut State,
     eth_provider: &eth::Provider,
+    requested_apis: &mut HashMap<PackageId, RequestedPackage>,
     requested_packages: &mut HashMap<PackageId, RequestedPackage>,
     req: &IncomingHttpRequest,
 ) -> anyhow::Result<(StatusCode, Option<HashMap<String, String>>, Vec<u8>)> {
@@ -432,7 +441,7 @@ fn serve_paths(
                     format!("Invalid method {method} for {bound_path}").into_bytes(),
                 ));
             }
-            crate::rebuild_index(our, state, eth_provider);
+            crate::rebuild_index(our, state, eth_provider, requested_apis);
             Ok((StatusCode::OK, None, vec![]))
         }
         _ => Ok((