Method upsert

packages/server/src/inspector.rs:458–475

(&self, process_identifier: i64, info: Value)

    }

    async fn upsert(&self, process_identifier: i64, info: Value) -> io::Result<()> {
        let _lock = RegistryFileLock::acquire(&self.path)?;
        let mut registry = read_registry_file(&self.path);
        prune_registry_file(&mut registry);
        registry.inspectors.retain(|entry| {
            !(entry.process_identifier == process_identifier && entry.service_id == self.service_id)
        });
        registry.inspectors.push(PublishedInspector {
            access_token: self.access_token.clone(),
            available_sources: inspector_available_sources(&info),
            service_id: self.service_id.clone(),
            info,
            process_identifier,
            server_url: self.server_url.clone(),
            updated_at_unix_ms: now_unix_ms(),
        });
        write_registry_file(&self.path, &registry)
    }

    async fn remove(&self, process_identifier: i64) -> io::Result<()> {
        let _lock = RegistryFileLock::acquire(&self.path)?;