async fn update(

    commodity: Commodity,

    tags: Arc<Mutex<HashMap<String, String>>>,

    script: &[u8],

) -> Result<Commodity, HookError> {

    let engine = Engine::default();

    let mut linker = Linker::new(&engine);

    let mut builder = CommodityBuilder::new();

    builder.id(commodity.id);

    let store_data = Arc::new(DataStore {

        data: Mutex::new((builder, tags.clone())),

        memory: Mutex::new(None),

    });

    let mut store = Store::new(&engine, store_data.clone());

    let module = Module::new(store.engine(), script).map_err(|e| {

    let get_tag_list = wrap_wasm_str_list_get(&mut store, |data| {

        let tags = data

            .1

            .lock()

            .map_err(|_| anyhow::anyhow!("Failed to lock tags"))?;

        tracing::info!("{:?}", tags.keys().cloned());

        Ok(tags.keys().cloned().collect())

    });

    linker.define(&store, "env", "get_tag_list", get_tag_list)?;

    let update_tag = wrap_wasm_str_map(&mut store, |data, key, value| {

        let mut tags = data

            .1

            .lock()

            .map_err(|_| anyhow::anyhow!("Failed to lock tags"))?;

        tracing::info!("Inserting {key:?} {value:?}");

        tags.insert(key, value);

        Ok(())

    });

    linker.define(&store, "env", "update_tag", update_tag)?;

    let get_tag = wrap_wasm_str_transform(&mut store, |data, key| {

        let tags = data

            .1

            .lock()

            .map_err(|_| anyhow::anyhow!("Failed to lock tags HashMap"))?;

        tracing::info!("Found value: {:?}", tags.get(&key).cloned());

        tags.get(&key)

            .cloned()

            .ok_or_else(|| anyhow::anyhow!("Key not found in tags: {key}"))

    });

    linker.define(&store, "env", "get_tag", get_tag)?;

    let instance = linker.instantiate(&mut store, &module)?;

    if let Some(memory) = instance.get_memory(&mut store, "memory") {

        store_data.memory.lock()?.replace(memory);

    let process = instance.get_typed_func::<(), ()>(&mut store, "process")?;

    process.call(&mut store, ())?;

    tracing::info!("{:?}", store_data.clone().data.lock()?.1);

    let result = store_data.clone().data.lock()?.0.build()?;

    Ok(result)

}

pub async fn apply_commodity_hook(

    commodity: Commodity,

    tags: Arc<Mutex<HashMap<String, String>>>,

    hook: &[u8],

) -> Result<Commodity, HookError> {

    let updated = update(commodity, tags, hook).await?;

    Ok(updated)

}