Add ibc_source_chain_callback entrypoint

Author: chipshort

internal/api/bindings.h

@@ -597,6 +597,18 @@ struct UnmanagedVector ibc_packet_timeout(struct cache_t *cache,
                                           struct GasReport *gas_report,
                                           struct UnmanagedVector *error_msg);
 
+struct UnmanagedVector ibc_source_chain_callback(struct cache_t *cache,
+                                                 struct ByteSliceView checksum,
+                                                 struct ByteSliceView env,
+                                                 struct ByteSliceView msg,
+                                                 struct Db db,
+                                                 struct GoApi api,
+                                                 struct GoQuerier querier,
+                                                 uint64_t gas_limit,
+                                                 bool print_debug,
+                                                 struct GasReport *gas_report,
+                                                 struct UnmanagedVector *error_msg);
+
 struct UnmanagedVector new_unmanaged_vector(bool nil, const uint8_t *ptr, uintptr_t length);
 
 void destroy_unmanaged_vector(struct UnmanagedVector v);

internal/api/lib.go

@@ -700,6 +700,48 @@ func IBCPacketTimeout(
 	return copyAndDestroyUnmanagedVector(res), convertGasReport(gasReport), nil
 }
 
+func IBCSourceChainCallback(
+	cache Cache,
+	checksum []byte,
+	env []byte,
+	msg []byte,
+	gasMeter *types.GasMeter,
+	store types.KVStore,
+	api *types.GoAPI,
+	querier *Querier,
+	gasLimit uint64,
+	printDebug bool,
+) ([]byte, types.GasReport, error) {
+	cs := makeView(checksum)
+	defer runtime.KeepAlive(checksum)
+	e := makeView(env)
+	defer runtime.KeepAlive(env)
+	ac := makeView(msg)
+	defer runtime.KeepAlive(msg)
+	var pinner runtime.Pinner
+	pinner.Pin(gasMeter)
+	checkAndPinAPI(api, pinner)
+	checkAndPinQuerier(querier, pinner)
+	defer pinner.Unpin()
+
+	callID := startCall()
+	defer endCall(callID)
+
+	dbState := buildDBState(store, callID)
+	db := buildDB(&dbState, gasMeter)
+	a := buildAPI(api)
+	q := buildQuerier(querier)
+	var gasReport C.GasReport
+	errmsg := uninitializedUnmanagedVector()
+
+	res, err := C.ibc_source_chain_callback(cache.ptr, cs, e, ac, db, a, q, cu64(gasLimit), cbool(printDebug), &gasReport, &errmsg)
+	if err != nil && err.(syscall.Errno) != C.ErrnoValue_Success {
+		// Depending on the nature of the error, `gasUsed` will either have a meaningful value, or just 0.
+		return nil, convertGasReport(gasReport), errorWithMessage(err, errmsg)
+	}
+	return copyAndDestroyUnmanagedVector(res), convertGasReport(gasReport), nil
+}
+
 func convertGasReport(report C.GasReport) types.GasReport {
 	return types.GasReport{
 		Limit:          uint64(report.limit),

lib_libwasmvm.go

@@ -532,6 +532,41 @@ func (vm *VM) IBCPacketTimeout(
 	return &result, gasReport.UsedInternally, nil
 }
 
+// IBCSourceChainCallback is available on IBC-enabled contracts with and is called when an
+// the response for an outgoing packet (previously sent by this contract)
+// is received
+func (vm *VM) IBCSourceChainCallback(
+	checksum Checksum,
+	env types.Env,
+	msg types.IBCSourceChainCallbackMsg,
+	store KVStore,
+	goapi GoAPI,
+	querier Querier,
+	gasMeter GasMeter,
+	gasLimit uint64,
+	deserCost types.UFraction,
+) (*types.IBCBasicResult, uint64, error) {
+	envBin, err := json.Marshal(env)
+	if err != nil {
+		return nil, 0, err
+	}
+	msgBin, err := json.Marshal(msg)
+	if err != nil {
+		return nil, 0, err
+	}
+	data, gasReport, err := api.IBCSourceChainCallback(vm.cache, checksum, envBin, msgBin, &gasMeter, store, &goapi, &querier, gasLimit, vm.printDebug)
+	if err != nil {
+		return nil, gasReport.UsedInternally, err
+	}
+
+	var result types.IBCBasicResult
+	err = DeserializeResponse(gasLimit, deserCost, &gasReport, data, &result)
+	if err != nil {
+		return nil, gasReport.UsedInternally, err
+	}
+	return &result, gasReport.UsedInternally, nil
+}
+
 func compileCost(code WasmCode) uint64 {
 	// CostPerByte is how much CosmWasm gas is charged *per byte* for compiling WASM code.
 	// Benchmarks and numbers (in SDK Gas) were discussed in:

libwasmvm/bindings.h

@@ -597,6 +597,18 @@ struct UnmanagedVector ibc_packet_timeout(struct cache_t *cache,
                                           struct GasReport *gas_report,
                                           struct UnmanagedVector *error_msg);
 
+struct UnmanagedVector ibc_source_chain_callback(struct cache_t *cache,
+                                                 struct ByteSliceView checksum,
+                                                 struct ByteSliceView env,
+                                                 struct ByteSliceView msg,
+                                                 struct Db db,
+                                                 struct GoApi api,
+                                                 struct GoQuerier querier,
+                                                 uint64_t gas_limit,
+                                                 bool print_debug,
+                                                 struct GasReport *gas_report,
+                                                 struct UnmanagedVector *error_msg);
+
 struct UnmanagedVector new_unmanaged_vector(bool nil, const uint8_t *ptr, uintptr_t length);
 
 void destroy_unmanaged_vector(struct UnmanagedVector v);

libwasmvm/src/calls.rs

@@ -9,8 +9,9 @@ use cosmwasm_std::Checksum;
 use cosmwasm_vm::{
     call_execute_raw, call_ibc_channel_close_raw, call_ibc_channel_connect_raw,
     call_ibc_channel_open_raw, call_ibc_packet_ack_raw, call_ibc_packet_receive_raw,
-    call_ibc_packet_timeout_raw, call_instantiate_raw, call_migrate_raw, call_query_raw,
-    call_reply_raw, call_sudo_raw, Backend, Cache, Instance, InstanceOptions, VmResult,
+    call_ibc_packet_timeout_raw, call_ibc_source_chain_callback_raw, call_instantiate_raw,
+    call_migrate_raw, call_query_raw, call_reply_raw, call_sudo_raw, Backend, Cache, Instance,
+    InstanceOptions, VmResult,
 };
 
 use crate::api::GoApi;
@@ -395,6 +396,36 @@ pub extern "C" fn ibc_packet_timeout(
     )
 }
 
+#[no_mangle]
+pub extern "C" fn ibc_source_chain_callback(
+    cache: *mut cache_t,
+    checksum: ByteSliceView,
+    env: ByteSliceView,
+    msg: ByteSliceView,
+    db: Db,
+    api: GoApi,
+    querier: GoQuerier,
+    gas_limit: u64,
+    print_debug: bool,
+    gas_report: Option<&mut GasReport>,
+    error_msg: Option<&mut UnmanagedVector>,
+) -> UnmanagedVector {
+    call_2_args(
+        call_ibc_source_chain_callback_raw,
+        cache,
+        checksum,
+        env,
+        msg,
+        db,
+        api,
+        querier,
+        gas_limit,
+        print_debug,
+        gas_report,
+        error_msg,
+    )
+}
+
 type VmFn2Args = fn(
     instance: &mut Instance<GoApi, GoStorage, GoQuerier>,
     arg1: &[u8],